/*
* Copyright (c) 2008, 2009, 2010, 2011 Kernel Drivers, LLC.
- * Copyright (c) 2009, 2010, 2011 Your File System, Inc.
+ * Copyright (c) 2009, 2010, 2011, 2012, 2013 Your File System, Inc.
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* - Redistributions of source code must retain the above copyright notice,
* this list of conditions and the following disclaimer.
* - Redistributions in binary form must reproduce the above copyright
- * notice,
- * this list of conditions and the following disclaimer in the
- * documentation
- * and/or other materials provided with the distribution.
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
* - Neither the names of Kernel Drivers, LLC and Your File System, Inc.
* nor the names of their contributors may be used to endorse or promote
* products derived from this software without specific prior written
if( pCurrentWorker == NULL)
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSInitializeWorkerPool Failed to allocate worker context\n");
+ "AFSInitializeWorkerPool Failed to allocate worker context\n"));
ntStatus = STATUS_INSUFFICIENT_RESOURCES;
if( !NT_SUCCESS( ntStatus))
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSInitializeWorkerPool Failed to initialize worker thread Status %08lX\n", ntStatus);
+ "AFSInitializeWorkerPool Failed to initialize worker thread Status %08lX\n",
+ ntStatus));
ExFreePool( pCurrentWorker);
if( pCurrentWorker == NULL)
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSInitializeWorkerPool Failed to allocate IO worker context\n");
+ "AFSInitializeWorkerPool Failed to allocate IO worker context\n"));
ntStatus = STATUS_INSUFFICIENT_RESOURCES;
if( !NT_SUCCESS( ntStatus))
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSInitializeWorkerPool Failed to initialize IO worker thread Status %08lX\n", ntStatus);
+ "AFSInitializeWorkerPool Failed to initialize IO worker thread Status %08lX\n",
+ ntStatus));
ExFreePool( pCurrentWorker);
if( !NT_SUCCESS( ntStatus))
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSWorkerThread Wait for queue items failed Status %08lX\n", ntStatus);
+ "AFSWorkerThread Wait for queue items failed Status %08lX\n",
+ ntStatus));
ntStatus = STATUS_SUCCESS;
}
default:
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSWorkerThread Unknown request type %d\n", pWorkItem->RequestType);
+ "AFSWorkerThread Unknown request type %d\n",
+ pWorkItem->RequestType));
break;
}
if( !NT_SUCCESS( ntStatus))
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSIOWorkerThread Wait for queue items failed Status %08lX\n", ntStatus);
+ "AFSIOWorkerThread Wait for queue items failed Status %08lX\n",
+ ntStatus));
ntStatus = STATUS_SUCCESS;
}
default:
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSIOWorkerThread Unknown request type %d\n", pWorkItem->RequestType);
+ "AFSIOWorkerThread Unknown request type %d\n",
+ pWorkItem->RequestType));
break;
}
pCurrentChildObject = pCurrentDirEntry->ObjectInformation;
- AFSDbgLogMsg( AFS_SUBSYSTEM_CLEANUP_PROCESSING | AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_CLEANUP_PROCESSING | AFS_SUBSYSTEM_DIRENTRY_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSExamineDirectory Deleting DE %wZ Object %p\n",
&pCurrentDirEntry->NameInformation.FileName,
- pCurrentChildObject);
+ pCurrentChildObject));
AFSDeleteDirEntry( pCurrentObject,
pCurrentDirEntry);
lCount = AFSObjectInfoIncrement( pCurrentChildObject,
AFS_OBJECT_REFERENCE_WORKER);
- AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSExamineDirectory Increment count on object %p Cnt %d\n",
pCurrentChildObject,
- lCount);
+ lCount));
if( lCount == 1 &&
pCurrentChildObject->Fcb != NULL &&
lCount = AFSObjectInfoDecrement( pCurrentChildObject,
AFS_OBJECT_REFERENCE_WORKER);
- AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSExamineDirectory Decrement1 count on object %p Cnt %d\n",
pCurrentChildObject,
- lCount);
+ lCount));
if( lCount == 0 &&
pCurrentChildObject->Fcb != NULL &&
AFSExFreePoolWithTag( pCurrentChildObject->Specific.Directory.PIOCtlDirectoryCB->NonPaged, AFS_DIR_ENTRY_NP_TAG);
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
+ AFSDbgTrace(( AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
AFS_TRACE_LEVEL_VERBOSE,
"AFSExamineDirectory (pioctl) AFS_DIR_ENTRY_TAG deallocating %p\n",
- pCurrentChildObject->Specific.Directory.PIOCtlDirectoryCB);
+ pCurrentChildObject->Specific.Directory.PIOCtlDirectoryCB));
AFSExFreePoolWithTag( pCurrentChildObject->Specific.Directory.PIOCtlDirectoryCB, AFS_DIR_ENTRY_TAG);
}
AFSReleaseResource( &pCurrentChildObject->NonPagedInfo->ObjectInfoLock);
- AFSDbgLogMsg( AFS_SUBSYSTEM_CLEANUP_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_CLEANUP_PROCESSING | AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSExamineDirectory Deleting object %p\n",
- pCurrentChildObject);
+ pCurrentChildObject));
AFSDeleteObjectInfo( &pCurrentChildObject);
}
//
if( BooleanFlagOn( pCurrentObject->Flags, AFS_OBJECT_FLAGS_DELETED) &&
- pCurrentObject->ObjectReferenceCount <= 0 &&
+ pCurrentObject->ObjectReferenceCount == 0 &&
( pCurrentObject->Fcb == NULL ||
pCurrentObject->Fcb->OpenReferenceCount == 0) &&
pCurrentObject->Specific.Directory.DirectoryNodeListHead == NULL &&
AFSAcquireExcl( &pCurrentObject->NonPagedInfo->ObjectInfoLock,
TRUE);
- if ( pCurrentObject->ObjectReferenceCount <= 0)
+ if ( pCurrentObject->ObjectReferenceCount == 0)
{
AFSRemoveFcb( &pCurrentObject->Fcb);
AFSExFreePoolWithTag( pCurrentChildObject->Specific.Directory.PIOCtlDirectoryCB->NonPaged, AFS_DIR_ENTRY_NP_TAG);
- AFSDbgLogMsg( AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
+ AFSDbgTrace(( AFS_SUBSYSTEM_DIRENTRY_ALLOCATION,
AFS_TRACE_LEVEL_VERBOSE,
"AFSExamineObjectInfo (pioctl) AFS_DIR_ENTRY_TAG deallocating %p\n",
- pCurrentObject->Specific.Directory.PIOCtlDirectoryCB);
+ pCurrentObject->Specific.Directory.PIOCtlDirectoryCB));
AFSExFreePoolWithTag( pCurrentObject->Specific.Directory.PIOCtlDirectoryCB, AFS_DIR_ENTRY_TAG);
}
AFSReleaseResource( &pCurrentObject->NonPagedInfo->ObjectInfoLock);
- AFSDbgLogMsg( AFS_SUBSYSTEM_CLEANUP_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_CLEANUP_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSExamineObjectInfo Deleting deleted object %p\n",
- pCurrentObject);
+ pCurrentObject));
AFSDeleteObjectInfo( &pCurrentObject);
}
if ( pCcb->NameArray) {
- AFSDbgLogMsg( AFS_SUBSYSTEM_CLEANUP_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_CLEANUP_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSExamineObjectInfo Found Object %p Fcb %p Ccb %p\n",
pCurrentObject,
pCurrentObject->Fcb,
- pCcb);
+ pCcb));
}
}
lCount = AFSObjectInfoIncrement( pCurrentObject,
AFS_OBJECT_REFERENCE_WORKER);
- AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSExamineObjectInfo Increment3 count on object %p Cnt %d\n",
pCurrentObject,
- lCount);
+ lCount));
AFSReleaseResource( pVolumeCB->ObjectInfoTree.TreeLock);
lCount = AFSObjectInfoDecrement( pCurrentObject,
AFS_OBJECT_REFERENCE_WORKER);
- AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSExamineObjectInfo Decrement3 count on object %p Cnt %d\n",
pCurrentObject,
- lCount);
-
+ lCount));
if ( bTemp == FALSE)
{
lCount = AFSObjectInfoIncrement( pNextObject,
AFS_OBJECT_REFERENCE_WORKER);
- AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSExamineVolume Increment count on object %p Cnt %d\n",
pNextObject,
- lCount);
+ lCount));
}
}
else
lCount = AFSObjectInfoDecrement( pNextObject,
AFS_OBJECT_REFERENCE_WORKER);
- AFSDbgLogMsg( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_OBJECT_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSExamineVolume Decrement count on object %p Cnt %d\n",
pNextObject,
- lCount);
+ lCount));
}
//
BOOLEAN bFcbBusy = FALSE;
LONG lCount;
- AFSDbgLogMsg( AFS_SUBSYSTEM_CLEANUP_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_CLEANUP_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSPrimaryVolumeWorkerThread Initialized\n");
+ "AFSPrimaryVolumeWorkerThread Initialized\n"));
//
// Initialize the timer for the worker thread
ClearFlag( pPoolContext->State, AFS_WORKER_INITIALIZED);
- AFSDbgLogMsg( AFS_SUBSYSTEM_CLEANUP_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_CLEANUP_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
- "AFSPrimaryVolumeWorkerThread Exiting\n");
+ "AFSPrimaryVolumeWorkerThread Exiting\n"));
lCount = InterlockedDecrement( &pControlDeviceExt->Specific.Control.VolumeWorkerThreadCount);
pControlDevExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
- AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSInsertWorkitem Acquiring Control QueueLock lock %p EXCL %08lX\n",
&pControlDevExt->Specific.Control.QueueLock,
- PsGetCurrentThread());
+ PsGetCurrentThread()));
AFSAcquireExcl( &pControlDevExt->Specific.Control.QueueLock,
TRUE);
lCount = InterlockedIncrement( &pControlDevExt->Specific.Control.QueueItemCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSInsertWorkitem Inserting work item %p Count %d\n",
WorkItem,
- lCount);
+ lCount));
if( pControlDevExt->Specific.Control.QueueTail != NULL) // queue already has nodes
{
pControlDevExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
- AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSInsertIOWorkitem Acquiring Control QueueLock lock %p EXCL %08lX\n",
&pControlDevExt->Specific.Control.IOQueueLock,
- PsGetCurrentThread());
+ PsGetCurrentThread()));
AFSAcquireExcl( &pControlDevExt->Specific.Control.IOQueueLock,
TRUE);
lCount = InterlockedIncrement( &pControlDevExt->Specific.Control.IOQueueItemCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSInsertWorkitem Inserting IO work item %p Count %d\n",
WorkItem,
- lCount);
+ lCount));
if( pControlDevExt->Specific.Control.IOQueueTail != NULL) // queue already has nodes
{
pControlDevExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
- AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSInsertWorkitemAtHead Acquiring Control QueueLock lock %p EXCL %08lX\n",
&pControlDevExt->Specific.Control.QueueLock,
- PsGetCurrentThread());
+ PsGetCurrentThread()));
AFSAcquireExcl( &pControlDevExt->Specific.Control.QueueLock,
TRUE);
lCount = InterlockedIncrement( &pControlDevExt->Specific.Control.QueueItemCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSInsertWorkitemAtHead Inserting work item %p Count %d\n",
WorkItem,
- lCount);
+ lCount));
//
// indicate that the queue has nodes
pControlDevExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
- AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSRemoveWorkItem Acquiring Control QueueLock lock %p EXCL %08lX\n",
&pControlDevExt->Specific.Control.QueueLock,
- PsGetCurrentThread());
+ PsGetCurrentThread()));
AFSAcquireExcl( &pControlDevExt->Specific.Control.QueueLock,
TRUE);
lCount = InterlockedDecrement( &pControlDevExt->Specific.Control.QueueItemCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSRemoveWorkItem Removing work item %p Count %d Thread %08lX\n",
pWorkItem,
lCount,
- PsGetCurrentThreadId());
+ PsGetCurrentThreadId()));
pControlDevExt->Specific.Control.QueueHead = pControlDevExt->Specific.Control.QueueHead->next;
pControlDevExt = (AFSDeviceExt *)AFSControlDeviceObject->DeviceExtension;
- AFSDbgLogMsg( AFS_SUBSYSTEM_LOCK_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_LOCK_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSRemoveIOWorkItem Acquiring Control QueueLock lock %p EXCL %08lX\n",
&pControlDevExt->Specific.Control.IOQueueLock,
- PsGetCurrentThread());
+ PsGetCurrentThread()));
AFSAcquireExcl( &pControlDevExt->Specific.Control.IOQueueLock,
TRUE);
lCount = InterlockedDecrement( &pControlDevExt->Specific.Control.IOQueueItemCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSRemoveWorkItem Removing work item %p Count %d Thread %08lX\n",
pWorkItem,
lCount,
- PsGetCurrentThreadId());
+ PsGetCurrentThreadId()));
pControlDevExt->Specific.Control.IOQueueHead = pControlDevExt->Specific.Control.IOQueueHead->next;
__try
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSQueueFlushExtents Queuing request for FID %08lX-%08lX-%08lX-%08lX\n",
Fcb->ObjectInformation->FileId.Cell,
Fcb->ObjectInformation->FileId.Volume,
Fcb->ObjectInformation->FileId.Vnode,
- Fcb->ObjectInformation->FileId.Unique);
+ Fcb->ObjectInformation->FileId.Unique));
//
// Increment our flush count here just to keep the number of items in the
if( lCount > 3)
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSQueueFlushExtents Max queued items for FID %08lX-%08lX-%08lX-%08lX\n",
Fcb->ObjectInformation->FileId.Cell,
Fcb->ObjectInformation->FileId.Volume,
Fcb->ObjectInformation->FileId.Vnode,
- Fcb->ObjectInformation->FileId.Unique);
+ Fcb->ObjectInformation->FileId.Unique));
try_return( ntStatus);
}
if( BooleanFlagOn( pRDRDeviceExt->DeviceFlags, AFS_DEVICE_FLAG_REDIRECTOR_SHUTDOWN))
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSQueueFlushExtents Failing request, in shutdown\n");
+ "AFSQueueFlushExtents Failing request, in shutdown\n"));
try_return( ntStatus = STATUS_TOO_LATE);
}
// Allocate our request structure and send it to the worker
//
- pWorkItem = (AFSWorkItem *)AFSLibExAllocatePoolWithTag( NonPagedPool,
- sizeof( AFSWorkItem),
- AFS_WORK_ITEM_TAG);
+ pWorkItem = (AFSWorkItem *)AFSExAllocatePoolWithTag( NonPagedPool,
+ sizeof( AFSWorkItem),
+ AFS_WORK_ITEM_TAG);
if( pWorkItem == NULL)
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSQueueFlushExtents Failed to allocate work item\n");
+ "AFSQueueFlushExtents Failed to allocate work item\n"));
try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
}
lCount = InterlockedIncrement( &Fcb->OpenReferenceCount);
- AFSDbgLogMsg( AFS_SUBSYSTEM_FCB_REF_COUNTING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FCB_REF_COUNTING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSQueueFlushExtents Increment count on Fcb %p Cnt %d\n",
Fcb,
- lCount);
+ lCount));
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSQueueFlushExtents Workitem %p for FID %08lX-%08lX-%08lX-%08lX\n",
pWorkItem,
Fcb->ObjectInformation->FileId.Cell,
Fcb->ObjectInformation->FileId.Volume,
Fcb->ObjectInformation->FileId.Vnode,
- Fcb->ObjectInformation->FileId.Unique);
+ Fcb->ObjectInformation->FileId.Unique));
ntStatus = AFSQueueWorkerRequest( pWorkItem);
try_exit:
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSQueueFlushExtents Request complete Status %08lX FID %08lX-%08lX-%08lX-%08lX\n",
Fcb->ObjectInformation->FileId.Cell,
Fcb->ObjectInformation->FileId.Volume,
Fcb->ObjectInformation->FileId.Vnode,
Fcb->ObjectInformation->FileId.Unique,
- ntStatus);
+ ntStatus));
//
// Remove the count we added above
ExFreePoolWithTag( pWorkItem, AFS_WORK_ITEM_TAG);
}
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSQueueFlushExtents Failed to queue request Status %08lX\n", ntStatus);
+ "AFSQueueFlushExtents Failed to queue request Status %08lX\n",
+ ntStatus));
}
}
__except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()) )
{
- AFSDbgLogMsg( 0,
+ AFSDbgTrace(( 0,
0,
- "EXCEPTION - AFSQueueFlushExtents\n");
+ "EXCEPTION - AFSQueueFlushExtents\n"));
AFSDumpTraceFilesFnc();
}
__try
{
- pWorkItem = (AFSWorkItem *) AFSLibExAllocatePoolWithTag( NonPagedPool,
- sizeof(AFSWorkItem),
- AFS_WORK_ITEM_TAG);
+ pWorkItem = (AFSWorkItem *) AFSExAllocatePoolWithTag( NonPagedPool,
+ sizeof(AFSWorkItem),
+ AFS_WORK_ITEM_TAG);
if (NULL == pWorkItem)
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_IO_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_IO_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSQueueGlobalRootEnumeration Failed to allocate work item\n");
+ "AFSQueueGlobalRootEnumeration Failed to allocate work item\n"));
try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES );
}
pWorkItem->RequestType = AFS_WORK_ENUMERATE_GLOBAL_ROOT;
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSQueueGlobalRootEnumeration Workitem %p\n",
- pWorkItem);
+ pWorkItem));
ntStatus = AFSQueueWorkerRequest( pWorkItem);
try_exit:
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSQueueGlobalRootEnumeration Request complete Status %08lX\n",
- ntStatus);
+ ntStatus));
if( !NT_SUCCESS( ntStatus))
{
ExFreePoolWithTag( pWorkItem, AFS_WORK_ITEM_TAG);
}
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
"AFSQueueGlobalRootEnumeration Failed to queue request Status %08lX\n",
- ntStatus);
+ ntStatus));
}
}
__except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()) )
{
- AFSDbgLogMsg( 0,
+ AFSDbgTrace(( 0,
0,
- "EXCEPTION - AFSQueueGlobalRootEnumeration\n");
+ "EXCEPTION - AFSQueueGlobalRootEnumeration\n"));
AFSDumpTraceFilesFnc();
}
if( BooleanFlagOn( pRDRDeviceExt->DeviceFlags, AFS_DEVICE_FLAG_REDIRECTOR_SHUTDOWN))
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSQueueStartIos Failing request, in shutdown\n");
+ "AFSQueueStartIos Failing request, in shutdown\n"));
try_return( ntStatus = STATUS_TOO_LATE);
}
// Allocate our request structure and send it to the worker
//
- pWorkItem = (AFSWorkItem *)AFSLibExAllocatePoolWithTag( NonPagedPool,
- sizeof( AFSWorkItem),
- AFS_WORK_ITEM_TAG);
+ pWorkItem = (AFSWorkItem *)AFSExAllocatePoolWithTag( NonPagedPool,
+ sizeof( AFSWorkItem),
+ AFS_WORK_ITEM_TAG);
if( pWorkItem == NULL)
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSQueueStartIos Failed to allocate work item\n");
+ "AFSQueueStartIos Failed to allocate work item\n"));
try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES);
}
pWorkItem->Specific.CacheAccess.GatherIo = GatherIo;
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSQueueStartIos Queuing IO Workitem %p\n",
- pWorkItem);
+ pWorkItem));
ntStatus = AFSQueueIOWorkerRequest( pWorkItem);
try_exit:
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSQueueStartIos Request complete Status %08lX\n",
- ntStatus);
+ ntStatus));
if( !NT_SUCCESS( ntStatus))
{
__except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()) )
{
- AFSDbgLogMsg( 0,
+ AFSDbgTrace(( 0,
0,
- "EXCEPTION - AFSQueueStartIos\n");
+ "EXCEPTION - AFSQueueStartIos\n"));
AFSDumpTraceFilesFnc();
}
__try
{
- pWorkItem = (AFSWorkItem *) AFSLibExAllocatePoolWithTag( NonPagedPool,
- sizeof(AFSWorkItem),
- AFS_WORK_ITEM_TAG);
+ pWorkItem = (AFSWorkItem *) AFSExAllocatePoolWithTag( NonPagedPool,
+ sizeof(AFSWorkItem),
+ AFS_WORK_ITEM_TAG);
if (NULL == pWorkItem)
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_IO_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_IO_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
- "AFSQueueInvalidateObject Failed to allocate work item\n");
+ "AFSQueueInvalidateObject Failed to allocate work item\n"));
try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES );
}
pWorkItem->Specific.Invalidate.InvalidateReason = InvalidateReason;
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSQueueInvalidateObject Workitem %p\n",
- pWorkItem);
+ pWorkItem));
ntStatus = AFSQueueWorkerRequest( pWorkItem);
try_exit:
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"AFSQueueInvalidateObject Request complete Status %08lX\n",
- ntStatus);
+ ntStatus));
if( !NT_SUCCESS( ntStatus))
{
ExFreePoolWithTag( pWorkItem, AFS_WORK_ITEM_TAG);
}
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
"AFSQueueInvalidateObject Failed to queue request Status %08lX\n",
- ntStatus);
+ ntStatus));
}
}
__except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()) )
{
- AFSDbgLogMsg( 0,
+ AFSDbgTrace(( 0,
0,
- "EXCEPTION - AFSQueueInvalidateObject\n");
+ "EXCEPTION - AFSQueueInvalidateObject\n"));
AFSDumpTraceFilesFnc();
}
if ( NULL == AFSLockSystemBuffer( Irp, BytesToWrite ))
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_IO_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_IO_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
"%s Could not pin user memory item\n",
- __FUNCTION__);
+ __FUNCTION__));
try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES );
}
- pWorkItem = (AFSWorkItem *) AFSLibExAllocatePoolWithTag( NonPagedPool,
- sizeof(AFSWorkItem),
- AFS_WORK_ITEM_TAG);
+ pWorkItem = (AFSWorkItem *) AFSExAllocatePoolWithTag( NonPagedPool,
+ sizeof(AFSWorkItem),
+ AFS_WORK_ITEM_TAG);
if (NULL == pWorkItem)
{
- AFSDbgLogMsg( AFS_SUBSYSTEM_IO_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_IO_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
"%s Failed to allocate work item\n",
- __FUNCTION__);
+ __FUNCTION__));
try_return( ntStatus = STATUS_INSUFFICIENT_RESOURCES );
}
pWorkItem->Specific.AsynchIo.Irp = Irp;
- AFSDbgLogMsg( AFS_SUBSYSTEM_IO_PROCESSING | AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_IO_PROCESSING | AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"%s Workitem %p\n",
__FUNCTION__,
- pWorkItem);
+ pWorkItem));
CcDeferWrite( FileObject, AFSPostedDeferredWrite, pWorkItem, NULL, BytesToWrite, bRetrying);
__except( AFSExceptionFilter( __FUNCTION__, GetExceptionCode(), GetExceptionInformation()) )
{
- AFSDbgLogMsg( 0,
+ AFSDbgTrace(( 0,
0,
"EXCEPTION - %s \n",
- __FUNCTION__);
+ __FUNCTION__));
ntStatus = GetExceptionCode();
}
try_exit:
- AFSDbgLogMsg( AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_VERBOSE,
"%s complete Status %08lX\n",
__FUNCTION__,
- ntStatus);
+ ntStatus));
if( !NT_SUCCESS( ntStatus))
{
ExFreePoolWithTag( pWorkItem, AFS_WORK_ITEM_TAG);
}
- AFSDbgLogMsg( AFS_SUBSYSTEM_FILE_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_FILE_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
"%s Failed to queue request Status %08lX\n",
__FUNCTION__,
- ntStatus);
+ ntStatus));
}
return ntStatus;
AFSWorkItem *pWorkItem = (AFSWorkItem *) Context1;
- AFSDbgLogMsg( AFS_SUBSYSTEM_IO_PROCESSING | AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_IO_PROCESSING | AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
"%s Workitem %p\n",
__FUNCTION__,
- pWorkItem);
+ pWorkItem));
ntStatus = AFSQueueIOWorkerRequest( pWorkItem);
ExFreePoolWithTag( pWorkItem, AFS_WORK_ITEM_TAG);
- AFSDbgLogMsg( AFS_SUBSYSTEM_IO_PROCESSING | AFS_SUBSYSTEM_WORKER_PROCESSING,
+ AFSDbgTrace(( AFS_SUBSYSTEM_IO_PROCESSING | AFS_SUBSYSTEM_WORKER_PROCESSING,
AFS_TRACE_LEVEL_ERROR,
"%s (%p) Failed to queue request Status %08lX\n",
__FUNCTION__,
pWorkItem->Specific.AsynchIo.Irp,
- ntStatus);
+ ntStatus));
}
}
git://git.openafs.org / openafs.git / blobdiff