ReactOS 0.4.15-dev-7988-g06a3508
Classes | Typedefs | Enumerations | Functions
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.

66{
67 RxDispatcherActive,
68 RxDispatcherInactive
69} RX_DISPATCHER_STATE, *PRX_DISPATCHER_STATE;
RX_DISPATCHER_STATE
enum _RX_DISPATCHER_STATE_ RX_DISPATCHER_STATE
PRX_DISPATCHER_STATE
enum _RX_DISPATCHER_STATE_ * PRX_DISPATCHER_STATE
RxDispatcherActive
@ RxDispatcherActive
Definition: rxworkq.h:67
RxDispatcherInactive
@ RxDispatcherInactive
Definition: rxworkq.h:68

◆ _RX_WORK_QUEUE_STATE_

enum _RX_WORK_QUEUE_STATE_
Enumerator
RxWorkQueueActive 
RxWorkQueueInactive 
RxWorkQueueRundownInProgress 

Definition at line 22 of file rxworkq.h.

23{
24 RxWorkQueueActive,
25 RxWorkQueueInactive,
26 RxWorkQueueRundownInProgress
27} RX_WORK_QUEUE_STATE, *PRX_WORK_QUEUE_STATE;
PRX_WORK_QUEUE_STATE
enum _RX_WORK_QUEUE_STATE_ * PRX_WORK_QUEUE_STATE
RxWorkQueueRundownInProgress
@ RxWorkQueueRundownInProgress
Definition: rxworkq.h:26
RxWorkQueueActive
@ RxWorkQueueActive
Definition: rxworkq.h:24
RxWorkQueueInactive
@ RxWorkQueueInactive
Definition: rxworkq.h:25
RX_WORK_QUEUE_STATE
enum _RX_WORK_QUEUE_STATE_ RX_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.

4690{
4691 NTSTATUS Status;
4692 HANDLE ThreadHandle;
4693
4694 PAGED_CODE();
4695
4696 RxFileSystemDeviceObject->DispatcherContext.NumberOfWorkerThreads = 0;
4697 RxFileSystemDeviceObject->DispatcherContext.pTearDownEvent = NULL;
4698
4699 /* Set appropriate timeouts: 10s & 60s */
4700 RxWorkQueueWaitInterval[CriticalWorkQueue].QuadPart = -10 * 1000 * 1000 * 10;
4701 RxWorkQueueWaitInterval[DelayedWorkQueue].QuadPart = -10 * 1000 * 1000 * 10;
4702 RxWorkQueueWaitInterval[HyperCriticalWorkQueue].QuadPart = -10 * 1000 * 1000 * 10;
4703 RxSpinUpDispatcherWaitInterval.QuadPart = -60 * 1000 * 1000 * 10;
4704
4705 RxDispatcher.NumberOfProcessors = 1;
4706 RxDispatcher.OwnerProcess = IoGetCurrentProcess();
4707 RxDispatcher.pWorkQueueDispatcher = &RxDispatcherWorkQueues;
4708
4709 /* Initialize our dispatchers */
4710 Status = RxInitializeWorkQueueDispatcher(RxDispatcher.pWorkQueueDispatcher);
4711 if (!NT_SUCCESS(Status))
4712 {
4713 return Status;
4714 }
4715
4716 Status = RxInitializeMRxDispatcher(RxFileSystemDeviceObject);
4717 if (!NT_SUCCESS(Status))
4718 {
4719 return Status;
4720 }
4721
4722 /* And start them */
4723 RxDispatcher.State = RxDispatcherActive;
4724 InitializeListHead(&RxDispatcher.SpinUpRequests);
4725 KeInitializeSpinLock(&RxDispatcher.SpinUpRequestsLock);
4726 KeInitializeEvent(&RxDispatcher.SpinUpRequestsEvent, 0, 0);
4727 KeInitializeEvent(&RxDispatcher.SpinUpRequestsTearDownEvent, 0, 0);
4728 Status = PsCreateSystemThread(&ThreadHandle, PROCESS_ALL_ACCESS, NULL,
4729 NULL, NULL, RxSpinUpRequestsDispatcher, &RxDispatcher);
4730 if (NT_SUCCESS(Status))
4731 {
4732 ZwClose(ThreadHandle);
4733 }
4734
4735 return Status;
4736}
PAGED_CODE
#define PAGED_CODE()
Definition: Bus_PDO_EvalMethod.c:87
NTSTATUS
LONG NTSTATUS
Definition: precomp.h:26
NULL
#define NULL
Definition: types.h:112
NT_SUCCESS
#define NT_SUCCESS(StatCode)
Definition: apphelp.c:32
KeInitializeEvent
#define KeInitializeEvent(pEvt, foo, foo2)
Definition: env_spec_w32.h:477
InitializeListHead
#define InitializeListHead(ListHead)
Definition: env_spec_w32.h:944
KeInitializeSpinLock
#define KeInitializeSpinLock(sl)
Definition: env_spec_w32.h:604
Status
Status
Definition: gdiplustypes.h:25
ZwClose
NTSYSAPI NTSTATUS NTAPI ZwClose(_In_ HANDLE Handle)
PROCESS_ALL_ACCESS
#define PROCESS_ALL_ACCESS
Definition: nt_native.h:1324
IoGetCurrentProcess
PEPROCESS NTAPI IoGetCurrentProcess(VOID)
Definition: util.c:139
PsCreateSystemThread
NTSTATUS NTAPI PsCreateSystemThread(OUT PHANDLE ThreadHandle, IN ACCESS_MASK DesiredAccess, IN POBJECT_ATTRIBUTES ObjectAttributes, IN HANDLE ProcessHandle, IN PCLIENT_ID ClientId, IN PKSTART_ROUTINE StartRoutine, IN PVOID StartContext)
Definition: thread.c:602
RxInitializeWorkQueueDispatcher
NTSTATUS RxInitializeWorkQueueDispatcher(PRX_WORK_QUEUE_DISPATCHER Dispatcher)
Definition: rxce.c:5090
RxSpinUpRequestsDispatcher
VOID NTAPI RxSpinUpRequestsDispatcher(PVOID Dispatcher)
Definition: rxce.c:8039
RxWorkQueueWaitInterval
LARGE_INTEGER RxWorkQueueWaitInterval[RxMaximumWorkQueue]
Definition: rxce.c:132
RxInitializeMRxDispatcher
NTSTATUS RxInitializeMRxDispatcher(IN OUT PRDBSS_DEVICE_OBJECT pMRxDeviceObject)
Definition: rxce.c:4860
RxDispatcher
RX_DISPATCHER RxDispatcher
Definition: rxce.c:134
RxDispatcherWorkQueues
RX_WORK_QUEUE_DISPATCHER RxDispatcherWorkQueues
Definition: rxce.c:135
RxSpinUpDispatcherWaitInterval
LARGE_INTEGER RxSpinUpDispatcherWaitInterval
Definition: rxce.c:133
RxFileSystemDeviceObject
PRDBSS_DEVICE_OBJECT RxFileSystemDeviceObject
Definition: rdbss.c:573
_RDBSS_DEVICE_OBJECT::DispatcherContext
RX_DISPATCHER_CONTEXT DispatcherContext
Definition: rxstruc.h:126
_RX_DISPATCHER_CONTEXT_::pTearDownEvent
volatile PKEVENT pTearDownEvent
Definition: rxstruc.h:67
_RX_DISPATCHER_CONTEXT_::NumberOfWorkerThreads
volatile LONG NumberOfWorkerThreads
Definition: rxstruc.h:66
_RX_DISPATCHER_::NumberOfProcessors
LONG NumberOfProcessors
Definition: rxworkq.h:73
_RX_DISPATCHER_::pWorkQueueDispatcher
PRX_WORK_QUEUE_DISPATCHER pWorkQueueDispatcher
Definition: rxworkq.h:75
_RX_DISPATCHER_::OwnerProcess
PEPROCESS OwnerProcess
Definition: rxworkq.h:74
_RX_DISPATCHER_::SpinUpRequestsTearDownEvent
KEVENT SpinUpRequestsTearDownEvent
Definition: rxworkq.h:80
_RX_DISPATCHER_::State
RX_DISPATCHER_STATE State
Definition: rxworkq.h:76
_RX_DISPATCHER_::SpinUpRequests
LIST_ENTRY SpinUpRequests
Definition: rxworkq.h:77
_RX_DISPATCHER_::SpinUpRequestsLock
KSPIN_LOCK SpinUpRequestsLock
Definition: rxworkq.h:78
_RX_DISPATCHER_::SpinUpRequestsEvent
KEVENT SpinUpRequestsEvent
Definition: rxworkq.h:79
_LARGE_INTEGER::QuadPart
LONGLONG QuadPart
Definition: typedefs.h:114
DelayedWorkQueue
@ DelayedWorkQueue
Definition: extypes.h:190
CriticalWorkQueue
@ CriticalWorkQueue
Definition: extypes.h:189
HyperCriticalWorkQueue
@ HyperCriticalWorkQueue
Definition: extypes.h:191

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.

6406{
6407 /* Initialize work queue item */
6408 pWorkQueueItem->List.Flink = NULL;
6409 pWorkQueueItem->WorkerRoutine = Routine;
6410 pWorkQueueItem->Parameter = pContext;
6411
6412 /* And insert it in the work queue */
6413 return RxInsertWorkQueueItem(pMRxDeviceObject, WorkQueueType, pWorkQueueItem);
6414}
RxInsertWorkQueueItem
NTSTATUS RxInsertWorkQueueItem(PRDBSS_DEVICE_OBJECT pMRxDeviceObject, WORK_QUEUE_TYPE WorkQueueType, PRX_WORK_QUEUE_ITEM WorkQueueItem)
Definition: rxce.c:5161

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