Merge remote-tracking branch 'upstream/master'
[mono.git] / mono / utils / mono-mutex.h
1 /* -*- Mode: C; tab-width: 8; indent-tabs-mode: t; c-basic-offset: 8 -*- */
2 /*
3  * mono-mutex.h: Portability wrappers around POSIX Mutexes
4  *
5  * Authors: Jeffrey Stedfast <fejj@ximian.com>
6  *
7  * Copyright 2002 Ximian, Inc. (www.ximian.com)
8  */
9
10
11 #ifndef __MONO_MUTEX_H__
12 #define __MONO_MUTEX_H__
13
14 #include <glib.h>
15 #ifdef HAVE_PTHREAD_H
16 #include <pthread.h>
17 #endif
18 #include <time.h>
19
20 #ifdef HOST_WIN32
21 #include <windows.h>
22 #endif
23
24 G_BEGIN_DECLS
25
26 #ifndef HOST_WIN32
27
28 typedef struct {
29         pthread_mutex_t mutex;
30         gboolean complete;
31 } mono_once_t;
32
33 #define MONO_ONCE_INIT { PTHREAD_MUTEX_INITIALIZER, FALSE }
34
35 int mono_once (mono_once_t *once, void (*once_init) (void));
36
37 typedef pthread_mutex_t mono_mutex_t;
38 typedef pthread_cond_t mono_cond_t;
39
40 #define mono_mutex_init(mutex) pthread_mutex_init (mutex, NULL)
41 #define mono_mutex_lock(mutex) pthread_mutex_lock (mutex)
42 #define mono_mutex_trylock(mutex) pthread_mutex_trylock (mutex)
43 #define mono_mutex_timedlock(mutex,timeout) pthread_mutex_timedlock (mutex, timeout)
44 #define mono_mutex_unlock(mutex) pthread_mutex_unlock (mutex)
45 #define mono_mutex_destroy(mutex) pthread_mutex_destroy (mutex)
46
47 #define mono_cond_init(cond,attr) pthread_cond_init (cond,attr)
48 #define mono_cond_wait(cond,mutex) pthread_cond_wait (cond, mutex)
49 #define mono_cond_timedwait(cond,mutex,timeout) pthread_cond_timedwait (cond, mutex, timeout)
50 #define mono_cond_signal(cond) pthread_cond_signal (cond)
51 #define mono_cond_broadcast(cond) pthread_cond_broadcast (cond)
52 #define mono_cond_destroy(cond)
53
54 /* This is a function so it can be passed to pthread_cleanup_push -
55  * that is a macro and giving it a macro as a parameter breaks.
56  */
57 G_GNUC_UNUSED
58 static inline int mono_mutex_unlock_in_cleanup (mono_mutex_t *mutex)
59 {
60         return(mono_mutex_unlock (mutex));
61 }
62
63 /* Returns zero on success. */
64 static inline int
65 mono_mutex_init_recursive (mono_mutex_t *mutex)
66 {
67         int res;
68         pthread_mutexattr_t attr;
69
70         pthread_mutexattr_init (&attr);
71         pthread_mutexattr_settype (&attr, PTHREAD_MUTEX_RECURSIVE);
72         res = pthread_mutex_init (mutex, &attr);
73         pthread_mutexattr_destroy (&attr);
74
75         return res;
76 }
77
78 #else
79
80 typedef CRITICAL_SECTION mono_mutex_t;
81 typedef HANDLE mono_cond_t;
82
83 #define mono_mutex_init(mutex) (InitializeCriticalSection((mutex)), 0)
84 #define mono_mutex_init_recursive(mutex) (InitializeCriticalSection((mutex)), 0)
85 #define mono_mutex_lock(mutex) EnterCriticalSection((mutex))
86 #define mono_mutex_trylock(mutex) TryEnterCriticalSection((mutex))
87 #define mono_mutex_unlock(mutex)  LeaveCriticalSection((mutex))
88 #define mono_mutex_destroy(mutex) DeleteCriticalSection((mutex))
89
90
91 #define mono_cond_init(cond,attr) do{*(cond) = CreateEvent(NULL,FALSE,FALSE,NULL); } while (0)
92 #define mono_cond_wait(cond,mutex) WaitForSingleObject(*(cond),INFINITE)
93 #define mono_cond_timedwait(cond,mutex,timeout) WaitForSingleObject(*(cond),timeout)
94 #define mono_cond_signal(cond) SetEvent(*(cond))
95 #define mono_cond_broadcast(cond) (!SetEvent(*(cond)))
96 #define mono_cond_destroy(cond) CloseHandle(*(cond))
97
98 #endif
99
100 int mono_mutex_init_suspend_safe (mono_mutex_t *mutex);
101
102 G_END_DECLS
103
104 #endif /* __MONO_MUTEX_H__ */