RetroArch/thread.c

358 lines
6.6 KiB
C
Raw Normal View History

2012-04-21 21:13:50 +00:00
/* RetroArch - A frontend for libretro.
2013-01-01 00:37:37 +00:00
* Copyright (C) 2010-2013 - Hans-Kristian Arntzen
* Copyright (C) 2011-2013 - Daniel De Matteis
*
2012-04-21 21:13:50 +00:00
* RetroArch is free software: you can redistribute it and/or modify it under the terms
* of the GNU General Public License as published by the Free Software Found-
* ation, either version 3 of the License, or (at your option) any later version.
*
2012-04-21 21:13:50 +00:00
* RetroArch is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;
* without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
* PURPOSE. See the GNU General Public License for more details.
*
2012-04-21 21:31:57 +00:00
* You should have received a copy of the GNU General Public License along with RetroArch.
* If not, see <http://www.gnu.org/licenses/>.
*/
#include "thread.h"
#include <stdlib.h>
2013-04-11 20:35:15 +00:00
#if defined(_WIN32)
#ifdef _XBOX
#include <xtl.h>
#else
#define WIN32_LEAN_AND_MEAN
#include <windows.h>
2013-04-11 20:35:15 +00:00
#endif
#elif defined(GEKKO)
#include "thread/gx_pthread.h"
#else
#include <pthread.h>
#include <time.h>
#endif
2011-10-06 18:49:00 +00:00
#ifdef __MACH__
#include <mach/clock.h>
#include <mach/mach.h>
#endif
2011-10-06 20:19:56 +00:00
struct thread_data
{
void (*func)(void*);
void *userdata;
};
#ifdef _WIN32
2011-10-06 20:19:56 +00:00
struct sthread
{
HANDLE thread;
};
static DWORD CALLBACK thread_wrap(void *data_)
{
2011-12-24 12:46:12 +00:00
struct thread_data *data = (struct thread_data*)data_;
2011-10-06 20:19:56 +00:00
data->func(data->userdata);
free(data);
return 0;
}
sthread_t *sthread_create(void (*thread_func)(void*), void *userdata)
{
2011-12-24 12:46:12 +00:00
sthread_t *thread = (sthread_t*)calloc(1, sizeof(*thread));
2011-10-06 20:19:56 +00:00
if (!thread)
return NULL;
2011-12-24 12:46:12 +00:00
struct thread_data *data = (struct thread_data*)calloc(1, sizeof(*data));
2011-10-06 20:19:56 +00:00
if (!data)
{
free(thread);
return NULL;
}
data->func = thread_func;
data->userdata = userdata;
thread->thread = CreateThread(NULL, 0, thread_wrap, data, 0, NULL);
if (!thread->thread)
{
free(data);
free(thread);
return NULL;
}
return thread;
}
int sthread_detach(sthread_t *thread)
{
CloseHandle(thread->thread);
2013-11-01 08:12:36 +00:00
free(thread);
return 0;
}
2011-10-06 20:19:56 +00:00
void sthread_join(sthread_t *thread)
{
WaitForSingleObject(thread->thread, INFINITE);
CloseHandle(thread->thread);
free(thread);
}
struct slock
{
2011-10-06 20:19:56 +00:00
CRITICAL_SECTION lock;
};
slock_t *slock_new(void)
{
2011-12-24 12:46:12 +00:00
slock_t *lock = (slock_t*)calloc(1, sizeof(*lock));
if (!lock)
return NULL;
2011-10-06 20:19:56 +00:00
InitializeCriticalSection(&lock->lock);
return lock;
}
2011-10-06 20:19:56 +00:00
void slock_free(slock_t *lock)
{
DeleteCriticalSection(&lock->lock);
free(lock);
}
2011-10-06 20:19:56 +00:00
void slock_lock(slock_t *lock)
{
EnterCriticalSection(&lock->lock);
}
2011-10-06 20:19:56 +00:00
void slock_unlock(slock_t *lock)
{
2011-10-06 20:19:56 +00:00
LeaveCriticalSection(&lock->lock);
}
struct scond
{
HANDLE event;
};
2011-10-06 20:19:56 +00:00
scond_t *scond_new(void)
{
2011-12-24 12:46:12 +00:00
scond_t *cond = (scond_t*)calloc(1, sizeof(*cond));
2011-10-06 20:19:56 +00:00
if (!cond)
return NULL;
cond->event = CreateEvent(NULL, FALSE, FALSE, NULL);
if (!cond->event)
{
free(cond);
return NULL;
}
return cond;
}
void scond_wait(scond_t *cond, slock_t *lock)
{
WaitForSingleObject(cond->event, 0);
slock_unlock(lock);
WaitForSingleObject(cond->event, INFINITE);
slock_lock(lock);
}
bool scond_wait_timeout(scond_t *cond, slock_t *lock, int64_t timeout_us)
2011-10-06 20:19:56 +00:00
{
WaitForSingleObject(cond->event, 0);
slock_unlock(lock);
DWORD res = WaitForSingleObject(cond->event, timeout_us / 1000);
2011-10-06 20:19:56 +00:00
slock_lock(lock);
return res == WAIT_OBJECT_0;
}
void scond_signal(scond_t *cond)
{
SetEvent(cond->event);
}
2013-10-31 22:12:40 +00:00
/* FIXME - check how this function should differ from scond_signal implementation */
int scond_broadcast(scond_t *cond)
{
SetEvent(cond->event);
return 0;
}
2011-10-06 20:19:56 +00:00
void scond_free(scond_t *cond)
{
CloseHandle(cond->event);
free(cond);
}
#else
struct sthread
{
pthread_t id;
};
static void *thread_wrap(void *data_)
{
2011-12-24 12:46:12 +00:00
struct thread_data *data = (struct thread_data*)data_;
data->func(data->userdata);
free(data);
2012-03-04 12:19:51 +00:00
return NULL;
}
sthread_t *sthread_create(void (*thread_func)(void*), void *userdata)
{
2011-12-24 12:46:12 +00:00
sthread_t *thr = (sthread_t*)calloc(1, sizeof(*thr));
if (!thr)
return NULL;
2011-12-24 12:46:12 +00:00
struct thread_data *data = (struct thread_data*)calloc(1, sizeof(*data));
if (!data)
{
free(thr);
return NULL;
}
data->func = thread_func;
data->userdata = userdata;
if (pthread_create(&thr->id, NULL, thread_wrap, data) < 0)
{
free(data);
free(thr);
return NULL;
}
return thr;
}
int sthread_detach(sthread_t *thread)
{
2013-11-01 08:12:36 +00:00
return pthread_detach(thread->id);
}
void sthread_join(sthread_t *thread)
{
pthread_join(thread->id, NULL);
free(thread);
}
struct slock
{
pthread_mutex_t lock;
};
slock_t *slock_new(void)
{
2011-12-24 12:46:12 +00:00
slock_t *lock = (slock_t*)calloc(1, sizeof(*lock));
if (!lock)
return NULL;
if (pthread_mutex_init(&lock->lock, NULL) < 0)
{
free(lock);
return NULL;
}
return lock;
}
void slock_free(slock_t *lock)
{
pthread_mutex_destroy(&lock->lock);
free(lock);
}
void slock_lock(slock_t *lock)
{
pthread_mutex_lock(&lock->lock);
}
void slock_unlock(slock_t *lock)
{
pthread_mutex_unlock(&lock->lock);
}
struct scond
{
pthread_cond_t cond;
};
scond_t *scond_new(void)
{
2011-12-24 12:46:12 +00:00
scond_t *cond = (scond_t*)calloc(1, sizeof(*cond));
if (!cond)
return NULL;
if (pthread_cond_init(&cond->cond, NULL) < 0)
{
free(cond);
return NULL;
}
return cond;
}
void scond_free(scond_t *cond)
{
pthread_cond_destroy(&cond->cond);
free(cond);
}
void scond_wait(scond_t *cond, slock_t *lock)
{
pthread_cond_wait(&cond->cond, &lock->lock);
}
2013-10-31 22:12:40 +00:00
int scond_broadcast(scond_t *cond)
{
return pthread_cond_broadcast(&cond->cond);
}
bool scond_wait_timeout(scond_t *cond, slock_t *lock, int64_t timeout_us)
{
struct timespec now = {0};
2011-10-06 18:49:00 +00:00
#ifdef __MACH__ // OSX doesn't have clock_gettime ... :(
clock_serv_t cclock;
mach_timespec_t mts;
host_get_clock_service(mach_host_self(), CALENDAR_CLOCK, &cclock);
clock_get_time(cclock, &mts);
mach_port_deallocate(mach_task_self(), cclock);
now.tv_sec = mts.tv_sec;
now.tv_nsec = mts.tv_nsec;
#elif defined(__CELLOS_LV2__)
sys_time_sec_t s;
sys_time_nsec_t n;
sys_time_get_current_time(&s, &n);
#elif !defined(GEKKO) // timeout on libogc is duration, not end time
clock_gettime(CLOCK_REALTIME, &now);
2011-10-06 18:49:00 +00:00
#endif
#if defined(__CELLOS_LV2__)
now.tv_sec = s;
now.tv_nsec = n;
#else
now.tv_sec += timeout_us / 1000000LL;
now.tv_nsec += timeout_us * 1000LL;
now.tv_sec += now.tv_nsec / 1000000000LL;
now.tv_nsec = now.tv_nsec % 1000000000LL;
#endif
int ret = pthread_cond_timedwait(&cond->cond, &lock->lock, &now);
return ret == 0;
}
void scond_signal(scond_t *cond)
{
pthread_cond_signal(&cond->cond);
}
#endif