X-Git-Url: https://git.ucc.asn.au/?a=blobdiff_plain;f=Kernel%2Fthreads.c;h=3e98e44817236f3ddde21d85a52a8196434d0d75;hb=652ddd443bc0b8cdde1295c7497854b4e4c854d5;hp=714b2b094173cfb5447f59e4452f51693787b4cf;hpb=a61b28e45899df847f74da32bddf24c673a7d91c;p=tpg%2Facess2.git diff --git a/Kernel/threads.c b/Kernel/threads.c index 714b2b09..3e98e448 100644 --- a/Kernel/threads.c +++ b/Kernel/threads.c @@ -30,6 +30,7 @@ void Threads_Kill(tThread *Thread, int Status); void Threads_Yield(); void Threads_Sleep(); void Threads_Wake(tThread *Thread); +void Threads_AddActive(tThread *Thread); int Threads_GetPID(); int Threads_GetTID(); int Threads_GetUID(); @@ -93,10 +94,11 @@ void Threads_Init() cur->ThreadName = "Idle Thread"; Threads_SetTickets(0); // Never called randomly cur->Quantum = 1; // 1 slice quantum + HALT(); for(;;) { - Log("---- Idle"); - Threads_Dump(); - __asm__ __volatile__ ("hlt"); // Just yeilds + //Log("---- Idle"); + //Threads_Dump(); + HALT(); // Just yeilds } } #endif @@ -425,6 +427,22 @@ void Threads_Wake(tThread *Thread) } } +/** + * \fn void Threads_AddActive(tThread *Thread) + * \brief Adds a thread to the active queue + */ +void Threads_AddActive(tThread *Thread) +{ + LOCK( &giThreadListLock ); + Thread->Next = gActiveThreads; + gActiveThreads = Thread; + giNumActiveThreads ++; + giTotalTickets += Thread->NumTickets; + //Log("Threads_AddActive: giNumActiveThreads = %i, giTotalTickets = %i", + // giNumActiveThreads, giTotalTickets); + RELEASE( &giThreadListLock ); +} + #if 0 /** * \fn void Threads_SetSignalHandler(int Num, void *Handler) @@ -534,9 +552,13 @@ tThread *Threads_GetNextToRun(int CPU) return gActiveThreads; } + //Log(" Threads_GetNextToRun: giNumActiveThreads=%i,giTotalTickets=%i", + // giNumActiveThreads, giTotalTickets); // Get the ticket number ticket = number = rand() % giTotalTickets; + //Log(" Threads_GetNextToRun: ticket = %i", ticket); + // Find the next thread for(thread=gActiveThreads;thread;thread=thread->Next) {