2 * Copyright (c) 2008, 2009, 2010, 2011 Kernel Drivers, LLC.
3 * Copyright (c) 2009, 2010, 2011, 2012, 2013 Your File System, Inc.
6 * Redistribution and use in source and binary forms, with or without
7 * modification, are permitted provided that the following conditions
10 * - Redistributions of source code must retain the above copyright notice,
11 * this list of conditions and the following disclaimer.
12 * - Redistributions in binary form must reproduce the above copyright
13 * notice, this list of conditions and the following disclaimer in the
14 * documentation and/or other materials provided with the distribution.
15 * - Neither the names of Kernel Drivers, LLC and Your File System, Inc.
16 * nor the names of their contributors may be used to endorse or promote
17 * products derived from this software without specific prior written
18 * permission from Kernel Drivers, LLC and Your File System, Inc.
20 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
21 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
22 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A
23 * PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER
24 * OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
25 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
26 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
27 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
28 * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
29 * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
30 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
34 // File: AFSGeneric.cpp
37 #include "AFSCommon.h"
40 // Function: AFSExceptionFilter
44 // This function is the exception handler
48 // A status is returned for the function
52 AFSExceptionFilter( IN CHAR *FunctionString,
54 IN PEXCEPTION_POINTERS ExceptPtrs)
57 UNREFERENCED_PARAMETER(Code);
58 PEXCEPTION_RECORD ExceptRec;
64 ExceptRec = ExceptPtrs->ExceptionRecord;
66 Context = ExceptPtrs->ContextRecord;
70 "AFSExceptionFilter (Library) - EXR %p CXR %p Function %s Code %08lX Address %p Routine %p\n",
74 ExceptRec->ExceptionCode,
75 ExceptRec->ExceptionAddress,
76 (void *)AFSExceptionFilter));
78 DbgPrint("**** Exception Caught in AFS Redirector Library ****\n");
80 DbgPrint("\n\nPerform the following WnDbg Cmds:\n");
81 DbgPrint("\n\t.exr %p ; .cxr %p\n\n", ExceptRec, Context);
83 DbgPrint("**** Exception Complete from AFS Redirector Library ****\n");
85 if( BooleanFlagOn( AFSDebugFlags, AFS_DBG_BUGCHECK_EXCEPTION))
88 KeBugCheck( (ULONG)-2);
96 __except( EXCEPTION_EXECUTE_HANDLER)
102 return EXCEPTION_EXECUTE_HANDLER;
106 // Function: AFSLibExAllocatePoolWithTag()
108 // Purpose: Allocate Pool Memory. If BugCheck Exception flag
109 // is configured on, then bugcheck the system if
110 // a memory allocation fails. The routine should be
111 // used for all memory allocations that are to be freed
112 // when the library is unloaded. Memory allocations that
113 // are to survive library unload and reload should be
114 // performed using AFSExAllocatePoolWithTag() which is
115 // provided by the AFS Framework.
118 // POOL_TYPE PoolType - Paged or NonPaged
119 // SIZE_T NumberOfBytes - requested allocation size
120 // ULONG Tag - Pool Allocation Tag to be applied for tracking
123 // void * - the memory allocation
127 AFSLibExAllocatePoolWithTag( IN POOL_TYPE PoolType,
128 IN SIZE_T NumberOfBytes,
132 void *pBuffer = NULL;
134 pBuffer = ExAllocatePoolWithTag( PoolType,
141 if( BooleanFlagOn( AFSDebugFlags, AFS_DBG_BUGCHECK_EXCEPTION))
144 KeBugCheck( (ULONG)-2);
151 "AFSLibExAllocatePoolWithTag failure Type %08lX Size %08lX Tag %08lX %08lX\n",
155 PsGetCurrentThread()));
165 // Function: AFSAcquireExcl()
167 // Purpose: Called to acquire a resource exclusive with optional wait
170 // PERESOURCE Resource - Resource to acquire
171 // BOOLEAN Wait - Whether to block
174 // BOOLEAN - Whether the mask was acquired
178 AFSAcquireExcl( IN PERESOURCE Resource,
182 BOOLEAN bStatus = FALSE;
185 // Normal kernel APCs must be disabled before calling
186 // ExAcquireResourceExclusiveLite. Otherwise a bugcheck occurs.
189 KeEnterCriticalRegion();
191 bStatus = ExAcquireResourceExclusiveLite( Resource,
197 KeLeaveCriticalRegion();
204 AFSAcquireSharedStarveExclusive( IN PERESOURCE Resource,
208 BOOLEAN bStatus = FALSE;
210 KeEnterCriticalRegion();
212 bStatus = ExAcquireSharedStarveExclusive( Resource,
218 KeLeaveCriticalRegion();
225 // Function: AFSAcquireShared()
227 // Purpose: Called to acquire a resource shared with optional wait
230 // PERESOURCE Resource - Resource to acquire
231 // BOOLEAN Wait - Whether to block
234 // BOOLEAN - Whether the mask was acquired
238 AFSAcquireShared( IN PERESOURCE Resource,
242 BOOLEAN bStatus = FALSE;
244 KeEnterCriticalRegion();
246 bStatus = ExAcquireResourceSharedLite( Resource,
252 KeLeaveCriticalRegion();
259 // Function: AFSReleaseResource()
261 // Purpose: Called to release a resource
264 // PERESOURCE Resource - Resource to release
271 AFSReleaseResource( IN PERESOURCE Resource)
274 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
275 AFS_TRACE_LEVEL_VERBOSE,
276 "AFSReleaseResource Releasing lock %p Thread %08lX\n",
278 PsGetCurrentThread()));
280 ExReleaseResourceLite( Resource);
282 KeLeaveCriticalRegion();
288 AFSConvertToShared( IN PERESOURCE Resource)
291 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
292 AFS_TRACE_LEVEL_VERBOSE,
293 "AFSConvertToShared Converting lock %p Thread %08lX\n",
295 PsGetCurrentThread()));
297 ExConvertExclusiveToSharedLite( Resource);
303 // Function: AFSCompleteRequest
307 // This function completes irps
311 // A status is returned for the function
315 AFSCompleteRequest( IN PIRP Irp,
319 Irp->IoStatus.Status = Status;
321 IoCompleteRequest( Irp,
328 // Function: AFSGenerateCRC
332 // Given a device and filename this function generates a CRC
336 // A status is returned for the function
340 AFSGenerateCRC( IN PUNICODE_STRING FileName,
341 IN BOOLEAN UpperCaseName)
345 NTSTATUS ntStatus = STATUS_SUCCESS;
347 ntStatus = RtlHashUnicodeString( FileName,
349 HASH_STRING_ALGORITHM_DEFAULT,
352 if( !NT_SUCCESS( ntStatus))
361 AFSLockSystemBuffer( IN PIRP Irp,
365 void *pAddress = NULL;
367 if( Irp->MdlAddress != NULL)
370 pAddress = MmGetSystemAddressForMdlSafe( Irp->MdlAddress,
373 else if( Irp->AssociatedIrp.SystemBuffer != NULL)
376 pAddress = Irp->AssociatedIrp.SystemBuffer;
378 else if( Irp->UserBuffer != NULL)
381 Irp->MdlAddress = IoAllocateMdl( Irp->UserBuffer,
387 if( Irp->MdlAddress != NULL)
391 // Lock the new Mdl in memory.
396 PIO_STACK_LOCATION pIoStack;
397 pIoStack = IoGetCurrentIrpStackLocation( Irp);
400 MmProbeAndLockPages( Irp->MdlAddress, KernelMode,
401 (pIoStack->MajorFunction == IRP_MJ_READ) ? IoWriteAccess : IoReadAccess);
403 pAddress = MmGetSystemAddressForMdlSafe( Irp->MdlAddress, NormalPagePriority );
406 __except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()) )
409 AFSDumpTraceFilesFnc();
411 IoFreeMdl( Irp->MdlAddress );
412 Irp->MdlAddress = NULL;
422 AFSLockUserBuffer( IN void *UserBuffer,
423 IN ULONG BufferLength,
427 NTSTATUS ntStatus = STATUS_SUCCESS;
428 void *pAddress = NULL;
434 pMdl = IoAllocateMdl( UserBuffer,
443 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
447 // Lock the new Mdl in memory.
453 MmProbeAndLockPages( pMdl,
457 pAddress = MmGetSystemAddressForMdlSafe( pMdl,
460 __except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()) )
463 AFSDumpTraceFilesFnc();
485 AFSMapToService( IN PIRP Irp,
489 NTSTATUS ntStatus = STATUS_SUCCESS;
490 void *pMappedBuffer = NULL;
491 AFSDeviceExt *pDevExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
497 if( pDevExt->Specific.Control.ServiceProcess == NULL)
500 try_return( ntStatus = STATUS_DEVICE_NOT_READY);
503 if( Irp->MdlAddress == NULL)
506 if( AFSLockSystemBuffer( Irp,
510 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
515 // Attach to the service process for mapping
518 KeStackAttachProcess( pDevExt->Specific.Control.ServiceProcess,
519 (PRKAPC_STATE)&stApcState);
521 pMappedBuffer = MmMapLockedPagesSpecifyCache( Irp->MdlAddress,
528 KeUnstackDetachProcess( (PRKAPC_STATE)&stApcState);
535 return pMappedBuffer;
539 AFSUnmapServiceMappedBuffer( IN void *MappedBuffer,
543 NTSTATUS ntStatus = STATUS_SUCCESS;
544 AFSDeviceExt *pDevExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
550 if( pDevExt->Specific.Control.ServiceProcess == NULL)
553 try_return( ntStatus = STATUS_DEVICE_NOT_READY);
560 // Attach to the service process for mapping
563 KeStackAttachProcess( pDevExt->Specific.Control.ServiceProcess,
564 (PRKAPC_STATE)&stApcState);
566 MmUnmapLockedPages( MappedBuffer,
569 KeUnstackDetachProcess( (PRKAPC_STATE)&stApcState);
581 AFSInitializeLibraryDevice()
584 NTSTATUS ntStatus = STATUS_SUCCESS;
585 AFSDeviceExt *pDeviceExt = NULL;
590 pDeviceExt = (AFSDeviceExt *)AFSLibraryDeviceObject->DeviceExtension;
593 // The PIOCtl file name
596 RtlInitUnicodeString( &AFSPIOCtlName,
597 AFS_PIOCTL_FILE_INTERFACE_NAME);
600 // And the global root share name
603 RtlInitUnicodeString( &AFSGlobalRootName,
604 AFS_GLOBAL_ROOT_SHARE_NAME);
612 AFSRemoveLibraryDevice()
615 NTSTATUS ntStatus = STATUS_SUCCESS;
626 AFSDefaultDispatch( IN PDEVICE_OBJECT DeviceObject,
630 UNREFERENCED_PARAMETER(DeviceObject);
631 NTSTATUS ntStatus = STATUS_INVALID_DEVICE_REQUEST;
633 AFSCompleteRequest( Irp,
640 AFSInitializeGlobalDirectoryEntries()
643 NTSTATUS ntStatus = STATUS_SUCCESS;
644 AFSDirectoryCB *pDirNode = NULL;
645 ULONG ulEntryLength = 0;
646 AFSObjectInfoCB *pObjectInfoCB = NULL;
647 AFSNonPagedDirectoryCB *pNonPagedDirEntry = NULL;
654 // Initialize the global . entry
657 pObjectInfoCB = AFSAllocateObjectInfo( &AFSGlobalRoot->ObjectInformation,
660 if( pObjectInfoCB == NULL)
663 AFSDbgTrace(( AFS_SUBSYSTEM_LOAD_LIBRARY | AFS_SUBSYSTEM_INIT_PROCESSING,
664 AFS_TRACE_LEVEL_ERROR,
665 "AFSInitializeGlobalDirectory AFSAllocateObjectInfo failure %08lX\n",
668 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
671 lCount = AFSObjectInfoIncrement( pObjectInfoCB,
672 AFS_OBJECT_REFERENCE_GLOBAL);
674 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
675 AFS_TRACE_LEVEL_VERBOSE,
676 "AFSInitializeGlobalDirectoryEntries Increment count on object %p Cnt %d\n",
680 ntStatus = STATUS_SUCCESS;
682 ulEntryLength = sizeof( AFSDirectoryCB) +
685 pDirNode = (AFSDirectoryCB *)AFSLibExAllocatePoolWithTag( PagedPool,
689 if( pDirNode == NULL)
692 lCount = AFSObjectInfoDecrement( pObjectInfoCB,
693 AFS_OBJECT_REFERENCE_GLOBAL);
695 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
696 AFS_TRACE_LEVEL_VERBOSE,
697 "AFSInitializeGlobalDirectoryEntries Decrement count on object %p Cnt %d\n",
704 AFSDeleteObjectInfo( &pObjectInfoCB);
707 AFSDbgTrace(( AFS_SUBSYSTEM_LOAD_LIBRARY | AFS_SUBSYSTEM_INIT_PROCESSING | AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
708 AFS_TRACE_LEVEL_ERROR,
709 "AFSInitializeGlobalDirectory AFS_DIR_ENTRY_TAG allocation failure\n"));
711 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
714 AFSDbgTrace(( AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
715 AFS_TRACE_LEVEL_VERBOSE,
716 "AFSInitializeGlobalDirectory AFS_DIR_ENTRY_TAG allocated %p\n",
719 pNonPagedDirEntry = (AFSNonPagedDirectoryCB *)AFSLibExAllocatePoolWithTag( NonPagedPool,
720 sizeof( AFSNonPagedDirectoryCB),
721 AFS_DIR_ENTRY_NP_TAG);
723 if( pNonPagedDirEntry == NULL)
726 AFSLibExFreePoolWithTag( pDirNode,
729 lCount = AFSObjectInfoDecrement( pObjectInfoCB,
730 AFS_OBJECT_REFERENCE_GLOBAL);
732 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
733 AFS_TRACE_LEVEL_VERBOSE,
734 "AFSInitializeGlobalDirectoryEntries Decrement count on object %p Cnt %d\n",
741 AFSDeleteObjectInfo( &pObjectInfoCB);
744 AFSDbgTrace(( AFS_SUBSYSTEM_LOAD_LIBRARY | AFS_SUBSYSTEM_INIT_PROCESSING,
745 AFS_TRACE_LEVEL_ERROR,
746 "AFSInitializeGlobalDirectory AFS_DIR_ENTRY_NP_TAG allocation failure\n"));
748 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
751 RtlZeroMemory( pDirNode,
754 RtlZeroMemory( pNonPagedDirEntry,
755 sizeof( AFSNonPagedDirectoryCB));
757 ExInitializeResourceLite( &pNonPagedDirEntry->Lock);
759 pDirNode->NonPaged = pNonPagedDirEntry;
761 pDirNode->ObjectInformation = pObjectInfoCB;
767 SetFlag( pDirNode->Flags, AFS_DIR_ENTRY_NOT_IN_PARENT_TREE | AFS_DIR_ENTRY_FAKE | AFS_DIR_ENTRY_VALID);
769 pDirNode->FileIndex = (ULONG)AFS_DIR_ENTRY_DOT_INDEX;
772 // Setup the names in the entry
775 pDirNode->NameInformation.FileName.Length = sizeof( WCHAR);
777 pDirNode->NameInformation.FileName.MaximumLength = sizeof( WCHAR);
779 pDirNode->NameInformation.FileName.Buffer = (WCHAR *)((char *)pDirNode + sizeof( AFSDirectoryCB));
781 pDirNode->NameInformation.FileName.Buffer[ 0] = L'.';
784 // Populate the rest of the data
787 pObjectInfoCB->FileType = AFS_FILE_TYPE_DIRECTORY;
789 pObjectInfoCB->FileAttributes = FILE_ATTRIBUTE_DIRECTORY;
791 AFSGlobalDotDirEntry = pDirNode;
797 pObjectInfoCB = AFSAllocateObjectInfo( &AFSGlobalRoot->ObjectInformation,
800 if( pObjectInfoCB == NULL)
803 AFSDbgTrace(( AFS_SUBSYSTEM_LOAD_LIBRARY | AFS_SUBSYSTEM_INIT_PROCESSING,
804 AFS_TRACE_LEVEL_ERROR,
805 "AFSInitializeGlobalDirectory AFSAllocateObjectInfo (2) failure %08lX\n",
808 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
811 lCount = AFSObjectInfoIncrement( pObjectInfoCB,
812 AFS_OBJECT_REFERENCE_GLOBAL);
814 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
815 AFS_TRACE_LEVEL_VERBOSE,
816 "AFSInitializeGlobalDirectoryEntries Increment count on object %p Cnt %d\n",
820 ntStatus = STATUS_SUCCESS;
822 ulEntryLength = sizeof( AFSDirectoryCB) +
823 ( 2 * sizeof( WCHAR));
825 pDirNode = (AFSDirectoryCB *)AFSLibExAllocatePoolWithTag( PagedPool,
829 if( pDirNode == NULL)
832 AFSDbgTrace(( AFS_SUBSYSTEM_LOAD_LIBRARY | AFS_SUBSYSTEM_INIT_PROCESSING | AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
833 AFS_TRACE_LEVEL_ERROR,
834 "AFSInitializeGlobalDirectoryEntries AFS_DIR_ENTRY_TAG allocation failure\n"));
836 lCount = AFSObjectInfoDecrement( pObjectInfoCB,
837 AFS_OBJECT_REFERENCE_GLOBAL);
839 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
840 AFS_TRACE_LEVEL_VERBOSE,
841 "AFSInitializeGlobalDirectoryEntries Decrement count on object %p Cnt %d\n",
848 AFSDeleteObjectInfo( &pObjectInfoCB);
851 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
854 AFSDbgTrace(( AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
855 AFS_TRACE_LEVEL_VERBOSE,
856 "AFSInitializeGlobalDirectoryEntries AFS_DIR_ENTRY_TAG allocated %p\n",
859 pNonPagedDirEntry = (AFSNonPagedDirectoryCB *)AFSLibExAllocatePoolWithTag( NonPagedPool,
860 sizeof( AFSNonPagedDirectoryCB),
861 AFS_DIR_ENTRY_NP_TAG);
863 if( pNonPagedDirEntry == NULL)
866 AFSLibExFreePoolWithTag( pDirNode,
869 lCount = AFSObjectInfoDecrement( pObjectInfoCB,
870 AFS_OBJECT_REFERENCE_GLOBAL);
872 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
873 AFS_TRACE_LEVEL_VERBOSE,
874 "AFSInitializeGlobalDirectoryEntries Decrement count on object %p Cnt %d\n",
881 AFSDeleteObjectInfo( &pObjectInfoCB);
884 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
887 RtlZeroMemory( pDirNode,
890 RtlZeroMemory( pNonPagedDirEntry,
891 sizeof( AFSNonPagedDirectoryCB));
893 ExInitializeResourceLite( &pNonPagedDirEntry->Lock);
895 pDirNode->NonPaged = pNonPagedDirEntry;
897 pDirNode->ObjectInformation = pObjectInfoCB;
903 SetFlag( pDirNode->Flags, AFS_DIR_ENTRY_NOT_IN_PARENT_TREE | AFS_DIR_ENTRY_FAKE | AFS_DIR_ENTRY_VALID);
905 pDirNode->FileIndex = (ULONG)AFS_DIR_ENTRY_DOT_DOT_INDEX;
908 // Setup the names in the entry
911 pDirNode->NameInformation.FileName.Length = 2 * sizeof( WCHAR);
913 pDirNode->NameInformation.FileName.MaximumLength = 2 * sizeof( WCHAR);
915 pDirNode->NameInformation.FileName.Buffer = (WCHAR *)((char *)pDirNode + sizeof( AFSDirectoryCB));
917 pDirNode->NameInformation.FileName.Buffer[ 0] = L'.';
919 pDirNode->NameInformation.FileName.Buffer[ 1] = L'.';
922 // Populate the rest of the data
925 pObjectInfoCB->FileType = AFS_FILE_TYPE_DIRECTORY;
927 pObjectInfoCB->FileAttributes = FILE_ATTRIBUTE_DIRECTORY;
929 AFSGlobalDotDotDirEntry = pDirNode;
933 if( !NT_SUCCESS( ntStatus))
936 if( AFSGlobalDotDirEntry != NULL)
939 lCount = AFSObjectInfoDecrement( AFSGlobalDotDirEntry->ObjectInformation,
940 AFS_OBJECT_REFERENCE_GLOBAL);
942 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
943 AFS_TRACE_LEVEL_VERBOSE,
944 "AFSInitializeGlobalDirectoryEntries Decrement count on object %p Cnt %d\n",
945 AFSGlobalDotDirEntry->ObjectInformation,
951 AFSDeleteObjectInfo( &AFSGlobalDotDirEntry->ObjectInformation);
954 ExDeleteResourceLite( &AFSGlobalDotDirEntry->NonPaged->Lock);
956 AFSLibExFreePoolWithTag( AFSGlobalDotDirEntry->NonPaged,
957 AFS_DIR_ENTRY_NP_TAG);
959 AFSLibExFreePoolWithTag( AFSGlobalDotDirEntry,
962 AFSGlobalDotDirEntry = NULL;
965 if( AFSGlobalDotDotDirEntry != NULL)
968 lCount = AFSObjectInfoDecrement( AFSGlobalDotDotDirEntry->ObjectInformation,
969 AFS_OBJECT_REFERENCE_GLOBAL);
971 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
972 AFS_TRACE_LEVEL_VERBOSE,
973 "AFSInitializeGlobalDirectoryEntries Decrement count on object %p Cnt %d\n",
974 AFSGlobalDotDotDirEntry->ObjectInformation,
980 AFSDeleteObjectInfo( &AFSGlobalDotDotDirEntry->ObjectInformation);
983 ExDeleteResourceLite( &AFSGlobalDotDotDirEntry->NonPaged->Lock);
985 AFSLibExFreePoolWithTag( AFSGlobalDotDotDirEntry->NonPaged,
986 AFS_DIR_ENTRY_NP_TAG);
988 AFSLibExFreePoolWithTag( AFSGlobalDotDotDirEntry,
991 AFSGlobalDotDotDirEntry = NULL;
1000 AFSInitDirEntry( IN AFSObjectInfoCB *ParentObjectInfo,
1001 IN PUNICODE_STRING FileName,
1002 IN PUNICODE_STRING TargetName,
1003 IN AFSDirEnumEntry *DirEnumEntry,
1007 AFSDirectoryCB *pDirNode = NULL;
1008 NTSTATUS ntStatus = STATUS_SUCCESS;
1009 ULONG ulEntryLength = 0;
1010 AFSObjectInfoCB *pObjectInfoCB = NULL;
1011 ULONGLONG ullIndex = 0;
1012 AFSNonPagedDirectoryCB *pNonPagedDirEntry = NULL;
1018 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1019 AFS_TRACE_LEVEL_VERBOSE,
1020 "AFSInitDirEntry Initializing entry %wZ parent FID %08lX-%08lX-%08lX-%08lX\n",
1022 ParentObjectInfo->FileId.Cell,
1023 ParentObjectInfo->FileId.Volume,
1024 ParentObjectInfo->FileId.Vnode,
1025 ParentObjectInfo->FileId.Unique));
1028 // First thing is to locate/create our object information block
1032 AFSAcquireExcl( ParentObjectInfo->VolumeCB->ObjectInfoTree.TreeLock,
1035 ullIndex = AFSCreateLowIndex( &DirEnumEntry->FileId);
1037 ntStatus = AFSLocateHashEntry( ParentObjectInfo->VolumeCB->ObjectInfoTree.TreeHead,
1039 (AFSBTreeEntry **)&pObjectInfoCB);
1041 if( !NT_SUCCESS( ntStatus))
1045 // Allocate our object info cb
1048 pObjectInfoCB = AFSAllocateObjectInfo( ParentObjectInfo,
1051 if( pObjectInfoCB == NULL)
1054 AFSReleaseResource( ParentObjectInfo->VolumeCB->ObjectInfoTree.TreeLock);
1056 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
1059 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1060 AFS_TRACE_LEVEL_VERBOSE,
1061 "AFSInitDirEntry initialized object %p Parent Object %p for %wZ\n",
1067 // If we allocated the object information cb then set the information
1070 pObjectInfoCB->FileId = DirEnumEntry->FileId;
1072 pObjectInfoCB->TargetFileId = DirEnumEntry->TargetFileId;
1074 pObjectInfoCB->FileType = DirEnumEntry->FileType;
1076 pObjectInfoCB->FileAttributes = DirEnumEntry->FileAttributes;
1078 if( pObjectInfoCB->FileType == AFS_FILE_TYPE_MOUNTPOINT ||
1079 pObjectInfoCB->FileType == AFS_FILE_TYPE_DFSLINK)
1082 pObjectInfoCB->FileAttributes |= (FILE_ATTRIBUTE_DIRECTORY | FILE_ATTRIBUTE_REPARSE_POINT);
1085 if (pObjectInfoCB->FileType == AFS_FILE_TYPE_SYMLINK)
1088 if ( pObjectInfoCB->FileAttributes == FILE_ATTRIBUTE_NORMAL)
1091 pObjectInfoCB->FileAttributes = FILE_ATTRIBUTE_REPARSE_POINT;
1096 pObjectInfoCB->FileAttributes |= FILE_ATTRIBUTE_REPARSE_POINT;
1101 // Check for the case where we have a filetype of SymLink but both the TargetFid and the
1102 // TargetName are empty. In this case set the filetype to zero so we evaluate it later in
1106 if( pObjectInfoCB->FileType == AFS_FILE_TYPE_SYMLINK &&
1107 pObjectInfoCB->TargetFileId.Vnode == 0 &&
1108 pObjectInfoCB->TargetFileId.Unique == 0 &&
1109 (TargetName == NULL || TargetName->Length == 0))
1113 // This will ensure we perform a validation on the node
1116 pObjectInfoCB->FileType = AFS_FILE_TYPE_UNKNOWN;
1119 if( pObjectInfoCB->FileType == AFS_FILE_TYPE_UNKNOWN)
1122 SetFlag( pObjectInfoCB->Flags, AFS_OBJECT_FLAGS_NOT_EVALUATED);
1125 SetFlag( pObjectInfoCB->Flags, AFS_OBJECT_FLAGS_VERIFY);
1128 if ( BooleanFlagOn( pObjectInfoCB->Flags, AFS_OBJECT_FLAGS_VERIFY))
1131 pObjectInfoCB->CreationTime = DirEnumEntry->CreationTime;
1133 pObjectInfoCB->LastAccessTime = DirEnumEntry->LastAccessTime;
1135 pObjectInfoCB->LastWriteTime = DirEnumEntry->LastWriteTime;
1137 pObjectInfoCB->ChangeTime = DirEnumEntry->ChangeTime;
1139 pObjectInfoCB->EndOfFile = DirEnumEntry->EndOfFile;
1141 pObjectInfoCB->AllocationSize = DirEnumEntry->AllocationSize;
1143 pObjectInfoCB->EaSize = DirEnumEntry->EaSize;
1145 pObjectInfoCB->Links = DirEnumEntry->Links;
1147 pObjectInfoCB->Expiration = DirEnumEntry->Expiration;
1149 pObjectInfoCB->DataVersion = DirEnumEntry->DataVersion;
1151 ClearFlag( pObjectInfoCB->Flags, AFS_OBJECT_FLAGS_VERIFY);
1155 // This reference count is either stored into the return DirectoryCB
1156 // or released before function exit.
1159 lCount = AFSObjectInfoIncrement( pObjectInfoCB,
1160 AFS_OBJECT_REFERENCE_DIRENTRY);
1162 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
1163 AFS_TRACE_LEVEL_VERBOSE,
1164 "AFSInitDirEntry Increment count on object %p Cnt %d\n",
1168 KeQueryTickCount( &pObjectInfoCB->LastAccessCount);
1170 AFSReleaseResource( ParentObjectInfo->VolumeCB->ObjectInfoTree.TreeLock);
1172 ntStatus = STATUS_SUCCESS;
1174 ulEntryLength = sizeof( AFSDirectoryCB) +
1177 if( TargetName != NULL)
1180 ulEntryLength += TargetName->Length;
1183 pDirNode = (AFSDirectoryCB *)AFSExAllocatePoolWithTag( PagedPool,
1187 if( pDirNode == NULL)
1190 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
1193 AFSDbgTrace(( AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
1194 AFS_TRACE_LEVEL_VERBOSE,
1195 "AFSInitDirEntry AFS_DIR_ENTRY_TAG allocated %p\n",
1198 pNonPagedDirEntry = (AFSNonPagedDirectoryCB *)AFSExAllocatePoolWithTag( NonPagedPool,
1199 sizeof( AFSNonPagedDirectoryCB),
1200 AFS_DIR_ENTRY_NP_TAG);
1202 if( pNonPagedDirEntry == NULL)
1205 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
1208 RtlZeroMemory( pDirNode,
1211 RtlZeroMemory( pNonPagedDirEntry,
1212 sizeof( AFSNonPagedDirectoryCB));
1214 ExInitializeResourceLite( &pNonPagedDirEntry->Lock);
1216 pDirNode->NonPaged = pNonPagedDirEntry;
1218 pDirNode->ObjectInformation = pObjectInfoCB;
1221 // Set valid entry and NOT_IN_PARENT flag
1224 SetFlag( pDirNode->Flags, AFS_DIR_ENTRY_VALID | AFS_DIR_ENTRY_NOT_IN_PARENT_TREE);
1226 pDirNode->FileIndex = FileIndex;
1229 // Setup the names in the entry
1232 if( FileName->Length > 0)
1235 pDirNode->NameInformation.FileName.Length = FileName->Length;
1237 pDirNode->NameInformation.FileName.MaximumLength = FileName->Length;
1239 pDirNode->NameInformation.FileName.Buffer = (WCHAR *)((char *)pDirNode + sizeof( AFSDirectoryCB));
1241 RtlCopyMemory( pDirNode->NameInformation.FileName.Buffer,
1243 pDirNode->NameInformation.FileName.Length);
1246 // Create a CRC for the file
1249 pDirNode->CaseSensitiveTreeEntry.HashIndex = AFSGenerateCRC( &pDirNode->NameInformation.FileName,
1252 pDirNode->CaseInsensitiveTreeEntry.HashIndex = AFSGenerateCRC( &pDirNode->NameInformation.FileName,
1256 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1257 AFS_TRACE_LEVEL_VERBOSE,
1258 "AFSInitDirEntry Initialized DE %p for %wZ in parent FID %08lX-%08lX-%08lX-%08lX\n",
1261 ParentObjectInfo->FileId.Cell,
1262 ParentObjectInfo->FileId.Volume,
1263 ParentObjectInfo->FileId.Vnode,
1264 ParentObjectInfo->FileId.Unique));
1266 if( TargetName != NULL &&
1267 TargetName->Length > 0)
1270 pDirNode->NameInformation.TargetName.Length = TargetName->Length;
1272 pDirNode->NameInformation.TargetName.MaximumLength = pDirNode->NameInformation.TargetName.Length;
1274 pDirNode->NameInformation.TargetName.Buffer = (WCHAR *)((char *)pDirNode +
1275 sizeof( AFSDirectoryCB) +
1276 pDirNode->NameInformation.FileName.Length);
1278 RtlCopyMemory( pDirNode->NameInformation.TargetName.Buffer,
1280 pDirNode->NameInformation.TargetName.Length);
1286 if( !NT_SUCCESS( ntStatus))
1289 if( pNonPagedDirEntry != NULL)
1292 ExDeleteResourceLite( &pNonPagedDirEntry->Lock);
1294 AFSExFreePoolWithTag( pNonPagedDirEntry, AFS_DIR_ENTRY_NP_TAG);
1297 if( pDirNode != NULL)
1300 AFSDbgTrace(( AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
1301 AFS_TRACE_LEVEL_VERBOSE,
1302 "AFSInitDirEntry AFS_DIR_ENTRY_TAG deallocating %p\n",
1305 AFSExFreePoolWithTag( pDirNode, AFS_DIR_ENTRY_TAG);
1311 // Dereference our object info block if we have one
1314 if( pObjectInfoCB != NULL)
1317 AFSAcquireShared( pObjectInfoCB->VolumeCB->ObjectInfoTree.TreeLock,
1320 lCount = AFSObjectInfoDecrement( pObjectInfoCB,
1321 AFS_OBJECT_REFERENCE_DIRENTRY);
1323 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
1324 AFS_TRACE_LEVEL_VERBOSE,
1325 "AFSInitDirEntry Decrement count on object %p Cnt %d\n",
1329 AFSReleaseResource( pObjectInfoCB->VolumeCB->ObjectInfoTree.TreeLock);
1338 AFSCheckForReadOnlyAccess( IN ACCESS_MASK DesiredAccess,
1339 IN BOOLEAN DirectoryEntry)
1342 BOOLEAN bReturn = TRUE;
1343 ACCESS_MASK stAccessMask = 0;
1346 // Get rid of anything we don't know about
1349 DesiredAccess = (DesiredAccess &
1355 ACCESS_SYSTEM_SECURITY |
1359 FILE_READ_ATTRIBUTES |
1360 FILE_WRITE_ATTRIBUTES |
1361 FILE_LIST_DIRECTORY |
1367 // Our 'read only' access mask. These are the accesses we will
1368 // allow for a read only file
1371 stAccessMask = DELETE |
1376 ACCESS_SYSTEM_SECURITY |
1380 FILE_READ_ATTRIBUTES |
1381 FILE_WRITE_ATTRIBUTES |
1383 FILE_LIST_DIRECTORY |
1387 // For a directory, add in the directory specific accesses
1393 stAccessMask |= FILE_ADD_SUBDIRECTORY |
1398 if( FlagOn( DesiredAccess, ~stAccessMask))
1402 // A write access is set ...
1412 AFSEvaluateNode( IN GUID *AuthGroup,
1413 IN AFSDirectoryCB *DirEntry)
1416 NTSTATUS ntStatus = STATUS_SUCCESS;
1417 AFSDirEnumEntry *pDirEntry = NULL;
1418 UNICODE_STRING uniTargetName;
1423 ntStatus = AFSEvaluateTargetByID( DirEntry->ObjectInformation,
1428 if( !NT_SUCCESS( ntStatus))
1431 try_return( ntStatus);
1434 DirEntry->ObjectInformation->TargetFileId = pDirEntry->TargetFileId;
1436 DirEntry->ObjectInformation->Expiration = pDirEntry->Expiration;
1438 DirEntry->ObjectInformation->DataVersion = pDirEntry->DataVersion;
1440 DirEntry->ObjectInformation->FileType = pDirEntry->FileType;
1442 DirEntry->ObjectInformation->CreationTime = pDirEntry->CreationTime;
1444 DirEntry->ObjectInformation->LastAccessTime = pDirEntry->LastAccessTime;
1446 DirEntry->ObjectInformation->LastWriteTime = pDirEntry->LastWriteTime;
1448 DirEntry->ObjectInformation->ChangeTime = pDirEntry->ChangeTime;
1450 DirEntry->ObjectInformation->EndOfFile = pDirEntry->EndOfFile;
1452 DirEntry->ObjectInformation->AllocationSize = pDirEntry->AllocationSize;
1454 DirEntry->ObjectInformation->FileAttributes = pDirEntry->FileAttributes;
1456 if( pDirEntry->FileType == AFS_FILE_TYPE_MOUNTPOINT ||
1457 pDirEntry->FileType == AFS_FILE_TYPE_DFSLINK)
1460 DirEntry->ObjectInformation->FileAttributes |= (FILE_ATTRIBUTE_DIRECTORY | FILE_ATTRIBUTE_REPARSE_POINT);
1463 if( pDirEntry->FileType == AFS_FILE_TYPE_SYMLINK)
1466 if ( DirEntry->ObjectInformation->FileAttributes == FILE_ATTRIBUTE_NORMAL)
1469 DirEntry->ObjectInformation->FileAttributes = FILE_ATTRIBUTE_REPARSE_POINT;
1474 DirEntry->ObjectInformation->FileAttributes |= FILE_ATTRIBUTE_REPARSE_POINT;
1478 DirEntry->ObjectInformation->EaSize = pDirEntry->EaSize;
1480 DirEntry->ObjectInformation->Links = pDirEntry->Links;
1483 // If we have a target name then see if it needs updating ...
1486 if( pDirEntry->TargetNameLength > 0)
1490 // Update the target name information if needed
1493 uniTargetName.Length = (USHORT)pDirEntry->TargetNameLength;
1495 uniTargetName.MaximumLength = uniTargetName.Length;
1497 uniTargetName.Buffer = (WCHAR *)((char *)pDirEntry + pDirEntry->TargetNameOffset);
1499 AFSAcquireExcl( &DirEntry->NonPaged->Lock,
1502 if( DirEntry->NameInformation.TargetName.Length == 0 ||
1503 RtlCompareUnicodeString( &uniTargetName,
1504 &DirEntry->NameInformation.TargetName,
1509 // Update the target name
1512 ntStatus = AFSUpdateTargetName( &DirEntry->NameInformation.TargetName,
1514 uniTargetName.Buffer,
1515 uniTargetName.Length);
1517 if( !NT_SUCCESS( ntStatus))
1520 AFSReleaseResource( &DirEntry->NonPaged->Lock);
1522 try_return( ntStatus);
1526 AFSReleaseResource( &DirEntry->NonPaged->Lock);
1531 if( pDirEntry != NULL)
1534 AFSExFreePoolWithTag( pDirEntry, AFS_GENERIC_MEMORY_2_TAG);
1542 AFSValidateSymLink( IN GUID *AuthGroup,
1543 IN AFSDirectoryCB *DirEntry)
1546 NTSTATUS ntStatus = STATUS_SUCCESS;
1547 AFSDirEnumEntry *pDirEntry = NULL;
1548 UNICODE_STRING uniTargetName;
1553 ntStatus = AFSEvaluateTargetByID( DirEntry->ObjectInformation,
1558 if( !NT_SUCCESS( ntStatus))
1561 try_return( ntStatus);
1564 if( pDirEntry->FileType == AFS_FILE_TYPE_UNKNOWN ||
1565 pDirEntry->FileType == AFS_FILE_TYPE_INVALID)
1568 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1569 AFS_TRACE_LEVEL_VERBOSE_2,
1570 "AFSValidateSymLink Invalid type Status %08lX\n",
1571 STATUS_OBJECT_NAME_NOT_FOUND));
1573 try_return( ntStatus = STATUS_OBJECT_NAME_NOT_FOUND);
1576 DirEntry->ObjectInformation->TargetFileId = pDirEntry->TargetFileId;
1578 DirEntry->ObjectInformation->Expiration = pDirEntry->Expiration;
1580 DirEntry->ObjectInformation->DataVersion = pDirEntry->DataVersion;
1583 // Update the target name information if needed
1586 uniTargetName.Length = (USHORT)pDirEntry->TargetNameLength;
1588 uniTargetName.MaximumLength = uniTargetName.Length;
1590 uniTargetName.Buffer = (WCHAR *)((char *)pDirEntry + pDirEntry->TargetNameOffset);
1592 if( uniTargetName.Length > 0)
1595 AFSAcquireExcl( &DirEntry->NonPaged->Lock,
1598 if( DirEntry->NameInformation.TargetName.Length == 0 ||
1599 RtlCompareUnicodeString( &uniTargetName,
1600 &DirEntry->NameInformation.TargetName,
1605 // Update the target name
1608 ntStatus = AFSUpdateTargetName( &DirEntry->NameInformation.TargetName,
1610 uniTargetName.Buffer,
1611 uniTargetName.Length);
1613 if( !NT_SUCCESS( ntStatus))
1616 AFSReleaseResource( &DirEntry->NonPaged->Lock);
1618 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
1622 AFSReleaseResource( &DirEntry->NonPaged->Lock);
1626 // If the FileType is the same then nothing to do since it IS
1630 if( pDirEntry->FileType == DirEntry->ObjectInformation->FileType)
1633 ASSERT( pDirEntry->FileType == AFS_FILE_TYPE_SYMLINK);
1635 try_return( ntStatus = STATUS_SUCCESS);
1638 DirEntry->ObjectInformation->FileType = pDirEntry->FileType;
1640 DirEntry->ObjectInformation->CreationTime = pDirEntry->CreationTime;
1642 DirEntry->ObjectInformation->LastAccessTime = pDirEntry->LastAccessTime;
1644 DirEntry->ObjectInformation->LastWriteTime = pDirEntry->LastWriteTime;
1646 DirEntry->ObjectInformation->ChangeTime = pDirEntry->ChangeTime;
1648 DirEntry->ObjectInformation->EndOfFile = pDirEntry->EndOfFile;
1650 DirEntry->ObjectInformation->AllocationSize = pDirEntry->AllocationSize;
1652 DirEntry->ObjectInformation->FileAttributes = pDirEntry->FileAttributes;
1654 if( pDirEntry->FileType == AFS_FILE_TYPE_MOUNTPOINT ||
1655 pDirEntry->FileType == AFS_FILE_TYPE_DFSLINK)
1658 DirEntry->ObjectInformation->FileAttributes |= (FILE_ATTRIBUTE_DIRECTORY | FILE_ATTRIBUTE_REPARSE_POINT);
1661 if( pDirEntry->FileType == AFS_FILE_TYPE_SYMLINK)
1664 if ( DirEntry->ObjectInformation->FileAttributes == FILE_ATTRIBUTE_NORMAL)
1667 DirEntry->ObjectInformation->FileAttributes = FILE_ATTRIBUTE_REPARSE_POINT;
1672 DirEntry->ObjectInformation->FileAttributes |= FILE_ATTRIBUTE_REPARSE_POINT;
1676 DirEntry->ObjectInformation->EaSize = pDirEntry->EaSize;
1678 DirEntry->ObjectInformation->Links = pDirEntry->Links;
1682 if( pDirEntry != NULL)
1685 AFSExFreePoolWithTag( pDirEntry, AFS_GENERIC_MEMORY_2_TAG);
1693 AFSInvalidateObject( IN OUT AFSObjectInfoCB **ppObjectInfo,
1697 NTSTATUS ntStatus = STATUS_SUCCESS;
1698 IO_STATUS_BLOCK stIoStatus;
1700 AFSObjectInfoCB * pParentObjectInfo = NULL;
1702 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1703 AFS_TRACE_LEVEL_VERBOSE,
1704 "AFSInvalidateObject Invalidation on node type %d for fid %08lX-%08lX-%08lX-%08lX Reason %d\n",
1705 (*ppObjectInfo)->FileType,
1706 (*ppObjectInfo)->FileId.Cell,
1707 (*ppObjectInfo)->FileId.Volume,
1708 (*ppObjectInfo)->FileId.Vnode,
1709 (*ppObjectInfo)->FileId.Unique,
1712 if ( BooleanFlagOn( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_PARENT_FID))
1715 pParentObjectInfo = AFSFindObjectInfo( (*ppObjectInfo)->VolumeCB,
1716 &(*ppObjectInfo)->ParentFileId,
1720 if( (*ppObjectInfo)->FileType == AFS_FILE_TYPE_SYMLINK ||
1721 (*ppObjectInfo)->FileType == AFS_FILE_TYPE_DFSLINK ||
1722 (*ppObjectInfo)->FileType == AFS_FILE_TYPE_MOUNTPOINT)
1725 // We only act on the mount point itself, not the target. If the
1726 // node has been deleted then mark it as such otherwise indicate
1727 // it requires verification
1730 if( Reason == AFS_INVALIDATE_DELETED)
1732 SetFlag( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_OBJECT_INVALID);
1737 if( Reason == AFS_INVALIDATE_FLUSHED)
1740 (*ppObjectInfo)->DataVersion.QuadPart = (ULONGLONG)-1;
1742 SetFlag( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_VERIFY_DATA);
1745 (*ppObjectInfo)->Expiration.QuadPart = 0;
1747 (*ppObjectInfo)->TargetFileId.Vnode = 0;
1749 (*ppObjectInfo)->TargetFileId.Unique = 0;
1751 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1752 AFS_TRACE_LEVEL_VERBOSE,
1753 "AFSInvalidateObject Setting VERIFY flag on fid %08lX-%08lX-%08lX-%08lX\n",
1754 (*ppObjectInfo)->FileId.Cell,
1755 (*ppObjectInfo)->FileId.Volume,
1756 (*ppObjectInfo)->FileId.Vnode,
1757 (*ppObjectInfo)->FileId.Unique));
1759 SetFlag( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_VERIFY);
1762 if ( pParentObjectInfo != NULL)
1765 ulFilter = FILE_NOTIFY_CHANGE_FILE_NAME;
1767 if( Reason == AFS_INVALIDATE_CREDS)
1769 ulFilter |= FILE_NOTIFY_CHANGE_SECURITY;
1772 if( Reason == AFS_INVALIDATE_DATA_VERSION ||
1773 Reason == AFS_INVALIDATE_FLUSHED)
1775 ulFilter |= FILE_NOTIFY_CHANGE_SIZE | FILE_NOTIFY_CHANGE_LAST_WRITE;
1779 ulFilter |= FILE_NOTIFY_CHANGE_ATTRIBUTES;
1782 AFSFsRtlNotifyFullReportChange( pParentObjectInfo,
1785 FILE_ACTION_MODIFIED);
1788 try_return( ntStatus);
1792 // Depending on the reason for invalidation then perform work on the node
1798 case AFS_INVALIDATE_DELETED:
1802 // Mark this node as invalid
1805 (*ppObjectInfo)->Links = 0;
1807 SetFlag( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_DELETED);
1809 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1810 AFS_TRACE_LEVEL_VERBOSE,
1811 "AFSInvalidateObject Set DELETE flag on fid %08lX-%08lX-%08lX-%08lX\n",
1812 (*ppObjectInfo)->FileId.Cell,
1813 (*ppObjectInfo)->FileId.Volume,
1814 (*ppObjectInfo)->FileId.Vnode,
1815 (*ppObjectInfo)->FileId.Unique));
1817 if( pParentObjectInfo != NULL)
1820 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1821 AFS_TRACE_LEVEL_VERBOSE,
1822 "AFSInvalidateObject Set VERIFY flag on parent fid %08lX-%08lX-%08lX-%08lX\n",
1823 pParentObjectInfo->FileId.Cell,
1824 pParentObjectInfo->FileId.Volume,
1825 pParentObjectInfo->FileId.Vnode,
1826 pParentObjectInfo->FileId.Unique));
1828 SetFlag( pParentObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
1830 pParentObjectInfo->DataVersion.QuadPart = (ULONGLONG)-1;
1832 pParentObjectInfo->Expiration.QuadPart = 0;
1834 if( (*ppObjectInfo)->FileType == AFS_FILE_TYPE_DIRECTORY)
1836 ulFilter = FILE_NOTIFY_CHANGE_DIR_NAME;
1840 ulFilter = FILE_NOTIFY_CHANGE_FILE_NAME;
1843 AFSFsRtlNotifyFullReportChange( pParentObjectInfo,
1846 FILE_ACTION_REMOVED);
1849 if( NT_SUCCESS( AFSQueueInvalidateObject( (*ppObjectInfo),
1852 (*ppObjectInfo) = NULL; // We'll dec the count in the worker item
1858 case AFS_INVALIDATE_FLUSHED:
1861 if( (*ppObjectInfo)->FileType == AFS_FILE_TYPE_FILE &&
1862 (*ppObjectInfo)->Fcb != NULL)
1865 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1866 AFS_TRACE_LEVEL_VERBOSE,
1867 "AFSInvalidateObject Flush/purge file fid %08lX-%08lX-%08lX-%08lX\n",
1868 (*ppObjectInfo)->FileId.Cell,
1869 (*ppObjectInfo)->FileId.Volume,
1870 (*ppObjectInfo)->FileId.Vnode,
1871 (*ppObjectInfo)->FileId.Unique));
1873 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING|AFS_SUBSYSTEM_SECTION_OBJECT,
1874 AFS_TRACE_LEVEL_VERBOSE,
1875 "AFSInvalidateObject Flush/purge Acquiring Fcb SectionObject lock %p EXCL %08lX\n",
1876 &(*ppObjectInfo)->Fcb->NPFcb->SectionObjectResource,
1877 PsGetCurrentThread()));
1879 AFSAcquireExcl( &(*ppObjectInfo)->Fcb->NPFcb->SectionObjectResource,
1885 CcFlushCache( &(*ppObjectInfo)->Fcb->NPFcb->SectionObjectPointers,
1890 if( !NT_SUCCESS( stIoStatus.Status))
1893 AFSDbgTrace(( AFS_SUBSYSTEM_IO_PROCESSING,
1894 AFS_TRACE_LEVEL_ERROR,
1895 "AFSInvalidateObject CcFlushCache failure FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX Bytes 0x%08lX\n",
1896 (*ppObjectInfo)->FileId.Cell,
1897 (*ppObjectInfo)->FileId.Volume,
1898 (*ppObjectInfo)->FileId.Vnode,
1899 (*ppObjectInfo)->FileId.Unique,
1901 stIoStatus.Information));
1903 ntStatus = stIoStatus.Status;
1907 if ( (*ppObjectInfo)->Fcb->NPFcb->SectionObjectPointers.DataSectionObject != NULL)
1910 if ( !CcPurgeCacheSection( &(*ppObjectInfo)->Fcb->NPFcb->SectionObjectPointers,
1916 AFSDbgTrace(( AFS_SUBSYSTEM_IO_PROCESSING,
1917 AFS_TRACE_LEVEL_WARNING,
1918 "AFSInvalidateObject CcPurgeCacheSection failure FID %08lX-%08lX-%08lX-%08lX\n",
1919 (*ppObjectInfo)->FileId.Cell,
1920 (*ppObjectInfo)->FileId.Volume,
1921 (*ppObjectInfo)->FileId.Vnode,
1922 (*ppObjectInfo)->FileId.Unique));
1924 SetFlag( (*ppObjectInfo)->Fcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
1928 __except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()))
1931 ntStatus = GetExceptionCode();
1935 "EXCEPTION - AFSInvalidateObject Cc FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX\n",
1936 (*ppObjectInfo)->FileId.Cell,
1937 (*ppObjectInfo)->FileId.Volume,
1938 (*ppObjectInfo)->FileId.Vnode,
1939 (*ppObjectInfo)->FileId.Unique,
1942 SetFlag( (*ppObjectInfo)->Fcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
1945 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING|AFS_SUBSYSTEM_SECTION_OBJECT,
1946 AFS_TRACE_LEVEL_VERBOSE,
1947 "AFSInvalidateObject Flush/purge Releasing Fcb SectionObject lock %p EXCL %08lX\n",
1948 &(*ppObjectInfo)->Fcb->NPFcb->SectionObjectResource,
1949 PsGetCurrentThread()));
1951 AFSReleaseResource( &(*ppObjectInfo)->Fcb->NPFcb->SectionObjectResource);
1954 // Clear out the extents
1955 // Get rid of them (note this involves waiting
1956 // for any writes or reads to the cache to complete)
1959 AFSTearDownFcbExtents( (*ppObjectInfo)->Fcb,
1963 (*ppObjectInfo)->DataVersion.QuadPart = (ULONGLONG)-1;
1966 if( (*ppObjectInfo)->FileType == AFS_FILE_TYPE_FILE)
1969 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1970 AFS_TRACE_LEVEL_VERBOSE,
1971 "AFSInvalidateObject Setting VERIFY_DATA flag on fid %08lX-%08lX-%08lX-%08lX\n",
1972 (*ppObjectInfo)->FileId.Cell,
1973 (*ppObjectInfo)->FileId.Volume,
1974 (*ppObjectInfo)->FileId.Vnode,
1975 (*ppObjectInfo)->FileId.Unique));
1977 SetFlag( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_VERIFY_DATA);
1980 // Fall through to the default processing
1986 if( (*ppObjectInfo)->FileType == AFS_FILE_TYPE_DIRECTORY)
1988 ulFilter = FILE_NOTIFY_CHANGE_DIR_NAME;
1992 ulFilter = FILE_NOTIFY_CHANGE_FILE_NAME;
1995 if( Reason == AFS_INVALIDATE_CREDS)
1997 ulFilter |= FILE_NOTIFY_CHANGE_SECURITY;
2000 if( Reason == AFS_INVALIDATE_DATA_VERSION)
2002 ulFilter |= FILE_NOTIFY_CHANGE_SIZE | FILE_NOTIFY_CHANGE_LAST_WRITE;
2006 ulFilter |= FILE_NOTIFY_CHANGE_ATTRIBUTES;
2009 if( (*ppObjectInfo)->FileType == AFS_FILE_TYPE_DIRECTORY)
2012 AFSFsRtlNotifyFullReportChange( (*ppObjectInfo),
2015 FILE_ACTION_MODIFIED);
2017 else if ( pParentObjectInfo != NULL)
2020 AFSFsRtlNotifyFullReportChange( pParentObjectInfo,
2023 FILE_ACTION_MODIFIED);
2027 // Indicate this node requires re-evaluation for the remaining reasons
2030 (*ppObjectInfo)->Expiration.QuadPart = 0;
2032 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2033 AFS_TRACE_LEVEL_VERBOSE,
2034 "AFSInvalidateObject Setting VERIFY flag on fid %08lX-%08lX-%08lX-%08lX\n",
2035 (*ppObjectInfo)->FileId.Cell,
2036 (*ppObjectInfo)->FileId.Volume,
2037 (*ppObjectInfo)->FileId.Vnode,
2038 (*ppObjectInfo)->FileId.Unique));
2040 SetFlag( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_VERIFY);
2042 if( Reason == AFS_INVALIDATE_DATA_VERSION ||
2043 (*ppObjectInfo)->FileType == AFS_FILE_TYPE_FILE &&
2044 ( Reason == AFS_INVALIDATE_CALLBACK ||
2045 Reason == AFS_INVALIDATE_EXPIRED))
2047 if ( NT_SUCCESS( AFSQueueInvalidateObject( (*ppObjectInfo),
2048 AFS_INVALIDATE_DATA_VERSION)))
2051 (*ppObjectInfo) = NULL; // We'll dec the count in the worker item
2061 if ( pParentObjectInfo != NULL)
2064 AFSReleaseObjectInfo( &pParentObjectInfo);
2071 AFSInvalidateCache( IN AFSInvalidateCacheCB *InvalidateCB)
2074 NTSTATUS ntStatus = STATUS_SUCCESS;
2075 AFSVolumeCB *pVolumeCB = NULL;
2076 AFSDeviceExt *pDevExt = (AFSDeviceExt *) AFSRDRDeviceObject->DeviceExtension;
2077 ULONGLONG ullIndex = 0;
2078 AFSObjectInfoCB *pObjectInfo = NULL;
2084 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2085 AFS_TRACE_LEVEL_VERBOSE,
2086 "AFSInvalidateCache Invalidation FID %08lX-%08lX-%08lX-%08lX Type %d WholeVolume %d Reason %d\n",
2087 InvalidateCB->FileID.Cell,
2088 InvalidateCB->FileID.Volume,
2089 InvalidateCB->FileID.Vnode,
2090 InvalidateCB->FileID.Unique,
2091 InvalidateCB->FileType,
2092 InvalidateCB->WholeVolume,
2093 InvalidateCB->Reason));
2096 // Need to locate the Fcb for the directory to purge
2099 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
2100 AFS_TRACE_LEVEL_VERBOSE,
2101 "AFSInvalidateCache Acquiring RDR VolumeTreeLock lock %p SHARED %08lX\n",
2102 &pDevExt->Specific.RDR.VolumeTreeLock,
2103 PsGetCurrentThread()));
2106 // Starve any exclusive waiters on this paticular call
2109 AFSAcquireSharedStarveExclusive( &pDevExt->Specific.RDR.VolumeTreeLock, TRUE);
2112 // Locate the volume node
2115 ullIndex = AFSCreateHighIndex( &InvalidateCB->FileID);
2117 ntStatus = AFSLocateHashEntry( pDevExt->Specific.RDR.VolumeTree.TreeHead,
2119 (AFSBTreeEntry **)&pVolumeCB);
2121 if( pVolumeCB != NULL)
2124 lCount = AFSVolumeIncrement( pVolumeCB,
2125 AFS_VOLUME_REFERENCE_INVALIDATE);
2127 AFSDbgTrace(( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
2128 AFS_TRACE_LEVEL_VERBOSE,
2129 "AFSInvalidateCache Increment count on volume %p Cnt %d\n",
2134 AFSReleaseResource( &pDevExt->Specific.RDR.VolumeTreeLock);
2136 if( !NT_SUCCESS( ntStatus) ||
2140 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2141 AFS_TRACE_LEVEL_WARNING,
2142 "AFSInvalidateCache Invalidation FAILURE Unable to locate volume node FID %08lX-%08lX-%08lX-%08lX Status %08lX\n",
2143 InvalidateCB->FileID.Cell,
2144 InvalidateCB->FileID.Volume,
2145 InvalidateCB->FileID.Vnode,
2146 InvalidateCB->FileID.Unique,
2149 try_return( ntStatus = STATUS_SUCCESS);
2153 // If this is a whole volume invalidation then go do it now
2156 if( InvalidateCB->WholeVolume)
2159 ntStatus = AFSInvalidateVolume( pVolumeCB,
2160 InvalidateCB->Reason);
2162 try_return( ntStatus);
2165 AFSAcquireExcl( pVolumeCB->ObjectInfoTree.TreeLock,
2168 if ( AFSIsVolumeFID( &InvalidateCB->FileID))
2171 pObjectInfo = &pVolumeCB->ObjectInformation;
2176 ullIndex = AFSCreateLowIndex( &InvalidateCB->FileID);
2178 ntStatus = AFSLocateHashEntry( pVolumeCB->ObjectInfoTree.TreeHead,
2180 (AFSBTreeEntry **)&pObjectInfo);
2183 if( pObjectInfo != NULL)
2187 // Reference the node so it won't be torn down
2190 lCount = AFSObjectInfoIncrement( pObjectInfo,
2191 AFS_OBJECT_REFERENCE_INVALIDATION);
2193 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2194 AFS_TRACE_LEVEL_VERBOSE,
2195 "AFSInvalidateCache Increment count on object %p Cnt %d\n",
2200 AFSReleaseResource( pVolumeCB->ObjectInfoTree.TreeLock);
2202 if( !NT_SUCCESS( ntStatus) ||
2203 pObjectInfo == NULL)
2206 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2207 AFS_TRACE_LEVEL_VERBOSE,
2208 "AFSInvalidateCache Invalidation FAILURE Unable to locate object FID %08lX-%08lX-%08lX-%08lX Status %08lX\n",
2209 InvalidateCB->FileID.Cell,
2210 InvalidateCB->FileID.Volume,
2211 InvalidateCB->FileID.Vnode,
2212 InvalidateCB->FileID.Unique,
2215 try_return( ntStatus = STATUS_SUCCESS);
2218 AFSInvalidateObject( &pObjectInfo,
2219 InvalidateCB->Reason);
2223 if( pObjectInfo != NULL)
2226 lCount = AFSObjectInfoDecrement( pObjectInfo,
2227 AFS_OBJECT_REFERENCE_INVALIDATION);
2229 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2230 AFS_TRACE_LEVEL_VERBOSE,
2231 "AFSInvalidateCache Decrement count on object %p Cnt %d\n",
2236 if ( pVolumeCB != NULL)
2239 lCount = AFSVolumeDecrement( pVolumeCB,
2240 AFS_VOLUME_REFERENCE_INVALIDATE);
2242 AFSDbgTrace(( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
2243 AFS_TRACE_LEVEL_VERBOSE,
2244 "AFSInvalidateCache Decrement count on volume %p Cnt %d\n",
2254 AFSIsChildOfParent( IN AFSFcb *Dcb,
2258 BOOLEAN bIsChild = FALSE;
2259 AFSFcb *pCurrentFcb = Fcb;
2260 AFSObjectInfoCB * pParentObjectInfo = NULL;
2262 while( pCurrentFcb != NULL)
2265 if( BooleanFlagOn( pCurrentFcb->ObjectInformation->Flags, AFS_OBJECT_FLAGS_PARENT_FID) &&
2266 AFSIsEqualFID( &pCurrentFcb->ObjectInformation->ParentFileId, &Dcb->ObjectInformation->FileId))
2274 pParentObjectInfo = AFSFindObjectInfo( pCurrentFcb->ObjectInformation->VolumeCB,
2275 &pCurrentFcb->ObjectInformation->ParentFileId,
2278 if ( pParentObjectInfo != NULL)
2281 pCurrentFcb = pParentObjectInfo->Fcb;
2283 AFSReleaseObjectInfo( &pParentObjectInfo);
2297 AFSCreateHighIndex( IN AFSFileID *FileID)
2300 ULONGLONG ullIndex = 0;
2302 ullIndex = (((ULONGLONG)FileID->Cell << 32) | FileID->Volume);
2309 AFSCreateLowIndex( IN AFSFileID *FileID)
2312 ULONGLONG ullIndex = 0;
2314 ullIndex = (((ULONGLONG)FileID->Vnode << 32) | FileID->Unique);
2320 AFSCheckAccess( IN ACCESS_MASK DesiredAccess,
2321 IN ACCESS_MASK GrantedAccess,
2322 IN BOOLEAN DirectoryEntry)
2325 BOOLEAN bAccessGranted = TRUE;
2328 // Check if we are asking for read/write and granted only read only
2329 // NOTE: There will be more checks here
2332 if( !AFSCheckForReadOnlyAccess( DesiredAccess,
2334 AFSCheckForReadOnlyAccess( GrantedAccess,
2338 bAccessGranted = FALSE;
2341 return bAccessGranted;
2345 AFSGetDriverStatus( IN AFSDriverStatusRespCB *DriverStatus)
2348 NTSTATUS ntStatus = STATUS_SUCCESS;
2349 AFSDeviceExt *pControlDevExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
2355 DriverStatus->Status = AFS_DRIVER_STATUS_READY;
2357 if( AFSGlobalRoot == NULL)
2364 DriverStatus->Status = AFS_DRIVER_STATUS_NOT_READY;
2367 if( pControlDevExt->Specific.Control.CommServiceCB.IrpPoolControlFlag != POOL_ACTIVE)
2374 DriverStatus->Status = AFS_DRIVER_STATUS_NO_SERVICE;
2381 AFSSubstituteSysName( IN UNICODE_STRING *ComponentName,
2382 IN UNICODE_STRING *SubstituteName,
2383 IN ULONG StringIndex)
2386 NTSTATUS ntStatus = STATUS_SUCCESS;
2387 AFSDeviceExt *pControlDevExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
2388 AFSSysNameCB *pSysName = NULL;
2389 ERESOURCE *pSysNameLock = NULL;
2392 UNICODE_STRING uniSysName;
2399 if( IoIs32bitProcess( NULL))
2402 pSysNameLock = &pControlDevExt->Specific.Control.SysName32ListLock;
2404 pSysName = pControlDevExt->Specific.Control.SysName32ListHead;
2409 pSysNameLock = &pControlDevExt->Specific.Control.SysName64ListLock;
2411 pSysName = pControlDevExt->Specific.Control.SysName64ListHead;
2415 pSysNameLock = &pControlDevExt->Specific.Control.SysName32ListLock;
2417 pSysName = pControlDevExt->Specific.Control.SysName32ListHead;
2421 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
2422 AFS_TRACE_LEVEL_VERBOSE,
2423 "AFSSubstituteSysName Acquiring SysName lock %p SHARED %08lX\n",
2425 PsGetCurrentThread()));
2427 AFSAcquireShared( pSysNameLock,
2431 // Find where we are in the list
2434 while( pSysName != NULL &&
2435 ulIndex < StringIndex)
2438 pSysName = pSysName->fLink;
2443 if( pSysName == NULL)
2446 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2447 AFS_TRACE_LEVEL_VERBOSE_2,
2448 "AFSSubstituteSysName No sysname %wZ Status %08lX\n",
2450 STATUS_OBJECT_NAME_NOT_FOUND));
2452 try_return( ntStatus = STATUS_OBJECT_NAME_NOT_FOUND);
2455 RtlInitUnicodeString( &uniSysName,
2458 // If it is a full component of @SYS then just substitue the
2462 if( RtlCompareUnicodeString( &uniSysName,
2467 SubstituteName->Length = pSysName->SysName.Length;
2468 SubstituteName->MaximumLength = SubstituteName->Length;
2470 SubstituteName->Buffer = (WCHAR *)AFSExAllocatePoolWithTag( PagedPool,
2471 SubstituteName->Length,
2472 AFS_SUBST_BUFFER_TAG);
2474 if( SubstituteName->Buffer == NULL)
2477 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
2480 RtlCopyMemory( SubstituteName->Buffer,
2481 pSysName->SysName.Buffer,
2482 pSysName->SysName.Length);
2489 while( ComponentName->Buffer[ usIndex] != L'@')
2495 SubstituteName->Length = (usIndex * sizeof( WCHAR)) + pSysName->SysName.Length;
2496 SubstituteName->MaximumLength = SubstituteName->Length;
2498 SubstituteName->Buffer = (WCHAR *)AFSExAllocatePoolWithTag( PagedPool,
2499 SubstituteName->Length,
2500 AFS_SUBST_BUFFER_TAG);
2502 if( SubstituteName->Buffer == NULL)
2505 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
2508 RtlCopyMemory( SubstituteName->Buffer,
2509 ComponentName->Buffer,
2510 usIndex * sizeof( WCHAR));
2512 RtlCopyMemory( &SubstituteName->Buffer[ usIndex],
2513 pSysName->SysName.Buffer,
2514 pSysName->SysName.Length);
2519 AFSReleaseResource( pSysNameLock);
2526 AFSSubstituteNameInPath( IN OUT UNICODE_STRING *FullPathName,
2527 IN OUT UNICODE_STRING *ComponentName,
2528 IN UNICODE_STRING *SubstituteName,
2529 IN OUT UNICODE_STRING *RemainingPath,
2530 IN BOOLEAN FreePathName)
2533 NTSTATUS ntStatus = STATUS_SUCCESS;
2534 UNICODE_STRING uniPathName;
2535 USHORT usPrefixNameLen = 0;
2536 SHORT sNameLenDelta = 0;
2542 // If the passed in name can handle the additional length
2543 // then just moves things around
2546 sNameLenDelta = SubstituteName->Length - ComponentName->Length;
2548 usPrefixNameLen = (USHORT)(ComponentName->Buffer - FullPathName->Buffer);
2550 if( FullPathName->MaximumLength > FullPathName->Length + sNameLenDelta)
2553 if( FullPathName->Length > usPrefixNameLen + ComponentName->Length)
2556 RtlMoveMemory( &FullPathName->Buffer[ ((usPrefixNameLen*sizeof( WCHAR) + SubstituteName->Length)/sizeof( WCHAR))],
2557 &FullPathName->Buffer[ ((usPrefixNameLen*sizeof( WCHAR) + ComponentName->Length)/sizeof( WCHAR))],
2558 FullPathName->Length - usPrefixNameLen*sizeof( WCHAR) - ComponentName->Length);
2561 RtlCopyMemory( &FullPathName->Buffer[ usPrefixNameLen],
2562 SubstituteName->Buffer,
2563 SubstituteName->Length);
2565 FullPathName->Length += sNameLenDelta;
2567 ComponentName->Length += sNameLenDelta;
2569 ComponentName->MaximumLength = ComponentName->Length;
2571 if ( RemainingPath->Buffer)
2574 RemainingPath->Buffer += sNameLenDelta/sizeof( WCHAR);
2577 try_return( ntStatus);
2581 // Need to re-allocate the buffer
2584 uniPathName.Length = FullPathName->Length -
2585 ComponentName->Length +
2586 SubstituteName->Length;
2588 uniPathName.MaximumLength = FullPathName->MaximumLength + PAGE_SIZE;
2590 uniPathName.Buffer = (WCHAR *)AFSExAllocatePoolWithTag( PagedPool,
2591 uniPathName.MaximumLength,
2592 AFS_NAME_BUFFER_FOUR_TAG);
2594 if( uniPathName.Buffer == NULL)
2597 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
2600 usPrefixNameLen = (USHORT)(ComponentName->Buffer - FullPathName->Buffer);
2602 usPrefixNameLen *= sizeof( WCHAR);
2604 RtlZeroMemory( uniPathName.Buffer,
2605 uniPathName.MaximumLength);
2607 RtlCopyMemory( uniPathName.Buffer,
2608 FullPathName->Buffer,
2611 RtlCopyMemory( &uniPathName.Buffer[ (usPrefixNameLen/sizeof( WCHAR))],
2612 SubstituteName->Buffer,
2613 SubstituteName->Length);
2615 if( FullPathName->Length > usPrefixNameLen + ComponentName->Length)
2618 RtlCopyMemory( &uniPathName.Buffer[ (usPrefixNameLen + SubstituteName->Length)/sizeof( WCHAR)],
2619 &FullPathName->Buffer[ (usPrefixNameLen + ComponentName->Length)/sizeof( WCHAR)],
2620 FullPathName->Length - usPrefixNameLen - ComponentName->Length);
2623 ComponentName->Buffer = uniPathName.Buffer + (ComponentName->Buffer - FullPathName->Buffer);
2625 ComponentName->Length += sNameLenDelta;
2627 ComponentName->MaximumLength = ComponentName->Length;
2629 if ( RemainingPath->Buffer)
2632 RemainingPath->Buffer = uniPathName.Buffer
2633 + (RemainingPath->Buffer - FullPathName->Buffer)
2634 + sNameLenDelta/sizeof( WCHAR);
2639 AFSExFreePoolWithTag( FullPathName->Buffer, 0);
2642 *FullPathName = uniPathName;
2653 AFSInvalidateVolume( IN AFSVolumeCB *VolumeCB,
2657 NTSTATUS ntStatus = STATUS_SUCCESS;
2658 AFSObjectInfoCB *pCurrentObject = NULL;
2659 AFSObjectInfoCB *pNextObject = NULL;
2665 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2666 AFS_TRACE_LEVEL_VERBOSE,
2667 "AFSInvalidateVolume Invalidate volume fid %08lX-%08lX-%08lX-%08lX Reason %08lX\n",
2668 VolumeCB->ObjectInformation.FileId.Cell,
2669 VolumeCB->ObjectInformation.FileId.Volume,
2670 VolumeCB->ObjectInformation.FileId.Vnode,
2671 VolumeCB->ObjectInformation.FileId.Unique,
2675 // Depending on the reason for invalidation then perform work on the node
2681 case AFS_INVALIDATE_DELETED:
2685 // Mark this volume as invalid
2688 SetFlag( VolumeCB->ObjectInformation.Flags, AFS_OBJECT_FLAGS_OBJECT_INVALID);
2690 SetFlag( VolumeCB->Flags, AFS_VOLUME_FLAGS_OFFLINE);
2696 AFSAcquireShared( VolumeCB->ObjectInfoTree.TreeLock,
2700 // Invalidate the volume root directory
2703 pCurrentObject = &VolumeCB->ObjectInformation;
2705 if ( pCurrentObject )
2708 lCount = AFSObjectInfoIncrement( pCurrentObject,
2709 AFS_OBJECT_REFERENCE_INVALIDATION);
2711 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2712 AFS_TRACE_LEVEL_VERBOSE,
2713 "AFSInvalidateVolumeObjects Increment count on object %p Cnt %d\n",
2717 AFSReleaseResource( VolumeCB->ObjectInfoTree.TreeLock);
2719 AFSInvalidateObject( &pCurrentObject,
2722 AFSAcquireShared( VolumeCB->ObjectInfoTree.TreeLock,
2725 if ( pCurrentObject)
2728 lCount = AFSObjectInfoDecrement( pCurrentObject,
2729 AFS_OBJECT_REFERENCE_INVALIDATION);
2731 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2732 AFS_TRACE_LEVEL_VERBOSE,
2733 "AFSInvalidateVolumeObjects Decrement count on object %p Cnt %d\n",
2740 // Apply invalidation to all other volume objects
2743 pCurrentObject = VolumeCB->ObjectInfoListHead;
2745 if ( pCurrentObject)
2749 // Reference the node so it won't be torn down
2752 lCount = AFSObjectInfoIncrement( pCurrentObject,
2753 AFS_OBJECT_REFERENCE_INVALIDATION);
2755 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2756 AFS_TRACE_LEVEL_VERBOSE,
2757 "AFSInvalidateVolumeObjects Increment count on object %p Cnt %d\n",
2762 while( pCurrentObject != NULL)
2765 pNextObject = (AFSObjectInfoCB *)pCurrentObject->ListEntry.fLink;
2771 // Reference the node so it won't be torn down
2774 lCount = AFSObjectInfoIncrement( pNextObject,
2775 AFS_OBJECT_REFERENCE_INVALIDATION);
2777 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2778 AFS_TRACE_LEVEL_VERBOSE,
2779 "AFSInvalidateVolumeObjects Increment count on object %p Cnt %d\n",
2784 AFSReleaseResource( VolumeCB->ObjectInfoTree.TreeLock);
2786 AFSInvalidateObject( &pCurrentObject,
2789 AFSAcquireShared( VolumeCB->ObjectInfoTree.TreeLock,
2792 if ( pCurrentObject )
2795 lCount = AFSObjectInfoDecrement( pCurrentObject,
2796 AFS_OBJECT_REFERENCE_INVALIDATION);
2798 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2799 AFS_TRACE_LEVEL_VERBOSE,
2800 "AFSInvalidateVolumeObjects Decrement count on object %p Cnt %d\n",
2805 pCurrentObject = pNextObject;
2808 AFSReleaseResource( VolumeCB->ObjectInfoTree.TreeLock);
2815 AFSInvalidateAllVolumes( VOID)
2817 AFSVolumeCB *pVolumeCB = NULL;
2818 AFSVolumeCB *pNextVolumeCB = NULL;
2819 AFSDeviceExt *pRDRDeviceExt = NULL;
2822 pRDRDeviceExt = (AFSDeviceExt *)AFSRDRDeviceObject->DeviceExtension;
2824 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
2825 AFS_TRACE_LEVEL_VERBOSE,
2826 "AFSInvalidateAllVolumes Acquiring RDR VolumeListLock lock %p SHARED %08lX\n",
2827 &pRDRDeviceExt->Specific.RDR.VolumeListLock,
2828 PsGetCurrentThread()));
2830 AFSAcquireShared( &pRDRDeviceExt->Specific.RDR.VolumeListLock,
2833 pVolumeCB = pRDRDeviceExt->Specific.RDR.VolumeListHead;
2838 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
2839 AFS_TRACE_LEVEL_VERBOSE,
2840 "AFSInvalidateAllVolumes Acquiring VolumeRoot ObjectInfoTree lock %p SHARED %08lX\n",
2841 pVolumeCB->ObjectInfoTree.TreeLock,
2842 PsGetCurrentThread()));
2844 lCount = AFSVolumeIncrement( pVolumeCB,
2845 AFS_VOLUME_REFERENCE_INVALIDATE);
2847 AFSDbgTrace(( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
2848 AFS_TRACE_LEVEL_VERBOSE,
2849 "AFSInvalidateAllVolumes Increment count on volume %p Cnt %d\n",
2854 while( pVolumeCB != NULL)
2857 pNextVolumeCB = (AFSVolumeCB *)pVolumeCB->ListEntry.fLink;
2862 lCount = AFSVolumeIncrement( pNextVolumeCB,
2863 AFS_VOLUME_REFERENCE_INVALIDATE);
2865 AFSDbgTrace(( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
2866 AFS_TRACE_LEVEL_VERBOSE,
2867 "AFSInvalidateAllVolumes Increment count on volume %p Cnt %d\n",
2872 AFSReleaseResource( &pRDRDeviceExt->Specific.RDR.VolumeListLock);
2874 // do I need to hold the volume lock here?
2876 AFSInvalidateVolume( pVolumeCB, AFS_INVALIDATE_EXPIRED);
2878 AFSAcquireShared( &pRDRDeviceExt->Specific.RDR.VolumeListLock,
2881 lCount = AFSVolumeDecrement( pVolumeCB,
2882 AFS_VOLUME_REFERENCE_INVALIDATE);
2884 AFSDbgTrace(( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
2885 AFS_TRACE_LEVEL_VERBOSE,
2886 "AFSInvalidateAllVolumes Decrement count on volume %p Cnt %d\n",
2890 pVolumeCB = pNextVolumeCB;
2893 AFSReleaseResource( &pRDRDeviceExt->Specific.RDR.VolumeListLock);
2897 AFSVerifyEntry( IN GUID *AuthGroup,
2898 IN AFSDirectoryCB *DirEntry,
2899 IN BOOLEAN bFollowMountPoint)
2902 NTSTATUS ntStatus = STATUS_SUCCESS;
2903 AFSDirEnumEntry *pDirEnumEntry = NULL;
2904 AFSObjectInfoCB *pObjectInfo = DirEntry->ObjectInformation;
2905 IO_STATUS_BLOCK stIoStatus;
2910 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2911 AFS_TRACE_LEVEL_VERBOSE_2,
2912 "AFSVerifyEntry Verifying entry %wZ FID %08lX-%08lX-%08lX-%08lX\n",
2913 &DirEntry->NameInformation.FileName,
2914 pObjectInfo->FileId.Cell,
2915 pObjectInfo->FileId.Volume,
2916 pObjectInfo->FileId.Vnode,
2917 pObjectInfo->FileId.Unique));
2919 ntStatus = AFSEvaluateTargetByID( pObjectInfo,
2921 bFollowMountPoint ? FALSE : TRUE,
2924 if( !NT_SUCCESS( ntStatus))
2927 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2928 AFS_TRACE_LEVEL_ERROR,
2929 "AFSVerifyEntry Evaluate Target failed %wZ FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX\n",
2930 &DirEntry->NameInformation.FileName,
2931 pObjectInfo->FileId.Cell,
2932 pObjectInfo->FileId.Volume,
2933 pObjectInfo->FileId.Vnode,
2934 pObjectInfo->FileId.Unique,
2937 try_return( ntStatus);
2941 // Check the data version of the file
2944 if( pObjectInfo->DataVersion.QuadPart == pDirEnumEntry->DataVersion.QuadPart &&
2945 !BooleanFlagOn( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY_DATA))
2948 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2949 AFS_TRACE_LEVEL_VERBOSE,
2950 "AFSVerifyEntry No DV change %I64X for Fcb %wZ FID %08lX-%08lX-%08lX-%08lX\n",
2951 pObjectInfo->DataVersion.QuadPart,
2952 &DirEntry->NameInformation.FileName,
2953 pObjectInfo->FileId.Cell,
2954 pObjectInfo->FileId.Volume,
2955 pObjectInfo->FileId.Vnode,
2956 pObjectInfo->FileId.Unique));
2959 // We are ok, just get out
2962 ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
2964 try_return( ntStatus = STATUS_SUCCESS);
2968 // New data version so we will need to process the node based on the type
2971 switch( pDirEnumEntry->FileType)
2974 case AFS_FILE_TYPE_MOUNTPOINT:
2978 // For a mount point we need to ensure the target is the same
2981 if( !AFSIsEqualFID( &pObjectInfo->TargetFileId,
2982 &pDirEnumEntry->TargetFileId))
2988 // Update the metadata for the entry
2991 ntStatus = AFSUpdateMetaData( DirEntry,
2994 if( NT_SUCCESS( ntStatus))
2997 ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
3003 case AFS_FILE_TYPE_SYMLINK:
3007 // Update the metadata for the entry
3010 ntStatus = AFSUpdateMetaData( DirEntry,
3013 if( NT_SUCCESS( ntStatus))
3016 ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
3022 case AFS_FILE_TYPE_FILE:
3024 FILE_OBJECT * pCCFileObject = NULL;
3026 if ( BooleanFlagOn( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY_DATA))
3029 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
3030 AFS_TRACE_LEVEL_VERBOSE,
3031 "AFSVerifyEntry Clearing VERIFY_DATA flag %wZ FID %08lX-%08lX-%08lX-%08lX\n",
3032 &DirEntry->NameInformation.FileName,
3033 pObjectInfo->FileId.Cell,
3034 pObjectInfo->FileId.Volume,
3035 pObjectInfo->FileId.Vnode,
3036 pObjectInfo->FileId.Unique));
3038 ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY_DATA);
3041 if( pObjectInfo->Fcb != NULL)
3044 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
3045 AFS_TRACE_LEVEL_VERBOSE,
3046 "AFSVerifyEntry Flush/purge entry %wZ FID %08lX-%08lX-%08lX-%08lX\n",
3047 &DirEntry->NameInformation.FileName,
3048 pObjectInfo->FileId.Cell,
3049 pObjectInfo->FileId.Volume,
3050 pObjectInfo->FileId.Vnode,
3051 pObjectInfo->FileId.Unique));
3053 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING|AFS_SUBSYSTEM_SECTION_OBJECT,
3054 AFS_TRACE_LEVEL_VERBOSE,
3055 "AFSVerifyEntry Acquiring Fcb SectionObject lock %p EXCL %08lX\n",
3056 &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
3057 PsGetCurrentThread()));
3059 AFSAcquireExcl( &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
3065 CcFlushCache( &pObjectInfo->Fcb->NPFcb->SectionObjectPointers,
3070 if( !NT_SUCCESS( stIoStatus.Status))
3073 AFSDbgTrace(( AFS_SUBSYSTEM_IO_PROCESSING,
3074 AFS_TRACE_LEVEL_ERROR,
3075 "AFSVerifyEntry CcFlushCache failure %wZ FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX Bytes 0x%08lX\n",
3076 &DirEntry->NameInformation.FileName,
3077 pObjectInfo->FileId.Cell,
3078 pObjectInfo->FileId.Volume,
3079 pObjectInfo->FileId.Vnode,
3080 pObjectInfo->FileId.Unique,
3082 stIoStatus.Information));
3084 ntStatus = stIoStatus.Status;
3087 if ( pObjectInfo->Fcb->NPFcb->SectionObjectPointers.DataSectionObject != NULL)
3090 if ( !CcPurgeCacheSection( &pObjectInfo->Fcb->NPFcb->SectionObjectPointers,
3096 AFSDbgTrace(( AFS_SUBSYSTEM_IO_PROCESSING,
3097 AFS_TRACE_LEVEL_WARNING,
3098 "AFSVerifyEntry CcPurgeCacheSection failure %wZ FID %08lX-%08lX-%08lX-%08lX\n",
3099 &DirEntry->NameInformation.FileName,
3100 pObjectInfo->FileId.Cell,
3101 pObjectInfo->FileId.Volume,
3102 pObjectInfo->FileId.Vnode,
3103 pObjectInfo->FileId.Unique));
3105 SetFlag( pObjectInfo->Fcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
3109 __except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()))
3111 ntStatus = GetExceptionCode();
3115 "EXCEPTION - AFSVerifyEntry CcFlushCache or CcPurgeCacheSection %wZ FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX\n",
3116 &DirEntry->NameInformation.FileName,
3117 pObjectInfo->FileId.Cell,
3118 pObjectInfo->FileId.Volume,
3119 pObjectInfo->FileId.Vnode,
3120 pObjectInfo->FileId.Unique,
3123 SetFlag( pObjectInfo->Fcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
3126 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING|AFS_SUBSYSTEM_SECTION_OBJECT,
3127 AFS_TRACE_LEVEL_VERBOSE,
3128 "AFSVerifyEntry Releasing Fcb SectionObject lock %p EXCL %08lX\n",
3129 &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
3130 PsGetCurrentThread()));
3132 AFSReleaseResource( &pObjectInfo->Fcb->NPFcb->SectionObjectResource);
3134 AFSFlushExtents( pObjectInfo->Fcb,
3138 // Acquire the Fcb to purge the cache
3141 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
3142 AFS_TRACE_LEVEL_VERBOSE,
3143 "AFSVerifyEntry Acquiring Fcb lock %p EXCL %08lX\n",
3144 &pObjectInfo->Fcb->NPFcb->Resource,
3145 PsGetCurrentThread()));
3147 AFSAcquireExcl( &pObjectInfo->Fcb->NPFcb->Resource,
3151 // Update the metadata for the entry
3154 ntStatus = AFSUpdateMetaData( DirEntry,
3157 if( !NT_SUCCESS( ntStatus))
3160 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
3161 AFS_TRACE_LEVEL_ERROR,
3162 "AFSVerifyEntry Meta Data Update failed %wZ FID %08lX-%08lX-%08lX-%08lX ntStatus %08lX\n",
3163 &DirEntry->NameInformation.FileName,
3164 pObjectInfo->FileId.Cell,
3165 pObjectInfo->FileId.Volume,
3166 pObjectInfo->FileId.Vnode,
3167 pObjectInfo->FileId.Unique,
3174 // Update file sizes
3177 pObjectInfo->Fcb->Header.AllocationSize.QuadPart = pObjectInfo->AllocationSize.QuadPart;
3178 pObjectInfo->Fcb->Header.FileSize.QuadPart = pObjectInfo->EndOfFile.QuadPart;
3179 pObjectInfo->Fcb->Header.ValidDataLength.QuadPart = pObjectInfo->EndOfFile.QuadPart;
3181 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING|AFS_SUBSYSTEM_SECTION_OBJECT,
3182 AFS_TRACE_LEVEL_VERBOSE,
3183 "AFSVerifyEntry Acquiring Fcb SectionObject lock %p EXCL %08lX\n",
3184 &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
3185 PsGetCurrentThread()));
3187 AFSAcquireExcl( &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
3193 pCCFileObject = CcGetFileObjectFromSectionPtrs( &pObjectInfo->Fcb->NPFcb->SectionObjectPointers);
3195 if ( pCCFileObject != NULL)
3197 CcSetFileSizes( pCCFileObject,
3198 (PCC_FILE_SIZES)&pObjectInfo->Fcb->Header.AllocationSize);
3201 __except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()))
3204 ntStatus = GetExceptionCode();
3208 "EXCEPTION - AFSVerifyEntry CcSetFileSized failed FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX\n",
3209 pObjectInfo->FileId.Cell,
3210 pObjectInfo->FileId.Volume,
3211 pObjectInfo->FileId.Vnode,
3212 pObjectInfo->FileId.Unique,
3216 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING|AFS_SUBSYSTEM_SECTION_OBJECT,
3217 AFS_TRACE_LEVEL_VERBOSE,
3218 "AFSVerifyEntry Releasing Fcb SectionObject lock %p EXCL %08lX\n",
3219 &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
3220 PsGetCurrentThread()));
3222 AFSReleaseResource( &pObjectInfo->Fcb->NPFcb->SectionObjectResource);
3225 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
3226 AFS_TRACE_LEVEL_VERBOSE,