workqueue.c File Reference

#include <wdm.h>

Include dependency graph for workqueue.c:

Go to the source code of this file.

Classes
struct	_WORK_ITEM

Macros
#define	FOURCC(w, x, y, z)   (((w) << 24) | ((x) << 16) | ((y) << 8) | (z))
#define	CHEW_TAG   FOURCC('C','H','E','W')

Typedefs
typedef struct _WORK_ITEM	WORK_ITEM
typedef struct _WORK_ITEM *	PWORK_ITEM

Functions
VOID	ChewInit (PDEVICE_OBJECT DeviceObject)
VOID	ChewShutdown (VOID)
VOID NTAPI	ChewWorkItem (PDEVICE_OBJECT DeviceObject, PVOID ChewItem)
BOOLEAN	ChewCreate (VOID(*Worker)(PVOID), PVOID WorkerContext)

Variables
PDEVICE_OBJECT	WorkQueueDevice
LIST_ENTRY	WorkQueue
KSPIN_LOCK	WorkQueueLock
KEVENT	WorkQueueClear

Macro Definition Documentation

CHEW_TAG

#define CHEW_TAG   FOURCC('C','H','E','W')

Definition at line 13 of file workqueue.c.

FOURCC

#define FOURCC	(		w,
			x,
			y,
			z
	)		(((w) << 24) | ((x) << 16) | ((y) << 8) | (z))

Definition at line 12 of file workqueue.c.

Typedef Documentation

PWORK_ITEM

typedef struct _WORK_ITEM * PWORK_ITEM

WORK_ITEM

typedef struct _WORK_ITEM WORK_ITEM

Function Documentation

ChewCreate()

BOOLEAN ChewCreate	(	VOID(*)(PVOID)	Worker,
		PVOID	WorkerContext
	)

Creates and queues a work item.

Definition at line 61 of file workqueue.c.

{
    PWORK_ITEM Item;
    Item = ExAllocatePoolWithTag(NonPagedPool,
                                 sizeof(WORK_ITEM),
                                 CHEW_TAG);
 
    if (Item)
    {
        Item->WorkItem = IoAllocateWorkItem(WorkQueueDevice);
        if (!Item->WorkItem)
        {
            ExFreePool(Item);
            return FALSE;
        }
 
        Item->Worker = Worker;
        Item->WorkerContext = WorkerContext;
        ExInterlockedInsertTailList(&WorkQueue, &Item->Entry, &WorkQueueLock);
        KeClearEvent(&WorkQueueClear);
        IoQueueWorkItem(Item->WorkItem, ChewWorkItem, DelayedWorkQueue, Item);
 
        return TRUE;
    }
    else
    {
        return FALSE;
    }
}

Referenced by CompleteBucket(), LanSubmitReceiveWork(), LoopTransmit(), and ProtocolStatus().

ChewInit()

VOID ChewInit

(

PDEVICE_OBJECT

DeviceObject

)

Initialize CHEW, given a device object (since IoAllocateWorkItem relies on it).

Definition at line 28 of file workqueue.c.

{
    WorkQueueDevice = DeviceObject;
    InitializeListHead(&WorkQueue);
    KeInitializeSpinLock(&WorkQueueLock);
    KeInitializeEvent(&WorkQueueClear, NotificationEvent, TRUE);
}

Referenced by DriverEntry().

ChewShutdown()

VOID ChewShutdown

(

VOID

)

Shutdown CHEW, waits for remaining work items.

Definition at line 36 of file workqueue.c.

{
    KeWaitForSingleObject(&WorkQueueClear, Executive, KernelMode, FALSE, NULL);
}

Referenced by TiUnload().

ChewWorkItem()

VOID NTAPI ChewWorkItem	(	PDEVICE_OBJECT	DeviceObject,
		PVOID	ChewItem
	)

Definition at line 41 of file workqueue.c.

{
    PWORK_ITEM WorkItem = ChewItem;
    KIRQL OldIrql;
 
    WorkItem->Worker(WorkItem->WorkerContext);
 
    IoFreeWorkItem(WorkItem->WorkItem);
 
    KeAcquireSpinLock(&WorkQueueLock, &OldIrql);
    RemoveEntryList(&WorkItem->Entry);
 
    if (IsListEmpty(&WorkQueue))
        KeSetEvent(&WorkQueueClear, 0, FALSE);
 
    KeReleaseSpinLock(&WorkQueueLock, OldIrql);
 
    ExFreePoolWithTag(WorkItem, CHEW_TAG);
}

Referenced by ChewCreate().

Variable Documentation

WorkQueue

LIST_ENTRY WorkQueue

Definition at line 16 of file workqueue.c.

Referenced by CcPostWorkQueue(), ChewCreate(), ChewInit(), ChewWorkItem(), ExpWorkerThreadEntryPoint(), ExQueueWorkItem(), RxBootstrapWorkerThreadDispatcher(), RxInitializeWorkQueue(), RxInsertWorkQueueItem(), RxpWorkerThreadDispatcher(), RxSpinUpRequestsDispatcher(), and RxSpinUpWorkerThread().

WorkQueueClear

KEVENT WorkQueueClear

Definition at line 18 of file workqueue.c.

Referenced by ChewCreate(), ChewInit(), ChewShutdown(), and ChewWorkItem().

WorkQueueDevice

PDEVICE_OBJECT WorkQueueDevice

Definition at line 15 of file workqueue.c.

Referenced by ChewCreate(), and ChewInit().

WorkQueueLock

KSPIN_LOCK WorkQueueLock

Definition at line 17 of file workqueue.c.

Referenced by ChewCreate(), ChewInit(), and ChewWorkItem().