Ros-diffs

ros-diffs@reactos.org

81390 discussions

[ion] 19086: - Unbreak build
by ion＠svn.reactos.com 09 Nov '05

09 Nov '05

- Unbreak build - Fix CallNamedPipeW, the pipe mode should also be set to PIPE_WAIT. Modified: trunk/reactos/lib/kernel32/file/npipe.c _____ Modified: trunk/reactos/lib/kernel32/file/npipe.c --- trunk/reactos/lib/kernel32/file/npipe.c 2005-11-09 02:53:58 UTC (rev 19085) +++ trunk/reactos/lib/kernel32/file/npipe.c 2005-11-09 03:02:33 UTC (rev 19086) @@ -674,12 +674,12 @@ LPDWORD lpBytesRead, DWORD nTimeOut) { - UNICODE_STRING PipeName = &NtCurrentTeb()->StaticUnicodeString; + PUNICODE_STRING PipeName = &NtCurrentTeb()->StaticUnicodeString; ANSI_STRING AnsiPipe; /* Initialize the string as ANSI_STRING and convert to Unicode */ - RtlInitAnsiString(&NameA, (LPSTR)lpName); - RtlAnsiStringToUnicodeString(NameU, &NameA, FALSE); + RtlInitAnsiString(&AnsiPipe, (LPSTR)lpNamedPipeName); + RtlAnsiStringToUnicodeString(PipeName, &AnsiPipe, FALSE); /* Call the Unicode function */ return CallNamedPipeW(PipeName->Buffer, @@ -694,65 +694,69 @@ /* * @implemented */ -BOOL STDCALL +BOOL +WINAPI CallNamedPipeW(LPCWSTR lpNamedPipeName, - LPVOID lpInBuffer, - DWORD nInBufferSize, - LPVOID lpOutBuffer, - DWORD nOutBufferSize, - LPDWORD lpBytesRead, - DWORD nTimeOut) + LPVOID lpInBuffer, + DWORD nInBufferSize, + LPVOID lpOutBuffer, + DWORD nOutBufferSize, + LPDWORD lpBytesRead, + DWORD nTimeOut) { - HANDLE hPipe = INVALID_HANDLE_VALUE; - BOOL bRetry = TRUE; - BOOL bError = FALSE; - DWORD dwPipeMode; + HANDLE hPipe; + BOOL bRetry = TRUE; + BOOL bError; + DWORD dwPipeMode; - while (TRUE) + while (TRUE) { - hPipe = CreateFileW(lpNamedPipeName, - GENERIC_READ | GENERIC_WRITE, - FILE_SHARE_READ | FILE_SHARE_WRITE, - NULL, - OPEN_EXISTING, - FILE_ATTRIBUTE_NORMAL, - NULL); - if (hPipe != INVALID_HANDLE_VALUE) - break; + /* Try creating it */ + hPipe = CreateFileW(lpNamedPipeName, + GENERIC_READ | GENERIC_WRITE, + FILE_SHARE_READ | FILE_SHARE_WRITE, + NULL, + OPEN_EXISTING, + FILE_ATTRIBUTE_NORMAL, + NULL); - if (bRetry == FALSE) - return(FALSE); + /* Success, break out */ + if (hPipe != INVALID_HANDLE_VALUE) break; - WaitNamedPipeW(lpNamedPipeName, - nTimeOut); + /* Already tried twice, give up */ + if (bRetry == FALSE) return FALSE; - bRetry = FALSE; + /* Wait on it */ + WaitNamedPipeW(lpNamedPipeName, nTimeOut); + + /* Get ready to try again */ + bRetry = FALSE; } - dwPipeMode = PIPE_READMODE_MESSAGE; - bError = SetNamedPipeHandleState(hPipe, - &dwPipeMode, - NULL, - NULL); - if (!bError) + /* Set the pipe mode */ + dwPipeMode = PIPE_READMODE_MESSAGE | PIPE_WAIT; + bError = SetNamedPipeHandleState(hPipe, &dwPipeMode, NULL, NULL); + if (!bError) { - CloseHandle(hPipe); - return(FALSE); + /* Couldn't change state, fail */ + CloseHandle(hPipe); + return FALSE; } - bError = TransactNamedPipe(hPipe, - lpInBuffer, - nInBufferSize, - lpOutBuffer, - nOutBufferSize, - lpBytesRead, - NULL); - CloseHandle(hPipe); - - return(bError); + /* Do the transact */ + bError = TransactNamedPipe(hPipe, + lpInBuffer, + nInBufferSize, + lpOutBuffer, + nOutBufferSize, + lpBytesRead, + NULL); + + /* Close the handle and return */ + CloseHandle(hPipe); + return bError; } - /* * @implemented */

1 0

[ion] 19085: - Optimize CallNamedPipeA too and remove accidental define.
by ion＠svn.reactos.com 09 Nov '05

09 Nov '05

- Optimize CallNamedPipeA too and remove accidental define. Modified: trunk/reactos/lib/kernel32/file/npipe.c _____ Modified: trunk/reactos/lib/kernel32/file/npipe.c --- trunk/reactos/lib/kernel32/file/npipe.c 2005-11-09 02:50:54 UTC (rev 19084) +++ trunk/reactos/lib/kernel32/file/npipe.c 2005-11-09 02:53:58 UTC (rev 19085) @@ -12,7 +12,7 @@ #include <k32.h> #define NDEBUG -#define USING_PROPER_NPFS_WAIT_SEMANTICS +//#define USING_PROPER_NPFS_WAIT_SEMANTICS #include "../include/debug.h" /* FUNCTIONS ****************************************************************/ @@ -664,35 +664,33 @@ /* * @implemented */ -BOOL STDCALL +BOOL +WINAPI CallNamedPipeA(LPCSTR lpNamedPipeName, - LPVOID lpInBuffer, - DWORD nInBufferSize, - LPVOID lpOutBuffer, - DWORD nOutBufferSize, - LPDWORD lpBytesRead, - DWORD nTimeOut) + LPVOID lpInBuffer, + DWORD nInBufferSize, + LPVOID lpOutBuffer, + DWORD nOutBufferSize, + LPDWORD lpBytesRead, + DWORD nTimeOut) { - UNICODE_STRING PipeName; - BOOL Result; + UNICODE_STRING PipeName = &NtCurrentTeb()->StaticUnicodeString; + ANSI_STRING AnsiPipe; - RtlCreateUnicodeStringFromAsciiz(&PipeName, - (LPSTR)lpNamedPipeName); + /* Initialize the string as ANSI_STRING and convert to Unicode */ + RtlInitAnsiString(&NameA, (LPSTR)lpName); + RtlAnsiStringToUnicodeString(NameU, &NameA, FALSE); - Result = CallNamedPipeW(PipeName.Buffer, - lpInBuffer, - nInBufferSize, - lpOutBuffer, - nOutBufferSize, - lpBytesRead, - nTimeOut); - - RtlFreeUnicodeString(&PipeName); - - return(Result); + /* Call the Unicode function */ + return CallNamedPipeW(PipeName->Buffer, + lpInBuffer, + nInBufferSize, + lpOutBuffer, + nOutBufferSize, + lpBytesRead, + nTimeOut); } - /* * @implemented */

1 0

[ion] 19084: Ansi->Unicode conversions:
by ion＠svn.reactos.com 09 Nov '05

09 Nov '05

Ansi->Unicode conversions: - Take advantage of TEB in CreateNamedPipeA - Use helper function in WaitNamedPipeA Modified: trunk/reactos/lib/kernel32/file/npipe.c _____ Modified: trunk/reactos/lib/kernel32/file/npipe.c --- trunk/reactos/lib/kernel32/file/npipe.c 2005-11-09 02:17:18 UTC (rev 19083) +++ trunk/reactos/lib/kernel32/file/npipe.c 2005-11-09 02:50:54 UTC (rev 19084) @@ -1,11 +1,10 @@ -/* $Id$ - * +/* * COPYRIGHT: See COPYING in the top level directory - * PROJECT: ReactOS system libraries + * PROJECT: ReactOS Win32 Kernel Library * FILE: lib/kernel32/file/npipe.c - * PURPOSE: Directory functions - * PROGRAMMER: Ariadne ( ariadne(a)xs4all.nl) - * UPDATE HISTORY: + * PURPOSE: Named Pipe Functions + * PROGRAMMER: Alex Ionescu (alex(a)relsoft.net) + * Ariadne ( ariadne(a)xs4all.nl) */ /* INCLUDES *****************************************************************/ @@ -13,7 +12,7 @@ #include <k32.h> #define NDEBUG -//#define USING_PROPER_NPFS_WAIT_SEMANTICS +#define USING_PROPER_NPFS_WAIT_SEMANTICS #include "../include/debug.h" /* FUNCTIONS ****************************************************************/ @@ -21,35 +20,33 @@ /* * @implemented */ -HANDLE STDCALL +HANDLE +WINAPI CreateNamedPipeA(LPCSTR 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) { - HANDLE NamedPipeHandle; - UNICODE_STRING NameU; - ANSI_STRING NameA; + PUNICODE_STRING NameU = &NtCurrentTeb()->StaticUnicodeString; + ANSI_STRING NameA; - RtlInitAnsiString(&NameA, (LPSTR)lpName); - RtlAnsiStringToUnicodeString(&NameU, &NameA, TRUE); + /* Initialize the string as ANSI_STRING and convert to Unicode */ + RtlInitAnsiString(&NameA, (LPSTR)lpName); + RtlAnsiStringToUnicodeString(NameU, &NameA, FALSE); - NamedPipeHandle = CreateNamedPipeW(NameU.Buffer, - dwOpenMode, - dwPipeMode, - nMaxInstances, - nOutBufferSize, - nInBufferSize, - nDefaultTimeOut, - lpSecurityAttributes); - - RtlFreeUnicodeString(&NameU); - - return(NamedPipeHandle); + /* Call the Unicode API */ + return CreateNamedPipeW(NameU->Buffer, + dwOpenMode, + dwPipeMode, + nMaxInstances, + nOutBufferSize, + nInBufferSize, + nDefaultTimeOut, + lpSecurityAttributes); } /* @@ -104,8 +101,8 @@ return(INVALID_HANDLE_VALUE); } - DPRINT1("Pipe name: %wZ\n", &NamedPipeName); - DPRINT1("Pipe name: %S\n", NamedPipeName.Buffer); + DPRINT("Pipe name: %wZ\n", &NamedPipeName); + DPRINT("Pipe name: %S\n", NamedPipeName.Buffer); /* Always case insensitive, check if we got extra attributes */ Attributes = OBJ_CASE_INSENSITIVE; @@ -226,26 +223,28 @@ return PipeHandle; } - /* * @implemented */ -BOOL STDCALL +BOOL +WINAPI WaitNamedPipeA(LPCSTR lpNamedPipeName, - DWORD nTimeOut) + DWORD nTimeOut) { - BOOL r; - UNICODE_STRING NameU; - ANSI_STRING NameA; + BOOL r; + UNICODE_STRING NameU; - RtlInitAnsiString(&NameA, (LPSTR)lpNamedPipeName); - RtlAnsiStringToUnicodeString(&NameU, &NameA, TRUE); + /* Convert the name to Unicode */ + Basep8BitStringToLiveUnicodeString(&NameU, lpNamedPipeName); - r = WaitNamedPipeW(NameU.Buffer, nTimeOut); + /* Call the Unicode API */ + r = WaitNamedPipeW(NameU.Buffer, nTimeOut); - RtlFreeUnicodeString(&NameU); + /* Free the Unicode string */ + RtlFreeUnicodeString(&NameU); - return(r); + /* Return result */ + return r; } /*

1 0

[ion] 19083: - Fix bugs in RtlSplay
by ion＠svn.reactos.com 09 Nov '05

09 Nov '05

- Fix bugs in RtlSplay Modified: trunk/reactos/lib/rtl/splaytree.c _____ Modified: trunk/reactos/lib/rtl/splaytree.c --- trunk/reactos/lib/rtl/splaytree.c 2005-11-09 02:16:03 UTC (rev 19082) +++ trunk/reactos/lib/rtl/splaytree.c 2005-11-09 02:17:18 UTC (rev 19083) @@ -3,7 +3,7 @@ * PROJECT: ReactOS system libraries * PURPOSE: Splay-Tree implementation * FILE: lib/rtl/splaytree.c - * PROGRAMMER: + * PROGRAMMER: Alex Ionescu (alex(a)relsoft.net) */ /* INCLUDES *****************************************************************/ @@ -274,7 +274,7 @@ * G was a right child, so change its parent's right * child link to point to N now. */ - RtlLeftChild(RtlParent(G)) = N; + RtlRightChild(RtlParent(G)) = N; } } @@ -335,7 +335,7 @@ * G was a right child, so change its parent's right * child link to point to N now. */ - RtlLeftChild(RtlParent(G)) = N; + RtlRightChild(RtlParent(G)) = N; } } @@ -416,7 +416,7 @@ * G was a right child, so change its parent's right * child link to point to N now. */ - RtlLeftChild(RtlParent(G)) = N; + RtlRightChild(RtlParent(G)) = N; } } @@ -477,7 +477,7 @@ * G was a right child, so change its parent's right * child link to point to N now. */ - RtlLeftChild(RtlParent(G)) = N; + RtlRightChild(RtlParent(G)) = N; } }

1 0

[ion] 19082: - Implement most of RtlDelete.
by ion＠svn.reactos.com 09 Nov '05

09 Nov '05

- Implement most of RtlDelete. Modified: trunk/reactos/lib/rtl/splaytree.c _____ Modified: trunk/reactos/lib/rtl/splaytree.c --- trunk/reactos/lib/rtl/splaytree.c 2005-11-09 01:39:39 UTC (rev 19081) +++ trunk/reactos/lib/rtl/splaytree.c 2005-11-09 02:16:03 UTC (rev 19082) @@ -16,16 +16,86 @@ /* FUNCTIONS ***************************************************************/ /* -* @unimplemented -*/ + * @implemented + */ PRTL_SPLAY_LINKS NTAPI -RtlDelete ( - PRTL_SPLAY_LINKS Links - ) +RtlDelete(PRTL_SPLAY_LINKS Links) { - UNIMPLEMENTED; - return 0; + PRTL_SPLAY_LINKS N, P, C, SP; + N = Links; + + /* Check if we have two children */ + if ((RtlLeftChild(N)) && (RtlRightChild(N))) + { + /* Get the predecessor */ + SP = RtlSubtreePredecessor(N); + + /* Swap it with N, this will guarantee that N will have only a child */ + //SwapSplayLinks(SP, N); + DPRINT1("UNIMPLEMENTED!\n"); + } + + /* Check if we have no children */ + if (!(RtlLeftChild(N)) && !(RtlRightChild(N))) + { + /* If we are also the root, then the tree is gone */ + return NULL; + + /* Get our parent */ + P = RtlParent(N); + + /* Find out who is referencing us and delete the reference */ + if (RtlIsLeftChild(N)) + { + /* N was a left child, so erase its parent's left child link */ + RtlLeftChild(RtlParent(N)) = NULL; + } + else + { + /* N was a right child, so erase its parent's right child link */ + RtlRightChild(RtlParent(N)) = NULL; + } + + /* And finally splay the parent */ + return RtlSplay(P); + } + + /* If we got here, we have a child (not two: we swapped above!) */ + if (RtlLeftChild(N)) + { + /* We have a left child, so get it */ + C = RtlLeftChild(N); + } + else + { + /* We have a right child, get him instead */ + C = RtlRightChild(N); + } + + /* Check if we are the root entry */ + if (RtlIsRoot(N)) + { + /* Our child is now root, return him */ + C->Parent = C; + return C; + } + + /* Find out who is referencing us and link to our child instead */ + if (RtlIsLeftChild(N)) + { + /* N was a left child, so set its parent's left child as our child */ + RtlLeftChild(RtlParent(N)) = C; + } + else + { + /* N was a right child, so set its parent's right child as our child */ + RtlRightChild(RtlParent(N)) = C; + } + + /* Finally, inherit our parent and splay the parent */ + C->Parent = N->Parent; + return RtlSplay(RtlParent(C)); } /*

1 0

[ion] 19081: - Implement RtlRealPrecessdor and RtlRealSuccessor
by ion＠svn.reactos.com 09 Nov '05

09 Nov '05

- Implement RtlRealPrecessdor and RtlRealSuccessor Modified: trunk/reactos/lib/rtl/splaytree.c _____ Modified: trunk/reactos/lib/rtl/splaytree.c --- trunk/reactos/lib/rtl/splaytree.c 2005-11-09 01:05:00 UTC (rev 19080) +++ trunk/reactos/lib/rtl/splaytree.c 2005-11-09 01:39:39 UTC (rev 19081) @@ -41,31 +41,62 @@ UNIMPLEMENTED; } - /* -* @unimplemented +* @implemented */ PRTL_SPLAY_LINKS NTAPI -RtlRealPredecessor ( - PRTL_SPLAY_LINKS Links - ) +RtlRealPredecessor(PRTL_SPLAY_LINKS Links) { - UNIMPLEMENTED; - return 0; + PRTL_SPLAY_LINKS Child; + + /* Get the left child */ + Child = RtlLeftChild(Links); + if (Child) + { + /* Get right-most child */ + while (RtlRightChild(Child)) Child = RtlRightChild(Child); + return Child; + } + + /* We don't have a left child, keep looping until we find our parent */ + Child = Links; + while (RtlIsLeftChild(Child)) Child = RtlParent(Child); + + /* The parent should be a right child, return the real predecessor */ + if (RtlIsRightChild(Child)) return RtlParent(Child); + + /* The parent isn't a right child, so no real precessor for us */ + return NULL; } /* -* @unimplemented +* @implemented */ PRTL_SPLAY_LINKS NTAPI -RtlRealSuccessor ( - PRTL_SPLAY_LINKS Links - ) +RtlRealSuccessor(PRTL_SPLAY_LINKS Links) { - UNIMPLEMENTED; - return 0; + PRTL_SPLAY_LINKS Child; + + /* Get the right child */ + Child = RtlRightChild(Links); + if (Child) + { + /* Get left-most child */ + while (RtlLeftChild(Child)) Child = RtlLeftChild(Child); + return Child; + } + + /* We don't have a right child, keep looping until we find our parent */ + Child = Links; + while (RtlIsRightChild(Child)) Child = RtlParent(Child); + + /* The parent should be a left child, return the real successor */ + if (RtlIsLeftChild(Child)) return RtlParent(Child); + + /* The parent isn't a right child, so no real successor for us */ + return NULL; } /*

1 0

[ion] 19080: - Fix RtlSubtreePredecessor/Successor, someone had implemented them backwards.
by ion＠svn.reactos.com 09 Nov '05

09 Nov '05

- Fix RtlSubtreePredecessor/Successor, someone had implemented them backwards. Modified: trunk/reactos/lib/rtl/splaytree.c _____ Modified: trunk/reactos/lib/rtl/splaytree.c --- trunk/reactos/lib/rtl/splaytree.c 2005-11-09 00:56:41 UTC (rev 19079) +++ trunk/reactos/lib/rtl/splaytree.c 2005-11-09 01:05:00 UTC (rev 19080) @@ -411,49 +411,44 @@ return N; } - /* * @implemented */ -PRTL_SPLAY_LINKS NTAPI -RtlSubtreePredecessor (IN PRTL_SPLAY_LINKS Links) +PRTL_SPLAY_LINKS +NTAPI +RtlSubtreePredecessor(IN PRTL_SPLAY_LINKS Links) { - PRTL_SPLAY_LINKS Child; + PRTL_SPLAY_LINKS Child; - Child = Links->RightChild; - if (Child == NULL) - return NULL; + /* Get the left child */ + Child = RtlLeftChild(Links); + if (!Child) return NULL; - if (Child->LeftChild == NULL) - return Child; + /* Get right-most child */ + while (RtlRightChild(Child)) Child = RtlRightChild(Child); - /* Get left-most child */ - while (Child->LeftChild != NULL) - Child = Child->LeftChild; - - return Child; + /* Return it */ + return Child; } /* * @implemented */ -PRTL_SPLAY_LINKS NTAPI -RtlSubtreeSuccessor (IN PRTL_SPLAY_LINKS Links) +PRTL_SPLAY_LINKS +NTAPI +RtlSubtreeSuccessor(IN PRTL_SPLAY_LINKS Links) { - PRTL_SPLAY_LINKS Child; + PRTL_SPLAY_LINKS Child; - Child = Links->LeftChild; - if (Child == NULL) - return NULL; + /* Get the right child */ + Child = RtlRightChild(Links); + if (!Child) return NULL; - if (Child->RightChild == NULL) - return Child; + /* Get left-most child */ + while (RtlLeftChild(Child)) Child = RtlLeftChild(Child); - /* Get right-most child */ - while (Child->RightChild != NULL) - Child = Child->RightChild; - - return Child; + /* Return it */ + return Child; } /* EOF */

1 0

[weiden] 19079: fixed data size calculation in RtlSelfRelativeToAbsoluteSD2
by weiden＠svn.reactos.com 09 Nov '05

09 Nov '05

fixed data size calculation in RtlSelfRelativeToAbsoluteSD2 Modified: trunk/reactos/lib/rtl/sd.c _____ Modified: trunk/reactos/lib/rtl/sd.c --- trunk/reactos/lib/rtl/sd.c 2005-11-09 00:44:37 UTC (rev 19078) +++ trunk/reactos/lib/rtl/sd.c 2005-11-09 00:56:41 UTC (rev 19079) @@ -815,7 +815,7 @@ ASSERT((ULONG_PTR)DataEnd >= (ULONG_PTR)DataStart); - DataSize = (ULONG)((ULONG_PTR)DataEnd >= (ULONG_PTR)DataStart); + DataSize = (ULONG)((ULONG_PTR)DataEnd - (ULONG_PTR)DataStart); if (*BufferSize < sizeof(SECURITY_DESCRIPTOR) + DataSize) {

1 0

[ion] 19078: - Fix CreateNamedPipeW to convert some NT flags properly, timeouts, etc, and document/prettify the function.
by ion＠svn.reactos.com 09 Nov '05

09 Nov '05

- 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; }

1 0

[ion] 19077: - Finish implementing RtlSplayTree
by ion＠svn.reactos.com 08 Nov '05

08 Nov '05

- Finish implementing RtlSplayTree Modified: trunk/reactos/lib/rtl/splaytree.c _____ Modified: trunk/reactos/lib/rtl/splaytree.c --- trunk/reactos/lib/rtl/splaytree.c 2005-11-08 23:47:25 UTC (rev 19076) +++ trunk/reactos/lib/rtl/splaytree.c 2005-11-08 23:51:46 UTC (rev 19077) @@ -69,7 +69,7 @@ } /* -* @unimplemented +* @implemented */ PRTL_SPLAY_LINKS NTAPI @@ -249,7 +249,18 @@ /* "Finally" case: N doesn't have a grandparent => P is root */ else { + /* P's left-child becomes N's right child */ + RtlLeftChild(P) = RtlRightChild(N); + /* If it exists, update its parent pointer too */ + if (RtlLeftChild(P)) RtlParent(RtlLeftChild(P)) = P; + + /* Now make N the root, no need to worry about references */ + N->Parent = N; + + /* And make P its right child */ + N->RightChild = P; + P->Parent = N; } } /* Case 2 & 4: N is right child of P */ @@ -380,7 +391,18 @@ /* "Finally" case: N doesn't have a grandparent => P is root */ else { + /* P's right-child becomes N's left child */ + RtlRightChild(P) = RtlLeftChild(N); + /* If it exists, update its parent pointer too */ + if (RtlRightChild(P)) RtlParent(RtlRightChild(P)) = P; + + /* Now make N the root, no need to worry about references */ + N->Parent = N; + + /* And make P its left child */ + N->LeftChild = P; + P->Parent = N; } } }

1 0

Jump to page:

2026

2025

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

2007

2006

2005

2004

Ros-diffs