mirror of https://github.com/mgba-emu/mgba.git
111 lines
2.3 KiB
C
111 lines
2.3 KiB
C
/* 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 N3DS_THREADING_H
|
|
#define N3DS_THREADING_H
|
|
|
|
#include <mgba-util/common.h>
|
|
|
|
#include <3ds.h>
|
|
#include <malloc.h>
|
|
|
|
#define THREAD_ENTRY void
|
|
typedef ThreadFunc ThreadEntry;
|
|
|
|
typedef LightLock Mutex;
|
|
typedef struct {
|
|
Mutex mutex;
|
|
Handle semaphore;
|
|
u32 waiting;
|
|
} Condition;
|
|
|
|
static inline int MutexInit(Mutex* mutex) {
|
|
LightLock_Init(mutex);
|
|
return 0;
|
|
}
|
|
|
|
static inline int MutexDeinit(Mutex* mutex) {
|
|
UNUSED(mutex);
|
|
return 0;
|
|
}
|
|
|
|
static inline int MutexLock(Mutex* mutex) {
|
|
LightLock_Lock(mutex);
|
|
return 0;
|
|
}
|
|
|
|
static inline int MutexTryLock(Mutex* mutex) {
|
|
return LightLock_TryLock(mutex);
|
|
}
|
|
|
|
static inline int MutexUnlock(Mutex* mutex) {
|
|
LightLock_Unlock(mutex);
|
|
return 0;
|
|
}
|
|
|
|
static inline int ConditionInit(Condition* cond) {
|
|
Result res = MutexInit(&cond->mutex);
|
|
if (res) {
|
|
return res;
|
|
}
|
|
res = svcCreateSemaphore(&cond->semaphore, 0, 1);
|
|
cond->waiting = 0;
|
|
return res;
|
|
}
|
|
|
|
static inline int ConditionDeinit(Condition* cond) {
|
|
return svcCloseHandle(cond->semaphore);
|
|
}
|
|
|
|
static inline int ConditionWait(Condition* cond, Mutex* mutex) {
|
|
MutexLock(&cond->mutex);
|
|
++cond->waiting;
|
|
MutexUnlock(mutex);
|
|
MutexUnlock(&cond->mutex);
|
|
svcWaitSynchronization(cond->semaphore, U64_MAX);
|
|
MutexLock(mutex);
|
|
return 0;
|
|
}
|
|
|
|
static inline int ConditionWaitTimed(Condition* cond, Mutex* mutex, int32_t timeoutMs) {
|
|
MutexLock(&cond->mutex);
|
|
++cond->waiting;
|
|
MutexUnlock(mutex);
|
|
MutexUnlock(&cond->mutex);
|
|
svcWaitSynchronization(cond->semaphore, timeoutMs * 10000000LL);
|
|
MutexLock(mutex);
|
|
return 0;
|
|
}
|
|
|
|
static inline int ConditionWake(Condition* cond) {
|
|
MutexLock(&cond->mutex);
|
|
if (cond->waiting) {
|
|
--cond->waiting;
|
|
s32 count = 0;
|
|
svcReleaseSemaphore(&count, cond->semaphore, 1);
|
|
}
|
|
MutexUnlock(&cond->mutex);
|
|
return 0;
|
|
}
|
|
|
|
static inline int ThreadCreate(Thread* thread, ThreadEntry entry, void* context) {
|
|
if (!entry || !thread) {
|
|
return 1;
|
|
}
|
|
*thread = threadCreate(entry, context, 0x8000, 0x18, 2, true);
|
|
return !*thread;
|
|
}
|
|
|
|
static inline int ThreadJoin(Thread thread) {
|
|
return threadJoin(thread, U64_MAX);
|
|
}
|
|
|
|
static inline void ThreadSetName(const char* name) {
|
|
UNUSED(name);
|
|
// Unimplemented
|
|
}
|
|
|
|
#endif
|