rxworkq.h File Reference

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	_RX_WORK_QUEUE_ITEM_
struct	_RX_WORK_DISPATCH_ITEM_
struct	_RX_WORK_QUEUE_RUNDOWN_CONTEXT_
struct	_RX_WORK_QUEUE_
struct	_RX_WORK_QUEUE_DISPATCHER_
struct	_RX_DISPATCHER_

Typedefs
typedef VOID(NTAPI *	PRX_WORKERTHREAD_ROUTINE) (_In_ PVOID Context)
typedef struct _RX_WORK_QUEUE_ITEM_	RX_WORK_QUEUE_ITEM
typedef struct _RX_WORK_QUEUE_ITEM_ *	PRX_WORK_QUEUE_ITEM
typedef struct _RX_WORK_DISPATCH_ITEM_	RX_WORK_DISPATCH_ITEM
typedef struct _RX_WORK_DISPATCH_ITEM_ *	PRX_WORK_DISPATCH_ITEM
typedef enum _RX_WORK_QUEUE_STATE_	RX_WORK_QUEUE_STATE
typedef enum _RX_WORK_QUEUE_STATE_ *	PRX_WORK_QUEUE_STATE
typedef struct _RX_WORK_QUEUE_RUNDOWN_CONTEXT_	RX_WORK_QUEUE_RUNDOWN_CONTEXT
typedef struct _RX_WORK_QUEUE_RUNDOWN_CONTEXT_ *	PRX_WORK_QUEUE_RUNDOWN_CONTEXT
typedef struct _RX_WORK_QUEUE_	RX_WORK_QUEUE
typedef struct _RX_WORK_QUEUE_ *	PRX_WORK_QUEUE
typedef struct _RX_WORK_QUEUE_DISPATCHER_	RX_WORK_QUEUE_DISPATCHER
typedef struct _RX_WORK_QUEUE_DISPATCHER_ *	PRX_WORK_QUEUE_DISPATCHER
typedef enum _RX_DISPATCHER_STATE_	RX_DISPATCHER_STATE
typedef enum _RX_DISPATCHER_STATE_ *	PRX_DISPATCHER_STATE
typedef struct _RX_DISPATCHER_	RX_DISPATCHER
typedef struct _RX_DISPATCHER_ *	PRX_DISPATCHER

Enumerations
enum	_RX_WORK_QUEUE_STATE_ { RxWorkQueueActive , RxWorkQueueInactive , RxWorkQueueRundownInProgress }
enum	_RX_DISPATCHER_STATE_ { RxDispatcherActive , RxDispatcherInactive }

Functions
NTSTATUS NTAPI	RxPostToWorkerThread (_In_ PRDBSS_DEVICE_OBJECT pMRxDeviceObject, _In_ WORK_QUEUE_TYPE WorkQueueType, _In_ PRX_WORK_QUEUE_ITEM pWorkQueueItem, _In_ PRX_WORKERTHREAD_ROUTINE Routine, _In_ PVOID pContext)
NTSTATUS NTAPI	RxDispatchToWorkerThread (_In_ PRDBSS_DEVICE_OBJECT pMRxDeviceObject, _In_ WORK_QUEUE_TYPE WorkQueueType, _In_ PRX_WORKERTHREAD_ROUTINE Routine, _In_ PVOID pContext)
NTSTATUS NTAPI	RxInitializeDispatcher (VOID)
NTSTATUS	RxInitializeMRxDispatcher (_Inout_ PRDBSS_DEVICE_OBJECT pMRxDeviceObject)

Typedef Documentation

PRX_DISPATCHER

typedef struct _RX_DISPATCHER_ * PRX_DISPATCHER

PRX_DISPATCHER_STATE

typedef enum _RX_DISPATCHER_STATE_ * PRX_DISPATCHER_STATE

PRX_WORK_DISPATCH_ITEM

typedef struct _RX_WORK_DISPATCH_ITEM_ * PRX_WORK_DISPATCH_ITEM

PRX_WORK_QUEUE

typedef struct _RX_WORK_QUEUE_ * PRX_WORK_QUEUE

PRX_WORK_QUEUE_DISPATCHER

typedef struct _RX_WORK_QUEUE_DISPATCHER_ * PRX_WORK_QUEUE_DISPATCHER

PRX_WORK_QUEUE_ITEM

typedef struct _RX_WORK_QUEUE_ITEM_ * PRX_WORK_QUEUE_ITEM

PRX_WORK_QUEUE_RUNDOWN_CONTEXT

typedef struct _RX_WORK_QUEUE_RUNDOWN_CONTEXT_ * PRX_WORK_QUEUE_RUNDOWN_CONTEXT

PRX_WORK_QUEUE_STATE

typedef enum _RX_WORK_QUEUE_STATE_ * PRX_WORK_QUEUE_STATE

PRX_WORKERTHREAD_ROUTINE

typedef VOID(NTAPI * PRX_WORKERTHREAD_ROUTINE) (_In_ PVOID Context)

Definition at line 5 of file rxworkq.h.

RX_DISPATCHER

typedef struct _RX_DISPATCHER_ RX_DISPATCHER

RX_DISPATCHER_STATE

typedef enum _RX_DISPATCHER_STATE_ RX_DISPATCHER_STATE

RX_WORK_DISPATCH_ITEM

typedef struct _RX_WORK_DISPATCH_ITEM_ RX_WORK_DISPATCH_ITEM

RX_WORK_QUEUE

typedef struct _RX_WORK_QUEUE_ RX_WORK_QUEUE

RX_WORK_QUEUE_DISPATCHER

typedef struct _RX_WORK_QUEUE_DISPATCHER_ RX_WORK_QUEUE_DISPATCHER

RX_WORK_QUEUE_ITEM

typedef struct _RX_WORK_QUEUE_ITEM_ RX_WORK_QUEUE_ITEM

RX_WORK_QUEUE_RUNDOWN_CONTEXT

typedef struct _RX_WORK_QUEUE_RUNDOWN_CONTEXT_ RX_WORK_QUEUE_RUNDOWN_CONTEXT

RX_WORK_QUEUE_STATE

typedef enum _RX_WORK_QUEUE_STATE_ RX_WORK_QUEUE_STATE

Enumeration Type Documentation

_RX_DISPATCHER_STATE_

enum _RX_DISPATCHER_STATE_

Enumerator
RxDispatcherActive
RxDispatcherInactive

Definition at line 65 of file rxworkq.h.

{
   RxDispatcherActive,
   RxDispatcherInactive
} RX_DISPATCHER_STATE, *PRX_DISPATCHER_STATE;

_RX_WORK_QUEUE_STATE_

enum _RX_WORK_QUEUE_STATE_

Enumerator
RxWorkQueueActive
RxWorkQueueInactive
RxWorkQueueRundownInProgress

Definition at line 22 of file rxworkq.h.

{
   RxWorkQueueActive,
   RxWorkQueueInactive,
   RxWorkQueueRundownInProgress
} RX_WORK_QUEUE_STATE, *PRX_WORK_QUEUE_STATE;

Function Documentation

RxDispatchToWorkerThread()

NTSTATUS NTAPI RxDispatchToWorkerThread	(	_In_ PRDBSS_DEVICE_OBJECT	pMRxDeviceObject,
		_In_ WORK_QUEUE_TYPE	WorkQueueType,
		_In_ PRX_WORKERTHREAD_ROUTINE	Routine,
		_In_ PVOID	pContext
	)

Referenced by nfs41_CreateSrvCall(), and RxCancelRoutine().

RxInitializeDispatcher()

NTSTATUS NTAPI RxInitializeDispatcher

(

VOID

)

Definition at line 4688 of file rxce.c.

{
    NTSTATUS Status;
    HANDLE ThreadHandle;
 
    PAGED_CODE();
 
    RxFileSystemDeviceObject->DispatcherContext.NumberOfWorkerThreads = 0;
    RxFileSystemDeviceObject->DispatcherContext.pTearDownEvent = NULL;
 
    /* Set appropriate timeouts: 10s & 60s */
    RxWorkQueueWaitInterval[CriticalWorkQueue].QuadPart = -10 * 1000 * 1000 * 10;
    RxWorkQueueWaitInterval[DelayedWorkQueue].QuadPart = -10 * 1000 * 1000 * 10;
    RxWorkQueueWaitInterval[HyperCriticalWorkQueue].QuadPart = -10 * 1000 * 1000 * 10;
    RxSpinUpDispatcherWaitInterval.QuadPart = -60 * 1000 * 1000 * 10;
 
    RxDispatcher.NumberOfProcessors = 1;
    RxDispatcher.OwnerProcess = IoGetCurrentProcess();
    RxDispatcher.pWorkQueueDispatcher = &RxDispatcherWorkQueues;
 
    /* Initialize our dispatchers */
    Status = RxInitializeWorkQueueDispatcher(RxDispatcher.pWorkQueueDispatcher);
    if (!NT_SUCCESS(Status))
    {
        return Status;
    }
 
    Status = RxInitializeMRxDispatcher(RxFileSystemDeviceObject);
    if (!NT_SUCCESS(Status))
    {
        return Status;
    }
 
    /* And start them */
    RxDispatcher.State = RxDispatcherActive;
    InitializeListHead(&RxDispatcher.SpinUpRequests);
    KeInitializeSpinLock(&RxDispatcher.SpinUpRequestsLock);
    KeInitializeEvent(&RxDispatcher.SpinUpRequestsEvent, 0, 0);
    KeInitializeEvent(&RxDispatcher.SpinUpRequestsTearDownEvent, 0, 0);
    Status = PsCreateSystemThread(&ThreadHandle, PROCESS_ALL_ACCESS, NULL,
                                  NULL, NULL, RxSpinUpRequestsDispatcher, &RxDispatcher);
    if (NT_SUCCESS(Status))
    {
        ZwClose(ThreadHandle);
    }
 
    return Status;
}

Referenced by RxDriverEntry().

RxInitializeMRxDispatcher()

NTSTATUS RxInitializeMRxDispatcher

(

_Inout_ PRDBSS_DEVICE_OBJECT

pMRxDeviceObject

)

Referenced by RxStartMinirdr().

RxPostToWorkerThread()

NTSTATUS NTAPI RxPostToWorkerThread	(	_In_ PRDBSS_DEVICE_OBJECT	pMRxDeviceObject,
		_In_ WORK_QUEUE_TYPE	WorkQueueType,
		_In_ PRX_WORK_QUEUE_ITEM	pWorkQueueItem,
		_In_ PRX_WORKERTHREAD_ROUTINE	Routine,
		_In_ PVOID	pContext
	)

Definition at line 6400 of file rxce.c.

{
    /* Initialize work queue item */
    pWorkQueueItem->List.Flink = NULL;
    pWorkQueueItem->WorkerRoutine = Routine;
    pWorkQueueItem->Parameter = pContext;
 
    /* And insert it in the work queue */
    return RxInsertWorkQueueItem(pMRxDeviceObject, WorkQueueType, pWorkQueueItem);
}

Referenced by RxCompleteSrvOpenKeyAssociation(), RxpDispatchChangeBufferingStateRequests(), and RxTimerDispatch().