waitchannel.c File Reference

#include <stdbool.h>
#include <stdint.h>
#include <string.h>
#include <sys/cdefs.h>
#include <sys/kassert.h>
#include <sys/kdebug.h>
#include <sys/queue.h>
#include <sys/thread.h>
#include <sys/spinlock.h>
#include <sys/waitchannel.h>

Include dependency graph for waitchannel.c:

Go to the source code of this file.

Functions
	LIST_HEAD (ChanListHead, WaitChannel)
void	WaitChannel_Init (WaitChannel *wchan, const char *name)
void	WaitChannel_Destroy (WaitChannel *wchan)
void	WaitChannel_Lock (WaitChannel *wchan)
void	WaitChannel_Sleep (WaitChannel *wchan)
void	WaitChannel_Wake (WaitChannel *wchan)
void	WaitChannel_WakeAll (WaitChannel *wchan)

Variables
Spinlock	chanListLock

Function Documentation

LIST_HEAD()

LIST_HEAD	(	ChanListHead	,
		WaitChannel
	)

Definition at line 19 of file waitchannel.c.

{
    Spinlock_Init(&chanListLock, "WaitChannel List", SPINLOCK_TYPE_NORMAL);
}

WaitChannel_Destroy()

void WaitChannel_Destroy

(

WaitChannel *

wchan

)

Definition at line 40 of file waitchannel.c.

{
    ASSERT(TAILQ_EMPTY(&wchan->chanQueue));
 
    Spinlock_Lock(&chanListLock);
    LIST_REMOVE(wchan, chanList);
    Spinlock_Unlock(&chanListLock);
 
    Spinlock_Destroy(&wchan->lock);
}

Here is the call graph for this function:

Here is the caller graph for this function:

WaitChannel_Init()

void WaitChannel_Init	(	WaitChannel *	wchan,
		const char *	name
	)

Definition at line 28 of file waitchannel.c.

{
    TAILQ_INIT(&wchan->chanQueue);
    strncpy(&wchan->name[0], name, WAITCHANNEL_NAMELEN);
    Spinlock_Init(&wchan->lock, name, SPINLOCK_TYPE_NORMAL);
 
    Spinlock_Lock(&chanListLock);
    LIST_INSERT_HEAD(&chanList, wchan, chanList);
    Spinlock_Unlock(&chanListLock);
}

Here is the call graph for this function:

Here is the caller graph for this function:

WaitChannel_Lock()

void WaitChannel_Lock

(

WaitChannel *

wchan

)

WaitChannel_Lock –

Acquires the wait channel lock.

Definition at line 57 of file waitchannel.c.

{
    Spinlock_Lock(&wchan->lock);
}

Here is the call graph for this function:

WaitChannel_Sleep()

void WaitChannel_Sleep

(

WaitChannel *

wchan

)

WaitChannel_Sleep –

Places the current thread to asleep while releasing the wait channel lock.

Side Effect: Retains a reference to thread until the thread is woken up.

Definition at line 71 of file waitchannel.c.

{
    Thread *thr = Sched_Current();
 
    Sched_SetWaiting(thr);
    TAILQ_INSERT_TAIL(&wchan->chanQueue, thr, chanQueue);
    Spinlock_Unlock(&wchan->lock);
 
    Sched_Scheduler();
}

Here is the call graph for this function:

WaitChannel_Wake()

void WaitChannel_Wake

(

WaitChannel *

wchan

)

WaitChannel_Wake –

Wake up a single thread.

Side Effects: Releases the thread reference once complete.

Definition at line 91 of file waitchannel.c.

{
    Thread *thr;
 
    Spinlock_Lock(&wchan->lock);
 
    thr = TAILQ_FIRST(&wchan->chanQueue);
    if (thr != NULL) {
        TAILQ_REMOVE(&wchan->chanQueue, thr, chanQueue);
        Sched_SetRunnable(thr);
        Thread_Release(thr);
    }
 
    Spinlock_Unlock(&wchan->lock);
}

Here is the call graph for this function:

WaitChannel_WakeAll()

void WaitChannel_WakeAll

(

WaitChannel *

wchan

)

WaitChannel_WakeAll –

Wakes up all threads currently sleeping on the wait channel.

Side Effects: Releases all thread references.

Definition at line 116 of file waitchannel.c.

{
    Thread *thr;
    Thread *thrTemp;
 
    Spinlock_Lock(&wchan->lock);
 
    TAILQ_FOREACH_SAFE(thr, &wchan->chanQueue, chanQueue, thrTemp) {
        TAILQ_REMOVE(&wchan->chanQueue, thr, chanQueue);
        Sched_SetRunnable(thr);
        Thread_Release(thr);
    }
 
    Spinlock_Unlock(&wchan->lock);
}

Here is the call graph for this function:

Variable Documentation

chanListLock

Spinlock chanListLock

Definition at line 18 of file waitchannel.c.