mono/utils/mono-coop-semaphore.h

   1 /**
   2  * \file
   3  */
   4
   5 #ifndef __MONO_COOP_SEMAPHORE_H__
   6 #define __MONO_COOP_SEMAPHORE_H__
   7
   8 #include <config.h>
   9 #include <glib.h>
  10
  11 #include "mono-os-semaphore.h"
  12 #include "mono-threads-api.h"
  13
  14 /* We put the OS sync primitives in struct, so the compiler will warn us if
  15  * we use mono_os_(mutex|cond|sem)_... on MonoCoop(Mutex|Cond|Sem) structures */
  16
  17 typedef struct _MonoCoopSem MonoCoopSem;
  18 struct _MonoCoopSem {
  19         MonoSemType s;
  20 };
  21
  22 static inline void
  23 mono_coop_sem_init (MonoCoopSem *sem, int value)
  24 {
  25         mono_os_sem_init (&sem->s, value);
  26 }
  27
  28 static inline void
  29 mono_coop_sem_destroy (MonoCoopSem *sem)
  30 {
  31         mono_os_sem_destroy (&sem->s);
  32 }
  33
  34 static inline gint
  35 mono_coop_sem_wait (MonoCoopSem *sem, MonoSemFlags flags)
  36 {
  37         gint res;
  38
  39         MONO_ENTER_GC_SAFE;
  40
  41         res = mono_os_sem_wait (&sem->s, flags);
  42
  43         MONO_EXIT_GC_SAFE;
  44
  45         return res;
  46 }
  47
  48 static inline MonoSemTimedwaitRet
  49 mono_coop_sem_timedwait (MonoCoopSem *sem, guint timeout_ms, MonoSemFlags flags)
  50 {
  51         MonoSemTimedwaitRet res;
  52
  53         MONO_ENTER_GC_SAFE;
  54
  55         res = mono_os_sem_timedwait (&sem->s, timeout_ms, flags);
  56
  57         MONO_EXIT_GC_SAFE;
  58
  59         return res;
  60 }
  61
  62 static inline void
  63 mono_coop_sem_post (MonoCoopSem *sem)
  64 {
  65         mono_os_sem_post (&sem->s);
  66 }
  67
  68 #endif /* __MONO_COOP_SEMAPHORE_H__ */