mirror/RetroArch
1
0
Fork 0
mirror of https://github.com/libretro/RetroArch synced 2025-01-29 09:32:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Update ctr_pthread.h

Browse Source
This commit is contained in:
Twinaphex 2018-01-18 21:12:07 +01:00 committed by GitHub
parent 194aa4ae7b
commit 318843a71d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
libretro-common/rthreads/ctr_pthread.h
View File

@ -54,6 +54,9 @@ static void ctr_thread_launcher(void* data)
static INLINE int pthread_create(pthread_t *thread,
const pthread_attr_t *attr, void *(*start_routine)(void*), void *arg)
{
s32 prio = 0;
Thread new_ctr_thread
if (!mutex_inited)
{
LightLock_Init(&safe_double_thread_launch);
@ -63,15 +66,17 @@ static INLINE int pthread_create(pthread_t *thread,
/*Must wait if attempting to launch 2 threads at once to prevent corruption of function pointer*/
while (LightLock_TryLock(&safe_double_thread_launch) != 0);
s32 prio = 0;
svcGetThreadPriority(&prio, CUR_THREAD_HANDLE);
start_routine_jump = start_routine;
Thread new_ctr_thread = threadCreate(ctr_thread_launcher, arg, STACKSIZE, prio - 1, -1/*No affinity, use any CPU*/, false);
if (new_ctr_thread == NULL)
new_ctr_thread = threadCreate(ctr_thread_launcher, arg, STACKSIZE, prio - 1, -1/*No affinity, use any CPU*/, false);
if (!new_ctr_thread)
{
LightLock_Unlock(&safe_double_thread_launch);
return EAGAIN;
}
*thread = new_ctr_thread;
return 0;
}
@ -143,15 +148,14 @@ static INLINE int pthread_cond_timedwait(pthread_cond_t *cond,
while (true)
{
struct timespec now = {0};
/* Missing clock_gettime*/
/* Missing clock_gettime*/
struct timeval tm;
gettimeofday(&tm, NULL);
now.tv_sec = tm.tv_sec;
now.tv_nsec = tm.tv_usec * 1000;
if (LightEvent_TryWait(cond) != 0 || now.tv_sec > abstime->tv_sec || (now.tv_sec == abstime->tv_sec && now.tv_nsec > abstime->tv_nsec))
{
break;
}
}
return 0;
@ -185,9 +189,7 @@ static INLINE int pthread_cond_destroy(pthread_cond_t *cond)
static INLINE int pthread_equal(pthread_t t1, pthread_t t2)
{
if (threadGetHandle(t1) == threadGetHandle(t2))
{
return 1;
}
return 0;
}