ktimer.c File Reference

#include <stddef.h>
#include <stdbool.h>
#include <stdint.h>
#include <sys/kassert.h>
#include <sys/queue.h>
#include <sys/spinlock.h>
#include <sys/kmem.h>
#include <sys/mp.h>
#include <sys/ktime.h>
#include <sys/ktimer.h>

Include dependency graph for ktimer.c:

Go to the source code of this file.

Macros
#define	TIMER_WHEEL_LENGTH   256

Functions
static	LIST_HEAD (TimerWheelHead, DEFINE_SLAB(KTimerEvent)
KTimerEvent *	KTimer_Create (uint64_t timeout, KTimerCB cb, void *arg)
void	KTimer_Retain (KTimerEvent *evt)
void	KTimer_Release (KTimerEvent *evt)
void	KTimer_Cancel (KTimerEvent *evt)
void	KTimer_Process ()

Variables
static int	timerHead = 0
static uint64_t	timerNow = 0

Macro Definition Documentation

TIMER_WHEEL_LENGTH

#define TIMER_WHEEL_LENGTH   256

Definition at line 14 of file ktimer.c.

Function Documentation

KTimer_Cancel()

void KTimer_Cancel

(

KTimerEvent *

evt

)

Definition at line 77 of file ktimer.c.

{
    Spinlock_Lock(&timerLock);
 
    LIST_REMOVE(evt, timerQueue);
    KTimer_Release(evt);
 
    Spinlock_Unlock(&timerLock);
}

Here is the call graph for this function:

KTimer_Create()

KTimerEvent * KTimer_Create	(	uint64_t	timeout,
		KTimerCB	cb,
		void *	arg
	)

Definition at line 41 of file ktimer.c.

{
    int slot;
    KTimerEvent *evt = KTimerEvent_Alloc();
 
    evt->refCount = 2; // One for the wheel and one for the callee
    evt->timeout = timerNow + timeout;
    evt->cb = cb;
    evt->arg = arg;
 
    Spinlock_Lock(&timerLock);
    slot = (timerHead + timeout + TIMER_WHEEL_LENGTH - 1) % TIMER_WHEEL_LENGTH;
    // XXX: should insert into tail
    LIST_INSERT_HEAD(&timerSlot[slot], evt, timerQueue);
    Spinlock_Unlock(&timerLock);
 
    return evt;
}

Here is the call graph for this function:

Here is the caller graph for this function:

KTimer_Process()

void KTimer_Process

(

)

Definition at line 88 of file ktimer.c.

{
    uint64_t now;
 
    if (CPU() != 0) {
        return;
    }
 
    now = KTime_GetEpoch();
 
    Spinlock_Lock(&timerLock);
 
    while (now > timerNow) {
        KTimerEvent *it, *tmp;
 
        // Dispatch pending timer events
        LIST_FOREACH_SAFE(it, &timerSlot[timerHead], timerQueue, tmp) {
            if (it->timeout <= now) {
                (it->cb)(it->arg);
                LIST_REMOVE(it, timerQueue);
                KTimer_Release(it);
            }
        }
 
        // Rotate wheel forward
        timerNow = timerNow + 1;
        timerHead = (timerHead + 1) % TIMER_WHEEL_LENGTH;
    }
 
    Spinlock_Unlock(&timerLock);
}

Here is the call graph for this function:

Here is the caller graph for this function:

KTimer_Release()

void KTimer_Release

(

KTimerEvent *

evt

)

Definition at line 68 of file ktimer.c.

{
    ASSERT(evt->refCount != 0);
    if (__sync_fetch_and_sub(&evt->refCount, 1) == 1) {
        KTimerEvent_Free(evt);
    }
}

Here is the caller graph for this function:

KTimer_Retain()

void KTimer_Retain

(

KTimerEvent *

evt

)

Definition at line 61 of file ktimer.c.

{
    ASSERT(evt->refCount != 0);
    __sync_fetch_and_add(&evt->refCount, 1);
}

LIST_HEAD()

static LIST_HEAD ( TimerWheelHead  , DEFINE_SLAB(  KTimerEvent  )

static

Definition at line 18 of file ktimer.c.

{
    int i;
 
    Spinlock_Init(&timerLock, "KTimer Lock", SPINLOCK_TYPE_NORMAL);
    Slab_Init(&timerSlab, "KTimerEvent Slab", sizeof(KTimerEvent), 16);
 
    // Initialize wheel
    timerHead = 0;
    timerNow = KTime_GetEpoch();
    for (i = 0; i < TIMER_WHEEL_LENGTH; i++) {
        LIST_INIT(&timerSlot[i]);
    }
}

Variable Documentation

timerHead

int timerHead = 0

static

Definition at line 16 of file ktimer.c.

timerNow

uint64_t timerNow = 0

static

Definition at line 17 of file ktimer.c.