[dgorbachev] 42724: Synchronize with paging I/O.

Author: dgorbachev
Date: Sun Aug 16 03:20:50 2009
New Revision: 42724
URL: http://svn.reactos.org/svn/reactos?rev=42724&view=rev
Log:
Synchronize with paging I/O.
Modified:
    trunk/reactos/drivers/filesystems/ext2/src/close.c
Modified: trunk/reactos/drivers/filesystems/ext2/src/close.c
URL:
http://svn.reactos.org/svn/reactos/trunk/reactos/drivers/filesystems/ext2/s…
==============================================================================
--- trunk/reactos/drivers/filesystems/ext2/src/close.c [iso-8859-1] (original)
+++ trunk/reactos/drivers/filesystems/ext2/src/close.c [iso-8859-1] Sun Aug 16 03:20:50
2009
@@ -115,6 +115,7 @@
        PtrExt2VCB                              PtrVCB = NULL;
        PtrExt2NTRequiredFCB    PtrReqdFCB = NULL;
        PERESOURCE                              PtrResourceAcquired = NULL;
+       PERESOURCE                              PtrPagingIoResourceAcquired = NULL;
        BOOLEAN                                 CompleteIrp = TRUE;
        BOOLEAN                                 PostRequest = FALSE;
@@ -180,10 +181,11 @@
                {
                        DebugTrace(DEBUG_TRACE_FILE_OBJ, "###### File Pointer 0x%LX
[Close]", PtrFileObject);
                }
+
                i = 1;
                while( !AcquiredVCB )
                {
-                       DebugTraceState( "VCB       AC:0x%LX   SW:0x%LX   EX:0x%LX
[Close]", PtrVCB->VCBResource.ActiveCount,
PtrVCB->VCBResource.NumberOfExclusiveWaiters,
PtrVCB->VCBResource.NumberOfSharedWaiters );
+                       DebugTraceState( "VCB       AC:0x%LX   EX:0x%LX   SW:0x%LX
[Close]", PtrVCB->VCBResource.ActiveCount,
PtrVCB->VCBResource.NumberOfExclusiveWaiters,
PtrVCB->VCBResource.NumberOfSharedWaiters );
                        if(! ExAcquireResourceExclusiveLite(
&(PtrVCB->VCBResource), FALSE ) )
                        {
                                DebugTrace(DEBUG_TRACE_MISC,   "*** VCB Acquisition
FAILED [Close]", 0);
@@ -231,13 +233,14 @@
                        {
                                DebugTrace(DEBUG_TRACE_FILE_OBJ,  "###### File
Pointer 0x%LX [Close]", PtrFileObject);
                        }
+
+                       PtrReqdFCB = &PtrFCB->NTRequiredFCB;
+
                        i = 1;
                        while( !PtrResourceAcquired )
                        {
-                               PtrReqdFCB = &(PtrFCB->NTRequiredFCB);
-
-                               DebugTraceState( "FCBMain   AC:0x%LX   SW:0x%LX
EX:0x%LX   [Close]", PtrReqdFCB->MainResource.ActiveCount,
PtrReqdFCB->MainResource.NumberOfExclusiveWaiters,
PtrReqdFCB->MainResource.NumberOfSharedWaiters );
-                               if(! ExAcquireResourceExclusiveLite(
&(PtrFCB->NTRequiredFCB.MainResource ), FALSE ) )
+                               DebugTraceState( "FCBMain   AC:0x%LX   EX:0x%LX
SW:0x%LX   [Close]", PtrReqdFCB->MainResource.ActiveCount,
PtrReqdFCB->MainResource.NumberOfExclusiveWaiters,
PtrReqdFCB->MainResource.NumberOfSharedWaiters );
+                               if(! ExAcquireResourceExclusiveLite(
&(PtrReqdFCB->MainResource), FALSE ) )
                                {
                                        DebugTrace(DEBUG_TRACE_MISC,   "*** FCB
Acquisition FAILED [Close]", 0);
                                        if( BlockForResource && i != 1000 )
@@ -261,7 +264,40 @@
                                else
                                {
                                        DebugTrace(DEBUG_TRACE_MISC,  "*** FCB
acquired [Close]", 0);
-                                       PtrResourceAcquired = & (
PtrFCB->NTRequiredFCB.MainResource );
+                                       PtrResourceAcquired = & (
PtrReqdFCB->MainResource );
+                               }
+                               i *= 10;
+                       }
+
+                       i = 1;
+                       while( !PtrPagingIoResourceAcquired )
+                       {
+                               DebugTraceState( "FCBPaging   AC:0x%LX   EX:0x%LX
SW:0x%LX   [Close]", PtrReqdFCB->PagingIoResource.ActiveCount,
PtrReqdFCB->PagingIoResource.NumberOfExclusiveWaiters,
PtrReqdFCB->PagingIoResource.NumberOfSharedWaiters );
+                               if(! ExAcquireResourceExclusiveLite(
&(PtrReqdFCB->PagingIoResource), FALSE ) )
+                               {
+                                       DebugTrace(DEBUG_TRACE_MISC,   "*** FCB
Acquisition FAILED [Close]", 0);
+                                       if( BlockForResource && i != 1000 )
+                                       {
+                                               LARGE_INTEGER Delay;
+
+                                               // KeSetPriorityThread(
PsGetCurrentThread(), LOW_REALTIME_PRIORITY );
+
+                                               Delay.QuadPart = -500 * i;
+                                               KeDelayExecutionThread( KernelMode, FALSE,
&Delay );
+                                               DebugTrace(DEBUG_TRACE_MISC,  "***
Retrying... after 50 * %ld ms [Close]", i);
+                                       }
+                                       else
+                                       {
+                                               if( i == 1000 )
+                                                       DebugTrace(DEBUG_TRACE_MISC,
"*** Reposting... [Close]", 0 );
+                                               PostRequest = TRUE;
+                                               try_return( RC = STATUS_PENDING );
+                                       }
+                               }
+                               else
+                               {
+                                       DebugTrace(DEBUG_TRACE_MISC,  "*** FCB
acquired [Close]", 0);
+                                       PtrPagingIoResourceAcquired = & (
PtrReqdFCB->PagingIoResource );
                                }
                                i *= 10;
                        }
@@ -372,11 +408,22 @@
                                        DebugTrace(DEBUG_TRACE_MISC,  "^^^^^Deleting
FCB  [Close]", 0);
                                        RemoveEntryList( &PtrFCB->NextFCB );
+                                       if ( PtrPagingIoResourceAcquired )
+                                       {
+
Ext2ReleaseResource(PtrPagingIoResourceAcquired);
+                                               DebugTraceState( "Resource
AC:0x%LX   EX:0x%LX   SW:0x%LX   [Close]",
+
PtrPagingIoResourceAcquired->ActiveCount,
+
PtrPagingIoResourceAcquired->NumberOfExclusiveWaiters,
+
PtrPagingIoResourceAcquired->NumberOfSharedWaiters );
+
+                                               PtrPagingIoResourceAcquired = NULL;
+                                       }
+
                                        if ( PtrResourceAcquired )
                                        {
                                                Ext2ReleaseResource(PtrResourceAcquired);
                                                DebugTrace(DEBUG_TRACE_MISC,  "***
FCB Released [Close]", 0);
-                                               DebugTraceState( "Resource
AC:0x%LX   SW:0x%LX   EX:0x%LX   [Close]",
+                                               DebugTraceState( "Resource
AC:0x%LX   EX:0x%LX   SW:0x%LX   [Close]",
PtrResourceAcquired->ActiveCount,
PtrResourceAcquired->NumberOfExclusiveWaiters,
PtrResourceAcquired->NumberOfSharedWaiters );
@@ -385,8 +432,9 @@
                                                {
                                                        DebugTrace(DEBUG_TRACE_FILE_OBJ,
"###### File Pointer 0x%LX [Close]", PtrFileObject);
                                                }
-                                               PtrResourceAcquired = FALSE;
-                                       }
+                                               PtrResourceAcquired = NULL;
+                                       }
+
                                        Ext2ReleaseFCB( PtrFCB );
                                }
@@ -407,11 +455,22 @@
        }
        finally
        {
+               if ( PtrPagingIoResourceAcquired )
+               {
+                       Ext2ReleaseResource(PtrPagingIoResourceAcquired);
+                       DebugTraceState( "Resource     AC:0x%LX   EX:0x%LX   SW:0x%LX
[Close]",
+                               PtrPagingIoResourceAcquired->ActiveCount,
+                               PtrPagingIoResourceAcquired->NumberOfExclusiveWaiters,
+                               PtrPagingIoResourceAcquired->NumberOfSharedWaiters );
+
+                       PtrPagingIoResourceAcquired = NULL;
+               }
+
                if ( PtrResourceAcquired )
                {
                        Ext2ReleaseResource(PtrResourceAcquired);
                        DebugTrace(DEBUG_TRACE_MISC,  "*** FCB Released
[Close]", 0);
-                       DebugTraceState( "Resource     AC:0x%LX   SW:0x%LX   EX:0x%LX
[Close]",
+                       DebugTraceState( "Resource     AC:0x%LX   EX:0x%LX   SW:0x%LX
[Close]",
                                PtrResourceAcquired->ActiveCount,
                                PtrResourceAcquired->NumberOfExclusiveWaiters,
                                PtrResourceAcquired->NumberOfSharedWaiters );
@@ -420,14 +479,14 @@
                        {
                                DebugTrace(DEBUG_TRACE_FILE_OBJ, "###### File Pointer
0x%LX [Close]", PtrFileObject);
                        }
-                       PtrResourceAcquired = FALSE;
+                       PtrResourceAcquired = NULL;
                }
                if (AcquiredVCB)
                {
                        ASSERT(PtrVCB);
                        Ext2ReleaseResource(&(PtrVCB->VCBResource));
-                       DebugTraceState( "VCB       AC:0x%LX   SW:0x%LX   EX:0x%LX
[Close]", PtrVCB->VCBResource.ActiveCount,
PtrVCB->VCBResource.NumberOfExclusiveWaiters,
PtrVCB->VCBResource.NumberOfSharedWaiters );
+                       DebugTraceState( "VCB       AC:0x%LX   EX:0x%LX   SW:0x%LX
[Close]", PtrVCB->VCBResource.ActiveCount,
PtrVCB->VCBResource.NumberOfExclusiveWaiters,
PtrVCB->VCBResource.NumberOfSharedWaiters );
                        DebugTrace(DEBUG_TRACE_MISC,   "*** VCB Released
[Close]", 0);
                        AcquiredVCB = FALSE;