2 * Copyright (c) 2008, 2009, 2010, 2011 Kernel Drivers, LLC.
3 * Copyright (c) 2009, 2010, 2011 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
14 * this list of conditions and the following disclaimer in the
16 * and/or other materials provided with the distribution.
17 * - Neither the names of Kernel Drivers, LLC and Your File System, Inc.
18 * nor the names of their contributors may be used to endorse or promote
19 * products derived from this software without specific prior written
20 * permission from Kernel Drivers, LLC and Your File System, Inc.
22 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
23 * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED
24 * TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A
25 * PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER
26 * OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
27 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
28 * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR
29 * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
30 * LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
31 * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS
32 * SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
36 // File: AFSGeneric.cpp
39 #include "AFSCommon.h"
42 // Function: AFSExceptionFilter
46 // This function is the exception handler
50 // A status is returned for the function
54 AFSExceptionFilter( IN CHAR *FunctionString,
56 IN PEXCEPTION_POINTERS ExceptPtrs)
59 UNREFERENCED_PARAMETER(Code);
60 PEXCEPTION_RECORD ExceptRec;
66 ExceptRec = ExceptPtrs->ExceptionRecord;
68 Context = ExceptPtrs->ContextRecord;
72 "AFSExceptionFilter (Library) - EXR %p CXR %p Function %s Code %08lX Address %p Routine %p\n",
76 ExceptRec->ExceptionCode,
77 ExceptRec->ExceptionAddress,
78 (void *)AFSExceptionFilter);
80 DbgPrint("**** Exception Caught in AFS Redirector Library ****\n");
82 DbgPrint("\n\nPerform the following WnDbg Cmds:\n");
83 DbgPrint("\n\t.exr %p ; .cxr %p\n\n", ExceptRec, Context);
85 DbgPrint("**** Exception Complete from AFS Redirector Library ****\n");
87 if( BooleanFlagOn( AFSDebugFlags, AFS_DBG_BUGCHECK_EXCEPTION))
90 KeBugCheck( (ULONG)-2);
98 __except( EXCEPTION_EXECUTE_HANDLER)
104 return EXCEPTION_EXECUTE_HANDLER;
108 // Function: AFSLibExAllocatePoolWithTag()
110 // Purpose: Allocate Pool Memory. If BugCheck Exception flag
111 // is configured on, then bugcheck the system if
112 // a memory allocation fails. The routine should be
113 // used for all memory allocations that are to be freed
114 // when the library is unloaded. Memory allocations that
115 // are to survive library unload and reload should be
116 // performed using AFSExAllocatePoolWithTag() which is
117 // provided by the AFS Framework.
120 // POOL_TYPE PoolType - Paged or NonPaged
121 // SIZE_T NumberOfBytes - requested allocation size
122 // ULONG Tag - Pool Allocation Tag to be applied for tracking
125 // void * - the memory allocation
129 AFSLibExAllocatePoolWithTag( IN POOL_TYPE PoolType,
130 IN SIZE_T NumberOfBytes,
134 void *pBuffer = NULL;
136 pBuffer = ExAllocatePoolWithTag( PoolType,
143 if( BooleanFlagOn( AFSDebugFlags, AFS_DBG_BUGCHECK_EXCEPTION))
146 KeBugCheck( (ULONG)-2);
153 "AFSLibExAllocatePoolWithTag failure Type %08lX Size %08lX Tag %08lX %08lX\n",
157 PsGetCurrentThread());
167 // Function: AFSAcquireExcl()
169 // Purpose: Called to acquire a resource exclusive with optional wait
172 // PERESOURCE Resource - Resource to acquire
173 // BOOLEAN Wait - Whether to block
176 // BOOLEAN - Whether the mask was acquired
180 AFSAcquireExcl( IN PERESOURCE Resource,
184 BOOLEAN bStatus = FALSE;
187 // Normal kernel APCs must be disabled before calling
188 // ExAcquireResourceExclusiveLite. Otherwise a bugcheck occurs.
191 KeEnterCriticalRegion();
193 bStatus = ExAcquireResourceExclusiveLite( Resource,
199 KeLeaveCriticalRegion();
206 AFSAcquireSharedStarveExclusive( IN PERESOURCE Resource,
210 BOOLEAN bStatus = FALSE;
212 KeEnterCriticalRegion();
214 bStatus = ExAcquireSharedStarveExclusive( Resource,
220 KeLeaveCriticalRegion();
227 // Function: AFSAcquireShared()
229 // Purpose: Called to acquire a resource shared with optional wait
232 // PERESOURCE Resource - Resource to acquire
233 // BOOLEAN Wait - Whether to block
236 // BOOLEAN - Whether the mask was acquired
240 AFSAcquireShared( IN PERESOURCE Resource,
244 BOOLEAN bStatus = FALSE;
246 KeEnterCriticalRegion();
248 bStatus = ExAcquireResourceSharedLite( Resource,
254 KeLeaveCriticalRegion();
261 // Function: AFSReleaseResource()
263 // Purpose: Called to release a resource
266 // PERESOURCE Resource - Resource to release
273 AFSReleaseResource( IN PERESOURCE Resource)
276 AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
277 AFS_TRACE_LEVEL_VERBOSE,
278 "AFSReleaseResource Releasing lock %p Thread %08lX\n",
280 PsGetCurrentThread());
282 ExReleaseResourceLite( Resource);
284 KeLeaveCriticalRegion();
290 AFSConvertToShared( IN PERESOURCE Resource)
293 AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
294 AFS_TRACE_LEVEL_VERBOSE,
295 "AFSConvertToShared Converting lock %p Thread %08lX\n",
297 PsGetCurrentThread());
299 ExConvertExclusiveToSharedLite( Resource);
305 // Function: AFSCompleteRequest
309 // This function completes irps
313 // A status is returned for the function
317 AFSCompleteRequest( IN PIRP Irp,
321 Irp->IoStatus.Status = Status;
323 IoCompleteRequest( Irp,
330 // Function: AFSGenerateCRC
334 // Given a device and filename this function generates a CRC
338 // A status is returned for the function
342 AFSGenerateCRC( IN PUNICODE_STRING FileName,
343 IN BOOLEAN UpperCaseName)
347 NTSTATUS ntStatus = STATUS_SUCCESS;
349 ntStatus = RtlHashUnicodeString( FileName,
351 HASH_STRING_ALGORITHM_DEFAULT,
354 if( !NT_SUCCESS( ntStatus))
363 AFSLockSystemBuffer( IN PIRP Irp,
367 void *pAddress = NULL;
369 if( Irp->MdlAddress != NULL)
372 pAddress = MmGetSystemAddressForMdlSafe( Irp->MdlAddress,
375 else if( Irp->AssociatedIrp.SystemBuffer != NULL)
378 pAddress = Irp->AssociatedIrp.SystemBuffer;
380 else if( Irp->UserBuffer != NULL)
383 Irp->MdlAddress = IoAllocateMdl( Irp->UserBuffer,
389 if( Irp->MdlAddress != NULL)
393 // Lock the new Mdl in memory.
398 PIO_STACK_LOCATION pIoStack;
399 pIoStack = IoGetCurrentIrpStackLocation( Irp);
402 MmProbeAndLockPages( Irp->MdlAddress, KernelMode,
403 (pIoStack->MajorFunction == IRP_MJ_READ) ? IoWriteAccess : IoReadAccess);
405 pAddress = MmGetSystemAddressForMdlSafe( Irp->MdlAddress, NormalPagePriority );
408 __except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()) )
411 AFSDumpTraceFilesFnc();
413 IoFreeMdl( Irp->MdlAddress );
414 Irp->MdlAddress = NULL;
424 AFSLockUserBuffer( IN void *UserBuffer,
425 IN ULONG BufferLength,
429 NTSTATUS ntStatus = STATUS_SUCCESS;
430 void *pAddress = NULL;
436 pMdl = IoAllocateMdl( UserBuffer,
445 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
449 // Lock the new Mdl in memory.
455 MmProbeAndLockPages( pMdl,
459 pAddress = MmGetSystemAddressForMdlSafe( pMdl,
462 __except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()) )
465 AFSDumpTraceFilesFnc();
487 AFSMapToService( IN PIRP Irp,
491 NTSTATUS ntStatus = STATUS_SUCCESS;
492 void *pMappedBuffer = NULL;
493 AFSDeviceExt *pDevExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
499 if( pDevExt->Specific.Control.ServiceProcess == NULL)
502 try_return( ntStatus = STATUS_DEVICE_NOT_READY);
505 if( Irp->MdlAddress == NULL)
508 if( AFSLockSystemBuffer( Irp,
512 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
517 // Attach to the service process for mapping
520 KeStackAttachProcess( pDevExt->Specific.Control.ServiceProcess,
521 (PRKAPC_STATE)&stApcState);
523 pMappedBuffer = MmMapLockedPagesSpecifyCache( Irp->MdlAddress,
530 KeUnstackDetachProcess( (PRKAPC_STATE)&stApcState);
537 return pMappedBuffer;
541 AFSUnmapServiceMappedBuffer( IN void *MappedBuffer,
545 NTSTATUS ntStatus = STATUS_SUCCESS;
546 AFSDeviceExt *pDevExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
552 if( pDevExt->Specific.Control.ServiceProcess == NULL)
555 try_return( ntStatus = STATUS_DEVICE_NOT_READY);
562 // Attach to the service process for mapping
565 KeStackAttachProcess( pDevExt->Specific.Control.ServiceProcess,
566 (PRKAPC_STATE)&stApcState);
568 MmUnmapLockedPages( MappedBuffer,
571 KeUnstackDetachProcess( (PRKAPC_STATE)&stApcState);
583 AFSInitializeLibraryDevice()
586 NTSTATUS ntStatus = STATUS_SUCCESS;
587 AFSDeviceExt *pDeviceExt = NULL;
592 pDeviceExt = (AFSDeviceExt *)AFSLibraryDeviceObject->DeviceExtension;
595 // The PIOCtl file name
598 RtlInitUnicodeString( &AFSPIOCtlName,
599 AFS_PIOCTL_FILE_INTERFACE_NAME);
602 // And the global root share name
605 RtlInitUnicodeString( &AFSGlobalRootName,
606 AFS_GLOBAL_ROOT_SHARE_NAME);
614 AFSRemoveLibraryDevice()
617 NTSTATUS ntStatus = STATUS_SUCCESS;
628 AFSDefaultDispatch( IN PDEVICE_OBJECT DeviceObject,
632 UNREFERENCED_PARAMETER(DeviceObject);
633 NTSTATUS ntStatus = STATUS_INVALID_DEVICE_REQUEST;
635 AFSCompleteRequest( Irp,
642 AFSInitializeGlobalDirectoryEntries()
645 NTSTATUS ntStatus = STATUS_SUCCESS;
646 AFSDirectoryCB *pDirNode = NULL;
647 ULONG ulEntryLength = 0;
648 AFSObjectInfoCB *pObjectInfoCB = NULL;
649 AFSNonPagedDirectoryCB *pNonPagedDirEntry = NULL;
656 // Initialize the global . entry
659 pObjectInfoCB = AFSAllocateObjectInfo( &AFSGlobalRoot->ObjectInformation,
662 if( pObjectInfoCB == NULL)
665 AFSDbgLogMsg( AFS_SUBSYSTEM_LOAD_LIBRARY | AFS_SUBSYSTEM_INIT_PROCESSING,
666 AFS_TRACE_LEVEL_ERROR,
667 "AFSInitializeGlobalDirectory AFSAllocateObjectInfo failure %08lX\n",
670 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
673 lCount = AFSObjectInfoIncrement( pObjectInfoCB,
674 AFS_OBJECT_REFERENCE_GLOBAL);
676 AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
677 AFS_TRACE_LEVEL_VERBOSE,
678 "AFSInitializeGlobalDirectoryEntries Increment count on object %p Cnt %d\n",
682 ntStatus = STATUS_SUCCESS;
684 ulEntryLength = sizeof( AFSDirectoryCB) +
687 pDirNode = (AFSDirectoryCB *)AFSLibExAllocatePoolWithTag( PagedPool,
691 if( pDirNode == NULL)
694 AFSDeleteObjectInfo( pObjectInfoCB);
696 AFSDbgLogMsg( AFS_SUBSYSTEM_LOAD_LIBRARY | AFS_SUBSYSTEM_INIT_PROCESSING | AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
697 AFS_TRACE_LEVEL_ERROR,
698 "AFSInitializeGlobalDirectory AFS_DIR_ENTRY_TAG allocation failure\n");
700 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
703 AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
704 AFS_TRACE_LEVEL_VERBOSE,
705 "AFSInitializeGlobalDirectory AFS_DIR_ENTRY_TAG allocated %p\n",
708 pNonPagedDirEntry = (AFSNonPagedDirectoryCB *)AFSLibExAllocatePoolWithTag( NonPagedPool,
709 sizeof( AFSNonPagedDirectoryCB),
710 AFS_DIR_ENTRY_NP_TAG);
712 if( pNonPagedDirEntry == NULL)
715 ExFreePool( pDirNode);
717 AFSDeleteObjectInfo( pObjectInfoCB);
719 AFSDbgLogMsg( AFS_SUBSYSTEM_LOAD_LIBRARY | AFS_SUBSYSTEM_INIT_PROCESSING,
720 AFS_TRACE_LEVEL_ERROR,
721 "AFSInitializeGlobalDirectory AFS_DIR_ENTRY_NP_TAG allocation failure\n");
723 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
726 RtlZeroMemory( pDirNode,
729 RtlZeroMemory( pNonPagedDirEntry,
730 sizeof( AFSNonPagedDirectoryCB));
732 ExInitializeResourceLite( &pNonPagedDirEntry->Lock);
734 pDirNode->NonPaged = pNonPagedDirEntry;
736 pDirNode->ObjectInformation = pObjectInfoCB;
742 SetFlag( pDirNode->Flags, AFS_DIR_ENTRY_NOT_IN_PARENT_TREE | AFS_DIR_ENTRY_FAKE | AFS_DIR_ENTRY_VALID);
744 pDirNode->FileIndex = (ULONG)AFS_DIR_ENTRY_DOT_INDEX;
747 // Setup the names in the entry
750 pDirNode->NameInformation.FileName.Length = sizeof( WCHAR);
752 pDirNode->NameInformation.FileName.MaximumLength = sizeof( WCHAR);
754 pDirNode->NameInformation.FileName.Buffer = (WCHAR *)((char *)pDirNode + sizeof( AFSDirectoryCB));
756 pDirNode->NameInformation.FileName.Buffer[ 0] = L'.';
759 // Populate the rest of the data
762 pObjectInfoCB->FileType = AFS_FILE_TYPE_DIRECTORY;
764 pObjectInfoCB->FileAttributes = FILE_ATTRIBUTE_DIRECTORY;
766 AFSGlobalDotDirEntry = pDirNode;
772 pObjectInfoCB = AFSAllocateObjectInfo( &AFSGlobalRoot->ObjectInformation,
775 if( pObjectInfoCB == NULL)
778 AFSDbgLogMsg( AFS_SUBSYSTEM_LOAD_LIBRARY | AFS_SUBSYSTEM_INIT_PROCESSING,
779 AFS_TRACE_LEVEL_ERROR,
780 "AFSInitializeGlobalDirectory AFSAllocateObjectInfo (2) failure %08lX\n",
783 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
786 lCount = AFSObjectInfoIncrement( pObjectInfoCB,
787 AFS_OBJECT_REFERENCE_GLOBAL);
789 AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
790 AFS_TRACE_LEVEL_VERBOSE,
791 "AFSInitializeGlobalDirectoryEntries Increment count on object %p Cnt %d\n",
795 ntStatus = STATUS_SUCCESS;
797 ulEntryLength = sizeof( AFSDirectoryCB) +
798 ( 2 * sizeof( WCHAR));
800 pDirNode = (AFSDirectoryCB *)AFSLibExAllocatePoolWithTag( PagedPool,
804 if( pDirNode == NULL)
807 AFSDbgLogMsg( AFS_SUBSYSTEM_LOAD_LIBRARY | AFS_SUBSYSTEM_INIT_PROCESSING | AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
808 AFS_TRACE_LEVEL_ERROR,
809 "AFSInitializeGlobalDirectoryEntries AFS_DIR_ENTRY_TAG allocation failure\n");
811 AFSDeleteObjectInfo( pObjectInfoCB);
813 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
816 AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
817 AFS_TRACE_LEVEL_VERBOSE,
818 "AFSInitializeGlobalDirectoryEntries AFS_DIR_ENTRY_TAG allocated %p\n",
821 pNonPagedDirEntry = (AFSNonPagedDirectoryCB *)AFSLibExAllocatePoolWithTag( NonPagedPool,
822 sizeof( AFSNonPagedDirectoryCB),
823 AFS_DIR_ENTRY_NP_TAG);
825 if( pNonPagedDirEntry == NULL)
828 ExFreePool( pDirNode);
830 AFSDeleteObjectInfo( pObjectInfoCB);
832 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
835 RtlZeroMemory( pDirNode,
838 RtlZeroMemory( pNonPagedDirEntry,
839 sizeof( AFSNonPagedDirectoryCB));
841 ExInitializeResourceLite( &pNonPagedDirEntry->Lock);
843 pDirNode->NonPaged = pNonPagedDirEntry;
845 pDirNode->ObjectInformation = pObjectInfoCB;
851 SetFlag( pDirNode->Flags, AFS_DIR_ENTRY_NOT_IN_PARENT_TREE | AFS_DIR_ENTRY_FAKE | AFS_DIR_ENTRY_VALID);
853 pDirNode->FileIndex = (ULONG)AFS_DIR_ENTRY_DOT_DOT_INDEX;
856 // Setup the names in the entry
859 pDirNode->NameInformation.FileName.Length = 2 * sizeof( WCHAR);
861 pDirNode->NameInformation.FileName.MaximumLength = 2 * sizeof( WCHAR);
863 pDirNode->NameInformation.FileName.Buffer = (WCHAR *)((char *)pDirNode + sizeof( AFSDirectoryCB));
865 pDirNode->NameInformation.FileName.Buffer[ 0] = L'.';
867 pDirNode->NameInformation.FileName.Buffer[ 1] = L'.';
870 // Populate the rest of the data
873 pObjectInfoCB->FileType = AFS_FILE_TYPE_DIRECTORY;
875 pObjectInfoCB->FileAttributes = FILE_ATTRIBUTE_DIRECTORY;
877 AFSGlobalDotDotDirEntry = pDirNode;
881 if( !NT_SUCCESS( ntStatus))
884 if( AFSGlobalDotDirEntry != NULL)
887 AFSDeleteObjectInfo( AFSGlobalDotDirEntry->ObjectInformation);
889 ExDeleteResourceLite( &AFSGlobalDotDirEntry->NonPaged->Lock);
891 ExFreePool( AFSGlobalDotDirEntry->NonPaged);
893 ExFreePool( AFSGlobalDotDirEntry);
895 AFSGlobalDotDirEntry = NULL;
898 if( AFSGlobalDotDotDirEntry != NULL)
901 AFSDeleteObjectInfo( AFSGlobalDotDotDirEntry->ObjectInformation);
903 ExDeleteResourceLite( &AFSGlobalDotDotDirEntry->NonPaged->Lock);
905 ExFreePool( AFSGlobalDotDotDirEntry->NonPaged);
907 ExFreePool( AFSGlobalDotDotDirEntry);
909 AFSGlobalDotDotDirEntry = NULL;
918 AFSInitDirEntry( IN AFSObjectInfoCB *ParentObjectInfo,
919 IN PUNICODE_STRING FileName,
920 IN PUNICODE_STRING TargetName,
921 IN AFSDirEnumEntry *DirEnumEntry,
925 AFSDirectoryCB *pDirNode = NULL;
926 NTSTATUS ntStatus = STATUS_SUCCESS;
927 ULONG ulEntryLength = 0;
928 AFSObjectInfoCB *pObjectInfoCB = NULL;
929 BOOLEAN bAllocatedObjectCB = FALSE;
930 ULONGLONG ullIndex = 0;
931 AFSNonPagedDirectoryCB *pNonPagedDirEntry = NULL;
937 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
938 AFS_TRACE_LEVEL_VERBOSE,
939 "AFSInitDirEntry Initializing entry %wZ parent FID %08lX-%08lX-%08lX-%08lX\n",
941 ParentObjectInfo->FileId.Cell,
942 ParentObjectInfo->FileId.Volume,
943 ParentObjectInfo->FileId.Vnode,
944 ParentObjectInfo->FileId.Unique);
947 // First thing is to locate/create our object information block
951 AFSAcquireExcl( ParentObjectInfo->VolumeCB->ObjectInfoTree.TreeLock,
954 ullIndex = AFSCreateLowIndex( &DirEnumEntry->FileId);
956 ntStatus = AFSLocateHashEntry( ParentObjectInfo->VolumeCB->ObjectInfoTree.TreeHead,
958 (AFSBTreeEntry **)&pObjectInfoCB);
960 if( !NT_SUCCESS( ntStatus) ||
961 pObjectInfoCB == NULL)
965 // Allocate our object info cb
968 pObjectInfoCB = AFSAllocateObjectInfo( ParentObjectInfo,
971 if( pObjectInfoCB == NULL)
974 AFSReleaseResource( ParentObjectInfo->VolumeCB->ObjectInfoTree.TreeLock);
976 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
979 bAllocatedObjectCB = TRUE;
981 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
982 AFS_TRACE_LEVEL_VERBOSE,
983 "AFSInitDirEntry initialized object %p Parent Object %p for %wZ\n",
989 lCount = AFSObjectInfoIncrement( pObjectInfoCB,
990 AFS_OBJECT_REFERENCE_DIRENTRY);
992 AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
993 AFS_TRACE_LEVEL_VERBOSE,
994 "AFSInitDirEntry Increment count on object %p Cnt %d\n",
998 AFSReleaseResource( ParentObjectInfo->VolumeCB->ObjectInfoTree.TreeLock);
1000 ntStatus = STATUS_SUCCESS;
1002 ulEntryLength = sizeof( AFSDirectoryCB) +
1005 if( TargetName != NULL)
1008 ulEntryLength += TargetName->Length;
1011 pDirNode = (AFSDirectoryCB *)AFSExAllocatePoolWithTag( PagedPool,
1015 if( pDirNode == NULL)
1018 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
1021 AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
1022 AFS_TRACE_LEVEL_VERBOSE,
1023 "AFSInitDirEntry AFS_DIR_ENTRY_TAG allocated %p\n",
1026 pNonPagedDirEntry = (AFSNonPagedDirectoryCB *)AFSExAllocatePoolWithTag( NonPagedPool,
1027 sizeof( AFSNonPagedDirectoryCB),
1028 AFS_DIR_ENTRY_NP_TAG);
1030 if( pNonPagedDirEntry == NULL)
1033 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
1036 RtlZeroMemory( pDirNode,
1039 RtlZeroMemory( pNonPagedDirEntry,
1040 sizeof( AFSNonPagedDirectoryCB));
1042 ExInitializeResourceLite( &pNonPagedDirEntry->Lock);
1044 pDirNode->NonPaged = pNonPagedDirEntry;
1046 pDirNode->ObjectInformation = pObjectInfoCB;
1049 // Set valid entry and NOT_IN_PARENT flag
1052 SetFlag( pDirNode->Flags, AFS_DIR_ENTRY_VALID | AFS_DIR_ENTRY_NOT_IN_PARENT_TREE);
1054 pDirNode->FileIndex = FileIndex;
1057 // Setup the names in the entry
1060 if( FileName->Length > 0)
1063 pDirNode->NameInformation.FileName.Length = FileName->Length;
1065 pDirNode->NameInformation.FileName.MaximumLength = FileName->Length;
1067 pDirNode->NameInformation.FileName.Buffer = (WCHAR *)((char *)pDirNode + sizeof( AFSDirectoryCB));
1069 RtlCopyMemory( pDirNode->NameInformation.FileName.Buffer,
1071 pDirNode->NameInformation.FileName.Length);
1074 // Create a CRC for the file
1077 pDirNode->CaseSensitiveTreeEntry.HashIndex = AFSGenerateCRC( &pDirNode->NameInformation.FileName,
1080 pDirNode->CaseInsensitiveTreeEntry.HashIndex = AFSGenerateCRC( &pDirNode->NameInformation.FileName,
1084 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
1085 AFS_TRACE_LEVEL_VERBOSE,
1086 "AFSInitDirEntry Initialized DE %p for %wZ in parent FID %08lX-%08lX-%08lX-%08lX\n",
1089 ParentObjectInfo->FileId.Cell,
1090 ParentObjectInfo->FileId.Volume,
1091 ParentObjectInfo->FileId.Vnode,
1092 ParentObjectInfo->FileId.Unique);
1094 if( TargetName != NULL &&
1095 TargetName->Length > 0)
1098 pDirNode->NameInformation.TargetName.Length = TargetName->Length;
1100 pDirNode->NameInformation.TargetName.MaximumLength = pDirNode->NameInformation.TargetName.Length;
1102 pDirNode->NameInformation.TargetName.Buffer = (WCHAR *)((char *)pDirNode +
1103 sizeof( AFSDirectoryCB) +
1104 pDirNode->NameInformation.FileName.Length);
1106 RtlCopyMemory( pDirNode->NameInformation.TargetName.Buffer,
1108 pDirNode->NameInformation.TargetName.Length);
1112 // If we allocated the object information cb then update the information
1115 if( bAllocatedObjectCB)
1119 // Populate the rest of the data
1122 pObjectInfoCB->FileId = DirEnumEntry->FileId;
1124 pObjectInfoCB->TargetFileId = DirEnumEntry->TargetFileId;
1126 pObjectInfoCB->FileType = DirEnumEntry->FileType;
1128 pObjectInfoCB->CreationTime = DirEnumEntry->CreationTime;
1130 pObjectInfoCB->LastAccessTime = DirEnumEntry->LastAccessTime;
1132 pObjectInfoCB->LastWriteTime = DirEnumEntry->LastWriteTime;
1134 pObjectInfoCB->ChangeTime = DirEnumEntry->ChangeTime;
1136 pObjectInfoCB->EndOfFile = DirEnumEntry->EndOfFile;
1138 pObjectInfoCB->AllocationSize = DirEnumEntry->AllocationSize;
1140 pObjectInfoCB->FileAttributes = DirEnumEntry->FileAttributes;
1142 if( pObjectInfoCB->FileType == AFS_FILE_TYPE_MOUNTPOINT)
1145 pObjectInfoCB->FileAttributes = (FILE_ATTRIBUTE_DIRECTORY | FILE_ATTRIBUTE_REPARSE_POINT);
1148 if (pObjectInfoCB->FileType == AFS_FILE_TYPE_SYMLINK ||
1149 pObjectInfoCB->FileType == AFS_FILE_TYPE_DFSLINK)
1152 pObjectInfoCB->FileAttributes = FILE_ATTRIBUTE_REPARSE_POINT;
1155 pObjectInfoCB->EaSize = DirEnumEntry->EaSize;
1158 // Check for the case where we have a filetype of SymLink but both the TargetFid and the
1159 // TargetName are empty. In this case set the filetype to zero so we evaluate it later in
1163 if( pObjectInfoCB->FileType == AFS_FILE_TYPE_SYMLINK &&
1164 pObjectInfoCB->TargetFileId.Vnode == 0 &&
1165 pObjectInfoCB->TargetFileId.Unique == 0 &&
1166 pDirNode->NameInformation.TargetName.Length == 0)
1170 // This will ensure we perform a validation on the node
1173 pObjectInfoCB->FileType = AFS_FILE_TYPE_UNKNOWN;
1176 if( pObjectInfoCB->FileType == AFS_FILE_TYPE_UNKNOWN)
1179 SetFlag( pObjectInfoCB->Flags, AFS_OBJECT_FLAGS_NOT_EVALUATED);
1184 // Object specific information
1187 pObjectInfoCB->Links = DirEnumEntry->Links;
1189 pObjectInfoCB->Expiration = DirEnumEntry->Expiration;
1191 pObjectInfoCB->DataVersion = DirEnumEntry->DataVersion;
1195 if( !NT_SUCCESS( ntStatus))
1198 if( pNonPagedDirEntry != NULL)
1201 ExDeleteResourceLite( &pNonPagedDirEntry->Lock);
1203 AFSExFreePoolWithTag( pNonPagedDirEntry, AFS_DIR_ENTRY_NP_TAG);
1206 if( pDirNode != NULL)
1209 AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
1210 AFS_TRACE_LEVEL_VERBOSE,
1211 "AFSInitDirEntry AFS_DIR_ENTRY_TAG deallocating %p\n",
1214 AFSExFreePoolWithTag( pDirNode, AFS_DIR_ENTRY_TAG);
1220 // Dereference our object info block if we have one
1223 if( pObjectInfoCB != NULL)
1226 lCount = AFSObjectInfoDecrement( pObjectInfoCB,
1227 AFS_OBJECT_REFERENCE_DIRENTRY);
1229 AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
1230 AFS_TRACE_LEVEL_VERBOSE,
1231 "AFSInitDirEntry Decrement count on object %p Cnt %d\n",
1235 if( bAllocatedObjectCB)
1238 ASSERT( pObjectInfoCB->ObjectReferenceCount == 0);
1240 AFSDeleteObjectInfo( pObjectInfoCB);
1250 AFSCheckForReadOnlyAccess( IN ACCESS_MASK DesiredAccess,
1251 IN BOOLEAN DirectoryEntry)
1254 BOOLEAN bReturn = TRUE;
1255 ACCESS_MASK stAccessMask = 0;
1258 // Get rid of anything we don't know about
1261 DesiredAccess = (DesiredAccess &
1267 ACCESS_SYSTEM_SECURITY |
1271 FILE_READ_ATTRIBUTES |
1272 FILE_WRITE_ATTRIBUTES |
1273 FILE_LIST_DIRECTORY |
1279 // Our 'read only' access mask. These are the accesses we will
1280 // allow for a read only file
1283 stAccessMask = DELETE |
1288 ACCESS_SYSTEM_SECURITY |
1292 FILE_READ_ATTRIBUTES |
1293 FILE_WRITE_ATTRIBUTES |
1295 FILE_LIST_DIRECTORY |
1299 // For a directory, add in the directory specific accesses
1305 stAccessMask |= FILE_ADD_SUBDIRECTORY |
1310 if( FlagOn( DesiredAccess, ~stAccessMask))
1314 // A write access is set ...
1324 AFSEvaluateNode( IN GUID *AuthGroup,
1325 IN AFSDirectoryCB *DirEntry)
1328 NTSTATUS ntStatus = STATUS_SUCCESS;
1329 AFSDirEnumEntry *pDirEntry = NULL;
1330 UNICODE_STRING uniTargetName;
1335 ntStatus = AFSEvaluateTargetByID( DirEntry->ObjectInformation,
1340 if( !NT_SUCCESS( ntStatus))
1343 try_return( ntStatus);
1346 DirEntry->ObjectInformation->TargetFileId = pDirEntry->TargetFileId;
1348 DirEntry->ObjectInformation->Expiration = pDirEntry->Expiration;
1350 DirEntry->ObjectInformation->DataVersion = pDirEntry->DataVersion;
1352 DirEntry->ObjectInformation->FileType = pDirEntry->FileType;
1354 DirEntry->ObjectInformation->CreationTime = pDirEntry->CreationTime;
1356 DirEntry->ObjectInformation->LastAccessTime = pDirEntry->LastAccessTime;
1358 DirEntry->ObjectInformation->LastWriteTime = pDirEntry->LastWriteTime;
1360 DirEntry->ObjectInformation->ChangeTime = pDirEntry->ChangeTime;
1362 DirEntry->ObjectInformation->EndOfFile = pDirEntry->EndOfFile;
1364 DirEntry->ObjectInformation->AllocationSize = pDirEntry->AllocationSize;
1366 DirEntry->ObjectInformation->FileAttributes = pDirEntry->FileAttributes;
1368 if( pDirEntry->FileType == AFS_FILE_TYPE_MOUNTPOINT)
1371 DirEntry->ObjectInformation->FileAttributes = (FILE_ATTRIBUTE_DIRECTORY | FILE_ATTRIBUTE_REPARSE_POINT);
1374 if( pDirEntry->FileType == AFS_FILE_TYPE_SYMLINK ||
1375 pDirEntry->FileType == AFS_FILE_TYPE_DFSLINK)
1378 DirEntry->ObjectInformation->FileAttributes = FILE_ATTRIBUTE_REPARSE_POINT;
1381 DirEntry->ObjectInformation->EaSize = pDirEntry->EaSize;
1383 DirEntry->ObjectInformation->Links = pDirEntry->Links;
1386 // If we have a target name then see if it needs updating ...
1389 if( pDirEntry->TargetNameLength > 0)
1393 // Update the target name information if needed
1396 uniTargetName.Length = (USHORT)pDirEntry->TargetNameLength;
1398 uniTargetName.MaximumLength = uniTargetName.Length;
1400 uniTargetName.Buffer = (WCHAR *)((char *)pDirEntry + pDirEntry->TargetNameOffset);
1402 AFSAcquireExcl( &DirEntry->NonPaged->Lock,
1405 if( DirEntry->NameInformation.TargetName.Length == 0 ||
1406 RtlCompareUnicodeString( &uniTargetName,
1407 &DirEntry->NameInformation.TargetName,
1412 // Update the target name
1415 ntStatus = AFSUpdateTargetName( &DirEntry->NameInformation.TargetName,
1417 uniTargetName.Buffer,
1418 uniTargetName.Length);
1420 if( !NT_SUCCESS( ntStatus))
1423 AFSReleaseResource( &DirEntry->NonPaged->Lock);
1425 try_return( ntStatus);
1429 AFSReleaseResource( &DirEntry->NonPaged->Lock);
1434 if( pDirEntry != NULL)
1437 AFSExFreePoolWithTag( pDirEntry, AFS_GENERIC_MEMORY_2_TAG);
1445 AFSValidateSymLink( IN GUID *AuthGroup,
1446 IN AFSDirectoryCB *DirEntry)
1449 NTSTATUS ntStatus = STATUS_SUCCESS;
1450 AFSDirEnumEntry *pDirEntry = NULL;
1451 UNICODE_STRING uniTargetName;
1456 ntStatus = AFSEvaluateTargetByID( DirEntry->ObjectInformation,
1461 if( !NT_SUCCESS( ntStatus))
1464 try_return( ntStatus);
1467 if( pDirEntry->FileType == AFS_FILE_TYPE_UNKNOWN ||
1468 pDirEntry->FileType == AFS_FILE_TYPE_INVALID)
1471 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
1472 AFS_TRACE_LEVEL_VERBOSE_2,
1473 "AFSValidateSymLink Invalid type Status %08lX\n",
1474 STATUS_OBJECT_NAME_NOT_FOUND);
1476 try_return( ntStatus = STATUS_OBJECT_NAME_NOT_FOUND);
1479 DirEntry->ObjectInformation->TargetFileId = pDirEntry->TargetFileId;
1481 DirEntry->ObjectInformation->Expiration = pDirEntry->Expiration;
1483 DirEntry->ObjectInformation->DataVersion = pDirEntry->DataVersion;
1486 // Update the target name information if needed
1489 uniTargetName.Length = (USHORT)pDirEntry->TargetNameLength;
1491 uniTargetName.MaximumLength = uniTargetName.Length;
1493 uniTargetName.Buffer = (WCHAR *)((char *)pDirEntry + pDirEntry->TargetNameOffset);
1495 if( uniTargetName.Length > 0)
1498 AFSAcquireExcl( &DirEntry->NonPaged->Lock,
1501 if( DirEntry->NameInformation.TargetName.Length == 0 ||
1502 RtlCompareUnicodeString( &uniTargetName,
1503 &DirEntry->NameInformation.TargetName,
1508 // Update the target name
1511 ntStatus = AFSUpdateTargetName( &DirEntry->NameInformation.TargetName,
1513 uniTargetName.Buffer,
1514 uniTargetName.Length);
1516 if( !NT_SUCCESS( ntStatus))
1519 AFSReleaseResource( &DirEntry->NonPaged->Lock);
1521 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
1525 AFSReleaseResource( &DirEntry->NonPaged->Lock);
1529 // If the FileType is the same then nothing to do since it IS
1533 if( pDirEntry->FileType == DirEntry->ObjectInformation->FileType)
1536 ASSERT( pDirEntry->FileType == AFS_FILE_TYPE_SYMLINK);
1538 try_return( ntStatus = STATUS_SUCCESS);
1541 DirEntry->ObjectInformation->FileType = pDirEntry->FileType;
1543 DirEntry->ObjectInformation->CreationTime = pDirEntry->CreationTime;
1545 DirEntry->ObjectInformation->LastAccessTime = pDirEntry->LastAccessTime;
1547 DirEntry->ObjectInformation->LastWriteTime = pDirEntry->LastWriteTime;
1549 DirEntry->ObjectInformation->ChangeTime = pDirEntry->ChangeTime;
1551 DirEntry->ObjectInformation->EndOfFile = pDirEntry->EndOfFile;
1553 DirEntry->ObjectInformation->AllocationSize = pDirEntry->AllocationSize;
1555 DirEntry->ObjectInformation->FileAttributes = pDirEntry->FileAttributes;
1557 if( pDirEntry->FileType == AFS_FILE_TYPE_MOUNTPOINT)
1560 DirEntry->ObjectInformation->FileAttributes = (FILE_ATTRIBUTE_DIRECTORY | FILE_ATTRIBUTE_REPARSE_POINT);
1563 if( pDirEntry->FileType == AFS_FILE_TYPE_SYMLINK ||
1564 pDirEntry->FileType == AFS_FILE_TYPE_DFSLINK)
1567 DirEntry->ObjectInformation->FileAttributes = FILE_ATTRIBUTE_REPARSE_POINT;
1570 DirEntry->ObjectInformation->EaSize = pDirEntry->EaSize;
1572 DirEntry->ObjectInformation->Links = pDirEntry->Links;
1576 if( pDirEntry != NULL)
1579 AFSExFreePoolWithTag( pDirEntry, AFS_GENERIC_MEMORY_2_TAG);
1587 AFSInvalidateObject( IN OUT AFSObjectInfoCB **ppObjectInfo,
1591 NTSTATUS ntStatus = STATUS_SUCCESS;
1592 IO_STATUS_BLOCK stIoStatus;
1595 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
1596 AFS_TRACE_LEVEL_VERBOSE,
1597 "AFSInvalidateObject Invalidation on node type %d for fid %08lX-%08lX-%08lX-%08lX Reason %d\n",
1598 (*ppObjectInfo)->FileType,
1599 (*ppObjectInfo)->FileId.Cell,
1600 (*ppObjectInfo)->FileId.Volume,
1601 (*ppObjectInfo)->FileId.Vnode,
1602 (*ppObjectInfo)->FileId.Unique,
1605 if( (*ppObjectInfo)->FileType == AFS_FILE_TYPE_SYMLINK ||
1606 (*ppObjectInfo)->FileType == AFS_FILE_TYPE_DFSLINK ||
1607 (*ppObjectInfo)->FileType == AFS_FILE_TYPE_MOUNTPOINT)
1610 // We only act on the mount point itself, not the target. If the
1611 // node has been deleted then mark it as such otherwise indicate
1612 // it requires verification
1615 if( Reason == AFS_INVALIDATE_DELETED)
1617 SetFlag( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_OBJECT_INVALID);
1622 if( Reason == AFS_INVALIDATE_FLUSHED)
1625 (*ppObjectInfo)->DataVersion.QuadPart = (ULONGLONG)-1;
1627 SetFlag( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_VERIFY_DATA);
1630 (*ppObjectInfo)->Expiration.QuadPart = 0;
1632 (*ppObjectInfo)->TargetFileId.Vnode = 0;
1634 (*ppObjectInfo)->TargetFileId.Unique = 0;
1636 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
1637 AFS_TRACE_LEVEL_VERBOSE,
1638 "AFSInvalidateObject Setting VERIFY flag on fid %08lX-%08lX-%08lX-%08lX\n",
1639 (*ppObjectInfo)->FileId.Cell,
1640 (*ppObjectInfo)->FileId.Volume,
1641 (*ppObjectInfo)->FileId.Vnode,
1642 (*ppObjectInfo)->FileId.Unique);
1644 SetFlag( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_VERIFY);
1647 ulFilter = FILE_NOTIFY_CHANGE_FILE_NAME;
1649 if( Reason == AFS_INVALIDATE_CREDS)
1651 ulFilter |= FILE_NOTIFY_CHANGE_SECURITY;
1654 if( Reason == AFS_INVALIDATE_DATA_VERSION ||
1655 Reason == AFS_INVALIDATE_FLUSHED)
1657 ulFilter |= FILE_NOTIFY_CHANGE_SIZE | FILE_NOTIFY_CHANGE_LAST_WRITE;
1661 ulFilter |= FILE_NOTIFY_CHANGE_ATTRIBUTES;
1664 AFSFsRtlNotifyFullReportChange( (*ppObjectInfo)->ParentObjectInformation,
1667 FILE_ACTION_MODIFIED);
1669 try_return( ntStatus);
1673 // Depending on the reason for invalidation then perform work on the node
1679 case AFS_INVALIDATE_DELETED:
1683 // Mark this node as invalid
1686 (*ppObjectInfo)->Links = 0;
1688 SetFlag( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_DELETED);
1690 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
1691 AFS_TRACE_LEVEL_VERBOSE,
1692 "AFSInvalidateObject Set DELETE flag on fid %08lX-%08lX-%08lX-%08lX\n",
1693 (*ppObjectInfo)->FileId.Cell,
1694 (*ppObjectInfo)->FileId.Volume,
1695 (*ppObjectInfo)->FileId.Vnode,
1696 (*ppObjectInfo)->FileId.Unique);
1698 if( (*ppObjectInfo)->ParentObjectInformation != NULL)
1701 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
1702 AFS_TRACE_LEVEL_VERBOSE,
1703 "AFSInvalidateObject Set VERIFY flag on parent fid %08lX-%08lX-%08lX-%08lX\n",
1704 (*ppObjectInfo)->ParentObjectInformation->FileId.Cell,
1705 (*ppObjectInfo)->ParentObjectInformation->FileId.Volume,
1706 (*ppObjectInfo)->ParentObjectInformation->FileId.Vnode,
1707 (*ppObjectInfo)->ParentObjectInformation->FileId.Unique);
1709 SetFlag( (*ppObjectInfo)->ParentObjectInformation->Flags, AFS_OBJECT_FLAGS_VERIFY);
1711 (*ppObjectInfo)->ParentObjectInformation->DataVersion.QuadPart = (ULONGLONG)-1;
1713 (*ppObjectInfo)->ParentObjectInformation->Expiration.QuadPart = 0;
1716 if( (*ppObjectInfo)->FileType == AFS_FILE_TYPE_DIRECTORY)
1718 ulFilter = FILE_NOTIFY_CHANGE_DIR_NAME;
1722 ulFilter = FILE_NOTIFY_CHANGE_FILE_NAME;
1725 AFSFsRtlNotifyFullReportChange( (*ppObjectInfo)->ParentObjectInformation,
1728 FILE_ACTION_REMOVED);
1730 if( NT_SUCCESS( AFSQueueInvalidateObject( (*ppObjectInfo),
1733 (*ppObjectInfo) = NULL; // We'll dec the count in the worker item
1739 case AFS_INVALIDATE_FLUSHED:
1742 if( (*ppObjectInfo)->FileType == AFS_FILE_TYPE_FILE &&
1743 (*ppObjectInfo)->Fcb != NULL)
1746 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
1747 AFS_TRACE_LEVEL_VERBOSE,
1748 "AFSInvalidateObject Flush/purge file fid %08lX-%08lX-%08lX-%08lX\n",
1749 (*ppObjectInfo)->FileId.Cell,
1750 (*ppObjectInfo)->FileId.Volume,
1751 (*ppObjectInfo)->FileId.Vnode,
1752 (*ppObjectInfo)->FileId.Unique);
1754 AFSAcquireExcl( &(*ppObjectInfo)->Fcb->NPFcb->SectionObjectResource,
1760 CcFlushCache( &(*ppObjectInfo)->Fcb->NPFcb->SectionObjectPointers,
1765 if( !NT_SUCCESS( stIoStatus.Status))
1768 AFSDbgLogMsg( AFS_SUBSYSTEM_IO_PROCESSING,
1769 AFS_TRACE_LEVEL_ERROR,
1770 "AFSInvalidateObject CcFlushCache failure FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX Bytes 0x%08lX\n",
1771 (*ppObjectInfo)->FileId.Cell,
1772 (*ppObjectInfo)->FileId.Volume,
1773 (*ppObjectInfo)->FileId.Vnode,
1774 (*ppObjectInfo)->FileId.Unique,
1776 stIoStatus.Information);
1778 ntStatus = stIoStatus.Status;
1782 if ( (*ppObjectInfo)->Fcb->NPFcb->SectionObjectPointers.DataSectionObject != NULL)
1785 if ( !CcPurgeCacheSection( &(*ppObjectInfo)->Fcb->NPFcb->SectionObjectPointers,
1791 AFSDbgLogMsg( AFS_SUBSYSTEM_IO_PROCESSING,
1792 AFS_TRACE_LEVEL_WARNING,
1793 "AFSInvalidateObject CcPurgeCacheSection failure FID %08lX-%08lX-%08lX-%08lX\n",
1794 (*ppObjectInfo)->FileId.Cell,
1795 (*ppObjectInfo)->FileId.Volume,
1796 (*ppObjectInfo)->FileId.Vnode,
1797 (*ppObjectInfo)->FileId.Unique);
1799 SetFlag( (*ppObjectInfo)->Fcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
1803 __except( EXCEPTION_EXECUTE_HANDLER)
1806 ntStatus = GetExceptionCode();
1810 "EXCEPTION - AFSInvalidateObject Cc FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX\n",
1811 (*ppObjectInfo)->FileId.Cell,
1812 (*ppObjectInfo)->FileId.Volume,
1813 (*ppObjectInfo)->FileId.Vnode,
1814 (*ppObjectInfo)->FileId.Unique,
1817 SetFlag( (*ppObjectInfo)->Fcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
1820 AFSReleaseResource( &(*ppObjectInfo)->Fcb->NPFcb->SectionObjectResource);
1823 // Clear out the extents
1824 // Get rid of them (note this involves waiting
1825 // for any writes or reads to the cache to complete)
1828 AFSTearDownFcbExtents( (*ppObjectInfo)->Fcb,
1832 (*ppObjectInfo)->DataVersion.QuadPart = (ULONGLONG)-1;
1835 if( (*ppObjectInfo)->FileType == AFS_FILE_TYPE_FILE)
1838 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
1839 AFS_TRACE_LEVEL_VERBOSE,
1840 "AFSInvalidateObject Setting VERIFY_DATA flag on fid %08lX-%08lX-%08lX-%08lX\n",
1841 (*ppObjectInfo)->FileId.Cell,
1842 (*ppObjectInfo)->FileId.Volume,
1843 (*ppObjectInfo)->FileId.Vnode,
1844 (*ppObjectInfo)->FileId.Unique);
1846 SetFlag( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_VERIFY_DATA);
1849 // Fall through to the default processing
1855 if( (*ppObjectInfo)->FileType == AFS_FILE_TYPE_DIRECTORY)
1857 ulFilter = FILE_NOTIFY_CHANGE_DIR_NAME;
1861 ulFilter = FILE_NOTIFY_CHANGE_FILE_NAME;
1864 if( Reason == AFS_INVALIDATE_CREDS)
1866 ulFilter |= FILE_NOTIFY_CHANGE_SECURITY;
1869 if( Reason == AFS_INVALIDATE_DATA_VERSION)
1871 ulFilter |= FILE_NOTIFY_CHANGE_SIZE | FILE_NOTIFY_CHANGE_LAST_WRITE;
1875 ulFilter |= FILE_NOTIFY_CHANGE_ATTRIBUTES;
1878 if( (*ppObjectInfo)->FileType == AFS_FILE_TYPE_DIRECTORY)
1881 AFSFsRtlNotifyFullReportChange( (*ppObjectInfo),
1884 FILE_ACTION_MODIFIED);
1889 AFSFsRtlNotifyFullReportChange( (*ppObjectInfo)->ParentObjectInformation,
1892 FILE_ACTION_MODIFIED);
1896 // Indicate this node requires re-evaluation for the remaining reasons
1899 (*ppObjectInfo)->Expiration.QuadPart = 0;
1901 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
1902 AFS_TRACE_LEVEL_VERBOSE,
1903 "AFSInvalidateObject Setting VERIFY flag on fid %08lX-%08lX-%08lX-%08lX\n",
1904 (*ppObjectInfo)->FileId.Cell,
1905 (*ppObjectInfo)->FileId.Volume,
1906 (*ppObjectInfo)->FileId.Vnode,
1907 (*ppObjectInfo)->FileId.Unique);
1909 SetFlag( (*ppObjectInfo)->Flags, AFS_OBJECT_FLAGS_VERIFY);
1911 if( Reason == AFS_INVALIDATE_DATA_VERSION ||
1912 (*ppObjectInfo)->FileType == AFS_FILE_TYPE_FILE &&
1913 ( Reason == AFS_INVALIDATE_CALLBACK ||
1914 Reason == AFS_INVALIDATE_EXPIRED))
1916 if ( NT_SUCCESS( AFSQueueInvalidateObject( (*ppObjectInfo),
1917 AFS_INVALIDATE_DATA_VERSION)))
1920 (*ppObjectInfo) = NULL; // We'll dec the count in the worker item
1934 AFSInvalidateCache( IN AFSInvalidateCacheCB *InvalidateCB)
1937 NTSTATUS ntStatus = STATUS_SUCCESS;
1938 AFSVolumeCB *pVolumeCB = NULL;
1939 AFSDeviceExt *pDevExt = (AFSDeviceExt *) AFSRDRDeviceObject->DeviceExtension;
1940 ULONGLONG ullIndex = 0;
1941 AFSObjectInfoCB *pObjectInfo = NULL;
1947 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
1948 AFS_TRACE_LEVEL_VERBOSE,
1949 "AFSInvalidateCache Invalidation FID %08lX-%08lX-%08lX-%08lX Type %d WholeVolume %d Reason %d\n",
1950 InvalidateCB->FileID.Cell,
1951 InvalidateCB->FileID.Volume,
1952 InvalidateCB->FileID.Vnode,
1953 InvalidateCB->FileID.Unique,
1954 InvalidateCB->FileType,
1955 InvalidateCB->WholeVolume,
1956 InvalidateCB->Reason);
1959 // Need to locate the Fcb for the directory to purge
1962 AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
1963 AFS_TRACE_LEVEL_VERBOSE,
1964 "AFSInvalidateCache Acquiring RDR VolumeTreeLock lock %p SHARED %08lX\n",
1965 &pDevExt->Specific.RDR.VolumeTreeLock,
1966 PsGetCurrentThread());
1969 // Starve any exclusive waiters on this paticular call
1972 AFSAcquireSharedStarveExclusive( &pDevExt->Specific.RDR.VolumeTreeLock, TRUE);
1975 // Locate the volume node
1978 ullIndex = AFSCreateHighIndex( &InvalidateCB->FileID);
1980 ntStatus = AFSLocateHashEntry( pDevExt->Specific.RDR.VolumeTree.TreeHead,
1982 (AFSBTreeEntry **)&pVolumeCB);
1984 if( pVolumeCB != NULL)
1987 lCount = InterlockedIncrement( &pVolumeCB->VolumeReferenceCount);
1989 AFSDbgLogMsg( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
1990 AFS_TRACE_LEVEL_VERBOSE,
1991 "AFSInvalidateCache Increment count on volume %p Cnt %d\n",
1996 AFSReleaseResource( &pDevExt->Specific.RDR.VolumeTreeLock);
1998 if( !NT_SUCCESS( ntStatus) ||
2002 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
2003 AFS_TRACE_LEVEL_WARNING,
2004 "AFSInvalidateCache Invalidation FAILURE Unable to locate volume node FID %08lX-%08lX-%08lX-%08lX Status %08lX\n",
2005 InvalidateCB->FileID.Cell,
2006 InvalidateCB->FileID.Volume,
2007 InvalidateCB->FileID.Vnode,
2008 InvalidateCB->FileID.Unique,
2011 try_return( ntStatus = STATUS_SUCCESS);
2015 // If this is a whole volume invalidation then go do it now
2018 if( InvalidateCB->WholeVolume)
2021 ntStatus = AFSInvalidateVolume( pVolumeCB,
2022 InvalidateCB->Reason);
2024 try_return( ntStatus);
2027 AFSAcquireShared( pVolumeCB->ObjectInfoTree.TreeLock,
2030 if ( AFSIsVolumeFID( &InvalidateCB->FileID))
2033 pObjectInfo = &pVolumeCB->ObjectInformation;
2038 ullIndex = AFSCreateLowIndex( &InvalidateCB->FileID);
2040 ntStatus = AFSLocateHashEntry( pVolumeCB->ObjectInfoTree.TreeHead,
2042 (AFSBTreeEntry **)&pObjectInfo);
2045 if( pObjectInfo != NULL)
2049 // Reference the node so it won't be torn down
2052 lCount = AFSObjectInfoIncrement( pObjectInfo,
2053 AFS_OBJECT_REFERENCE_INVALIDATION);
2055 AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2056 AFS_TRACE_LEVEL_VERBOSE,
2057 "AFSInvalidateCache Increment count on object %p Cnt %d\n",
2062 AFSReleaseResource( pVolumeCB->ObjectInfoTree.TreeLock);
2064 if( !NT_SUCCESS( ntStatus) ||
2065 pObjectInfo == NULL)
2068 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
2069 AFS_TRACE_LEVEL_VERBOSE,
2070 "AFSInvalidateCache Invalidation FAILURE Unable to locate object FID %08lX-%08lX-%08lX-%08lX Status %08lX\n",
2071 InvalidateCB->FileID.Cell,
2072 InvalidateCB->FileID.Volume,
2073 InvalidateCB->FileID.Vnode,
2074 InvalidateCB->FileID.Unique,
2077 try_return( ntStatus = STATUS_SUCCESS);
2080 AFSInvalidateObject( &pObjectInfo,
2081 InvalidateCB->Reason);
2085 if( pObjectInfo != NULL)
2088 lCount = AFSObjectInfoDecrement( pObjectInfo,
2089 AFS_OBJECT_REFERENCE_INVALIDATION);
2091 AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2092 AFS_TRACE_LEVEL_VERBOSE,
2093 "AFSInvalidateCache Decrement count on object %p Cnt %d\n",
2098 if ( pVolumeCB != NULL)
2101 lCount = InterlockedDecrement( &pVolumeCB->VolumeReferenceCount);
2103 AFSDbgLogMsg( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
2104 AFS_TRACE_LEVEL_VERBOSE,
2105 "AFSInvalidateCache Decrement count on volume %p Cnt %d\n",
2115 AFSIsChildOfParent( IN AFSFcb *Dcb,
2119 BOOLEAN bIsChild = FALSE;
2120 AFSFcb *pCurrentFcb = Fcb;
2122 while( pCurrentFcb != NULL)
2125 if( pCurrentFcb->ObjectInformation->ParentObjectInformation == Dcb->ObjectInformation)
2133 pCurrentFcb = pCurrentFcb->ObjectInformation->ParentObjectInformation->Fcb;
2141 AFSCreateHighIndex( IN AFSFileID *FileID)
2144 ULONGLONG ullIndex = 0;
2146 ullIndex = (((ULONGLONG)FileID->Cell << 32) | FileID->Volume);
2153 AFSCreateLowIndex( IN AFSFileID *FileID)
2156 ULONGLONG ullIndex = 0;
2158 ullIndex = (((ULONGLONG)FileID->Vnode << 32) | FileID->Unique);
2164 AFSCheckAccess( IN ACCESS_MASK DesiredAccess,
2165 IN ACCESS_MASK GrantedAccess,
2166 IN BOOLEAN DirectoryEntry)
2169 BOOLEAN bAccessGranted = TRUE;
2172 // Check if we are asking for read/write and granted only read only
2173 // NOTE: There will be more checks here
2176 if( !AFSCheckForReadOnlyAccess( DesiredAccess,
2178 AFSCheckForReadOnlyAccess( GrantedAccess,
2182 bAccessGranted = FALSE;
2185 return bAccessGranted;
2189 AFSGetDriverStatus( IN AFSDriverStatusRespCB *DriverStatus)
2192 NTSTATUS ntStatus = STATUS_SUCCESS;
2193 AFSDeviceExt *pControlDevExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
2199 DriverStatus->Status = AFS_DRIVER_STATUS_READY;
2201 if( AFSGlobalRoot == NULL)
2208 DriverStatus->Status = AFS_DRIVER_STATUS_NOT_READY;
2211 if( pControlDevExt->Specific.Control.CommServiceCB.IrpPoolControlFlag != POOL_ACTIVE)
2218 DriverStatus->Status = AFS_DRIVER_STATUS_NO_SERVICE;
2225 AFSSubstituteSysName( IN UNICODE_STRING *ComponentName,
2226 IN UNICODE_STRING *SubstituteName,
2227 IN ULONG StringIndex)
2230 NTSTATUS ntStatus = STATUS_SUCCESS;
2231 AFSDeviceExt *pControlDevExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
2232 AFSSysNameCB *pSysName = NULL;
2233 ERESOURCE *pSysNameLock = NULL;
2236 UNICODE_STRING uniSysName;
2243 if( IoIs32bitProcess( NULL))
2246 pSysNameLock = &pControlDevExt->Specific.Control.SysName32ListLock;
2248 pSysName = pControlDevExt->Specific.Control.SysName32ListHead;
2253 pSysNameLock = &pControlDevExt->Specific.Control.SysName64ListLock;
2255 pSysName = pControlDevExt->Specific.Control.SysName64ListHead;
2259 pSysNameLock = &pControlDevExt->Specific.Control.SysName32ListLock;
2261 pSysName = pControlDevExt->Specific.Control.SysName32ListHead;
2265 AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
2266 AFS_TRACE_LEVEL_VERBOSE,
2267 "AFSSubstituteSysName Acquiring SysName lock %p SHARED %08lX\n",
2269 PsGetCurrentThread());
2271 AFSAcquireShared( pSysNameLock,
2275 // Find where we are in the list
2278 while( pSysName != NULL &&
2279 ulIndex < StringIndex)
2282 pSysName = pSysName->fLink;
2287 if( pSysName == NULL)
2290 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
2291 AFS_TRACE_LEVEL_VERBOSE_2,
2292 "AFSSubstituteSysName No sysname %wZ Status %08lX\n",
2294 STATUS_OBJECT_NAME_NOT_FOUND);
2296 try_return( ntStatus = STATUS_OBJECT_NAME_NOT_FOUND);
2299 RtlInitUnicodeString( &uniSysName,
2302 // If it is a full component of @SYS then just substitue the
2306 if( RtlCompareUnicodeString( &uniSysName,
2311 SubstituteName->Length = pSysName->SysName.Length;
2312 SubstituteName->MaximumLength = SubstituteName->Length;
2314 SubstituteName->Buffer = (WCHAR *)AFSExAllocatePoolWithTag( PagedPool,
2315 SubstituteName->Length,
2316 AFS_SUBST_BUFFER_TAG);
2318 if( SubstituteName->Buffer == NULL)
2321 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
2324 RtlCopyMemory( SubstituteName->Buffer,
2325 pSysName->SysName.Buffer,
2326 pSysName->SysName.Length);
2333 while( ComponentName->Buffer[ usIndex] != L'@')
2339 SubstituteName->Length = (usIndex * sizeof( WCHAR)) + pSysName->SysName.Length;
2340 SubstituteName->MaximumLength = SubstituteName->Length;
2342 SubstituteName->Buffer = (WCHAR *)AFSExAllocatePoolWithTag( PagedPool,
2343 SubstituteName->Length,
2344 AFS_SUBST_BUFFER_TAG);
2346 if( SubstituteName->Buffer == NULL)
2349 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
2352 RtlCopyMemory( SubstituteName->Buffer,
2353 ComponentName->Buffer,
2354 usIndex * sizeof( WCHAR));
2356 RtlCopyMemory( &SubstituteName->Buffer[ usIndex],
2357 pSysName->SysName.Buffer,
2358 pSysName->SysName.Length);
2363 AFSReleaseResource( pSysNameLock);
2370 AFSSubstituteNameInPath( IN OUT UNICODE_STRING *FullPathName,
2371 IN OUT UNICODE_STRING *ComponentName,
2372 IN UNICODE_STRING *SubstituteName,
2373 IN OUT UNICODE_STRING *RemainingPath,
2374 IN BOOLEAN FreePathName)
2377 NTSTATUS ntStatus = STATUS_SUCCESS;
2378 UNICODE_STRING uniPathName;
2379 USHORT usPrefixNameLen = 0;
2380 SHORT sNameLenDelta = 0;
2386 // If the passed in name can handle the additional length
2387 // then just moves things around
2390 sNameLenDelta = SubstituteName->Length - ComponentName->Length;
2392 usPrefixNameLen = (USHORT)(ComponentName->Buffer - FullPathName->Buffer);
2394 if( FullPathName->MaximumLength > FullPathName->Length + sNameLenDelta)
2397 if( FullPathName->Length > usPrefixNameLen + ComponentName->Length)
2400 RtlMoveMemory( &FullPathName->Buffer[ ((usPrefixNameLen*sizeof( WCHAR) + SubstituteName->Length)/sizeof( WCHAR))],
2401 &FullPathName->Buffer[ ((usPrefixNameLen*sizeof( WCHAR) + ComponentName->Length)/sizeof( WCHAR))],
2402 FullPathName->Length - usPrefixNameLen*sizeof( WCHAR) - ComponentName->Length);
2405 RtlCopyMemory( &FullPathName->Buffer[ usPrefixNameLen],
2406 SubstituteName->Buffer,
2407 SubstituteName->Length);
2409 FullPathName->Length += sNameLenDelta;
2411 ComponentName->Length += sNameLenDelta;
2413 ComponentName->MaximumLength = ComponentName->Length;
2415 if ( RemainingPath->Buffer)
2418 RemainingPath->Buffer += sNameLenDelta/sizeof( WCHAR);
2421 try_return( ntStatus);
2425 // Need to re-allocate the buffer
2428 uniPathName.Length = FullPathName->Length -
2429 ComponentName->Length +
2430 SubstituteName->Length;
2432 uniPathName.MaximumLength = FullPathName->MaximumLength + PAGE_SIZE;
2434 uniPathName.Buffer = (WCHAR *)AFSExAllocatePoolWithTag( PagedPool,
2435 uniPathName.MaximumLength,
2436 AFS_NAME_BUFFER_FOUR_TAG);
2438 if( uniPathName.Buffer == NULL)
2441 try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
2444 usPrefixNameLen = (USHORT)(ComponentName->Buffer - FullPathName->Buffer);
2446 usPrefixNameLen *= sizeof( WCHAR);
2448 RtlZeroMemory( uniPathName.Buffer,
2449 uniPathName.MaximumLength);
2451 RtlCopyMemory( uniPathName.Buffer,
2452 FullPathName->Buffer,
2455 RtlCopyMemory( &uniPathName.Buffer[ (usPrefixNameLen/sizeof( WCHAR))],
2456 SubstituteName->Buffer,
2457 SubstituteName->Length);
2459 if( FullPathName->Length > usPrefixNameLen + ComponentName->Length)
2462 RtlCopyMemory( &uniPathName.Buffer[ (usPrefixNameLen + SubstituteName->Length)/sizeof( WCHAR)],
2463 &FullPathName->Buffer[ (usPrefixNameLen + ComponentName->Length)/sizeof( WCHAR)],
2464 FullPathName->Length - usPrefixNameLen - ComponentName->Length);
2467 ComponentName->Buffer = uniPathName.Buffer + (ComponentName->Buffer - FullPathName->Buffer);
2469 ComponentName->Length += sNameLenDelta;
2471 ComponentName->MaximumLength = ComponentName->Length;
2473 if ( RemainingPath->Buffer)
2476 RemainingPath->Buffer = uniPathName.Buffer
2477 + (RemainingPath->Buffer - FullPathName->Buffer)
2478 + sNameLenDelta/sizeof( WCHAR);
2483 AFSExFreePoolWithTag( FullPathName->Buffer, 0);
2486 *FullPathName = uniPathName;
2497 AFSInvalidateVolume( IN AFSVolumeCB *VolumeCB,
2501 NTSTATUS ntStatus = STATUS_SUCCESS;
2502 AFSObjectInfoCB *pCurrentObject = NULL;
2503 AFSObjectInfoCB *pNextObject = NULL;
2509 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
2510 AFS_TRACE_LEVEL_VERBOSE,
2511 "AFSInvalidateVolume Invalidate volume fid %08lX-%08lX-%08lX-%08lX Reason %08lX\n",
2512 VolumeCB->ObjectInformation.FileId.Cell,
2513 VolumeCB->ObjectInformation.FileId.Volume,
2514 VolumeCB->ObjectInformation.FileId.Vnode,
2515 VolumeCB->ObjectInformation.FileId.Unique,
2519 // Depending on the reason for invalidation then perform work on the node
2525 case AFS_INVALIDATE_DELETED:
2529 // Mark this volume as invalid
2532 SetFlag( VolumeCB->ObjectInformation.Flags, AFS_OBJECT_FLAGS_OBJECT_INVALID);
2534 SetFlag( VolumeCB->Flags, AFS_VOLUME_FLAGS_OFFLINE);
2541 // Invalidate the volume root directory
2544 pCurrentObject = &VolumeCB->ObjectInformation;
2546 if ( pCurrentObject )
2549 lCount = AFSObjectInfoIncrement( pCurrentObject,
2550 AFS_OBJECT_REFERENCE_INVALIDATION);
2552 AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2553 AFS_TRACE_LEVEL_VERBOSE,
2554 "AFSInvalidateVolumeObjects Increment count on object %p Cnt %d\n",
2558 AFSInvalidateObject( &pCurrentObject,
2561 if ( pCurrentObject)
2564 lCount = AFSObjectInfoDecrement( pCurrentObject,
2565 AFS_OBJECT_REFERENCE_INVALIDATION);
2567 AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2568 AFS_TRACE_LEVEL_VERBOSE,
2569 "AFSInvalidateVolumeObjects Decrement count on object %p Cnt %d\n",
2576 // Apply invalidation to all other volume objects
2579 AFSAcquireShared( VolumeCB->ObjectInfoTree.TreeLock,
2582 pCurrentObject = VolumeCB->ObjectInfoListHead;
2584 if ( pCurrentObject)
2588 // Reference the node so it won't be torn down
2591 lCount = AFSObjectInfoIncrement( pCurrentObject,
2592 AFS_OBJECT_REFERENCE_INVALIDATION);
2594 AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2595 AFS_TRACE_LEVEL_VERBOSE,
2596 "AFSInvalidateVolumeObjects Increment count on object %p Cnt %d\n",
2601 while( pCurrentObject != NULL)
2604 pNextObject = (AFSObjectInfoCB *)pCurrentObject->ListEntry.fLink;
2610 // Reference the node so it won't be torn down
2613 lCount = AFSObjectInfoIncrement( pNextObject,
2614 AFS_OBJECT_REFERENCE_INVALIDATION);
2616 AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2617 AFS_TRACE_LEVEL_VERBOSE,
2618 "AFSInvalidateVolumeObjects Increment count on object %p Cnt %d\n",
2623 AFSReleaseResource( VolumeCB->ObjectInfoTree.TreeLock);
2625 AFSInvalidateObject( &pCurrentObject,
2628 if ( pCurrentObject )
2631 lCount = AFSObjectInfoDecrement( pCurrentObject,
2632 AFS_OBJECT_REFERENCE_INVALIDATION);
2634 AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
2635 AFS_TRACE_LEVEL_VERBOSE,
2636 "AFSInvalidateVolumeObjects Decrement count on object %p Cnt %d\n",
2641 AFSAcquireShared( VolumeCB->ObjectInfoTree.TreeLock,
2644 pCurrentObject = pNextObject;
2647 AFSReleaseResource( VolumeCB->ObjectInfoTree.TreeLock);
2654 AFSInvalidateAllVolumes( VOID)
2656 AFSVolumeCB *pVolumeCB = NULL;
2657 AFSVolumeCB *pNextVolumeCB = NULL;
2658 AFSDeviceExt *pRDRDeviceExt = NULL;
2661 pRDRDeviceExt = (AFSDeviceExt *)AFSRDRDeviceObject->DeviceExtension;
2663 AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
2664 AFS_TRACE_LEVEL_VERBOSE,
2665 "AFSInvalidateAllVolumes Acquiring RDR VolumeListLock lock %p SHARED %08lX\n",
2666 &pRDRDeviceExt->Specific.RDR.VolumeListLock,
2667 PsGetCurrentThread());
2669 AFSAcquireShared( &pRDRDeviceExt->Specific.RDR.VolumeListLock,
2672 pVolumeCB = pRDRDeviceExt->Specific.RDR.VolumeListHead;
2677 AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
2678 AFS_TRACE_LEVEL_VERBOSE,
2679 "AFSInvalidateAllVolumes Acquiring VolumeRoot ObjectInfoTree lock %p SHARED %08lX\n",
2680 pVolumeCB->ObjectInfoTree.TreeLock,
2681 PsGetCurrentThread());
2683 lCount = InterlockedIncrement( &pVolumeCB->VolumeReferenceCount);
2685 AFSDbgLogMsg( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
2686 AFS_TRACE_LEVEL_VERBOSE,
2687 "AFSInvalidateAllVolumes Increment count on volume %p Cnt %d\n",
2692 while( pVolumeCB != NULL)
2695 pNextVolumeCB = (AFSVolumeCB *)pVolumeCB->ListEntry.fLink;
2700 lCount = InterlockedIncrement( &pNextVolumeCB->VolumeReferenceCount);
2702 AFSDbgLogMsg( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
2703 AFS_TRACE_LEVEL_VERBOSE,
2704 "AFSInvalidateAllVolumes Increment count on volume %p Cnt %d\n",
2709 AFSReleaseResource( &pRDRDeviceExt->Specific.RDR.VolumeListLock);
2711 // do I need to hold the volume lock here?
2713 AFSInvalidateVolume( pVolumeCB, AFS_INVALIDATE_EXPIRED);
2715 AFSAcquireShared( &pRDRDeviceExt->Specific.RDR.VolumeListLock,
2718 lCount = InterlockedDecrement( &pVolumeCB->VolumeReferenceCount);
2720 AFSDbgLogMsg( AFS_SUBSYSTEM_VOLUME_REF_COUNTING,
2721 AFS_TRACE_LEVEL_VERBOSE,
2722 "AFSInvalidateAllVolumes Decrement count on volume %p Cnt %d\n",
2726 pVolumeCB = pNextVolumeCB;
2729 AFSReleaseResource( &pRDRDeviceExt->Specific.RDR.VolumeListLock);
2733 AFSVerifyEntry( IN GUID *AuthGroup,
2734 IN AFSDirectoryCB *DirEntry)
2737 NTSTATUS ntStatus = STATUS_SUCCESS;
2738 AFSDirEnumEntry *pDirEnumEntry = NULL;
2739 AFSObjectInfoCB *pObjectInfo = DirEntry->ObjectInformation;
2740 IO_STATUS_BLOCK stIoStatus;
2745 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
2746 AFS_TRACE_LEVEL_VERBOSE_2,
2747 "AFSVerifyEntry Verifying entry %wZ FID %08lX-%08lX-%08lX-%08lX\n",
2748 &DirEntry->NameInformation.FileName,
2749 pObjectInfo->FileId.Cell,
2750 pObjectInfo->FileId.Volume,
2751 pObjectInfo->FileId.Vnode,
2752 pObjectInfo->FileId.Unique);
2754 ntStatus = AFSEvaluateTargetByID( pObjectInfo,
2759 if( !NT_SUCCESS( ntStatus))
2762 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
2763 AFS_TRACE_LEVEL_ERROR,
2764 "AFSVerifyEntry Evaluate Target failed %wZ FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX\n",
2765 &DirEntry->NameInformation.FileName,
2766 pObjectInfo->FileId.Cell,
2767 pObjectInfo->FileId.Volume,
2768 pObjectInfo->FileId.Vnode,
2769 pObjectInfo->FileId.Unique,
2772 try_return( ntStatus);
2776 // Check the data version of the file
2779 if( pObjectInfo->DataVersion.QuadPart == pDirEnumEntry->DataVersion.QuadPart)
2781 if ( !BooleanFlagOn( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY_DATA))
2784 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
2785 AFS_TRACE_LEVEL_VERBOSE,
2786 "AFSVerifyEntry No DV change %I64X for Fcb %wZ FID %08lX-%08lX-%08lX-%08lX\n",
2787 pObjectInfo->DataVersion.QuadPart,
2788 &DirEntry->NameInformation.FileName,
2789 pObjectInfo->FileId.Cell,
2790 pObjectInfo->FileId.Volume,
2791 pObjectInfo->FileId.Vnode,
2792 pObjectInfo->FileId.Unique);
2795 // We are ok, just get out
2798 ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
2800 try_return( ntStatus = STATUS_SUCCESS);
2805 // New data version so we will need to process the node based on the type
2808 switch( pDirEnumEntry->FileType)
2811 case AFS_FILE_TYPE_MOUNTPOINT:
2815 // For a mount point we need to ensure the target is the same
2818 if( !AFSIsEqualFID( &pObjectInfo->TargetFileId,
2819 &pDirEnumEntry->TargetFileId))
2825 // Update the metadata for the entry
2828 ntStatus = AFSUpdateMetaData( DirEntry,
2831 if( NT_SUCCESS( ntStatus))
2834 ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
2840 case AFS_FILE_TYPE_SYMLINK:
2844 // Update the metadata for the entry
2847 ntStatus = AFSUpdateMetaData( DirEntry,
2850 if( NT_SUCCESS( ntStatus))
2853 ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
2859 case AFS_FILE_TYPE_FILE:
2861 FILE_OBJECT * pCCFileObject = NULL;
2862 BOOLEAN bPurgeExtents = FALSE;
2864 if ( pObjectInfo->DataVersion.QuadPart != pDirEnumEntry->DataVersion.QuadPart)
2867 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
2868 AFS_TRACE_LEVEL_VERBOSE,
2869 "AFSVerifyEntry DV Change %wZ FID %08lX-%08lX-%08lX-%08lX (%08lX != %08lX)\n",
2870 &DirEntry->NameInformation.FileName,
2871 pObjectInfo->FileId.Cell,
2872 pObjectInfo->FileId.Volume,
2873 pObjectInfo->FileId.Vnode,
2874 pObjectInfo->FileId.Unique,
2875 pObjectInfo->DataVersion.LowPart,
2876 pDirEnumEntry->DataVersion.LowPart
2879 bPurgeExtents = TRUE;
2882 if ( BooleanFlagOn( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY_DATA))
2885 bPurgeExtents = TRUE;
2887 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
2888 AFS_TRACE_LEVEL_VERBOSE,
2889 "AFSVerifyEntry Clearing VERIFY_DATA flag %wZ FID %08lX-%08lX-%08lX-%08lX\n",
2890 &DirEntry->NameInformation.FileName,
2891 pObjectInfo->FileId.Cell,
2892 pObjectInfo->FileId.Volume,
2893 pObjectInfo->FileId.Vnode,
2894 pObjectInfo->FileId.Unique);
2896 ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY_DATA);
2899 if( pObjectInfo->Fcb != NULL)
2902 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
2903 AFS_TRACE_LEVEL_VERBOSE,
2904 "AFSVerifyEntry Flush/purge entry %wZ FID %08lX-%08lX-%08lX-%08lX\n",
2905 &DirEntry->NameInformation.FileName,
2906 pObjectInfo->FileId.Cell,
2907 pObjectInfo->FileId.Volume,
2908 pObjectInfo->FileId.Vnode,
2909 pObjectInfo->FileId.Unique);
2911 AFSAcquireExcl( &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
2917 CcFlushCache( &pObjectInfo->Fcb->NPFcb->SectionObjectPointers,
2922 if( !NT_SUCCESS( stIoStatus.Status))
2925 AFSDbgLogMsg( AFS_SUBSYSTEM_IO_PROCESSING,
2926 AFS_TRACE_LEVEL_ERROR,
2927 "AFSVerifyEntry CcFlushCache failure %wZ FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX Bytes 0x%08lX\n",
2928 &DirEntry->NameInformation.FileName,
2929 pObjectInfo->FileId.Cell,
2930 pObjectInfo->FileId.Volume,
2931 pObjectInfo->FileId.Vnode,
2932 pObjectInfo->FileId.Unique,
2934 stIoStatus.Information);
2936 ntStatus = stIoStatus.Status;
2939 if ( bPurgeExtents &&
2940 pObjectInfo->Fcb->NPFcb->SectionObjectPointers.DataSectionObject != NULL)
2943 if ( !CcPurgeCacheSection( &pObjectInfo->Fcb->NPFcb->SectionObjectPointers,
2949 AFSDbgLogMsg( AFS_SUBSYSTEM_IO_PROCESSING,
2950 AFS_TRACE_LEVEL_WARNING,
2951 "AFSVerifyEntry CcPurgeCacheSection failure %wZ FID %08lX-%08lX-%08lX-%08lX\n",
2952 &DirEntry->NameInformation.FileName,
2953 pObjectInfo->FileId.Cell,
2954 pObjectInfo->FileId.Volume,
2955 pObjectInfo->FileId.Vnode,
2956 pObjectInfo->FileId.Unique);
2958 SetFlag( pObjectInfo->Fcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
2962 __except( EXCEPTION_EXECUTE_HANDLER)
2964 ntStatus = GetExceptionCode();
2968 "EXCEPTION - AFSVerifyEntry CcFlushCache or CcPurgeCacheSection %wZ FID %08lX-%08lX-%08lX-%08lX Status 0x%08lX\n",
2969 &DirEntry->NameInformation.FileName,
2970 pObjectInfo->FileId.Cell,
2971 pObjectInfo->FileId.Volume,
2972 pObjectInfo->FileId.Vnode,
2973 pObjectInfo->FileId.Unique,
2976 SetFlag( pObjectInfo->Fcb->Flags, AFS_FCB_FLAG_PURGE_ON_CLOSE);
2979 AFSReleaseResource( &pObjectInfo->Fcb->NPFcb->SectionObjectResource);
2983 AFSFlushExtents( pObjectInfo->Fcb,
2988 // Reacquire the Fcb to purge the cache
2991 AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
2992 AFS_TRACE_LEVEL_VERBOSE,
2993 "AFSVerifyEntry Acquiring Fcb lock %p EXCL %08lX\n",
2994 &pObjectInfo->Fcb->NPFcb->Resource,
2995 PsGetCurrentThread());
2997 AFSAcquireExcl( &pObjectInfo->Fcb->NPFcb->Resource,
3001 // Update the metadata for the entry
3004 ntStatus = AFSUpdateMetaData( DirEntry,
3007 if( !NT_SUCCESS( ntStatus))
3010 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
3011 AFS_TRACE_LEVEL_ERROR,
3012 "AFSVerifyEntry Meta Data Update failed %wZ FID %08lX-%08lX-%08lX-%08lX ntStatus %08lX\n",
3013 &DirEntry->NameInformation.FileName,
3014 pObjectInfo->FileId.Cell,
3015 pObjectInfo->FileId.Volume,
3016 pObjectInfo->FileId.Vnode,
3017 pObjectInfo->FileId.Unique,
3024 // Update file sizes
3027 pObjectInfo->Fcb->Header.AllocationSize.QuadPart = pObjectInfo->AllocationSize.QuadPart;
3028 pObjectInfo->Fcb->Header.FileSize.QuadPart = pObjectInfo->EndOfFile.QuadPart;
3029 pObjectInfo->Fcb->Header.ValidDataLength.QuadPart = pObjectInfo->EndOfFile.QuadPart;
3031 AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
3032 AFS_TRACE_LEVEL_VERBOSE,
3033 "AFSVerifyEntry Acquiring Fcb SectionObject lock %p EXCL %08lX\n",
3034 &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
3035 PsGetCurrentThread());
3037 AFSAcquireExcl( &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
3040 pCCFileObject = CcGetFileObjectFromSectionPtrs( &pObjectInfo->Fcb->NPFcb->SectionObjectPointers);
3042 if ( pCCFileObject != NULL)
3044 CcSetFileSizes( pCCFileObject,
3045 (PCC_FILE_SIZES)&pObjectInfo->Fcb->Header.AllocationSize);
3048 AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
3049 AFS_TRACE_LEVEL_VERBOSE,
3050 "AFSVerifyEntry Releasing Fcb SectionObject lock %p EXCL %08lX\n",
3051 &pObjectInfo->Fcb->NPFcb->SectionObjectResource,
3052 PsGetCurrentThread());
3054 AFSReleaseResource( &pObjectInfo->Fcb->NPFcb->SectionObjectResource);
3056 AFSReleaseResource( &pObjectInfo->Fcb->NPFcb->Resource);
3062 // Update the metadata for the entry
3065 ntStatus = AFSUpdateMetaData( DirEntry,
3068 if( !NT_SUCCESS( ntStatus))
3071 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
3072 AFS_TRACE_LEVEL_ERROR,
3073 "AFSVerifyEntry Meta Data Update failed %wZ FID %08lX-%08lX-%08lX-%08lX ntStatus %08lX\n",
3074 &DirEntry->NameInformation.FileName,
3075 pObjectInfo->FileId.Cell,
3076 pObjectInfo->FileId.Volume,
3077 pObjectInfo->FileId.Vnode,
3078 pObjectInfo->FileId.Unique,
3084 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
3085 AFS_TRACE_LEVEL_WARNING,
3086 "AFSVerifyEntry Fcb NULL %wZ FID %08lX-%08lX-%08lX-%08lX\n",
3087 &DirEntry->NameInformation.FileName,
3088 pObjectInfo->FileId.Cell,
3089 pObjectInfo->FileId.Volume,
3090 pObjectInfo->FileId.Vnode,
3091 pObjectInfo->FileId.Unique);
3094 ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
3099 case AFS_FILE_TYPE_DIRECTORY:
3103 // For a directory or root entry flush the content of
3104 // the directory enumeration.
3107 if( BooleanFlagOn( pObjectInfo->Flags, AFS_OBJECT_FLAGS_DIRECTORY_ENUMERATED))
3110 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
3111 AFS_TRACE_LEVEL_VERBOSE_2,
3112 "AFSVerifyEntry Validating directory content for entry %wZ FID %08lX-%08lX-%08lX-%08lX\n",
3113 &DirEntry->NameInformation.FileName,
3114 pObjectInfo->FileId.Cell,
3115 pObjectInfo->FileId.Volume,
3116 pObjectInfo->FileId.Vnode,
3117 pObjectInfo->FileId.Unique);
3119 AFSAcquireExcl( pObjectInfo->Specific.Directory.DirectoryNodeHdr.TreeLock,
3122 ntStatus = AFSValidateDirectoryCache( pObjectInfo,
3125 AFSReleaseResource( pObjectInfo->Specific.Directory.DirectoryNodeHdr.TreeLock);
3127 if ( !NT_SUCCESS( ntStatus))
3130 try_return( ntStatus);
3135 // Update the metadata for the entry
3138 ntStatus = AFSUpdateMetaData( DirEntry,
3141 if( NT_SUCCESS( ntStatus))
3144 ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
3150 case AFS_FILE_TYPE_DFSLINK:
3153 UNICODE_STRING uniTargetName;
3156 // For a DFS link need to check the target name has not changed
3159 uniTargetName.Length = (USHORT)pDirEnumEntry->TargetNameLength;
3161 uniTargetName.MaximumLength = uniTargetName.Length;
3163 uniTargetName.Buffer = (WCHAR *)((char *)pDirEnumEntry + pDirEnumEntry->TargetNameOffset);
3165 AFSAcquireExcl( &DirEntry->NonPaged->Lock,
3168 if( DirEntry->NameInformation.TargetName.Length == 0 ||
3169 RtlCompareUnicodeString( &uniTargetName,
3170 &DirEntry->NameInformation.TargetName,
3175 // Update the target name
3178 ntStatus = AFSUpdateTargetName( &DirEntry->NameInformation.TargetName,
3180 uniTargetName.Buffer,
3181 uniTargetName.Length);
3183 if( !NT_SUCCESS( ntStatus))
3186 AFSReleaseResource( &DirEntry->NonPaged->Lock);
3192 AFSReleaseResource( &DirEntry->NonPaged->Lock);
3195 // Update the metadata for the entry
3198 ntStatus = AFSUpdateMetaData( DirEntry,
3201 if( NT_SUCCESS( ntStatus))
3204 ClearFlag( pObjectInfo->Flags, AFS_OBJECT_FLAGS_VERIFY);
3212 AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
3213 AFS_TRACE_LEVEL_WARNING,
3214 "AFSVerifyEntry Attempt to verify node of type %d %wZ FID %08lX-%08lX-%08lX-%08lX\n",
3215 pObjectInfo->FileType,
3216 &DirEntry->NameInformation.FileName,
3217 pObjectInfo->FileId.Cell,
3218 pObjectInfo->FileId.Volume,
3219 pObjectInfo->FileId.Vnode,
3220 pObjectInfo->FileId.Unique);
3227 if( pDirEnumEntry != NULL)
3230 AFSExFreePoolWithTag( pDirEnumEntry, AFS_GENERIC_MEMORY_2_TAG);
3238 AFSSetVolumeState( IN AFSVolumeStatusCB *VolumeStatus)