1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
|
///////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////
#ifndef __GSPLATFORMTHREAD_H__
#define __GSPLATFORMTHREAD_H__
#include "gsPlatform.h"
#ifdef __cplusplus
extern "C" {
#endif
///////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////
// Thread types
#if defined(_WIN32)
typedef CRITICAL_SECTION GSICriticalSection;
typedef HANDLE GSISemaphoreID;
typedef HANDLE GSIThreadID;
typedef DWORD (WINAPI *GSThreadFunc)(void *arg);
#elif defined(_PS2)
typedef int GSIThreadID;
typedef int GSISemaphoreID;
typedef struct
{
// A critical section is a re-entrant semaphore
GSISemaphoreID mSemaphore;
GSIThreadID mOwnerThread;
gsi_u32 mEntryCount; // track re-entry
gsi_u32 mPad; // make 16bytes
} GSICriticalSection;
typedef void (*GSThreadFunc)(void *arg);
#elif defined(_NITRO)
typedef OSMutex GSICriticalSection;
typedef struct
{
OSMutex mLock;
gsi_i32 mValue;
gsi_i32 mMax;
} GSISemaphoreID;
typedef struct
{
OSThread mThread;
void * mStack;
} GSIThreadID;
typedef void (*GSThreadFunc)(void *arg);
#elif defined(_REVOLUTION)
typedef OSMutex GSICriticalSection;
typedef OSSemaphore GSISemaphoreID;
typedef struct
{
OSThread mThread;
void * mStack;
} GSIThreadID;
typedef void *(*GSThreadFunc)(void *arg);
#elif defined(_PSP)
// Todo: Test PSP thread code, then remove this define
#define GSI_NO_THREADS
typedef int GSIThreadID;
typedef int GSISemaphoreID;
typedef struct
{
// A critical section is a re-entrant semaphore
GSISemaphoreID mSemaphore;
GSIThreadID mOwnerThread;
gsi_u32 mEntryCount; // track re-entry
gsi_u32 mPad; // make 16bytes
} GSICriticalSection;
typedef void (*GSThreadFunc)(void *arg);
#elif defined(_PS3)
// Todo: Test PS3 ppu thread code, then remove this define
#define GSI_NO_THREADS
typedef int GSIThreadID;
typedef int GSISemaphoreID;
typedef struct
{
// A critical section is a re-entrant semaphore
GSISemaphoreID mSemaphore;
GSIThreadID mOwnerThread;
gsi_u32 mEntryCount; // track re-entry
gsi_u32 mPad; // make 16bytes
} GSICriticalSection;
typedef void (*GSThreadFunc)(void *arg);
#elif defined(_UNIX) // Linux, Mac OS X, openbsd, etc.
#if defined(__OpenBSD__)
#include <pthread.h>
#endif
typedef pthread_mutex_t GSICriticalSection;
typedef struct
{
pthread_mutex_t mLock;
gsi_i32 mValue;
gsi_i32 mMax;
} GSISemaphoreID;
typedef struct
{
pthread_t thread;
pthread_attr_t attr;
} GSIThreadID;
typedef void (*GSThreadFunc)(void *arg);
#else
#define GSI_NO_THREADS
#endif
#if defined(WIN32)
#define GSI_INFINITE INFINITE
#else
#define GSI_INFINITE (gsi_u32)(-1)
#endif
#if !defined(GSI_NO_THREADS)
// The increment/read operations must not be preempted
#if defined(_WIN32)
#define gsiInterlockedIncrement(a) InterlockedIncrement((long*)a)
#define gsiInterlockedDecrement(a) InterlockedDecrement((long*)a)
#elif defined(_PS2)
gsi_u32 gsiInterlockedIncrement(gsi_u32* num);
gsi_u32 gsiInterlockedDecrement(gsi_u32* num);
#elif defined(_PS3)
// TODO - threading in PS3 uses pthreads, just like Linux
#elif defined(_NITRO)
gsi_u32 gsiInterlockedIncrement(gsi_u32* num);
gsi_u32 gsiInterlockedDecrement(gsi_u32* num);
#elif defined(_REVOLUTION)
gsi_u32 gsiInterlockedIncrement(gsi_u32* num);
gsi_u32 gsiInterlockedDecrement(gsi_u32* num);
#elif defined(_UNIX)
gsi_u32 gsiInterlockedIncrement(gsi_u32* num);
gsi_u32 gsiInterlockedDecrement(gsi_u32* num);
#endif
#else
// Don't worry about concurrancy when GSI_NO_THREADS is defined
#define gsiInterlockedIncrement(a) (++(*a))
#define gsiInterlockedDecrement(a) (--(*a))
#endif
///////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////
#if !defined(GSI_NO_THREADS)
int gsiStartThread(GSThreadFunc aThreadFunc, gsi_u32 theStackSize, void *arg, GSIThreadID* theThreadIdOut);
void gsiCancelThread(GSIThreadID theThreadID);
void gsiExitThread(GSIThreadID theThreadID);
void gsiCleanupThread(GSIThreadID theThreadID);
// Thread Synchronization - Startup/Shutdown
gsi_u32 gsiHasThreadShutdown(GSIThreadID theThreadID);
// Thread Synchronization - Critical Section
void gsiInitializeCriticalSection(GSICriticalSection *theCrit);
void gsiEnterCriticalSection(GSICriticalSection *theCrit);
void gsiLeaveCriticalSection(GSICriticalSection *theCrit);
void gsiDeleteCriticalSection(GSICriticalSection *theCrit);
// Thread Synchronization - Semaphore
GSISemaphoreID gsiCreateSemaphore(gsi_i32 theInitialCount, gsi_i32 theMaxCount, char* theName);
gsi_u32 gsiWaitForSemaphore(GSISemaphoreID theSemaphore, gsi_u32 theTimeoutMs);
void gsiReleaseSemaphore(GSISemaphoreID theSemaphore, gsi_i32 theReleaseCount);
void gsiCloseSemaphore(GSISemaphoreID theSemaphore);
#else
// NO THREADS - stub everything to unused
#define gsiStartThread(a, b, c, d) (-1) // must return something
#define gsiCancelThread(a)
#define gsiExitThread(a)
#define gsiCleanupThread(a)
#define gsiHasThreadShutdown(a) (1) // must return something
#define gsiInitializeCriticalSection(a)
#define gsiEnterCriticalSection(a)
#define gsiLeaveCriticalSection(a)
#define gsiDeleteCriticalSection(a)
#define gsiCreateSemaphore(a,b,c) (-1)
#define gsiWaitForSemaphore(a,b) (0)
#define gsiReleaseSemaphore(a,b)
#define gsiCloseSemaphore(a)
#endif // GSI_NO_THREADS
///////////////////////////////////////////////////////////////////////////////
///////////////////////////////////////////////////////////////////////////////
#ifdef __cplusplus
}
#endif
#endif // __GSPLATFORMTHREAD_H__
|
