2015-06-18 08:00:35 +00:00
|
|
|
/* Copyright (c) 2013-2015 Jeffrey Pfau
|
|
|
|
*
|
|
|
|
* This Source Code Form is subject to the terms of the Mozilla Public
|
|
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
|
|
* file, You can obtain one at http://mozilla.org/MPL/2.0/. */
|
|
|
|
#ifndef POSIX_THREADING_H
|
|
|
|
#define POSIX_THREADING_H
|
|
|
|
|
2016-12-31 01:00:22 +00:00
|
|
|
#include <mgba-util/common.h>
|
2015-06-18 08:00:35 +00:00
|
|
|
|
2016-12-27 05:01:55 +00:00
|
|
|
CXX_GUARD_START
|
|
|
|
|
2015-06-18 08:00:35 +00:00
|
|
|
#include <pthread.h>
|
|
|
|
#include <sys/time.h>
|
2015-07-28 23:50:07 +00:00
|
|
|
#if defined(__FreeBSD__) || defined(__OpenBSD__)
|
2015-06-18 08:00:35 +00:00
|
|
|
#include <pthread_np.h>
|
2017-04-24 04:16:11 +00:00
|
|
|
#elif defined(__HAIKU__)
|
|
|
|
#include <OS.h>
|
2015-06-18 08:00:35 +00:00
|
|
|
#endif
|
|
|
|
|
|
|
|
#define THREAD_ENTRY void*
|
|
|
|
typedef THREAD_ENTRY (*ThreadEntry)(void*);
|
|
|
|
|
|
|
|
typedef pthread_t Thread;
|
|
|
|
typedef pthread_mutex_t Mutex;
|
|
|
|
typedef pthread_cond_t Condition;
|
|
|
|
|
|
|
|
static inline int MutexInit(Mutex* mutex) {
|
|
|
|
return pthread_mutex_init(mutex, 0);
|
|
|
|
}
|
|
|
|
|
|
|
|
static inline int MutexDeinit(Mutex* mutex) {
|
|
|
|
return pthread_mutex_destroy(mutex);
|
|
|
|
}
|
|
|
|
|
|
|
|
static inline int MutexLock(Mutex* mutex) {
|
|
|
|
return pthread_mutex_lock(mutex);
|
|
|
|
}
|
|
|
|
|
2015-11-13 06:50:09 +00:00
|
|
|
static inline int MutexTryLock(Mutex* mutex) {
|
|
|
|
return pthread_mutex_trylock(mutex);
|
|
|
|
}
|
|
|
|
|
2015-06-18 08:00:35 +00:00
|
|
|
static inline int MutexUnlock(Mutex* mutex) {
|
|
|
|
return pthread_mutex_unlock(mutex);
|
|
|
|
}
|
|
|
|
|
|
|
|
static inline int ConditionInit(Condition* cond) {
|
|
|
|
return pthread_cond_init(cond, 0);
|
|
|
|
}
|
|
|
|
|
|
|
|
static inline int ConditionDeinit(Condition* cond) {
|
|
|
|
return pthread_cond_destroy(cond);
|
|
|
|
}
|
|
|
|
|
|
|
|
static inline int ConditionWait(Condition* cond, Mutex* mutex) {
|
|
|
|
return pthread_cond_wait(cond, mutex);
|
|
|
|
}
|
|
|
|
|
|
|
|
static inline int ConditionWaitTimed(Condition* cond, Mutex* mutex, int32_t timeoutMs) {
|
|
|
|
struct timespec ts;
|
|
|
|
struct timeval tv;
|
|
|
|
|
|
|
|
gettimeofday(&tv, 0);
|
|
|
|
ts.tv_sec = tv.tv_sec;
|
|
|
|
ts.tv_nsec = (tv.tv_usec + timeoutMs * 1000L) * 1000L;
|
|
|
|
if (ts.tv_nsec >= 1000000000L) {
|
|
|
|
ts.tv_nsec -= 1000000000L;
|
|
|
|
++ts.tv_sec;
|
|
|
|
}
|
|
|
|
|
|
|
|
return pthread_cond_timedwait(cond, mutex, &ts);
|
|
|
|
}
|
|
|
|
|
|
|
|
static inline int ConditionWake(Condition* cond) {
|
|
|
|
return pthread_cond_broadcast(cond);
|
|
|
|
}
|
|
|
|
|
|
|
|
static inline int ThreadCreate(Thread* thread, ThreadEntry entry, void* context) {
|
|
|
|
return pthread_create(thread, 0, entry, context);
|
|
|
|
}
|
|
|
|
|
|
|
|
static inline int ThreadJoin(Thread thread) {
|
|
|
|
return pthread_join(thread, 0);
|
|
|
|
}
|
|
|
|
|
|
|
|
static inline int ThreadSetName(const char* name) {
|
|
|
|
#ifdef __APPLE__
|
2017-12-23 23:37:57 +00:00
|
|
|
#if __ENVIRONMENT_MAC_OS_X_VERSION_MIN_REQUIRED__ >= 1060
|
2015-06-18 08:00:35 +00:00
|
|
|
return pthread_setname_np(name);
|
2017-12-23 23:37:57 +00:00
|
|
|
#else
|
|
|
|
UNUSED(name);
|
|
|
|
return 0;
|
|
|
|
#endif
|
2015-07-28 16:04:28 +00:00
|
|
|
#elif defined(__FreeBSD__) || defined(__OpenBSD__)
|
2015-06-18 08:00:35 +00:00
|
|
|
pthread_set_name_np(pthread_self(), name);
|
|
|
|
return 0;
|
2017-04-24 04:16:11 +00:00
|
|
|
#elif defined(__HAIKU__)
|
|
|
|
rename_thread(find_thread(NULL), name);
|
|
|
|
return 0;
|
2015-10-12 06:59:48 +00:00
|
|
|
#elif !defined(BUILD_PANDORA) // Pandora's glibc is too old
|
2015-06-18 08:00:35 +00:00
|
|
|
return pthread_setname_np(pthread_self(), name);
|
2015-10-12 06:59:48 +00:00
|
|
|
#else
|
|
|
|
UNUSED(name);
|
|
|
|
return 0;
|
2015-06-18 08:00:35 +00:00
|
|
|
#endif
|
|
|
|
}
|
|
|
|
|
2016-12-27 05:01:55 +00:00
|
|
|
CXX_GUARD_END
|
|
|
|
|
2015-06-18 08:00:35 +00:00
|
|
|
#endif
|