X-Git-Url: https://git.ucc.asn.au/?a=blobdiff_plain;f=Kernel%2Fevents.c;h=a9eab7865e86244ded7a8cf9dd08bbcf529e7678;hb=61cfad415a64c52ca253460231046f47fcb7fb15;hp=4c872bc0c5c25118bb0de50fa20f256f6858a9a8;hpb=def8ed174653a8e4b4ecbd58561a5bf8c908aa7a;p=tpg%2Facess2.git

diff --git a/Kernel/events.c b/Kernel/events.c
index 4c872bc0..a9eab786 100644
--- a/Kernel/events.c
+++ b/Kernel/events.c
@@ -5,6 +5,7 @@
  * events.c
  * - Thread level event handling
  */
+#define DEBUG	0
 #include <acess.h>
 #include <threads_int.h>
 #include <events.h>
@@ -17,9 +18,12 @@ void Threads_PostEvent(tThread *Thread, Uint32 EventMask)
 	if( EventMask == 0 )	return ;
 	// TODO: Check that only one bit is set?
 	
+	ENTER("pThread xEventMask", Thread, EventMask);
+
 	SHORTLOCK( &Thread->IsLocked );
 
 	Thread->EventState |= EventMask;
+	LOG("Thread->EventState = 0x%x", Thread->EventState);
 	
 	// Currently sleeping on an event?
 	if( Thread->Status == THREAD_STAT_EVENTSLEEP )
@@ -28,12 +32,13 @@ void Threads_PostEvent(tThread *Thread, Uint32 EventMask)
 		if( (Uint32)Thread->RetStatus & EventMask )
 		{
 			// Wake up
-			// TODO: Does it matter if the thread is locked here?
+			LOG("Waking thread %p(%i %s)", Thread, Thread->TID, Thread->ThreadName);
 			Threads_AddActive(Thread);
 		}
 	}
 	
 	SHORTREL( &Thread->IsLocked );
+	LEAVE('-');
 }
 
 /**
@@ -44,24 +49,31 @@ Uint32 Threads_WaitEvents(Uint32 EventMask)
 	Uint32	rv;
 	tThread	*us = Proc_GetCurThread();
 
+	ENTER("xEventMask", EventMask);
+
 	// Early return check
 	if( EventMask == 0 )
 	{
+		LEAVE('i', 0);
 		return 0;
 	}
 	
+	LOG("us = %p(%i %s)", us, us->TID, us->ThreadName);
+
 	// Check if a wait is needed
 	SHORTLOCK( &us->IsLocked );
 	while( !(us->EventState & EventMask) )
 	{
+		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_MUTEXSLEEP)	Threads_Yield();
+		while(us->Status == THREAD_STAT_EVENTSLEEP)	Threads_Yield();
 		// Woken when lock is acquired
 		SHORTLOCK( &us->IsLocked );
 	}
@@ -72,6 +84,7 @@ Uint32 Threads_WaitEvents(Uint32 EventMask)
 	
 	SHORTREL( &us->IsLocked );
 	
+	LEAVE('x', rv);
 	return rv;
 }