X-Git-Url: https://git.ucc.asn.au/?a=blobdiff_plain;f=KernelLand%2FKernel%2Fthreads.c;h=4dcdb9461981a6dac8f49bfe85e4ce44a0fd8139;hb=0e1f2361c44760869b3b7164217e00889884b976;hp=21dc055f3e6abef59d660a87513b5b31b17b5a9b;hpb=5117f5901dfec46d535a7685d1904f802d21d62f;p=tpg%2Facess2.git

diff --git a/KernelLand/Kernel/threads.c b/KernelLand/Kernel/threads.c
index 21dc055f..4dcdb946 100644
--- a/KernelLand/Kernel/threads.c
+++ b/KernelLand/Kernel/threads.c
@@ -10,6 +10,7 @@
 #include <errno.h>
 #include <hal_proc.h>
 #include <semaphore.h>
+#include <rwlock.h>
 #include <vfs_threads.h>	// VFS Handle maintainence
 #include <events.h>
 
@@ -49,7 +50,7 @@ void	Threads_Delete(tThread *Thread);
 char	*Threads_GetName(tTID ID);
 #if 0
 void	Threads_SetPriority(tThread *Thread, int Pri);
-tThread	*Threads_CloneTCB(Uint *Err, Uint Flags);
+tThread	*Threads_CloneTCB(Uint Flags);
  int	Threads_WaitTID(int TID, int *status);
 tThread	*Threads_GetThread(Uint TID);
 #endif
@@ -59,9 +60,7 @@ void	Threads_int_AddToList(tThreadList *List, tThread *Thread);
 void	Threads_Exit(int TID, int Status);
 void	Threads_Kill(tThread *Thread, int Status);
 void	Threads_Yield(void);
-#endif
-void	Threads_int_Sleep(enum eThreadStatus Status, void *Ptr, int Num, tThread **ListHead, tThread **ListTail, tShortSpinlock *Lock);
-#if 0
+ int	Threads_int_Sleep(enum eThreadStatus Status, void *Ptr, int Num, tThread **ListHead, tThread **ListTail, tShortSpinlock *Lock);
 void	Threads_Sleep(void);
  int	Threads_Wake(tThread *Thread);
 void	Threads_AddActive(tThread *Thread);
@@ -507,6 +506,7 @@ tTID Threads_WaitTID(int TID, int *Status)
 	// Specific Thread
 	if(TID > 0)
 	{
+		// TODO: Register on thread to be poked when it dies
 		tTID	ret;
 		// NOTE: Race condition - Other child dies, desired child dies, first death is 'lost'
 		while( (ret = Threads_WaitTID(-1, Status)) != TID )
@@ -754,7 +754,7 @@ void Threads_int_WaitForStatusEnd(enum eThreadStatus Status)
 	}
 }
 
-void Threads_int_Sleep(enum eThreadStatus Status, void *Ptr, int Num, tThread **ListHead, tThread **ListTail, tShortSpinlock *Lock)
+int Threads_int_Sleep(enum eThreadStatus Status, void *Ptr, int Num, tThread **ListHead, tThread **ListTail, tShortSpinlock *Lock)
 {
 	SHORTLOCK( &glThreadListLock );
 	tThread	*us = Threads_RemActive();
@@ -768,12 +768,11 @@ void Threads_int_Sleep(enum eThreadStatus Status, void *Ptr, int Num, tThread **
 	if( ListTail ) {
 		if(*ListTail) {
 			(*ListTail)->Next = us;
-			*ListTail = us;
 		}
 		else {
 			*ListHead = us;
-			*ListTail = us;
 		}
+		*ListTail = us;
 	}
 	else {
 		*ListHead = us;
@@ -783,8 +782,10 @@ void Threads_int_Sleep(enum eThreadStatus Status, void *Ptr, int Num, tThread **
 	//	return ;
 	SHORTREL( &glThreadListLock );
 	if( Lock )
-		SHORTLOCK( Lock );
+		SHORTREL( Lock );
 	Threads_int_WaitForStatusEnd(Status);
+	us->WaitPointer = NULL;
+	return us->RetStatus;
 }
 
 /**
@@ -1251,6 +1252,11 @@ void Threads_int_DumpThread(tThread *thread)
 	case THREAD_STAT_MUTEXSLEEP:
 		Log("  Mutex Pointer: %p", thread->WaitPointer);
 		break;
+	case THREAD_STAT_RWLOCKSLEEP:
+		Log("  Lock Pointer: %p", thread->WaitPointer);
+		Log("  Lock Name: %s",
+			((tRWLock*)thread->WaitPointer)->Name);
+		break;
 	case THREAD_STAT_SEMAPHORESLEEP:
 		Log("  Semaphore Pointer: %p", thread->WaitPointer);
 		Log("  Semaphore Name: %s:%s",