The-Homebrew-Cloud/wut
2
0
Fork 0
mirror of https://github.com/wiiu-env/wut.git synced 2025-01-08 12:40:42 +01:00
Code Issues Packages Projects Releases Wiki Activity

wutstdc++: Implement __gthread_cond_timedwait.

Browse Source
This commit is contained in:
James Benton 2018-05-25 18:45:19 +01:00
parent 750a2370d8
commit ec59508010
2 changed files with 58 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

54
libraries/wutstdc++/gthread_cond.cc
View File

@ -1,5 +1,10 @@
#include "include/bits/gthr-default.h" #include "include/bits/gthr-default.h"
#include <coreinit/alarm.h>
#include <coreinit/systeminfo.h>
#include <coreinit/time.h>
#include <chrono>
void void
__gthread_cond_init_function (__gthread_cond_t *__cond) __gthread_cond_init_function (__gthread_cond_t *__cond)
{ {
@ -27,6 +32,55 @@ __gthread_cond_wait (__gthread_cond_t *__cond, __gthread_mutex_t *__mutex)
return 0; return 0;
} }
struct TimedWaitData
{
__gthread_cond_t *cond;
bool timed_out;
};
static void
__gthread_timedwait_alarm_callback(OSAlarm *alarm, OSContext *context)
{
TimedWaitData *data = (TimedWaitData *)OSGetAlarmUserData(alarm);
data->timed_out = true;
OSSignalCond(data->cond);
}
int
__gthread_cond_timedwait (__gthread_cond_t *__cond, __gthread_mutex_t *__mutex,
const __gthread_time_t *__abs_timeout)
{
auto time = std::chrono::system_clock::now();
auto timeout = std::chrono::system_clock::time_point(
std::chrono::seconds(__abs_timeout->tv_sec) +
std::chrono::nanoseconds(__abs_timeout->tv_nsec));
// Already timed out!
if (timeout <= time) {
return ETIMEDOUT;
}
auto duration =
std::chrono::duration_cast<std::chrono::nanoseconds>(timeout - time);
// Set an alarm
OSAlarm alarm;
TimedWaitData data;
data.timed_out = false;
data.cond = __cond;
OSCreateAlarm(&alarm);
OSSetAlarmUserData(&alarm, &data);
OSSetAlarm(&alarm, OSNanoseconds(duration.count()),
&__gthread_timedwait_alarm_callback);
// Wait on the condition
OSWaitCond(__cond, __mutex);
OSCancelAlarm(&alarm);
return data.timed_out ? ETIMEDOUT : 0;
}
int int
__gthread_cond_wait_recursive (__gthread_cond_t *__cond, __gthread_cond_wait_recursive (__gthread_cond_t *__cond,
__gthread_recursive_mutex_t *__mutex) __gthread_recursive_mutex_t *__mutex)

4
libraries/wutstdc++/include/bits/gthr-default.h
View File

@ -151,6 +151,10 @@ __gthread_cond_signal (__gthread_cond_t *__cond);
int int
__gthread_cond_wait (__gthread_cond_t *__cond, __gthread_mutex_t *__mutex); __gthread_cond_wait (__gthread_cond_t *__cond, __gthread_mutex_t *__mutex);
int
__gthread_cond_timedwait (__gthread_cond_t *__cond, __gthread_mutex_t *__mutex,
const __gthread_time_t *__abs_timeout);
int int
__gthread_cond_wait_recursive (__gthread_cond_t *__cond, __gthread_cond_wait_recursive (__gthread_cond_t *__cond,
__gthread_recursive_mutex_t *__mutex); __gthread_recursive_mutex_t *__mutex);