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 ExFreePool( pDirNode);
728 lCount = AFSObjectInfoDecrement( pObjectInfoCB,
729 AFS_OBJECT_REFERENCE_GLOBAL);
731 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
732 AFS_TRACE_LEVEL_VERBOSE,
733 "AFSInitializeGlobalDirectoryEntries Decrement count on object %p Cnt %d\n",
740 AFSDeleteObjectInfo( &pObjectInfoCB);
743 AFSDbgTrace(( AFS_SUBSYSTEM_LOAD_LIBRARY | AFS_SUBSYSTEM_INIT_PROCESSING,
744 AFS_TRACE_LEVEL_ERROR,
745 "AFSInitializeGlobalDirectory AFS_DIR_ENTRY_NP_TAG allocation failure\n"));
747 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
750 RtlZeroMemory( pDirNode,
753 RtlZeroMemory( pNonPagedDirEntry,
754 sizeof( AFSNonPagedDirectoryCB));
756 ExInitializeResourceLite( &pNonPagedDirEntry->Lock);
758 pDirNode->NonPaged = pNonPagedDirEntry;
760 pDirNode->ObjectInformation = pObjectInfoCB;
766 SetFlag( pDirNode->Flags, AFS_DIR_ENTRY_NOT_IN_PARENT_TREE | AFS_DIR_ENTRY_FAKE | AFS_DIR_ENTRY_VALID);
768 pDirNode->FileIndex = (ULONG)AFS_DIR_ENTRY_DOT_INDEX;
771 // Setup the names in the entry
774 pDirNode->NameInformation.FileName.Length = sizeof( WCHAR);
776 pDirNode->NameInformation.FileName.MaximumLength = sizeof( WCHAR);
778 pDirNode->NameInformation.FileName.Buffer = (WCHAR *)((char *)pDirNode + sizeof( AFSDirectoryCB));
780 pDirNode->NameInformation.FileName.Buffer[ 0] = L'.';
783 // Populate the rest of the data
786 pObjectInfoCB->FileType = AFS_FILE_TYPE_DIRECTORY;
788 pObjectInfoCB->FileAttributes = FILE_ATTRIBUTE_DIRECTORY;
790 AFSGlobalDotDirEntry = pDirNode;
796 pObjectInfoCB = AFSAllocateObjectInfo( &AFSGlobalRoot->ObjectInformation,
799 if( pObjectInfoCB == NULL)
802 AFSDbgTrace(( AFS_SUBSYSTEM_LOAD_LIBRARY | AFS_SUBSYSTEM_INIT_PROCESSING,
803 AFS_TRACE_LEVEL_ERROR,
804 "AFSInitializeGlobalDirectory AFSAllocateObjectInfo (2) failure %08lX\n",
807 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
810 lCount = AFSObjectInfoIncrement( pObjectInfoCB,
811 AFS_OBJECT_REFERENCE_GLOBAL);
813 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
814 AFS_TRACE_LEVEL_VERBOSE,
815 "AFSInitializeGlobalDirectoryEntries Increment count on object %p Cnt %d\n",
819 ntStatus = STATUS_SUCCESS;
821 ulEntryLength = sizeof( AFSDirectoryCB) +
822 ( 2 * sizeof( WCHAR));
824 pDirNode = (AFSDirectoryCB *)AFSLibExAllocatePoolWithTag( PagedPool,
828 if( pDirNode == NULL)
831 AFSDbgTrace(( AFS_SUBSYSTEM_LOAD_LIBRARY | AFS_SUBSYSTEM_INIT_PROCESSING | AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
832 AFS_TRACE_LEVEL_ERROR,
833 "AFSInitializeGlobalDirectoryEntries AFS_DIR_ENTRY_TAG allocation failure\n"));
835 lCount = AFSObjectInfoDecrement( pObjectInfoCB,
836 AFS_OBJECT_REFERENCE_GLOBAL);
838 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
839 AFS_TRACE_LEVEL_VERBOSE,
840 "AFSInitializeGlobalDirectoryEntries Decrement count on object %p Cnt %d\n",
847 AFSDeleteObjectInfo( &pObjectInfoCB);
850 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
853 AFSDbgTrace(( AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
854 AFS_TRACE_LEVEL_VERBOSE,
855 "AFSInitializeGlobalDirectoryEntries AFS_DIR_ENTRY_TAG allocated %p\n",
858 pNonPagedDirEntry = (AFSNonPagedDirectoryCB *)AFSLibExAllocatePoolWithTag( NonPagedPool,
859 sizeof( AFSNonPagedDirectoryCB),
860 AFS_DIR_ENTRY_NP_TAG);
862 if( pNonPagedDirEntry == NULL)
865 ExFreePool( pDirNode);
867 lCount = AFSObjectInfoDecrement( pObjectInfoCB,
868 AFS_OBJECT_REFERENCE_GLOBAL);
870 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
871 AFS_TRACE_LEVEL_VERBOSE,
872 "AFSInitializeGlobalDirectoryEntries Decrement count on object %p Cnt %d\n",
879 AFSDeleteObjectInfo( &pObjectInfoCB);
882 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
885 RtlZeroMemory( pDirNode,
888 RtlZeroMemory( pNonPagedDirEntry,
889 sizeof( AFSNonPagedDirectoryCB));
891 ExInitializeResourceLite( &pNonPagedDirEntry->Lock);
893 pDirNode->NonPaged = pNonPagedDirEntry;
895 pDirNode->ObjectInformation = pObjectInfoCB;
901 SetFlag( pDirNode->Flags, AFS_DIR_ENTRY_NOT_IN_PARENT_TREE | AFS_DIR_ENTRY_FAKE | AFS_DIR_ENTRY_VALID);
903 pDirNode->FileIndex = (ULONG)AFS_DIR_ENTRY_DOT_DOT_INDEX;
906 // Setup the names in the entry
909 pDirNode->NameInformation.FileName.Length = 2 * sizeof( WCHAR);
911 pDirNode->NameInformation.FileName.MaximumLength = 2 * sizeof( WCHAR);
913 pDirNode->NameInformation.FileName.Buffer = (WCHAR *)((char *)pDirNode + sizeof( AFSDirectoryCB));
915 pDirNode->NameInformation.FileName.Buffer[ 0] = L'.';
917 pDirNode->NameInformation.FileName.Buffer[ 1] = L'.';
920 // Populate the rest of the data
923 pObjectInfoCB->FileType = AFS_FILE_TYPE_DIRECTORY;
925 pObjectInfoCB->FileAttributes = FILE_ATTRIBUTE_DIRECTORY;
927 AFSGlobalDotDotDirEntry = pDirNode;
931 if( !NT_SUCCESS( ntStatus))
934 if( AFSGlobalDotDirEntry != NULL)
937 lCount = AFSObjectInfoDecrement( AFSGlobalDotDirEntry->ObjectInformation,
938 AFS_OBJECT_REFERENCE_GLOBAL);
940 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
941 AFS_TRACE_LEVEL_VERBOSE,
942 "AFSInitializeGlobalDirectoryEntries Decrement count on object %p Cnt %d\n",
943 AFSGlobalDotDirEntry->ObjectInformation,
949 AFSDeleteObjectInfo( &AFSGlobalDotDirEntry->ObjectInformation);
952 ExDeleteResourceLite( &AFSGlobalDotDirEntry->NonPaged->Lock);
954 ExFreePool( AFSGlobalDotDirEntry->NonPaged);
956 ExFreePool( AFSGlobalDotDirEntry);
958 AFSGlobalDotDirEntry = NULL;
961 if( AFSGlobalDotDotDirEntry != NULL)
964 lCount = AFSObjectInfoDecrement( AFSGlobalDotDotDirEntry->ObjectInformation,
965 AFS_OBJECT_REFERENCE_GLOBAL);
967 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
968 AFS_TRACE_LEVEL_VERBOSE,
969 "AFSInitializeGlobalDirectoryEntries Decrement count on object %p Cnt %d\n",
970 AFSGlobalDotDotDirEntry->ObjectInformation,
976 AFSDeleteObjectInfo( &AFSGlobalDotDotDirEntry->ObjectInformation);
979 ExDeleteResourceLite( &AFSGlobalDotDotDirEntry->NonPaged->Lock);
981 ExFreePool( AFSGlobalDotDotDirEntry->NonPaged);
983 ExFreePool( AFSGlobalDotDotDirEntry);
985 AFSGlobalDotDotDirEntry = NULL;
994 AFSInitDirEntry( IN AFSObjectInfoCB *ParentObjectInfo,
995 IN PUNICODE_STRING FileName,
996 IN PUNICODE_STRING TargetName,
997 IN AFSDirEnumEntry *DirEnumEntry,
1001 AFSDirectoryCB *pDirNode = NULL;
1002 NTSTATUS ntStatus = STATUS_SUCCESS;
1003 ULONG ulEntryLength = 0;
1004 AFSObjectInfoCB *pObjectInfoCB = NULL;
1005 BOOLEAN bAllocatedObjectCB = FALSE;
1006 ULONGLONG ullIndex = 0;
1007 AFSNonPagedDirectoryCB *pNonPagedDirEntry = NULL;
1013 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1014 AFS_TRACE_LEVEL_VERBOSE,
1015 "AFSInitDirEntry Initializing entry %wZ parent FID %08lX-%08lX-%08lX-%08lX\n",
1017 ParentObjectInfo->FileId.Cell,
1018 ParentObjectInfo->FileId.Volume,
1019 ParentObjectInfo->FileId.Vnode,
1020 ParentObjectInfo->FileId.Unique));
1023 // First thing is to locate/create our object information block
1027 AFSAcquireExcl( ParentObjectInfo->VolumeCB->ObjectInfoTree.TreeLock,
1030 ullIndex = AFSCreateLowIndex( &DirEnumEntry->FileId);
1032 ntStatus = AFSLocateHashEntry( ParentObjectInfo->VolumeCB->ObjectInfoTree.TreeHead,
1034 (AFSBTreeEntry **)&pObjectInfoCB);
1036 if( !NT_SUCCESS( ntStatus) ||
1037 pObjectInfoCB == NULL)
1041 // Allocate our object info cb
1044 pObjectInfoCB = AFSAllocateObjectInfo( ParentObjectInfo,
1047 if( pObjectInfoCB == NULL)
1050 AFSReleaseResource( ParentObjectInfo->VolumeCB->ObjectInfoTree.TreeLock);
1052 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
1055 bAllocatedObjectCB = TRUE;
1057 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1058 AFS_TRACE_LEVEL_VERBOSE,
1059 "AFSInitDirEntry initialized object %p Parent Object %p for %wZ\n",
1066 // This reference count is either stored into the return DirectoryCB
1067 // or released before function exit.
1070 lCount = AFSObjectInfoIncrement( pObjectInfoCB,
1071 AFS_OBJECT_REFERENCE_DIRENTRY);
1073 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
1074 AFS_TRACE_LEVEL_VERBOSE,
1075 "AFSInitDirEntry Increment count on object %p Cnt %d\n",
1079 AFSReleaseResource( ParentObjectInfo->VolumeCB->ObjectInfoTree.TreeLock);
1081 ntStatus = STATUS_SUCCESS;
1083 ulEntryLength = sizeof( AFSDirectoryCB) +
1086 if( TargetName != NULL)
1089 ulEntryLength += TargetName->Length;
1092 pDirNode = (AFSDirectoryCB *)AFSExAllocatePoolWithTag( PagedPool,
1096 if( pDirNode == NULL)
1099 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
1102 AFSDbgTrace(( AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
1103 AFS_TRACE_LEVEL_VERBOSE,
1104 "AFSInitDirEntry AFS_DIR_ENTRY_TAG allocated %p\n",
1107 pNonPagedDirEntry = (AFSNonPagedDirectoryCB *)AFSExAllocatePoolWithTag( NonPagedPool,
1108 sizeof( AFSNonPagedDirectoryCB),
1109 AFS_DIR_ENTRY_NP_TAG);
1111 if( pNonPagedDirEntry == NULL)
1114 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
1117 RtlZeroMemory( pDirNode,
1120 RtlZeroMemory( pNonPagedDirEntry,
1121 sizeof( AFSNonPagedDirectoryCB));
1123 ExInitializeResourceLite( &pNonPagedDirEntry->Lock);
1125 pDirNode->NonPaged = pNonPagedDirEntry;
1127 pDirNode->ObjectInformation = pObjectInfoCB;
1130 // Set valid entry and NOT_IN_PARENT flag
1133 SetFlag( pDirNode->Flags, AFS_DIR_ENTRY_VALID | AFS_DIR_ENTRY_NOT_IN_PARENT_TREE);
1135 pDirNode->FileIndex = FileIndex;
1138 // Setup the names in the entry
1141 if( FileName->Length > 0)
1144 pDirNode->NameInformation.FileName.Length = FileName->Length;
1146 pDirNode->NameInformation.FileName.MaximumLength = FileName->Length;
1148 pDirNode->NameInformation.FileName.Buffer = (WCHAR *)((char *)pDirNode + sizeof( AFSDirectoryCB));
1150 RtlCopyMemory( pDirNode->NameInformation.FileName.Buffer,
1152 pDirNode->NameInformation.FileName.Length);
1155 // Create a CRC for the file
1158 pDirNode->CaseSensitiveTreeEntry.HashIndex = AFSGenerateCRC( &pDirNode->NameInformation.FileName,
1161 pDirNode->CaseInsensitiveTreeEntry.HashIndex = AFSGenerateCRC( &pDirNode->NameInformation.FileName,
1165 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1166 AFS_TRACE_LEVEL_VERBOSE,
1167 "AFSInitDirEntry Initialized DE %p for %wZ in parent FID %08lX-%08lX-%08lX-%08lX\n",
1170 ParentObjectInfo->FileId.Cell,
1171 ParentObjectInfo->FileId.Volume,
1172 ParentObjectInfo->FileId.Vnode,
1173 ParentObjectInfo->FileId.Unique));
1175 if( TargetName != NULL &&
1176 TargetName->Length > 0)
1179 pDirNode->NameInformation.TargetName.Length = TargetName->Length;
1181 pDirNode->NameInformation.TargetName.MaximumLength = pDirNode->NameInformation.TargetName.Length;
1183 pDirNode->NameInformation.TargetName.Buffer = (WCHAR *)((char *)pDirNode +
1184 sizeof( AFSDirectoryCB) +
1185 pDirNode->NameInformation.FileName.Length);
1187 RtlCopyMemory( pDirNode->NameInformation.TargetName.Buffer,
1189 pDirNode->NameInformation.TargetName.Length);
1193 // If we allocated the object information cb then update the information
1196 if( bAllocatedObjectCB)
1200 // Populate the rest of the data
1203 pObjectInfoCB->FileId = DirEnumEntry->FileId;
1205 pObjectInfoCB->TargetFileId = DirEnumEntry->TargetFileId;
1207 pObjectInfoCB->FileType = DirEnumEntry->FileType;
1209 pObjectInfoCB->CreationTime = DirEnumEntry->CreationTime;
1211 pObjectInfoCB->LastAccessTime = DirEnumEntry->LastAccessTime;
1213 pObjectInfoCB->LastWriteTime = DirEnumEntry->LastWriteTime;
1215 pObjectInfoCB->ChangeTime = DirEnumEntry->ChangeTime;
1217 pObjectInfoCB->EndOfFile = DirEnumEntry->EndOfFile;
1219 pObjectInfoCB->AllocationSize = DirEnumEntry->AllocationSize;
1221 pObjectInfoCB->FileAttributes = DirEnumEntry->FileAttributes;
1223 if( pObjectInfoCB->FileType == AFS_FILE_TYPE_MOUNTPOINT ||
1224 pObjectInfoCB->FileType == AFS_FILE_TYPE_DFSLINK)
1227 pObjectInfoCB->FileAttributes |= (FILE_ATTRIBUTE_DIRECTORY | FILE_ATTRIBUTE_REPARSE_POINT);
1230 if (pObjectInfoCB->FileType == AFS_FILE_TYPE_SYMLINK)
1233 if ( pObjectInfoCB->FileAttributes == FILE_ATTRIBUTE_NORMAL)
1236 pObjectInfoCB->FileAttributes = FILE_ATTRIBUTE_REPARSE_POINT;
1241 pObjectInfoCB->FileAttributes |= FILE_ATTRIBUTE_REPARSE_POINT;
1245 pObjectInfoCB->EaSize = DirEnumEntry->EaSize;
1248 // Check for the case where we have a filetype of SymLink but both the TargetFid and the
1249 // TargetName are empty. In this case set the filetype to zero so we evaluate it later in
1253 if( pObjectInfoCB->FileType == AFS_FILE_TYPE_SYMLINK &&
1254 pObjectInfoCB->TargetFileId.Vnode == 0 &&
1255 pObjectInfoCB->TargetFileId.Unique == 0 &&
1256 pDirNode->NameInformation.TargetName.Length == 0)
1260 // This will ensure we perform a validation on the node
1263 pObjectInfoCB->FileType = AFS_FILE_TYPE_UNKNOWN;
1266 if( pObjectInfoCB->FileType == AFS_FILE_TYPE_UNKNOWN)
1269 SetFlag( pObjectInfoCB->Flags, AFS_OBJECT_FLAGS_NOT_EVALUATED);
1274 // Object specific information
1277 pObjectInfoCB->Links = DirEnumEntry->Links;
1279 pObjectInfoCB->Expiration = DirEnumEntry->Expiration;
1281 pObjectInfoCB->DataVersion = DirEnumEntry->DataVersion;
1285 if( !NT_SUCCESS( ntStatus))
1288 if( pNonPagedDirEntry != NULL)
1291 ExDeleteResourceLite( &pNonPagedDirEntry->Lock);
1293 AFSExFreePoolWithTag( pNonPagedDirEntry, AFS_DIR_ENTRY_NP_TAG);
1296 if( pDirNode != NULL)
1299 AFSDbgTrace(( AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
1300 AFS_TRACE_LEVEL_VERBOSE,
1301 "AFSInitDirEntry AFS_DIR_ENTRY_TAG deallocating %p\n",
1304 AFSExFreePoolWithTag( pDirNode, AFS_DIR_ENTRY_TAG);
1310 // Dereference our object info block if we have one
1313 if( pObjectInfoCB != NULL)
1316 lCount = AFSObjectInfoDecrement( pObjectInfoCB,
1317 AFS_OBJECT_REFERENCE_DIRENTRY);
1319 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
1320 AFS_TRACE_LEVEL_VERBOSE,
1321 "AFSInitDirEntry Decrement count on object %p Cnt %d\n",
1325 if( bAllocatedObjectCB &&
1329 AFSDeleteObjectInfo( &pObjectInfoCB);
1339 AFSCheckForReadOnlyAccess( IN ACCESS_MASK DesiredAccess,
1340 IN BOOLEAN DirectoryEntry)
1343 BOOLEAN bReturn = TRUE;
1344 ACCESS_MASK stAccessMask = 0;
1347 // Get rid of anything we don't know about
1350 DesiredAccess = (DesiredAccess &
1356 ACCESS_SYSTEM_SECURITY |
1360 FILE_READ_ATTRIBUTES |
1361 FILE_WRITE_ATTRIBUTES |
1362 FILE_LIST_DIRECTORY |
1368 // Our 'read only' access mask. These are the accesses we will
1369 // allow for a read only file
1372 stAccessMask = DELETE |
1377 ACCESS_SYSTEM_SECURITY |
1381 FILE_READ_ATTRIBUTES |
1382 FILE_WRITE_ATTRIBUTES |
1384 FILE_LIST_DIRECTORY |
1388 // For a directory, add in the directory specific accesses
1394 stAccessMask |= FILE_ADD_SUBDIRECTORY |
1399 if( FlagOn( DesiredAccess, ~stAccessMask))
1403 // A write access is set ...
1413 AFSEvaluateNode( IN GUID *AuthGroup,
1414 IN AFSDirectoryCB *DirEntry)
1417 NTSTATUS ntStatus = STATUS_SUCCESS;
1418 AFSDirEnumEntry *pDirEntry = NULL;
1419 UNICODE_STRING uniTargetName;
1424 ntStatus = AFSEvaluateTargetByID( DirEntry->ObjectInformation,
1429 if( !NT_SUCCESS( ntStatus))
1432 try_return( ntStatus);
1435 DirEntry->ObjectInformation->TargetFileId = pDirEntry->TargetFileId;
1437 DirEntry->ObjectInformation->Expiration = pDirEntry->Expiration;
1439 DirEntry->ObjectInformation->DataVersion = pDirEntry->DataVersion;
1441 DirEntry->ObjectInformation->FileType = pDirEntry->FileType;
1443 DirEntry->ObjectInformation->CreationTime = pDirEntry->CreationTime;
1445 DirEntry->ObjectInformation->LastAccessTime = pDirEntry->LastAccessTime;
1447 DirEntry->ObjectInformation->LastWriteTime = pDirEntry->LastWriteTime;
1449 DirEntry->ObjectInformation->ChangeTime = pDirEntry->ChangeTime;
1451 DirEntry->ObjectInformation->EndOfFile = pDirEntry->EndOfFile;
1453 DirEntry->ObjectInformation->AllocationSize = pDirEntry->AllocationSize;
1455 DirEntry->ObjectInformation->FileAttributes = pDirEntry->FileAttributes;
1457 if( pDirEntry->FileType == AFS_FILE_TYPE_MOUNTPOINT ||
1458 pDirEntry->FileType == AFS_FILE_TYPE_DFSLINK)
1461 DirEntry->ObjectInformation->FileAttributes |= (FILE_ATTRIBUTE_DIRECTORY | FILE_ATTRIBUTE_REPARSE_POINT);
1464 if( pDirEntry->FileType == AFS_FILE_TYPE_SYMLINK)
1467 if ( DirEntry->ObjectInformation->FileAttributes == FILE_ATTRIBUTE_NORMAL)
1470 DirEntry->ObjectInformation->FileAttributes = FILE_ATTRIBUTE_REPARSE_POINT;
1475 DirEntry->ObjectInformation->FileAttributes |= FILE_ATTRIBUTE_REPARSE_POINT;
1479 DirEntry->ObjectInformation->EaSize = pDirEntry->EaSize;
1481 DirEntry->ObjectInformation->Links = pDirEntry->Links;
1484 // If we have a target name then see if it needs updating ...
1487 if( pDirEntry->TargetNameLength > 0)
1491 // Update the target name information if needed
1494 uniTargetName.Length = (USHORT)pDirEntry->TargetNameLength;
1496 uniTargetName.MaximumLength = uniTargetName.Length;
1498 uniTargetName.Buffer = (WCHAR *)((char *)pDirEntry + pDirEntry->TargetNameOffset);
1500 AFSAcquireExcl( &DirEntry->NonPaged->Lock,
1503 if( DirEntry->NameInformation.TargetName.Length == 0 ||
1504 RtlCompareUnicodeString( &uniTargetName,
1505 &DirEntry->NameInformation.TargetName,
1510 // Update the target name
1513 ntStatus = AFSUpdateTargetName( &DirEntry->NameInformation.TargetName,
1515 uniTargetName.Buffer,
1516 uniTargetName.Length);
1518 if( !NT_SUCCESS( ntStatus))
1521 AFSReleaseResource( &DirEntry->NonPaged->Lock);
1523 try_return( ntStatus);
1527 AFSReleaseResource( &DirEntry->NonPaged->Lock);
1532 if( pDirEntry != NULL)
1535 AFSExFreePoolWithTag( pDirEntry, AFS_GENERIC_MEMORY_2_TAG);
1543 AFSValidateSymLink( IN GUID *AuthGroup,
1544 IN AFSDirectoryCB *DirEntry)
1547 NTSTATUS ntStatus = STATUS_SUCCESS;
1548 AFSDirEnumEntry *pDirEntry = NULL;
1549 UNICODE_STRING uniTargetName;
1554 ntStatus = AFSEvaluateTargetByID( DirEntry->ObjectInformation,
1559 if( !NT_SUCCESS( ntStatus))
1562 try_return( ntStatus);
1565 if( pDirEntry->FileType == AFS_FILE_TYPE_UNKNOWN ||
1566 pDirEntry->FileType == AFS_FILE_TYPE_INVALID)
1569 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1570 AFS_TRACE_LEVEL_VERBOSE_2,
1571 "AFSValidateSymLink Invalid type Status %08lX\n",
1572 STATUS_OBJECT_NAME_NOT_FOUND));
1574 try_return( ntStatus = STATUS_OBJECT_NAME_NOT_FOUND);
1577 DirEntry->ObjectInformation->TargetFileId = pDirEntry->TargetFileId;
1579 DirEntry->ObjectInformation->Expiration = pDirEntry->Expiration;
1581 DirEntry->ObjectInformation->DataVersion = pDirEntry->DataVersion;
1584 // Update the target name information if needed
1587 uniTargetName.Length = (USHORT)pDirEntry->TargetNameLength;
1589 uniTargetName.MaximumLength = uniTargetName.Length;
1591 uniTargetName.Buffer = (WCHAR *)((char *)pDirEntry + pDirEntry->TargetNameOffset);
1593 if( uniTargetName.Length > 0)
1596 AFSAcquireExcl( &DirEntry->NonPaged->Lock,
1599 if( DirEntry->NameInformation.TargetName.Length == 0 ||
1600 RtlCompareUnicodeString( &uniTargetName,
1601 &DirEntry->NameInformation.TargetName,
1606 // Update the target name
1609 ntStatus = AFSUpdateTargetName( &DirEntry->NameInformation.TargetName,
1611 uniTargetName.Buffer,
1612 uniTargetName.Length);
1614 if( !NT_SUCCESS( ntStatus))
1617 AFSReleaseResource( &DirEntry->NonPaged->Lock);
1619 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
1623 AFSReleaseResource( &DirEntry->NonPaged->Lock);
1627 // If the FileType is the same then nothing to do since it IS
1631 if( pDirEntry->FileType == DirEntry->ObjectInformation->FileType)
1634 ASSERT( pDirEntry->FileType == AFS_FILE_TYPE_SYMLINK);
1636 try_return( ntStatus = STATUS_SUCCESS);
1639 DirEntry->ObjectInformation->FileType = pDirEntry->FileType;
1641 DirEntry->ObjectInformation->CreationTime = pDirEntry->CreationTime;
1643 DirEntry->ObjectInformation->LastAccessTime = pDirEntry->LastAccessTime;
1645 DirEntry->ObjectInformation->LastWriteTime = pDirEntry->LastWriteTime;
1647 DirEntry->ObjectInformation->ChangeTime = pDirEntry->ChangeTime;
1649 DirEntry->ObjectInformation->EndOfFile = pDirEntry->EndOfFile;
1651 DirEntry->ObjectInformation->AllocationSize = pDirEntry->AllocationSize;
1653 DirEntry->ObjectInformation->FileAttributes = pDirEntry->FileAttributes;
1655 if( pDirEntry->FileType == AFS_FILE_TYPE_MOUNTPOINT ||
1656 pDirEntry->FileType == AFS_FILE_TYPE_DFSLINK)
1659 DirEntry->ObjectInformation->FileAttributes |= (FILE_ATTRIBUTE_DIRECTORY | FILE_ATTRIBUTE_REPARSE_POINT);
1662 if( pDirEntry->FileType == AFS_FILE_TYPE_SYMLINK)
1665 if ( DirEntry->ObjectInformation->FileAttributes == FILE_ATTRIBUTE_NORMAL)
1668 DirEntry->ObjectInformation->FileAttributes = FILE_ATTRIBUTE_REPARSE_POINT;
1673 DirEntry->ObjectInformation->FileAttributes |= FILE_ATTRIBUTE_REPARSE_POINT;
1677 DirEntry->ObjectInformation->EaSize = pDirEntry->EaSize;
1679 DirEntry->ObjectInformation->Links = pDirEntry->Links;
1683 if( pDirEntry != NULL)
1686 AFSExFreePoolWithTag( pDirEntry, AFS_GENERIC_MEMORY_2_TAG);
1694 AFSInvalidateObject( IN OUT AFSObjectInfoCB **ppObjectInfo,
1698 NTSTATUS ntStatus = STATUS_SUCCESS;
1699 IO_STATUS_BLOCK stIoStatus;
1701 AFSObjectInfoCB * pParentObjectInfo = NULL;
1703 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1704 AFS_TRACE_LEVEL_VERBOSE,
1705 "AFSInvalidateObject Invalidation on node type %d for fid %08lX-%08lX-%08lX-%08lX Reason %d\n",
1706 (*ppObjectInfo)->FileType,
1707 (*ppObjectInfo)->FileId.Cell,
1708 (*ppObjectInfo)->FileId.Volume,
1709 (*ppObjectInfo)->FileId.Vnode,
1710 (*ppObjectInfo)->FileId.Unique,
1713 if ( BooleanFlagOn( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_PARENT_FID))
1716 pParentObjectInfo = AFSFindObjectInfo( (*ppObjectInfo)->VolumeCB,
1717 &(*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 AFSAcquireExcl( &(*ppObjectInfo)->Fcb->NPFcb->SectionObjectResource,
1879 CcFlushCache( &(*ppObjectInfo)->Fcb->NPFcb->SectionObjectPointers,
1884 if( !NT_SUCCESS( stIoStatus.Status))
1887 AFSDbgTrace(( AFS_SUBSYSTEM_IO_PROCESSING,
1888 AFS_TRACE_LEVEL_ERROR,
1889 "AFSInvalidateObject CcFlushCache failure FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX Bytes 0x%08lX\n",
1890 (*ppObjectInfo)->FileId.Cell,
1891 (*ppObjectInfo)->FileId.Volume,
1892 (*ppObjectInfo)->FileId.Vnode,
1893 (*ppObjectInfo)->FileId.Unique,
1895 stIoStatus.Information));
1897 ntStatus = stIoStatus.Status;
1901 if ( (*ppObjectInfo)->Fcb->NPFcb->SectionObjectPointers.DataSectionObject != NULL)
1904 if ( !CcPurgeCacheSection( &(*ppObjectInfo)->Fcb->NPFcb->SectionObjectPointers,
1910 AFSDbgTrace(( AFS_SUBSYSTEM_IO_PROCESSING,
1911 AFS_TRACE_LEVEL_WARNING,
1912 "AFSInvalidateObject CcPurgeCacheSection failure FID %08lX-%08lX-%08lX-%08lX\n",
1913 (*ppObjectInfo)->FileId.Cell,
1914 (*ppObjectInfo)->FileId.Volume,
1915 (*ppObjectInfo)->FileId.Vnode,
1916 (*ppObjectInfo)->FileId.Unique));
1918 SetFlag( (*ppObjectInfo)->Fcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
1922 __except( EXCEPTION_EXECUTE_HANDLER)
1925 ntStatus = GetExceptionCode();
1929 "EXCEPTION - AFSInvalidateObject Cc FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX\n",
1930 (*ppObjectInfo)->FileId.Cell,
1931 (*ppObjectInfo)->FileId.Volume,
1932 (*ppObjectInfo)->FileId.Vnode,
1933 (*ppObjectInfo)->FileId.Unique,
1936 SetFlag( (*ppObjectInfo)->Fcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
1939 AFSReleaseResource( &(*ppObjectInfo)->Fcb->NPFcb->SectionObjectResource);
1942 // Clear out the extents
1943 // Get rid of them (note this involves waiting
1944 // for any writes or reads to the cache to complete)
1947 AFSTearDownFcbExtents( (*ppObjectInfo)->Fcb,
1951 (*ppObjectInfo)->DataVersion.QuadPart = (ULONGLONG)-1;
1954 if( (*ppObjectInfo)->FileType == AFS_FILE_TYPE_FILE)
1957 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
1958 AFS_TRACE_LEVEL_VERBOSE,
1959 "AFSInvalidateObject Setting VERIFY_DATA flag on fid %08lX-%08lX-%08lX-%08lX\n",
1960 (*ppObjectInfo)->FileId.Cell,
1961 (*ppObjectInfo)->FileId.Volume,
1962 (*ppObjectInfo)->FileId.Vnode,
1963 (*ppObjectInfo)->FileId.Unique));
1965 SetFlag( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_VERIFY_DATA);
1968 // Fall through to the default processing
1974 if( (*ppObjectInfo)->FileType == AFS_FILE_TYPE_DIRECTORY)
1976 ulFilter = FILE_NOTIFY_CHANGE_DIR_NAME;
1980 ulFilter = FILE_NOTIFY_CHANGE_FILE_NAME;
1983 if( Reason == AFS_INVALIDATE_CREDS)
1985 ulFilter |= FILE_NOTIFY_CHANGE_SECURITY;
1988 if( Reason == AFS_INVALIDATE_DATA_VERSION)
1990 ulFilter |= FILE_NOTIFY_CHANGE_SIZE | FILE_NOTIFY_CHANGE_LAST_WRITE;
1994 ulFilter |= FILE_NOTIFY_CHANGE_ATTRIBUTES;
1997 if( (*ppObjectInfo)->FileType == AFS_FILE_TYPE_DIRECTORY)
2000 AFSFsRtlNotifyFullReportChange( (*ppObjectInfo),
2003 FILE_ACTION_MODIFIED);
2005 else if ( pParentObjectInfo != NULL)
2008 AFSFsRtlNotifyFullReportChange( pParentObjectInfo,
2011 FILE_ACTION_MODIFIED);
2015 // Indicate this node requires re-evaluation for the remaining reasons
2018 (*ppObjectInfo)->Expiration.QuadPart = 0;
2020 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2021 AFS_TRACE_LEVEL_VERBOSE,
2022 "AFSInvalidateObject Setting VERIFY flag on fid %08lX-%08lX-%08lX-%08lX\n",
2023 (*ppObjectInfo)->FileId.Cell,
2024 (*ppObjectInfo)->FileId.Volume,
2025 (*ppObjectInfo)->FileId.Vnode,
2026 (*ppObjectInfo)->FileId.Unique));
2028 SetFlag( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_VERIFY);
2030 if( Reason == AFS_INVALIDATE_DATA_VERSION ||
2031 (*ppObjectInfo)->FileType == AFS_FILE_TYPE_FILE &&
2032 ( Reason == AFS_INVALIDATE_CALLBACK ||
2033 Reason == AFS_INVALIDATE_EXPIRED))
2035 if ( NT_SUCCESS( AFSQueueInvalidateObject( (*ppObjectInfo),
2036 AFS_INVALIDATE_DATA_VERSION)))
2039 (*ppObjectInfo) = NULL; // We'll dec the count in the worker item
2049 if ( pParentObjectInfo != NULL)
2052 AFSReleaseObjectInfo( &pParentObjectInfo);
2059 AFSInvalidateCache( IN AFSInvalidateCacheCB *InvalidateCB)
2062 NTSTATUS ntStatus = STATUS_SUCCESS;
2063 AFSVolumeCB *pVolumeCB = NULL;
2064 AFSDeviceExt *pDevExt = (AFSDeviceExt *) AFSRDRDeviceObject->DeviceExtension;
2065 ULONGLONG ullIndex = 0;
2066 AFSObjectInfoCB *pObjectInfo = NULL;
2072 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2073 AFS_TRACE_LEVEL_VERBOSE,
2074 "AFSInvalidateCache Invalidation FID %08lX-%08lX-%08lX-%08lX Type %d WholeVolume %d Reason %d\n",
2075 InvalidateCB->FileID.Cell,
2076 InvalidateCB->FileID.Volume,
2077 InvalidateCB->FileID.Vnode,
2078 InvalidateCB->FileID.Unique,
2079 InvalidateCB->FileType,
2080 InvalidateCB->WholeVolume,
2081 InvalidateCB->Reason));
2084 // Need to locate the Fcb for the directory to purge
2087 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
2088 AFS_TRACE_LEVEL_VERBOSE,
2089 "AFSInvalidateCache Acquiring RDR VolumeTreeLock lock %p SHARED %08lX\n",
2090 &pDevExt->Specific.RDR.VolumeTreeLock,
2091 PsGetCurrentThread()));
2094 // Starve any exclusive waiters on this paticular call
2097 AFSAcquireSharedStarveExclusive( &pDevExt->Specific.RDR.VolumeTreeLock, TRUE);
2100 // Locate the volume node
2103 ullIndex = AFSCreateHighIndex( &InvalidateCB->FileID);
2105 ntStatus = AFSLocateHashEntry( pDevExt->Specific.RDR.VolumeTree.TreeHead,
2107 (AFSBTreeEntry **)&pVolumeCB);
2109 if( pVolumeCB != NULL)
2112 lCount = AFSVolumeIncrement( pVolumeCB,
2113 AFS_VOLUME_REFERENCE_INVALIDATE);
2115 AFSDbgTrace(( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
2116 AFS_TRACE_LEVEL_VERBOSE,
2117 "AFSInvalidateCache Increment count on volume %p Cnt %d\n",
2122 AFSReleaseResource( &pDevExt->Specific.RDR.VolumeTreeLock);
2124 if( !NT_SUCCESS( ntStatus) ||
2128 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2129 AFS_TRACE_LEVEL_WARNING,
2130 "AFSInvalidateCache Invalidation FAILURE Unable to locate volume node FID %08lX-%08lX-%08lX-%08lX Status %08lX\n",
2131 InvalidateCB->FileID.Cell,
2132 InvalidateCB->FileID.Volume,
2133 InvalidateCB->FileID.Vnode,
2134 InvalidateCB->FileID.Unique,
2137 try_return( ntStatus = STATUS_SUCCESS);
2141 // If this is a whole volume invalidation then go do it now
2144 if( InvalidateCB->WholeVolume)
2147 ntStatus = AFSInvalidateVolume( pVolumeCB,
2148 InvalidateCB->Reason);
2150 try_return( ntStatus);
2153 AFSAcquireShared( pVolumeCB->ObjectInfoTree.TreeLock,
2156 if ( AFSIsVolumeFID( &InvalidateCB->FileID))
2159 pObjectInfo = &pVolumeCB->ObjectInformation;
2164 ullIndex = AFSCreateLowIndex( &InvalidateCB->FileID);
2166 ntStatus = AFSLocateHashEntry( pVolumeCB->ObjectInfoTree.TreeHead,
2168 (AFSBTreeEntry **)&pObjectInfo);
2171 if( pObjectInfo != NULL)
2175 // Reference the node so it won't be torn down
2178 lCount = AFSObjectInfoIncrement( pObjectInfo,
2179 AFS_OBJECT_REFERENCE_INVALIDATION);
2181 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2182 AFS_TRACE_LEVEL_VERBOSE,
2183 "AFSInvalidateCache Increment count on object %p Cnt %d\n",
2188 AFSReleaseResource( pVolumeCB->ObjectInfoTree.TreeLock);
2190 if( !NT_SUCCESS( ntStatus) ||
2191 pObjectInfo == NULL)
2194 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2195 AFS_TRACE_LEVEL_VERBOSE,
2196 "AFSInvalidateCache Invalidation FAILURE Unable to locate object FID %08lX-%08lX-%08lX-%08lX Status %08lX\n",
2197 InvalidateCB->FileID.Cell,
2198 InvalidateCB->FileID.Volume,
2199 InvalidateCB->FileID.Vnode,
2200 InvalidateCB->FileID.Unique,
2203 try_return( ntStatus = STATUS_SUCCESS);
2206 AFSInvalidateObject( &pObjectInfo,
2207 InvalidateCB->Reason);
2211 if( pObjectInfo != NULL)
2214 lCount = AFSObjectInfoDecrement( pObjectInfo,
2215 AFS_OBJECT_REFERENCE_INVALIDATION);
2217 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2218 AFS_TRACE_LEVEL_VERBOSE,
2219 "AFSInvalidateCache Decrement count on object %p Cnt %d\n",
2224 if ( pVolumeCB != NULL)
2227 lCount = AFSVolumeDecrement( pVolumeCB,
2228 AFS_VOLUME_REFERENCE_INVALIDATE);
2230 AFSDbgTrace(( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
2231 AFS_TRACE_LEVEL_VERBOSE,
2232 "AFSInvalidateCache Decrement count on volume %p Cnt %d\n",
2242 AFSIsChildOfParent( IN AFSFcb *Dcb,
2246 BOOLEAN bIsChild = FALSE;
2247 AFSFcb *pCurrentFcb = Fcb;
2248 AFSObjectInfoCB * pParentObjectInfo = NULL;
2250 while( pCurrentFcb != NULL)
2253 if( BooleanFlagOn( pCurrentFcb->ObjectInformation->Flags, AFS_OBJECT_FLAGS_PARENT_FID) &&
2254 AFSIsEqualFID( &pCurrentFcb->ObjectInformation->ParentFileId, &Dcb->ObjectInformation->FileId))
2262 pParentObjectInfo = AFSFindObjectInfo( pCurrentFcb->ObjectInformation->VolumeCB,
2263 &pCurrentFcb->ObjectInformation->ParentFileId);
2265 if ( pParentObjectInfo != NULL)
2268 pCurrentFcb = pParentObjectInfo->Fcb;
2270 AFSReleaseObjectInfo( &pParentObjectInfo);
2284 AFSCreateHighIndex( IN AFSFileID *FileID)
2287 ULONGLONG ullIndex = 0;
2289 ullIndex = (((ULONGLONG)FileID->Cell << 32) | FileID->Volume);
2296 AFSCreateLowIndex( IN AFSFileID *FileID)
2299 ULONGLONG ullIndex = 0;
2301 ullIndex = (((ULONGLONG)FileID->Vnode << 32) | FileID->Unique);
2307 AFSCheckAccess( IN ACCESS_MASK DesiredAccess,
2308 IN ACCESS_MASK GrantedAccess,
2309 IN BOOLEAN DirectoryEntry)
2312 BOOLEAN bAccessGranted = TRUE;
2315 // Check if we are asking for read/write and granted only read only
2316 // NOTE: There will be more checks here
2319 if( !AFSCheckForReadOnlyAccess( DesiredAccess,
2321 AFSCheckForReadOnlyAccess( GrantedAccess,
2325 bAccessGranted = FALSE;
2328 return bAccessGranted;
2332 AFSGetDriverStatus( IN AFSDriverStatusRespCB *DriverStatus)
2335 NTSTATUS ntStatus = STATUS_SUCCESS;
2336 AFSDeviceExt *pControlDevExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
2342 DriverStatus->Status = AFS_DRIVER_STATUS_READY;
2344 if( AFSGlobalRoot == NULL)
2351 DriverStatus->Status = AFS_DRIVER_STATUS_NOT_READY;
2354 if( pControlDevExt->Specific.Control.CommServiceCB.IrpPoolControlFlag != POOL_ACTIVE)
2361 DriverStatus->Status = AFS_DRIVER_STATUS_NO_SERVICE;
2368 AFSSubstituteSysName( IN UNICODE_STRING *ComponentName,
2369 IN UNICODE_STRING *SubstituteName,
2370 IN ULONG StringIndex)
2373 NTSTATUS ntStatus = STATUS_SUCCESS;
2374 AFSDeviceExt *pControlDevExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
2375 AFSSysNameCB *pSysName = NULL;
2376 ERESOURCE *pSysNameLock = NULL;
2379 UNICODE_STRING uniSysName;
2386 if( IoIs32bitProcess( NULL))
2389 pSysNameLock = &pControlDevExt->Specific.Control.SysName32ListLock;
2391 pSysName = pControlDevExt->Specific.Control.SysName32ListHead;
2396 pSysNameLock = &pControlDevExt->Specific.Control.SysName64ListLock;
2398 pSysName = pControlDevExt->Specific.Control.SysName64ListHead;
2402 pSysNameLock = &pControlDevExt->Specific.Control.SysName32ListLock;
2404 pSysName = pControlDevExt->Specific.Control.SysName32ListHead;
2408 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
2409 AFS_TRACE_LEVEL_VERBOSE,
2410 "AFSSubstituteSysName Acquiring SysName lock %p SHARED %08lX\n",
2412 PsGetCurrentThread()));
2414 AFSAcquireShared( pSysNameLock,
2418 // Find where we are in the list
2421 while( pSysName != NULL &&
2422 ulIndex < StringIndex)
2425 pSysName = pSysName->fLink;
2430 if( pSysName == NULL)
2433 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2434 AFS_TRACE_LEVEL_VERBOSE_2,
2435 "AFSSubstituteSysName No sysname %wZ Status %08lX\n",
2437 STATUS_OBJECT_NAME_NOT_FOUND));
2439 try_return( ntStatus = STATUS_OBJECT_NAME_NOT_FOUND);
2442 RtlInitUnicodeString( &uniSysName,
2445 // If it is a full component of @SYS then just substitue the
2449 if( RtlCompareUnicodeString( &uniSysName,
2454 SubstituteName->Length = pSysName->SysName.Length;
2455 SubstituteName->MaximumLength = SubstituteName->Length;
2457 SubstituteName->Buffer = (WCHAR *)AFSExAllocatePoolWithTag( PagedPool,
2458 SubstituteName->Length,
2459 AFS_SUBST_BUFFER_TAG);
2461 if( SubstituteName->Buffer == NULL)
2464 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
2467 RtlCopyMemory( SubstituteName->Buffer,
2468 pSysName->SysName.Buffer,
2469 pSysName->SysName.Length);
2476 while( ComponentName->Buffer[ usIndex] != L'@')
2482 SubstituteName->Length = (usIndex * sizeof( WCHAR)) + pSysName->SysName.Length;
2483 SubstituteName->MaximumLength = SubstituteName->Length;
2485 SubstituteName->Buffer = (WCHAR *)AFSExAllocatePoolWithTag( PagedPool,
2486 SubstituteName->Length,
2487 AFS_SUBST_BUFFER_TAG);
2489 if( SubstituteName->Buffer == NULL)
2492 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
2495 RtlCopyMemory( SubstituteName->Buffer,
2496 ComponentName->Buffer,
2497 usIndex * sizeof( WCHAR));
2499 RtlCopyMemory( &SubstituteName->Buffer[ usIndex],
2500 pSysName->SysName.Buffer,
2501 pSysName->SysName.Length);
2506 AFSReleaseResource( pSysNameLock);
2513 AFSSubstituteNameInPath( IN OUT UNICODE_STRING *FullPathName,
2514 IN OUT UNICODE_STRING *ComponentName,
2515 IN UNICODE_STRING *SubstituteName,
2516 IN OUT UNICODE_STRING *RemainingPath,
2517 IN BOOLEAN FreePathName)
2520 NTSTATUS ntStatus = STATUS_SUCCESS;
2521 UNICODE_STRING uniPathName;
2522 USHORT usPrefixNameLen = 0;
2523 SHORT sNameLenDelta = 0;
2529 // If the passed in name can handle the additional length
2530 // then just moves things around
2533 sNameLenDelta = SubstituteName->Length - ComponentName->Length;
2535 usPrefixNameLen = (USHORT)(ComponentName->Buffer - FullPathName->Buffer);
2537 if( FullPathName->MaximumLength > FullPathName->Length + sNameLenDelta)
2540 if( FullPathName->Length > usPrefixNameLen + ComponentName->Length)
2543 RtlMoveMemory( &FullPathName->Buffer[ ((usPrefixNameLen*sizeof( WCHAR) + SubstituteName->Length)/sizeof( WCHAR))],
2544 &FullPathName->Buffer[ ((usPrefixNameLen*sizeof( WCHAR) + ComponentName->Length)/sizeof( WCHAR))],
2545 FullPathName->Length - usPrefixNameLen*sizeof( WCHAR) - ComponentName->Length);
2548 RtlCopyMemory( &FullPathName->Buffer[ usPrefixNameLen],
2549 SubstituteName->Buffer,
2550 SubstituteName->Length);
2552 FullPathName->Length += sNameLenDelta;
2554 ComponentName->Length += sNameLenDelta;
2556 ComponentName->MaximumLength = ComponentName->Length;
2558 if ( RemainingPath->Buffer)
2561 RemainingPath->Buffer += sNameLenDelta/sizeof( WCHAR);
2564 try_return( ntStatus);
2568 // Need to re-allocate the buffer
2571 uniPathName.Length = FullPathName->Length -
2572 ComponentName->Length +
2573 SubstituteName->Length;
2575 uniPathName.MaximumLength = FullPathName->MaximumLength + PAGE_SIZE;
2577 uniPathName.Buffer = (WCHAR *)AFSExAllocatePoolWithTag( PagedPool,
2578 uniPathName.MaximumLength,
2579 AFS_NAME_BUFFER_FOUR_TAG);
2581 if( uniPathName.Buffer == NULL)
2584 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
2587 usPrefixNameLen = (USHORT)(ComponentName->Buffer - FullPathName->Buffer);
2589 usPrefixNameLen *= sizeof( WCHAR);
2591 RtlZeroMemory( uniPathName.Buffer,
2592 uniPathName.MaximumLength);
2594 RtlCopyMemory( uniPathName.Buffer,
2595 FullPathName->Buffer,
2598 RtlCopyMemory( &uniPathName.Buffer[ (usPrefixNameLen/sizeof( WCHAR))],
2599 SubstituteName->Buffer,
2600 SubstituteName->Length);
2602 if( FullPathName->Length > usPrefixNameLen + ComponentName->Length)
2605 RtlCopyMemory( &uniPathName.Buffer[ (usPrefixNameLen + SubstituteName->Length)/sizeof( WCHAR)],
2606 &FullPathName->Buffer[ (usPrefixNameLen + ComponentName->Length)/sizeof( WCHAR)],
2607 FullPathName->Length - usPrefixNameLen - ComponentName->Length);
2610 ComponentName->Buffer = uniPathName.Buffer + (ComponentName->Buffer - FullPathName->Buffer);
2612 ComponentName->Length += sNameLenDelta;
2614 ComponentName->MaximumLength = ComponentName->Length;
2616 if ( RemainingPath->Buffer)
2619 RemainingPath->Buffer = uniPathName.Buffer
2620 + (RemainingPath->Buffer - FullPathName->Buffer)
2621 + sNameLenDelta/sizeof( WCHAR);
2626 AFSExFreePoolWithTag( FullPathName->Buffer, 0);
2629 *FullPathName = uniPathName;
2640 AFSInvalidateVolume( IN AFSVolumeCB *VolumeCB,
2644 NTSTATUS ntStatus = STATUS_SUCCESS;
2645 AFSObjectInfoCB *pCurrentObject = NULL;
2646 AFSObjectInfoCB *pNextObject = NULL;
2652 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2653 AFS_TRACE_LEVEL_VERBOSE,
2654 "AFSInvalidateVolume Invalidate volume fid %08lX-%08lX-%08lX-%08lX Reason %08lX\n",
2655 VolumeCB->ObjectInformation.FileId.Cell,
2656 VolumeCB->ObjectInformation.FileId.Volume,
2657 VolumeCB->ObjectInformation.FileId.Vnode,
2658 VolumeCB->ObjectInformation.FileId.Unique,
2662 // Depending on the reason for invalidation then perform work on the node
2668 case AFS_INVALIDATE_DELETED:
2672 // Mark this volume as invalid
2675 SetFlag( VolumeCB->ObjectInformation.Flags, AFS_OBJECT_FLAGS_OBJECT_INVALID);
2677 SetFlag( VolumeCB->Flags, AFS_VOLUME_FLAGS_OFFLINE);
2684 // Invalidate the volume root directory
2687 pCurrentObject = &VolumeCB->ObjectInformation;
2689 if ( pCurrentObject )
2692 lCount = AFSObjectInfoIncrement( pCurrentObject,
2693 AFS_OBJECT_REFERENCE_INVALIDATION);
2695 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2696 AFS_TRACE_LEVEL_VERBOSE,
2697 "AFSInvalidateVolumeObjects Increment count on object %p Cnt %d\n",
2701 AFSInvalidateObject( &pCurrentObject,
2704 if ( pCurrentObject)
2707 lCount = AFSObjectInfoDecrement( pCurrentObject,
2708 AFS_OBJECT_REFERENCE_INVALIDATION);
2710 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2711 AFS_TRACE_LEVEL_VERBOSE,
2712 "AFSInvalidateVolumeObjects Decrement count on object %p Cnt %d\n",
2719 // Apply invalidation to all other volume objects
2722 AFSAcquireShared( VolumeCB->ObjectInfoTree.TreeLock,
2725 pCurrentObject = VolumeCB->ObjectInfoListHead;
2727 if ( pCurrentObject)
2731 // Reference the node so it won't be torn down
2734 lCount = AFSObjectInfoIncrement( pCurrentObject,
2735 AFS_OBJECT_REFERENCE_INVALIDATION);
2737 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2738 AFS_TRACE_LEVEL_VERBOSE,
2739 "AFSInvalidateVolumeObjects Increment count on object %p Cnt %d\n",
2744 while( pCurrentObject != NULL)
2747 pNextObject = (AFSObjectInfoCB *)pCurrentObject->ListEntry.fLink;
2753 // Reference the node so it won't be torn down
2756 lCount = AFSObjectInfoIncrement( pNextObject,
2757 AFS_OBJECT_REFERENCE_INVALIDATION);
2759 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2760 AFS_TRACE_LEVEL_VERBOSE,
2761 "AFSInvalidateVolumeObjects Increment count on object %p Cnt %d\n",
2766 AFSReleaseResource( VolumeCB->ObjectInfoTree.TreeLock);
2768 AFSInvalidateObject( &pCurrentObject,
2771 if ( pCurrentObject )
2774 lCount = AFSObjectInfoDecrement( pCurrentObject,
2775 AFS_OBJECT_REFERENCE_INVALIDATION);
2777 AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2778 AFS_TRACE_LEVEL_VERBOSE,
2779 "AFSInvalidateVolumeObjects Decrement count on object %p Cnt %d\n",
2784 AFSAcquireShared( VolumeCB->ObjectInfoTree.TreeLock,
2787 pCurrentObject = pNextObject;
2790 AFSReleaseResource( VolumeCB->ObjectInfoTree.TreeLock);
2797 AFSInvalidateAllVolumes( VOID)
2799 AFSVolumeCB *pVolumeCB = NULL;
2800 AFSVolumeCB *pNextVolumeCB = NULL;
2801 AFSDeviceExt *pRDRDeviceExt = NULL;
2804 pRDRDeviceExt = (AFSDeviceExt *)AFSRDRDeviceObject->DeviceExtension;
2806 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
2807 AFS_TRACE_LEVEL_VERBOSE,
2808 "AFSInvalidateAllVolumes Acquiring RDR VolumeListLock lock %p SHARED %08lX\n",
2809 &pRDRDeviceExt->Specific.RDR.VolumeListLock,
2810 PsGetCurrentThread()));
2812 AFSAcquireShared( &pRDRDeviceExt->Specific.RDR.VolumeListLock,
2815 pVolumeCB = pRDRDeviceExt->Specific.RDR.VolumeListHead;
2820 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
2821 AFS_TRACE_LEVEL_VERBOSE,
2822 "AFSInvalidateAllVolumes Acquiring VolumeRoot ObjectInfoTree lock %p SHARED %08lX\n",
2823 pVolumeCB->ObjectInfoTree.TreeLock,
2824 PsGetCurrentThread()));
2826 lCount = AFSVolumeIncrement( pVolumeCB,
2827 AFS_VOLUME_REFERENCE_INVALIDATE);
2829 AFSDbgTrace(( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
2830 AFS_TRACE_LEVEL_VERBOSE,
2831 "AFSInvalidateAllVolumes Increment count on volume %p Cnt %d\n",
2836 while( pVolumeCB != NULL)
2839 pNextVolumeCB = (AFSVolumeCB *)pVolumeCB->ListEntry.fLink;
2844 lCount = AFSVolumeIncrement( pNextVolumeCB,
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 AFSReleaseResource( &pRDRDeviceExt->Specific.RDR.VolumeListLock);
2856 // do I need to hold the volume lock here?
2858 AFSInvalidateVolume( pVolumeCB, AFS_INVALIDATE_EXPIRED);
2860 AFSAcquireShared( &pRDRDeviceExt->Specific.RDR.VolumeListLock,
2863 lCount = AFSVolumeDecrement( pVolumeCB,
2864 AFS_VOLUME_REFERENCE_INVALIDATE);
2866 AFSDbgTrace(( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
2867 AFS_TRACE_LEVEL_VERBOSE,
2868 "AFSInvalidateAllVolumes Decrement count on volume %p Cnt %d\n",
2872 pVolumeCB = pNextVolumeCB;
2875 AFSReleaseResource( &pRDRDeviceExt->Specific.RDR.VolumeListLock);
2879 AFSVerifyEntry( IN GUID *AuthGroup,
2880 IN AFSDirectoryCB *DirEntry)
2883 NTSTATUS ntStatus = STATUS_SUCCESS;
2884 AFSDirEnumEntry *pDirEnumEntry = NULL;
2885 AFSObjectInfoCB *pObjectInfo = DirEntry->ObjectInformation;
2886 IO_STATUS_BLOCK stIoStatus;
2891 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2892 AFS_TRACE_LEVEL_VERBOSE_2,
2893 "AFSVerifyEntry Verifying entry %wZ FID %08lX-%08lX-%08lX-%08lX\n",
2894 &DirEntry->NameInformation.FileName,
2895 pObjectInfo->FileId.Cell,
2896 pObjectInfo->FileId.Volume,
2897 pObjectInfo->FileId.Vnode,
2898 pObjectInfo->FileId.Unique));
2900 ntStatus = AFSEvaluateTargetByID( pObjectInfo,
2905 if( !NT_SUCCESS( ntStatus))
2908 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2909 AFS_TRACE_LEVEL_ERROR,
2910 "AFSVerifyEntry Evaluate Target failed %wZ FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX\n",
2911 &DirEntry->NameInformation.FileName,
2912 pObjectInfo->FileId.Cell,
2913 pObjectInfo->FileId.Volume,
2914 pObjectInfo->FileId.Vnode,
2915 pObjectInfo->FileId.Unique,
2918 try_return( ntStatus);
2922 // Check the data version of the file
2925 if( pObjectInfo->DataVersion.QuadPart == pDirEnumEntry->DataVersion.QuadPart)
2927 if ( !BooleanFlagOn( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY_DATA))
2930 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
2931 AFS_TRACE_LEVEL_VERBOSE,
2932 "AFSVerifyEntry No DV change %I64X for Fcb %wZ FID %08lX-%08lX-%08lX-%08lX\n",
2933 pObjectInfo->DataVersion.QuadPart,
2934 &DirEntry->NameInformation.FileName,
2935 pObjectInfo->FileId.Cell,
2936 pObjectInfo->FileId.Volume,
2937 pObjectInfo->FileId.Vnode,
2938 pObjectInfo->FileId.Unique));
2941 // We are ok, just get out
2944 ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
2946 try_return( ntStatus = STATUS_SUCCESS);
2951 // New data version so we will need to process the node based on the type
2954 switch( pDirEnumEntry->FileType)
2957 case AFS_FILE_TYPE_MOUNTPOINT:
2961 // For a mount point we need to ensure the target is the same
2964 if( !AFSIsEqualFID( &pObjectInfo->TargetFileId,
2965 &pDirEnumEntry->TargetFileId))
2971 // Update the metadata for the entry
2974 ntStatus = AFSUpdateMetaData( DirEntry,
2977 if( NT_SUCCESS( ntStatus))
2980 ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
2986 case AFS_FILE_TYPE_SYMLINK:
2990 // Update the metadata for the entry
2993 ntStatus = AFSUpdateMetaData( DirEntry,
2996 if( NT_SUCCESS( ntStatus))
2999 ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
3005 case AFS_FILE_TYPE_FILE:
3007 FILE_OBJECT * pCCFileObject = NULL;
3008 BOOLEAN bPurgeExtents = FALSE;
3010 if ( pObjectInfo->DataVersion.QuadPart != pDirEnumEntry->DataVersion.QuadPart)
3013 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
3014 AFS_TRACE_LEVEL_VERBOSE,
3015 "AFSVerifyEntry DV Change %wZ FID %08lX-%08lX-%08lX-%08lX (%08lX != %08lX)\n",
3016 &DirEntry->NameInformation.FileName,
3017 pObjectInfo->FileId.Cell,
3018 pObjectInfo->FileId.Volume,
3019 pObjectInfo->FileId.Vnode,
3020 pObjectInfo->FileId.Unique,
3021 pObjectInfo->DataVersion.LowPart,
3022 pDirEnumEntry->DataVersion.LowPart));
3024 bPurgeExtents = TRUE;
3027 if ( BooleanFlagOn( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY_DATA))
3030 bPurgeExtents = TRUE;
3032 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
3033 AFS_TRACE_LEVEL_VERBOSE,
3034 "AFSVerifyEntry Clearing VERIFY_DATA flag %wZ FID %08lX-%08lX-%08lX-%08lX\n",
3035 &DirEntry->NameInformation.FileName,
3036 pObjectInfo->FileId.Cell,
3037 pObjectInfo->FileId.Volume,
3038 pObjectInfo->FileId.Vnode,
3039 pObjectInfo->FileId.Unique));
3041 ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY_DATA);
3044 if( pObjectInfo->Fcb != NULL)
3047 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
3048 AFS_TRACE_LEVEL_VERBOSE,
3049 "AFSVerifyEntry Flush/purge entry %wZ FID %08lX-%08lX-%08lX-%08lX\n",
3050 &DirEntry->NameInformation.FileName,
3051 pObjectInfo->FileId.Cell,
3052 pObjectInfo->FileId.Volume,
3053 pObjectInfo->FileId.Vnode,
3054 pObjectInfo->FileId.Unique));
3056 AFSAcquireExcl( &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
3062 CcFlushCache( &pObjectInfo->Fcb->NPFcb->SectionObjectPointers,
3067 if( !NT_SUCCESS( stIoStatus.Status))
3070 AFSDbgTrace(( AFS_SUBSYSTEM_IO_PROCESSING,
3071 AFS_TRACE_LEVEL_ERROR,
3072 "AFSVerifyEntry CcFlushCache failure %wZ FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX Bytes 0x%08lX\n",
3073 &DirEntry->NameInformation.FileName,
3074 pObjectInfo->FileId.Cell,
3075 pObjectInfo->FileId.Volume,
3076 pObjectInfo->FileId.Vnode,
3077 pObjectInfo->FileId.Unique,
3079 stIoStatus.Information));
3081 ntStatus = stIoStatus.Status;
3084 if ( bPurgeExtents &&
3085 pObjectInfo->Fcb->NPFcb->SectionObjectPointers.DataSectionObject != NULL)
3088 if ( !CcPurgeCacheSection( &pObjectInfo->Fcb->NPFcb->SectionObjectPointers,
3094 AFSDbgTrace(( AFS_SUBSYSTEM_IO_PROCESSING,
3095 AFS_TRACE_LEVEL_WARNING,
3096 "AFSVerifyEntry CcPurgeCacheSection failure %wZ FID %08lX-%08lX-%08lX-%08lX\n",
3097 &DirEntry->NameInformation.FileName,
3098 pObjectInfo->FileId.Cell,
3099 pObjectInfo->FileId.Volume,
3100 pObjectInfo->FileId.Vnode,
3101 pObjectInfo->FileId.Unique));
3103 SetFlag( pObjectInfo->Fcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
3107 __except( EXCEPTION_EXECUTE_HANDLER)
3109 ntStatus = GetExceptionCode();
3113 "EXCEPTION - AFSVerifyEntry CcFlushCache or CcPurgeCacheSection %wZ FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX\n",
3114 &DirEntry->NameInformation.FileName,
3115 pObjectInfo->FileId.Cell,
3116 pObjectInfo->FileId.Volume,
3117 pObjectInfo->FileId.Vnode,
3118 pObjectInfo->FileId.Unique,
3121 SetFlag( pObjectInfo->Fcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
3124 AFSReleaseResource( &pObjectInfo->Fcb->NPFcb->SectionObjectResource);
3128 AFSFlushExtents( pObjectInfo->Fcb,
3133 // Reacquire the Fcb to purge the cache
3136 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
3137 AFS_TRACE_LEVEL_VERBOSE,
3138 "AFSVerifyEntry Acquiring Fcb lock %p EXCL %08lX\n",
3139 &pObjectInfo->Fcb->NPFcb->Resource,
3140 PsGetCurrentThread()));
3142 AFSAcquireExcl( &pObjectInfo->Fcb->NPFcb->Resource,
3146 // Update the metadata for the entry
3149 ntStatus = AFSUpdateMetaData( DirEntry,
3152 if( !NT_SUCCESS( ntStatus))
3155 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
3156 AFS_TRACE_LEVEL_ERROR,
3157 "AFSVerifyEntry Meta Data Update failed %wZ FID %08lX-%08lX-%08lX-%08lX ntStatus %08lX\n",
3158 &DirEntry->NameInformation.FileName,
3159 pObjectInfo->FileId.Cell,
3160 pObjectInfo->FileId.Volume,
3161 pObjectInfo->FileId.Vnode,
3162 pObjectInfo->FileId.Unique,
3169 // Update file sizes
3172 pObjectInfo->Fcb->Header.AllocationSize.QuadPart = pObjectInfo->AllocationSize.QuadPart;
3173 pObjectInfo->Fcb->Header.FileSize.QuadPart = pObjectInfo->EndOfFile.QuadPart;
3174 pObjectInfo->Fcb->Header.ValidDataLength.QuadPart = pObjectInfo->EndOfFile.QuadPart;
3176 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
3177 AFS_TRACE_LEVEL_VERBOSE,
3178 "AFSVerifyEntry Acquiring Fcb SectionObject lock %p EXCL %08lX\n",
3179 &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
3180 PsGetCurrentThread()));
3182 AFSAcquireExcl( &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
3185 pCCFileObject = CcGetFileObjectFromSectionPtrs( &pObjectInfo->Fcb->NPFcb->SectionObjectPointers);
3187 if ( pCCFileObject != NULL)
3189 CcSetFileSizes( pCCFileObject,
3190 (PCC_FILE_SIZES)&pObjectInfo->Fcb->Header.AllocationSize);
3193 AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
3194 AFS_TRACE_LEVEL_VERBOSE,
3195 "AFSVerifyEntry Releasing Fcb SectionObject lock %p EXCL %08lX\n",
3196 &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
3197 PsGetCurrentThread()));
3199 AFSReleaseResource( &pObjectInfo->Fcb->NPFcb->SectionObjectResource);
3201 AFSReleaseResource( &pObjectInfo->Fcb->NPFcb->Resource);
3207 // Update the metadata for the entry
3210 ntStatus = AFSUpdateMetaData( DirEntry,
3213 if( !NT_SUCCESS( ntStatus))
3216 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
3217 AFS_TRACE_LEVEL_ERROR,
3218 "AFSVerifyEntry Meta Data Update failed %wZ FID %08lX-%08lX-%08lX-%08lX ntStatus %08lX\n",
3219 &DirEntry->NameInformation.FileName,
3220 pObjectInfo->FileId.Cell,
3221 pObjectInfo->FileId.Volume,
3222 pObjectInfo->FileId.Vnode,
3223 pObjectInfo->FileId.Unique,
3229 AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
3230 AFS_TRACE_LEVEL_WARNING,
3231 "AFSVerifyEntry Fcb NULL %wZ FID %08lX-%08lX-%08lX-%08lX\n",
3232 &DirEntry->NameInformation.FileName,
3233 pObjectInfo->FileId.Cell,
3234 pObjectInfo->FileId.Volume,
3235 pObjectInfo->FileId.Vnode,