29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
#if defined(OF_HAVE_PTHREADS)
# include <pthread.h>
typedef pthread_t of_thread_t;
typedef pthread_key_t of_tlskey_t;
typedef pthread_mutex_t of_mutex_t;
typedef pthread_cond_t of_condition_t;
#elif defined(_WIN32)
/*
* winsock2.h needs to be included before windows.h. Not including it here
* would make it impossible to use sockets after threading.h has been
* imported.
*/
# ifdef OF_HAVE_SOCKETS
# include <winsock2.h>
# endif
# include <windows.h>
typedef HANDLE of_thread_t;
typedef DWORD of_tlskey_t;
typedef CRITICAL_SECTION of_mutex_t;
typedef struct {
HANDLE event;
int count;
} of_condition_t;
#else
# error No threads available!
#endif
#if defined(OF_HAVE_ATOMIC_OPS)
# import "atomic.h"
typedef volatile int of_spinlock_t;
|
>
>
>
>
|
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
|
#if defined(OF_HAVE_PTHREADS)
# include <pthread.h>
typedef pthread_t of_thread_t;
typedef pthread_key_t of_tlskey_t;
typedef pthread_mutex_t of_mutex_t;
typedef pthread_cond_t of_condition_t;
typedef pthread_once_t of_once_t;
# define OF_ONCE_INIT PTHREAD_ONCE_INIT
#elif defined(_WIN32)
/*
* winsock2.h needs to be included before windows.h. Not including it here
* would make it impossible to use sockets after threading.h has been
* imported.
*/
# ifdef OF_HAVE_SOCKETS
# include <winsock2.h>
# endif
# include <windows.h>
typedef HANDLE of_thread_t;
typedef DWORD of_tlskey_t;
typedef CRITICAL_SECTION of_mutex_t;
typedef struct {
HANDLE event;
int count;
} of_condition_t;
typedef volatile LONG of_once_t;
# define OF_ONCE_INIT 0
#else
# error No threads available!
#endif
#if defined(OF_HAVE_ATOMIC_OPS)
# import "atomic.h"
typedef volatile int of_spinlock_t;
|
146
147
148
149
150
151
152
153
154
155
156
157
158
159
|
pthread_exit(NULL);
#elif defined(_WIN32)
ExitThread(0);
#else
# error of_thread_exit not implemented!
#endif
}
static OF_INLINE bool
of_mutex_new(of_mutex_t *mutex)
{
#if defined(OF_HAVE_PTHREADS)
return !pthread_mutex_init(mutex, NULL);
#elif defined(_WIN32)
|
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
|
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
|
pthread_exit(NULL);
#elif defined(_WIN32)
ExitThread(0);
#else
# error of_thread_exit not implemented!
#endif
}
static OF_INLINE void
of_once(of_once_t *control, void (*func)(void))
{
#if defined(OF_HAVE_PTHREADS)
pthread_once(control, func);
#elif defined(_WIN32)
switch (InterlockedCompareExchange(control, 1, 0)) {
case 0:
func();
InterlockedIncrement(control);
break;
case 1:
while (*control == 1)
Sleep(0);
break;
}
#else
# error of_once not implemented!
#endif
}
static OF_INLINE bool
of_mutex_new(of_mutex_t *mutex)
{
#if defined(OF_HAVE_PTHREADS)
return !pthread_mutex_init(mutex, NULL);
#elif defined(_WIN32)
|