X-Git-Url: https://git.ucc.asn.au/?a=blobdiff_plain;ds=sidebyside;f=KernelLand%2FKernel%2Fevents.c;h=a572d43362d1e66628a7cd258a7bdfee581892fa;hb=14d0ba44433f0f828aff710184fd3c597ab73999;hp=c3ab282ffbe09f80f0290569af431b3e680f171d;hpb=2db551c69841b4fb5a70ae05e08d54b1a016364b;p=tpg%2Facess2.git diff --git a/KernelLand/Kernel/events.c b/KernelLand/Kernel/events.c index c3ab282f..a572d433 100644 --- a/KernelLand/Kernel/events.c +++ b/KernelLand/Kernel/events.c @@ -7,8 +7,8 @@ */ #define DEBUG 0 #include -#include #include +#include // === CODE === void Threads_PostEvent(tThread *Thread, Uint32 EventMask) @@ -45,6 +45,8 @@ void Threads_PostEvent(tThread *Thread, Uint32 EventMask) Semaphore_ForceWake(Thread); } break; + default: + break; } SHORTREL( &Thread->IsLocked ); @@ -80,19 +82,12 @@ Uint32 Threads_WaitEvents(Uint32 EventMask) // Check if a wait is needed SHORTLOCK( &us->IsLocked ); - while( !(us->EventState & EventMask) ) + LOG("Locked and preparing for wait"); + if( (us->EventState & EventMask) == 0 ) { - LOG("Locked and preparing for wait"); - // Wait - us->RetStatus = EventMask; // HACK: Store EventMask in RetStatus - SHORTLOCK( &glThreadListLock ); - us = Threads_RemActive(); - us->Status = THREAD_STAT_EVENTSLEEP; - // Note stored anywhere because we're woken using other means - SHORTREL( &glThreadListLock ); - SHORTREL( &us->IsLocked ); - while(us->Status == THREAD_STAT_EVENTSLEEP) Threads_Yield(); - // Woken when lock is acquired + Threads_int_Sleep(THREAD_STAT_EVENTSLEEP, NULL, EventMask, + &us, NULL, &us->IsLocked); + // Woken when an event fires SHORTLOCK( &us->IsLocked ); }