Ros-diffs

ros-diffs@reactos.org

81390 discussions

[pschweitzer] 74703: [NTDLL_VISTA] Create a new NTDLL library that exports some of the NTDLL Vista+ functions. This new NTDLL includes at the time of commit: - SRW locks implementation that was ori...
by pschweitzer＠svn.reactos.org 30 May '17

30 May '17

Author: pschweitzer Date: Tue May 30 21:35:05 2017 New Revision: 74703 URL: http://svn.reactos.org/svn/reactos?rev=74703&view=rev Log: [NTDLL_VISTA] Create a new NTDLL library that exports some of the NTDLL Vista+ functions. This new NTDLL includes at the time of commit: - SRW locks implementation that was originally built in RTL but never used ; - Condition variables implementation which is a new code in ReactOS trunk. Condition variables is an implementation of Stephan Röger, with minor formatting changes by Timo Kreuzer and various changes by myself. CORE-7546 CORE-8204 Added: trunk/reactos/dll/win32/ntdll_vista/ trunk/reactos/dll/win32/ntdll_vista/CMakeLists.txt (with props) trunk/reactos/dll/win32/ntdll_vista/DllMain.c (with props) trunk/reactos/dll/win32/ntdll_vista/condvar.c (with props) trunk/reactos/dll/win32/ntdll_vista/ntdll_vista.spec (with props) trunk/reactos/dll/win32/ntdll_vista/rtl_vista.h (with props) trunk/reactos/dll/win32/ntdll_vista/srw.c - copied, changed from r74702, trunk/reactos/sdk/lib/rtl/srw.c Removed: trunk/reactos/sdk/lib/rtl/srw.c Modified: trunk/reactos/dll/win32/CMakeLists.txt trunk/reactos/sdk/lib/rtl/CMakeLists.txt Modified: trunk/reactos/dll/win32/CMakeLists.txt URL: http://svn.reactos.org/svn/reactos/trunk/reactos/dll/win32/CMakeLists.txt?r… ============================================================================== --- trunk/reactos/dll/win32/CMakeLists.txt [iso-8859-1] (original) +++ trunk/reactos/dll/win32/CMakeLists.txt [iso-8859-1] Tue May 30 21:35:05 2017 @@ -134,6 +134,7 @@ add_subdirectory(netid) add_subdirectory(newdev) add_subdirectory(npptools) +add_subdirectory(ntdll_vista) add_subdirectory(ntdsapi) add_subdirectory(ntlanman) add_subdirectory(ntmarta) Added: trunk/reactos/dll/win32/ntdll_vista/CMakeLists.txt URL: http://svn.reactos.org/svn/reactos/trunk/reactos/dll/win32/ntdll_vista/CMak… ============================================================================== --- trunk/reactos/dll/win32/ntdll_vista/CMakeLists.txt (added) +++ trunk/reactos/dll/win32/ntdll_vista/CMakeLists.txt [iso-8859-1] Tue May 30 21:35:05 2017 @@ -0,0 +1,17 @@ + +remove_definitions(-D_WIN32_WINNT=0x502 -DWINVER=0x502) +add_definitions(-D_WIN32_WINNT=0x600 -DWINVER=0x600) + +spec2def(ntdll_vista.dll ntdll_vista.spec ADD_IMPORTLIB) + +list(APPEND SOURCE + DllMain.c + condvar.c + srw.c + ${CMAKE_CURRENT_BINARY_DIR}/ntdll_vista.def) + +add_library(ntdll_vista SHARED ${SOURCE}) +set_module_type(ntdll_vista win32dll ENTRYPOINT DllMain 12) +add_importlibs(ntdll_vista ntdll kernel32) +add_dependencies(ntdll_vista psdk) +add_cd_file(TARGET ntdll_vista DESTINATION reactos/system32 FOR all) Propchange: trunk/reactos/dll/win32/ntdll_vista/CMakeLists.txt ------------------------------------------------------------------------------ svn:eol-style = native Added: trunk/reactos/dll/win32/ntdll_vista/DllMain.c URL: http://svn.reactos.org/svn/reactos/trunk/reactos/dll/win32/ntdll_vista/DllM… ============================================================================== --- trunk/reactos/dll/win32/ntdll_vista/DllMain.c (added) +++ trunk/reactos/dll/win32/ntdll_vista/DllMain.c [iso-8859-1] Tue May 30 21:35:05 2017 @@ -0,0 +1,36 @@ +#include <stdarg.h> + +#define WIN32_NO_STATUS + +#include <windef.h> +#include <winbase.h> +#include <winreg.h> +#include <winuser.h> +#include <winwlx.h> + +#define NDEBUG +#include <debug.h> + +VOID +RtlpInitializeKeyedEvent(VOID); + +VOID +RtlpCloseKeyedEvent(VOID); + +BOOL +WINAPI +DllMain(HANDLE hDll, + DWORD dwReason, + LPVOID lpReserved) +{ + if (dwReason == DLL_PROCESS_ATTACH) + { + DisableThreadLibraryCalls(hDll); + RtlpInitializeKeyedEvent(); + } + else if (dwReason == DLL_PROCESS_DETACH) + { + RtlpCloseKeyedEvent(); + } + return TRUE; +} Propchange: trunk/reactos/dll/win32/ntdll_vista/DllMain.c ------------------------------------------------------------------------------ svn:eol-style = native Added: trunk/reactos/dll/win32/ntdll_vista/condvar.c URL: http://svn.reactos.org/svn/reactos/trunk/reactos/dll/win32/ntdll_vista/cond… ============================================================================== --- trunk/reactos/dll/win32/ntdll_vista/condvar.c (added) +++ trunk/reactos/dll/win32/ntdll_vista/condvar.c [iso-8859-1] Tue May 30 21:35:05 2017 @@ -0,0 +1,525 @@ +/* + * COPYRIGHT: See COPYING in the top level directory + * PROJECT: ReactOS system libraries + * PURPOSE: Condition Variable Routines + * PROGRAMMERS: Thomas Weidenmueller <w3seek(a)reactos.com> + * Stephan A. Rï¿½ger + */ + +/* NOTE: This functionality can be optimized for releasing single + threads or for releasing all waiting threads at once. This + implementation is optimized for releasing a single thread at a time. + It wakes up sleeping threads in FIFO order. */ + +/* INCLUDES ******************************************************************/ + +#include <rtl_vista.h> + +#define NDEBUG +#include <debug.h> + +/* INTERNAL TYPES ************************************************************/ + +#define COND_VAR_UNUSED_FLAG ((ULONG_PTR)1) +#define COND_VAR_LOCKED_FLAG ((ULONG_PTR)2) +#define COND_VAR_FLAGS_MASK ((ULONG_PTR)3) +#define COND_VAR_ADDRESS_MASK (~COND_VAR_FLAGS_MASK) + +typedef struct _COND_VAR_WAIT_ENTRY +{ + /* ListEntry must have an alignment of at least 32-bits, since we + want COND_VAR_ADDRESS_MASK to cover all of the address. */ + LIST_ENTRY ListEntry; + PVOID WaitKey; + BOOLEAN ListRemovalHandled; +} COND_VAR_WAIT_ENTRY, * PCOND_VAR_WAIT_ENTRY; + +#define CONTAINING_COND_VAR_WAIT_ENTRY(address, field) \ + CONTAINING_RECORD(address, COND_VAR_WAIT_ENTRY, field) + +/* GLOBALS *******************************************************************/ + +static HANDLE CondVarKeyedEventHandle = NULL; + +/* INTERNAL FUNCTIONS ********************************************************/ + +FORCEINLINE +ULONG_PTR +InternalCmpXChgCondVarAcq(IN OUT PRTL_CONDITION_VARIABLE ConditionVariable, + IN ULONG_PTR Exchange, + IN ULONG_PTR Comperand) +{ + return (ULONG_PTR)InterlockedCompareExchangePointerAcquire(&ConditionVariable->Ptr, + (PVOID)Exchange, + (PVOID)Comperand); +} + +FORCEINLINE +ULONG_PTR +InternalCmpXChgCondVarRel(IN OUT PRTL_CONDITION_VARIABLE ConditionVariable, + IN ULONG_PTR Exchange, + IN ULONG_PTR Comperand) +{ + return (ULONG_PTR)InterlockedCompareExchangePointerRelease(&ConditionVariable->Ptr, + (PVOID)Exchange, + (PVOID)Comperand); +} + +FORCEINLINE +BOOLEAN * +InternalGetListRemovalHandledFlag(IN PCOND_VAR_WAIT_ENTRY Entry) +{ + return (BOOLEAN *)&Entry->ListRemovalHandled; +} + +static +PCOND_VAR_WAIT_ENTRY +InternalLockCondVar(IN OUT PRTL_CONDITION_VARIABLE ConditionVariable, + IN PCOND_VAR_WAIT_ENTRY InsertEntry OPTIONAL, + IN BOOLEAN * AbortIfLocked OPTIONAL) +{ + /* InsertEntry and AbortIfLocked may be NULL on entry. This routine + will return NULL if the lock was not acquired. Otherwise it has + successfully acquired the lock and the return value is a valid + reference to the list head associated with ConditionVariable. + The caller must in this case call InternalUnlockCondVar later + in order to unlock the condition variable. + + If InsertEntry is NULL and there are no entries on the list, this + routine will not acquire the lock and return NULL. If InsertEntry + is not NULL this routine ensures that InsertEntry will be on the + list when it returns successfully. + + If the lock is owned by another thread and AbortIfLocked is NULL, + this routine will block until it acquires the lock. If AbortIfLocked + is not NULL and the lock is owned by another thread, this routine + will periodically check if *AbortIfLocked is nonzero and if so, will + return NULL instead of continuing the wait. */ + + ULONG_PTR OldVal = (ULONG_PTR)ConditionVariable->Ptr; + + for (;;) + { + ULONG_PTR NewVal, LockRes; + PLIST_ENTRY OldListHead; + + if (OldVal & COND_VAR_LOCKED_FLAG) + { + /* The locked flag is set, indicating someone else currently + holds the lock. We'll spin until this flag becomes + clear or we're asked to abort. */ + YieldProcessor(); + + if ((AbortIfLocked != NULL) && *AbortIfLocked) + { + /* The caller wants us to abort in this case. */ + return NULL; + } + + /* Refresh OldVal and try again. */ + OldVal = *(ULONG_PTR *)&ConditionVariable->Ptr; + continue; + } + + /* Retrieve the list head currently associated with the + condition variable. */ + OldListHead = (PLIST_ENTRY)(OldVal & COND_VAR_ADDRESS_MASK); + if (InsertEntry == NULL) + { + /* The caller doesn't want to put any entry on the list. */ + if (OldListHead == NULL) + { + /* The list is empty, so there is nothing to lock. */ + return NULL; + } + + /* The list isn't empty. In this case we need to preserve + all of OldVal. */ + NewVal = OldVal; + } + else + { + /* Let InsertEntry be the new list head. Preserve only the + bits inside the COND_VAR_FLAGS_MASK range. */ + NewVal = ((OldVal & COND_VAR_FLAGS_MASK) | + (ULONG_PTR)&InsertEntry->ListEntry); + } + + /* Set the flag that indicates someone is holding the lock and + try to update the condition variable thread-safe. */ + NewVal |= COND_VAR_LOCKED_FLAG; + LockRes = InternalCmpXChgCondVarAcq(ConditionVariable, NewVal, OldVal); + if (LockRes == OldVal) + { + /* We successfully updated ConditionVariable the way we + wanted and now hold the lock. */ + if (InsertEntry == NULL) + { + /* We know that OldVal contains a valid address in + this case. */ + ASSERT(OldListHead != NULL); + return CONTAINING_COND_VAR_WAIT_ENTRY(OldListHead, ListEntry); + } + + /* InsertEntry is not on the list yet, so add it. In any + case InsertEntry will be the new list head. */ + if (OldListHead == NULL) + { + /* List was empty before. */ + InitializeListHead(&InsertEntry->ListEntry); + } + else + { + /* Make InsertEntry the last entry of the old list. + As InsertEntry will take the role as new list head, + OldListHead will become the second entry (InsertEntry->Flink) + on the new list. */ + InsertTailList(OldListHead, &InsertEntry->ListEntry); + } + + return InsertEntry; + } + + /* We didn't manage to update ConditionVariable, so try again. */ + OldVal = LockRes; + } +} + +static +VOID +InternalUnlockCondVar(IN OUT PRTL_CONDITION_VARIABLE ConditionVariable, + IN PCOND_VAR_WAIT_ENTRY RemoveEntry OPTIONAL) +{ + /* This routine assumes that the lock is being held on entry. + RemoveEntry may be NULL. If it is not NULL, this routine + assumes that RemoveEntry is on the list and will remove it + before releasing the lock. */ + ULONG_PTR OldVal = (ULONG_PTR)ConditionVariable->Ptr; + PLIST_ENTRY NewHeadEntry; + + ASSERT((OldVal & COND_VAR_LOCKED_FLAG) && + (OldVal & COND_VAR_ADDRESS_MASK)); + + NewHeadEntry = (PLIST_ENTRY)(OldVal & COND_VAR_ADDRESS_MASK); + if (RemoveEntry != NULL) + { + /* We have to drop RemoveEntry from the list. */ + if (&RemoveEntry->ListEntry == NewHeadEntry) + { + /* RemoveEntry is the list head. */ + if (!IsListEmpty(NewHeadEntry)) + { + /* The second entry in the list will become the new + list head. It's from the thread that arrived + right before the owner of RemoveEntry. */ + NewHeadEntry = NewHeadEntry->Flink; + RemoveEntryList(&RemoveEntry->ListEntry); + } + else + { + /* The list will be empty, so discard the list. */ + NewHeadEntry = NULL; + } + } + else + { + /* RemoveEntry is not the list head. The current list head + will remain. */ + RemoveEntryList(&RemoveEntry->ListEntry); + } + + /* Indicate to the owner of RemoveEntry that the entry + was removed from the list. RemoveEntry may not be touched + from here on. We don't use volatile semantics here since + the cache will anyway be flushed soon when we update + ConditionVariable. */ + RemoveEntry->ListRemovalHandled = TRUE; + } + + /* Now unlock thread-safe, while preserving any flags within the + COND_VAR_FLAGS_MASK range except for COND_VAR_LOCKED_FLAG. */ + for (;;) + { + ULONG_PTR NewVal = ((OldVal & (COND_VAR_FLAGS_MASK ^ COND_VAR_LOCKED_FLAG)) | + (ULONG_PTR)NewHeadEntry); + ULONG_PTR LockRes = InternalCmpXChgCondVarRel(ConditionVariable, NewVal, OldVal); + if (LockRes == OldVal) + { + /* We unlocked. */ + break; + } + + /* Try again. */ + OldVal = LockRes; + } +} + +static +VOID +InternalWake(IN OUT PRTL_CONDITION_VARIABLE ConditionVariable, + IN BOOLEAN ReleaseAll) +{ + /* If ReleaseAll is zero on entry, one thread at most will be woken. + Otherwise all waiting threads are woken. Wakeups happen in FIFO + order. */ + PCOND_VAR_WAIT_ENTRY CONST HeadEntry = InternalLockCondVar(ConditionVariable, NULL, NULL); + PCOND_VAR_WAIT_ENTRY Entry; + PCOND_VAR_WAIT_ENTRY NextEntry; + LARGE_INTEGER Timeout; + PCOND_VAR_WAIT_ENTRY RemoveOnUnlockEntry; + + ASSERT(CondVarKeyedEventHandle != NULL); + + if (HeadEntry == NULL) + { + /* There is noone there to wake up. In this case do nothing + and return immediately. We don't stockpile releases. */ + return; + } + + Timeout.QuadPart = 0; + RemoveOnUnlockEntry = NULL; + + /* Release sleeping threads. We will iterate from the last entry on + the list to the first. Note that the loop condition is always + true for the initial test. */ + for (Entry = CONTAINING_COND_VAR_WAIT_ENTRY(HeadEntry->ListEntry.Blink, ListEntry); + Entry != NULL; + Entry = NextEntry) + { + NTSTATUS Status; + + if (HeadEntry == Entry) + { + /* After the current entry we've iterated through the + entire list in backward direction. Then exit.*/ + NextEntry = NULL; + } + else + { + /* Store away the next reference right now, since we may + not touch Entry anymore at the end of the block. */ + NextEntry = CONTAINING_COND_VAR_WAIT_ENTRY(Entry->ListEntry.Blink, ListEntry); + } + + /* Wake the thread associated with this event. We will + immediately return if we failed (zero timeout). */ + Status = NtReleaseKeyedEvent(CondVarKeyedEventHandle, + &Entry->WaitKey, + FALSE, + &Timeout); + + if (!NT_SUCCESS(Status)) + { + /* We failed to wake a thread. We'll keep trying. */ + ASSERT(STATUS_INVALID_HANDLE != Status); + continue; + } + + /* We've woken a thread and will make sure this thread + is removed from the list. */ + if (HeadEntry == Entry) + { + /* This is the list head. We can't remove it as easily as + other entries and will pass it to the unlock routine + later (we will exit the loop after this round anyway). */ + RemoveOnUnlockEntry = HeadEntry; + } + else + { + /* We can remove the entry right away. */ + RemoveEntryList(&Entry->ListEntry); + + /* Now tell the woken thread that removal from the list was + already taken care of here so that this thread can resume + its normal operation more quickly. We may not touch + Entry after signaling this, since it may lie in invalid + memory from there on. */ + *InternalGetListRemovalHandledFlag(Entry) = TRUE; + } + + if (!ReleaseAll) + { + /* We've successfully woken one thread as the caller + demanded. */ + break; + } + } + + InternalUnlockCondVar(ConditionVariable, RemoveOnUnlockEntry); +} + +VOID +NTAPI +RtlAcquireSRWLockExclusive(IN OUT PRTL_SRWLOCK SRWLock); +VOID +NTAPI +RtlAcquireSRWLockShared(IN OUT PRTL_SRWLOCK SRWLock); +VOID +NTAPI +RtlReleaseSRWLockExclusive(IN OUT PRTL_SRWLOCK SRWLock); +VOID +NTAPI +RtlReleaseSRWLockShared(IN OUT PRTL_SRWLOCK SRWLock); + +static +NTSTATUS +InternalSleep(IN OUT PRTL_CONDITION_VARIABLE ConditionVariable, + IN OUT PRTL_CRITICAL_SECTION CriticalSection OPTIONAL, + IN OUT PRTL_SRWLOCK SRWLock OPTIONAL, + IN ULONG SRWFlags, + IN const LARGE_INTEGER * TimeOut OPTIONAL) +{ + /* Either CriticalSection or SRWLock must be NULL, but not both. + These caller provided lock must be held on entry and will be + held again on return. */ + + COND_VAR_WAIT_ENTRY OwnEntry; + NTSTATUS Status; + + ASSERT(CondVarKeyedEventHandle != NULL); + ASSERT((CriticalSection == NULL) != (SRWLock == NULL)); + + RtlZeroMemory(&OwnEntry, sizeof(OwnEntry)); + + /* Put OwnEntry on the list. */ + InternalLockCondVar(ConditionVariable, &OwnEntry, NULL); + InternalUnlockCondVar(ConditionVariable, NULL); + + /* We can now drop the caller provided lock as a preparation for + going to sleep. */ + if (CriticalSection == NULL) + { + if (0 == (RTL_CONDITION_VARIABLE_LOCKMODE_SHARED & SRWFlags)) + { + RtlReleaseSRWLockExclusive(SRWLock); + } + else + { + RtlReleaseSRWLockShared(SRWLock); + } + } + else + { + RtlLeaveCriticalSection(CriticalSection); + } + + /* Now sleep using the caller provided timeout. */ + Status = NtWaitForKeyedEvent(CondVarKeyedEventHandle, + &OwnEntry.WaitKey, + FALSE, + (PLARGE_INTEGER)TimeOut); + + ASSERT(STATUS_INVALID_HANDLE != Status); + + if (!*InternalGetListRemovalHandledFlag(&OwnEntry)) + { + /* Remove OwnEntry from the list again, since it still seems to + be on the list. We will know for sure once we've acquired + the lock. */ + if (InternalLockCondVar(ConditionVariable, + NULL, + InternalGetListRemovalHandledFlag(&OwnEntry))) + { + /* Unlock and potentially remove OwnEntry. Self-removal is + usually only necessary when a timeout occurred. */ + InternalUnlockCondVar(ConditionVariable, + !OwnEntry.ListRemovalHandled ? + &OwnEntry : NULL); + } + } + +#if _DEBUG + /* Clear OwnEntry to aid in detecting bugs. */ + RtlZeroMemory(&OwnEntry, sizeof(OwnEntry)); +#endif + + /* Reacquire the caller provided lock, as we are about to return. */ + if (CriticalSection == NULL) + { + if (0 == (RTL_CONDITION_VARIABLE_LOCKMODE_SHARED & SRWFlags)) + { + RtlAcquireSRWLockExclusive(SRWLock); + } + else + { + RtlAcquireSRWLockShared(SRWLock); + } + } + else + { + RtlEnterCriticalSection(CriticalSection); + } + + /* Return whatever NtWaitForKeyedEvent returned. */ + return Status; +} + +VOID +RtlpInitializeKeyedEvent(VOID) +{ + ASSERT(CondVarKeyedEventHandle == NULL); + NtCreateKeyedEvent(&CondVarKeyedEventHandle, EVENT_ALL_ACCESS, NULL, 0); +} + +VOID +RtlpCloseKeyedEvent(VOID) +{ + ASSERT(CondVarKeyedEventHandle != NULL); + NtClose(CondVarKeyedEventHandle); + CondVarKeyedEventHandle = NULL; +} + +/* EXPORTED FUNCTIONS ********************************************************/ + +VOID +NTAPI +RtlInitializeConditionVariable(OUT PRTL_CONDITION_VARIABLE ConditionVariable) +{ + ConditionVariable->Ptr = NULL; +} + +VOID +NTAPI +RtlWakeConditionVariable(IN OUT PRTL_CONDITION_VARIABLE ConditionVariable) +{ + InternalWake(ConditionVariable, FALSE); +} + +VOID +NTAPI +RtlWakeAllConditionVariable(IN OUT PRTL_CONDITION_VARIABLE ConditionVariable) +{ + InternalWake(ConditionVariable, TRUE); +} + +NTSYSAPI +NTSTATUS +NTAPI +RtlSleepConditionVariableCS(IN OUT PRTL_CONDITION_VARIABLE ConditionVariable, + IN OUT PRTL_CRITICAL_SECTION CriticalSection, + IN const LARGE_INTEGER * TimeOut OPTIONAL) +{ + return InternalSleep(ConditionVariable, + CriticalSection, + (PRTL_SRWLOCK)NULL, + 0, + TimeOut); +} + +NTSYSAPI +NTSTATUS +NTAPI +RtlSleepConditionVariableSRW(IN OUT PRTL_CONDITION_VARIABLE ConditionVariable, + IN OUT PRTL_SRWLOCK SRWLock, + IN const LARGE_INTEGER * TimeOut OPTIONAL, + IN ULONG Flags) +{ + return InternalSleep(ConditionVariable, + (PRTL_CRITICAL_SECTION)NULL, + SRWLock, + Flags, + TimeOut); +} + +/* EOF */ Propchange: trunk/reactos/dll/win32/ntdll_vista/condvar.c ------------------------------------------------------------------------------ svn:eol-style = native Added: trunk/reactos/dll/win32/ntdll_vista/ntdll_vista.spec URL: http://svn.reactos.org/svn/reactos/trunk/reactos/dll/win32/ntdll_vista/ntdl… ============================================================================== --- trunk/reactos/dll/win32/ntdll_vista/ntdll_vista.spec (added) +++ trunk/reactos/dll/win32/ntdll_vista/ntdll_vista.spec [iso-8859-1] Tue May 30 21:35:05 2017 @@ -0,0 +1,10 @@ +@ stdcall RtlInitializeConditionVariable(ptr) +@ stdcall RtlWakeConditionVariable(ptr) +@ stdcall RtlWakeAllConditionVariable(ptr) +@ stdcall RtlSleepConditionVariableCS(ptr ptr ptr) +@ stdcall RtlSleepConditionVariableSRW(ptr ptr ptr long) +@ stdcall RtlInitializeSRWLock(ptr) +@ stdcall RtlAcquireSRWLockShared(ptr) +@ stdcall RtlReleaseSRWLockShared(ptr) +@ stdcall RtlAcquireSRWLockExclusive(ptr) +@ stdcall RtlReleaseSRWLockExclusive(ptr) Propchange: trunk/reactos/dll/win32/ntdll_vista/ntdll_vista.spec ------------------------------------------------------------------------------ svn:eol-style = native Added: trunk/reactos/dll/win32/ntdll_vista/rtl_vista.h URL: http://svn.reactos.org/svn/reactos/trunk/reactos/dll/win32/ntdll_vista/rtl_… ============================================================================== --- trunk/reactos/dll/win32/ntdll_vista/rtl_vista.h (added) +++ trunk/reactos/dll/win32/ntdll_vista/rtl_vista.h [iso-8859-1] Tue May 30 21:35:05 2017 @@ -0,0 +1,57 @@ +/* + * COPYRIGHT: See COPYING in the top level directory + * PROJECT: ReactOS System Libraries + * FILE: lib/rtl/rtl.h + * PURPOSE: Run-Time Libary Header + * PROGRAMMER: Alex Ionescu + */ + +#ifndef RTL_H +#define RTL_H + +/* We're a core NT DLL, we don't import syscalls */ +#define _INC_SWPRINTF_INL_ +#undef __MSVCRT__ + +/* C Headers */ +#include <stdlib.h> +#include <stdio.h> + +/* PSDK/NDK Headers */ +#define WIN32_NO_STATUS +#define _INC_WINDOWS +#define COM_NO_WINDOWS_H +#define COBJMACROS +#define CONST_VTABLE +#include <windef.h> +#include <winbase.h> +#include <winreg.h> +#include <objbase.h> +#include <ntintsafe.h> +#include <ndk/exfuncs.h> +#include <ndk/iofuncs.h> +#include <ndk/kefuncs.h> +#include <ndk/ldrfuncs.h> +#include <ndk/mmfuncs.h> +#include <ndk/obfuncs.h> +#include <ndk/psfuncs.h> +#include <ndk/rtlfuncs.h> +#include <ndk/setypes.h> +#include <ndk/sefuncs.h> +#include <ndk/umfuncs.h> + +/* SEH support with PSEH */ +#include <pseh/pseh2.h> + +/* Use intrinsics for x86 and x64 */ +#if defined(_M_IX86) || defined(_M_AMD64) +#define InterlockedCompareExchange _InterlockedCompareExchange +#define InterlockedIncrement _InterlockedIncrement +#define InterlockedDecrement _InterlockedDecrement +#define InterlockedExchangeAdd _InterlockedExchangeAdd +#define InterlockedExchange _InterlockedExchange +#define InterlockedBitTestAndSet _interlockedbittestandset +#define InterlockedBitTestAndSet64 _interlockedbittestandset64 +#endif + +#endif /* RTL_H */ Propchange: trunk/reactos/dll/win32/ntdll_vista/rtl_vista.h ------------------------------------------------------------------------------ svn:eol-style = native Copied: trunk/reactos/dll/win32/ntdll_vista/srw.c (from r74702, trunk/reactos/sdk/lib/rtl/srw.c) URL: http://svn.reactos.org/svn/reactos/trunk/reactos/dll/win32/ntdll_vista/srw.… ============================================================================== --- trunk/reactos/sdk/lib/rtl/srw.c [iso-8859-1] (original) +++ trunk/reactos/dll/win32/ntdll_vista/srw.c [iso-8859-1] Tue May 30 21:35:05 2017 @@ -13,7 +13,7 @@ /* INCLUDES *****************************************************************/ -#include <rtl.h> +#include <rtl_vista.h> #define NDEBUG #include <debug.h> Modified: trunk/reactos/sdk/lib/rtl/CMakeLists.txt URL: http://svn.reactos.org/svn/reactos/trunk/reactos/sdk/lib/rtl/CMakeLists.txt… ============================================================================== --- trunk/reactos/sdk/lib/rtl/CMakeLists.txt [iso-8859-1] (original) +++ trunk/reactos/sdk/lib/rtl/CMakeLists.txt [iso-8859-1] Tue May 30 21:35:05 2017 @@ -16,7 +16,6 @@ bitmap.c bootdata.c compress.c - condvar.c crc32.c critical.c dbgbuffer.c @@ -56,7 +55,6 @@ security.c slist.c sid.c - srw.c splaytree.c thread.c time.c Removed: trunk/reactos/sdk/lib/rtl/srw.c URL: http://svn.reactos.org/svn/reactos/trunk/reactos/sdk/lib/rtl/srw.c?rev=74702 ============================================================================== --- trunk/reactos/sdk/lib/rtl/srw.c [iso-8859-1] (original) +++ trunk/reactos/sdk/lib/rtl/srw.c (removed) @@ -1,765 +0,0 @@ -/* - * COPYRIGHT: See COPYING in the top level directory - * PROJECT: ReactOS system libraries - * PURPOSE: Slim Reader/Writer (SRW) Routines - * PROGRAMMER: Thomas Weidenmueller <w3seek(a)reactos.com> - * - * NOTES: The algorithms used in this implementation - * may be different from Vista's implementation. - * Since applications should treat the RTL_SRWLOCK - * structure as opaque data, it should not matter. - * The algorithms are probably not as optimized. - */ - -/* INCLUDES *****************************************************************/ - -#include <rtl.h> - -#define NDEBUG -#include <debug.h> - -/* FUNCTIONS *****************************************************************/ - -#ifdef _WIN64 -#define InterlockedBitTestAndSetPointer(ptr,val) InterlockedBitTestAndSet64((PLONGLONG)ptr,(LONGLONG)val) -#define InterlockedAddPointer(ptr,val) InterlockedAdd64((PLONGLONG)ptr,(LONGLONG)val) -#define InterlockedAndPointer(ptr,val) InterlockedAnd64((PLONGLONG)ptr,(LONGLONG)val) -#define InterlockedOrPointer(ptr,val) InterlockedOr64((PLONGLONG)ptr,(LONGLONG)val) -#else -#define InterlockedBitTestAndSetPointer(ptr,val) InterlockedBitTestAndSet((PLONG)ptr,(LONG)val) -#define InterlockedAddPointer(ptr,val) InterlockedAdd((PLONG)ptr,(LONG)val) -#define InterlockedAndPointer(ptr,val) InterlockedAnd((PLONG)ptr,(LONG)val) -#define InterlockedOrPointer(ptr,val) InterlockedOr((PLONG)ptr,(LONG)val) -#endif - -#define RTL_SRWLOCK_OWNED_BIT 0 -#define RTL_SRWLOCK_CONTENDED_BIT 1 -#define RTL_SRWLOCK_SHARED_BIT 2 -#define RTL_SRWLOCK_CONTENTION_LOCK_BIT 3 -#define RTL_SRWLOCK_OWNED (1 << RTL_SRWLOCK_OWNED_BIT) -#define RTL_SRWLOCK_CONTENDED (1 << RTL_SRWLOCK_CONTENDED_BIT) -#define RTL_SRWLOCK_SHARED (1 << RTL_SRWLOCK_SHARED_BIT) -#define RTL_SRWLOCK_CONTENTION_LOCK (1 << RTL_SRWLOCK_CONTENTION_LOCK_BIT) -#define RTL_SRWLOCK_MASK (RTL_SRWLOCK_OWNED | RTL_SRWLOCK_CONTENDED | \ - RTL_SRWLOCK_SHARED | RTL_SRWLOCK_CONTENTION_LOCK) -#define RTL_SRWLOCK_BITS 4 - -typedef struct _RTLP_SRWLOCK_SHARED_WAKE -{ - LONG Wake; - volatile struct _RTLP_SRWLOCK_SHARED_WAKE *Next; -} volatile RTLP_SRWLOCK_SHARED_WAKE, *PRTLP_SRWLOCK_SHARED_WAKE; - -typedef struct _RTLP_SRWLOCK_WAITBLOCK -{ - /* SharedCount is the number of shared acquirers. */ - LONG SharedCount; - - /* Last points to the last wait block in the chain. The value - is only valid when read from the first wait block. */ - volatile struct _RTLP_SRWLOCK_WAITBLOCK *Last; - - /* Next points to the next wait block in the chain. */ - volatile struct _RTLP_SRWLOCK_WAITBLOCK *Next; - - union - { - /* Wake is only valid for exclusive wait blocks */ - LONG Wake; - /* The wake chain is only valid for shared wait blocks */ - struct - { - PRTLP_SRWLOCK_SHARED_WAKE SharedWakeChain; - PRTLP_SRWLOCK_SHARED_WAKE LastSharedWake; - }; - }; - - BOOLEAN Exclusive; -} volatile RTLP_SRWLOCK_WAITBLOCK, *PRTLP_SRWLOCK_WAITBLOCK; - - -static VOID -NTAPI -RtlpReleaseWaitBlockLockExclusive(IN OUT PRTL_SRWLOCK SRWLock, - IN PRTLP_SRWLOCK_WAITBLOCK FirstWaitBlock) -{ - PRTLP_SRWLOCK_WAITBLOCK Next; - LONG_PTR NewValue; - - /* NOTE: We're currently in an exclusive lock in contended mode. */ - - Next = FirstWaitBlock->Next; - if (Next != NULL) - { - /* There's more blocks chained, we need to update the pointers - in the next wait block and update the wait block pointer. */ - NewValue = (LONG_PTR)Next | RTL_SRWLOCK_OWNED | RTL_SRWLOCK_CONTENDED; - if (!FirstWaitBlock->Exclusive) - { - /* The next wait block has to be an exclusive lock! */ - ASSERT(Next->Exclusive); - - /* Save the shared count */ - Next->SharedCount = FirstWaitBlock->SharedCount; - - NewValue |= RTL_SRWLOCK_SHARED; - } - - Next->Last = FirstWaitBlock->Last; - } - else - { - /* Convert the lock to a simple lock. */ - if (FirstWaitBlock->Exclusive) - NewValue = RTL_SRWLOCK_OWNED; - else - { - ASSERT(FirstWaitBlock->SharedCount > 0); - - NewValue = ((LONG_PTR)FirstWaitBlock->SharedCount << RTL_SRWLOCK_BITS) | - RTL_SRWLOCK_SHARED | RTL_SRWLOCK_OWNED; - } - } - - (void)InterlockedExchangePointer(&SRWLock->Ptr, (PVOID)NewValue); - - if (FirstWaitBlock->Exclusive) - { - (void)InterlockedOr(&FirstWaitBlock->Wake, - TRUE); - } - else - { - PRTLP_SRWLOCK_SHARED_WAKE WakeChain, NextWake; - - /* If we were the first one to acquire the shared - lock, we now need to wake all others... */ - WakeChain = FirstWaitBlock->SharedWakeChain; - do - { - NextWake = WakeChain->Next; - - (void)InterlockedOr((PLONG)&WakeChain->Wake, - TRUE); - - WakeChain = NextWake; - } while (WakeChain != NULL); - } -} - - -static VOID -NTAPI -RtlpReleaseWaitBlockLockLastShared(IN OUT PRTL_SRWLOCK SRWLock, - IN PRTLP_SRWLOCK_WAITBLOCK FirstWaitBlock) -{ - PRTLP_SRWLOCK_WAITBLOCK Next; - LONG_PTR NewValue; - - /* NOTE: We're currently in a shared lock in contended mode. */ - - /* The next acquirer to be unwaited *must* be an exclusive lock! */ - ASSERT(FirstWaitBlock->Exclusive); - - Next = FirstWaitBlock->Next; - if (Next != NULL) - { - /* There's more blocks chained, we need to update the pointers - in the next wait block and update the wait block pointer. */ - NewValue = (LONG_PTR)Next | RTL_SRWLOCK_OWNED | RTL_SRWLOCK_CONTENDED; - - Next->Last = FirstWaitBlock->Last; - } - else - { - /* Convert the lock to a simple exclusive lock. */ - NewValue = RTL_SRWLOCK_OWNED; - } - - (void)InterlockedExchangePointer(&SRWLock->Ptr, (PVOID)NewValue); - - (void)InterlockedOr(&FirstWaitBlock->Wake, - TRUE); -} - - -static VOID -NTAPI -RtlpReleaseWaitBlockLock(IN OUT PRTL_SRWLOCK SRWLock) -{ - InterlockedAndPointer(&SRWLock->Ptr, - ~RTL_SRWLOCK_CONTENTION_LOCK); -} - - -static PRTLP_SRWLOCK_WAITBLOCK -NTAPI -RtlpAcquireWaitBlockLock(IN OUT PRTL_SRWLOCK SRWLock) -{ - LONG_PTR PrevValue; - PRTLP_SRWLOCK_WAITBLOCK WaitBlock; - - while (1) - { - PrevValue = InterlockedOrPointer(&SRWLock->Ptr, - RTL_SRWLOCK_CONTENTION_LOCK); - - if (!(PrevValue & RTL_SRWLOCK_CONTENTION_LOCK)) - break; - - YieldProcessor(); - } - - if (!(PrevValue & RTL_SRWLOCK_CONTENDED) || - (PrevValue & ~RTL_SRWLOCK_MASK) == 0) - { - /* Too bad, looks like the wait block was removed in the - meanwhile, unlock again */ - RtlpReleaseWaitBlockLock(SRWLock); - return NULL; - } - - WaitBlock = (PRTLP_SRWLOCK_WAITBLOCK)(PrevValue & ~RTL_SRWLOCK_MASK); - - return WaitBlock; -} - - -static VOID -NTAPI -RtlpAcquireSRWLockExclusiveWait(IN OUT PRTL_SRWLOCK SRWLock, - IN PRTLP_SRWLOCK_WAITBLOCK WaitBlock) -{ - LONG_PTR CurrentValue; - - while (1) - { - CurrentValue = *(volatile LONG_PTR *)&SRWLock->Ptr; - if (!(CurrentValue & RTL_SRWLOCK_SHARED)) - { - if (CurrentValue & RTL_SRWLOCK_CONTENDED) - { - if (WaitBlock->Wake != 0) - { - /* Our wait block became the first one - in the chain, we own the lock now! */ - break; - } - } - else - { - /* The last wait block was removed and/or we're - finally a simple exclusive lock. This means we - don't need to wait anymore, we acquired the lock! */ - break; - } - } - - YieldProcessor(); - } -} - - -static VOID -NTAPI -RtlpAcquireSRWLockSharedWait(IN OUT PRTL_SRWLOCK SRWLock, - IN OUT PRTLP_SRWLOCK_WAITBLOCK FirstWait OPTIONAL, - IN OUT PRTLP_SRWLOCK_SHARED_WAKE WakeChain) -{ - if (FirstWait != NULL) - { - while (WakeChain->Wake == 0) - { - YieldProcessor(); - } - } - else - { - LONG_PTR CurrentValue; - - while (1) - { - CurrentValue = *(volatile LONG_PTR *)&SRWLock->Ptr; - if (CurrentValue & RTL_SRWLOCK_SHARED) - { - /* The RTL_SRWLOCK_OWNED bit always needs to be set when - RTL_SRWLOCK_SHARED is set! */ - ASSERT(CurrentValue & RTL_SRWLOCK_OWNED); - - if (CurrentValue & RTL_SRWLOCK_CONTENDED) - { - if (WakeChain->Wake != 0) - { - /* Our wait block became the first one - in the chain, we own the lock now! */ - break; - } - } - else - { - /* The last wait block was removed and/or we're - finally a simple shared lock. This means we - don't need to wait anymore, we acquired the lock! */ - break; - } - } - - YieldProcessor(); - } - } -} - - -VOID -NTAPI -RtlInitializeSRWLock(OUT PRTL_SRWLOCK SRWLock) -{ - SRWLock->Ptr = NULL; -} - - -VOID -NTAPI -RtlAcquireSRWLockShared(IN OUT PRTL_SRWLOCK SRWLock) -{ - __ALIGNED(16) RTLP_SRWLOCK_WAITBLOCK StackWaitBlock; - RTLP_SRWLOCK_SHARED_WAKE SharedWake; - LONG_PTR CurrentValue, NewValue; - PRTLP_SRWLOCK_WAITBLOCK First, Shared, FirstWait; - - while (1) - { - CurrentValue = *(volatile LONG_PTR *)&SRWLock->Ptr; - - if (CurrentValue & RTL_SRWLOCK_SHARED) - { - /* NOTE: It is possible that the RTL_SRWLOCK_OWNED bit is set! */ - - if (CurrentValue & RTL_SRWLOCK_CONTENDED) - { - /* There's other waiters already, lock the wait blocks and - increment the shared count */ - First = RtlpAcquireWaitBlockLock(SRWLock); - if (First != NULL) - { - FirstWait = NULL; - - if (First->Exclusive) - { - /* We need to setup a new wait block! Although - we're currently in a shared lock and we're acquiring - a shared lock, there are exclusive locks queued. We need - to wait until those are released. */ - Shared = First->Last; - - if (Shared->Exclusive) - { - StackWaitBlock.Exclusive = FALSE; - StackWaitBlock.SharedCount = 1; - StackWaitBlock.Next = NULL; - StackWaitBlock.Last = &StackWaitBlock; - StackWaitBlock.SharedWakeChain = &SharedWake; - - Shared->Next = &StackWaitBlock; - First->Last = &StackWaitBlock; - - Shared = &StackWaitBlock; - FirstWait = &StackWaitBlock; - } - else - { - Shared->LastSharedWake->Next = &SharedWake; - Shared->SharedCount++; - } - } - else - { - Shared = First; - Shared->LastSharedWake->Next = &SharedWake; - Shared->SharedCount++; - } - - SharedWake.Next = NULL; - SharedWake.Wake = 0; - - Shared->LastSharedWake = &SharedWake; - - RtlpReleaseWaitBlockLock(SRWLock); - - RtlpAcquireSRWLockSharedWait(SRWLock, - FirstWait, - &SharedWake); - - /* Successfully incremented the shared count, we acquired the lock */ - break; - } - } - else - { - /* This is a fastest path, just increment the number of - current shared locks */ - - /* Since the RTL_SRWLOCK_SHARED bit is set, the RTL_SRWLOCK_OWNED bit also has - to be set! */ - - ASSERT(CurrentValue & RTL_SRWLOCK_OWNED); - - NewValue = (CurrentValue >> RTL_SRWLOCK_BITS) + 1; - NewValue = (NewValue << RTL_SRWLOCK_BITS) | (CurrentValue & RTL_SRWLOCK_MASK); - - if ((LONG_PTR)InterlockedCompareExchangePointer(&SRWLock->Ptr, - (PVOID)NewValue, - (PVOID)CurrentValue) == CurrentValue) - { - /* Successfully incremented the shared count, we acquired the lock */ - break; - } - } - } - else - { - if (CurrentValue & RTL_SRWLOCK_OWNED) - { - /* The resource is currently acquired exclusively */ - if (CurrentValue & RTL_SRWLOCK_CONTENDED) - { - SharedWake.Next = NULL; - SharedWake.Wake = 0; - - /* There's other waiters already, lock the wait blocks and - increment the shared count. If the last block in the chain - is an exclusive lock, add another block. */ - - StackWaitBlock.Exclusive = FALSE; - StackWaitBlock.SharedCount = 0; - StackWaitBlock.Next = NULL; - StackWaitBlock.Last = &StackWaitBlock; - StackWaitBlock.SharedWakeChain = &SharedWake; - - First = RtlpAcquireWaitBlockLock(SRWLock); - if (First != NULL) - { - Shared = First->Last; - if (Shared->Exclusive) - { - Shared->Next = &StackWaitBlock; - First->Last = &StackWaitBlock; - - Shared = &StackWaitBlock; - FirstWait = &StackWaitBlock; - } - else - { - FirstWait = NULL; - Shared->LastSharedWake->Next = &SharedWake; - } - - Shared->SharedCount++; - Shared->LastSharedWake = &SharedWake; - - RtlpReleaseWaitBlockLock(SRWLock); - - RtlpAcquireSRWLockSharedWait(SRWLock, - FirstWait, - &SharedWake); - - /* Successfully incremented the shared count, we acquired the lock */ - break; - } - } - else - { - SharedWake.Next = NULL; - SharedWake.Wake = 0; - - /* We need to setup the first wait block. Currently an exclusive lock is - held, change the lock to contended mode. */ - StackWaitBlock.Exclusive = FALSE; - StackWaitBlock.SharedCount = 1; - StackWaitBlock.Next = NULL; - StackWaitBlock.Last = &StackWaitBlock; - StackWaitBlock.SharedWakeChain = &SharedWake; - StackWaitBlock.LastSharedWake = &SharedWake; - - NewValue = (ULONG_PTR)&StackWaitBlock | RTL_SRWLOCK_OWNED | RTL_SRWLOCK_CONTENDED; - if ((LONG_PTR)InterlockedCompareExchangePointer(&SRWLock->Ptr, - (PVOID)NewValue, - (PVOID)CurrentValue) == CurrentValue) - { - RtlpAcquireSRWLockSharedWait(SRWLock, - &StackWaitBlock, - &SharedWake); - - /* Successfully set the shared count, we acquired the lock */ - break; - } - } - } - else - { - /* This is a fast path, we can simply try to set the shared count to 1 */ - NewValue = (1 << RTL_SRWLOCK_BITS) | RTL_SRWLOCK_SHARED | RTL_SRWLOCK_OWNED; - - /* The RTL_SRWLOCK_CONTENDED bit should never be set if neither the - RTL_SRWLOCK_SHARED nor the RTL_SRWLOCK_OWNED bit is set */ - ASSERT(!(CurrentValue & RTL_SRWLOCK_CONTENDED)); - - if ((LONG_PTR)InterlockedCompareExchangePointer(&SRWLock->Ptr, - (PVOID)NewValue, - (PVOID)CurrentValue) == CurrentValue) - { - /* Successfully set the shared count, we acquired the lock */ - break; - } - } - } - - YieldProcessor(); - } -} - - -VOID -NTAPI -RtlReleaseSRWLockShared(IN OUT PRTL_SRWLOCK SRWLock) -{ - LONG_PTR CurrentValue, NewValue; - PRTLP_SRWLOCK_WAITBLOCK WaitBlock; - BOOLEAN LastShared; - - while (1) - { - CurrentValue = *(volatile LONG_PTR *)&SRWLock->Ptr; - - if (CurrentValue & RTL_SRWLOCK_SHARED) - { - if (CurrentValue & RTL_SRWLOCK_CONTENDED) - { - /* There's a wait block, we need to wake a pending - exclusive acquirer if this is the last shared release */ - WaitBlock = RtlpAcquireWaitBlockLock(SRWLock); - if (WaitBlock != NULL) - { - LastShared = (--WaitBlock->SharedCount == 0); - - if (LastShared) - RtlpReleaseWaitBlockLockLastShared(SRWLock, - WaitBlock); - else - RtlpReleaseWaitBlockLock(SRWLock); - - /* We released the lock */ - break; - } - } - else - { - /* This is a fast path, we can simply decrement the shared - count and store the pointer */ - NewValue = CurrentValue >> RTL_SRWLOCK_BITS; - - if (--NewValue != 0) - { - NewValue = (NewValue << RTL_SRWLOCK_BITS) | RTL_SRWLOCK_SHARED | RTL_SRWLOCK_OWNED; - } - - if ((LONG_PTR)InterlockedCompareExchangePointer(&SRWLock->Ptr, - (PVOID)NewValue, - (PVOID)CurrentValue) == CurrentValue) - { - /* Successfully released the lock */ - break; - } - } - } - else - { - /* The RTL_SRWLOCK_SHARED bit has to be present now, - even in the contended case! */ - RtlRaiseStatus(STATUS_RESOURCE_NOT_OWNED); - } - - YieldProcessor(); - } -} - - -VOID -NTAPI -RtlAcquireSRWLockExclusive(IN OUT PRTL_SRWLOCK SRWLock) -{ - __ALIGNED(16) RTLP_SRWLOCK_WAITBLOCK StackWaitBlock; - PRTLP_SRWLOCK_WAITBLOCK First, Last; - - if (InterlockedBitTestAndSetPointer(&SRWLock->Ptr, - RTL_SRWLOCK_OWNED_BIT)) - { - LONG_PTR CurrentValue, NewValue; - - while (1) - { - CurrentValue = *(volatile LONG_PTR *)&SRWLock->Ptr; - - if (CurrentValue & RTL_SRWLOCK_SHARED) - { - /* A shared lock is being held right now. We need to add a wait block! */ - - if (CurrentValue & RTL_SRWLOCK_CONTENDED) - { - goto AddWaitBlock; - } - else - { - /* There are no wait blocks so far, we need to add ourselves as the first - wait block. We need to keep the shared count! */ - StackWaitBlock.Exclusive = TRUE; - StackWaitBlock.SharedCount = (LONG)(CurrentValue >> RTL_SRWLOCK_BITS); - StackWaitBlock.Next = NULL; - StackWaitBlock.Last = &StackWaitBlock; - StackWaitBlock.Wake = 0; - - NewValue = (ULONG_PTR)&StackWaitBlock | RTL_SRWLOCK_SHARED | RTL_SRWLOCK_CONTENDED | RTL_SRWLOCK_OWNED; - - if ((LONG_PTR)InterlockedCompareExchangePointer(&SRWLock->Ptr, - (PVOID)NewValue, - (PVOID)CurrentValue) == CurrentValue) - { - RtlpAcquireSRWLockExclusiveWait(SRWLock, - &StackWaitBlock); - - /* Successfully acquired the exclusive lock */ - break; - } - } - } - else - { - if (CurrentValue & RTL_SRWLOCK_OWNED) - { - /* An exclusive lock is being held right now. We need to add a wait block! */ - - if (CurrentValue & RTL_SRWLOCK_CONTENDED) - { -AddWaitBlock: - StackWaitBlock.Exclusive = TRUE; - StackWaitBlock.SharedCount = 0; - StackWaitBlock.Next = NULL; - StackWaitBlock.Last = &StackWaitBlock; - StackWaitBlock.Wake = 0; - - First = RtlpAcquireWaitBlockLock(SRWLock); - if (First != NULL) - { - Last = First->Last; - Last->Next = &StackWaitBlock; - First->Last = &StackWaitBlock; - - RtlpReleaseWaitBlockLock(SRWLock); - - RtlpAcquireSRWLockExclusiveWait(SRWLock, - &StackWaitBlock); - - /* Successfully acquired the exclusive lock */ - break; - } - } - else - { - /* There are no wait blocks so far, we need to add ourselves as the first - wait block. We need to keep the shared count! */ - StackWaitBlock.Exclusive = TRUE; - StackWaitBlock.SharedCount = 0; - StackWaitBlock.Next = NULL; - StackWaitBlock.Last = &StackWaitBlock; - StackWaitBlock.Wake = 0; - - NewValue = (ULONG_PTR)&StackWaitBlock | RTL_SRWLOCK_OWNED | RTL_SRWLOCK_CONTENDED; - if ((LONG_PTR)InterlockedCompareExchangePointer(&SRWLock->Ptr, - (PVOID)NewValue, - (PVOID)CurrentValue) == CurrentValue) - { - RtlpAcquireSRWLockExclusiveWait(SRWLock, - &StackWaitBlock); - - /* Successfully acquired the exclusive lock */ - break; - } - } - } - else - { - if (!InterlockedBitTestAndSetPointer(&SRWLock->Ptr, - RTL_SRWLOCK_OWNED_BIT)) - { - /* We managed to get hold of a simple exclusive lock! */ - break; - } - } - } - - YieldProcessor(); - } - } -} - - -VOID -NTAPI -RtlReleaseSRWLockExclusive(IN OUT PRTL_SRWLOCK SRWLock) -{ - LONG_PTR CurrentValue, NewValue; - PRTLP_SRWLOCK_WAITBLOCK WaitBlock; - - while (1) - { - CurrentValue = *(volatile LONG_PTR *)&SRWLock->Ptr; - - if (!(CurrentValue & RTL_SRWLOCK_OWNED)) - { - RtlRaiseStatus(STATUS_RESOURCE_NOT_OWNED); - } - - if (!(CurrentValue & RTL_SRWLOCK_SHARED)) - { - if (CurrentValue & RTL_SRWLOCK_CONTENDED) - { - /* There's a wait block, we need to wake the next pending - acquirer (exclusive or shared) */ - WaitBlock = RtlpAcquireWaitBlockLock(SRWLock); - if (WaitBlock != NULL) - { - RtlpReleaseWaitBlockLockExclusive(SRWLock, - WaitBlock); - - /* We released the lock */ - break; - } - } - else - { - /* This is a fast path, we can simply clear the RTL_SRWLOCK_OWNED - bit. All other bits should be 0 now because this is a simple - exclusive lock and no one is waiting. */ - - ASSERT(!(CurrentValue & ~RTL_SRWLOCK_OWNED)); - - NewValue = 0; - if ((LONG_PTR)InterlockedCompareExchangePointer(&SRWLock->Ptr, - (PVOID)NewValue, - (PVOID)CurrentValue) == CurrentValue) - { - /* We released the lock */ - break; - } - } - } - else - { - /* The RTL_SRWLOCK_SHARED bit must not be present now, - not even in the contended case! */ - RtlRaiseStatus(STATUS_RESOURCE_NOT_OWNED); - } - - YieldProcessor(); - } -}

1 0

[mjansen] 74702: [KERNEL32] Do not use TEB->StaticUnicodeString in CreateProcessInternalA. CORE-10368
by mjansen＠svn.reactos.org 30 May '17

30 May '17

Author: mjansen Date: Tue May 30 20:57:45 2017 New Revision: 74702 URL: http://svn.reactos.org/svn/reactos?rev=74702&view=rev Log: [KERNEL32] Do not use TEB->StaticUnicodeString in CreateProcessInternalA. CORE-10368 Modified: trunk/reactos/dll/win32/kernel32/client/proc.c Modified: trunk/reactos/dll/win32/kernel32/client/proc.c URL: http://svn.reactos.org/svn/reactos/trunk/reactos/dll/win32/kernel32/client/… ============================================================================== --- trunk/reactos/dll/win32/kernel32/client/proc.c [iso-8859-1] (original) +++ trunk/reactos/dll/win32/kernel32/client/proc.c [iso-8859-1] Tue May 30 20:57:45 2017 @@ -4660,9 +4660,7 @@ LPPROCESS_INFORMATION lpProcessInformation, PHANDLE hNewToken) { - PUNICODE_STRING CommandLine = NULL; - UNICODE_STRING DummyString; - UNICODE_STRING LiveCommandLine; + UNICODE_STRING CommandLine; UNICODE_STRING ApplicationName; UNICODE_STRING CurrentDirectory; BOOL bRetVal; @@ -4677,8 +4675,7 @@ RtlMoveMemory(&StartupInfo, lpStartupInfo, sizeof(*lpStartupInfo)); /* Initialize all strings to nothing */ - LiveCommandLine.Buffer = NULL; - DummyString.Buffer = NULL; + CommandLine.Buffer = NULL; ApplicationName.Buffer = NULL; CurrentDirectory.Buffer = NULL; StartupInfo.lpDesktop = NULL; @@ -4688,24 +4685,8 @@ /* Convert the Command line */ if (lpCommandLine) { - /* If it's too long, then we'll have a problem */ - if ((strlen(lpCommandLine) + 1) * sizeof(WCHAR) < - NtCurrentTeb()->StaticUnicodeString.MaximumLength) - { - /* Cache it in the TEB */ - CommandLine = Basep8BitStringToStaticUnicodeString(lpCommandLine); - } - else - { - /* Use a dynamic version */ - Basep8BitStringToDynamicUnicodeString(&LiveCommandLine, - lpCommandLine); - } - } - else - { - /* The logic below will use CommandLine, so we must make it valid */ - CommandLine = &DummyString; + Basep8BitStringToDynamicUnicodeString(&CommandLine, + lpCommandLine); } /* Convert the Name and Directory */ @@ -4740,8 +4721,7 @@ /* Call the Unicode function */ bRetVal = CreateProcessInternalW(hToken, ApplicationName.Buffer, - LiveCommandLine.Buffer ? - LiveCommandLine.Buffer : CommandLine->Buffer, + CommandLine.Buffer, lpProcessAttributes, lpThreadAttributes, bInheritHandles, @@ -4754,7 +4734,7 @@ /* Clean up */ RtlFreeUnicodeString(&ApplicationName); - RtlFreeUnicodeString(&LiveCommandLine); + RtlFreeUnicodeString(&CommandLine); RtlFreeUnicodeString(&CurrentDirectory); RtlFreeHeap(RtlGetProcessHeap(), 0, StartupInfo.lpDesktop); RtlFreeHeap(RtlGetProcessHeap(), 0, StartupInfo.lpReserved);

1 0

[mjansen] 74701: [KERNEL32_APITEST] Add test to show that we should not spoil TEB->StaticUnicodeString in CreateProcessA. CORE-10368
by mjansen＠svn.reactos.org 30 May '17

30 May '17

Author: mjansen Date: Tue May 30 20:55:15 2017 New Revision: 74701 URL: http://svn.reactos.org/svn/reactos?rev=74701&view=rev Log: [KERNEL32_APITEST] Add test to show that we should not spoil TEB->StaticUnicodeString in CreateProcessA. CORE-10368 Added: trunk/rostests/apitests/kernel32/CreateProcess.c (with props) Modified: trunk/rostests/apitests/kernel32/CMakeLists.txt trunk/rostests/apitests/kernel32/testlist.c Modified: trunk/rostests/apitests/kernel32/CMakeLists.txt URL: http://svn.reactos.org/svn/reactos/trunk/rostests/apitests/kernel32/CMakeLi… ============================================================================== --- trunk/rostests/apitests/kernel32/CMakeLists.txt [iso-8859-1] (original) +++ trunk/rostests/apitests/kernel32/CMakeLists.txt [iso-8859-1] Tue May 30 20:55:15 2017 @@ -3,6 +3,7 @@ list(APPEND SOURCE Console.c + CreateProcess.c DefaultActCtx.c DeviceIoControl.c dosdev.c Added: trunk/rostests/apitests/kernel32/CreateProcess.c URL: http://svn.reactos.org/svn/reactos/trunk/rostests/apitests/kernel32/CreateP… ============================================================================== --- trunk/rostests/apitests/kernel32/CreateProcess.c (added) +++ trunk/rostests/apitests/kernel32/CreateProcess.c [iso-8859-1] Tue May 30 20:55:15 2017 @@ -0,0 +1,34 @@ +/* + * PROJECT: ReactOS api tests + * LICENSE: GPLv2+ - See COPYING in the top level directory + * PURPOSE: Test spoiling of StaticUnicodeString by CreateProcessA + * PROGRAMMERS: Mark Jansen + */ + +#include <apitest.h> +#include <ndk/rtltypes.h> +#include <ndk/rtlfuncs.h> + + +START_TEST(CreateProcess) +{ + PUNICODE_STRING StaticString; + UNICODE_STRING CompareString; + BOOL Process; + STARTUPINFO si = {0}; + PROCESS_INFORMATION pi = {0}; + LONG Result; + + StaticString = &NtCurrentTeb()->StaticUnicodeString; + RtlInitUnicodeString(&CompareString, L"--sentinel--"); + RtlCopyUnicodeString(StaticString, &CompareString); + + si.cb = sizeof(si); + Process = CreateProcessA("ApplicationName", "CommandLine", NULL, NULL, FALSE, 0, NULL, "CurrentDir", &si, &pi); + ok_int(Process, 0); + + Result = RtlCompareUnicodeString(StaticString, &CompareString, TRUE); + ok(!Result, "Expected %s to equal %s\n", + wine_dbgstr_wn(StaticString->Buffer, StaticString->Length / sizeof(WCHAR)), + wine_dbgstr_wn(CompareString.Buffer, CompareString.Length / sizeof(WCHAR))); +} Propchange: trunk/rostests/apitests/kernel32/CreateProcess.c ------------------------------------------------------------------------------ svn:eol-style = native Modified: trunk/rostests/apitests/kernel32/testlist.c URL: http://svn.reactos.org/svn/reactos/trunk/rostests/apitests/kernel32/testlis… ============================================================================== --- trunk/rostests/apitests/kernel32/testlist.c [iso-8859-1] (original) +++ trunk/rostests/apitests/kernel32/testlist.c [iso-8859-1] Tue May 30 20:55:15 2017 @@ -4,6 +4,7 @@ #include <apitest.h> extern void func_Console(void); +extern void func_CreateProcess(void); extern void func_DefaultActCtx(void); extern void func_DeviceIoControl(void); extern void func_dosdev(void); @@ -30,6 +31,7 @@ const struct test winetest_testlist[] = { { "ConsoleCP", func_Console }, + { "CreateProcess", func_CreateProcess }, { "DefaultActCtx", func_DefaultActCtx }, { "DeviceIoControl", func_DeviceIoControl }, { "dosdev", func_dosdev },

1 0

[tfaber] 74700: [NTOS:IO] - Fix key handle leak in PipCallDriverAddDevice - Avoid double-close in failure case of IopAttachFilterDrivers - Simplify closing handles, and use sensible variables names...
by tfaber＠svn.reactos.org 30 May '17

30 May '17

Author: tfaber Date: Tue May 30 18:14:31 2017 New Revision: 74700 URL: http://svn.reactos.org/svn/reactos?rev=74700&view=rev Log: [NTOS:IO] - Fix key handle leak in PipCallDriverAddDevice - Avoid double-close in failure case of IopAttachFilterDrivers - Simplify closing handles, and use sensible variables names in IopAttachFilterDrivers CORE-13336 Modified: trunk/reactos/ntoskrnl/io/iomgr/driver.c trunk/reactos/ntoskrnl/io/pnpmgr/pnpinit.c Modified: trunk/reactos/ntoskrnl/io/iomgr/driver.c URL: http://svn.reactos.org/svn/reactos/trunk/reactos/ntoskrnl/io/iomgr/driver.c… ============================================================================== --- trunk/reactos/ntoskrnl/io/iomgr/driver.c [iso-8859-1] (original) +++ trunk/reactos/ntoskrnl/io/iomgr/driver.c [iso-8859-1] Tue May 30 18:14:31 2017 @@ -648,6 +648,7 @@ UNICODE_STRING EnumRoot = RTL_CONSTANT_STRING(ENUM_ROOT); UNICODE_STRING ControlClass = RTL_CONSTANT_STRING(L"\\Registry\\Machine\\System\\CurrentControlSet\\Control\\Class"); HANDLE EnumRootKey, SubKey; + HANDLE ControlKey, ClassKey; NTSTATUS Status; /* Open enumeration root key */ @@ -667,11 +668,11 @@ EnumRootKey, &DeviceNode->InstancePath, KEY_READ); + ZwClose(EnumRootKey); if (!NT_SUCCESS(Status)) { DPRINT1("IopOpenRegistryKeyEx() failed for '%wZ' with status 0x%lx\n", &DeviceNode->InstancePath, Status); - ZwClose(EnumRootKey); return Status; } @@ -696,7 +697,6 @@ DPRINT1("Failed to load device %s filters: %08X\n", Lower ? "lower" : "upper", Status); ZwClose(SubKey); - ZwClose(EnumRootKey); return Status; } @@ -717,9 +717,8 @@ DeviceNode, NULL); - /* Close handles */ + /* Close subkey */ ZwClose(SubKey); - ZwClose(EnumRootKey); /* If there is no class GUID, we're done */ if (!NT_SUCCESS(Status)) @@ -730,7 +729,7 @@ /* * Load the class filter driver */ - Status = IopOpenRegistryKeyEx(&EnumRootKey, + Status = IopOpenRegistryKeyEx(&ControlKey, NULL, &ControlClass, KEY_READ); @@ -742,8 +741,8 @@ } /* Open subkey */ - Status = IopOpenRegistryKeyEx(&SubKey, - EnumRootKey, + Status = IopOpenRegistryKeyEx(&ClassKey, + ControlKey, &Class, KEY_READ); if (!NT_SUCCESS(Status)) @@ -751,7 +750,7 @@ /* It's okay if there's no class key */ DPRINT1("IopOpenRegistryKeyEx() failed for '%wZ' with status 0x%lx\n", &Class, Status); - ZwClose(EnumRootKey); + ZwClose(ControlKey); return STATUS_SUCCESS; } @@ -765,21 +764,19 @@ QueryTable[0].DefaultType = REG_NONE; Status = RtlQueryRegistryValues(RTL_REGISTRY_HANDLE, - (PWSTR)SubKey, + (PWSTR)ClassKey, QueryTable, DeviceNode, NULL); /* Clean up */ - ZwClose(SubKey); - ZwClose(EnumRootKey); + ZwClose(ClassKey); + ZwClose(ControlKey); if (!NT_SUCCESS(Status)) { DPRINT1("Failed to load class %s filters: %08X\n", Lower ? "lower" : "upper", Status); - ZwClose(SubKey); - ZwClose(EnumRootKey); return Status; } Modified: trunk/reactos/ntoskrnl/io/pnpmgr/pnpinit.c URL: http://svn.reactos.org/svn/reactos/trunk/reactos/ntoskrnl/io/pnpmgr/pnpinit… ============================================================================== --- trunk/reactos/ntoskrnl/io/pnpmgr/pnpinit.c [iso-8859-1] (original) +++ trunk/reactos/ntoskrnl/io/pnpmgr/pnpinit.c [iso-8859-1] Tue May 30 18:14:31 2017 @@ -290,6 +290,7 @@ Status = IopGetRegistryValue(SubKey, REGSTR_VAL_CLASSGUID, &KeyValueInformation); + ZwClose(SubKey); if (NT_SUCCESS(Status)) { /* Convert to unicode string */

1 0

[tfaber] 74699: [NTOS:IO] - Save an indentation level in IopAttachFilterDrivers CORE-13336
by tfaber＠svn.reactos.org 30 May '17

30 May '17

Author: tfaber Date: Tue May 30 17:22:13 2017 New Revision: 74699 URL: http://svn.reactos.org/svn/reactos?rev=74699&view=rev Log: [NTOS:IO] - Save an indentation level in IopAttachFilterDrivers CORE-13336 Modified: trunk/reactos/ntoskrnl/io/iomgr/driver.c Modified: trunk/reactos/ntoskrnl/io/iomgr/driver.c URL: http://svn.reactos.org/svn/reactos/trunk/reactos/ntoskrnl/io/iomgr/driver.c… ============================================================================== --- trunk/reactos/ntoskrnl/io/iomgr/driver.c [iso-8859-1] (original) +++ trunk/reactos/ntoskrnl/io/iomgr/driver.c [iso-8859-1] Tue May 30 17:22:13 2017 @@ -646,6 +646,7 @@ UNICODE_STRING Class; WCHAR ClassBuffer[40]; UNICODE_STRING EnumRoot = RTL_CONSTANT_STRING(ENUM_ROOT); + UNICODE_STRING ControlClass = RTL_CONSTANT_STRING(L"\\Registry\\Machine\\System\\CurrentControlSet\\Control\\Class"); HANDLE EnumRootKey, SubKey; NTSTATUS Status; @@ -720,65 +721,66 @@ ZwClose(SubKey); ZwClose(EnumRootKey); + /* If there is no class GUID, we're done */ + if (!NT_SUCCESS(Status)) + { + return STATUS_SUCCESS; + } + /* * Load the class filter driver */ - if (NT_SUCCESS(Status)) - { - UNICODE_STRING ControlClass = RTL_CONSTANT_STRING(L"\\Registry\\Machine\\System\\CurrentControlSet\\Control\\Class"); - - Status = IopOpenRegistryKeyEx(&EnumRootKey, - NULL, - &ControlClass, - KEY_READ); - if (!NT_SUCCESS(Status)) - { - DPRINT1("IopOpenRegistryKeyEx() failed for '%wZ' with status 0x%lx\n", - &ControlClass, Status); - return Status; - } - - /* Open subkey */ - Status = IopOpenRegistryKeyEx(&SubKey, - EnumRootKey, - &Class, - KEY_READ); - if (!NT_SUCCESS(Status)) - { - /* It's okay if there's no class key */ - DPRINT1("IopOpenRegistryKeyEx() failed for '%wZ' with status 0x%lx\n", - &Class, Status); - ZwClose(EnumRootKey); - return STATUS_SUCCESS; - } - - QueryTable[0].QueryRoutine = IopAttachFilterDriversCallback; - if (Lower) - QueryTable[0].Name = L"LowerFilters"; - else - QueryTable[0].Name = L"UpperFilters"; - QueryTable[0].EntryContext = NULL; - QueryTable[0].Flags = 0; - QueryTable[0].DefaultType = REG_NONE; - - Status = RtlQueryRegistryValues(RTL_REGISTRY_HANDLE, - (PWSTR)SubKey, - QueryTable, - DeviceNode, - NULL); - - /* Clean up */ + Status = IopOpenRegistryKeyEx(&EnumRootKey, + NULL, + &ControlClass, + KEY_READ); + if (!NT_SUCCESS(Status)) + { + DPRINT1("IopOpenRegistryKeyEx() failed for '%wZ' with status 0x%lx\n", + &ControlClass, Status); + return Status; + } + + /* Open subkey */ + Status = IopOpenRegistryKeyEx(&SubKey, + EnumRootKey, + &Class, + KEY_READ); + if (!NT_SUCCESS(Status)) + { + /* It's okay if there's no class key */ + DPRINT1("IopOpenRegistryKeyEx() failed for '%wZ' with status 0x%lx\n", + &Class, Status); + ZwClose(EnumRootKey); + return STATUS_SUCCESS; + } + + QueryTable[0].QueryRoutine = IopAttachFilterDriversCallback; + if (Lower) + QueryTable[0].Name = L"LowerFilters"; + else + QueryTable[0].Name = L"UpperFilters"; + QueryTable[0].EntryContext = NULL; + QueryTable[0].Flags = 0; + QueryTable[0].DefaultType = REG_NONE; + + Status = RtlQueryRegistryValues(RTL_REGISTRY_HANDLE, + (PWSTR)SubKey, + QueryTable, + DeviceNode, + NULL); + + /* Clean up */ + ZwClose(SubKey); + ZwClose(EnumRootKey); + + if (!NT_SUCCESS(Status)) + { + DPRINT1("Failed to load class %s filters: %08X\n", + Lower ? "lower" : "upper", Status); ZwClose(SubKey); ZwClose(EnumRootKey); - - if (!NT_SUCCESS(Status)) - { - DPRINT1("Failed to load class %s filters: %08X\n", - Lower ? "lower" : "upper", Status); - ZwClose(SubKey); - ZwClose(EnumRootKey); - return Status; - } + return Status; } return STATUS_SUCCESS;

1 0

[hbelusca] 74698: [USETUP]: Minor fixes & simplifications: - Remove a redundant NtClose call; - Return failure if NtQuerySymbolicLinkObject fails; - Use RTL_CONSTANT_STRING and RtlInitEmptyUnicodeS...
by hbelusca＠svn.reactos.org 30 May '17

30 May '17

Author: hbelusca Date: Tue May 30 00:15:54 2017 New Revision: 74698 URL: http://svn.reactos.org/svn/reactos?rev=74698&view=rev Log: [USETUP]: Minor fixes & simplifications: - Remove a redundant NtClose call; - Return failure if NtQuerySymbolicLinkObject fails; - Use RTL_CONSTANT_STRING and RtlInitEmptyUnicodeString where needed; - Reduce code indent level; - Add old-style function annotations; - Remove the deprecated code copyright notice, since the copyright in usage is already reported in the COPYING file in the top level ReactOS source code directory. Modified: branches/setup_improvements/base/setup/usetup/drivesup.c branches/setup_improvements/base/setup/usetup/drivesup.h Modified: branches/setup_improvements/base/setup/usetup/drivesup.c URL: http://svn.reactos.org/svn/reactos/branches/setup_improvements/base/setup/u… ============================================================================== --- branches/setup_improvements/base/setup/usetup/drivesup.c [iso-8859-1] (original) +++ branches/setup_improvements/base/setup/usetup/drivesup.c [iso-8859-1] Tue May 30 00:15:54 2017 @@ -1,21 +1,3 @@ -/* - * ReactOS kernel - * Copyright (C) 2002 ReactOS Team - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License along - * with this program; if not, write to the Free Software Foundation, Inc., - * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. - */ /* * COPYRIGHT: See COPYING in the top level directory * PROJECT: ReactOS text-mode setup @@ -35,21 +17,18 @@ NTSTATUS GetSourcePaths( - PUNICODE_STRING SourcePath, - PUNICODE_STRING SourceRootPath, - PUNICODE_STRING SourceRootDir) + OUT PUNICODE_STRING SourcePath, + OUT PUNICODE_STRING SourceRootPath, + OUT PUNICODE_STRING SourceRootDir) { + NTSTATUS Status; OBJECT_ATTRIBUTES ObjectAttributes; - UNICODE_STRING LinkName; + UNICODE_STRING LinkName = RTL_CONSTANT_STRING(L"\\SystemRoot"); UNICODE_STRING SourceName; - WCHAR SourceBuffer[MAX_PATH] = {L'\0'}; + WCHAR SourceBuffer[MAX_PATH] = L""; HANDLE Handle; - NTSTATUS Status; ULONG Length; PWCHAR Ptr; - - RtlInitUnicodeString(&LinkName, - L"\\SystemRoot"); InitializeObjectAttributes(&ObjectAttributes, &LinkName, @@ -63,35 +42,33 @@ if (!NT_SUCCESS(Status)) return Status; - SourceName.Length = 0; - SourceName.MaximumLength = MAX_PATH * sizeof(WCHAR); - SourceName.Buffer = SourceBuffer; + RtlInitEmptyUnicodeString(&SourceName, SourceBuffer, sizeof(SourceBuffer)); Status = NtQuerySymbolicLinkObject(Handle, &SourceName, &Length); NtClose(Handle); - if (NT_SUCCESS(Status)) + if (!NT_SUCCESS(Status)) + return Status; + + RtlCreateUnicodeString(SourcePath, + SourceName.Buffer); + + /* Strip trailing directory */ + Ptr = wcsrchr(SourceName.Buffer, OBJ_NAME_PATH_SEPARATOR); + if (Ptr) { - RtlCreateUnicodeString(SourcePath, - SourceName.Buffer); - - /* strip trailing directory */ - Ptr = wcsrchr(SourceName.Buffer, L'\\'); - if (Ptr) - { - RtlCreateUnicodeString(SourceRootDir, Ptr); - *Ptr = 0; - } - else - RtlCreateUnicodeString(SourceRootDir, L""); - - RtlCreateUnicodeString(SourceRootPath, - SourceName.Buffer); + RtlCreateUnicodeString(SourceRootDir, Ptr); + *Ptr = UNICODE_NULL; + } + else + { + RtlCreateUnicodeString(SourceRootDir, L""); } - NtClose(Handle); + RtlCreateUnicodeString(SourceRootPath, + SourceName.Buffer); return STATUS_SUCCESS; } Modified: branches/setup_improvements/base/setup/usetup/drivesup.h URL: http://svn.reactos.org/svn/reactos/branches/setup_improvements/base/setup/u… ============================================================================== --- branches/setup_improvements/base/setup/usetup/drivesup.h [iso-8859-1] (original) +++ branches/setup_improvements/base/setup/usetup/drivesup.h [iso-8859-1] Tue May 30 00:15:54 2017 @@ -1,21 +1,3 @@ -/* - * ReactOS kernel - * Copyright (C) 2002 ReactOS Team - * - * This program is free software; you can redistribute it and/or modify - * it under the terms of the GNU General Public License as published by - * the Free Software Foundation; either version 2 of the License, or - * (at your option) any later version. - * - * This program is distributed in the hope that it will be useful, - * but WITHOUT ANY WARRANTY; without even the implied warranty of - * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the - * GNU General Public License for more details. - * - * You should have received a copy of the GNU General Public License along - * with this program; if not, write to the Free Software Foundation, Inc., - * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. - */ /* * COPYRIGHT: See COPYING in the top level directory * PROJECT: ReactOS text-mode setup @@ -28,8 +10,8 @@ NTSTATUS GetSourcePaths( - PUNICODE_STRING SourcePath, - PUNICODE_STRING SourceRootPath, - PUNICODE_STRING SourceRootDir); + OUT PUNICODE_STRING SourcePath, + OUT PUNICODE_STRING SourceRootPath, + OUT PUNICODE_STRING SourceRootDir); /* EOF */

1 0

[mjansen] 74697: [KERNEL32] Actually disable the shim engine while it is not ready yet.... CORE-10368
by mjansen＠svn.reactos.org 29 May '17

29 May '17

Author: mjansen Date: Mon May 29 21:14:15 2017 New Revision: 74697 URL: http://svn.reactos.org/svn/reactos?rev=74697&view=rev Log: [KERNEL32] Actually disable the shim engine while it is not ready yet.... CORE-10368 Modified: trunk/reactos/dll/win32/kernel32/client/appcache.c Modified: trunk/reactos/dll/win32/kernel32/client/appcache.c URL: http://svn.reactos.org/svn/reactos/trunk/reactos/dll/win32/kernel32/client/… ============================================================================== --- trunk/reactos/dll/win32/kernel32/client/appcache.c [iso-8859-1] (original) +++ trunk/reactos/dll/win32/kernel32/client/appcache.c [iso-8859-1] Mon May 29 21:14:15 2017 @@ -15,7 +15,7 @@ /* GLOBALS ********************************************************************/ -ULONG g_ShimsEnabled; +ULONG g_ShimsEnabled = -1; static BOOL g_ApphelpInitialized = FALSE; static PVOID g_pApphelpCheckRunAppEx; static PVOID g_pSdbPackAppCompatData;

1 0

[tfaber] 74696: [ACPI] - Remove some dead code in acpi_system_add. CID 502179 - Define deviceName only in debug builds in Bus_AddDevice. CID 502180
by tfaber＠svn.reactos.org 29 May '17

29 May '17

Author: tfaber Date: Mon May 29 09:23:33 2017 New Revision: 74696 URL: http://svn.reactos.org/svn/reactos?rev=74696&view=rev Log: [ACPI] - Remove some dead code in acpi_system_add. CID 502179 - Define deviceName only in debug builds in Bus_AddDevice. CID 502180 Modified: trunk/reactos/drivers/bus/acpi/busmgr/system.c trunk/reactos/drivers/bus/acpi/main.c Modified: trunk/reactos/drivers/bus/acpi/busmgr/system.c URL: http://svn.reactos.org/svn/reactos/trunk/reactos/drivers/bus/acpi/busmgr/sy… ============================================================================== --- trunk/reactos/drivers/bus/acpi/busmgr/system.c [iso-8859-1] (original) +++ trunk/reactos/drivers/bus/acpi/busmgr/system.c [iso-8859-1] Mon May 29 09:23:33 2017 @@ -65,7 +65,6 @@ acpi_system_add ( struct acpi_device *device) { - int result = 0; ACPI_STATUS status = AE_OK; struct acpi_system *system = NULL; UINT8 i = 0; @@ -114,10 +113,7 @@ // } //#endif - if (result) - ExFreePoolWithTag(system, 'IPCA'); - - return_VALUE(result); + return_VALUE(0); } static int Modified: trunk/reactos/drivers/bus/acpi/main.c URL: http://svn.reactos.org/svn/reactos/trunk/reactos/drivers/bus/acpi/main.c?re… ============================================================================== --- trunk/reactos/drivers/bus/acpi/main.c [iso-8859-1] (original) +++ trunk/reactos/drivers/bus/acpi/main.c [iso-8859-1] Mon May 29 09:23:33 2017 @@ -37,8 +37,8 @@ NTSTATUS status; PDEVICE_OBJECT deviceObject = NULL; PFDO_DEVICE_DATA deviceData = NULL; +#ifndef NDEBUG PWCHAR deviceName = NULL; -#ifndef NDEBUG ULONG nameLength; #endif @@ -159,9 +159,11 @@ deviceObject->Flags &= ~DO_DEVICE_INITIALIZING; End: +#ifndef NDEBUG if (deviceName){ ExFreePoolWithTag(deviceName, 'MpcA'); } +#endif if (!NT_SUCCESS(status) && deviceObject){ if (deviceData && deviceData->NextLowerDriver){ IoDetachDevice (deviceData->NextLowerDriver);

1 0

[tthompson] 74695: [CMAKE] - Fix formatting of last configure.cmd commit; change tabs to spaces.
by tthompson＠svn.reactos.org 28 May '17

28 May '17

Author: tthompson Date: Sun May 28 23:11:03 2017 New Revision: 74695 URL: http://svn.reactos.org/svn/reactos?rev=74695&view=rev Log: [CMAKE] - Fix formatting of last configure.cmd commit; change tabs to spaces. Modified: branches/GSoC_2016/NTFS/configure.cmd Modified: branches/GSoC_2016/NTFS/configure.cmd URL: http://svn.reactos.org/svn/reactos/branches/GSoC_2016/NTFS/configure.cmd?re… ============================================================================== --- branches/GSoC_2016/NTFS/configure.cmd [iso-8859-1] (original) +++ branches/GSoC_2016/NTFS/configure.cmd [iso-8859-1] Sun May 28 23:11:03 2017 @@ -36,11 +36,11 @@ REM Ensure there's no spaces in the source path echo %REACTOS_SOURCE_DIR%| find " " > NUL if %ERRORLEVEL% == 0 ( - echo. && echo Your source path contains at least one space. - echo This will cause problems with building. - echo Please rename your folders so there are no spaces in the source path, - echo or move your source to a different folder. - goto quit + echo. && echo Your source path contains at least one space. + echo This will cause problems with building. + echo Please rename your folders so there are no spaces in the source path, + echo or move your source to a different folder. + goto quit ) REM Set default generator @@ -109,8 +109,8 @@ ) else if /I "%1" == "RTC" ( echo. && echo Warning: RTC switch is ignored outside of a Visual Studio environment. && echo. ) else if /I "%1" NEQ "" ( - echo. && echo Warning: Unrecognized switch "%1" && echo. - ) else ( + echo. && echo Warning: Unrecognized switch "%1" && echo. + ) else ( goto continue ) ) else ( @@ -175,8 +175,8 @@ echo Runtime checks enabled set VS_RUNTIME_CHECKS=1 ) else if /I "%1" NEQ "" ( - echo. && echo Warning: Unrecognized switch "%1" && echo. - ) else ( + echo. && echo Warning: Unrecognized switch "%1" && echo. + ) else ( goto continue ) ) @@ -214,13 +214,13 @@ echo. && echo Error: This directory has already been configured for ninja. echo An output folder configured for ninja can't be reconfigured for VSSolution. echo Use an empty folder or delete the contents of this folder, then try again. - goto quit + goto quit ) ) else if exist REACTOS.sln ( echo. && echo Error: This directory has already been configured for Visual Studio. echo An output folder configured for VSSolution can't be reconfigured for ninja. echo Use an empty folder or delete the contents of this folder, then try again. && echo. - goto quit + goto quit ) if "%NEW_STYLE_BUILD%"=="0" ( @@ -279,18 +279,18 @@ ) if %ERRORLEVEL% NEQ 0 ( - goto quit + goto quit ) if "%CD_SAME_AS_SOURCE%" == "1" ( - set ENDV= from %REACTOS_OUTPUT_PATH% + set ENDV= from %REACTOS_OUTPUT_PATH% ) if "%VS_SOLUTION%" == "1" ( - set ENDV= You can now open REACTOS.sln%ENDV%. + set ENDV= You can now open REACTOS.sln%ENDV%. ) else ( - set ENDV= Execute appropriate build commands ^(ex: ninja, make, nmake, etc...^)%ENDV% - ) + set ENDV= Execute appropriate build commands ^(ex: ninja, make, nmake, etc...^)%ENDV% + ) ) echo. && echo Configure script complete^^!%ENDV%

1 0

[tthompson] 74694: [NTFS] - Decrease debug spam
by tthompson＠svn.reactos.org 28 May '17

28 May '17

Author: tthompson Date: Sun May 28 20:51:31 2017 New Revision: 74694 URL: http://svn.reactos.org/svn/reactos?rev=74694&view=rev Log: [NTFS] - Decrease debug spam Modified: branches/GSoC_2016/NTFS/drivers/filesystems/ntfs/mft.c branches/GSoC_2016/NTFS/drivers/filesystems/ntfs/rw.c Modified: branches/GSoC_2016/NTFS/drivers/filesystems/ntfs/mft.c URL: http://svn.reactos.org/svn/reactos/branches/GSoC_2016/NTFS/drivers/filesyst… ============================================================================== --- branches/GSoC_2016/NTFS/drivers/filesystems/ntfs/mft.c [iso-8859-1] (original) +++ branches/GSoC_2016/NTFS/drivers/filesystems/ntfs/mft.c [iso-8859-1] Sun May 28 20:51:31 2017 @@ -32,7 +32,6 @@ #include "ntfs.h" #define NDEBUG -#undef NDEBUG #include <debug.h> /* FUNCTIONS ****************************************************************/ Modified: branches/GSoC_2016/NTFS/drivers/filesystems/ntfs/rw.c URL: http://svn.reactos.org/svn/reactos/branches/GSoC_2016/NTFS/drivers/filesyst… ============================================================================== --- branches/GSoC_2016/NTFS/drivers/filesystems/ntfs/rw.c [iso-8859-1] (original) +++ branches/GSoC_2016/NTFS/drivers/filesystems/ntfs/rw.c [iso-8859-1] Sun May 28 20:51:31 2017 @@ -165,7 +165,7 @@ AllocatedBuffer = TRUE; } - DPRINT1("Effective read: %lu at %lu for stream '%S'\n", RealLength, RealReadOffset, Fcb->Stream); + DPRINT("Effective read: %lu at %lu for stream '%S'\n", RealLength, RealReadOffset, Fcb->Stream); RealLengthRead = ReadAttribute(DeviceExt, DataContext, RealReadOffset, (PCHAR)ReadBuffer, RealLength); if (RealLengthRead == 0) { @@ -184,7 +184,7 @@ *LengthRead = ToRead; - DPRINT1("%lu got read\n", *LengthRead); + DPRINT("%lu got read\n", *LengthRead); if (AllocatedBuffer) {

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