root / Whitix / branches / network / kernel / wait.c

#include <sched.h>
#include <task.h>
#include <wait.h>

/***********************************************************************
 *
 * FUNCTION: WakeUp
 *
 * DESCRIPTION: Wake up all threads waiting on a waitqueue.
 *
 * PARAMETERS: waitQueue - wait queue in question.
 *
 * RETURNS: Nothing.
 *
 ***********************************************************************/

void WakeUp(WaitQueue* waitQueue)
{
        struct WaitQueueEntry* curr;

        /* No point if it's empty */
        if (ListEmpty(&waitQueue->list))
                return;

        SpinLockIrq(&waitQueue->spinLock);

        ListForEachEntry(curr,&(waitQueue->list),next)
        {
#ifdef WAIT_DEBUG
                if (curr->magic != 0xDEADBEEF)          
                        printf("WakeUp: Error, %#X!, thread = %#X, prev = %#X, next = %#X, magic = %#X, from %#X\n",
                                waitQueue,curr->thread,curr->next.prev,curr->next.next,curr->magic,__builtin_return_address(0));
#endif
                ThrResumeThread(curr->thread); /* No need to remove entry, whole waitQueue list is destroyed */
        }

        SpinUnlockIrq(&waitQueue->spinLock);

        if (thrNeedSchedule)
                ThrSchedule();
}