/**
|
* \file
|
*/
|
|
#ifndef __MONO_COOP_MUTEX_H__
|
#define __MONO_COOP_MUTEX_H__
|
|
#include <config.h>
|
#include <glib.h>
|
|
#include "mono-os-mutex.h"
|
#include "mono-threads-api.h"
|
|
G_BEGIN_DECLS
|
|
/* We put the OS sync primitives in struct, so the compiler will warn us if
|
* we use mono_os_(mutex|cond|sem)_... on MonoCoop(Mutex|Cond|Sem) structures */
|
|
typedef struct _MonoCoopMutex MonoCoopMutex;
|
struct _MonoCoopMutex {
|
mono_mutex_t m;
|
};
|
|
typedef struct _MonoCoopCond MonoCoopCond;
|
struct _MonoCoopCond {
|
mono_cond_t c;
|
};
|
|
static inline void
|
mono_coop_mutex_init (MonoCoopMutex *mutex)
|
{
|
mono_os_mutex_init (&mutex->m);
|
}
|
|
static inline void
|
mono_coop_mutex_init_recursive (MonoCoopMutex *mutex)
|
{
|
mono_os_mutex_init_recursive (&mutex->m);
|
}
|
|
static inline void
|
mono_coop_mutex_destroy (MonoCoopMutex *mutex)
|
{
|
mono_os_mutex_destroy (&mutex->m);
|
}
|
|
static inline void
|
mono_coop_mutex_lock (MonoCoopMutex *mutex)
|
{
|
/* Avoid thread state switch if lock is not contended */
|
if (mono_os_mutex_trylock (&mutex->m) == 0)
|
return;
|
|
MONO_ENTER_GC_SAFE;
|
|
mono_os_mutex_lock (&mutex->m);
|
|
MONO_EXIT_GC_SAFE;
|
}
|
|
static inline gint
|
mono_coop_mutex_trylock (MonoCoopMutex *mutex)
|
{
|
return mono_os_mutex_trylock (&mutex->m);
|
}
|
|
static inline void
|
mono_coop_mutex_unlock (MonoCoopMutex *mutex)
|
{
|
mono_os_mutex_unlock (&mutex->m);
|
}
|
|
static inline void
|
mono_coop_cond_init (MonoCoopCond *cond)
|
{
|
mono_os_cond_init (&cond->c);
|
}
|
|
static inline void
|
mono_coop_cond_destroy (MonoCoopCond *cond)
|
{
|
mono_os_cond_destroy (&cond->c);
|
}
|
|
static inline void
|
mono_coop_cond_wait (MonoCoopCond *cond, MonoCoopMutex *mutex)
|
{
|
MONO_ENTER_GC_SAFE;
|
|
mono_os_cond_wait (&cond->c, &mutex->m);
|
|
MONO_EXIT_GC_SAFE;
|
}
|
|
static inline gint
|
mono_coop_cond_timedwait (MonoCoopCond *cond, MonoCoopMutex *mutex, guint32 timeout_ms)
|
{
|
gint res;
|
|
MONO_ENTER_GC_SAFE;
|
|
res = mono_os_cond_timedwait (&cond->c, &mutex->m, timeout_ms);
|
|
MONO_EXIT_GC_SAFE;
|
|
return res;
|
}
|
|
static inline void
|
mono_coop_cond_signal (MonoCoopCond *cond)
|
{
|
mono_os_cond_signal (&cond->c);
|
}
|
|
static inline void
|
mono_coop_cond_broadcast (MonoCoopCond *cond)
|
{
|
mono_os_cond_broadcast (&cond->c);
|
}
|
|
G_END_DECLS
|
|
#endif /* __MONO_COOP_MUTEX_H__ */
|
