[ion] 19078: - Fix CreateNamedPipeW to convert some NT flags properly, timeouts, etc, and document/prettify the function.
- Fix CreateNamedPipeW to convert some NT flags properly, timeouts, etc, and document/prettify the function. - NT 5.2 NPFS now works great, the kernel32_wintest pipe runs without crashing, and reports "411 tests passed, 30 failures". Modified: trunk/reactos/include/ndk/iotypes.h Modified: trunk/reactos/lib/kernel32/file/npipe.c _____
Modified: trunk/reactos/include/ndk/iotypes.h --- trunk/reactos/include/ndk/iotypes.h 2005-11-08 23:51:46 UTC (rev 19077) +++ trunk/reactos/include/ndk/iotypes.h 2005-11-09 00:44:37 UTC (rev 19078) @@ -38,6 +38,7 @@
/* Pipe Flags */ #define FILE_PIPE_BYTE_STREAM_TYPE 0x00000000 +#define FILE_PIPE_MESSAGE_TYPE 0x00000001 #define FILE_PIPE_BYTE_STREAM_MODE 0x00000000 #define FILE_PIPE_MESSAGE_MODE 0x00000001 #define FILE_PIPE_QUEUE_OPERATION 0x00000000 _____
Modified: trunk/reactos/lib/kernel32/file/npipe.c --- trunk/reactos/lib/kernel32/file/npipe.c 2005-11-08 23:51:46 UTC (rev 19077) +++ trunk/reactos/lib/kernel32/file/npipe.c 2005-11-09 00:44:37 UTC (rev 19078) @@ -13,6 +13,7 @@
#include <k32.h>
#define NDEBUG +//#define USING_PROPER_NPFS_WAIT_SEMANTICS #include "../include/debug.h"
/* FUNCTIONS ****************************************************************/ @@ -51,130 +52,178 @@ return(NamedPipeHandle); }
- /* * @implemented */ -HANDLE STDCALL +HANDLE +STDCALL CreateNamedPipeW(LPCWSTR lpName, - DWORD dwOpenMode, - DWORD dwPipeMode, - DWORD nMaxInstances, - DWORD nOutBufferSize, - DWORD nInBufferSize, - DWORD nDefaultTimeOut, - LPSECURITY_ATTRIBUTES lpSecurityAttributes) + DWORD dwOpenMode, + DWORD dwPipeMode, + DWORD nMaxInstances, + DWORD nOutBufferSize, + DWORD nInBufferSize, + DWORD nDefaultTimeOut, + LPSECURITY_ATTRIBUTES lpSecurityAttributes) { - UNICODE_STRING NamedPipeName; - BOOL Result; - NTSTATUS Status; - OBJECT_ATTRIBUTES ObjectAttributes; - HANDLE PipeHandle; - ACCESS_MASK DesiredAccess; - ULONG CreateOptions; - ULONG WriteModeMessage; - ULONG ReadModeMessage; - ULONG NonBlocking; - IO_STATUS_BLOCK Iosb; - ULONG ShareAccess, Attributes; - LARGE_INTEGER DefaultTimeOut; - PSECURITY_DESCRIPTOR SecurityDescriptor = NULL; + UNICODE_STRING NamedPipeName; + BOOL Result; + NTSTATUS Status; + OBJECT_ATTRIBUTES ObjectAttributes; + HANDLE PipeHandle; + ACCESS_MASK DesiredAccess; + ULONG CreateOptions = 0; + ULONG WriteModeMessage; + ULONG ReadModeMessage; + ULONG NonBlocking; + IO_STATUS_BLOCK Iosb; + ULONG ShareAccess = 0, Attributes; + LARGE_INTEGER DefaultTimeOut; + PSECURITY_DESCRIPTOR SecurityDescriptor = NULL;
- if (nMaxInstances == 0 || nMaxInstances > PIPE_UNLIMITED_INSTANCES) - { - SetLastError(ERROR_INVALID_PARAMETER); - return INVALID_HANDLE_VALUE; - } + /* Check for valid instances */ + if (nMaxInstances == 0 || nMaxInstances > PIPE_UNLIMITED_INSTANCES) + { + /* Fail */ + SetLastError(ERROR_INVALID_PARAMETER); + return INVALID_HANDLE_VALUE; + }
- Result = RtlDosPathNameToNtPathName_U((LPWSTR)lpName, - &NamedPipeName, - NULL, - NULL); - if (!Result) - { - SetLastError(ERROR_PATH_NOT_FOUND); - return(INVALID_HANDLE_VALUE); - } + /* Convert to NT syntax */ + if (nMaxInstances == PIPE_UNLIMITED_INSTANCES) nMaxInstances = -1;
- DPRINT("Pipe name: %wZ\n", &NamedPipeName); - DPRINT("Pipe name: %S\n", NamedPipeName.Buffer); + /* Convert the name */ + Result = RtlDosPathNameToNtPathName_U((LPWSTR)lpName, + &NamedPipeName, + NULL, + NULL); + if (!Result) + { + /* Conversion failed */ + SetLastError(ERROR_PATH_NOT_FOUND); + return(INVALID_HANDLE_VALUE); + }
- Attributes = OBJ_CASE_INSENSITIVE; - if(lpSecurityAttributes) - { - SecurityDescriptor = lpSecurityAttributes->lpSecurityDescriptor; - if(lpSecurityAttributes->bInheritHandle) - Attributes |= OBJ_INHERIT; - } + DPRINT1("Pipe name: %wZ\n", &NamedPipeName); + DPRINT1("Pipe name: %S\n", NamedPipeName.Buffer);
- InitializeObjectAttributes(&ObjectAttributes, - &NamedPipeName, - Attributes, - NULL, - SecurityDescriptor); + /* Always case insensitive, check if we got extra attributes */ + Attributes = OBJ_CASE_INSENSITIVE; + if(lpSecurityAttributes) + { + /* We did; get the security descriptor */ + SecurityDescriptor = lpSecurityAttributes->lpSecurityDescriptor;
- DesiredAccess = SYNCHRONIZE | (dwOpenMode & (WRITE_DAC | WRITE_OWNER | ACCESS_SYSTEM_SECURITY)); - ShareAccess = 0; - CreateOptions = 0; + /* And check if this is pipe's handle will beinheritable */ + if(lpSecurityAttributes->bInheritHandle) Attributes |= OBJ_INHERIT; + }
- if (dwOpenMode & FILE_FLAG_WRITE_THROUGH) - CreateOptions = CreateOptions | FILE_WRITE_THROUGH; + /* Now we can initialize the object attributes */ + InitializeObjectAttributes(&ObjectAttributes, + &NamedPipeName, + Attributes, + NULL, + SecurityDescriptor);
- if (!(dwOpenMode & FILE_FLAG_OVERLAPPED)) - CreateOptions = CreateOptions | FILE_SYNCHRONOUS_IO_NONALERT; + /* Setup the default Desired Access */ + DesiredAccess = SYNCHRONIZE | (dwOpenMode & (WRITE_DAC | + WRITE_OWNER | + ACCESS_SYSTEM_SECURITY));
- if (dwOpenMode & PIPE_ACCESS_OUTBOUND) - { - ShareAccess |= FILE_SHARE_READ; - DesiredAccess |= GENERIC_WRITE; - } - if (dwOpenMode & PIPE_ACCESS_INBOUND) - { - ShareAccess |= FILE_SHARE_WRITE; - DesiredAccess |= GENERIC_READ; - } - if (dwPipeMode & PIPE_TYPE_MESSAGE) - WriteModeMessage = FILE_PIPE_MESSAGE_MODE; - else - WriteModeMessage = FILE_PIPE_BYTE_STREAM_MODE; + /* Convert to NT Create Flags */ + if (dwOpenMode & FILE_FLAG_WRITE_THROUGH) + { + CreateOptions |= FILE_WRITE_THROUGH; + } + if (!(dwOpenMode & FILE_FLAG_OVERLAPPED)) + { + CreateOptions |= FILE_SYNCHRONOUS_IO_NONALERT; + }
- if (dwPipeMode & PIPE_READMODE_MESSAGE) - ReadModeMessage = FILE_PIPE_MESSAGE_MODE; - else - ReadModeMessage = FILE_PIPE_BYTE_STREAM_MODE; + /* Handle all open modes */ + if (dwOpenMode & PIPE_ACCESS_OUTBOUND) + { + ShareAccess |= FILE_SHARE_READ; + DesiredAccess |= GENERIC_WRITE; + } + if (dwOpenMode & PIPE_ACCESS_INBOUND) + { + ShareAccess |= FILE_SHARE_WRITE; + DesiredAccess |= GENERIC_READ; + }
- if (dwPipeMode & PIPE_NOWAIT) - NonBlocking = FILE_PIPE_COMPLETE_OPERATION; - else - NonBlocking = FILE_PIPE_QUEUE_OPERATION; + /* Handle the type flags */ + if (dwPipeMode & PIPE_TYPE_MESSAGE) + { + WriteModeMessage = FILE_PIPE_MESSAGE_TYPE; + } + else + { + WriteModeMessage = FILE_PIPE_BYTE_STREAM_TYPE; + }
- DefaultTimeOut.QuadPart = nDefaultTimeOut * -10000LL; + /* Handle the mode flags */ + if (dwPipeMode & PIPE_READMODE_MESSAGE) + { + ReadModeMessage = FILE_PIPE_MESSAGE_MODE; + } + else + { + ReadModeMessage = FILE_PIPE_BYTE_STREAM_MODE; + }
- Status = NtCreateNamedPipeFile(&PipeHandle, - DesiredAccess, - &ObjectAttributes, - &Iosb, - ShareAccess, - FILE_OPEN_IF, - CreateOptions, - WriteModeMessage, - ReadModeMessage, - NonBlocking, - nMaxInstances, - nInBufferSize, - nOutBufferSize, - &DefaultTimeOut); + /* Handle the blocking mode */ + if (dwPipeMode & PIPE_NOWAIT) + { + NonBlocking = FILE_PIPE_COMPLETE_OPERATION; + } + else + { + NonBlocking = FILE_PIPE_QUEUE_OPERATION; + }
- RtlFreeUnicodeString(&NamedPipeName); + /* Check if we have a timeout */ + if (nDefaultTimeOut) + { + /* Convert the time to NT format */ + DefaultTimeOut.QuadPart = UInt32x32To64(nDefaultTimeOut, -10000); + } + else + { + /* Use default timeout of 50 ms */ + DefaultTimeOut.QuadPart = -500000; + }
- if (!NT_SUCCESS(Status)) - { - DPRINT("NtCreateNamedPipe failed (Status %x)!\n", Status); - SetLastErrorByStatus (Status); - return INVALID_HANDLE_VALUE; - } + /* Now create the pipe */ + Status = NtCreateNamedPipeFile(&PipeHandle, + DesiredAccess, + &ObjectAttributes, + &Iosb, + ShareAccess, + FILE_OPEN_IF, + CreateOptions, + WriteModeMessage, + ReadModeMessage, + NonBlocking, + nMaxInstances, + nInBufferSize, + nOutBufferSize, + &DefaultTimeOut);
- return PipeHandle; + /* Free the name */ + RtlFreeUnicodeString(&NamedPipeName); + + /* Check status */ + if (!NT_SUCCESS(Status)) + { + /* Failed to create it */ + DPRINT1("NtCreateNamedPipe failed (Status %x)!\n", Status); + SetLastErrorByStatus (Status); + return INVALID_HANDLE_VALUE; + } + + /* Return the handle */ + return PipeHandle; }
-
ion＠svn.reactos.com