sizeof( AFSDeviceExt),
pFsRtlRegisterUncProviderEx ? NULL : &uniDeviceName,
FILE_DEVICE_NETWORK_FILE_SYSTEM,
- FILE_REMOTE_DEVICE,
+ FILE_DEVICE_SECURE_OPEN | FILE_REMOTE_DEVICE,
FALSE,
&AFSRDRDeviceObject);
if( !NT_SUCCESS( ntStatus))
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_INIT_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_INIT_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
"AFSInitRDRDevice IoCreateDevice failure %08lX\n",
- ntStatus);
+ ntStatus));
try_return( ntStatus);
}
if ( !NT_SUCCESS(ntStatus))
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_INIT_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_INIT_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
"AFSInitRDRDevice AFSInitRdrFcb failure %08lX\n",
- ntStatus);
+ ntStatus));
try_return( ntStatus);
}
AFSRDRDeviceObject->Flags &= ~DO_DEVICE_INITIALIZING;
//
+ // Increase the StackSize to support the extra stack frame required
+ // for use of IoCompletion routines.
+ //
+
+ AFSRDRDeviceObject->StackSize++;
+
+ //
// Register this device with MUP with FilterMgr if Vista or above
//
0);
if ( !NT_SUCCESS( ntStatus))
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_INIT_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_INIT_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
"AFSInitRDRDevice FsRtlRegisterUncProvider failure %08lX\n",
- ntStatus);
+ ntStatus));
}
}
else
}
else
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_INIT_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_INIT_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
"AFSInitRDRDevice FsRtlRegisterUncProvider failure %08lX\n",
- ntStatus);
+ ntStatus));
}
}
if( !NT_SUCCESS( ntStatus))
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_INIT_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_INIT_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
"AFSInitializeRedirector AFSLoadLibrary failure %08lX\n",
- ntStatus);
+ ntStatus));
try_return( ntStatus);
}
if( AFSDumpFileLocation.Buffer == NULL)
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_INIT_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_INIT_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSInitializeRedirector AFS_GENERIC_MEMORY_23_TAG allocation error\n");
+ "AFSInitializeRedirector AFS_GENERIC_MEMORY_23_TAG allocation error\n"));
try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
}
SetFlag( pDevExt->DeviceFlags, AFS_DEVICE_FLAG_DISABLE_SHORTNAMES);
}
- if( RedirInitInfo->MemoryCacheOffset.QuadPart != 0 &&
- RedirInitInfo->MemoryCacheLength.QuadPart != 0)
+ //
+ // Are we performing direct to service IO?
+ //
+
+ if( BooleanFlagOn( RedirInitInfo->Flags, AFS_REDIR_INIT_PERFORM_SERVICE_IO))
{
- ntStatus = STATUS_INSUFFICIENT_RESOURCES;
+ //
+ // Send IO requests directly to service
+ //
-#ifdef AMD64
- pDevExt->Specific.RDR.CacheMdl = MmCreateMdl( NULL,
- (void *)RedirInitInfo->MemoryCacheOffset.QuadPart,
- RedirInitInfo->MemoryCacheLength.QuadPart);
-#else
- pDevExt->Specific.RDR.CacheMdl = MmCreateMdl( NULL,
- (void *)RedirInitInfo->MemoryCacheOffset.LowPart,
- RedirInitInfo->MemoryCacheLength.LowPart);
-#endif
+ SetFlag( pDevExt->DeviceFlags, AFS_DEVICE_FLAG_DIRECT_SERVICE_IO);
+ }
+ else
+ {
- if( pDevExt->Specific.RDR.CacheMdl != NULL)
+ if( RedirInitInfo->MemoryCacheOffset.QuadPart != 0 &&
+ RedirInitInfo->MemoryCacheLength.QuadPart != 0)
{
- __try
- {
+ ntStatus = STATUS_INSUFFICIENT_RESOURCES;
- MmProbeAndLockPages( pDevExt->Specific.RDR.CacheMdl,
- KernelMode,
- IoModifyAccess);
+#ifdef AMD64
+ pDevExt->Specific.RDR.CacheMdl = MmCreateMdl( NULL,
+ (void *)RedirInitInfo->MemoryCacheOffset.QuadPart,
+ RedirInitInfo->MemoryCacheLength.QuadPart);
+#else
+ pDevExt->Specific.RDR.CacheMdl = MmCreateMdl( NULL,
+ (void *)RedirInitInfo->MemoryCacheOffset.LowPart,
+ RedirInitInfo->MemoryCacheLength.LowPart);
+#endif
- pDevExt->Specific.RDR.CacheBaseAddress = MmGetSystemAddressForMdlSafe( pDevExt->Specific.RDR.CacheMdl,
- NormalPagePriority);
- }
- __except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()) )
+ if( pDevExt->Specific.RDR.CacheMdl != NULL)
{
- AFSDumpTraceFilesFnc();
-
- IoFreeMdl( pDevExt->Specific.RDR.CacheMdl);
- pDevExt->Specific.RDR.CacheMdl = NULL;
- }
+ __try
+ {
- if( pDevExt->Specific.RDR.CacheMdl != NULL)
- {
- pDevExt->Specific.RDR.CacheLength = RedirInitInfo->MemoryCacheLength;
- ntStatus = STATUS_SUCCESS;
- }
+ MmProbeAndLockPages( pDevExt->Specific.RDR.CacheMdl,
+ KernelMode,
+ IoModifyAccess);
- }
- }
+ pDevExt->Specific.RDR.CacheBaseAddress = MmGetSystemAddressForMdlSafe( pDevExt->Specific.RDR.CacheMdl,
+ NormalPagePriority);
+ }
+ __except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()) )
+ {
- if( !NT_SUCCESS( ntStatus) &&
- RedirInitInfo->CacheFileNameLength == 0)
- {
+ AFSDumpTraceFilesFnc();
- AFSDbgLogMsg( AFS_SUBSYSTEM_INIT_PROCESSING,
- AFS_TRACE_LEVEL_ERROR,
- "AFSInitializeRedirector Unable to initialize cache file %08lX\n",
- ntStatus);
+ IoFreeMdl( pDevExt->Specific.RDR.CacheMdl);
+ pDevExt->Specific.RDR.CacheMdl = NULL;
+ }
- try_return( ntStatus);
- }
+ if( pDevExt->Specific.RDR.CacheMdl != NULL)
+ {
+ pDevExt->Specific.RDR.CacheLength = RedirInitInfo->MemoryCacheLength;
+ ntStatus = STATUS_SUCCESS;
+ }
- if( pDevExt->Specific.RDR.CacheMdl == NULL)
- {
+ }
+ }
- if( RedirInitInfo->CacheFileNameLength == 0)
+ if( !NT_SUCCESS( ntStatus) &&
+ RedirInitInfo->CacheFileNameLength == 0)
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_INIT_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_INIT_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSInitializeRedirector CacheMdl == NULL\n");
+ "AFSInitializeRedirector Unable to initialize cache file %08lX\n",
+ ntStatus));
- try_return( ntStatus = STATUS_INVALID_PARAMETER);
+ try_return( ntStatus);
}
- //
- // Go open the cache file
- //
+ if( pDevExt->Specific.RDR.CacheMdl == NULL)
+ {
- pDevExt->Specific.RDR.CacheFile.Length = 0;
- pDevExt->Specific.RDR.CacheFile.MaximumLength = (USHORT)RedirInitInfo->CacheFileNameLength + (4 * sizeof( WCHAR));
+ if( RedirInitInfo->CacheFileNameLength == 0)
+ {
- pDevExt->Specific.RDR.CacheFile.Buffer = (WCHAR *)AFSExAllocatePoolWithTag( PagedPool,
- pDevExt->Specific.RDR.CacheFile.MaximumLength,
- AFS_GENERIC_MEMORY_24_TAG);
+ AFSDbgTrace(( AFS_SUBSYSTEM_INIT_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSInitializeRedirector CacheMdl == NULL\n"));
- if( pDevExt->Specific.RDR.CacheFile.Buffer == NULL)
- {
+ try_return( ntStatus = STATUS_INVALID_PARAMETER);
+ }
- AFSDbgLogMsg( AFS_SUBSYSTEM_INIT_PROCESSING,
- AFS_TRACE_LEVEL_ERROR,
- "AFSInitializeRedirector AFS_GENERIC_MEMORY_24_TAG allocation failure\n");
+ //
+ // Go open the cache file
+ //
- try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
- }
+ pDevExt->Specific.RDR.CacheFile.Length = 0;
+ pDevExt->Specific.RDR.CacheFile.MaximumLength = (USHORT)RedirInitInfo->CacheFileNameLength + (4 * sizeof( WCHAR));
- RtlCopyMemory( pDevExt->Specific.RDR.CacheFile.Buffer,
- L"\\??\\",
- 4 * sizeof( WCHAR));
+ pDevExt->Specific.RDR.CacheFile.Buffer = (WCHAR *)AFSExAllocatePoolWithTag( PagedPool,
+ pDevExt->Specific.RDR.CacheFile.MaximumLength,
+ AFS_GENERIC_MEMORY_24_TAG);
- pDevExt->Specific.RDR.CacheFile.Length = 4 * sizeof( WCHAR);
+ if( pDevExt->Specific.RDR.CacheFile.Buffer == NULL)
+ {
- RtlCopyMemory( &pDevExt->Specific.RDR.CacheFile.Buffer[ pDevExt->Specific.RDR.CacheFile.Length/sizeof( WCHAR)],
- RedirInitInfo->CacheFileName,
- RedirInitInfo->CacheFileNameLength);
+ AFSDbgTrace(( AFS_SUBSYSTEM_INIT_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSInitializeRedirector AFS_GENERIC_MEMORY_24_TAG allocation failure\n"));
- pDevExt->Specific.RDR.CacheFile.Length += (USHORT)RedirInitInfo->CacheFileNameLength;
+ try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
+ }
- InitializeObjectAttributes( &stObjectAttribs,
- &pDevExt->Specific.RDR.CacheFile,
- OBJ_KERNEL_HANDLE | OBJ_CASE_INSENSITIVE,
- NULL,
- NULL);
+ RtlCopyMemory( pDevExt->Specific.RDR.CacheFile.Buffer,
+ L"\\??\\",
+ 4 * sizeof( WCHAR));
- ntStatus = ZwOpenFile( &pDevExt->Specific.RDR.CacheFileHandle,
- GENERIC_READ | GENERIC_WRITE,
- &stObjectAttribs,
- &stIoStatus,
- FILE_SHARE_READ | FILE_SHARE_WRITE,
- FILE_WRITE_THROUGH | FILE_RANDOM_ACCESS);
+ pDevExt->Specific.RDR.CacheFile.Length = 4 * sizeof( WCHAR);
- if( !NT_SUCCESS( ntStatus))
- {
+ RtlCopyMemory( &pDevExt->Specific.RDR.CacheFile.Buffer[ pDevExt->Specific.RDR.CacheFile.Length/sizeof( WCHAR)],
+ RedirInitInfo->CacheFileName,
+ RedirInitInfo->CacheFileNameLength);
- AFSDbgLogMsg( AFS_SUBSYSTEM_INIT_PROCESSING,
- AFS_TRACE_LEVEL_ERROR,
- "AFSInitializeRedirector ZwOpenFile failure %08lX\n",
- ntStatus);
+ pDevExt->Specific.RDR.CacheFile.Length += (USHORT)RedirInitInfo->CacheFileNameLength;
- try_return( ntStatus);
- }
+ InitializeObjectAttributes( &stObjectAttribs,
+ &pDevExt->Specific.RDR.CacheFile,
+ OBJ_KERNEL_HANDLE | OBJ_CASE_INSENSITIVE,
+ NULL,
+ NULL);
- //
- // Map to the fileobject
- //
+ ntStatus = ZwOpenFile( &pDevExt->Specific.RDR.CacheFileHandle,
+ GENERIC_READ | GENERIC_WRITE,
+ &stObjectAttribs,
+ &stIoStatus,
+ FILE_SHARE_READ | FILE_SHARE_WRITE,
+ FILE_WRITE_THROUGH | FILE_RANDOM_ACCESS);
- ntStatus = ObReferenceObjectByHandle( pDevExt->Specific.RDR.CacheFileHandle,
- SYNCHRONIZE,
- NULL,
- KernelMode,
- (void **)&pDevExt->Specific.RDR.CacheFileObject,
- NULL);
+ if( !NT_SUCCESS( ntStatus))
+ {
- if( !NT_SUCCESS( ntStatus))
- {
+ AFSDbgTrace(( AFS_SUBSYSTEM_INIT_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSInitializeRedirector ZwOpenFile failure %08lX\n",
+ ntStatus));
- AFSDbgLogMsg( AFS_SUBSYSTEM_INIT_PROCESSING,
- AFS_TRACE_LEVEL_ERROR,
- "AFSInitializeRedirector ObReferenceObjectByHandle failure %08lX\n",
- ntStatus);
+ try_return( ntStatus);
+ }
- try_return( ntStatus);
+ //
+ // Map to the fileobject
+ //
+
+ ntStatus = ObReferenceObjectByHandle( pDevExt->Specific.RDR.CacheFileHandle,
+ SYNCHRONIZE,
+ NULL,
+ KernelMode,
+ (void **)&pDevExt->Specific.RDR.CacheFileObject,
+ NULL);
+
+ if( !NT_SUCCESS( ntStatus))
+ {
+
+ AFSDbgTrace(( AFS_SUBSYSTEM_INIT_PROCESSING,
+ AFS_TRACE_LEVEL_ERROR,
+ "AFSInitializeRedirector ObReferenceObjectByHandle failure %08lX\n",
+ ntStatus));
+
+ try_return( ntStatus);
+ }
}
}
if ( !NT_SUCCESS( ntStatus))
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_INIT_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_INIT_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
"AFSInitializeRedirector AFSInitializeLibrary failure %08lX\n",
- ntStatus);
+ ntStatus));
}
try_exit:
if( pFcb == NULL)
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSInitRdrFcb Failed to allocate the root fcb\n");
+ "AFSInitRdrFcb Failed to allocate the root fcb\n"));
try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
}
if( pNPFcb == NULL)
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSInitRdrFcb Failed to allocate the non-paged fcb\n");
+ "AFSInitRdrFcb Failed to allocate the non-paged fcb\n"));
try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
}
ExInitializeResourceLite( &pNPFcb->Resource);
- AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSInitRootFcb Acquiring Fcb lock %08lX EXCL %08lX\n",
+ "AFSInitRootFcb Acquiring Fcb lock %p EXCL %08lX\n",
&pNPFcb->Resource,
- PsGetCurrentThread());
+ PsGetCurrentThread()));
ExInitializeResourceLite( &pNPFcb->PagingResource);
git://git.openafs.org / openafs.git / blobdiff