This repository has been archived by the owner on Feb 11, 2021. It is now read-only.
/
SDL_syssem.c
224 lines (186 loc) · 4.59 KB
1
2
/*
SDL - Simple DirectMedia Layer
3
Copyright (C) 1997-2006 Sam Lantinga
4
5
This library is free software; you can redistribute it and/or
6
modify it under the terms of the GNU Lesser General Public
7
License as published by the Free Software Foundation; either
8
version 2.1 of the License, or (at your option) any later version.
9
10
11
12
This library 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
13
Lesser General Public License for more details.
14
15
16
17
You should have received a copy of the GNU Lesser General Public
License along with this library; if not, write to the Free Software
Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
18
19
Sam Lantinga
20
slouken@libsdl.org
21
*/
22
#include "SDL_config.h"
23
24
25
26
27
28
29
30
/* An implementation of semaphores using mutexes and condition variables */
#include "SDL_timer.h"
#include "SDL_thread.h"
#include "SDL_systhread_c.h"
31
#if SDL_THREADS_DISABLED
32
33
34
SDL_sem *
SDL_CreateSemaphore (Uint32 initial_value)
35
{
36
37
SDL_SetError ("SDL not configured with thread support");
return (SDL_sem *) 0;
38
39
}
40
41
void
SDL_DestroySemaphore (SDL_sem * sem)
42
{
43
return;
44
45
}
46
47
int
SDL_SemTryWait (SDL_sem * sem)
48
{
49
50
SDL_SetError ("SDL not configured with thread support");
return -1;
51
52
}
53
54
int
SDL_SemWaitTimeout (SDL_sem * sem, Uint32 timeout)
55
{
56
57
SDL_SetError ("SDL not configured with thread support");
return -1;
58
59
}
60
61
int
SDL_SemWait (SDL_sem * sem)
62
{
63
64
SDL_SetError ("SDL not configured with thread support");
return -1;
65
66
}
67
68
Uint32
SDL_SemValue (SDL_sem * sem)
69
{
70
return 0;
71
72
}
73
74
int
SDL_SemPost (SDL_sem * sem)
75
{
76
77
SDL_SetError ("SDL not configured with thread support");
return -1;
78
79
80
81
82
83
}
#else
struct SDL_semaphore
{
84
85
86
87
Uint32 count;
Uint32 waiters_count;
SDL_mutex *count_lock;
SDL_cond *count_nonzero;
88
89
};
90
91
SDL_sem *
SDL_CreateSemaphore (Uint32 initial_value)
92
{
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
SDL_sem *sem;
sem = (SDL_sem *) SDL_malloc (sizeof (*sem));
if (!sem) {
SDL_OutOfMemory ();
return NULL;
}
sem->count = initial_value;
sem->waiters_count = 0;
sem->count_lock = SDL_CreateMutex ();
sem->count_nonzero = SDL_CreateCond ();
if (!sem->count_lock || !sem->count_nonzero) {
SDL_DestroySemaphore (sem);
return NULL;
}
return sem;
111
112
113
114
115
}
/* WARNING:
You cannot call this function when another thread is using the semaphore.
*/
116
117
void
SDL_DestroySemaphore (SDL_sem * sem)
118
{
119
120
121
122
123
124
125
126
127
128
129
130
131
132
if (sem) {
sem->count = 0xFFFFFFFF;
while (sem->waiters_count > 0) {
SDL_CondSignal (sem->count_nonzero);
SDL_Delay (10);
}
SDL_DestroyCond (sem->count_nonzero);
if (sem->count_lock) {
SDL_mutexP (sem->count_lock);
SDL_mutexV (sem->count_lock);
SDL_DestroyMutex (sem->count_lock);
}
SDL_free (sem);
}
133
134
}
135
136
int
SDL_SemTryWait (SDL_sem * sem)
137
{
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
int retval;
if (!sem) {
SDL_SetError ("Passed a NULL semaphore");
return -1;
}
retval = SDL_MUTEX_TIMEDOUT;
SDL_LockMutex (sem->count_lock);
if (sem->count > 0) {
--sem->count;
retval = 0;
}
SDL_UnlockMutex (sem->count_lock);
return retval;
154
155
}
156
157
int
SDL_SemWaitTimeout (SDL_sem * sem, Uint32 timeout)
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
int retval;
if (!sem) {
SDL_SetError ("Passed a NULL semaphore");
return -1;
}
/* A timeout of 0 is an easy case */
if (timeout == 0) {
return SDL_SemTryWait (sem);
}
SDL_LockMutex (sem->count_lock);
++sem->waiters_count;
retval = 0;
while ((sem->count == 0) && (retval != SDL_MUTEX_TIMEDOUT)) {
retval = SDL_CondWaitTimeout (sem->count_nonzero,
sem->count_lock, timeout);
}
--sem->waiters_count;
--sem->count;
SDL_UnlockMutex (sem->count_lock);
return retval;
183
184
}
185
186
int
SDL_SemWait (SDL_sem * sem)
187
{
188
return SDL_SemWaitTimeout (sem, SDL_MUTEX_MAXWAIT);
189
190
}
191
192
Uint32
SDL_SemValue (SDL_sem * sem)
193
{
194
195
196
197
198
199
200
201
202
Uint32 value;
value = 0;
if (sem) {
SDL_LockMutex (sem->count_lock);
value = sem->count;
SDL_UnlockMutex (sem->count_lock);
}
return value;
203
204
}
205
206
int
SDL_SemPost (SDL_sem * sem)
207
{
208
209
210
211
212
213
214
215
216
217
218
219
220
if (!sem) {
SDL_SetError ("Passed a NULL semaphore");
return -1;
}
SDL_LockMutex (sem->count_lock);
if (sem->waiters_count > 0) {
SDL_CondSignal (sem->count_nonzero);
}
++sem->count;
SDL_UnlockMutex (sem->count_lock);
return 0;
221
222
}
223
#endif /* SDL_THREADS_DISABLED */
224
/* vi: set ts=4 sw=4 expandtab: */