This repository has been archived by the owner on Feb 11, 2021. It is now read-only.
SDL_syssem.c
1
2
/*
SDL - Simple DirectMedia Layer
3
Copyright (C) 1997-2010 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.
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
/* Semaphore functions using the Win32 API */
26
27
#define WIN32_LEAN_AND_MEAN
#include <windows.h>
28
29
30
#include "SDL_thread.h"
#if defined(_WIN32_WCE) && (_WIN32_WCE < 300)
31
32
#include "win_ce_semaphore.h"
#endif
33
34
35
36
struct SDL_semaphore
{
37
#if defined(_WIN32_WCE) && (_WIN32_WCE < 300)
38
SYNCHHANDLE id;
42
LONG volatile count;
43
44
45
46
};
/* Create a semaphore */
47
48
SDL_sem *
SDL_CreateSemaphore(Uint32 initial_value)
50
SDL_sem *sem;
52
53
54
55
/* Allocate sem memory */
sem = (SDL_sem *) SDL_malloc(sizeof(*sem));
if (sem) {
/* Create the semaphore, with max value 32K */
56
#if defined(_WIN32_WCE) && (_WIN32_WCE < 300)
57
sem->id = CreateSemaphoreCE(NULL, initial_value, 32 * 1024, NULL);
59
sem->id = CreateSemaphore(NULL, initial_value, 32 * 1024, NULL);
61
62
63
64
65
66
67
68
69
70
sem->count = initial_value;
if (!sem->id) {
SDL_SetError("Couldn't create semaphore");
SDL_free(sem);
sem = NULL;
}
} else {
SDL_OutOfMemory();
}
return (sem);
71
72
73
}
/* Free the semaphore */
74
75
void
SDL_DestroySemaphore(SDL_sem * sem)
77
78
if (sem) {
if (sem->id) {
79
#if defined(_WIN32_WCE) && (_WIN32_WCE < 300)
80
CloseSynchHandle(sem->id);
82
CloseHandle(sem->id);
84
85
86
87
sem->id = 0;
}
SDL_free(sem);
}
88
89
}
90
91
int
SDL_SemWaitTimeout(SDL_sem * sem, Uint32 timeout)
93
94
95
96
97
98
99
100
101
102
103
104
105
int retval;
DWORD dwMilliseconds;
if (!sem) {
SDL_SetError("Passed a NULL sem");
return -1;
}
if (timeout == SDL_MUTEX_MAXWAIT) {
dwMilliseconds = INFINITE;
} else {
dwMilliseconds = (DWORD) timeout;
}
106
#if defined(_WIN32_WCE) && (_WIN32_WCE < 300)
107
switch (WaitForSemaphoreCE(sem->id, dwMilliseconds)) {
109
switch (WaitForSingleObject(sem->id, dwMilliseconds)) {
111
case WAIT_OBJECT_0:
112
InterlockedDecrement(&sem->count);
113
114
115
116
117
118
119
120
121
122
123
retval = 0;
break;
case WAIT_TIMEOUT:
retval = SDL_MUTEX_TIMEDOUT;
break;
default:
SDL_SetError("WaitForSingleObject() failed");
retval = -1;
break;
}
return retval;
124
125
}
126
127
int
SDL_SemTryWait(SDL_sem * sem)
128
{
129
return SDL_SemWaitTimeout(sem, 0);
130
131
}
132
133
int
SDL_SemWait(SDL_sem * sem)
134
{
135
return SDL_SemWaitTimeout(sem, SDL_MUTEX_MAXWAIT);
136
137
138
}
/* Returns the current count of the semaphore */
139
140
Uint32
SDL_SemValue(SDL_sem * sem)
141
{
142
143
144
145
if (!sem) {
SDL_SetError("Passed a NULL sem");
return 0;
}
146
return (Uint32)sem->count;
147
148
}
149
150
int
SDL_SemPost(SDL_sem * sem)
151
{
152
153
154
155
156
157
158
159
160
if (!sem) {
SDL_SetError("Passed a NULL sem");
return -1;
}
/* Increase the counter in the first place, because
* after a successful release the semaphore may
* immediately get destroyed by another thread which
* is waiting for this semaphore.
*/
161
InterlockedIncrement(&sem->count);
162
#if defined(_WIN32_WCE) && (_WIN32_WCE < 300)
163
if (ReleaseSemaphoreCE(sem->id, 1, NULL) == FALSE) {
165
if (ReleaseSemaphore(sem->id, 1, NULL) == FALSE) {
167
InterlockedDecrement(&sem->count); /* restore */
168
169
170
171
SDL_SetError("ReleaseSemaphore() failed");
return -1;
}
return 0;
172
}
173
174
/* vi: set ts=4 sw=4 expandtab: */