2 Copyright © 1995-2011, The AROS Development Team. All rights reserved.
5 Desc: Exec utility functions.
9 #include <aros/debug.h>
10 #include <exec/lists.h>
11 #include <exec/tasks.h>
12 #include <exec/memory.h>
13 #include <exec/execbase.h>
14 #include <dos/dosextens.h>
16 #include <proto/exec.h>
19 #include "exec_intern.h"
20 #include "exec_util.h"
21 #include "taskstorage.h"
23 /*i***************************************************************************
26 #include "exec_util.h"
28 struct ETask
* Exec_FindChild(
32 struct ExecBase
*SysBase
)
35 Scan through the current tasks children list searching for the task
36 whose et_UniqueID field matches.
39 id - The task ID to match.
42 Address of the ETask structure that matches, or
46 This is an internal exec.library function not exported from the
57 ******************************************************************************/
62 thisET
= GetETask(FindTask(NULL
));
65 ForeachNode (&thisET
->et_Children
, et
)
67 if (et
->et_UniqueID
== id
)
70 ForeachNode(&thisET
->et_TaskMsgPort
.mp_MsgList
, et
)
72 if (et
->et_UniqueID
== id
)
80 Exec_InitETask(struct Task
*task
, struct ExecBase
*SysBase
)
82 struct Task
*thistask
= FindTask(NULL
);
84 * We don't add this to the task memory, it isn't free'd by
85 * RemTask(), rather by somebody else calling ChildFree().
86 * Alternatively, an orphaned task will free its own ETask.
89 AllocMem(sizeof(struct IntETask
), MEMF_PUBLIC
| MEMF_CLEAR
);
90 D(bug("[TSS] Create new ETask=%p for task=%p with size %d\n",
91 et
, task
, sizeof(struct IntETask
)));
93 task
->tc_UnionETask
.tc_ETask
= et
;
96 task
->tc_Flags
|= TF_ETASK
;
100 /* Clone parent's TaskStorage */
101 struct ETask
*thiset
= GetETask(thistask
);
103 IPTR
*thists
= thiset
->et_TaskStorage
;
106 IPTR
*ts
= AllocMem(thists
[__TS_FIRSTSLOT
] * sizeof(thists
[0]), MEMF_ANY
);
108 FreeMem(et
, sizeof(struct IntETask
));
111 CopyMem(thists
, ts
, thists
[__TS_FIRSTSLOT
] * sizeof(thists
[0]));
112 et
->et_TaskStorage
= ts
;
117 et
->et_Parent
= thistask
;
118 NEWLIST(&et
->et_Children
);
120 /* Initialise the message list */
121 InitMsgPort(&et
->et_TaskMsgPort
);
122 et
->et_TaskMsgPort
.mp_SigTask
= task
;
123 et
->et_TaskMsgPort
.mp_SigBit
= SIGB_CHILD
;
125 /* Initialise the trap fields */
126 et
->et_TrapAlloc
= SysBase
->TaskTrapAlloc
;
131 int len
= strlen(task
->tc_Node
.ln_Name
) + 1;
132 IntETask(et
)->iet_Me
= AllocVec(len
, MEMF_CLEAR
|MEMF_PUBLIC
);
133 if (IntETask(et
)->iet_Me
!= NULL
)
134 CopyMem(task
->tc_Node
.ln_Name
, IntETask(et
)->iet_Me
, len
);
138 /* Get a unique identifier for this task */
140 while(et
->et_UniqueID
== 0)
143 * Add some fuzz on wrapping. It's likely that the early numbers
144 * where taken by somebody else.
146 if(++SysBase
->ex_TaskID
== 0)
147 SysBase
->ex_TaskID
= 1024;
150 if (FindTaskByPID(SysBase
->ex_TaskID
) == NULL
)
151 et
->et_UniqueID
= SysBase
->ex_TaskID
;
156 /* Finally if the parent task is an ETask, add myself as its child */
157 if(et
->et_Parent
&& ((struct Task
*) et
->et_Parent
)->tc_Flags
& TF_ETASK
)
160 ADDHEAD(&GetETask(et
->et_Parent
)->et_Children
, et
);
168 Exec_CleanupETask(struct Task
*task
, struct ExecBase
*SysBase
)
170 struct ETask
*et
= NULL
, *child
, *nextchild
, *parent
;
171 struct Node
*tmpNode
;
174 if(task
->tc_Flags
& TF_ETASK
)
175 et
= task
->tc_UnionETask
.tc_ETask
;
179 D(bug("CleanupETask: task=%x, et=%x\n", task
, et
));
183 /* Clean up after all the children that the task didn't do itself. */
184 ForeachNodeSafe(&et
->et_TaskMsgPort
.mp_MsgList
, child
, tmpNode
)
189 /* If we have an ETask parent, tell it we have exited. */
190 if(et
->et_Parent
!= NULL
)
192 parent
= GetETask(et
->et_Parent
);
194 /* Link children to our parent. */
195 ForeachNodeSafe(&et
->et_Children
, child
, nextchild
)
197 child
->et_Parent
= et
->et_Parent
;
200 ADDTAIL(&parent
->et_Children
, child
);
204 /* Notify parent only if child was created with NP_NotifyOnDeath set
211 (((struct Task
*)task
)->tc_Node
.ln_Type
== NT_PROCESS
) &&
212 (((struct Process
*) task
)->pr_Flags
& PRF_NOTIFYONDEATH
)
215 PutMsg(&parent
->et_TaskMsgPort
, (struct Message
*)et
);
222 /* Orphan all our remaining children. */
223 ForeachNode(&et
->et_Children
, child
)
224 child
->et_Parent
= NULL
;
234 Exec_ExpungeETask(struct ETask
*et
, struct ExecBase
*SysBase
)
236 IPTR
*ts
= et
->et_TaskStorage
;
239 FreeVec(et
->et_Result2
);
242 FreeVec(IntETask(et
)->iet_Me
);
244 D(bug("Exec_ExpungeETask: Freeing et=%x, ts=%x, size=%d\n",
245 et
, ts
, ts
? (ULONG
)ts
[__TS_FIRSTSLOT
] : 0
247 FreeMem(et
, sizeof(struct IntETask
));
249 FreeMem(ts
, ts
[__TS_FIRSTSLOT
] * sizeof(ts
[0]));
252 BOOL
Exec_CheckTask(struct Task
*task
, struct ExecBase
*SysBase
)
261 if (task
== SysBase
->ThisTask
)
267 ForeachNode(&SysBase
->TaskReady
, t
)
276 ForeachNode(&SysBase
->TaskWait
, t
)