ReactOS 0.4.16-dev-297-gc569aee
fspdisp.c File Reference
#include "cdprocs.h"
Include dependency graph for fspdisp.c:

Go to the source code of this file.

Macros

#define BugCheckFileId   (CDFS_BUG_CHECK_FSPDISP)
 

Functions

VOID NTAPI CdFspDispatch (_In_ PVOID Context)
 

Macro Definition Documentation

◆ BugCheckFileId

#define BugCheckFileId   (CDFS_BUG_CHECK_FSPDISP)

Definition at line 23 of file fspdisp.c.

Function Documentation

◆ CdFspDispatch()

VOID NTAPI CdFspDispatch ( _In_ PVOID  Context)

Definition at line 28 of file fspdisp.c.

51{
52 THREAD_CONTEXT ThreadContext = {0};
53 PIRP_CONTEXT IrpContext = Context;
55
56 PIRP Irp = IrpContext->Irp;
58
60
61 //
62 // If this request has an associated volume device object, remember it.
63 //
64
65 if (IrpSp->FileObject != NULL) {
66
70 }
71
72 //
73 // Now case on the function code. For each major function code,
74 // either call the appropriate worker routine. This routine that
75 // we call is responsible for completing the IRP, and not us.
76 // That way the routine can complete the IRP and then continue
77 // post processing as required. For example, a read can be
78 // satisfied right away and then read can be done.
79 //
80 // We'll do all of the work within an exception handler that
81 // will be invoked if ever some underlying operation gets into
82 // trouble.
83 //
84
85 while ( TRUE ) {
86
87 //
88 // Set all the flags indicating we are in the Fsp.
89 //
90
91 SetFlag( IrpContext->Flags, IRP_CONTEXT_FSP_FLAGS );
92
94
95 CdSetThreadContext( IrpContext, &ThreadContext );
96
97 while (TRUE) {
98
99 _SEH2_TRY {
100
101 //
102 // Reinitialize for the next try at completing this
103 // request.
104 //
105
106 Status =
107 IrpContext->ExceptionStatus = STATUS_SUCCESS;
108
109 //
110 // Initialize the Io status field in the Irp.
111 //
112
113 Irp->IoStatus.Status = STATUS_SUCCESS;
114 Irp->IoStatus.Information = 0;
115
116 //
117 // Case on the major irp code.
118 //
119
120 switch (IrpContext->MajorFunction) {
121
122 case IRP_MJ_CREATE :
123
124 CdCommonCreate( IrpContext, Irp );
125 break;
126
127 case IRP_MJ_CLOSE :
128
129 NT_ASSERT( FALSE );
130 break;
131
132 case IRP_MJ_READ :
133
134 CdCommonRead( IrpContext, Irp );
135 break;
136
138
139 CdCommonQueryInfo( IrpContext, Irp );
140 break;
141
143
144 CdCommonSetInfo( IrpContext, Irp );
145 break;
146
148
149 CdCommonQueryVolInfo( IrpContext, Irp );
150 break;
151
153
154 CdCommonDirControl( IrpContext, Irp );
155 break;
156
158
159 CdCommonFsControl( IrpContext, Irp );
160 break;
161
163
164 CdCommonDevControl( IrpContext, Irp );
165 break;
166
168
169 CdCommonLockControl( IrpContext, Irp );
170 break;
171
172 case IRP_MJ_CLEANUP :
173
174 CdCommonCleanup( IrpContext, Irp );
175 break;
176
177 case IRP_MJ_PNP :
178
179 NT_ASSERT( FALSE );
180 CdCommonPnp( IrpContext, Irp );
181 break;
182
183 default :
184
186 CdCompleteRequest( IrpContext, Irp, Status );
187 }
188
190
191 Status = CdProcessException( IrpContext, Irp, _SEH2_GetExceptionCode() );
192 } _SEH2_END;
193
194 //
195 // Break out of the loop if we didn't get CANT_WAIT.
196 //
197
198 if (Status != STATUS_CANT_WAIT) { break; }
199
200 //
201 // We are retrying this request. Cleanup the IrpContext for the retry.
202 //
203
204 SetFlag( IrpContext->Flags, IRP_CONTEXT_FLAG_MORE_PROCESSING );
205 CdCleanupIrpContext( IrpContext, FALSE );
206 }
207
209
210 //
211 // If there are any entries on this volume's overflow queue, service
212 // them.
213 //
214
215 if (VolDo != NULL) {
216
217 KIRQL SavedIrql;
218 PVOID Entry = NULL;
219
220 //
221 // We have a volume device object so see if there is any work
222 // left to do in its overflow queue.
223 //
224
225 KeAcquireSpinLock( &VolDo->OverflowQueueSpinLock, &SavedIrql );
226
227 if (VolDo->OverflowQueueCount > 0) {
228
229 //
230 // There is overflow work to do in this volume so we'll
231 // decrement the Overflow count, dequeue the IRP, and release
232 // the Event
233 //
234
235 VolDo->OverflowQueueCount -= 1;
236
238
239 } else {
240
241 VolDo->PostedRequestCount -= 1;
242
243 Entry = NULL;
244 }
245
246 KeReleaseSpinLock( &VolDo->OverflowQueueSpinLock, SavedIrql );
247
248 //
249 // There wasn't an entry, break out of the loop and return to
250 // the Ex Worker thread.
251 //
252
253 if (Entry == NULL) {
254
255 break;
256 }
257
258 //
259 // Extract the IrpContext , Irp, set wait to TRUE, and loop.
260 //
261
262 IrpContext = CONTAINING_RECORD( Entry,
264 WorkQueueItem.List );
265
266 Irp = IrpContext->Irp;
268 __analysis_assert( IrpSp != 0 );
269
270 continue;
271 }
272
273 break;
274 }
275
276 return;
277}
static PIO_STACK_LOCATION IoGetCurrentIrpStackLocation(PIRP Irp)
LONG NTSTATUS
Definition: precomp.h:26
VOID CdCompleteRequest(_Inout_opt_ PIRP_CONTEXT IrpContext, _Inout_opt_ PIRP Irp, _In_ NTSTATUS Status)
Definition: cddata.c:914
LONG CdExceptionFilter(_Inout_ PIRP_CONTEXT IrpContext, _In_ PEXCEPTION_POINTERS ExceptionPointer)
Definition: cddata.c:525
VOID CdSetThreadContext(_Inout_ PIRP_CONTEXT IrpContext, _In_ PTHREAD_CONTEXT ThreadContext)
Definition: cddata.c:981
VOID CdCleanupIrpContext(_In_ PIRP_CONTEXT IrpContext, _In_ BOOLEAN Post)
Definition: strucsup.c:1733
NTSTATUS CdCommonLockControl(_Inout_ PIRP_CONTEXT IrpContext, _Inout_ PIRP Irp)
Definition: lockctrl.c:35
NTSTATUS CdCommonDevControl(_Inout_ PIRP_CONTEXT IrpContext, _Inout_ PIRP Irp)
Definition: devctrl.c:46
#define IRP_MJ_PNP
Definition: cdrw_usr.h:52
#define IRP_CONTEXT_FSP_FLAGS
Definition: cdstruc.h:1261
#define IRP_CONTEXT_FLAG_MORE_PROCESSING
Definition: cdstruc.h:1214
_In_ PIRP Irp
Definition: csq.h:116
#define NULL
Definition: types.h:112
#define TRUE
Definition: types.h:120
#define FALSE
Definition: types.h:117
_In_ PIO_STACK_LOCATION IrpSp
Definition: create.c:4137
UCHAR KIRQL
Definition: env_spec_w32.h:591
#define KeReleaseSpinLock(sl, irql)
Definition: env_spec_w32.h:627
#define KeAcquireSpinLock(sl, irql)
Definition: env_spec_w32.h:609
#define RemoveHeadList(ListHead)
Definition: env_spec_w32.h:964
#define SetFlag(_F, _SF)
Definition: ext2fs.h:187
#define FsRtlEnterFileSystem
#define FsRtlExitFileSystem
Status
Definition: gdiplustypes.h:25
#define STATUS_CANT_WAIT
Definition: ntstatus.h:452
#define _SEH2_GetExceptionCode()
Definition: pseh2_64.h:165
#define _SEH2_EXCEPT(...)
Definition: pseh2_64.h:66
#define _SEH2_GetExceptionInformation()
Definition: pseh2_64.h:164
#define _SEH2_END
Definition: pseh2_64.h:155
#define _SEH2_TRY
Definition: pseh2_64.h:55
#define IRP_MJ_DIRECTORY_CONTROL
Definition: rdpdr.c:51
#define IRP_MJ_CLOSE
Definition: rdpdr.c:45
#define IRP_MJ_READ
Definition: rdpdr.c:46
#define IRP_MJ_DEVICE_CONTROL
Definition: rdpdr.c:52
#define IRP_MJ_QUERY_VOLUME_INFORMATION
Definition: rdpdr.c:50
#define IRP_MJ_LOCK_CONTROL
Definition: rdpdr.c:53
#define IRP_MJ_SET_INFORMATION
Definition: rdpdr.c:49
#define IRP_MJ_CREATE
Definition: rdpdr.c:44
#define IRP_MJ_QUERY_INFORMATION
Definition: rdpdr.c:48
#define STATUS_SUCCESS
Definition: shellext.h:65
#define __analysis_assert(e)
Definition: specstrings.h:259
base of all file and directory entries
Definition: entries.h:83
PIRP Irp
Definition: usbstor.h:99
PFILE_OBJECT FileObject
Definition: iotypes.h:3169
PDEVICE_OBJECT DeviceObject
Definition: iotypes.h:3223
__volatile LONG PostedRequestCount
Definition: cdstruc.h:739
KSPIN_LOCK OverflowQueueSpinLock
Definition: cdstruc.h:760
LIST_ENTRY OverflowQueue
Definition: cdstruc.h:754
ULONG OverflowQueueCount
Definition: cdstruc.h:746
#define CONTAINING_RECORD(address, type, field)
Definition: typedefs.h:260
#define STATUS_INVALID_DEVICE_REQUEST
Definition: udferr_usr.h:138
_In_ PDEVICE_OBJECT DeviceObject
Definition: wdfdevice.h:2055
#define IRP_MJ_FILE_SYSTEM_CONTROL
#define IRP_MJ_CLEANUP
#define NT_ASSERT
Definition: rtlfuncs.h:3327