Intravision/reactos
1
0
Fork 0
mirror of https://github.com/reactos/reactos.git synced 2024-11-19 21:48:10 +00:00
Code Issues Projects Releases Packages Wiki Activity

Testing shows that MS-Win does allow a thread to leave a critical section

Browse source 
entered by another thread.

svn path=/trunk/; revision=7959
This commit is contained in:
Gé van Geldorp 2004-02-01 14:05:30 +00:00
parent cac89868b0
commit 2cb71414cb
1 changed files with 9 additions and 47 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

56
reactos/lib/ntdll/rtl/critical.c
View file

@ -1,4 +1,4 @@
/* $Id: critical.c,v 1.17 2004/01/30 17:32:17 navaraf Exp $
/* $Id: critical.c,v 1.18 2004/02/01 14:05:30 gvg Exp $
*
* COPYRIGHT: See COPYING in the top level directory
* PROJECT: ReactOS system libraries
@ -14,6 +14,7 @@
#include <ntdll/rtl.h>
#include <ntos/synch.h>
#define NDEBUG
#include <ntdll/ntdll.h>
/* FUNCTIONS *****************************************************************/
@ -46,37 +47,18 @@ RtlEnterCriticalSection(PCRITICAL_SECTION CriticalSection)
return;
}
// DbgPrint("Entering wait for critical section\n");
DPRINT("Entering wait for critical section\n");
Status = NtWaitForSingleObject(CriticalSection->LockSemaphore,
0, FALSE);
if (!NT_SUCCESS(Status))
{
DbgPrint("RtlEnterCriticalSection: Failed to wait (Status %x)\n",
Status);
DPRINT1("RtlEnterCriticalSection: Failed to wait (Status %x)\n",
Status);
}
// DbgPrint("Left wait for critical section\n");
DPRINT("Left wait for critical section\n");
}
CriticalSection->OwningThread = Thread;
CriticalSection->RecursionCount = 1;
#if 0
if ((ret = InterlockedIncrement(&(CriticalSection->LockCount) )) != 1)
{
if (CriticalSection->OwningThread != Thread)
{
NtWaitForSingleObject(CriticalSection->LockSemaphore,
0,
FALSE);
CriticalSection->OwningThread = Thread;
}
}
else
{
CriticalSection->OwningThread = Thread;
}
CriticalSection->RecursionCount++;
#endif
}
/*
@ -110,8 +92,7 @@ RtlLeaveCriticalSection(PCRITICAL_SECTION CriticalSection)
if (CriticalSection->OwningThread != Thread)
{
DbgPrint("Freeing critical section not owned\n");
return;
DPRINT1("Freeing critical section not owned\n");
}
CriticalSection->RecursionCount--;
@ -128,29 +109,10 @@ RtlLeaveCriticalSection(PCRITICAL_SECTION CriticalSection)
Status = NtReleaseSemaphore(CriticalSection->LockSemaphore, 1, NULL);
if (!NT_SUCCESS(Status))
{
DbgPrint("Failed to release semaphore (Status %x)\n",
Status);
DPRINT1("Failed to release semaphore (Status %x)\n",
Status);
}
}
#if 0
CriticalSection->RecursionCount--;
if (CriticalSection->RecursionCount == 0)
{
CriticalSection->OwningThread = (HANDLE)-1;
// if LockCount > 0 and RecursionCount == 0 there
// is a waiting thread
// ReleaseSemaphore will fire up a waiting thread
if (InterlockedDecrement(&CriticalSection->LockCount) > 0)
{
NtReleaseSemaphore(CriticalSection->LockSemaphore,1,NULL);
}
}
else
{
InterlockedDecrement(&CriticalSection->LockCount);
}
#endif
}
/*