AFSCreate( IN PDEVICE_OBJECT LibDeviceObject,
IN PIRP Irp)
{
-
+ UNREFERENCED_PARAMETER(LibDeviceObject);
NTSTATUS ntStatus = STATUS_SUCCESS;
IO_STACK_LOCATION *pIrpSp;
FILE_OBJECT *pFileObject = NULL;
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate (%08lX) Processing control device open request\n",
+ "AFSCreate (%p) Processing control device open request\n",
Irp);
ntStatus = AFSControlDeviceCreate( Irp);
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate (%08lX) Invalid request to open before library is initialized\n",
+ "AFSCreate (%p) Invalid request to open before library is initialized\n",
Irp);
try_return( ntStatus = STATUS_DEVICE_NOT_READY);
NOTHING;
}
- __except( AFSExceptionFilter( GetExceptionCode(), GetExceptionInformation()) )
+ __except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()) )
{
AFSDbgLogMsg( 0,
"EXCEPTION - AFSCreate\n");
ntStatus = STATUS_ACCESS_DENIED;
+
+ AFSDumpTraceFilesFnc();
}
//
AFSDeviceExt *pDeviceExt = NULL;
BOOLEAN bOpenTargetDirectory = FALSE, bReleaseVolume = FALSE;
PACCESS_MASK pDesiredAccess = NULL;
- UNICODE_STRING uniComponentName, uniPathName, uniRootFileName, uniParsedFileName;
+ UNICODE_STRING uniComponentName, uniRootFileName, uniParsedFileName;
UNICODE_STRING uniSubstitutedPathName;
UNICODE_STRING uniRelativeName;
AFSNameArrayHdr *pNameArray = NULL;
AFSVolumeCB *pVolumeCB = NULL;
+ LONG VolumeReferenceReason = AFS_VOLUME_REFERENCE_INVALID;
+ AFSVolumeCB *pNewVolumeCB = NULL;
+ LONG NewVolumeReferenceReason = AFS_VOLUME_REFERENCE_INVALID;
AFSDirectoryCB *pParentDirectoryCB = NULL, *pDirectoryCB = NULL;
+ AFSDirectoryCB *pNewParentDirectoryCB = NULL;
+ BOOLEAN bReleaseParentDir = FALSE, bReleaseDir = FALSE;
ULONG ulParseFlags = 0;
- GUID stAuthGroup;
+ GUID stAuthGroup = {0};
ULONG ulNameProcessingFlags = 0;
BOOLEAN bOpenedReparsePoint = FALSE;
+ LONG lCount;
__Enter
{
(ULONGLONG)PsGetCurrentThreadId(),
&stAuthGroup);
+ //
+ // If we are in shutdown mode then fail the request
+ //
+
+ if( BooleanFlagOn( pDeviceExt->DeviceFlags, AFS_DEVICE_FLAG_REDIRECTOR_SHUTDOWN))
+ {
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFS_TRACE_LEVEL_WARNING,
+ "AFSCommonCreate (%p) Open request after shutdown\n",
+ Irp);
+
+ try_return( ntStatus = STATUS_TOO_LATE);
+ }
+
if( !BooleanFlagOn( AFSGlobalRoot->ObjectInformation.Flags, AFS_OBJECT_FLAGS_DIRECTORY_ENUMERATED))
{
}
//
- // If we are in shutdown mode then fail the request
- //
-
- if( BooleanFlagOn( pDeviceExt->DeviceFlags, AFS_DEVICE_FLAG_REDIRECTOR_SHUTDOWN))
- {
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
- AFS_TRACE_LEVEL_WARNING,
- "AFSCommonCreate (%08lX) Open request after shutdown\n",
- Irp);
-
- try_return( ntStatus = STATUS_TOO_LATE);
- }
-
- //
// Go and parse the name for processing.
// If ulParseFlags is returned with AFS_PARSE_FLAG_FREE_FILE_BUFFER set,
// then we are responsible for releasing the uniRootFileName.Buffer.
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
uniFileName.Length > 0 ? AFS_TRACE_LEVEL_ERROR : AFS_TRACE_LEVEL_VERBOSE,
- "AFSCommonCreate (%08lX) Failed to parse name \"%wZ\" Status %08lX\n",
+ "AFSCommonCreate (%p) Failed to parse name \"%wZ\" Status %08lX\n",
Irp,
&uniFileName,
ntStatus);
try_return( ntStatus);
}
+ if ( pParentDirectoryCB != NULL)
+ {
+
+ bReleaseParentDir = TRUE;
+ }
+
//
// If the returned volume cb is NULL then we are dealing with the \\Server\GlobalRoot
// name
TRUE) == 0)
{
+ //
+ // AFSOpenIOCtlFcb does not free a DirOpenReferenceCount for
+ // AFSGlobalRoot->DirectoryCB.
+ //
+
ntStatus = AFSOpenIOCtlFcb( Irp,
&stAuthGroup,
AFSGlobalRoot->DirectoryCB,
ntStatus);
}
}
- else if( pParentDirectoryCB != NULL &&
- pParentDirectoryCB->ObjectInformation->FileType == AFS_FILE_TYPE_SPECIAL_SHARE_NAME)
+ else if( pParentDirectoryCB != NULL)
{
- ntStatus = AFSOpenSpecialShareFcb( Irp,
- &stAuthGroup,
- pParentDirectoryCB,
- &pFcb,
- &pCcb);
-
- if( !NT_SUCCESS( ntStatus))
+ if( pParentDirectoryCB->ObjectInformation->FileType == AFS_FILE_TYPE_SPECIAL_SHARE_NAME)
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
- AFS_TRACE_LEVEL_ERROR,
- "AFSCommonCreate Failed to open special share Fcb Status %08lX\n",
- ntStatus);
+ ntStatus = AFSOpenSpecialShareFcb( Irp,
+ &stAuthGroup,
+ pParentDirectoryCB,
+ &pFcb,
+ &pCcb);
+
+ if( !NT_SUCCESS( ntStatus))
+ {
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSCommonCreate Failed to open special share Fcb Status %08lX\n",
+ ntStatus);
+ }
}
}
AFS_TRACE_LEVEL_ERROR,
"AFSCommonCreate Failed to open root Status %08lX\n",
ntStatus);
-
- InterlockedDecrement( &AFSGlobalRoot->DirectoryCB->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate Decrement1 count on &wZ DE %p Ccb %p Cnt %d\n",
- &AFSGlobalRoot->DirectoryCB->NameInformation.FileName,
- AFSGlobalRoot->DirectoryCB,
- NULL,
- AFSGlobalRoot->DirectoryCB->OpenReferenceCount);
}
try_return( ntStatus);
}
//
- // We have our root node shared
+ // We have a reference on the root volume
//
+ VolumeReferenceReason = AFS_VOLUME_REFERENCE_PARSE_NAME;
+
bReleaseVolume = TRUE;
//
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCommonCreate (%08lX) Invalid name %wZ Status %08lX\n",
+ "AFSCommonCreate (%p) Invalid name %wZ Status %08lX\n",
Irp,
&uniFileName,
ntStatus);
&uniParsedFileName,
pNameArray,
ulNameProcessingFlags,
- &pVolumeCB,
- &pParentDirectoryCB,
+ pVolumeCB,
+ pParentDirectoryCB,
+ &pNewVolumeCB,
+ &NewVolumeReferenceReason,
+ &pNewParentDirectoryCB,
&pDirectoryCB,
&uniComponentName);
+ if ( pNewVolumeCB != NULL)
+ {
+
+ //
+ // AFSLocateNameEntry returns pNewVolumeCB with a reference held
+ // even if pVolumeCB == pNewVolumeCB. It is always safe to release
+ // the reference on pVolumeCB that was held prior to the call.
+ // If pVolumeCB == pNewVolumeCB, the reference from AFSLocateNameEntry
+ // will be released second.
+ //
+
+ lCount = AFSVolumeDecrement( pVolumeCB,
+ VolumeReferenceReason);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSCommonCreate Decrement count on volume %p Reason %u Cnt %d\n",
+ pVolumeCB,
+ VolumeReferenceReason,
+ lCount);
+
+ pVolumeCB = pNewVolumeCB;
+
+ pNewVolumeCB = NULL;
+
+ VolumeReferenceReason = NewVolumeReferenceReason;
+
+ NewVolumeReferenceReason = AFS_VOLUME_REFERENCE_INVALID;
+
+ bReleaseVolume = (pVolumeCB != NULL);
+ }
+
+ //
+ // AFSLocateNameEntry does not alter the reference count of
+ // pParentDirectoryCB and it returns pNewParentDirectoryCB with
+ // a reference held.
+ //
+
+ if ( bReleaseParentDir)
+ {
+
+ lCount = InterlockedDecrement( &pParentDirectoryCB->DirOpenReferenceCount);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSCommonCreate DecrementX count on %wZ DE %p Ccb %p Cnt %d\n",
+ &pParentDirectoryCB->NameInformation.FileName,
+ pParentDirectoryCB,
+ pCcb,
+ lCount);
+ }
+
+ pParentDirectoryCB = pNewParentDirectoryCB;
+
+ pNewParentDirectoryCB = NULL;
+
+ bReleaseParentDir = (pParentDirectoryCB != NULL);
+
+ if ( pDirectoryCB)
+ {
+
+ bReleaseDir = TRUE;
+ }
+
if( !NT_SUCCESS( ntStatus) &&
ntStatus != STATUS_OBJECT_NAME_NOT_FOUND)
{
}
//
- // The routine above released the root while walking the
+ // AFSLocateNameEntry released the Parent while walking the
// branch
//
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCommonCreate (%08lX) Failed to locate name entry for %wZ Status %08lX\n",
+ "AFSCommonCreate (%p) Failed to locate name entry for %wZ Status %08lX\n",
Irp,
&uniFileName,
ntStatus);
- //
- // We released any root volume locks in the above on failure
- //
-
- bReleaseVolume = FALSE;
-
try_return( ntStatus);
}
Irp->IoStatus.Information = IO_REPARSE;
- //
- // We released the volume lock above
- //
-
- bReleaseVolume = FALSE;
-
try_return( ntStatus);
}
pParentDirectoryCB != NULL)
{
+ //
+ // pParentDirectoryCB DirOpenReferenceCount is still held
+ //
+
UNICODE_STRING uniFinalComponent;
uniFinalComponent.Length = 0;
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCommonCreate (%08lX) Failing access to symlink %wZ Status %08lX\n",
+ "AFSCommonCreate (%p) Failing access to symlink %wZ Status %08lX\n",
Irp,
&uniFileName,
ntStatus);
{
pDirectoryCB = pVolumeCB->DirectoryCB;
+
+ lCount = InterlockedIncrement( &pDirectoryCB->DirOpenReferenceCount);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSCommonCreate Increment0 count on %wZ DE %p Ccb %p Cnt %d\n",
+ &pDirectoryCB->NameInformation.FileName,
+ pDirectoryCB,
+ pCcb,
+ lCount);
+
+ bReleaseDir = TRUE;
}
if( bOpenTargetDirectory)
if( pDirectoryCB != NULL)
{
- //
- // Perform in this order to prevent thrashing
- //
+ if ( !bReleaseParentDir)
+ {
- InterlockedIncrement( &pParentDirectoryCB->OpenReferenceCount);
+ //
+ // Perform in this order to prevent thrashing
+ //
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate Increment1 count on %wZ DE %p Ccb %p Cnt %d\n",
- &pParentDirectoryCB->NameInformation.FileName,
- pParentDirectoryCB,
- NULL,
- pParentDirectoryCB->OpenReferenceCount);
+ lCount = InterlockedIncrement( &pParentDirectoryCB->DirOpenReferenceCount);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSCommonCreate Increment1 count on %wZ DE %p Ccb %p Cnt %d\n",
+ &pParentDirectoryCB->NameInformation.FileName,
+ pParentDirectoryCB,
+ pCcb,
+ lCount);
+
+ bReleaseParentDir = TRUE;
+ }
//
// Do NOT decrement the reference count on the pDirectoryCB yet.
&uniComponentName,
&pFcb,
&pCcb);
- if( pDirectoryCB != NULL)
- {
- //
- // It is now safe to drop the Reference Count
- //
- InterlockedDecrement( &pDirectoryCB->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate Decrement2 count on %wZ DE %p Ccb %p Cnt %d\n",
- &pDirectoryCB->NameInformation.FileName,
- pDirectoryCB,
- NULL,
- pDirectoryCB->OpenReferenceCount);
- }
if( !NT_SUCCESS( ntStatus))
{
"AFSCommonCreate Failed to open target directory %wZ Status %08lX\n",
&pParentDirectoryCB->NameInformation.FileName,
ntStatus);
-
- //
- // Decrement the reference on the parent
- //
-
- InterlockedDecrement( &pParentDirectoryCB->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate Decrement3 count on %wZ DE %p Ccb %p Cnt %d\n",
- &pParentDirectoryCB->NameInformation.FileName,
- pParentDirectoryCB,
- NULL,
- pParentDirectoryCB->OpenReferenceCount);
}
try_return( ntStatus);
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCommonCreate (%08lX) Reparse open request but attribute not set for %wZ DirCB %p Type %08lX\n",
+ "AFSCommonCreate (%p) Reparse open request but attribute not set for %wZ DirCB %p Type %08lX\n",
Irp,
&uniFileName,
pDirectoryCB,
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCommonCreate (%08lX) Opening as reparse point %wZ Type %08lX\n",
+ "AFSCommonCreate (%p) Opening as reparse point %wZ Type %08lX\n",
Irp,
&uniFileName,
pDirectoryCB->ObjectInformation->FileType);
// fail with collision
//
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSCommonCreate Object name collision on create of %wZ Status %08lX\n",
- &pDirectoryCB->NameInformation.FileName,
- ntStatus);
-
if( pDirectoryCB != NULL)
{
- InterlockedDecrement( &pDirectoryCB->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate Decrement4 count on %wZ DE %p Ccb %p Cnt %d\n",
+ "AFSCommonCreate Object name collision on create of %wZ Status %08lX\n",
&pDirectoryCB->NameInformation.FileName,
- pDirectoryCB,
- NULL,
- pDirectoryCB->OpenReferenceCount);
+ ntStatus);
}
else
{
- InterlockedDecrement( &pParentDirectoryCB->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate Decrement5 count on %wZ DE %p Ccb %p Cnt %d\n",
- &pParentDirectoryCB->NameInformation.FileName,
- pParentDirectoryCB,
- NULL,
- pParentDirectoryCB->OpenReferenceCount);
+ "AFSCommonCreate Object name collision on create Status %08lX\n",
+ ntStatus);
}
try_return( ntStatus = STATUS_OBJECT_NAME_COLLISION);
ntStatus);
}
- //
- // Dereference the parent entry
- //
-
- InterlockedDecrement( &pParentDirectoryCB->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate Decrement6 count on %wZ DE %p Ccb %p Cnt %d\n",
- &pParentDirectoryCB->NameInformation.FileName,
- pParentDirectoryCB,
- NULL,
- pParentDirectoryCB->OpenReferenceCount);
-
try_return( ntStatus);
}
TRUE) == 0)
{
+ //
+ // AFSOpenIOCtlFcb does not free a DirOpenReferenceCount for
+ // pParentDirectoryCB.
+ //
+
ntStatus = AFSOpenIOCtlFcb( Irp,
&stAuthGroup,
pParentDirectoryCB,
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCommonCreate (%08lX) File %wZ name not found\n",
+ "AFSCommonCreate (%p) File %wZ name not found\n",
Irp,
&uniFileName);
ntStatus = STATUS_OBJECT_NAME_NOT_FOUND;
}
- if( !NT_SUCCESS( ntStatus))
- {
-
- //
- // Dereference the parent entry
- //
-
- if( pDirectoryCB != NULL)
- {
-
- InterlockedDecrement( &pDirectoryCB->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate Decrement7a count on %wZ DE %p Ccb %p Cnt %d\n",
- &pDirectoryCB->NameInformation.FileName,
- pDirectoryCB,
- NULL,
- pDirectoryCB->OpenReferenceCount);
- }
- else
- {
-
- InterlockedDecrement( &pParentDirectoryCB->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate Decrement7b count on %wZ DE %p Ccb %p Cnt %d\n",
- &pParentDirectoryCB->NameInformation.FileName,
- pParentDirectoryCB,
- NULL,
- pParentDirectoryCB->OpenReferenceCount);
- }
- }
-
try_return( ntStatus);
}
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSCommonCreate (%08lX) Attempt to open root as delete on close\n",
+ "AFSCommonCreate (%p) Attempt to open root as delete on close\n",
Irp);
- InterlockedDecrement( &pDirectoryCB->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate Decrement8 count on %wZ DE %p Ccb %p Cnt %d\n",
- &pDirectoryCB->NameInformation.FileName,
- pDirectoryCB,
- NULL,
- pDirectoryCB->OpenReferenceCount);
-
try_return( ntStatus = STATUS_CANNOT_DELETE);
}
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSCommonCreate (%08lX) Attempt to open root as target directory\n",
+ "AFSCommonCreate (%p) Attempt to open root as target directory\n",
Irp);
- InterlockedDecrement( &pDirectoryCB->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate Decrement9 count on %wZ DE %p Ccb %p Cnt %d\n",
- &pDirectoryCB->NameInformation.FileName,
- pDirectoryCB,
- NULL,
- pDirectoryCB->OpenReferenceCount);
-
try_return( ntStatus = STATUS_INVALID_PARAMETER);
}
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSCommonCreate Failed to open root (2) Status %08lX\n",
+ "AFSCommonCreate Failed to open volume root %08lX-%08lX Status %08lX\n",
+ pVolumeCB->ObjectInformation.FileId.Cell,
+ pVolumeCB->ObjectInformation.FileId.Volume,
ntStatus);
-
- InterlockedDecrement( &pDirectoryCB->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate Decrement10 count on %wZ DE %p Ccb %p Cnt %d\n",
- &pDirectoryCB->NameInformation.FileName,
- pDirectoryCB,
- NULL,
- pDirectoryCB->OpenReferenceCount);
}
try_return( ntStatus);
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSCommonCreate Failing access to %wZ\n",
+ "AFSCommonCreate Failing access to %wZ Name not found\n",
&uniFileName);
try_return( ntStatus = STATUS_OBJECT_NAME_NOT_FOUND);
"AFSCommonCreate Failed overwrite/supersede on %wZ Status %08lX\n",
&pDirectoryCB->NameInformation.FileName,
ntStatus);
-
- InterlockedDecrement( &pDirectoryCB->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate Decrement11 count on %wZ DE %p Ccb %p Cnt %d\n",
- &pDirectoryCB->NameInformation.FileName,
- pDirectoryCB,
- NULL,
- pDirectoryCB->OpenReferenceCount);
}
try_return( ntStatus);
"AFSCommonCreate Failed open on %wZ Status %08lX\n",
&pDirectoryCB->NameInformation.FileName,
ntStatus);
-
- InterlockedDecrement( &pDirectoryCB->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate Decrement12 count on %wZ DE %p Ccb %p Cnt %d\n",
- &pDirectoryCB->NameInformation.FileName,
- pDirectoryCB,
- NULL,
- pDirectoryCB->OpenReferenceCount);
}
try_exit:
if( pCcb != NULL)
{
+ AFSAcquireExcl( &pCcb->NPCcb->CcbLock,
+ TRUE);
+
+ RtlCopyMemory( &pCcb->AuthGroup,
+ &stAuthGroup,
+ sizeof( GUID));
+
//
// If we have a substitute name, then use it
//
SetFlag( pCcb->Flags, CCB_FLAG_MASK_OPENED_REPARSE_POINT);
}
+ lCount = pCcb->DirectoryCB->DirOpenReferenceCount;
+
AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCreate Count on %wZ DE %p Ccb %p Cnt %d\n",
+ "AFSCommonCreate Count on %wZ DE %p Ccb %p Cnt %d\n",
&pCcb->DirectoryCB->NameInformation.FileName,
pCcb->DirectoryCB,
pCcb,
- pCcb->DirectoryCB->OpenReferenceCount);
+ lCount);
- ASSERT( pCcb->DirectoryCB->OpenReferenceCount > 0);
+ ASSERT( lCount >= 0);
pCcb->CurrentDirIndex = 0;
pCcb->NameArray = pNameArray;
pNameArray = NULL;
+
+ AFSReleaseResource( &pCcb->NPCcb->CcbLock);
}
//
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE_2,
- "AFSCommonCreate (%08lX) FileObject %08lX FsContext %08lX FsContext2 %08lX\n",
+ "AFSCommonCreate (%p) FileObject %p FsContext %p FsContext2 %p\n",
Irp,
pFileObject,
pFcb,
ClearFlag( pFcb->Flags, AFS_FCB_FILE_CLOSED);
- RtlCopyMemory( &pFcb->AuthGroup,
- &stAuthGroup,
- sizeof( GUID));
-
//
// For files perform additional processing
//
- if( pFcb->Header.NodeTypeCode == AFS_FILE_FCB)
+ switch( pFcb->Header.NodeTypeCode)
{
- pFileObject->SectionObjectPointer = &pFcb->NPFcb->SectionObjectPointers;
+
+ case AFS_FILE_FCB:
+ case AFS_IOCTL_FCB:
+ {
+
+ pFileObject->SectionObjectPointer = &pFcb->NPFcb->SectionObjectPointers;
+ }
}
//
//
KeQuerySystemTime( &pFcb->ObjectInformation->LastAccessTime);
+
+ if( pCcb != NULL)
+ {
+ AFSInsertCcb( pFcb,
+ pCcb);
+ }
}
else
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSCommonCreate (%08lX) Returning with NULL Fcb FileObject %08lX FsContext %08lX FsContext2 %08lX\n",
+ "AFSCommonCreate (%p) Returning with NULL Fcb FileObject %p FsContext %p FsContext2 %p\n",
Irp,
pFileObject,
pFcb,
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSCommonCreate (%08lX) STATUS_REPARSE FileObject %08lX FsContext %08lX FsContext2 %08lX\n",
+ "AFSCommonCreate (%p) STATUS_REPARSE FileObject %p FsContext %p FsContext2 %p\n",
Irp,
pFileObject,
pFcb,
if( uniSubstitutedPathName.Buffer != NULL)
{
- AFSExFreePool( uniSubstitutedPathName.Buffer);
+ AFSExFreePoolWithTag( uniSubstitutedPathName.Buffer, 0);
ClearFlag( ulParseFlags, AFS_PARSE_FLAG_FREE_FILE_BUFFER);
}
if( BooleanFlagOn( ulParseFlags, AFS_PARSE_FLAG_FREE_FILE_BUFFER))
{
- AFSExFreePool( uniRootFileName.Buffer);
+ AFSExFreePoolWithTag( uniRootFileName.Buffer, 0);
}
if( bReleaseVolume)
{
- InterlockedDecrement( &pVolumeCB->VolumeReferenceCount);
+ lCount = AFSVolumeDecrement( pVolumeCB,
+ VolumeReferenceReason);
AFSDbgLogMsg( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSCommonCreate Decrement count on Volume %08lX Cnt %d\n",
+ "AFSCommonCreate Decrement count on Volume %08lX Reason %u Cnt %d\n",
pVolumeCB,
- pVolumeCB->VolumeReferenceCount);
+ VolumeReferenceReason,
+ lCount);
+ }
+
+ if ( bReleaseDir)
+ {
+
+ //
+ // Release the reference from AFSLocateNameEntry
+ //
+
+ lCount = InterlockedDecrement( &pDirectoryCB->DirOpenReferenceCount);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSCommonCreate Decrement count on %wZ DE %p Ccb %p Cnt %d\n",
+ &pDirectoryCB->NameInformation.FileName,
+ pDirectoryCB,
+ pCcb,
+ lCount);
+
+ ASSERT( lCount >= 0);
+ }
+
+ if ( bReleaseParentDir)
+ {
+
+ //
+ // Release the reference from AFSLocateNameEntry
+ //
+
+ lCount = InterlockedDecrement( &pParentDirectoryCB->DirOpenReferenceCount);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSCommonCreate Decrement count on %wZ DE %p Ccb %p Cnt %d\n",
+ &pParentDirectoryCB->NameInformation.FileName,
+ pParentDirectoryCB,
+ pCcb,
+ lCount);
- AFSReleaseResource( pVolumeCB->VolumeLock);
+ ASSERT( lCount >= 0);
}
//
}
NTSTATUS
-AFSOpenRedirector( IN PIRP Irp,
- IN AFSFcb **Fcb,
- IN AFSCcb **Ccb)
-{
-
- NTSTATUS ntStatus = STATUS_SUCCESS;
-
- __Enter
- {
-
- //
- // Initialize the Ccb for the file.
- //
-
- ntStatus = AFSInitCcb( Ccb);
-
- if( !NT_SUCCESS( ntStatus))
- {
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
- AFS_TRACE_LEVEL_ERROR,
- "AFSOpenRedirector (%08lX) Failed to allocate Ccb\n",
- Irp);
-
- try_return( ntStatus);
- }
-
- //
- // Setup the Ccb
- //
-
- (*Ccb)->DirectoryCB = AFSRedirectorRoot->DirectoryCB;
-
- //
- // Increment the open count on this Fcb
- //
-
- InterlockedIncrement( &AFSRedirectorRoot->RootFcb->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenRedirector Increment count on Fcb %08lX Cnt %d\n",
- AFSRedirectorRoot->RootFcb,
- AFSRedirectorRoot->RootFcb->OpenReferenceCount);
-
- InterlockedIncrement( &AFSRedirectorRoot->RootFcb->OpenHandleCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenRedirector Increment handle count on Fcb %08lX Cnt %d\n",
- AFSRedirectorRoot->RootFcb,
- AFSRedirectorRoot->RootFcb->OpenHandleCount);
-
- *Fcb = AFSRedirectorRoot->RootFcb;
-
- InterlockedIncrement( &(*Ccb)->DirectoryCB->OpenReferenceCount);
-
- //
- // Return the open result for this file
- //
-
- Irp->IoStatus.Information = FILE_OPENED;
-
-try_exit:
-
- NOTHING;
- }
-
- return ntStatus;
-}
-
-NTSTATUS
AFSOpenAFSRoot( IN PIRP Irp,
IN AFSFcb **Fcb,
IN AFSCcb **Ccb)
{
NTSTATUS ntStatus = STATUS_SUCCESS;
+ LONG lCount;
__Enter
{
// Initialize the Ccb for the file.
//
- ntStatus = AFSInitCcb( Ccb);
+ ntStatus = AFSInitCcb( Ccb,
+ AFSGlobalRoot->DirectoryCB,
+ 0,
+ 0);
if( !NT_SUCCESS( ntStatus))
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSOpenAFSRoot (%08lX) Failed to allocate Ccb\n",
+ "AFSOpenAFSRoot (%p) Failed to allocate Ccb\n",
Irp);
try_return( ntStatus);
}
//
- // Setup the Ccb
- //
-
- (*Ccb)->DirectoryCB = AFSGlobalRoot->DirectoryCB;
-
- //
// Increment the open count on this Fcb
//
- InterlockedIncrement( &AFSGlobalRoot->RootFcb->OpenReferenceCount);
+ lCount = InterlockedIncrement( &AFSGlobalRoot->RootFcb->OpenReferenceCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenAFSRoot Increment count on Fcb %08lX Cnt %d\n",
+ "AFSOpenAFSRoot Increment count on Fcb %p Cnt %d\n",
AFSGlobalRoot->RootFcb,
- AFSGlobalRoot->RootFcb->OpenReferenceCount);
+ lCount);
- InterlockedIncrement( &AFSGlobalRoot->RootFcb->OpenHandleCount);
+ lCount = InterlockedIncrement( &AFSGlobalRoot->RootFcb->OpenHandleCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenAFSRoot Increment handle count on Fcb %08lX Cnt %d\n",
+ "AFSOpenAFSRoot Increment handle count on Fcb %p Cnt %d\n",
AFSGlobalRoot->RootFcb,
- AFSGlobalRoot->RootFcb->OpenHandleCount);
+ lCount);
*Fcb = AFSGlobalRoot->RootFcb;
PIO_STACK_LOCATION pIrpSp = IoGetCurrentIrpStackLocation( Irp);
PACCESS_MASK pDesiredAccess = NULL;
USHORT usShareAccess;
+ ULONG ulOptions;
BOOLEAN bAllocatedCcb = FALSE;
BOOLEAN bReleaseFcb = FALSE;
AFSFileOpenCB stOpenCB;
AFSFileOpenResultCB stOpenResultCB;
ULONG ulResultLen = 0;
+ LONG lCount;
__Enter
{
pDesiredAccess = &pIrpSp->Parameters.Create.SecurityContext->DesiredAccess;
usShareAccess = pIrpSp->Parameters.Create.ShareAccess;
+ ulOptions = pIrpSp->Parameters.Create.Options;
pFileObject = pIrpSp->FileObject;
+ if( BooleanFlagOn( ulOptions, FILE_NON_DIRECTORY_FILE))
+ {
+
+ ntStatus = STATUS_FILE_IS_A_DIRECTORY;
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSOpenRoot (%p) Attempt to open root as file Status %08lX\n",
+ Irp,
+ ntStatus);
+
+ try_return( ntStatus);
+ }
+
//
// Check if we should go and retrieve updated information for the node
//
ntStatus = AFSValidateEntry( VolumeCB->DirectoryCB,
AuthGroup,
- TRUE,
- FALSE);
+ FALSE,
+ TRUE);
if( !NT_SUCCESS( ntStatus))
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSOpenRoot (%08lX) Failed to validate root entry Status %08lX\n",
+ "AFSOpenRoot (%p) Failed to validate root entry Status %08lX\n",
Irp,
ntStatus);
AuthGroup,
NULL,
&VolumeCB->ObjectInformation.FileId,
+ VolumeCB->VolumeInformation.Cell,
+ VolumeCB->VolumeInformation.CellLength,
(void *)&stOpenCB,
sizeof( AFSFileOpenCB),
(void *)&stOpenResultCB,
if( !NT_SUCCESS( ntStatus))
{
+ UNICODE_STRING uniGUID;
+
+ uniGUID.Length = 0;
+ uniGUID.MaximumLength = 0;
+ uniGUID.Buffer = NULL;
+
+ if( AuthGroup != NULL)
+ {
+ RtlStringFromGUID( *AuthGroup,
+ &uniGUID);
+ }
+
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSOpenRoot (%08lX) Failed open in service AFSRoot Status %08lX\n",
+ "AFSOpenRoot (%p) Failed open in service volume %08lX-%08lX AuthGroup %wZ Status %08lX\n",
Irp,
+ VolumeCB->ObjectInformation.FileId.Cell,
+ VolumeCB->ObjectInformation.FileId.Volume,
+ &uniGUID,
ntStatus);
+ if( AuthGroup != NULL)
+ {
+ RtlFreeUnicodeString( &uniGUID);
+ }
+
try_return( ntStatus);
}
AFSAcquireExcl( VolumeCB->ObjectInformation.Specific.Directory.DirectoryNodeHdr.TreeLock,
TRUE);
- if( !BooleanFlagOn( VolumeCB->ObjectInformation.Flags, AFS_OBJECT_FLAGS_DIRECTORY_ENUMERATED))
- {
-
- ntStatus = AFSEnumerateDirectory( AuthGroup,
- &VolumeCB->ObjectInformation,
- TRUE);
-
- if( !NT_SUCCESS( ntStatus))
- {
+ ntStatus = AFSEnumerateDirectory( AuthGroup,
+ &VolumeCB->ObjectInformation,
+ TRUE);
- AFSReleaseResource( VolumeCB->ObjectInformation.Specific.Directory.DirectoryNodeHdr.TreeLock);
+ if( !NT_SUCCESS( ntStatus))
+ {
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
- AFS_TRACE_LEVEL_ERROR,
- "AFSOpenRoot (%08lX) Failed to enumerate directory Status %08lX\n",
- Irp,
- ntStatus);
+ AFSReleaseResource( VolumeCB->ObjectInformation.Specific.Directory.DirectoryNodeHdr.TreeLock);
- try_return( ntStatus);
- }
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSOpenRoot (%p) Failed to enumerate directory Status %08lX\n",
+ Irp,
+ ntStatus);
- SetFlag( VolumeCB->ObjectInformation.Flags, AFS_OBJECT_FLAGS_DIRECTORY_ENUMERATED);
+ try_return( ntStatus);
}
AFSReleaseResource( VolumeCB->ObjectInformation.Specific.Directory.DirectoryNodeHdr.TreeLock);
// init the volume fcb
//
- if( VolumeCB->RootFcb == NULL)
- {
-
- ntStatus = AFSInitRootFcb( (ULONGLONG)PsGetCurrentProcessId(),
- VolumeCB);
-
- if( !NT_SUCCESS( ntStatus))
- {
+ ntStatus = AFSInitRootFcb( (ULONGLONG)PsGetCurrentProcessId(),
+ VolumeCB);
- try_return( ntStatus);
- }
- }
- else
+ if( !NT_SUCCESS( ntStatus))
{
- AFSAcquireExcl( VolumeCB->RootFcb->Header.Resource,
- TRUE);
+ try_return( ntStatus);
}
+ lCount = InterlockedIncrement( &VolumeCB->RootFcb->OpenReferenceCount);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSOpenRoot Increment count on Fcb %p Cnt %d\n",
+ VolumeCB->RootFcb,
+ lCount);
+
bReleaseFcb = TRUE;
//
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSOpenRoot (%08lX) Access check failure Status %08lX\n",
+ "AFSOpenRoot (%p) Access check failure Status %08lX\n",
Irp,
ntStatus);
// Initialize the Ccb for the file.
//
- ntStatus = AFSInitCcb( Ccb);
+ ntStatus = AFSInitCcb( Ccb,
+ VolumeCB->DirectoryCB,
+ *pDesiredAccess,
+ 0);
if( !NT_SUCCESS( ntStatus))
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSOpenRoot (%08lX) Failed to allocate Ccb Status %08lX\n",
+ "AFSOpenRoot (%p) Failed to allocate Ccb Status %08lX\n",
Irp,
ntStatus);
bAllocatedCcb = TRUE;
//
- // Setup the ccb
- //
-
- (*Ccb)->DirectoryCB = VolumeCB->DirectoryCB;
-
- //
// OK, update the share access on the fileobject
//
// Increment the open count on this Fcb
//
- InterlockedIncrement( &VolumeCB->RootFcb->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenRoot Increment count on Fcb %08lX Cnt %d\n",
- VolumeCB->RootFcb,
- VolumeCB->RootFcb->OpenReferenceCount);
-
- InterlockedIncrement( &VolumeCB->RootFcb->OpenHandleCount);
+ lCount = InterlockedIncrement( &VolumeCB->RootFcb->OpenHandleCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenRoot Increment handle count on Fcb %08lX Cnt %d\n",
+ "AFSOpenRoot Increment handle count on Fcb %p Cnt %d\n",
VolumeCB->RootFcb,
- VolumeCB->RootFcb->OpenHandleCount);
+ lCount);
//
// Indicate the object is held
if( bReleaseFcb)
{
+ if ( !NT_SUCCESS( ntStatus))
+ {
+
+ lCount = InterlockedDecrement( &VolumeCB->RootFcb->OpenReferenceCount);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSOpenRoot Decrement count on Fcb %p Cnt %d\n",
+ VolumeCB->RootFcb,
+ lCount);
+ }
AFSReleaseResource( VolumeCB->RootFcb->Header.Resource);
}
if( bAllocatedCcb)
{
- AFSRemoveCcb( *Ccb);
+ AFSRemoveCcb( NULL,
+ *Ccb);
*Ccb = NULL;
}
PFILE_OBJECT pFileObject = NULL;
PIO_STACK_LOCATION pIrpSp = IoGetCurrentIrpStackLocation( Irp);
ULONG ulOptions = 0;
- ULONG ulShareMode = 0;
- ULONG ulAccess = 0;
ULONG ulAttributes = 0;
- LARGE_INTEGER liAllocationSize = {0,0};
BOOLEAN bFileCreated = FALSE, bReleaseFcb = FALSE, bAllocatedCcb = FALSE;
- BOOLEAN bAllocatedFcb = FALSE;
PACCESS_MASK pDesiredAccess = NULL;
USHORT usShareAccess;
AFSDirectoryCB *pDirEntry = NULL;
AFSObjectInfoCB *pParentObjectInfo = NULL;
AFSObjectInfoCB *pObjectInfo = NULL;
+ LONG lCount;
__Enter
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessCreate (%08lX) Creating file %wZ Attributes %08lX\n",
+ "AFSProcessCreate (%p) Creating file %wZ Attributes %08lX\n",
Irp,
FullFileName,
ulAttributes);
"AFSProcessCreate Request failed due to read only volume %wZ\n",
FullFileName);
- try_return( ntStatus = STATUS_ACCESS_DENIED);
+ try_return( ntStatus = STATUS_MEDIA_WRITE_PROTECTED);
}
pParentObjectInfo = ParentDirCB->ObjectInformation;
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessCreate (%08lX) Failed to create directory entry %wZ Status %08lX\n",
+ "AFSProcessCreate (%p) Failed to create directory entry %wZ Status %08lX\n",
Irp,
FullFileName,
ntStatus);
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessCreate (%08lX) Evaluating object %wZ FID %08lX-%08lX-%08lX-%08lX\n",
+ "AFSProcessCreate (%p) Evaluating object %wZ FID %08lX-%08lX-%08lX-%08lX\n",
Irp,
&pDirEntry->NameInformation.FileName,
pObjectInfo->FileId.Cell,
if( !NT_SUCCESS( ntStatus))
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
- AFS_TRACE_LEVEL_ERROR,
- "AFSProcessCreate (%08lX) Failed to evaluate object %wZ FID %08lX-%08lX-%08lX-%08lX Status %08lX\n",
- Irp,
- &pDirEntry->NameInformation.FileName,
- pObjectInfo->FileId.Cell,
- pObjectInfo->FileId.Volume,
- pObjectInfo->FileId.Vnode,
- pObjectInfo->FileId.Unique,
- ntStatus);
+ if ( ntStatus == STATUS_NOT_A_DIRECTORY)
+ {
+
+ if ( !BooleanFlagOn( pObjectInfo->Flags, AFS_OBJECT_FLAGS_PARENT_FID))
+ {
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSProcessCreate (%p) Failed to evaluate object %wZ FID %08lX-%08lX-%08lX-%08lX PARENT %08lX-%08lX-%08lX-%08lX != NULL Status %08lX\n",
+ Irp,
+ &pDirEntry->NameInformation.FileName,
+ pObjectInfo->FileId.Cell,
+ pObjectInfo->FileId.Volume,
+ pObjectInfo->FileId.Vnode,
+ pObjectInfo->FileId.Unique,
+ pParentObjectInfo->FileId.Cell,
+ pParentObjectInfo->FileId.Volume,
+ pParentObjectInfo->FileId.Vnode,
+ pParentObjectInfo->FileId.Unique,
+ ntStatus);
+ }
+ else if ( AFSIsEqualFID( &pParentObjectInfo->FileId, &pObjectInfo->ParentFileId))
+ {
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSProcessCreate (%p) Failed to evaluate object %wZ FID %08lX-%08lX-%08lX-%08lX PARENT %08lX-%08lX-%08lX-%08lX Status %08lX\n",
+ Irp,
+ &pDirEntry->NameInformation.FileName,
+ pObjectInfo->FileId.Cell,
+ pObjectInfo->FileId.Volume,
+ pObjectInfo->FileId.Vnode,
+ pObjectInfo->FileId.Unique,
+ pParentObjectInfo->FileId.Cell,
+ pParentObjectInfo->FileId.Volume,
+ pParentObjectInfo->FileId.Vnode,
+ pParentObjectInfo->FileId.Unique,
+ ntStatus);
+ }
+ else
+ {
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSProcessCreate (%p) Failed to evaluate object %wZ FID %08lX-%08lX-%08lX-%08lX PARENT %08lX-%08lX-%08lX-%08lX != %08lX-%08lX-%08lX-%08lX Status %08lX\n",
+ Irp,
+ &pDirEntry->NameInformation.FileName,
+ pObjectInfo->FileId.Cell,
+ pObjectInfo->FileId.Volume,
+ pObjectInfo->FileId.Vnode,
+ pObjectInfo->FileId.Unique,
+ pParentObjectInfo->FileId.Cell,
+ pParentObjectInfo->FileId.Volume,
+ pParentObjectInfo->FileId.Vnode,
+ pParentObjectInfo->FileId.Unique,
+ pObjectInfo->ParentFileId.Cell,
+ pObjectInfo->ParentFileId.Volume,
+ pObjectInfo->ParentFileId.Vnode,
+ pObjectInfo->ParentFileId.Unique,
+ ntStatus);
+ }
+ }
+ else
+ {
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSProcessCreate (%p) Failed to evaluate object %wZ FID %08lX-%08lX-%08lX-%08lX Status %08lX\n",
+ Irp,
+ &pDirEntry->NameInformation.FileName,
+ pObjectInfo->FileId.Cell,
+ pObjectInfo->FileId.Volume,
+ pObjectInfo->FileId.Vnode,
+ pObjectInfo->FileId.Unique,
+ ntStatus);
+ }
try_return( ntStatus);
}
ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_NOT_EVALUATED);
}
+ ASSERT( BooleanFlagOn( pObjectInfo->Flags, AFS_OBJECT_FLAGS_PARENT_FID) &&
+ AFSIsEqualFID( &pParentObjectInfo->FileId, &pObjectInfo->ParentFileId));
+
//
// We may have raced and the Fcb is already created
//
- if( pObjectInfo->Fcb != NULL)
- {
+ //
+ // Allocate and initialize the Fcb for the file.
+ //
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessCreate (%08lX) Not allocating Fcb for file %wZ\n",
- Irp,
- FullFileName);
+ ntStatus = AFSInitFcb( pDirEntry);
- *Fcb = pObjectInfo->Fcb;
+ *Fcb = pObjectInfo->Fcb;
- AFSAcquireExcl( &(*Fcb)->NPFcb->Resource,
- TRUE);
- }
- else
+ if( !NT_SUCCESS( ntStatus))
{
- //
- // Allocate and initialize the Fcb for the file.
- //
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSProcessCreate (%p) Failed to initialize fcb %wZ Status %08lX\n",
+ Irp,
+ FullFileName,
+ ntStatus);
- ntStatus = AFSInitFcb( pDirEntry,
- Fcb);
+ try_return( ntStatus);
+ }
- if( !NT_SUCCESS( ntStatus))
- {
+ ntStatus = STATUS_SUCCESS;
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
- AFS_TRACE_LEVEL_ERROR,
- "AFSProcessCreate (%08lX) Failed to initialize fcb %wZ Status %08lX\n",
- Irp,
- FullFileName,
- ntStatus);
+ //
+ // Increment the open count on this Fcb
+ //
- try_return( ntStatus);
- }
+ lCount = InterlockedIncrement( &(*Fcb)->OpenReferenceCount);
- bAllocatedFcb = TRUE;
- }
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSProcessCreate Increment count on Fcb %p Cnt %d\n",
+ *Fcb,
+ lCount);
bReleaseFcb = TRUE;
// Initialize the Ccb for the file.
//
- ntStatus = AFSInitCcb( Ccb);
+ ntStatus = AFSInitCcb( Ccb,
+ pDirEntry,
+ *pDesiredAccess,
+ 0);
if( !NT_SUCCESS( ntStatus))
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessCreate (%08lX) Failed to initialize ccb %wZ Status %08lX\n",
+ "AFSProcessCreate (%p) Failed to initialize ccb %wZ Status %08lX\n",
Irp,
FullFileName,
ntStatus);
bAllocatedCcb = TRUE;
//
- // Initialize the Ccb
- //
-
- (*Ccb)->DirectoryCB = pDirEntry;
-
- //
// If this is a file, update the headers filesizes.
//
AFSFsRtlNotifyFullReportChange( pParentObjectInfo,
*Ccb,
- (ULONG)FILE_NOTIFY_CHANGE_FILE_NAME,
- (ULONG)FILE_ACTION_ADDED);
+ (ULONG)FILE_NOTIFY_CHANGE_FILE_NAME,
+ (ULONG)FILE_ACTION_ADDED);
(*Fcb)->NPFcb->Specific.File.ExtentsRequestStatus = STATUS_SUCCESS;
}
AFSFsRtlNotifyFullReportChange( pParentObjectInfo,
*Ccb,
- (ULONG)FILE_NOTIFY_CHANGE_DIR_NAME,
- (ULONG)FILE_ACTION_ADDED);
+ (ULONG)FILE_NOTIFY_CHANGE_DIR_NAME,
+ (ULONG)FILE_ACTION_ADDED);
}
else if( (*Fcb)->Header.NodeTypeCode == AFS_MOUNT_POINT_FCB ||
(*Fcb)->Header.NodeTypeCode == AFS_SYMBOLIC_LINK_FCB ||
- (*Fcb)->Header.NodeTypeCode == AFS_DFS_LINK_FCB)
+ (*Fcb)->Header.NodeTypeCode == AFS_DFS_LINK_FCB ||
+ (*Fcb)->Header.NodeTypeCode == AFS_INVALID_FCB)
{
//
AFSFsRtlNotifyFullReportChange( pParentObjectInfo,
*Ccb,
- (ULONG)FILE_NOTIFY_CHANGE_DIR_NAME,
- (ULONG)FILE_ACTION_ADDED);
+ (ULONG)FILE_NOTIFY_CHANGE_DIR_NAME,
+ (ULONG)FILE_ACTION_ADDED);
}
//
pFileObject,
&(*Fcb)->ShareAccess);
- //
- // Increment the open count on this Fcb
- //
-
- InterlockedIncrement( &(*Fcb)->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessCreate Increment count on Fcb %08lX Cnt %d\n",
- *Fcb,
- (*Fcb)->OpenReferenceCount);
-
- InterlockedIncrement( &(*Fcb)->OpenHandleCount);
+ lCount = InterlockedIncrement( &(*Fcb)->OpenHandleCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessCreate Increment handle count on Fcb %08lX Cnt %d\n",
+ "AFSProcessCreate Increment handle count on Fcb %p Cnt %d\n",
(*Fcb),
- (*Fcb)->OpenHandleCount);
+ lCount);
//
// Increment the open reference and handle on the parent node
//
- InterlockedIncrement( &pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount);
+ lCount = InterlockedIncrement( &pParentObjectInfo->Specific.Directory.ChildOpenHandleCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessCreate Increment child open handle count on Parent object %08lX Cnt %d\n",
- pObjectInfo->ParentObjectInformation,
- pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount);
+ "AFSProcessCreate Increment child open handle count on Parent object %p Cnt %d\n",
+ pParentObjectInfo,
+ lCount);
- InterlockedIncrement( &pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenReferenceCount);
+ lCount = InterlockedIncrement( &pParentObjectInfo->Specific.Directory.ChildOpenReferenceCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessCreate Increment child open ref count on Parent object %08lX Cnt %d\n",
- pObjectInfo->ParentObjectInformation,
- pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenReferenceCount);
+ "AFSProcessCreate Increment child open ref count on Parent object %p Cnt %d\n",
+ pParentObjectInfo,
+ lCount);
if( ulOptions & FILE_DELETE_ON_CLOSE)
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessCreate (%08lX) Setting PENDING_DELETE flag in DirEntry %p Name %wZ\n",
+ "AFSProcessCreate (%p) Setting PENDING_DELETE flag in DirEntry %p Name %wZ\n",
Irp,
pDirEntry,
FullFileName);
if( bReleaseFcb)
{
+ if( !NT_SUCCESS( ntStatus))
+ {
+ //
+ // Decrement the open count on this Fcb
+ //
+
+ lCount = InterlockedDecrement( &(*Fcb)->OpenReferenceCount);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSProcessCreate Decrement count on Fcb %p Cnt %d\n",
+ *Fcb,
+ lCount);
+ }
+
AFSReleaseResource( &(*Fcb)->NPFcb->Resource);
}
+ if ( bFileCreated)
+ {
+
+ //
+ // Decrement the reference added during initialization of the DE
+ // AFSInitCcb allocates its own reference count.
+ //
+
+ lCount = InterlockedDecrement( &pDirEntry->DirOpenReferenceCount);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSProcessCreate Decrement count on %wZ DE %p Cnt %d\n",
+ &pDirEntry->NameInformation.FileName,
+ pDirEntry,
+ lCount);
+
+ ASSERT( lCount >= 0);
+ }
+
if( !NT_SUCCESS( ntStatus))
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessCreate Create failed, removing DE %p from aprent object %p Status %08lX\n",
+ "AFSProcessCreate Create failed, removing DE %p from parent object %p Status %08lX\n",
pDirEntry,
pParentObjectInfo,
ntStatus);
SetFlag( pDirEntry->Flags, AFS_DIR_ENTRY_DELETED);
- //
- // Decrement the reference added during initialization of the DE
- //
-
- InterlockedDecrement( &pDirEntry->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessCreate Decrement count on %wZ DE %p Cnt %d\n",
- &pDirEntry->NameInformation.FileName,
- pDirEntry,
- pDirEntry->OpenReferenceCount);
+ AFSNotifyDelete( pDirEntry,
+ AuthGroup,
+ FALSE);
//
// Pull the directory entry from the parent
pDirEntry,
FALSE); // Leave it in the enum list so the worker cleans it up
- AFSNotifyDelete( pDirEntry,
- FALSE);
-
//
// Tag the parent as needing verification
//
SetFlag( pParentObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
+ pParentObjectInfo->DataVersion.QuadPart = (ULONGLONG)-1;
+
AFSReleaseResource( pParentObjectInfo->Specific.Directory.DirectoryNodeHdr.TreeLock);
}
if( bAllocatedCcb)
{
- AFSRemoveCcb( *Ccb);
+ AFSRemoveCcb( NULL,
+ *Ccb);
}
- if( bAllocatedFcb)
- {
+ //
+ // Fcb will be freed by AFSPrimaryVolumeWorker thread
+ //
- AFSRemoveFcb( pObjectInfo->Fcb);
-
- pObjectInfo->Fcb = NULL;
- }
-
- *Fcb = NULL;
+ *Fcb = NULL;
*Ccb = NULL;
}
OUT AFSFcb **Fcb,
OUT AFSCcb **Ccb)
{
-
+ UNREFERENCED_PARAMETER(VolumeCB);
NTSTATUS ntStatus = STATUS_SUCCESS;
PFILE_OBJECT pFileObject = NULL;
PIO_STACK_LOCATION pIrpSp = IoGetCurrentIrpStackLocation( Irp);
PACCESS_MASK pDesiredAccess = NULL;
USHORT usShareAccess;
BOOLEAN bAllocatedCcb = FALSE;
- BOOLEAN bReleaseFcb = FALSE, bAllocatedFcb = FALSE;
- AFSObjectInfoCB *pParentObject = NULL, *pTargetObject = NULL;
+ BOOLEAN bReleaseFcb = FALSE;
+ AFSObjectInfoCB *pParentObject = NULL;
+ AFSObjectInfoCB *pGrandParentObject = NULL;
UNICODE_STRING uniTargetName;
+ LONG lCount;
__Enter
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenTargetDirectory (%08lX) Processing file %wZ\n",
+ "AFSOpenTargetDirectory (%p) Processing file %wZ\n",
Irp,
TargetName);
//
// Make sure we have an Fcb for the access
+
+ //
+ // Allocate and initialize the Fcb for the file.
//
- if( pParentObject->Fcb != NULL)
- {
+ ntStatus = AFSInitFcb( ParentDirectoryCB);
- *Fcb = pParentObject->Fcb;
+ *Fcb = pParentObject->Fcb;
- AFSAcquireExcl( &(*Fcb)->NPFcb->Resource,
- TRUE);
- }
- else
+ if( !NT_SUCCESS( ntStatus))
{
- //
- // Allocate and initialize the Fcb for the file.
- //
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSOpenTargetDirectory (%p) Failed to initialize fcb %wZ Status %08lX\n",
+ Irp,
+ &ParentDirectoryCB->NameInformation.FileName,
+ ntStatus);
- ntStatus = AFSInitFcb( ParentDirectoryCB,
- Fcb);
+ try_return( ntStatus);
+ }
- if( !NT_SUCCESS( ntStatus))
- {
+ ntStatus = STATUS_SUCCESS;
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
- AFS_TRACE_LEVEL_ERROR,
- "AFSProcessCreate (%08lX) Failed to initialize fcb %wZ Status %08lX\n",
- Irp,
- &ParentDirectoryCB->NameInformation.FileName,
- ntStatus);
+ //
+ // Increment the open count on this Fcb
+ //
- try_return( ntStatus);
- }
+ lCount = InterlockedIncrement( &pParentObject->Fcb->OpenReferenceCount);
- bAllocatedFcb = TRUE;
- }
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSOpenTargetDirectory Increment count on Fcb %p Cnt %d\n",
+ pParentObject->Fcb,
+ lCount);
bReleaseFcb = TRUE;
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSOpenTargetDirectory (%08lX) Access check failure %wZ Status %08lX\n",
+ "AFSOpenTargetDirectory (%p) Access check failure %wZ Status %08lX\n",
Irp,
&ParentDirectoryCB->NameInformation.FileName,
ntStatus);
// Initialize the Ccb for the file.
//
- ntStatus = AFSInitCcb( Ccb);
+ ntStatus = AFSInitCcb( Ccb,
+ ParentDirectoryCB,
+ *pDesiredAccess,
+ 0);
if( !NT_SUCCESS( ntStatus))
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSOpenTargetDirectory (%08lX) Failed to initialize ccb %wZ Status %08lX\n",
+ "AFSOpenTargetDirectory (%p) Failed to initialize ccb %wZ Status %08lX\n",
Irp,
&ParentDirectoryCB->NameInformation.FileName,
ntStatus);
bAllocatedCcb = TRUE;
- //
- // Initialize the Ccb
- //
-
- (*Ccb)->DirectoryCB = ParentDirectoryCB;
-
if( TargetDirectoryCB != NULL &&
FsRtlAreNamesEqual( &TargetDirectoryCB->NameInformation.FileName,
TargetName,
&pParentObject->Fcb->ShareAccess);
}
- //
- // Increment the open count on this Fcb
- //
-
- InterlockedIncrement( &pParentObject->Fcb->OpenReferenceCount);
+ lCount = InterlockedIncrement( &pParentObject->Fcb->OpenHandleCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenTargetDirectory Increment count on Fcb %08lX Cnt %d\n",
+ "AFSOpenTargetDirectory Increment handle count on Fcb %p Cnt %d\n",
pParentObject->Fcb,
- pParentObject->Fcb->OpenReferenceCount);
-
- InterlockedIncrement( &pParentObject->Fcb->OpenHandleCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenTargetDirectory Increment handle count on Fcb %08lX Cnt %d\n",
- pParentObject->Fcb,
- pParentObject->Fcb->OpenHandleCount);
+ lCount);
//
// Increment the open reference and handle on the parent node
//
- if( pParentObject->ParentObjectInformation != NULL)
+ if( BooleanFlagOn( pParentObject->Flags, AFS_OBJECT_FLAGS_PARENT_FID))
{
- InterlockedIncrement( &pParentObject->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount);
+ pGrandParentObject = AFSFindObjectInfo( pParentObject->VolumeCB,
+ &pParentObject->ParentFileId);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenTargetDirectory Increment child open handle count on Parent object %08lX Cnt %d\n",
- pParentObject->ParentObjectInformation,
- pParentObject->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount);
+ if ( pGrandParentObject)
+ {
- InterlockedIncrement( &pParentObject->ParentObjectInformation->Specific.Directory.ChildOpenReferenceCount);
+ lCount = InterlockedIncrement( &pGrandParentObject->Specific.Directory.ChildOpenHandleCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenTargetDirectory Increment child open ref count on Parent object %08lX Cnt %d\n",
- pParentObject->ParentObjectInformation,
- pParentObject->ParentObjectInformation->Specific.Directory.ChildOpenReferenceCount);
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSOpenTargetDirectory Increment child open handle count on Parent object %p Cnt %d\n",
+ pGrandParentObject,
+ lCount);
+
+ lCount = InterlockedIncrement( &pGrandParentObject->Specific.Directory.ChildOpenReferenceCount);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSOpenTargetDirectory Increment child open ref count on Parent object %p Cnt %d\n",
+ pGrandParentObject,
+ lCount);
+
+ AFSReleaseObjectInfo( &pGrandParentObject);
+ }
}
try_exit:
if( bReleaseFcb)
{
+ if( !NT_SUCCESS( ntStatus))
+ {
+ //
+ // Decrement the open count on this Fcb
+ //
+
+ lCount = InterlockedDecrement( &pParentObject->Fcb->OpenReferenceCount);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSOpenTargetDirectory Decrement count on Fcb %p Cnt %d\n",
+ pParentObject->Fcb,
+ lCount);
+ }
+
AFSReleaseResource( &pParentObject->Fcb->NPFcb->Resource);
}
if( bAllocatedCcb)
{
- AFSRemoveCcb( *Ccb);
+ AFSRemoveCcb( NULL,
+ *Ccb);
}
*Ccb = NULL;
- if( bAllocatedFcb)
- {
-
- AFSRemoveFcb( pParentObject->Fcb);
-
- pParentObject->Fcb = NULL;
- }
+ //
+ // Fcb will be freed by AFSPrimaryVolumeWorker thread
+ //
*Fcb = NULL;
}
OUT AFSFcb **Fcb,
OUT AFSCcb **Ccb)
{
-
+ UNREFERENCED_PARAMETER(VolumeCB);
NTSTATUS ntStatus = STATUS_SUCCESS;
PFILE_OBJECT pFileObject = NULL;
PIO_STACK_LOCATION pIrpSp = IoGetCurrentIrpStackLocation( Irp);
PACCESS_MASK pDesiredAccess = NULL;
USHORT usShareAccess;
- BOOLEAN bAllocatedCcb = FALSE, bReleaseFcb = FALSE, bAllocatedFcb = FALSE;
- ULONG ulAdditionalFlags = 0, ulOptions = 0;
+ BOOLEAN bAllocatedCcb = FALSE, bReleaseFcb = FALSE;
+ ULONG ulOptions = 0;
AFSFileOpenCB stOpenCB;
AFSFileOpenResultCB stOpenResultCB;
ULONG ulResultLen = 0;
AFSObjectInfoCB *pObjectInfo = NULL;
ULONG ulFileAccess = 0;
AFSFileAccessReleaseCB stReleaseFileAccess;
+ LONG lCount;
__Enter
{
pObjectInfo = DirectoryCB->ObjectInformation;
+ ASSERT( BooleanFlagOn( pObjectInfo->Flags, AFS_OBJECT_FLAGS_PARENT_FID) &&
+ AFSIsEqualFID( &pParentObjectInfo->FileId, &pObjectInfo->ParentFileId));
+
//
// Check if the entry is pending a deletion
//
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOpen (%08lX) Entry pending delete %wZ Status %08lX\n",
+ "AFSProcessOpen (%p) Entry pending delete %wZ Status %08lX\n",
Irp,
&DirectoryCB->NameInformation.FileName,
ntStatus);
ntStatus = AFSValidateEntry( DirectoryCB,
AuthGroup,
- TRUE,
- FALSE);
+ FALSE,
+ TRUE);
if( !NT_SUCCESS( ntStatus))
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOpen (%08lX) Failed to validate entry %wZ Status %08lX\n",
+ "AFSProcessOpen (%p) Failed to validate entry %wZ Status %08lX\n",
Irp,
&DirectoryCB->NameInformation.FileName,
ntStatus);
{
ntStatus = AFSNotifyDelete( DirectoryCB,
+ AuthGroup,
TRUE);
if( !NT_SUCCESS( ntStatus))
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOpen (%08lX) Cannot delete entry %wZ marked for delete on close Status %08lX\n",
+ "AFSProcessOpen (%p) Cannot delete entry %wZ marked for delete on close Status %08lX\n",
Irp,
&DirectoryCB->NameInformation.FileName,
ntStatus);
// Be sure we have an Fcb for the current object
//
- if( pObjectInfo->Fcb == NULL)
- {
+ ntStatus = AFSInitFcb( DirectoryCB);
- ntStatus = AFSInitFcb( DirectoryCB,
- &pObjectInfo->Fcb);
-
- if( !NT_SUCCESS( ntStatus))
- {
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
- AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOpen (%08lX) Failed to init fcb on %wZ Status %08lX\n",
- Irp,
- &DirectoryCB->NameInformation.FileName,
- ntStatus);
+ if( !NT_SUCCESS( ntStatus))
+ {
- try_return( ntStatus);
- }
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSProcessOpen (%p) Failed to init fcb on %wZ Status %08lX\n",
+ Irp,
+ &DirectoryCB->NameInformation.FileName,
+ ntStatus);
- bAllocatedFcb = TRUE;
+ try_return( ntStatus);
}
- else
- {
- AFSAcquireExcl( pObjectInfo->Fcb->Header.Resource,
- TRUE);
- }
+ ntStatus = STATUS_SUCCESS;
+
+ //
+ // AFSInitFcb returns the Fcb resource held
+ //
bReleaseFcb = TRUE;
//
- // Reference the Fcb so it won't go away while we call into the service for processing
+ // Increment the open count on this Fcb
//
- InterlockedIncrement( &pObjectInfo->Fcb->OpenReferenceCount);
+ lCount = InterlockedIncrement( &pObjectInfo->Fcb->OpenReferenceCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessOpen Increment count on Fcb %08lX Cnt %d\n",
+ "AFSProcessOpen Increment2 count on Fcb %p Cnt %d\n",
pObjectInfo->Fcb,
- pObjectInfo->Fcb->OpenReferenceCount);
+ lCount);
//
// Check access on the entry
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOpen (%08lX) Failed to check share access on %wZ Status %08lX\n",
+ "AFSProcessOpen (%p) Failed to check share access on %wZ Status %08lX\n",
Irp,
&DirectoryCB->NameInformation.FileName,
ntStatus);
BooleanFlagOn(ulOptions, FILE_DELETE_ON_CLOSE))
{
- if( !MmFlushImageSection( &pObjectInfo->Fcb->NPFcb->SectionObjectPointers,
- MmFlushForWrite))
+ BOOLEAN bMmFlushed;
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSProcessOpen Acquiring Fcb SectionObject lock %p EXCL %08lX\n",
+ &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
+ PsGetCurrentThread());
+
+ AFSAcquireExcl( &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
+ TRUE);
+
+ bMmFlushed = MmFlushImageSection( &pObjectInfo->Fcb->NPFcb->SectionObjectPointers,
+ MmFlushForWrite);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSProcessOpen Releasing Fcb SectionObject lock %p EXCL %08lX\n",
+ &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
+ PsGetCurrentThread());
+
+ AFSReleaseResource( &pObjectInfo->Fcb->NPFcb->SectionObjectResource);
+
+ if ( !bMmFlushed)
{
ntStatus = BooleanFlagOn(ulOptions, FILE_DELETE_ON_CLOSE) ? STATUS_CANNOT_DELETE :
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOpen (%08lX) Failed to flush image section %wZ Status %08lX\n",
+ "AFSProcessOpen (%p) Failed to flush image section %wZ Status %08lX\n",
Irp,
&DirectoryCB->NameInformation.FileName,
ntStatus);
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOpen (%08lX) Attempt to open file as directory %wZ Status %08lX\n",
+ "AFSProcessOpen (%p) Attempt to open file as directory %wZ Status %08lX\n",
Irp,
&DirectoryCB->NameInformation.FileName,
ntStatus);
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOpen (%08lX) Attempt to open directory as file %wZ Status %08lX\n",
+ "AFSProcessOpen (%p) Attempt to open directory as file %wZ Status %08lX\n",
Irp,
&DirectoryCB->NameInformation.FileName,
ntStatus);
}
else if( pObjectInfo->Fcb->Header.NodeTypeCode == AFS_MOUNT_POINT_FCB ||
pObjectInfo->Fcb->Header.NodeTypeCode == AFS_SYMBOLIC_LINK_FCB ||
- pObjectInfo->Fcb->Header.NodeTypeCode == AFS_DFS_LINK_FCB)
+ pObjectInfo->Fcb->Header.NodeTypeCode == AFS_DFS_LINK_FCB ||
+ pObjectInfo->Fcb->Header.NodeTypeCode == AFS_INVALID_FCB)
{
}
AuthGroup,
&DirectoryCB->NameInformation.FileName,
&pObjectInfo->FileId,
+ pObjectInfo->VolumeCB->VolumeInformation.Cell,
+ pObjectInfo->VolumeCB->VolumeInformation.CellLength,
(void *)&stOpenCB,
sizeof( AFSFileOpenCB),
(void *)&stOpenResultCB,
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOpen (%08lX) Failed open in service %wZ Status %08lX\n",
+ "AFSProcessOpen (%p) Failed open in service %wZ Status %08lX\n",
Irp,
&DirectoryCB->NameInformation.FileName,
ntStatus);
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOpen (%08lX) Failed to check access from service Desired %08lX Granted %08lX Entry %wZ Status %08lX\n",
+ "AFSProcessOpen (%p) Failed to check access from service Desired %08lX Granted %08lX Entry %wZ Status %08lX\n",
Irp,
*pDesiredAccess,
stOpenResultCB.GrantedAccess,
// Initialize the Ccb for the file.
//
- ntStatus = AFSInitCcb( Ccb);
+ ntStatus = AFSInitCcb( Ccb,
+ DirectoryCB,
+ *pDesiredAccess,
+ ulFileAccess);
if( !NT_SUCCESS( ntStatus))
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOpen (%08lX) Failed to initialize ccb %wZ Status %08lX\n",
+ "AFSProcessOpen (%p) Failed to initialize ccb %wZ Status %08lX\n",
Irp,
&DirectoryCB->NameInformation.FileName,
ntStatus);
bAllocatedCcb = TRUE;
- (*Ccb)->DirectoryCB = DirectoryCB;
-
- (*Ccb)->FileAccess = ulFileAccess;
-
//
// Perform the access check on the target if this is a mount point or symlink
//
&pObjectInfo->Fcb->ShareAccess);
}
- //
- // Increment the open count on this Fcb
- //
-
- InterlockedIncrement( &pObjectInfo->Fcb->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessOpen Increment2 count on Fcb %08lX Cnt %d\n",
- pObjectInfo->Fcb,
- pObjectInfo->Fcb->OpenReferenceCount);
-
- InterlockedIncrement( &pObjectInfo->Fcb->OpenHandleCount);
+ lCount = InterlockedIncrement( &pObjectInfo->Fcb->OpenHandleCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessOpen Increment handle count on Fcb %08lX Cnt %d\n",
+ "AFSProcessOpen Increment handle count on Fcb %p Cnt %d\n",
pObjectInfo->Fcb,
- pObjectInfo->Fcb->OpenHandleCount);
+ lCount);
//
// Increment the open reference and handle on the parent node
//
- InterlockedIncrement( &pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount);
+ lCount = InterlockedIncrement( &pParentObjectInfo->Specific.Directory.ChildOpenHandleCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessOpen Increment child open handle count on Parent object %08lX Cnt %d\n",
- pObjectInfo->ParentObjectInformation,
- pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount);
+ "AFSProcessOpen Increment child open handle count on Parent object %p Cnt %d\n",
+ pParentObjectInfo,
+ lCount);
- InterlockedIncrement( &pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenReferenceCount);
+ lCount = InterlockedIncrement( &pParentObjectInfo->Specific.Directory.ChildOpenReferenceCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessOpen Increment child open ref count on Parent object %08lX Cnt %d\n",
- pObjectInfo->ParentObjectInformation,
- pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenReferenceCount);
+ "AFSProcessOpen Increment child open ref count on Parent object %p Cnt %d\n",
+ pParentObjectInfo,
+ lCount);
if( BooleanFlagOn( ulOptions, FILE_DELETE_ON_CLOSE))
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessOpen (%08lX) Setting PENDING_DELETE flag in DirEntry %p Name %wZ\n",
+ "AFSProcessOpen (%p) Setting PENDING_DELETE flag in DirEntry %p Name %wZ\n",
Irp,
DirectoryCB,
&DirectoryCB->NameInformation.FileName);
if( bReleaseFcb)
{
- //
- // Remove the reference we added initially
- //
+ if( !NT_SUCCESS( ntStatus))
+ {
+ //
+ // Decrement the open count on this Fcb
+ //
- InterlockedDecrement( &pObjectInfo->Fcb->OpenReferenceCount);
+ lCount = InterlockedDecrement( &pObjectInfo->Fcb->OpenReferenceCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessOpen Decrement count on Fcb %08lX Cnt %d\n",
- pObjectInfo->Fcb,
- pObjectInfo->Fcb->OpenReferenceCount);
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSProcessOpen Decrement2 count on Fcb %p Cnt %d\n",
+ pObjectInfo->Fcb,
+ lCount);
+ }
AFSReleaseResource( pObjectInfo->Fcb->Header.Resource);
}
AuthGroup,
&DirectoryCB->NameInformation.FileName,
&pObjectInfo->FileId,
+ pObjectInfo->VolumeCB->VolumeInformation.Cell,
+ pObjectInfo->VolumeCB->VolumeInformation.CellLength,
(void *)&stReleaseFileAccess,
sizeof( AFSFileAccessReleaseCB),
NULL,
if( bAllocatedCcb)
{
- AFSRemoveCcb( *Ccb);
+ AFSRemoveCcb( NULL,
+ *Ccb);
}
*Ccb = NULL;
- if( bAllocatedFcb)
- {
-
- AFSRemoveFcb( pObjectInfo->Fcb);
-
- pObjectInfo->Fcb = NULL;
- }
+ //
+ // Fcb will be freed by AFSPrimaryVolumeWorker thread
+ //
*Fcb = NULL;
}
OUT AFSFcb **Fcb,
OUT AFSCcb **Ccb)
{
-
+ UNREFERENCED_PARAMETER(DeviceObject);
NTSTATUS ntStatus = STATUS_SUCCESS;
PIO_STACK_LOCATION pIrpSp = IoGetCurrentIrpStackLocation( Irp);
PFILE_OBJECT pFileObject = NULL;
LARGE_INTEGER liZero = {0,0};
BOOLEAN bReleasePaging = FALSE, bReleaseFcb = FALSE;
ULONG ulAttributes = 0;
- LARGE_INTEGER liTime;
ULONG ulCreateDisposition = 0;
- BOOLEAN bAllocatedCcb = FALSE, bAllocatedFcb = FALSE;
+ BOOLEAN bAllocatedCcb = FALSE;
+ BOOLEAN bUserMapped = FALSE;
PACCESS_MASK pDesiredAccess = NULL;
USHORT usShareAccess;
AFSObjectInfoCB *pParentObjectInfo = NULL;
AFSObjectInfoCB *pObjectInfo = NULL;
+ LONG lCount;
+ LARGE_INTEGER liSaveSize;
+ LARGE_INTEGER liSaveVDL;
+ LARGE_INTEGER liSaveAlloc;
__Enter
{
pDesiredAccess = &pIrpSp->Parameters.Create.SecurityContext->DesiredAccess;
+
usShareAccess = pIrpSp->Parameters.Create.ShareAccess;
pFileObject = pIrpSp->FileObject;
Irp,
&DirectoryCB->NameInformation.FileName);
- try_return( ntStatus = STATUS_ACCESS_DENIED);
+ try_return( ntStatus = STATUS_MEDIA_WRITE_PROTECTED);
}
pParentObjectInfo = ParentDirCB->ObjectInformation;
pObjectInfo = DirectoryCB->ObjectInformation;
+ ASSERT( BooleanFlagOn( pObjectInfo->Flags, AFS_OBJECT_FLAGS_PARENT_FID) &&
+ AFSIsEqualFID( &pParentObjectInfo->FileId, &pObjectInfo->ParentFileId));
+
//
// Check if we should go and retrieve updated information for the node
//
ntStatus = AFSValidateEntry( DirectoryCB,
AuthGroup,
- TRUE,
- FALSE);
+ FALSE,
+ TRUE);
if( !NT_SUCCESS( ntStatus))
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOverwriteSupersede (%08lX) Failed to validate entry %wZ Status %08lX\n",
+ "AFSProcessOverwriteSupersede (%p) Failed to validate entry %wZ Status %08lX\n",
Irp,
&DirectoryCB->NameInformation.FileName,
ntStatus);
// Be sure we have an Fcb for the object block
//
- if( pObjectInfo->Fcb == NULL)
- {
+ ntStatus = AFSInitFcb( DirectoryCB);
- ntStatus = AFSInitFcb( DirectoryCB,
- Fcb);
-
- if( !NT_SUCCESS( ntStatus))
- {
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
- AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOverwriteSupersede (%08lX) Failed to initialize fcb %wZ Status %08lX\n",
- Irp,
- &DirectoryCB->NameInformation.FileName,
- ntStatus);
-
- try_return( ntStatus);
- }
+ *Fcb = pObjectInfo->Fcb;
- bAllocatedFcb = TRUE;
- }
- else
+ if( !NT_SUCCESS( ntStatus))
{
- AFSAcquireExcl( pObjectInfo->Fcb->Header.Resource,
- TRUE);
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSProcessOverwriteSupersede (%p) Failed to initialize fcb %wZ Status %08lX\n",
+ Irp,
+ &DirectoryCB->NameInformation.FileName,
+ ntStatus);
+
+ try_return( ntStatus);
}
- bReleaseFcb = TRUE;
+ ntStatus = STATUS_SUCCESS;
//
- // Reference the Fcb so it won't go away while processing the request
+ // Increment the open count on this Fcb.
//
- InterlockedIncrement( &pObjectInfo->Fcb->OpenReferenceCount);
+ lCount = InterlockedIncrement( &pObjectInfo->Fcb->OpenReferenceCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessOverwriteSupersede Increment count on Fcb %08lX Cnt %d\n",
+ "AFSProcessOverwriteSupersede Increment2 count on Fcb %p Cnt %d\n",
pObjectInfo->Fcb,
- pObjectInfo->Fcb->OpenReferenceCount);
+ lCount);
+
+ bReleaseFcb = TRUE;
//
// Check access on the entry
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOverwriteSupersede (%08lX) Access check failure %wZ Status %08lX\n",
+ "AFSProcessOverwriteSupersede (%p) Access check failure %wZ Status %08lX\n",
Irp,
&DirectoryCB->NameInformation.FileName,
ntStatus);
}
}
+ AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSProcessOverwriteSupercede Acquiring Fcb SectionObject lock %p EXCL %08lX\n",
+ &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
+ PsGetCurrentThread());
+
+ AFSAcquireExcl( &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
+ TRUE);
+
//
// Before we actually truncate, check to see if the purge
// is going to fail.
//
- if( !MmCanFileBeTruncated( &pObjectInfo->Fcb->NPFcb->SectionObjectPointers,
- &liZero))
+ bUserMapped = !MmCanFileBeTruncated( &pObjectInfo->Fcb->NPFcb->SectionObjectPointers,
+ &liZero);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSProcessOverwriteSupercede Releasing Fcb SectionObject lock %p EXCL %08lX\n",
+ &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
+ PsGetCurrentThread());
+
+ AFSReleaseResource( &pObjectInfo->Fcb->NPFcb->SectionObjectResource);
+
+ if( bUserMapped)
{
ntStatus = STATUS_USER_MAPPED_FILE;
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOverwriteSupersede (%08lX) File user mapped %wZ Status %08lX\n",
+ "AFSProcessOverwriteSupersede (%p) File user mapped %wZ Status %08lX\n",
Irp,
&DirectoryCB->NameInformation.FileName,
ntStatus);
// Initialize the Ccb for the file.
//
- ntStatus = AFSInitCcb( Ccb);
+ ntStatus = AFSInitCcb( Ccb,
+ DirectoryCB,
+ *pDesiredAccess,
+ 0);
if( !NT_SUCCESS( ntStatus))
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOverwriteSupersede (%08lX) Failed to initialize ccb %wZ Status %08lX\n",
+ "AFSProcessOverwriteSupersede (%p) Failed to initialize ccb %wZ Status %08lX\n",
Irp,
&DirectoryCB->NameInformation.FileName,
ntStatus);
bAllocatedCcb = TRUE;
//
- // Initialize the Ccb
+ // Set the file length to zero
//
- (*Ccb)->DirectoryCB = DirectoryCB;
+ AFSAcquireExcl( pObjectInfo->Fcb->Header.PagingIoResource,
+ TRUE);
- //
- // Need to purge any data currently in the cache
- //
+ bReleasePaging = TRUE;
- CcPurgeCacheSection( &pObjectInfo->Fcb->NPFcb->SectionObjectPointers,
- NULL,
- 0,
- FALSE);
+ liSaveSize = pObjectInfo->Fcb->Header.FileSize;
+ liSaveAlloc = pObjectInfo->Fcb->Header.AllocationSize;
+ liSaveVDL = pObjectInfo->Fcb->Header.ValidDataLength;
pObjectInfo->Fcb->Header.FileSize.QuadPart = 0;
pObjectInfo->Fcb->Header.ValidDataLength.QuadPart = 0;
KeQuerySystemTime( &pObjectInfo->LastAccessTime);
- //KeQuerySystemTime( &pObjectInfo->CreationTime);
-
KeQuerySystemTime( &pObjectInfo->LastWriteTime);
+ //
+ // Set the update flag accordingly
+ //
+
+ SetFlag( pObjectInfo->Fcb->Flags, AFS_FCB_FLAG_FILE_MODIFIED |
+ AFS_FCB_FLAG_UPDATE_CREATE_TIME |
+ AFS_FCB_FLAG_UPDATE_CHANGE_TIME |
+ AFS_FCB_FLAG_UPDATE_ACCESS_TIME |
+ AFS_FCB_FLAG_UPDATE_LAST_WRITE_TIME);
+
ntStatus = AFSUpdateFileInformation( &pParentObjectInfo->FileId,
pObjectInfo,
AuthGroup);
if( !NT_SUCCESS( ntStatus))
{
+ pObjectInfo->Fcb->Header.ValidDataLength = liSaveVDL;
+ pObjectInfo->Fcb->Header.FileSize = liSaveSize;
+ pObjectInfo->Fcb->Header.AllocationSize = liSaveAlloc;
+ pObjectInfo->Fcb->ObjectInformation->EndOfFile = liSaveSize;
+ pObjectInfo->Fcb->ObjectInformation->AllocationSize = liSaveAlloc;
+
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSProcessOverwriteSupersede (%08lX) Failed to update file information %wZ Status %08lX\n",
+ "AFSProcessOverwriteSupersede (%p) Failed to update file information %wZ Status %08lX\n",
Irp,
&DirectoryCB->NameInformation.FileName,
ntStatus);
try_return( ntStatus);
}
- AFSAcquireExcl( pObjectInfo->Fcb->Header.PagingIoResource,
- TRUE);
-
- bReleasePaging = TRUE;
-
- pFileObject->SectionObjectPointer = &pObjectInfo->Fcb->NPFcb->SectionObjectPointers;
-
- pFileObject->FsContext = (void *)pObjectInfo->Fcb;
-
- pFileObject->FsContext2 = (void *)*Ccb;
-
- //
- // Set the update flag accordingly
- //
-
- SetFlag( pObjectInfo->Fcb->Flags, AFS_FCB_FLAG_FILE_MODIFIED |
- AFS_FCB_FLAG_UPDATE_CREATE_TIME |
- AFS_FCB_FLAG_UPDATE_CHANGE_TIME |
- AFS_FCB_FLAG_UPDATE_ACCESS_TIME |
- AFS_FCB_FLAG_UPDATE_LAST_WRITE_TIME);
-
- CcSetFileSizes( pFileObject,
- (PCC_FILE_SIZES)&pObjectInfo->Fcb->Header.AllocationSize);
-
- AFSReleaseResource( pObjectInfo->Fcb->Header.PagingIoResource);
-
- bReleasePaging = FALSE;
-
ulAttributes |= FILE_ATTRIBUTE_ARCHIVE;
if( ulCreateDisposition == FILE_SUPERSEDE)
Irp->IoStatus.Information = FILE_OVERWRITTEN;
}
- //
- // Increment the open count on this Fcb.
- //
-
- InterlockedIncrement( &pObjectInfo->Fcb->OpenReferenceCount);
+ lCount = InterlockedIncrement( &pObjectInfo->Fcb->OpenHandleCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessOverwriteSupersede Increment2 count on Fcb %08lX Cnt %d\n",
+ "AFSProcessOverwriteSupersede Increment handle count on Fcb %p Cnt %d\n",
pObjectInfo->Fcb,
- pObjectInfo->Fcb->OpenReferenceCount);
-
- InterlockedIncrement( &pObjectInfo->Fcb->OpenHandleCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessOverwriteSupersede Increment handle count on Fcb %08lX Cnt %d\n",
- pObjectInfo->Fcb,
- pObjectInfo->Fcb->OpenHandleCount);
+ lCount);
//
// Increment the open reference and handle on the parent node
//
- InterlockedIncrement( &pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount);
+ lCount = InterlockedIncrement( &pParentObjectInfo->Specific.Directory.ChildOpenHandleCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessOverwriteSupersede Increment child open handle count on Parent object %08lX Cnt %d\n",
- pObjectInfo->ParentObjectInformation,
- pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenHandleCount);
+ "AFSProcessOverwriteSupersede Increment child open handle count on Parent object %p Cnt %d\n",
+ pParentObjectInfo,
+ lCount);
- InterlockedIncrement( &pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenReferenceCount);
+ lCount = InterlockedIncrement( &pParentObjectInfo->Specific.Directory.ChildOpenReferenceCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessOverwriteSupersede Increment child open ref count on Parent object %08lX Cnt %d\n",
- pObjectInfo->ParentObjectInformation,
- pObjectInfo->ParentObjectInformation->Specific.Directory.ChildOpenReferenceCount);
+ "AFSProcessOverwriteSupersede Increment child open ref count on Parent object %p Cnt %d\n",
+ pParentObjectInfo,
+ lCount);
+
+ AFSReleaseResource( pObjectInfo->Fcb->Header.Resource);
+
+ bReleaseFcb = FALSE;
*Fcb = pObjectInfo->Fcb;
+ //
+ // Now that the Fcb->Resource has been dropped
+ // we can call CcSetFileSizes. We are still holding
+ // the PagingIoResource
+ //
+
+ pFileObject->SectionObjectPointer = &pObjectInfo->Fcb->NPFcb->SectionObjectPointers;
+
+ pFileObject->FsContext = (void *)pObjectInfo->Fcb;
+
+ pFileObject->FsContext2 = (void *)*Ccb;
+
+ CcSetFileSizes( pFileObject,
+ (PCC_FILE_SIZES)&pObjectInfo->Fcb->Header.AllocationSize);
+
try_exit:
if( bReleasePaging)
if( bReleaseFcb)
{
- //
- // Remove the reference we added above to prevent tear down
- //
+ if( !NT_SUCCESS( ntStatus))
+ {
+ //
+ // Decrement the open count on this Fcb.
+ //
- InterlockedDecrement( &pObjectInfo->Fcb->OpenReferenceCount);
+ lCount = InterlockedDecrement( &pObjectInfo->Fcb->OpenReferenceCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSProcessOverwriteSupersede Decrement count on Fcb %08lX Cnt %d\n",
- pObjectInfo->Fcb,
- pObjectInfo->Fcb->OpenReferenceCount);
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSProcessOverwriteSupersede Decrement2 count on Fcb %p Cnt %d\n",
+ pObjectInfo->Fcb,
+ lCount);
+ }
AFSReleaseResource( pObjectInfo->Fcb->Header.Resource);
}
if( bAllocatedCcb)
{
- AFSRemoveCcb( *Ccb);
+ AFSRemoveCcb( NULL,
+ *Ccb);
}
*Ccb = NULL;
- if( bAllocatedFcb)
- {
-
- AFSRemoveFcb( pObjectInfo->Fcb);
-
- pObjectInfo->Fcb = NULL;
- }
+ //
+ // Fcb will be freed by AFSPrimaryVolumeWorker thread
+ //
*Fcb = NULL;
}
__Enter
{
- //
- // For now, jsut let the open happen
- //
-
- Irp->IoStatus.Information = FILE_OPENED;
+ if ( KernelMode == Irp->RequestorMode) {
+ //
+ // For now, just let the open happen
+ //
+ Irp->IoStatus.Information = FILE_OPENED;
+ }
+ else
+ {
+ //
+ // Not from usermode, All access must be via
+ // the FS component (which will do the
+ // security check)
+ //
+ ntStatus = STATUS_ACCESS_DENIED;
+ }
}
return ntStatus;
}
+//
+// AFSOpenIOCtlFcb does not release a DirOpenReferenceCount on
+// the ParentDirCB.
+//
+
NTSTATUS
AFSOpenIOCtlFcb( IN PIRP Irp,
IN GUID *AuthGroup,
NTSTATUS ntStatus = STATUS_SUCCESS;
PFILE_OBJECT pFileObject = NULL;
PIO_STACK_LOCATION pIrpSp = IoGetCurrentIrpStackLocation( Irp);
- BOOLEAN bReleaseFcb = FALSE, bAllocatedCcb = FALSE, bAllocatedFcb = FALSE;
- UNICODE_STRING uniFullFileName;
+ BOOLEAN bReleaseFcb = FALSE, bAllocatedCcb = FALSE;
AFSPIOCtlOpenCloseRequestCB stPIOCtlOpen;
AFSFileID stFileID;
AFSObjectInfoCB *pParentObjectInfo = NULL;
+ LONG lCount;
__Enter
{
}
}
- if( pParentObjectInfo->Specific.Directory.PIOCtlDirectoryCB->ObjectInformation->Fcb == NULL)
- {
-
- //
- // Allocate and initialize the Fcb for the file.
- //
+ //
+ // Allocate and initialize the Fcb for the file.
+ //
- ntStatus = AFSInitFcb( pParentObjectInfo->Specific.Directory.PIOCtlDirectoryCB,
- Fcb);
+ ntStatus = AFSInitFcb( pParentObjectInfo->Specific.Directory.PIOCtlDirectoryCB);
- if( !NT_SUCCESS( ntStatus))
- {
+ *Fcb = pParentObjectInfo->Specific.Directory.PIOCtlDirectoryCB->ObjectInformation->Fcb;
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
- AFS_TRACE_LEVEL_ERROR,
- "AFSOpenIOCtlFcb (%08lX) Failed to initialize fcb Status %08lX\n",
- Irp,
- ntStatus);
+ if( !NT_SUCCESS( ntStatus))
+ {
- try_return( ntStatus);
- }
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSOpenIOCtlFcb (%p) Failed to initialize fcb Status %08lX\n",
+ Irp,
+ ntStatus);
- bAllocatedFcb = TRUE;
+ try_return( ntStatus);
}
- else
- {
- *Fcb = pParentObjectInfo->Specific.Directory.PIOCtlDirectoryCB->ObjectInformation->Fcb;
+ ntStatus = STATUS_SUCCESS;
- AFSAcquireExcl( &(*Fcb)->NPFcb->Resource,
- TRUE);
- }
+ //
+ // Increment the open reference and handle on the node
+ //
+
+ lCount = InterlockedIncrement( &(*Fcb)->OpenReferenceCount);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSOpenIOCtlFcb Increment count on Fcb %p Cnt %d\n",
+ (*Fcb),
+ lCount);
bReleaseFcb = TRUE;
// Initialize the Ccb for the file.
//
- ntStatus = AFSInitCcb( Ccb);
+ ntStatus = AFSInitCcb( Ccb,
+ pParentObjectInfo->Specific.Directory.PIOCtlDirectoryCB,
+ 0,
+ 0);
if( !NT_SUCCESS( ntStatus))
{
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSOpenIOCtlFcb (%08lX) Failed to initialize ccb Status %08lX\n",
+ "AFSOpenIOCtlFcb (%p) Failed to initialize ccb Status %08lX\n",
Irp,
ntStatus);
bAllocatedCcb = TRUE;
//
- // Setup the Ccb
- //
-
- (*Ccb)->DirectoryCB = pParentObjectInfo->Specific.Directory.PIOCtlDirectoryCB;
-
- //
// Set the PIOCtl index
//
AuthGroup,
NULL,
&stFileID,
+ NULL,
+ 0,
(void *)&stPIOCtlOpen,
sizeof( AFSPIOCtlOpenCloseRequestCB),
NULL,
AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSOpenIOCtlFcb (%08lX) Failed service open Status %08lX\n",
+ "AFSOpenIOCtlFcb (%p) Failed service open Status %08lX\n",
Irp,
ntStatus);
}
//
- // Reference the directory entry
+ // Increment the handle on the node
//
- InterlockedIncrement( &((*Ccb)->DirectoryCB->OpenReferenceCount));
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenIOCtlFcb Increment count on %wZ DE %p Ccb %p Cnt %d\n",
- &(*Ccb)->DirectoryCB->NameInformation.FileName,
- (*Ccb)->DirectoryCB,
- (*Ccb),
- (*Ccb)->DirectoryCB->OpenReferenceCount);
-
- //
- // Increment the open reference and handle on the node
- //
-
- InterlockedIncrement( &(*Fcb)->OpenReferenceCount);
+ lCount = InterlockedIncrement( &(*Fcb)->OpenHandleCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenIOCtlFcb Increment count on Fcb %08lX Cnt %d\n",
+ "AFSOpenIOCtlFcb Increment handle count on Fcb %p Cnt %d\n",
(*Fcb),
- (*Fcb)->OpenReferenceCount);
-
- InterlockedIncrement( &(*Fcb)->OpenHandleCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenIOCtlFcb Increment handle count on Fcb %08lX Cnt %d\n",
- (*Fcb),
- (*Fcb)->OpenHandleCount);
+ lCount);
//
// Increment the open reference and handle on the parent node
//
- InterlockedIncrement( &pParentObjectInfo->Specific.Directory.ChildOpenHandleCount);
+ lCount = InterlockedIncrement( &pParentObjectInfo->Specific.Directory.ChildOpenHandleCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenIOCtlFcb Increment child open handle count on Parent object %08lX Cnt %d\n",
+ "AFSOpenIOCtlFcb Increment child open handle count on Parent object %p Cnt %d\n",
pParentObjectInfo,
- pParentObjectInfo->Specific.Directory.ChildOpenHandleCount);
+ lCount);
- InterlockedIncrement( &pParentObjectInfo->Specific.Directory.ChildOpenReferenceCount);
+ lCount = InterlockedIncrement( &pParentObjectInfo->Specific.Directory.ChildOpenReferenceCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenIOCtlFcb Increment child open ref count on Parent object %08lX Cnt %d\n",
+ "AFSOpenIOCtlFcb Increment child open ref count on Parent object %p Cnt %d\n",
pParentObjectInfo,
- pParentObjectInfo->Specific.Directory.ChildOpenReferenceCount);
+ lCount);
//
// Return the open result for this file
try_exit:
//
- //Dereference the passed in parent since the returned dir entry
- // is already referenced
- //
-
- InterlockedDecrement( &ParentDirCB->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenIOCtlFcb Decrement count on %wZ DE %p Ccb %p Cnt %d\n",
- &ParentDirCB->NameInformation.FileName,
- ParentDirCB,
- NULL,
- ParentDirCB->OpenReferenceCount);
-
- //
// If we created the Fcb we need to release the resources
//
if( bReleaseFcb)
{
+ if( !NT_SUCCESS( ntStatus))
+ {
+ //
+ // Decrement the open reference and handle on the node
+ //
+
+ lCount = InterlockedDecrement( &(*Fcb)->OpenReferenceCount);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSOpenIOCtlFcb Decrement count on Fcb %p Cnt %d\n",
+ (*Fcb),
+ lCount);
+ }
+
AFSReleaseResource( &(*Fcb)->NPFcb->Resource);
}
if( bAllocatedCcb)
{
- AFSRemoveCcb( *Ccb);
-
- *Ccb = NULL;
+ AFSRemoveCcb( NULL,
+ *Ccb);
}
- if( bAllocatedFcb)
- {
-
- //
- // Need to tear down this Fcb since it is not in the tree for the worker thread
- //
-
- AFSRemoveFcb( *Fcb);
+ *Ccb = NULL;
- pParentObjectInfo->Specific.Directory.PIOCtlDirectoryCB->ObjectInformation->Fcb = NULL;
- }
+ //
+ // Fcb will be freed by AFSPrimaryVolumeWorker thread
+ //
*Fcb = NULL;
-
- *Ccb = NULL;
}
}
PFILE_OBJECT pFileObject = NULL;
PIO_STACK_LOCATION pIrpSp = IoGetCurrentIrpStackLocation( Irp);
BOOLEAN bReleaseFcb = FALSE, bAllocatedCcb = FALSE, bAllocateFcb = FALSE;
+ AFSObjectInfoCB *pObjectInfo = NULL;
AFSObjectInfoCB *pParentObjectInfo = NULL;
AFSPipeOpenCloseRequestCB stPipeOpen;
+ LONG lCount;
__Enter
{
AFSDbgLogMsg( AFS_SUBSYSTEM_PIPE_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE_2,
- "AFSOpenSpecialShareFcb (%08lX) Processing Share %wZ open\n",
+ "AFSOpenSpecialShareFcb (%p) Processing Share %wZ open\n",
Irp,
&DirectoryCB->NameInformation.FileName);
- pParentObjectInfo = DirectoryCB->ObjectInformation->ParentObjectInformation;
+ pObjectInfo = DirectoryCB->ObjectInformation;
+
+ if ( BooleanFlagOn( pObjectInfo->Flags, AFS_OBJECT_FLAGS_PARENT_FID))
+ {
+
+ pParentObjectInfo = AFSFindObjectInfo( pObjectInfo->VolumeCB,
+ &pObjectInfo->ParentFileId);
+ }
if( DirectoryCB->ObjectInformation->Fcb == NULL)
{
// Allocate and initialize the Fcb for the file.
//
- ntStatus = AFSInitFcb( DirectoryCB,
- Fcb);
+ ntStatus = AFSInitFcb( DirectoryCB);
+
+ *Fcb = pObjectInfo->Fcb;
if( !NT_SUCCESS( ntStatus))
{
AFSDbgLogMsg( AFS_SUBSYSTEM_PIPE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSOpenSpecialShareFcb (%08lX) Failed to initialize fcb Status %08lX\n",
+ "AFSOpenSpecialShareFcb (%p) Failed to initialize fcb Status %08lX\n",
Irp,
ntStatus);
try_return( ntStatus);
}
- bAllocateFcb = TRUE;
+ if ( ntStatus != STATUS_REPARSE)
+ {
+
+ bAllocateFcb = TRUE;
+ }
+
+ ntStatus = STATUS_SUCCESS;
}
else
{
- *Fcb = DirectoryCB->ObjectInformation->Fcb;
+ *Fcb = pObjectInfo->Fcb;
AFSAcquireExcl( &(*Fcb)->NPFcb->Resource,
TRUE);
}
+ //
+ // Increment the open count on this Fcb
+ //
+
+ lCount = InterlockedIncrement( &(*Fcb)->OpenReferenceCount);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSOpenSpecialShareFcb Increment count on Fcb %p Cnt %d\n",
+ (*Fcb),
+ lCount);
+
bReleaseFcb = TRUE;
//
// Initialize the Ccb for the file.
//
- ntStatus = AFSInitCcb( Ccb);
+ ntStatus = AFSInitCcb( Ccb,
+ DirectoryCB,
+ 0,
+ 0);
if( !NT_SUCCESS( ntStatus))
{
AFSDbgLogMsg( AFS_SUBSYSTEM_PIPE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSOpenSpecialShareFcb (%08lX) Failed to initialize ccb Status %08lX\n",
+ "AFSOpenSpecialShareFcb (%p) Failed to initialize ccb Status %08lX\n",
Irp,
ntStatus);
bAllocatedCcb = TRUE;
//
- // Setup the Ccb
- //
-
- (*Ccb)->DirectoryCB = DirectoryCB;
-
- //
// Call the service to open the share
//
AuthGroup,
&DirectoryCB->NameInformation.FileName,
NULL,
+ NULL,
+ 0,
(void *)&stPipeOpen,
sizeof( AFSPipeOpenCloseRequestCB),
NULL,
AFSDbgLogMsg( AFS_SUBSYSTEM_PIPE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSOpenSpecialShareFcb (%08lX) Failed service open Status %08lX\n",
+ "AFSOpenSpecialShareFcb (%p) Failed service open Status %08lX\n",
Irp,
ntStatus);
try_return( ntStatus);
}
- //
- // Increment the open count on this Fcb
- //
-
- InterlockedIncrement( &(*Fcb)->OpenReferenceCount);
-
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
- AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenSpecialShareFcb Increment count on Fcb %08lX Cnt %d\n",
- (*Fcb),
- (*Fcb)->OpenReferenceCount);
-
- InterlockedIncrement( &(*Fcb)->OpenHandleCount);
+ lCount = InterlockedIncrement( &(*Fcb)->OpenHandleCount);
AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenSpecialShareFcb Increment handle count on Fcb %08lX Cnt %d\n",
+ "AFSOpenSpecialShareFcb Increment handle count on Fcb %p Cnt %d\n",
(*Fcb),
- (*Fcb)->OpenHandleCount);
+ lCount);
//
// Increment the open reference and handle on the parent node
//
- InterlockedIncrement( &pParentObjectInfo->Specific.Directory.ChildOpenHandleCount);
+ lCount = InterlockedIncrement( &pParentObjectInfo->Specific.Directory.ChildOpenHandleCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenSpecialShareFcb Increment child open handle count on Parent object %08lX Cnt %d\n",
+ "AFSOpenSpecialShareFcb Increment child open handle count on Parent object %p Cnt %d\n",
pParentObjectInfo,
- pParentObjectInfo->Specific.Directory.ChildOpenHandleCount);
+ lCount);
- InterlockedIncrement( &pParentObjectInfo->Specific.Directory.ChildOpenReferenceCount);
+ lCount = InterlockedIncrement( &pParentObjectInfo->Specific.Directory.ChildOpenReferenceCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSOpenSpecialShareFcb Increment child open ref count on Parent object %08lX Cnt %d\n",
+ "AFSOpenSpecialShareFcb Increment child open ref count on Parent object %p Cnt %d\n",
pParentObjectInfo,
- pParentObjectInfo->Specific.Directory.ChildOpenReferenceCount);
+ lCount);
//
// Return the open result for this file
if( bReleaseFcb)
{
+ if( !NT_SUCCESS( ntStatus))
+ {
+ //
+ // Decrement the open count on this Fcb
+ //
+
+ lCount = InterlockedDecrement( &(*Fcb)->OpenReferenceCount);
+
+ AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFS_TRACE_LEVEL_VERBOSE,
+ "AFSOpenSpecialShareFcb Decrement count on Fcb %p Cnt %d\n",
+ (*Fcb),
+ lCount);
+ }
+
AFSReleaseResource( &(*Fcb)->NPFcb->Resource);
}
if( bAllocatedCcb)
{
- AFSRemoveCcb( *Ccb);
-
- *Ccb = NULL;
+ AFSRemoveCcb( NULL,
+ *Ccb);
}
+ *Ccb = NULL;
+
if( bAllocateFcb)
{
// Need to tear down this Fcb since it is not in the tree for the worker thread
//
- AFSRemoveFcb( *Fcb);
+ AFSAcquireExcl( &DirectoryCB->ObjectInformation->NonPagedInfo->ObjectInfoLock,
+ TRUE);
+
+ AFSRemoveFcb( &DirectoryCB->ObjectInformation->Fcb);
- DirectoryCB->ObjectInformation->Fcb = NULL;
+ AFSReleaseResource( &DirectoryCB->ObjectInformation->NonPagedInfo->ObjectInfoLock);
}
*Fcb = NULL;
-
- *Ccb = NULL;
}
}
git://git.openafs.org / openafs.git / blobdiff