#include <wdm.h>

Include dependency graph for workqueue.c:

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().

Classes

Macros

Typedefs

Functions

Variables