| /* |
| * Win32 critical sections |
| * |
| * Copyright 1998 Alexandre Julliard |
| */ |
| |
| #include <assert.h> |
| #include <errno.h> |
| #include <stdio.h> |
| #include <sys/types.h> |
| #include "debug.h" |
| #include "winerror.h" |
| #include "winbase.h" |
| #include "heap.h" |
| #include "debug.h" |
| #include "thread.h" |
| |
| DEFAULT_DEBUG_CHANNEL(win32) |
| DECLARE_DEBUG_CHANNEL(relay) |
| |
| |
| /*********************************************************************** |
| * InitializeCriticalSection (KERNEL32.472) (NTDLL.406) |
| */ |
| void WINAPI InitializeCriticalSection( CRITICAL_SECTION *crit ) |
| { |
| crit->LockCount = -1; |
| crit->RecursionCount = 0; |
| crit->OwningThread = 0; |
| crit->LockSemaphore = CreateSemaphoreA( NULL, 0, 1, NULL ); |
| crit->Reserved = GetCurrentProcessId(); |
| } |
| |
| |
| /*********************************************************************** |
| * DeleteCriticalSection (KERNEL32.185) (NTDLL.327) |
| */ |
| void WINAPI DeleteCriticalSection( CRITICAL_SECTION *crit ) |
| { |
| if (crit->LockSemaphore) |
| { |
| if (crit->RecursionCount) /* Should not happen */ |
| MSG("Deleting owned critical section (%p)\n", crit ); |
| |
| crit->LockCount = -1; |
| crit->RecursionCount = 0; |
| crit->OwningThread = 0; |
| CloseHandle( crit->LockSemaphore ); |
| crit->LockSemaphore = 0; |
| crit->Reserved = (DWORD)-1; |
| } |
| } |
| |
| |
| /*********************************************************************** |
| * EnterCriticalSection (KERNEL32.195) (NTDLL.344) |
| */ |
| void WINAPI EnterCriticalSection( CRITICAL_SECTION *crit ) |
| { |
| DWORD res; |
| |
| if (!crit->LockSemaphore) |
| { |
| FIXME(win32,"entering uninitialized section(%p)?\n",crit); |
| InitializeCriticalSection(crit); |
| } |
| if (InterlockedIncrement( &crit->LockCount )) |
| { |
| if (crit->OwningThread == GetCurrentThreadId()) |
| { |
| crit->RecursionCount++; |
| return; |
| } |
| /* Now wait for it */ |
| |
| if ( crit->Reserved && crit->Reserved != GetCurrentProcessId() ) |
| { |
| FIXME( win32, "Crst %p belongs to process %ld, current is %ld!\n", |
| crit, crit->Reserved, GetCurrentProcessId() ); |
| return; |
| } |
| |
| res = WaitForSingleObject( crit->LockSemaphore, 5000L ); |
| if ( res == WAIT_TIMEOUT ) |
| { |
| ERR( win32, "Critical section %p wait timed out, retrying (60 sec)\n", crit ); |
| res = WaitForSingleObject( crit->LockSemaphore, 60000L ); |
| } |
| if ( res == WAIT_TIMEOUT && TRACE_ON(relay) ) |
| { |
| ERR( win32, "Critical section %p wait timed out, retrying (5 min)\n", crit ); |
| res = WaitForSingleObject( crit->LockSemaphore, 300000L ); |
| } |
| if (res != STATUS_WAIT_0) |
| { |
| ERR(win32, "Critical section %p wait failed err=%lx\n", crit, res ); |
| /* FIXME: should raise an exception */ |
| } |
| } |
| crit->OwningThread = GetCurrentThreadId(); |
| crit->RecursionCount = 1; |
| } |
| |
| |
| /*********************************************************************** |
| * TryEnterCriticalSection (KERNEL32.898) (NTDLL.969) |
| */ |
| BOOL WINAPI TryEnterCriticalSection( CRITICAL_SECTION *crit ) |
| { |
| if (InterlockedIncrement( &crit->LockCount )) |
| { |
| if (crit->OwningThread == GetCurrentThreadId()) |
| { |
| crit->RecursionCount++; |
| return TRUE; |
| } |
| /* FIXME: this doesn't work */ |
| InterlockedDecrement( &crit->LockCount ); |
| return FALSE; |
| } |
| crit->OwningThread = GetCurrentThreadId(); |
| crit->RecursionCount = 1; |
| return TRUE; |
| } |
| |
| |
| /*********************************************************************** |
| * LeaveCriticalSection (KERNEL32.494) (NTDLL.426) |
| */ |
| void WINAPI LeaveCriticalSection( CRITICAL_SECTION *crit ) |
| { |
| if (crit->OwningThread != GetCurrentThreadId()) return; |
| |
| if (--crit->RecursionCount) |
| { |
| InterlockedDecrement( &crit->LockCount ); |
| return; |
| } |
| crit->OwningThread = 0; |
| if (InterlockedDecrement( &crit->LockCount ) >= 0) |
| { |
| /* Someone is waiting */ |
| ReleaseSemaphore( crit->LockSemaphore, 1, NULL ); |
| } |
| } |
| |
| |
| /*********************************************************************** |
| * MakeCriticalSectionGlobal (KERNEL32.515) |
| */ |
| void WINAPI MakeCriticalSectionGlobal( CRITICAL_SECTION *crit ) |
| { |
| crit->LockSemaphore = ConvertToGlobalHandle( crit->LockSemaphore ); |
| crit->Reserved = 0L; |
| } |
| |
| |
| /*********************************************************************** |
| * ReinitializeCriticalSection (KERNEL32.581) |
| */ |
| void WINAPI ReinitializeCriticalSection( CRITICAL_SECTION *crit ) |
| { |
| if ( !crit->LockSemaphore ) |
| InitializeCriticalSection( crit ); |
| |
| else if ( crit->Reserved && crit->Reserved != GetCurrentProcessId() ) |
| { |
| FIXME( win32, "(%p) called for %08lx first, %08lx now: making global\n", |
| crit, crit->Reserved, GetCurrentProcessId() ); |
| |
| MakeCriticalSectionGlobal( crit ); |
| } |
| } |
| |
| |
| /*********************************************************************** |
| * UninitializeCriticalSection (KERNEL32.703) |
| */ |
| void WINAPI UninitializeCriticalSection( CRITICAL_SECTION *crit ) |
| { |
| if ( crit->LockSemaphore ) |
| { |
| if ( crit->Reserved ) /* not global */ |
| DeleteCriticalSection( crit ); |
| else |
| FIXME( win32, "(%p) for %08lx: Crst is global, don't know whether to delete\n", |
| crit, GetCurrentProcessId() ); |
| } |
| } |
| |