This repository has been archived by the owner on Feb 11, 2021. It is now read-only.
/
SDL_syssem.c
230 lines (198 loc) · 4.71 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
31
32
33
34
35
36
37
38
#include "SDL_thread.h"
#include "SDL_timer.h"
#include <stdio.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/ipc.h>
#include <sys/sem.h>
#include <errno.h>
#include "SDL_error.h"
#include "SDL_thread.h"
39
40
41
struct SDL_semaphore
{
int id;
42
43
44
};
/* Not defined by many operating systems, use configure to detect */
45
/*
46
47
48
49
50
51
52
#if !defined(HAVE_SEMUN)
union semun {
int val;
struct semid_ds *buf;
ushort *array;
};
#endif
53
*/
54
55
static struct sembuf op_trywait[2] = {
56
{0, -1, (IPC_NOWAIT | SEM_UNDO)} /* Decrement semaphore, no block */
57
58
};
static struct sembuf op_wait[2] = {
59
{0, -1, SEM_UNDO} /* Decrement semaphore */
60
61
};
static struct sembuf op_post[1] = {
62
{0, 1, (IPC_NOWAIT | SEM_UNDO)} /* Increment semaphore */
63
64
65
};
/* Create a blockable semaphore */
66
67
SDL_sem *
SDL_CreateSemaphore (Uint32 initial_value)
68
{
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
extern int _creating_thread_lock; /* SDL_threads.c */
SDL_sem *sem;
union semun init;
sem = (SDL_sem *) SDL_malloc (sizeof (*sem));
if (sem == NULL) {
SDL_OutOfMemory ();
return (NULL);
}
sem->id = semget (IPC_PRIVATE, 1, (0600 | IPC_CREAT));
if (sem->id < 0) {
SDL_SetError ("Couldn't create semaphore");
SDL_free (sem);
return (NULL);
}
init.val = initial_value; /* Initialize semaphore */
semctl (sem->id, 0, SETVAL, init);
return (sem);
87
88
}
89
90
void
SDL_DestroySemaphore (SDL_sem * sem)
91
{
92
if (sem) {
93
#ifdef __IRIX__
94
semctl (sem->id, 0, IPC_RMID);
95
#else
96
97
98
union semun dummy;
dummy.val = 0;
semctl (sem->id, 0, IPC_RMID, dummy);
99
#endif
100
101
SDL_free (sem);
}
102
103
}
104
105
int
SDL_SemTryWait (SDL_sem * sem)
106
{
107
int retval;
108
109
110
111
112
if (!sem) {
SDL_SetError ("Passed a NULL semaphore");
return -1;
}
113
114
retval = 0;
115
tryagain:
116
117
118
119
120
121
122
if (semop (sem->id, op_trywait, 1) < 0) {
if (errno == EINTR) {
goto tryagain;
}
retval = SDL_MUTEX_TIMEDOUT;
}
return retval;
123
124
}
125
126
int
SDL_SemWait (SDL_sem * sem)
127
{
128
int retval;
129
130
131
132
133
if (!sem) {
SDL_SetError ("Passed a NULL semaphore");
return -1;
}
134
135
retval = 0;
136
tryagain:
137
138
139
140
141
142
143
144
if (semop (sem->id, op_wait, 1) < 0) {
if (errno == EINTR) {
goto tryagain;
}
SDL_SetError ("Semaphore operation error");
retval = -1;
}
return retval;
145
146
}
147
148
int
SDL_SemWaitTimeout (SDL_sem * sem, Uint32 timeout)
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
int retval;
if (!sem) {
SDL_SetError ("Passed a NULL semaphore");
return -1;
}
/* Try the easy cases first */
if (timeout == 0) {
return SDL_SemTryWait (sem);
}
if (timeout == SDL_MUTEX_MAXWAIT) {
return SDL_SemWait (sem);
}
/* Ack! We have to busy wait... */
timeout += SDL_GetTicks ();
do {
retval = SDL_SemTryWait (sem);
if (retval == 0) {
break;
}
SDL_Delay (1);
}
while (SDL_GetTicks () < timeout);
return retval;
177
178
}
179
180
Uint32
SDL_SemValue (SDL_sem * sem)
181
{
182
183
184
185
186
187
int semval;
Uint32 value;
value = 0;
if (sem) {
tryagain:
188
#ifdef __IRIX__
189
semval = semctl (sem->id, 0, GETVAL);
190
#else
191
192
193
194
195
{
union semun arg;
arg.val = 0;
semval = semctl (sem->id, 0, GETVAL, arg);
}
196
#endif
197
198
199
200
201
202
203
204
205
if (semval < 0) {
if (errno == EINTR) {
goto tryagain;
}
} else {
value = (Uint32) semval;
}
}
return value;
206
207
}
208
209
int
SDL_SemPost (SDL_sem * sem)
210
{
211
int retval;
212
213
214
215
216
if (!sem) {
SDL_SetError ("Passed a NULL semaphore");
return -1;
}
217
218
retval = 0;
219
tryagain:
220
221
222
223
224
225
226
227
if (semop (sem->id, op_post, 1) < 0) {
if (errno == EINTR) {
goto tryagain;
}
SDL_SetError ("Semaphore operation error");
retval = -1;
}
return retval;
228
}
229
230
/* vi: set ts=4 sw=4 expandtab: */