From 8cb3e2eee81c3ec87f27fbfab18d6560490cb6d8 Mon Sep 17 00:00:00 2001 From: Jeffrey Altman Date: Sun, 16 Dec 2012 02:02:06 -0500 Subject: [PATCH] Windows: reformat Change-Id: Ifba4f0d54032bd9580c97e7a94d2550e49b1a1ac Reviewed-on: http://gerrit.openafs.org/8950 Tested-by: BuildBot Reviewed-by: Jeffrey Altman Tested-by: Jeffrey Altman --- src/WINNT/afsrdr/user/RDRInit.cpp | 580 +++++++++++++++--------------- 1 file changed, 290 insertions(+), 290 deletions(-) diff --git a/src/WINNT/afsrdr/user/RDRInit.cpp b/src/WINNT/afsrdr/user/RDRInit.cpp index dffa4bff1..d481a781e 100644 --- a/src/WINNT/afsrdr/user/RDRInit.cpp +++ b/src/WINNT/afsrdr/user/RDRInit.cpp @@ -925,388 +925,388 @@ RDR_ProcessRequest( AFSCommRequest *RequestBuffer) break; } - case AFS_REQUEST_TYPE_PIOCTL_READ: - { - AFSPIOCtlIORequestCB *pPioctlCB = (AFSPIOCtlIORequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); + case AFS_REQUEST_TYPE_PIOCTL_READ: + { + AFSPIOCtlIORequestCB *pPioctlCB = (AFSPIOCtlIORequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIOCTL_READ Index %08lX Parent %08lX.%08lX.%08lX.%08lX", - RequestBuffer->RequestIndex, - RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, - RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIOCTL_READ Index %08lX Parent %08lX.%08lX.%08lX.%08lX", + RequestBuffer->RequestIndex, + RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, + RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); + } - RDR_PioctlRead( userp, - RequestBuffer->FileId, - pPioctlCB, - bWow64, - bIsLocalSystem, - RequestBuffer->ResultBufferLength, - &pResultCB); - break; + RDR_PioctlRead( userp, + RequestBuffer->FileId, + pPioctlCB, + bWow64, + bIsLocalSystem, + RequestBuffer->ResultBufferLength, + &pResultCB); + break; + } + + case AFS_REQUEST_TYPE_PIOCTL_CLOSE: + { + AFSPIOCtlOpenCloseRequestCB *pPioctlCB = (AFSPIOCtlOpenCloseRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); + + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIOCTL_CLOSE Index %08lX Parent %08lX.%08lX.%08lX.%08lX", + RequestBuffer->RequestIndex, + RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, + RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); + + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); } - case AFS_REQUEST_TYPE_PIOCTL_CLOSE: - { - AFSPIOCtlOpenCloseRequestCB *pPioctlCB = (AFSPIOCtlOpenCloseRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); + RDR_PioctlClose( userp, + RequestBuffer->FileId, + pPioctlCB, + bWow64, + RequestBuffer->ResultBufferLength, + &pResultCB); + break; + } - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIOCTL_CLOSE Index %08lX Parent %08lX.%08lX.%08lX.%08lX", - RequestBuffer->RequestIndex, - RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, - RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + case AFS_REQUEST_TYPE_BYTE_RANGE_LOCK: + { + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_BYTE_RANGE_LOCK Index %08lX File %08lX.%08lX.%08lX.%08lX %S", + RequestBuffer->RequestIndex, + RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, + RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique, + BooleanFlagOn( RequestBuffer->RequestFlags, AFS_REQUEST_FLAG_SYNCHRONOUS) ? L"Sync" : L"Async"); - RDR_PioctlClose( userp, - RequestBuffer->FileId, - pPioctlCB, - bWow64, - RequestBuffer->ResultBufferLength, - &pResultCB); - break; + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); } + AFSByteRangeLockRequestCB *pBRLRequestCB = (AFSByteRangeLockRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); - case AFS_REQUEST_TYPE_BYTE_RANGE_LOCK: - { - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_BYTE_RANGE_LOCK Index %08lX File %08lX.%08lX.%08lX.%08lX %S", - RequestBuffer->RequestIndex, - RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, - RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique, - BooleanFlagOn( RequestBuffer->RequestFlags, AFS_REQUEST_FLAG_SYNCHRONOUS) ? L"Sync" : L"Async"); + RDR_ByteRangeLockSync( userp, + RequestBuffer->FileId, + pBRLRequestCB, + bWow64, + RequestBuffer->ResultBufferLength, + &pResultCB); - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + break; + } - AFSByteRangeLockRequestCB *pBRLRequestCB = (AFSByteRangeLockRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); + case AFS_REQUEST_TYPE_BYTE_RANGE_UNLOCK: + { + AFSByteRangeUnlockRequestCB *pBRURequestCB = (AFSByteRangeUnlockRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); - RDR_ByteRangeLockSync( userp, - RequestBuffer->FileId, - pBRLRequestCB, - bWow64, - RequestBuffer->ResultBufferLength, - &pResultCB); + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_BYTE_RANGE_UNLOCK Index %08lX File %08lX.%08lX.%08lX.%08lX", + RequestBuffer->RequestIndex, + RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, + RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); - break; + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); } - case AFS_REQUEST_TYPE_BYTE_RANGE_UNLOCK: - { - AFSByteRangeUnlockRequestCB *pBRURequestCB = (AFSByteRangeUnlockRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); + RDR_ByteRangeUnlock( userp, + RequestBuffer->FileId, + pBRURequestCB, + bWow64, + RequestBuffer->ResultBufferLength, + &pResultCB); + break; + } - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_BYTE_RANGE_UNLOCK Index %08lX File %08lX.%08lX.%08lX.%08lX", - RequestBuffer->RequestIndex, - RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, - RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); + case AFS_REQUEST_TYPE_BYTE_RANGE_UNLOCK_ALL: + { + AFSByteRangeUnlockRequestCB *pBRURequestCB = (AFSByteRangeUnlockRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_BYTE_RANGE_UNLOCK_ALL Index %08lX File %08lX.%08lX.%08lX.%08lX", + RequestBuffer->RequestIndex, + RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, + RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); - RDR_ByteRangeUnlock( userp, - RequestBuffer->FileId, - pBRURequestCB, - bWow64, - RequestBuffer->ResultBufferLength, - &pResultCB); - break; + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); } - case AFS_REQUEST_TYPE_BYTE_RANGE_UNLOCK_ALL: - { - AFSByteRangeUnlockRequestCB *pBRURequestCB = (AFSByteRangeUnlockRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); - - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_BYTE_RANGE_UNLOCK_ALL Index %08lX File %08lX.%08lX.%08lX.%08lX", - RequestBuffer->RequestIndex, - RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, - RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); + RDR_ByteRangeUnlockAll( userp, + RequestBuffer->FileId, + pBRURequestCB, + bWow64, + RequestBuffer->ResultBufferLength, + &pResultCB); + break; + } - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + case AFS_REQUEST_TYPE_GET_VOLUME_INFO: + { + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_GET_VOLUME_INFO Index %08lX File %08lX.%08lX.%08lX.%08lX", + RequestBuffer->RequestIndex, + RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, + RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); - RDR_ByteRangeUnlockAll( userp, - RequestBuffer->FileId, - pBRURequestCB, - bWow64, - RequestBuffer->ResultBufferLength, - &pResultCB); - break; + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); } - case AFS_REQUEST_TYPE_GET_VOLUME_INFO: - { - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_GET_VOLUME_INFO Index %08lX File %08lX.%08lX.%08lX.%08lX", - RequestBuffer->RequestIndex, - RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, - RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); + RDR_GetVolumeInfo( userp, + RequestBuffer->FileId, + bWow64, + RequestBuffer->ResultBufferLength, + &pResultCB); + break; + } - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + case AFS_REQUEST_TYPE_GET_VOLUME_SIZE_INFO: + { + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_GET_VOLUME_SIZE_INFO Index %08lX File %08lX.%08lX.%08lX.%08lX", + RequestBuffer->RequestIndex, + RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, + RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); - RDR_GetVolumeInfo( userp, + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); + } + + RDR_GetVolumeSizeInfo( userp, RequestBuffer->FileId, bWow64, RequestBuffer->ResultBufferLength, &pResultCB); - break; - } + break; + } - case AFS_REQUEST_TYPE_GET_VOLUME_SIZE_INFO: - { - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_GET_VOLUME_SIZE_INFO Index %08lX File %08lX.%08lX.%08lX.%08lX", - RequestBuffer->RequestIndex, - RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, - RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); + case AFS_REQUEST_TYPE_HOLD_FID: + { - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + AFSHoldFidRequestCB *pHoldFidCB = (AFSHoldFidRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); - RDR_GetVolumeSizeInfo( userp, - RequestBuffer->FileId, - bWow64, - RequestBuffer->ResultBufferLength, - &pResultCB); - break; + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_HOLD_FID Index %08lX", + RequestBuffer->RequestIndex); + + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); } - case AFS_REQUEST_TYPE_HOLD_FID: - { + RDR_HoldFid( userp, + pHoldFidCB, + bFast, + RequestBuffer->ResultBufferLength, + &pResultCB); - AFSHoldFidRequestCB *pHoldFidCB = (AFSHoldFidRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); + break; + } - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_HOLD_FID Index %08lX", - RequestBuffer->RequestIndex); + case AFS_REQUEST_TYPE_RELEASE_FID: + { - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + AFSReleaseFidRequestCB *pReleaseFidCB = (AFSReleaseFidRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); - RDR_HoldFid( userp, - pHoldFidCB, - bFast, - RequestBuffer->ResultBufferLength, - &pResultCB); + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_RELEASE_FID Index %08lX", + RequestBuffer->RequestIndex); - break; + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); } - case AFS_REQUEST_TYPE_RELEASE_FID: - { + RDR_ReleaseFid( userp, + pReleaseFidCB, + bFast, + RequestBuffer->ResultBufferLength, + &pResultCB); - AFSReleaseFidRequestCB *pReleaseFidCB = (AFSReleaseFidRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); + break; + } - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_RELEASE_FID Index %08lX", - RequestBuffer->RequestIndex); + case AFS_REQUEST_TYPE_CLEANUP_PROCESSING: + { - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + AFSFileCleanupCB *pCleanupCB = (AFSFileCleanupCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); - RDR_ReleaseFid( userp, - pReleaseFidCB, - bFast, - RequestBuffer->ResultBufferLength, - &pResultCB); + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_CLEANUP_FILE Index %08lX File %08lX.%08lX.%08lX.%08lX", + RequestBuffer->RequestIndex, + RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, + RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); - break; + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); } - case AFS_REQUEST_TYPE_CLEANUP_PROCESSING: - { + RDR_CleanupFileEntry( userp, + RequestBuffer->FileId, + RequestBuffer->Name, + RequestBuffer->NameLength, + pCleanupCB, + bWow64, + bFlushFile, + bDeleteFile, + bUnlockFile, + RequestBuffer->ResultBufferLength, + &pResultCB); - AFSFileCleanupCB *pCleanupCB = (AFSFileCleanupCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); + break; + } - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_CLEANUP_FILE Index %08lX File %08lX.%08lX.%08lX.%08lX", - RequestBuffer->RequestIndex, - RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, - RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); + case AFS_REQUEST_TYPE_PIPE_OPEN: + { + AFSPipeOpenCloseRequestCB *pPipeCB = (AFSPipeOpenCloseRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIPE_OPEN Index %08lX Parent %08lX.%08lX.%08lX.%08lX", + RequestBuffer->RequestIndex, + RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, + RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); - RDR_CleanupFileEntry( userp, - RequestBuffer->FileId, - RequestBuffer->Name, - RequestBuffer->NameLength, - pCleanupCB, - bWow64, - bFlushFile, - bDeleteFile, - bUnlockFile, - RequestBuffer->ResultBufferLength, - &pResultCB); - - break; + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); } - case AFS_REQUEST_TYPE_PIPE_OPEN: - { - AFSPipeOpenCloseRequestCB *pPipeCB = (AFSPipeOpenCloseRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); + RDR_PipeOpen( userp, + RequestBuffer->FileId, + RequestBuffer->Name, + RequestBuffer->NameLength, + pPipeCB, + bWow64, + RequestBuffer->ResultBufferLength, + &pResultCB); + break; + } - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIPE_OPEN Index %08lX Parent %08lX.%08lX.%08lX.%08lX", - RequestBuffer->RequestIndex, - RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, - RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); + case AFS_REQUEST_TYPE_PIPE_WRITE: + { + AFSPipeIORequestCB *pPipeCB = (AFSPipeIORequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); + BYTE *pPipeData = ((BYTE *)RequestBuffer->Name + RequestBuffer->DataOffset + sizeof(AFSPipeIORequestCB)); - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIPE_WRITE Index %08lX Parent %08lX.%08lX.%08lX.%08lX", + RequestBuffer->RequestIndex, + RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, + RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); - RDR_PipeOpen( userp, - RequestBuffer->FileId, - RequestBuffer->Name, - RequestBuffer->NameLength, - pPipeCB, - bWow64, - RequestBuffer->ResultBufferLength, - &pResultCB); - break; + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); } - case AFS_REQUEST_TYPE_PIPE_WRITE: - { - AFSPipeIORequestCB *pPipeCB = (AFSPipeIORequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); - BYTE *pPipeData = ((BYTE *)RequestBuffer->Name + RequestBuffer->DataOffset + sizeof(AFSPipeIORequestCB)); + RDR_PipeWrite( userp, + RequestBuffer->FileId, + pPipeCB, + pPipeData, + bWow64, + RequestBuffer->ResultBufferLength, + &pResultCB); + break; + } - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIPE_WRITE Index %08lX Parent %08lX.%08lX.%08lX.%08lX", - RequestBuffer->RequestIndex, - RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, - RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); + case AFS_REQUEST_TYPE_PIPE_READ: + { + AFSPipeIORequestCB *pPipeCB = (AFSPipeIORequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIPE_READ Index %08lX Parent %08lX.%08lX.%08lX.%08lX", + RequestBuffer->RequestIndex, + RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, + RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); - RDR_PipeWrite( userp, - RequestBuffer->FileId, - pPipeCB, - pPipeData, - bWow64, - RequestBuffer->ResultBufferLength, - &pResultCB); - break; + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); } - case AFS_REQUEST_TYPE_PIPE_READ: - { - AFSPipeIORequestCB *pPipeCB = (AFSPipeIORequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); + RDR_PipeRead( userp, + RequestBuffer->FileId, + pPipeCB, + bWow64, + RequestBuffer->ResultBufferLength, + &pResultCB); + break; + } - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIPE_READ Index %08lX Parent %08lX.%08lX.%08lX.%08lX", - RequestBuffer->RequestIndex, - RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, - RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); + case AFS_REQUEST_TYPE_PIPE_CLOSE: + { + AFSPipeOpenCloseRequestCB *pPipeCB = (AFSPipeOpenCloseRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIPE_CLOSE Index %08lX Parent %08lX.%08lX.%08lX.%08lX", + RequestBuffer->RequestIndex, + RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, + RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); - RDR_PipeRead( userp, - RequestBuffer->FileId, - pPipeCB, - bWow64, - RequestBuffer->ResultBufferLength, - &pResultCB); - break; + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); } - case AFS_REQUEST_TYPE_PIPE_CLOSE: - { - AFSPipeOpenCloseRequestCB *pPipeCB = (AFSPipeOpenCloseRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); + RDR_PipeClose( userp, + RequestBuffer->FileId, + pPipeCB, + bWow64, + RequestBuffer->ResultBufferLength, + &pResultCB); + break; + } - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIPE_CLOSE Index %08lX Parent %08lX.%08lX.%08lX.%08lX", - RequestBuffer->RequestIndex, - RequestBuffer->FileId.Cell, RequestBuffer->FileId.Volume, - RequestBuffer->FileId.Vnode, RequestBuffer->FileId.Unique); - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + case AFS_REQUEST_TYPE_PIPE_TRANSCEIVE: + { + AFSPipeIORequestCB *pPipeCB = (AFSPipeIORequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); + BYTE *pPipeData = ((BYTE *)RequestBuffer->Name + RequestBuffer->DataOffset + sizeof(AFSPipeIORequestCB)); + + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIPE_TRANSCEIVE Index %08lX", + RequestBuffer->RequestIndex); + + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); + } - RDR_PipeClose( userp, + RDR_PipeTransceive( userp, RequestBuffer->FileId, pPipeCB, + pPipeData, bWow64, RequestBuffer->ResultBufferLength, &pResultCB); - break; - } - - - case AFS_REQUEST_TYPE_PIPE_TRANSCEIVE: - { - AFSPipeIORequestCB *pPipeCB = (AFSPipeIORequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); - BYTE *pPipeData = ((BYTE *)RequestBuffer->Name + RequestBuffer->DataOffset + sizeof(AFSPipeIORequestCB)); + break; + } - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIPE_TRANSCEIVE Index %08lX", - RequestBuffer->RequestIndex); + case AFS_REQUEST_TYPE_PIPE_QUERY_INFO: + { + AFSPipeInfoRequestCB *pPipeInfoCB = (AFSPipeInfoRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIPE_QUERY_INFO Index %08lX", + RequestBuffer->RequestIndex); - RDR_PipeTransceive( userp, - RequestBuffer->FileId, - pPipeCB, - pPipeData, - bWow64, - RequestBuffer->ResultBufferLength, - &pResultCB); - break; + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); } - case AFS_REQUEST_TYPE_PIPE_QUERY_INFO: - { - AFSPipeInfoRequestCB *pPipeInfoCB = (AFSPipeInfoRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); + RDR_PipeQueryInfo( userp, + RequestBuffer->FileId, + pPipeInfoCB, + bWow64, + RequestBuffer->ResultBufferLength, + &pResultCB); + break; + } - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIPE_QUERY_INFO Index %08lX", - RequestBuffer->RequestIndex); + case AFS_REQUEST_TYPE_PIPE_SET_INFO: + { + AFSPipeInfoRequestCB *pPipeInfoCB = (AFSPipeInfoRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); + BYTE *pPipeData = ((BYTE *)RequestBuffer->Name + RequestBuffer->DataOffset + sizeof(AFSPipeInfoRequestCB)); - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } + if (afsd_logp->enabled) { + swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIPE_SET_INFO Index %08lX", + RequestBuffer->RequestIndex); - RDR_PipeQueryInfo( userp, - RequestBuffer->FileId, - pPipeInfoCB, - bWow64, - RequestBuffer->ResultBufferLength, - &pResultCB); - break; + osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); } - case AFS_REQUEST_TYPE_PIPE_SET_INFO: - { - AFSPipeInfoRequestCB *pPipeInfoCB = (AFSPipeInfoRequestCB *)((char *)RequestBuffer->Name + RequestBuffer->DataOffset); - BYTE *pPipeData = ((BYTE *)RequestBuffer->Name + RequestBuffer->DataOffset + sizeof(AFSPipeInfoRequestCB)); - - if (afsd_logp->enabled) { - swprintf( wchBuffer, L"ProcessRequest Processing AFS_REQUEST_TYPE_PIPE_SET_INFO Index %08lX", - RequestBuffer->RequestIndex); - - osi_Log1(afsd_logp, "%S", osi_LogSaveStringW(afsd_logp, wchBuffer)); - } - - RDR_PipeSetInfo( userp, - RequestBuffer->FileId, - pPipeInfoCB, - pPipeData, - bWow64, - RequestBuffer->ResultBufferLength, - &pResultCB); + RDR_PipeSetInfo( userp, + RequestBuffer->FileId, + pPipeInfoCB, + pPipeData, + bWow64, + RequestBuffer->ResultBufferLength, + &pResultCB); - break; - } + break; + } - default: + default: bUnsupported = TRUE; if (afsd_logp->enabled) { -- 2.39.5