2 * mono-semaphore.c: mono-semaphore functions
5 * Gonzalo Paniagua Javier <gonzalo@novell.com>
7 * (C) 2010 Novell, Inc.
12 #include "utils/mono-semaphore.h"
13 #ifdef HAVE_SYS_TIME_H
20 #if (defined(HAVE_SEMAPHORE_H) || defined(USE_MACH_SEMA))
21 /* sem_* or semaphore_* functions in use */
23 # define TIMESPEC mach_timespec_t
24 # define WAIT_BLOCK(a,b) semaphore_timedwait (*(a), *(b))
25 # elif defined(__OpenBSD__)
26 # define TIMESPEC struct timespec
27 # define WAIT_BLOCK(a) sem_trywait(a)
29 # define TIMESPEC struct timespec
30 # define WAIT_BLOCK(a,b) sem_timedwait (a, b)
34 mono_sem_timedwait (MonoSemType
*sem
, guint32 timeout_ms
, gboolean alertable
)
39 #if defined(__OpenBSD__)
45 return (!sem_trywait (sem
));
47 if (timeout_ms
== (guint32
) 0xFFFFFFFF)
48 return mono_sem_wait (sem
, alertable
);
50 gettimeofday (&t
, NULL
);
51 ts
.tv_sec
= timeout_ms
/ 1000 + t
.tv_sec
;
52 ts
.tv_nsec
= (timeout_ms
% 1000) * 1000000 + t
.tv_usec
* 1000;
53 while (ts
.tv_nsec
> 1000000000) {
54 ts
.tv_nsec
-= 1000000000;
57 #if defined(__OpenBSD__)
60 if ((res
= WAIT_BLOCK (sem
)) == 0)
66 usleep (ts
.tv_nsec
/ 1000);
71 while ((res
= WAIT_BLOCK (sem
, &ts
) == -1) && errno
== EINTR
) {
81 mono_sem_wait (MonoSemType
*sem
, gboolean alertable
)
85 while ((res
= sem_wait (sem
) == -1) && errno
== EINTR
)
87 while ((res
= semaphore_wait (*sem
) == -1) && errno
== EINTR
)
97 mono_sem_post (MonoSemType
*sem
)
100 #ifndef USE_MACH_SEMA
101 while ((res
= sem_post (sem
) == -1) && errno
== EINTR
);
103 while ((res
= semaphore_signal (*sem
) == -1) && errno
== EINTR
);
109 /* Windows or io-layer functions in use */
111 mono_sem_wait (MonoSemType
*sem
, gboolean alertable
)
113 return mono_sem_timedwait (sem
, INFINITE
, alertable
);
117 mono_sem_timedwait (MonoSemType
*sem
, guint32 timeout_ms
, gboolean alertable
)
121 res
= WaitForSingleObjectEx (*sem
, timeout_ms
, alertable
);
128 mono_sem_post (MonoSemType
*sem
)
130 if (!ReleaseSemaphore (*sem
, 1, NULL
))