Something went wrong. Try again.
Reactos
Something went wrong. Try again.
9.2 kB · 422 lines
C
at master
123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423/*++
Copyright (c) 1989-2000 Microsoft Corporation
Module Name:
WorkQue.c
Abstract:
This module implements the Work queue routines for the Cdfs File system.
--*/
#include "cdprocs.h"
//// The Bug check file id for this module//
#define BugCheckFileId (CDFS_BUG_CHECK_WORKQUE)
//// The following constant is the maximum number of ExWorkerThreads that we// will allow to be servicing a particular target device at any one time.//
#define FSP_PER_DEVICE_THRESHOLD (2)
//// Local support routines//
VOIDCdAddToWorkque ( _Inout_ PIRP_CONTEXT IrpContext, _Inout_ PIRP Irp );
#ifdef ALLOC_PRAGMA#pragma alloc_text(PAGE, CdFsdPostRequest)#pragma alloc_text(PAGE, CdOplockComplete)#pragma alloc_text(PAGE, CdPrePostIrp)#endif
_Requires_lock_held_(_Global_critical_region_)NTSTATUSCdFsdPostRequest ( _Inout_ PIRP_CONTEXT IrpContext, _Inout_ PIRP Irp )
/*++
Routine Description:
This routine enqueues the request packet specified by IrpContext to the work queue associated with the FileSystemDeviceObject. This is a FSD routine.
Arguments:
IrpContext - Pointer to the IrpContext to be queued to the Fsp.
Irp - I/O Request Packet.
Return Value:
STATUS_PENDING
--*/
{ PAGED_CODE();
ASSERT_IRP_CONTEXT( IrpContext ); ASSERT_IRP( Irp );
// // Posting is a three step operation. First lock down any buffers // in the Irp. Next cleanup the IrpContext for the post and finally // add this to a workque. //
CdPrePostIrp( IrpContext, Irp );
CdAddToWorkque( IrpContext, Irp );
// // And return to our caller //
return STATUS_PENDING;}
_Requires_lock_held_(_Global_critical_region_)VOIDNTAPI /* ReactOS Change: GCC Does not support STDCALL by default */CdPrePostIrp ( _Inout_ PIRP_CONTEXT IrpContext, _Inout_ PIRP Irp )
/*++
Routine Description:
This routine performs any neccessary work before STATUS_PENDING is returned with the Fsd thread. This routine is called within the filesystem and by the oplock package.
Arguments:
Context - Pointer to the IrpContext to be queued to the Fsp
Irp - I/O Request Packet.
Return Value:
None.
--*/
{ PIO_STACK_LOCATION IrpSp = IoGetCurrentIrpStackLocation( Irp ); BOOLEAN RemovedFcb;
PAGED_CODE();
ASSERT_IRP_CONTEXT( IrpContext ); ASSERT_IRP( Irp );
// // Case on the type of the operation. //
switch (IrpContext->MajorFunction) {
case IRP_MJ_CREATE :
// // If called from the oplock package then there is an // Fcb to possibly teardown. We will call the teardown // routine and release the Fcb if still present. The cleanup // code in create will know not to release this Fcb because // we will clear the pointer. //
if ((IrpContext->TeardownFcb != NULL) && *(IrpContext->TeardownFcb) != NULL) {
CdTeardownStructures( IrpContext, *(IrpContext->TeardownFcb), &RemovedFcb );
if (!RemovedFcb) {
_Analysis_assume_lock_held_((*IrpContext->TeardownFcb)->FcbNonpaged->FcbResource); CdReleaseFcb( IrpContext, *(IrpContext->TeardownFcb) ); }
*(IrpContext->TeardownFcb) = NULL; IrpContext->TeardownFcb = NULL; }
break;
// // We need to lock the user's buffer, unless this is an MDL read/write, // in which case there is no user buffer. //
case IRP_MJ_READ :
if (!FlagOn( IrpContext->MinorFunction, IRP_MN_MDL )) {
CdLockUserBuffer( IrpContext, IrpSp->Parameters.Read.Length, IoWriteAccess ); }
break;
case IRP_MJ_WRITE :
if (!FlagOn( IrpContext->MinorFunction, IRP_MN_MDL )) {
CdLockUserBuffer( IrpContext, IrpSp->Parameters.Read.Length, IoReadAccess ); }
break;
// // We also need to check whether this is a query file operation. //
case IRP_MJ_DIRECTORY_CONTROL :
if (IrpContext->MinorFunction == IRP_MN_QUERY_DIRECTORY) {
CdLockUserBuffer( IrpContext, IrpSp->Parameters.QueryDirectory.Length, IoWriteAccess ); }
break; }
// // Cleanup the IrpContext for the post. //
SetFlag( IrpContext->Flags, IRP_CONTEXT_FLAG_MORE_PROCESSING ); CdCleanupIrpContext( IrpContext, TRUE );
// // Mark the Irp to show that we've already returned pending to the user. //
IoMarkIrpPending( Irp );
return;}
_Requires_lock_held_(_Global_critical_region_)VOIDNTAPI /* ReactOS Change: GCC Does not support STDCALL by default */CdOplockComplete ( _Inout_ PIRP_CONTEXT IrpContext, _Inout_ PIRP Irp )
/*++
Routine Description:
This routine is called by the oplock package when an oplock break has completed, allowing an Irp to resume execution. If the status in the Irp is STATUS_SUCCESS, then we queue the Irp to the Fsp queue. Otherwise we complete the Irp with the status in the Irp.
If we are completing due to an error then check if there is any cleanup to do.
Arguments:
Irp - I/O Request Packet.
Return Value:
None.
--*/
{ BOOLEAN RemovedFcb;
PAGED_CODE();
// // Check on the return value in the Irp. If success then we // are to post this request. //
if (Irp->IoStatus.Status == STATUS_SUCCESS) {
// // Check if there is any cleanup work to do. //
switch (IrpContext->MajorFunction) {
case IRP_MJ_CREATE :
// // If called from the oplock package then there is an // Fcb to possibly teardown. We will call the teardown // routine and release the Fcb if still present. The cleanup // code in create will know not to release this Fcb because // we will clear the pointer. //
if (IrpContext->TeardownFcb != NULL) {
CdTeardownStructures( IrpContext, *(IrpContext->TeardownFcb), &RemovedFcb );
if (!RemovedFcb) {
_Analysis_assume_lock_held_((*IrpContext->TeardownFcb)->FcbNonpaged->FcbResource); CdReleaseFcb( IrpContext, *(IrpContext->TeardownFcb) ); }
*(IrpContext->TeardownFcb) = NULL; IrpContext->TeardownFcb = NULL; }
break; }
// // Insert the Irp context in the workqueue. //
CdAddToWorkque( IrpContext, Irp );
// // Otherwise complete the request. //
} else {
CdCompleteRequest( IrpContext, Irp, Irp->IoStatus.Status ); }
return;}
//// Local support routine//
VOIDCdAddToWorkque ( _Inout_ PIRP_CONTEXT IrpContext, _Inout_ PIRP Irp )
/*++
Routine Description:
This routine is called to acually store the posted Irp to the Fsp workque.
Arguments:
IrpContext - Pointer to the IrpContext to be queued to the Fsp
Irp - I/O Request Packet.
Return Value:
None.
--*/
{ PVOLUME_DEVICE_OBJECT Vdo; KIRQL SavedIrql; PIO_STACK_LOCATION IrpSp = IoGetCurrentIrpStackLocation( Irp );
// // Check if this request has an associated file object, and thus volume // device object. //
if (IrpSp->FileObject != NULL) {
Vdo = CONTAINING_RECORD( IrpSp->DeviceObject, VOLUME_DEVICE_OBJECT, DeviceObject );
// // Check to see if this request should be sent to the overflow // queue. If not, then send it off to an exworker thread. //
KeAcquireSpinLock( &Vdo->OverflowQueueSpinLock, &SavedIrql );
if (Vdo->PostedRequestCount > FSP_PER_DEVICE_THRESHOLD) {
// // We cannot currently respond to this IRP so we'll just enqueue it // to the overflow queue on the volume. //
InsertTailList( &Vdo->OverflowQueue, &IrpContext->WorkQueueItem.List );
Vdo->OverflowQueueCount += 1;
KeReleaseSpinLock( &Vdo->OverflowQueueSpinLock, SavedIrql );
return;
} else {
// // We are going to send this Irp to an ex worker thread so up // the count. //
Vdo->PostedRequestCount += 1;
KeReleaseSpinLock( &Vdo->OverflowQueueSpinLock, SavedIrql ); } }
// // Send it off..... //
#ifdef _MSC_VER#pragma prefast(suppress:28155, "the function prototype is correct")#endif ExInitializeWorkItem( &IrpContext->WorkQueueItem, (PVOID)CdFspDispatch,/* ReactOS Change: GCC "assignment from incompatible pointer type" */ IrpContext );
#ifdef _MSC_VER#pragma prefast(suppress: 28159, "prefast believes this routine is obsolete, but it is ok for CDFS to continue using it")#endif ExQueueWorkItem( &IrpContext->WorkQueueItem, CriticalWorkQueue );
return;}