AFSCleanup( IN PDEVICE_OBJECT LibDeviceObject,
IN PIRP Irp)
{
-
+ UNREFERENCED_PARAMETER(LibDeviceObject);
NTSTATUS ntStatus = STATUS_SUCCESS;
AFSDeviceExt *pDeviceExt = NULL;
IO_STACK_LOCATION *pIrpSp = IoGetCurrentIrpStackLocation( Irp);
AFSDeviceExt *pControlDeviceExt = NULL;
IO_STATUS_BLOCK stIoSB;
AFSObjectInfoCB *pObjectInfo = NULL;
+ AFSObjectInfoCB *pParentObjectInfo = NULL;
AFSFileCleanupCB stFileCleanup;
AFSFileCleanupResultCB *pResultCB = NULL;
ULONG ulResultLen = 0;
}
pDeviceExt = (AFSDeviceExt *)AFSRDRDeviceObject->DeviceExtension;
+
pControlDeviceExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
//
AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup Acquiring GlobalRoot lock %08lX EXCL %08lX\n",
+ "AFSCleanup Acquiring GlobalRoot lock %p EXCL %08lX\n",
&pFcb->NPFcb->Resource,
PsGetCurrentThread());
AFSAcquireExcl( &pFcb->NPFcb->Resource,
TRUE);
- ASSERT( pFcb->OpenHandleCount != 0);
+ FsRtlNotifyCleanup( pControlDeviceExt->Specific.Control.NotifySync,
+ &pControlDeviceExt->Specific.Control.DirNotifyList,
+ pCcb);
- AFSReleaseResource( &pFcb->NPFcb->Resource);
+ ASSERT( pFcb->OpenHandleCount != 0);
lCount = InterlockedDecrement( &pFcb->OpenHandleCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup (RootAll) Decrement handle count on Fcb %08lX Cnt %d\n",
+ "AFSCleanup (RootAll) Decrement handle count on Fcb %p Cnt %d\n",
pFcb,
lCount);
- FsRtlNotifyCleanup( pControlDeviceExt->Specific.Control.NotifySync,
- &pControlDeviceExt->Specific.Control.DirNotifyList,
- pCcb);
+ AFSReleaseResource( &pFcb->NPFcb->Resource);
break;
}
AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup Acquiring PIOCtl lock %08lX EXCL %08lX\n",
+ "AFSCleanup Acquiring PIOCtl lock %p EXCL %08lX\n",
&pFcb->NPFcb->Resource,
PsGetCurrentThread());
lCount = InterlockedDecrement( &pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup (IOCtl) Decrement child open handle count on Parent object %08lX Cnt %d\n",
+ "AFSCleanup (IOCtl) Decrement child open handle count on Parent object %p Cnt %d\n",
pObjectInfo->ParentObjectInformation,
lCount);
}
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup (IOCtl) Decrement handle count on Fcb %08lX Cnt %d\n",
+ "AFSCleanup (IOCtl) Decrement handle count on Fcb %p Cnt %d\n",
pFcb,
lCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup Acquiring Fcb lock %08lX EXCL %08lX\n",
- &pFcb->NPFcb->Resource,
+ "AFSCleanup Acquiring Fcb SectionObject lock %p EXCL %08lX\n",
+ &pFcb->NPFcb->SectionObjectResource,
PsGetCurrentThread());
- AFSAcquireExcl( &pFcb->NPFcb->Resource,
+ AFSAcquireExcl( &pFcb->NPFcb->SectionObjectResource,
TRUE);
//
// If the handle has write permission ...
//
- if( (pCcb->GrantedAccess & FILE_WRITE_DATA) &&
+ if( ((pCcb->GrantedAccess & FILE_WRITE_DATA) || pFcb->OpenHandleCount == 1) &&
CcIsFileCached( pIrpSp->FileObject))
{
ntStatus = stIoSB.Status;
}
+
+ if ( ( pFcb->OpenHandleCount == 1 ||
+ BooleanFlagOn( pFcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE)) &&
+ pFcb->NPFcb->SectionObjectPointers.DataSectionObject != NULL)
+ {
+
+ if ( !CcPurgeCacheSection( &pFcb->NPFcb->SectionObjectPointers,
+ NULL,
+ 0,
+ FALSE))
+ {
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_IO_PROCESSING,
+ AFS_TRACE_LEVEL_WARNING,
+ "AFSCleanup CcPurgeCacheSection failure FID %08lX-%08lX-%08lX-%08lX\n",
+ pObjectInfo->FileId.Cell,
+ pObjectInfo->FileId.Volume,
+ pObjectInfo->FileId.Vnode,
+ pObjectInfo->FileId.Unique);
+
+ SetFlag( pObjectInfo->Fcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
+ }
+ else
+ {
+ ClearFlag( pObjectInfo->Fcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
+ }
+ }
}
__except( EXCEPTION_EXECUTE_HANDLER)
{
ntStatus = GetExceptionCode();
+
+ AFSDbgLogMsg( 0,
+ 0,
+ "EXCEPTION - AFSCleanup Cc FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX\n",
+ pObjectInfo->FileId.Cell,
+ pObjectInfo->FileId.Volume,
+ pObjectInfo->FileId.Vnode,
+ pObjectInfo->FileId.Unique,
+ ntStatus);
+
+ SetFlag( pObjectInfo->Fcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
}
}
AFSDbgLogMsg( AFS_SUBSYSTEM_IO_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup Tearing down cache map for Fcb %08lX FileObject %08lX\n",
+ "AFSCleanup Tearing down cache map for Fcb %p FileObject %p\n",
pFcb,
pFileObject);
NULL,
NULL);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSCleanup Releasing Fcb SectionObject lock %p EXCL %08lX\n",
+ &pFcb->NPFcb->SectionObjectResource,
+ PsGetCurrentThread());
+
+ AFSReleaseResource( &pFcb->NPFcb->SectionObjectResource);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSCleanup Acquiring Fcb lock %p EXCL %08lX\n",
+ &pFcb->NPFcb->Resource,
+ PsGetCurrentThread());
+
+ AFSAcquireExcl( &pFcb->NPFcb->Resource,
+ TRUE);
+
//
// Unlock all outstanding locks on the file, again, unconditionally
//
BooleanFlagOn( pCcb->DirectoryCB->Flags, AFS_DIR_ENTRY_PENDING_DELETE))
{
- //
- // Stop anything possibly in process
- //
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup Acquiring Fcb extents lock %08lX EXCL %08lX\n",
- &pFcb->NPFcb->Specific.File.ExtentsResource,
- PsGetCurrentThread());
-
- AFSAcquireExcl( &pObjectInfo->Fcb->NPFcb->Specific.File.ExtentsResource,
- TRUE);
-
- pObjectInfo->Fcb->NPFcb->Specific.File.ExtentsRequestStatus = STATUS_FILE_DELETED;
-
- KeSetEvent( &pObjectInfo->Fcb->NPFcb->Specific.File.ExtentsRequestComplete,
- 0,
- FALSE);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup Releasing Fcb extents lock %08lX EXCL %08lX\n",
- &pFcb->NPFcb->Specific.File.ExtentsResource,
- PsGetCurrentThread());
-
- AFSReleaseResource( &pObjectInfo->Fcb->NPFcb->Specific.File.ExtentsResource);
-
- //
- // Before telling the server about the deleted file, tear down all extents for
- // the file
- //
-
- AFSTearDownFcbExtents( pFcb,
- &pCcb->AuthGroup);
-
ntStatus = STATUS_SUCCESS;
ulNotificationFlags |= AFS_REQUEST_FLAG_FILE_DELETED;
ntStatus = STATUS_SUCCESS;
+ if ( --pObjectInfo->Links < 1)
+ {
+
+ //
+ // Stop anything possibly in process
+ //
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSCleanup Acquiring Fcb extents lock %p EXCL %08lX\n",
+ &pFcb->NPFcb->Specific.File.ExtentsResource,
+ PsGetCurrentThread());
+
+ AFSAcquireExcl( &pFcb->NPFcb->Specific.File.ExtentsResource,
+ TRUE);
+
+ pFcb->NPFcb->Specific.File.ExtentsRequestStatus = STATUS_FILE_DELETED;
+
+ KeSetEvent( &pFcb->NPFcb->Specific.File.ExtentsRequestComplete,
+ 0,
+ FALSE);
+
+ //
+ // The file has been deleted since the Link count is zero
+ //
+
+ AFSDeleteFcbExtents( pFcb);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSCleanup Releasing Fcb extents lock %p EXCL %08lX\n",
+ &pFcb->NPFcb->Specific.File.ExtentsResource,
+ PsGetCurrentThread());
+
+ AFSReleaseResource( &pFcb->NPFcb->Specific.File.ExtentsResource);
+ }
+
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSCleanup Setting DELETE flag in file %wZ Dir Entry %p\n",
SetFlag( pCcb->DirectoryCB->Flags, AFS_DIR_ENTRY_DELETED);
- ASSERT( pObjectInfo->ParentObjectInformation != NULL);
+ ClearFlag( pCcb->DirectoryCB->Flags, AFS_DIR_ENTRY_PENDING_DELETE);
+
+ pParentObjectInfo = pObjectInfo->ParentObjectInformation;
+
+ ASSERT( pParentObjectInfo != NULL);
- AFSAcquireExcl( pObjectInfo->ParentObjectInformation->Specific.Directory.DirectoryNodeHdr.TreeLock,
+ AFSAcquireExcl( pParentObjectInfo->Specific.Directory.DirectoryNodeHdr.TreeLock,
TRUE);
- if ( pObjectInfo->ParentObjectInformation->DataVersion.QuadPart != pResultCB->ParentDataVersion.QuadPart - 1)
+ if ( pParentObjectInfo->DataVersion.QuadPart != pResultCB->ParentDataVersion.QuadPart - 1)
{
- SetFlag( pObjectInfo->ParentObjectInformation->Flags, AFS_OBJECT_FLAGS_VERIFY);
+ SetFlag( pParentObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
+
+ pParentObjectInfo->DataVersion.QuadPart = (ULONGLONG)-1;
}
else
{
- pObjectInfo->ParentObjectInformation->DataVersion.QuadPart = pResultCB->ParentDataVersion.QuadPart;
+
+ pParentObjectInfo->DataVersion.QuadPart = pResultCB->ParentDataVersion.QuadPart;
}
//
pCcb->DirectoryCB,
&pCcb->DirectoryCB->NameInformation.FileName);
- AFSRemoveNameEntry( pObjectInfo->ParentObjectInformation,
+ AFSRemoveNameEntry( pParentObjectInfo,
pCcb->DirectoryCB);
}
else
&pCcb->DirectoryCB->NameInformation.FileName);
}
- AFSReleaseResource( pObjectInfo->ParentObjectInformation->Specific.Directory.DirectoryNodeHdr.TreeLock);
+ AFSReleaseResource( pParentObjectInfo->Specific.Directory.DirectoryNodeHdr.TreeLock);
- AFSFsRtlNotifyFullReportChange( pObjectInfo->ParentObjectInformation,
+ AFSFsRtlNotifyFullReportChange( pParentObjectInfo,
pCcb,
(ULONG)FILE_NOTIFY_CHANGE_FILE_NAME,
(ULONG)FILE_ACTION_REMOVED);
(ULONG)FILE_ACTION_MODIFIED);
}
+
//
- // Attempt to flush any dirty extents to the server. This may be a little
- // aggressive, to flush whenever the handle is closed, but it ensures
- // coherency.
+ // Whenever a handle with write access or the last handle is closed
+ // notify the service to FSync the file. If the redirector is holding
+ // dirty extents, flush them to the service. This is a bit aggressive
+ // but it ensures cache coherency.
//
- if( (pCcb->GrantedAccess & FILE_WRITE_DATA) &&
- pFcb->Specific.File.ExtentsDirtyCount != 0)
+ if( (pCcb->GrantedAccess & FILE_WRITE_DATA) || (pFcb->OpenHandleCount == 1))
{
- AFSFlushExtents( pFcb,
- &pCcb->AuthGroup);
+ if ( pFcb->Specific.File.ExtentsDirtyCount != 0)
+ {
+
+ AFSFlushExtents( pFcb,
+ &pCcb->AuthGroup);
+ }
+
+ ulNotificationFlags |= AFS_REQUEST_FLAG_FLUSH_FILE;
}
if( pFcb->OpenHandleCount == 1)
AFSWaitOnQueuedFlushes( pFcb);
- ulNotificationFlags |= AFS_REQUEST_FLAG_FLUSH_FILE;
+ AFSTearDownFcbExtents( pFcb,
+ &pCcb->AuthGroup);
}
//
stFileCleanup.FileAccess = pCcb->FileAccess;
//
+ // Remove the share access at this time since we may not get the close for sometime on this FO.
+ //
+
+ IoRemoveShareAccess( pFileObject,
+ &pFcb->ShareAccess);
+
+
+ //
+ // We don't need the name array after the user closes the handle on the file
+ //
+
+ if( pCcb->NameArray != NULL)
+ {
+
+ AFSFreeNameArray( pCcb->NameArray);
+
+ pCcb->NameArray = NULL;
+ }
+
+ //
+ // Release the Fcb Resource across the call to the service
+ // which may block for quite a while if flushing of the
+ // data is required.
+ //
+
+ AFSReleaseResource( &pFcb->NPFcb->Resource);
+
+ //
// Push the request to the service
//
pResultCB,
&ulResultLen);
+ //
+ // Regain exclusive access to the Fcb
+ //
+
+ AFSAcquireExcl( &pFcb->NPFcb->Resource,
+ TRUE);
+
if ( NT_SUCCESS( ntStatus))
{
- if ( pObjectInfo->ParentObjectInformation != NULL)
+ pParentObjectInfo = pObjectInfo->ParentObjectInformation;
+
+ if ( pParentObjectInfo != NULL)
{
- AFSAcquireShared( pObjectInfo->ParentObjectInformation->Specific.Directory.DirectoryNodeHdr.TreeLock,
- TRUE);
+ AFSAcquireExcl( pParentObjectInfo->Specific.Directory.DirectoryNodeHdr.TreeLock,
+ TRUE);
- if ( pObjectInfo->ParentObjectInformation->DataVersion.QuadPart != pResultCB->ParentDataVersion.QuadPart)
+ if ( pParentObjectInfo->DataVersion.QuadPart != pResultCB->ParentDataVersion.QuadPart)
{
- SetFlag( pObjectInfo->ParentObjectInformation->Flags, AFS_OBJECT_FLAGS_VERIFY);
+ SetFlag( pParentObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
+
+ pParentObjectInfo->DataVersion.QuadPart = (ULONGLONG)-1;
}
- AFSReleaseResource( pObjectInfo->ParentObjectInformation->Specific.Directory.DirectoryNodeHdr.TreeLock);
+ AFSReleaseResource( pParentObjectInfo->Specific.Directory.DirectoryNodeHdr.TreeLock);
}
}
}
//
- // Remove the share access at this time since we may not get the close for sometime on this FO.
- //
-
- IoRemoveShareAccess( pFileObject,
- &pFcb->ShareAccess);
-
- //
- // We don't need the name array after the user closes the handle on the file
- //
-
- if( pCcb->NameArray != NULL)
- {
-
- AFSFreeNameArray( pCcb->NameArray);
-
- pCcb->NameArray = NULL;
- }
-
- //
// Decrement the open child handle count
//
- if( pObjectInfo->ParentObjectInformation != NULL)
+ pParentObjectInfo = pObjectInfo->ParentObjectInformation;
+
+ if( pParentObjectInfo != NULL)
{
- ASSERT( pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount > 0);
+ ASSERT( pParentObjectInfo->Specific.Directory.ChildOpenHandleCount > 0);
- lCount = InterlockedDecrement( &pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount);
+ lCount = InterlockedDecrement( &pParentObjectInfo->Specific.Directory.ChildOpenHandleCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup (File) Decrement child open handle count on Parent object %08lX Cnt %d\n",
- pObjectInfo->ParentObjectInformation,
+ "AFSCleanup (File) Decrement child open handle count on Parent object %p Cnt %d\n",
+ pParentObjectInfo,
lCount);
}
- AFSReleaseResource( &pFcb->NPFcb->Resource);
lCount = InterlockedDecrement( &pFcb->OpenHandleCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup (File) Decrement handle count on Fcb %08lX Cnt %d\n",
+ "AFSCleanup (File) Decrement handle count on Fcb %p Cnt %d\n",
pFcb,
lCount);
+ if( BooleanFlagOn( pFcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE))
+ {
+ //
+ // The ObjectReferenceCount will be freed by AFSPerformObjectInvalidate
+ //
+
+ lCount = AFSObjectInfoIncrement( pObjectInfo,
+ AFS_OBJECT_REFERENCE_INVALIDATION);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSCleanup Setting Purge on Close Increment count on object %p Cnt %d\n",
+ pObjectInfo,
+ lCount);
+
+ ClearFlag( pFcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
+
+ AFSReleaseResource( &pFcb->NPFcb->Resource);
+
+ AFSPerformObjectInvalidate( pObjectInfo,
+ AFS_INVALIDATE_DATA_VERSION);
+ }
+ else
+ {
+
+ AFSReleaseResource( &pFcb->NPFcb->Resource);
+ }
+
break;
}
AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup Acquiring Dcb lock %08lX EXCL %08lX\n",
+ "AFSCleanup Acquiring Dcb lock %p EXCL %08lX\n",
&pFcb->NPFcb->Resource,
PsGetCurrentThread());
SetFlag( pCcb->DirectoryCB->Flags, AFS_DIR_ENTRY_DELETED);
- ASSERT( pObjectInfo->ParentObjectInformation != NULL);
+ ClearFlag( pCcb->DirectoryCB->Flags, AFS_DIR_ENTRY_PENDING_DELETE);
+
+ pParentObjectInfo = pObjectInfo->ParentObjectInformation;
+
+ ASSERT( pParentObjectInfo != NULL);
- AFSAcquireExcl( pObjectInfo->ParentObjectInformation->Specific.Directory.DirectoryNodeHdr.TreeLock,
+ AFSAcquireExcl( pParentObjectInfo->Specific.Directory.DirectoryNodeHdr.TreeLock,
TRUE);
- if ( pObjectInfo->ParentObjectInformation->DataVersion.QuadPart != pResultCB->ParentDataVersion.QuadPart - 1)
+ if ( pParentObjectInfo->DataVersion.QuadPart != pResultCB->ParentDataVersion.QuadPart - 1)
{
- SetFlag( pObjectInfo->ParentObjectInformation->Flags, AFS_OBJECT_FLAGS_VERIFY);
+ SetFlag( pParentObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
- pObjectInfo->ParentObjectInformation->DataVersion.QuadPart = (ULONGLONG)-1;
+ pParentObjectInfo->DataVersion.QuadPart = (ULONGLONG)-1;
}
else
{
- pObjectInfo->ParentObjectInformation->DataVersion.QuadPart = pResultCB->ParentDataVersion.QuadPart;
+
+ pParentObjectInfo->DataVersion.QuadPart = pResultCB->ParentDataVersion.QuadPart;
}
//
if( !BooleanFlagOn( pCcb->DirectoryCB->Flags, AFS_DIR_ENTRY_NOT_IN_PARENT_TREE))
{
- AFSRemoveNameEntry( pObjectInfo->ParentObjectInformation,
+ AFSRemoveNameEntry( pParentObjectInfo,
pCcb->DirectoryCB);
}
else
&pCcb->DirectoryCB->NameInformation.FileName);
}
- AFSReleaseResource( pObjectInfo->ParentObjectInformation->Specific.Directory.DirectoryNodeHdr.TreeLock);
+ AFSReleaseResource( pParentObjectInfo->Specific.Directory.DirectoryNodeHdr.TreeLock);
- AFSFsRtlNotifyFullReportChange( pObjectInfo->ParentObjectInformation,
+ AFSFsRtlNotifyFullReportChange( pParentObjectInfo,
pCcb,
(ULONG)FILE_NOTIFY_CHANGE_FILE_NAME,
(ULONG)FILE_ACTION_REMOVED);
ClearFlag( pFcb->Flags, AFS_FCB_FLAG_FILE_MODIFIED);
- if( pObjectInfo->ParentObjectInformation != NULL)
+ pParentObjectInfo = pObjectInfo->ParentObjectInformation;
+
+ if( pParentObjectInfo != NULL)
{
ulNotifyFilter |= (FILE_NOTIFY_CHANGE_ATTRIBUTES);
- AFSFsRtlNotifyFullReportChange( pObjectInfo->ParentObjectInformation,
+ AFSFsRtlNotifyFullReportChange( pParentObjectInfo,
pCcb,
(ULONG)ulNotifyFilter,
(ULONG)FILE_ACTION_MODIFIED);
if ( NT_SUCCESS( ntStatus))
{
- if ( pObjectInfo->ParentObjectInformation != NULL)
+ pParentObjectInfo = pObjectInfo->ParentObjectInformation;
+
+ if ( pParentObjectInfo != NULL)
{
- AFSAcquireShared( pObjectInfo->ParentObjectInformation->Specific.Directory.DirectoryNodeHdr.TreeLock,
+ AFSAcquireExcl( pParentObjectInfo->Specific.Directory.DirectoryNodeHdr.TreeLock,
TRUE);
- if ( pObjectInfo->ParentObjectInformation->DataVersion.QuadPart != pResultCB->ParentDataVersion.QuadPart)
+ if ( pParentObjectInfo->DataVersion.QuadPart != pResultCB->ParentDataVersion.QuadPart)
{
- SetFlag( pObjectInfo->ParentObjectInformation->Flags, AFS_OBJECT_FLAGS_VERIFY);
+ SetFlag( pParentObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
- pObjectInfo->ParentObjectInformation->DataVersion.QuadPart = (ULONGLONG)-1;
+ pParentObjectInfo->DataVersion.QuadPart = (ULONGLONG)-1;
}
- AFSReleaseResource( pObjectInfo->ParentObjectInformation->Specific.Directory.DirectoryNodeHdr.TreeLock);
+ AFSReleaseResource( pParentObjectInfo->Specific.Directory.DirectoryNodeHdr.TreeLock);
}
}
// Decrement the open child handle count
//
- if( pObjectInfo->ParentObjectInformation != NULL)
+ pParentObjectInfo = pObjectInfo->ParentObjectInformation;
+
+ if( pParentObjectInfo != NULL)
{
- ASSERT( pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount > 0);
+ ASSERT( pParentObjectInfo->Specific.Directory.ChildOpenHandleCount > 0);
- lCount = InterlockedDecrement( &pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount);
+ lCount = InterlockedDecrement( &pParentObjectInfo->Specific.Directory.ChildOpenHandleCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup (Dir) Decrement child open handle count on Parent object %08lX Cnt %d\n",
- pObjectInfo->ParentObjectInformation,
+ "AFSCleanup (Dir) Decrement child open handle count on Parent object %p Cnt %d\n",
+ pParentObjectInfo,
lCount);
}
- AFSReleaseResource( &pFcb->NPFcb->Resource);
-
lCount = InterlockedDecrement( &pFcb->OpenHandleCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup (Dir) Decrement handle count on Fcb %08lX Cnt %d\n",
+ "AFSCleanup (Dir) Decrement handle count on Fcb %p Cnt %d\n",
pFcb,
lCount);
+ AFSReleaseResource( &pFcb->NPFcb->Resource);
+
break;
}
AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup (MP/SL) Acquiring Dcb lock %08lX EXCL %08lX\n",
+ "AFSCleanup (MP/SL) Acquiring Dcb lock %p EXCL %08lX\n",
&pFcb->NPFcb->Resource,
PsGetCurrentThread());
SetFlag( pCcb->DirectoryCB->Flags, AFS_DIR_ENTRY_DELETED);
- ASSERT( pObjectInfo->ParentObjectInformation != NULL);
+ ClearFlag( pCcb->DirectoryCB->Flags, AFS_DIR_ENTRY_PENDING_DELETE);
+
+ pParentObjectInfo = pObjectInfo->ParentObjectInformation;
+
+ ASSERT( pParentObjectInfo != NULL);
- AFSAcquireExcl( pObjectInfo->ParentObjectInformation->Specific.Directory.DirectoryNodeHdr.TreeLock,
+ AFSAcquireExcl( pParentObjectInfo->Specific.Directory.DirectoryNodeHdr.TreeLock,
TRUE);
- if ( pObjectInfo->ParentObjectInformation->DataVersion.QuadPart != pResultCB->ParentDataVersion.QuadPart - 1)
+ if ( pParentObjectInfo->DataVersion.QuadPart != pResultCB->ParentDataVersion.QuadPart - 1)
{
- SetFlag( pObjectInfo->ParentObjectInformation->Flags, AFS_OBJECT_FLAGS_VERIFY);
+ SetFlag( pParentObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
- pObjectInfo->ParentObjectInformation->DataVersion.QuadPart = (ULONGLONG)-1;
+ pParentObjectInfo->DataVersion.QuadPart = (ULONGLONG)-1;
}
else
{
- pObjectInfo->ParentObjectInformation->DataVersion.QuadPart = pResultCB->ParentDataVersion.QuadPart;
+ pParentObjectInfo->DataVersion.QuadPart = pResultCB->ParentDataVersion.QuadPart;
}
//
if( !BooleanFlagOn( pCcb->DirectoryCB->Flags, AFS_DIR_ENTRY_NOT_IN_PARENT_TREE))
{
- AFSRemoveNameEntry( pObjectInfo->ParentObjectInformation,
+ AFSRemoveNameEntry( pParentObjectInfo,
pCcb->DirectoryCB);
}
else
&pCcb->DirectoryCB->NameInformation.FileName);
}
- AFSReleaseResource( pObjectInfo->ParentObjectInformation->Specific.Directory.DirectoryNodeHdr.TreeLock);
+ AFSReleaseResource( pParentObjectInfo->Specific.Directory.DirectoryNodeHdr.TreeLock);
- AFSFsRtlNotifyFullReportChange( pObjectInfo->ParentObjectInformation,
+ AFSFsRtlNotifyFullReportChange( pParentObjectInfo,
pCcb,
(ULONG)FILE_NOTIFY_CHANGE_FILE_NAME,
(ULONG)FILE_ACTION_REMOVED);
ClearFlag( pFcb->Flags, AFS_FCB_FLAG_FILE_MODIFIED);
- if( pObjectInfo->ParentObjectInformation != NULL)
+ pParentObjectInfo = pObjectInfo->ParentObjectInformation;
+
+ if( pParentObjectInfo != NULL)
{
ulNotifyFilter |= (FILE_NOTIFY_CHANGE_ATTRIBUTES);
- AFSFsRtlNotifyFullReportChange( pObjectInfo->ParentObjectInformation,
+ AFSFsRtlNotifyFullReportChange( pParentObjectInfo,
pCcb,
(ULONG)ulNotifyFilter,
(ULONG)FILE_ACTION_MODIFIED);
if ( NT_SUCCESS( ntStatus))
{
- if ( pObjectInfo->ParentObjectInformation != NULL)
+ pParentObjectInfo = pObjectInfo->ParentObjectInformation;
+
+ if ( pParentObjectInfo != NULL)
{
- AFSAcquireShared( pObjectInfo->ParentObjectInformation->Specific.Directory.DirectoryNodeHdr.TreeLock,
+ AFSAcquireExcl( pParentObjectInfo->Specific.Directory.DirectoryNodeHdr.TreeLock,
TRUE);
- if ( pObjectInfo->ParentObjectInformation->DataVersion.QuadPart != pResultCB->ParentDataVersion.QuadPart)
+ if ( pParentObjectInfo->DataVersion.QuadPart != pResultCB->ParentDataVersion.QuadPart)
{
- SetFlag( pObjectInfo->ParentObjectInformation->Flags, AFS_OBJECT_FLAGS_VERIFY);
+ SetFlag( pParentObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
- pObjectInfo->ParentObjectInformation->DataVersion.QuadPart = (ULONGLONG)-1;
+ pParentObjectInfo->DataVersion.QuadPart = (ULONGLONG)-1;
}
- AFSReleaseResource( pObjectInfo->ParentObjectInformation->Specific.Directory.DirectoryNodeHdr.TreeLock);
+ AFSReleaseResource( pParentObjectInfo->Specific.Directory.DirectoryNodeHdr.TreeLock);
}
}
// Decrement the open child handle count
//
- if( pObjectInfo->ParentObjectInformation != NULL)
+ pParentObjectInfo = pObjectInfo->ParentObjectInformation;
+
+ if( pParentObjectInfo != NULL)
{
- ASSERT( pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount > 0);
+ ASSERT( pParentObjectInfo->Specific.Directory.ChildOpenHandleCount > 0);
- lCount = InterlockedDecrement( &pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount);
+ lCount = InterlockedDecrement( &pParentObjectInfo->Specific.Directory.ChildOpenHandleCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup (MP/SL) Decrement child open handle count on Parent object %08lX Cnt %d\n",
- pObjectInfo->ParentObjectInformation,
+ "AFSCleanup (MP/SL) Decrement child open handle count on Parent object %p Cnt %d\n",
+ pParentObjectInfo,
lCount);
}
- AFSReleaseResource( &pFcb->NPFcb->Resource);
-
lCount = InterlockedDecrement( &pFcb->OpenHandleCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup (MP/SL) Decrement handle count on Fcb %08lX Cnt %d\n",
+ "AFSCleanup (MP/SL) Decrement handle count on Fcb %p Cnt %d\n",
pFcb,
lCount);
+ AFSReleaseResource( &pFcb->NPFcb->Resource);
+
break;
}
AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup Acquiring SPECIAL SHARE lock %08lX EXCL %08lX\n",
+ "AFSCleanup Acquiring SPECIAL SHARE lock %p EXCL %08lX\n",
&pFcb->NPFcb->Resource,
PsGetCurrentThread());
// Decrement the open child handle count
//
- if( pObjectInfo->ParentObjectInformation != NULL &&
- pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount > 0)
+ pParentObjectInfo = pObjectInfo->ParentObjectInformation;
+
+ if( pParentObjectInfo != NULL &&
+ pParentObjectInfo->Specific.Directory.ChildOpenHandleCount > 0)
{
- lCount = InterlockedDecrement( &pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount);
+ lCount = InterlockedDecrement( &pParentObjectInfo->Specific.Directory.ChildOpenHandleCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup (Share) Decrement child open handle count on Parent object %08lX Cnt %d\n",
- pObjectInfo->ParentObjectInformation,
+ "AFSCleanup (Share) Decrement child open handle count on Parent object %p Cnt %d\n",
+ pParentObjectInfo,
lCount);
}
- AFSReleaseResource( &pFcb->NPFcb->Resource);
-
lCount = InterlockedDecrement( &pFcb->OpenHandleCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCleanup (Share) Decrement handle count on Fcb %08lX Cnt %d\n",
+ "AFSCleanup (Share) Decrement handle count on Fcb %p Cnt %d\n",
pFcb,
lCount);
+ AFSReleaseResource( &pFcb->NPFcb->Resource);
+
break;
}
default:
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
- AFS_TRACE_LEVEL_WARNING,
+ AFS_TRACE_LEVEL_ERROR,
"AFSCleanup Processing unknown node type %d\n",
pFcb->Header.NodeTypeCode);
if( pResultCB != NULL)
{
- AFSExFreePool( pResultCB);
+ AFSExFreePoolWithTag( pResultCB, AFS_GENERIC_MEMORY_32_TAG);
}
if( pFileObject != NULL)
AFSCompleteRequest( Irp, ntStatus);
}
- __except( AFSExceptionFilter( GetExceptionCode(), GetExceptionInformation()) )
+ __except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()) )
{
AFSDbgLogMsg( 0,
0,
"EXCEPTION - AFSCleanup\n");
+
+ AFSDumpTraceFilesFnc();
}
return ntStatus;
git://git.openafs.org / openafs.git / blobdiff