3 * - By John Hodge (thePowersGang)
11 #include <threads_int.h>
16 * \fn int Proc_SendMessage(Uint *Err, Uint Dest, int Length, void *Data)
17 * \brief Send an IPC message
18 * \param Err Pointer to the errno variable
19 * \param Dest Destination Thread
20 * \param Length Length of the message
21 * \param Data Message data
23 int Proc_SendMessage(Uint *Err, Uint Dest, int Length, void *Data)
28 ENTER("pErr iDest iLength pData", Err, Dest, Length, Data);
30 if(Length <= 0 || !Data) {
36 thread = Threads_GetThread( Dest );
39 if(!thread) LEAVE_RET('i', -1);
42 SHORTLOCK( &thread->IsLocked );
44 // Check if thread is still alive
45 if(thread->Status == THREAD_STAT_DEAD) {
46 SHORTREL( &thread->IsLocked );
51 msg = malloc( sizeof(tMsg)+Length );
53 msg->Source = Proc_GetCurThread()->TID;
55 memcpy(msg->Data, Data, Length);
57 // If there are already messages
58 if(thread->LastMessage) {
59 thread->LastMessage->Next = msg;
60 thread->LastMessage = msg;
62 thread->Messages = msg;
63 thread->LastMessage = msg;
66 SHORTREL(&thread->IsLocked);
68 SHORTLOCK(&glThreadListLock);
69 LOG("Waking %p (%i %s)", thread, thread->TID, thread->ThreadName);
70 Threads_Wake( thread );
71 SHORTREL(&glThreadListLock);
77 * \fn int Proc_GetMessage(Uint *Err, Uint *Source, void *Buffer)
78 * \brief Gets a message
79 * \param Err Pointer to \a errno
80 * \param Source Where to put the source TID
81 * \param Buffer Buffer to place the message data (set to NULL to just get message length)
83 int Proc_GetMessage(Uint *Err, Uint *Source, void *Buffer)
87 tThread *cur = Proc_GetCurThread();
89 ENTER("pSource pBuffer", Source, Buffer);
91 // Check if queue has any items
97 SHORTLOCK( &cur->IsLocked );
100 *Source = cur->Messages->Source;
101 LOG("*Source = %i", *Source);
104 // Get message length
106 ret = cur->Messages->Length;
107 SHORTREL( &cur->IsLocked );
113 if(Buffer != GETMSG_IGNORE)
115 if( !CheckMem( Buffer, cur->Messages->Length ) )
117 LOG("Invalid buffer");
119 SHORTREL( &cur->IsLocked );
123 LOG("Copied to buffer");
124 memcpy(Buffer, cur->Messages->Data, cur->Messages->Length);
126 ret = cur->Messages->Length;
130 cur->Messages = cur->Messages->Next;
131 if(cur->Messages == NULL) cur->LastMessage = NULL;
133 SHORTREL( &cur->IsLocked );
135 free(tmp); // Free outside of lock