2 * Win32 critical sections
4 * Copyright 1998 Alexandre Julliard
10 #include <sys/types.h>
15 #include "debugtools.h"
18 DEFAULT_DEBUG_CHANNEL(win32
)
19 DECLARE_DEBUG_CHANNEL(relay
)
22 /***********************************************************************
23 * InitializeCriticalSection (KERNEL32.472) (NTDLL.406)
25 void WINAPI
InitializeCriticalSection( CRITICAL_SECTION
*crit
)
28 crit
->RecursionCount
= 0;
29 crit
->OwningThread
= 0;
30 crit
->LockSemaphore
= CreateSemaphoreA( NULL
, 0, 1, NULL
);
31 crit
->Reserved
= GetCurrentProcessId();
35 /***********************************************************************
36 * DeleteCriticalSection (KERNEL32.185) (NTDLL.327)
38 void WINAPI
DeleteCriticalSection( CRITICAL_SECTION
*crit
)
40 if (crit
->LockSemaphore
)
42 if (crit
->RecursionCount
) /* Should not happen */
43 ERR("Deleting owned critical section (%p)\n", crit
);
46 crit
->RecursionCount
= 0;
47 crit
->OwningThread
= 0;
48 CloseHandle( crit
->LockSemaphore
);
49 crit
->LockSemaphore
= 0;
50 crit
->Reserved
= (DWORD
)-1;
55 /***********************************************************************
56 * EnterCriticalSection (KERNEL32.195) (NTDLL.344)
58 void WINAPI
EnterCriticalSection( CRITICAL_SECTION
*crit
)
62 if (!crit
->LockSemaphore
)
64 FIXME("entering uninitialized section(%p)?\n",crit
);
65 InitializeCriticalSection(crit
);
67 if ( crit
->Reserved
&& crit
->Reserved
!= GetCurrentProcessId() )
69 FIXME("Crst %p belongs to process %ld, current is %ld!\n",
70 crit
, crit
->Reserved
, GetCurrentProcessId() );
73 if (InterlockedIncrement( &crit
->LockCount
))
75 if (crit
->OwningThread
== GetCurrentThreadId())
77 crit
->RecursionCount
++;
86 res
= WaitForSingleObject( crit
->LockSemaphore
, 5000L );
87 if ( res
== WAIT_TIMEOUT
)
89 ERR("Critical section %p wait timed out, retrying (60 sec)\n", crit
);
90 res
= WaitForSingleObject( crit
->LockSemaphore
, 60000L );
91 if ( res
== WAIT_TIMEOUT
&& TRACE_ON(relay
) )
93 ERR("Critical section %p wait timed out, retrying (5 min)\n", crit
);
94 res
= WaitForSingleObject( crit
->LockSemaphore
, 300000L );
97 if (res
== STATUS_WAIT_0
) break;
99 rec
.ExceptionCode
= EXCEPTION_CRITICAL_SECTION_WAIT
;
100 rec
.ExceptionFlags
= 0;
101 rec
.ExceptionRecord
= NULL
;
102 rec
.ExceptionAddress
= RtlRaiseException
; /* sic */
103 rec
.NumberParameters
= 1;
104 rec
.ExceptionInformation
[0] = (DWORD
)crit
;
105 RtlRaiseException( &rec
);
108 crit
->OwningThread
= GetCurrentThreadId();
109 crit
->RecursionCount
= 1;
113 /***********************************************************************
114 * TryEnterCriticalSection (KERNEL32.898) (NTDLL.969)
116 BOOL WINAPI
TryEnterCriticalSection( CRITICAL_SECTION
*crit
)
119 if (InterlockedCompareExchange( (PVOID
*)&crit
->LockCount
,
120 (PVOID
)0L, (PVOID
)-1L ) == (PVOID
)-1L)
122 crit
->OwningThread
= GetCurrentThreadId();
123 crit
->RecursionCount
= 1;
126 else if (crit
->OwningThread
== GetCurrentThreadId())
128 InterlockedIncrement( &crit
->LockCount
);
129 crit
->RecursionCount
++;
136 /***********************************************************************
137 * LeaveCriticalSection (KERNEL32.494) (NTDLL.426)
139 void WINAPI
LeaveCriticalSection( CRITICAL_SECTION
*crit
)
141 if (crit
->OwningThread
!= GetCurrentThreadId()) return;
143 if (--crit
->RecursionCount
)
145 InterlockedDecrement( &crit
->LockCount
);
148 crit
->OwningThread
= 0;
149 if (InterlockedDecrement( &crit
->LockCount
) >= 0)
151 /* Someone is waiting */
152 ReleaseSemaphore( crit
->LockSemaphore
, 1, NULL
);
157 /***********************************************************************
158 * MakeCriticalSectionGlobal (KERNEL32.515)
160 void WINAPI
MakeCriticalSectionGlobal( CRITICAL_SECTION
*crit
)
162 crit
->LockSemaphore
= ConvertToGlobalHandle( crit
->LockSemaphore
);
167 /***********************************************************************
168 * ReinitializeCriticalSection (KERNEL32.581)
170 void WINAPI
ReinitializeCriticalSection( CRITICAL_SECTION
*crit
)
172 if ( !crit
->LockSemaphore
)
173 InitializeCriticalSection( crit
);
175 else if ( crit
->Reserved
&& crit
->Reserved
!= GetCurrentProcessId() )
177 FIXME("(%p) called for %08lx first, %08lx now: making global\n",
178 crit
, crit
->Reserved
, GetCurrentProcessId() );
180 MakeCriticalSectionGlobal( crit
);
185 /***********************************************************************
186 * UninitializeCriticalSection (KERNEL32.703)
188 void WINAPI
UninitializeCriticalSection( CRITICAL_SECTION
*crit
)
190 if ( crit
->LockSemaphore
)
192 if ( crit
->Reserved
) /* not global */
193 DeleteCriticalSection( crit
);
195 FIXME("(%p) for %08lx: Crst is global, don't know whether to delete\n",
196 crit
, GetCurrentProcessId() );
202 PVOID WINAPI
InterlockedCompareExchange( PVOID
*dest
, PVOID xchg
, PVOID compare
);
203 __ASM_GLOBAL_FUNC(InterlockedCompareExchange
,
204 "movl 12(%esp),%eax\n\t"
205 "movl 8(%esp),%ecx\n\t"
206 "movl 4(%esp),%edx\n\t"
207 "lock; cmpxchgl %ecx,(%edx)\n\t"
210 LONG WINAPI
InterlockedExchange( PLONG dest
, LONG val
);
211 __ASM_GLOBAL_FUNC(InterlockedExchange
,
212 "movl 8(%esp),%eax\n\t"
213 "movl 4(%esp),%edx\n\t"
214 "lock; xchgl %eax,(%edx)\n\t"
217 LONG WINAPI
InterlockedExchangeAdd( PLONG dest
, LONG incr
);
218 __ASM_GLOBAL_FUNC(InterlockedExchangeAdd
,
219 "movl 8(%esp),%eax\n\t"
220 "movl 4(%esp),%edx\n\t"
221 "lock; xaddl %eax,(%edx)\n\t"
224 LONG WINAPI
InterlockedIncrement( PLONG dest
);
225 __ASM_GLOBAL_FUNC(InterlockedIncrement
,
226 "movl 4(%esp),%edx\n\t"
228 "lock; xaddl %eax,(%edx)\n\t"
232 LONG WINAPI
InterlockedDecrement( PLONG dest
);
233 __ASM_GLOBAL_FUNC(InterlockedDecrement
,
234 "movl 4(%esp),%edx\n\t"
236 "lock; xaddl %eax,(%edx)\n\t"
241 #error You must implement the Interlocked* functions for your CPU
242 #endif /* __i386__ */