Update libretro-common

This commit is contained in:
twinaphex 2016-03-21 05:44:45 +01:00
parent 1114e3960e
commit f9992c5e47
7 changed files with 91 additions and 23 deletions

View File

@ -60,7 +60,17 @@ extern int optind, opterr, optopt;
#ifdef __cplusplus #ifdef __cplusplus
} }
#endif #endif
/* If these are variously #defined, then we have bigger problems */
#ifndef no_argument
#define no_argument 0
#define required_argument 1
#define optional_argument 2
#endif #endif
/* HAVE_GETOPT_LONG */
#endif
/* pragma once */
#endif #endif

View File

@ -86,7 +86,9 @@ typedef int ssize_t;
#pragma warning(disable : 4723) #pragma warning(disable : 4723)
#pragma warning(disable : 4996) #pragma warning(disable : 4996)
#if _MSC_VER < 1200
#define roundf(in) (in >= 0.0f ? floorf(in + 0.5f) : ceilf(in - 0.5f)) #define roundf(in) (in >= 0.0f ? floorf(in + 0.5f) : ceilf(in - 0.5f))
#endif
#ifndef PATH_MAX #ifndef PATH_MAX
#define PATH_MAX _MAX_PATH #define PATH_MAX _MAX_PATH

View File

@ -41,15 +41,20 @@ char *strtok_r(char *str, const char *delim, char **saveptr);
#ifdef _MSC_VER #ifdef _MSC_VER
#undef strcasecmp #undef strcasecmp
#undef strdup #undef strdup
#undef isblank
#define strcasecmp(a, b) retro_strcasecmp__(a, b) #define strcasecmp(a, b) retro_strcasecmp__(a, b)
#define strdup(orig) retro_strdup__(orig) #define strdup(orig) retro_strdup__(orig)
#define isblank(c) retro_isblank__(c)
int strcasecmp(const char *a, const char *b); int strcasecmp(const char *a, const char *b);
char *strdup(const char *orig); char *strdup(const char *orig);
#if _MSC_VER < 1200
#undef isblank
#define isblank(c) retro_isblank__(c)
int isblank(int c); int isblank(int c);
#endif #endif
#endif
#ifdef __cplusplus #ifdef __cplusplus
} }
#endif #endif

View File

@ -74,6 +74,19 @@ int sthread_detach(sthread_t *thread);
*/ */
void sthread_join(sthread_t *thread); void sthread_join(sthread_t *thread);
/**
* sthread_isself:
* @thread : pointer to thread object
*
* Join with a terminated thread. Waits for the thread specified by
* @thread to terminate. If that thread has already terminated, then
* it will return immediately. The thread specified by @thread must
* be joinable.
*
* Returns: true (1) if calling thread is the specified thread
*/
bool sthread_isself(sthread_t *thread);
/** /**
* slock_new: * slock_new:
* *

View File

@ -107,6 +107,12 @@ static INLINE int pthread_create(pthread_t *thread,
0, STACKSIZE, 64, 0 /* unused */); 0, STACKSIZE, 64, 0 /* unused */);
} }
static INLINE pthread_t pthread_self(void)
{
/* zero 20-mar-2016: untested */
return LWP_GetSelf();
}
static INLINE int pthread_mutex_init(pthread_mutex_t *mutex, static INLINE int pthread_mutex_init(pthread_mutex_t *mutex,
const pthread_mutexattr_t *attr) const pthread_mutexattr_t *attr)
{ {

View File

@ -190,4 +190,11 @@ static INLINE void pthread_exit(void *retval)
(void)retval; (void)retval;
} }
static INLINE pthread_t pthread_self(void)
{
/* zero 20-mar-2016: untested */
return sceKernelGetThreadId();
}
#endif //_PSP_PTHREAD_WRAP__ #endif //_PSP_PTHREAD_WRAP__

View File

@ -25,7 +25,10 @@
#include <boolean.h> #include <boolean.h>
#include <rthreads/rthreads.h> #include <rthreads/rthreads.h>
#if defined(_WIN32) /* with RETRO_WIN32_USE_PTHREADS, pthreads can be used even on win32. Maybe only supported in MSVC>=2005 */
#if defined(_WIN32) && !defined(RETRO_WIN32_USE_PTHREADS)
#define USE_WIN32_THREADS
#ifdef _XBOX #ifdef _XBOX
#include <xtl.h> #include <xtl.h>
#else #else
@ -54,7 +57,7 @@ struct thread_data
struct sthread struct sthread
{ {
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
HANDLE thread; HANDLE thread;
#else #else
pthread_t id; pthread_t id;
@ -63,7 +66,7 @@ struct sthread
struct slock struct slock
{ {
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
HANDLE lock; HANDLE lock;
#else #else
pthread_mutex_t lock; pthread_mutex_t lock;
@ -72,14 +75,14 @@ struct slock
struct scond struct scond
{ {
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
HANDLE event; HANDLE event;
#else #else
pthread_cond_t cond; pthread_cond_t cond;
#endif #endif
}; };
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
static DWORD CALLBACK thread_wrap(void *data_) static DWORD CALLBACK thread_wrap(void *data_)
#else #else
static void *thread_wrap(void *data_) static void *thread_wrap(void *data_)
@ -119,9 +122,9 @@ sthread_t *sthread_create(void (*thread_func)(void*), void *userdata)
data->func = thread_func; data->func = thread_func;
data->userdata = userdata; data->userdata = userdata;
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
thread->thread = CreateThread(NULL, 0, thread_wrap, data, 0, NULL); thread->thread = CreateThread(NULL, 0, thread_wrap, data, 0, NULL);
thread_created = thread->thread; thread_created = !!thread->thread;
#else #else
thread_created = pthread_create(&thread->id, NULL, thread_wrap, data) == 0; thread_created = pthread_create(&thread->id, NULL, thread_wrap, data) == 0;
#endif #endif
@ -151,7 +154,7 @@ error:
*/ */
int sthread_detach(sthread_t *thread) int sthread_detach(sthread_t *thread)
{ {
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
CloseHandle(thread->thread); CloseHandle(thread->thread);
free(thread); free(thread);
return 0; return 0;
@ -173,7 +176,7 @@ int sthread_detach(sthread_t *thread)
*/ */
void sthread_join(sthread_t *thread) void sthread_join(sthread_t *thread)
{ {
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
WaitForSingleObject(thread->thread, INFINITE); WaitForSingleObject(thread->thread, INFINITE);
CloseHandle(thread->thread); CloseHandle(thread->thread);
#else #else
@ -182,6 +185,26 @@ void sthread_join(sthread_t *thread)
free(thread); free(thread);
} }
/**
* sthread_isself:
* @thread : pointer to thread object
*
* Join with a terminated thread. Waits for the thread specified by
* @thread to terminate. If that thread has already terminated, then
* it will return immediately. The thread specified by @thread must
* be joinable.
*
* Returns: true (1) if calling thread is the specified thread
*/
bool sthread_isself(sthread_t *thread)
{
#ifdef USE_WIN32_THREADS
return GetCurrentThread() == thread->thread;
#else
return pthread_equal(pthread_self(),thread->id);
#endif
}
/** /**
* slock_new: * slock_new:
* *
@ -197,9 +220,9 @@ slock_t *slock_new(void)
if (!lock) if (!lock)
return NULL; return NULL;
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
lock->lock = CreateMutex(NULL, FALSE, NULL); lock->lock = CreateMutex(NULL, FALSE, NULL);
mutex_created = lock->lock; mutex_created = !!lock->lock;
#else #else
mutex_created = (pthread_mutex_init(&lock->lock, NULL) == 0); mutex_created = (pthread_mutex_init(&lock->lock, NULL) == 0);
#endif #endif
@ -225,7 +248,7 @@ void slock_free(slock_t *lock)
if (!lock) if (!lock)
return; return;
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
CloseHandle(lock->lock); CloseHandle(lock->lock);
#else #else
pthread_mutex_destroy(&lock->lock); pthread_mutex_destroy(&lock->lock);
@ -243,7 +266,7 @@ void slock_free(slock_t *lock)
**/ **/
void slock_lock(slock_t *lock) void slock_lock(slock_t *lock)
{ {
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
WaitForSingleObject(lock->lock, INFINITE); WaitForSingleObject(lock->lock, INFINITE);
#else #else
pthread_mutex_lock(&lock->lock); pthread_mutex_lock(&lock->lock);
@ -258,7 +281,7 @@ void slock_lock(slock_t *lock)
**/ **/
void slock_unlock(slock_t *lock) void slock_unlock(slock_t *lock)
{ {
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
ReleaseMutex(lock->lock); ReleaseMutex(lock->lock);
#else #else
pthread_mutex_unlock(&lock->lock); pthread_mutex_unlock(&lock->lock);
@ -282,9 +305,9 @@ scond_t *scond_new(void)
if (!cond) if (!cond)
return NULL; return NULL;
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
cond->event = CreateEvent(NULL, FALSE, FALSE, NULL); cond->event = CreateEvent(NULL, FALSE, FALSE, NULL);
event_created = cond->event; event_created = !!cond->event;
#else #else
event_created = (pthread_cond_init(&cond->cond, NULL) == 0); event_created = (pthread_cond_init(&cond->cond, NULL) == 0);
#endif #endif
@ -310,7 +333,7 @@ void scond_free(scond_t *cond)
if (!cond) if (!cond)
return; return;
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
CloseHandle(cond->event); CloseHandle(cond->event);
#else #else
pthread_cond_destroy(&cond->cond); pthread_cond_destroy(&cond->cond);
@ -327,7 +350,7 @@ void scond_free(scond_t *cond)
**/ **/
void scond_wait(scond_t *cond, slock_t *lock) void scond_wait(scond_t *cond, slock_t *lock)
{ {
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
WaitForSingleObject(cond->event, 0); WaitForSingleObject(cond->event, 0);
SignalObjectAndWait(lock->lock, cond->event, INFINITE, FALSE); SignalObjectAndWait(lock->lock, cond->event, INFINITE, FALSE);
@ -346,7 +369,7 @@ void scond_wait(scond_t *cond, slock_t *lock)
**/ **/
int scond_broadcast(scond_t *cond) int scond_broadcast(scond_t *cond)
{ {
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
/* FIXME _- check how this function should differ /* FIXME _- check how this function should differ
* from scond_signal implementation. */ * from scond_signal implementation. */
SetEvent(cond->event); SetEvent(cond->event);
@ -365,7 +388,7 @@ int scond_broadcast(scond_t *cond)
**/ **/
void scond_signal(scond_t *cond) void scond_signal(scond_t *cond)
{ {
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
SetEvent(cond->event); SetEvent(cond->event);
#else #else
pthread_cond_signal(&cond->cond); pthread_cond_signal(&cond->cond);
@ -386,7 +409,7 @@ void scond_signal(scond_t *cond)
**/ **/
bool scond_wait_timeout(scond_t *cond, slock_t *lock, int64_t timeout_us) bool scond_wait_timeout(scond_t *cond, slock_t *lock, int64_t timeout_us)
{ {
#ifdef _WIN32 #ifdef USE_WIN32_THREADS
DWORD ret; DWORD ret;
WaitForSingleObject(cond->event, 0); WaitForSingleObject(cond->event, 0);
@ -423,6 +446,8 @@ bool scond_wait_timeout(scond_t *cond, slock_t *lock, int64_t timeout_us)
gettimeofday(&tm, NULL); gettimeofday(&tm, NULL);
now.tv_sec = tm.tv_sec; now.tv_sec = tm.tv_sec;
now.tv_nsec = tm.tv_usec * 1000; now.tv_nsec = tm.tv_usec * 1000;
#elif defined(RETRO_WIN32_USE_PTHREADS)
_ftime64_s(&now);
#elif !defined(GEKKO) #elif !defined(GEKKO)
/* timeout on libogc is duration, not end time. */ /* timeout on libogc is duration, not end time. */
clock_gettime(CLOCK_REALTIME, &now); clock_gettime(CLOCK_REALTIME, &now);