16 #include "objfw-defs.h"
22 #if !defined(OF_HAVE_THREADS) || \
23 (!defined(OF_HAVE_PTHREADS) && !defined(OF_WINDOWS) && !defined(OF_AMIGAOS))
24 # error No mutexes available!
29 #if defined(OF_HAVE_PTHREADS)
31 typedef pthread_mutex_t of_mutex_t;
32 #elif defined(OF_WINDOWS)
34 typedef CRITICAL_SECTION of_mutex_t;
35 #elif defined(OF_AMIGAOS)
36 # include <exec/semaphores.h>
37 typedef struct SignalSemaphore of_mutex_t;
40 #if defined(OF_HAVE_ATOMIC_OPS)
42 typedef volatile int of_spinlock_t;
43 # define OF_SPINCOUNT 10
44 #elif defined(OF_HAVE_PTHREAD_SPINLOCKS)
45 typedef pthread_spinlock_t of_spinlock_t;
47 typedef of_mutex_t of_spinlock_t;
50 #ifdef OF_HAVE_SCHED_YIELD
54 #if defined(OF_HAVE_RECURSIVE_PTHREAD_MUTEXES) || defined(OF_WINDOWS) || \
56 # define of_rmutex_t of_mutex_t
68 extern int of_mutex_new(of_mutex_t *mutex);
69 extern int of_mutex_lock(of_mutex_t *mutex);
70 extern int of_mutex_trylock(of_mutex_t *mutex);
71 extern int of_mutex_unlock(of_mutex_t *mutex);
72 extern int of_mutex_free(of_mutex_t *mutex);
73 extern int of_rmutex_new(of_rmutex_t *rmutex);
74 extern int of_rmutex_lock(of_rmutex_t *rmutex);
75 extern int of_rmutex_trylock(of_rmutex_t *rmutex);
76 extern int of_rmutex_unlock(of_rmutex_t *rmutex);
77 extern int of_rmutex_free(of_rmutex_t *rmutex);
87 #if defined(OF_HAVE_SCHED_YIELD)
89 #elif defined(OF_WINDOWS)
95 of_spinlock_new(of_spinlock_t *spinlock)
97 #if defined(OF_HAVE_ATOMIC_OPS)
100 #elif defined(OF_HAVE_PTHREAD_SPINLOCKS)
101 return pthread_spin_init(spinlock, 0);
103 return of_mutex_new(spinlock);
108 of_spinlock_trylock(of_spinlock_t *spinlock)
110 #if defined(OF_HAVE_ATOMIC_OPS)
111 if (of_atomic_int_cmpswap(spinlock, 0, 1)) {
112 of_memory_barrier_acquire();
117 #elif defined(OF_HAVE_PTHREAD_SPINLOCKS)
118 return pthread_spin_trylock(spinlock);
120 return of_mutex_trylock(spinlock);
125 of_spinlock_lock(of_spinlock_t *spinlock)
127 #if defined(OF_HAVE_ATOMIC_OPS)
130 for (i = 0; i < OF_SPINCOUNT; i++)
131 if (of_spinlock_trylock(spinlock) == 0)
134 while (of_spinlock_trylock(spinlock) == EBUSY)
138 #elif defined(OF_HAVE_PTHREAD_SPINLOCKS)
139 return pthread_spin_lock(spinlock);
141 return of_mutex_lock(spinlock);
146 of_spinlock_unlock(of_spinlock_t *spinlock)
148 #if defined(OF_HAVE_ATOMIC_OPS)
149 bool ret = of_atomic_int_cmpswap(spinlock, 1, 0);
151 of_memory_barrier_release();
153 return (ret ? 0 : EINVAL);
154 #elif defined(OF_HAVE_PTHREAD_SPINLOCKS)
155 return pthread_spin_unlock(spinlock);
157 return of_mutex_unlock(spinlock);
162 of_spinlock_free(of_spinlock_t *spinlock)
164 #if defined(OF_HAVE_ATOMIC_OPS)
166 #elif defined(OF_HAVE_PTHREAD_SPINLOCKS)
167 return pthread_spin_destroy(spinlock);
169 return of_mutex_free(spinlock);