SDL_syssem.c
1
2
/*
SDL - Simple DirectMedia Layer
3
Copyright (C) 1997, 1998, 1999, 2000, 2001, 2002 Sam Lantinga
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Library General Public
License as published by the Free Software Foundation; either
version 2 of the License, or (at your option) any later version.
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
Library General Public License for more details.
You should have received a copy of the GNU Library General Public
License along with this library; if not, write to the Free
Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
Sam Lantinga
20
slouken@libsdl.org
21
22
23
24
25
26
27
*/
#ifdef SAVE_RCSID
static char rcsid =
"@(#) $Id$";
#endif
28
/* An implementation of semaphores using mutexes and condition variables */
29
30
31
32
33
34
35
36
37
#include "SDL_error.h"
#include "SDL_thread.h"
#include "SDL_systhread_c.h"
struct SDL_semaphore
{
struct SignalSemaphore Sem;
38
39
40
41
Uint32 count;
Uint32 waiters_count;
SDL_mutex *count_lock;
SDL_cond *count_nonzero;
42
43
};
45
46
47
48
49
50
51
52
#define D(x)
SDL_sem *SDL_CreateSemaphore(Uint32 initial_value)
{
SDL_sem *sem;
sem = (SDL_sem *)malloc(sizeof(*sem));
54
55
56
57
58
59
60
if ( ! sem ) {
SDL_OutOfMemory();
return(0);
}
D(bug("Creating semaphore %lx...\n",sem));
61
62
memset(sem,0,sizeof(*sem));
63
InitSemaphore(&sem->Sem);
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
return(sem);
}
void SDL_DestroySemaphore(SDL_sem *sem)
{
D(bug("Destroying semaphore %lx...\n",sem));
if ( sem ) {
// Condizioni per liberare i task in attesa?
free(sem);
}
}
int SDL_SemTryWait(SDL_sem *sem)
{
if ( ! sem ) {
SDL_SetError("Passed a NULL semaphore");
return -1;
}
D(bug("TryWait semaphore...%lx\n",sem));
87
88
89
90
ObtainSemaphore(&sem->Sem);
// ReleaseSemaphore(&sem->Sem);
return 1;
91
92
93
94
95
96
}
int SDL_SemWaitTimeout(SDL_sem *sem, Uint32 timeout)
{
int retval;
98
99
100
101
102
103
104
if ( ! sem ) {
SDL_SetError("Passed a NULL semaphore");
return -1;
}
D(bug("WaitTimeout (%ld) semaphore...%lx\n",timeout,sem));
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
/* 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);
*/
121
122
123
124
125
126
127
128
129
130
131
if(!(retval=AttemptSemaphore(&sem->Sem)))
{
SDL_Delay(timeout);
retval=AttemptSemaphore(&sem->Sem);
}
if(retval==TRUE)
{
// ReleaseSemaphore(&sem->Sem);
retval=1;
}
133
134
135
136
137
138
return retval;
}
int SDL_SemWait(SDL_sem *sem)
{
ObtainSemaphore(&sem->Sem);
139
140
return 0;
// return SDL_SemWaitTimeout(sem, SDL_MUTEX_MAXWAIT);
141
142
143
144
145
}
Uint32 SDL_SemValue(SDL_sem *sem)
{
Uint32 value;
147
148
value = 0;
if ( sem ) {
149
150
151
#ifdef STORMC4_WOS
value = sem->Sem.ssppc_SS.ss_NestCount;
#else
152
value = sem->Sem.ss_NestCount;
153
#endif
154
// SDL_UnlockMutex(sem->count_lock);
155
156
157
158
159
160
161
162
163
164
165
166
167
}
return value;
}
int SDL_SemPost(SDL_sem *sem)
{
if ( ! sem ) {
SDL_SetError("Passed a NULL semaphore");
return -1;
}
D(bug("SemPost semaphore...%lx\n",sem));
ReleaseSemaphore(&sem->Sem);
168
169
170
171
172
173
174
175
#if 0
SDL_LockMutex(sem->count_lock);
if ( sem->waiters_count > 0 ) {
SDL_CondSignal(sem->count_nonzero);
}
++sem->count;
SDL_UnlockMutex(sem->count_lock);
#endif
176
177
return 0;
}