X-Git-Url: https://git.ucc.asn.au/?a=blobdiff_plain;f=Kernel%2Fthreads.c;h=1ccac9f68ca495b152ee5ecfb1e86843a47acad1;hb=cc4cb2c933b04f63a236735bbfc8a055c1bf5abd;hp=1644b504b758ce35659b840db9207494467a6bdd;hpb=0259a3c08b2c7d5c9d05bd0d051a67399e755638;p=tpg%2Facess2.git diff --git a/Kernel/threads.c b/Kernel/threads.c index 1644b504..1ccac9f6 100644 --- a/Kernel/threads.c +++ b/Kernel/threads.c @@ -23,6 +23,7 @@ void Threads_SetName(char *NewName); void Threads_SetTickets(int Num); int Threads_WaitTID(int TID, int *status); tThread *Threads_GetThread(Uint TID); +void Threads_AddToDelete(tThread *Thread); tThread *Threads_int_GetPrev(tThread **List, tThread *Thread); void Threads_Exit(int TID, int Status); void Threads_Kill(tThread *Thread, int Status); @@ -164,10 +165,11 @@ int Threads_WaitTID(int TID, int *status) { case THREAD_STAT_ZOMBIE: t->Status = THREAD_STAT_DEAD; - *status = 0; + if(status) *status = 0; + Threads_AddToDelete( t ); break; default: - *status = -1; + if(status) *status = -1; break; } return ret; @@ -205,6 +207,22 @@ tThread *Threads_GetThread(Uint TID) return NULL; } +/** + * \fn void Threads_AddToDelete(tThread *Thread) + * \brief Adds a thread to the delete queue + */ +void Threads_AddToDelete(tThread *Thread) +{ + // Add to delete queue + if(gDeleteThreads) { + Thread->Next = gDeleteThreads; + gDeleteThreads = Thread; + } else { + Thread->Next = NULL; + gDeleteThreads = Thread; + } +} + /** * \fn tThread *Threads_int_GetPrev(tThread *List, tThread *Thread) * \brief Gets the previous entry in a thead linked list @@ -298,14 +316,7 @@ void Threads_Kill(tThread *Thread, int Status) if(Status == -1) { Thread->Status = THREAD_STAT_DEAD; - // Add to delete queue - if(gDeleteThreads) { - Thread->Next = gDeleteThreads; - gDeleteThreads = Thread; - } else { - Thread->Next = NULL; - gDeleteThreads = Thread; - } + Threads_AddToDelete( Thread ); } else { Thread->Status = THREAD_STAT_ZOMBIE; }