Author: hbelusca
Date: Sun Mar 23 00:23:54 2014
New Revision: 62547
URL: http://svn.reactos.org/svn/reactos?rev=62547&view=rev
Log:
[RTL]
- Code formatting (homogeneisation of...).
- For "Deadlock" DPRINT, replace the DPRINT1 by a ERROR_DBGBREAK for (user) debugging purposes only (a priori this shouldn't be hit during our automated tests).
Modified:
trunk/reactos/lib/rtl/critical.c
Modified: trunk/reactos/lib/rtl/critical.c
URL: http://svn.reactos.org/svn/reactos/trunk/reactos/lib/rtl/critical.c?rev=625…
==============================================================================
--- trunk/reactos/lib/rtl/critical.c [iso-8859-1] (original)
+++ trunk/reactos/lib/rtl/critical.c [iso-8859-1] Sun Mar 23 00:23:54 2014
@@ -52,7 +52,6 @@
/* Check if we have an event */
if (!hEvent)
{
-
/* No, so create it */
Status = NtCreateEvent(&hNewEvent,
EVENT_ALL_ACCESS,
@@ -61,11 +60,13 @@
FALSE);
if (!NT_SUCCESS(Status))
{
- DPRINT1("Failed to Create Event!\n");
-
- /* Use INVALID_HANDLE_VALUE (-1) to signal that the global
- keyed event must be used */
- hNewEvent = INVALID_HANDLE_VALUE;
+ DPRINT1("Failed to Create Event!\n");
+
+ /*
+ * Use INVALID_HANDLE_VALUE (-1) to signal that
+ * the global keyed event must be used.
+ */
+ hNewEvent = INVALID_HANDLE_VALUE;
}
DPRINT("Created Event: %p \n", hNewEvent);
@@ -111,7 +112,8 @@
BOOLEAN LastChance = FALSE;
/* Do we have an Event yet? */
- if (!CriticalSection->LockSemaphore) {
+ if (!CriticalSection->LockSemaphore)
+ {
RtlpCreateCriticalSectionSem(CriticalSection);
}
@@ -123,8 +125,8 @@
if (CriticalSection->DebugInfo)
CriticalSection->DebugInfo->EntryCount++;
- for (;;) {
-
+ for (;;)
+ {
/* Increase the number of times we've had contention */
if (CriticalSection->DebugInfo)
CriticalSection->DebugInfo->ContentionCount++;
@@ -147,12 +149,12 @@
}
/* We have Timed out */
- if (Status == STATUS_TIMEOUT) {
-
+ if (Status == STATUS_TIMEOUT)
+ {
/* Is this the 2nd time we've timed out? */
- if (LastChance) {
-
- DPRINT1("Deadlock: %p\n", CriticalSection);
+ if (LastChance)
+ {
+ ERROR_DBGBREAK("Deadlock: 0x%p\n", CriticalSection);
/* Yes it is, we are raising an exception */
ExceptionRecord.ExceptionCode = STATUS_POSSIBLE_DEADLOCK;
@@ -162,14 +164,13 @@
ExceptionRecord.NumberParameters = 1;
ExceptionRecord.ExceptionInformation[0] = (ULONG_PTR)CriticalSection;
RtlRaiseException(&ExceptionRecord);
-
}
/* One more try */
LastChance = TRUE;
-
- } else {
-
+ }
+ else
+ {
/* If we are here, everything went fine */
return STATUS_SUCCESS;
}
@@ -198,7 +199,8 @@
NTSTATUS Status;
/* Do we have an Event yet? */
- if (!CriticalSection->LockSemaphore) {
+ if (!CriticalSection->LockSemaphore)
+ {
RtlpCreateCriticalSectionSem(CriticalSection);
}
@@ -219,8 +221,8 @@
Status = NtSetEvent(CriticalSection->LockSemaphore, NULL);
}
- if (!NT_SUCCESS(Status)) {
-
+ if (!NT_SUCCESS(Status))
+ {
/* We've failed */
DPRINT1("Signaling Failed for: %p, %p, 0x%08lx\n",
CriticalSection,
@@ -249,7 +251,6 @@
NTAPI
RtlpInitDeferedCriticalSection(VOID)
{
-
/* Initialize the Process Critical Section List */
InitializeListHead(&RtlCriticalSectionList);
@@ -283,11 +284,11 @@
ULONG i;
/* Try to allocate from our buffer first */
- for (i = 0; i < MAX_STATIC_CS_DEBUG_OBJECTS; i++) {
-
+ for (i = 0; i < MAX_STATIC_CS_DEBUG_OBJECTS; i++)
+ {
/* Check if Entry is free */
- if (!RtlpDebugInfoFreeList[i]) {
-
+ if (!RtlpDebugInfoFreeList[i])
+ {
/* Mark entry in use */
DPRINT("Using entry: %lu. Buffer: %p\n", i, &RtlpStaticDebugInfo[i]);
RtlpDebugInfoFreeList[i] = TRUE;
@@ -295,7 +296,6 @@
/* Use free entry found */
return &RtlpStaticDebugInfo[i];
}
-
}
/* We are out of static buffer, allocate dynamic */
@@ -328,8 +328,8 @@
/* Is it part of our cached entries? */
if ((DebugInfo >= RtlpStaticDebugInfo) &&
- (DebugInfo <= &RtlpStaticDebugInfo[MAX_STATIC_CS_DEBUG_OBJECTS-1])) {
-
+ (DebugInfo <= &RtlpStaticDebugInfo[MAX_STATIC_CS_DEBUG_OBJECTS-1]))
+ {
/* Yes. zero it out */
RtlZeroMemory(DebugInfo, sizeof(RTL_CRITICAL_SECTION_DEBUG));
@@ -341,21 +341,21 @@
NtCurrentTeb()->ClientId.UniqueProcess);
RtlpDebugInfoFreeList[EntryId] = FALSE;
- } else if (!DebugInfo->Flags) {
-
+ }
+ else if (!DebugInfo->Flags)
+ {
/* It's a dynamic one, so free from the heap */
DPRINT("Freeing from Heap: %p inside Process: %p\n",
DebugInfo,
NtCurrentTeb()->ClientId.UniqueProcess);
RtlFreeHeap(NtCurrentPeb()->ProcessHeap, 0, DebugInfo);
-
- } else {
-
+ }
+ else
+ {
/* Wine stores a section name pointer in the Flags member */
DPRINT("Assuming static: %p inside Process: %p\n",
DebugInfo,
NtCurrentTeb()->ClientId.UniqueProcess);
-
}
}
@@ -382,12 +382,12 @@
NTSTATUS Status = STATUS_SUCCESS;
DPRINT("Deleting Critical Section: %p\n", CriticalSection);
+
/* Close the Event Object Handle if it exists */
- if (CriticalSection->LockSemaphore) {
-
+ if (CriticalSection->LockSemaphore)
+ {
/* In case NtClose fails, return the status */
Status = NtClose(CriticalSection->LockSemaphore);
-
}
/* Protect List */
@@ -397,7 +397,8 @@
{
/* Remove it from the list */
RemoveEntryList(&CriticalSection->DebugInfo->ProcessLocksList);
-#if 0 /* We need to preserve Flags for RtlpFreeDebugInfo */
+#if 0
+ /* We need to preserve Flags for RtlpFreeDebugInfo */
RtlZeroMemory(CriticalSection->DebugInfo, sizeof(RTL_CRITICAL_SECTION_DEBUG));
#endif
}
@@ -470,18 +471,17 @@
{
HANDLE Thread = (HANDLE)NtCurrentTeb()->ClientId.UniqueThread;
- /* Try to Lock it */
- if (InterlockedIncrement(&CriticalSection->LockCount) != 0) {
-
- /*
- * We've failed to lock it! Does this thread
- * actually own it?
- */
- if (Thread == CriticalSection->OwningThread) {
-
- /* You own it, so you'll get it when you're done with it! No need to
- use the interlocked functions as only the thread who already owns
- the lock can modify this data. */
+ /* Try to lock it */
+ if (InterlockedIncrement(&CriticalSection->LockCount) != 0)
+ {
+ /* We've failed to lock it! Does this thread actually own it? */
+ if (Thread == CriticalSection->OwningThread)
+ {
+ /*
+ * You own it, so you'll get it when you're done with it! No need to
+ * use the interlocked functions as only the thread who already owns
+ * the lock can modify this data.
+ */
CriticalSection->RecursionCount++;
return STATUS_SUCCESS;
}
@@ -497,9 +497,11 @@
RtlpWaitForCriticalSection(CriticalSection);
}
- /* Lock successful. Changing this information has not to be serialized because
- only one thread at a time can actually change it (the one who acquired
- the lock)! */
+ /*
+ * Lock successful. Changing this information has not to be serialized
+ * because only one thread at a time can actually change it (the one who
+ * acquired the lock)!
+ */
CriticalSection->OwningThread = Thread;
CriticalSection->RecursionCount = 1;
return STATUS_SUCCESS;
@@ -568,8 +570,8 @@
CritcalSectionDebugData,
NtCurrentTeb()->ClientId.UniqueProcess);
- if (!CritcalSectionDebugData) {
-
+ if (!CritcalSectionDebugData)
+ {
/* This is bad! */
DPRINT1("Couldn't allocate Debug Data for: %p\n", CriticalSection);
return STATUS_NO_MEMORY;
@@ -584,12 +586,12 @@
CriticalSection->DebugInfo = CritcalSectionDebugData;
/*
- * Add it to the List of Critical Sections owned by the process.
- * If we've initialized the Lock, then use it. If not, then probably
- * this is the lock initialization itself, so insert it directly.
- */
- if ((CriticalSection != &RtlCriticalSectionLock) && (RtlpCritSectInitialized)) {
-
+ * Add it to the List of Critical Sections owned by the process.
+ * If we've initialized the Lock, then use it. If not, then probably
+ * this is the lock initialization itself, so insert it directly.
+ */
+ if ((CriticalSection != &RtlCriticalSectionLock) && (RtlpCritSectInitialized))
+ {
DPRINT("Securely Inserting into ProcessLocks: %p, %p, %p\n",
&CritcalSectionDebugData->ProcessLocksList,
CriticalSection,
@@ -603,9 +605,9 @@
/* Unprotect */
RtlLeaveCriticalSection(&RtlCriticalSectionLock);
-
- } else {
-
+ }
+ else
+ {
DPRINT("Inserting into ProcessLocks: %p, %p, %p\n",
&CritcalSectionDebugData->ProcessLocksList,
CriticalSection,
@@ -680,8 +682,10 @@
#if DBG
HANDLE Thread = (HANDLE)NtCurrentTeb()->ClientId.UniqueThread;
- /* In win this case isn't checked. However it's a valid check so it should only
- be performed in debug builds! */
+ /*
+ * In win this case isn't checked. However it's a valid check so it should
+ * only be performed in debug builds!
+ */
if (Thread != CriticalSection->OwningThread)
{
DPRINT1("Releasing critical section not owned!\n");
@@ -689,23 +693,28 @@
}
#endif
- /* Decrease the Recursion Count. No need to do this atomically because only
- the thread who holds the lock can call this function (unless the program
- is totally screwed... */
- if (--CriticalSection->RecursionCount) {
-
+ /*
+ * Decrease the Recursion Count. No need to do this atomically because only
+ * the thread who holds the lock can call this function (unless the program
+ * is totally screwed...
+ */
+ if (--CriticalSection->RecursionCount)
+ {
/* Someone still owns us, but we are free. This needs to be done atomically. */
InterlockedDecrement(&CriticalSection->LockCount);
- } else {
-
- /* Nobody owns us anymore. No need to do this atomically. See comment
- above. */
+ }
+ else
+ {
+ /*
+ * Nobody owns us anymore. No need to do this atomically.
+ * See comment above.
+ */
CriticalSection->OwningThread = 0;
/* Was someone wanting us? This needs to be done atomically. */
- if (-1 != InterlockedDecrement(&CriticalSection->LockCount)) {
-
+ if (-1 != InterlockedDecrement(&CriticalSection->LockCount))
+ {
/* Let him have us */
RtlpUnWaitCriticalSection(CriticalSection);
}
@@ -736,17 +745,15 @@
RtlTryEnterCriticalSection(PRTL_CRITICAL_SECTION CriticalSection)
{
/* Try to take control */
- if (InterlockedCompareExchange(&CriticalSection->LockCount,
- 0,
- -1) == -1) {
-
+ if (InterlockedCompareExchange(&CriticalSection->LockCount, 0, -1) == -1)
+ {
/* It's ours */
CriticalSection->OwningThread = NtCurrentTeb()->ClientId.UniqueThread;
CriticalSection->RecursionCount = 1;
return TRUE;
-
- } else if (CriticalSection->OwningThread == NtCurrentTeb()->ClientId.UniqueThread) {
-
+ }
+ else if (CriticalSection->OwningThread == NtCurrentTeb()->ClientId.UniqueThread)
+ {
/* It's already ours */
InterlockedIncrement(&CriticalSection->LockCount);
CriticalSection->RecursionCount++;
@@ -759,8 +766,7 @@
VOID
NTAPI
-RtlCheckForOrphanedCriticalSections(
- HANDLE ThreadHandle)
+RtlCheckForOrphanedCriticalSections(HANDLE ThreadHandle)
{
UNIMPLEMENTED;
}