This repository has been archived by the owner on Feb 11, 2021. It is now read-only.
SDL_syscond.c
1
2
/*
SDL - Simple DirectMedia Layer
3
Copyright (C) 1997-2011 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
26
27
28
29
30
31
32
33
#include <sys/time.h>
#include <unistd.h>
#include <errno.h>
#include <pthread.h>
#include "SDL_thread.h"
#include "SDL_sysmutex_c.h"
struct SDL_cond
{
34
pthread_cond_t cond;
35
36
37
};
/* Create a condition variable */
38
39
SDL_cond *
SDL_CreateCond(void)
41
42
43
44
45
46
47
48
49
50
51
SDL_cond *cond;
cond = (SDL_cond *) SDL_malloc(sizeof(SDL_cond));
if (cond) {
if (pthread_cond_init(&cond->cond, NULL) < 0) {
SDL_SetError("pthread_cond_init() failed");
SDL_free(cond);
cond = NULL;
}
}
return (cond);
52
53
54
}
/* Destroy a condition variable */
55
56
void
SDL_DestroyCond(SDL_cond * cond)
58
59
60
61
if (cond) {
pthread_cond_destroy(&cond->cond);
SDL_free(cond);
}
62
63
64
}
/* Restart one of the threads that are waiting on the condition variable */
65
66
int
SDL_CondSignal(SDL_cond * cond)
68
69
70
71
72
73
74
75
76
77
78
79
80
int retval;
if (!cond) {
SDL_SetError("Passed a NULL condition variable");
return -1;
}
retval = 0;
if (pthread_cond_signal(&cond->cond) != 0) {
SDL_SetError("pthread_cond_signal() failed");
retval = -1;
}
return retval;
81
82
83
}
/* Restart all threads that are waiting on the condition variable */
84
85
int
SDL_CondBroadcast(SDL_cond * cond)
87
88
89
90
91
92
93
94
95
96
97
98
99
int retval;
if (!cond) {
SDL_SetError("Passed a NULL condition variable");
return -1;
}
retval = 0;
if (pthread_cond_broadcast(&cond->cond) != 0) {
SDL_SetError("pthread_cond_broadcast() failed");
retval = -1;
}
return retval;
100
101
}
102
103
int
SDL_CondWaitTimeout(SDL_cond * cond, SDL_mutex * mutex, Uint32 ms)
104
{
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
int retval;
struct timeval delta;
struct timespec abstime;
if (!cond) {
SDL_SetError("Passed a NULL condition variable");
return -1;
}
gettimeofday(&delta, NULL);
abstime.tv_sec = delta.tv_sec + (ms / 1000);
abstime.tv_nsec = (delta.tv_usec + (ms % 1000) * 1000) * 1000;
if (abstime.tv_nsec > 1000000000) {
abstime.tv_sec += 1;
abstime.tv_nsec -= 1000000000;
}
122
123
tryagain:
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
retval = pthread_cond_timedwait(&cond->cond, &mutex->id, &abstime);
switch (retval) {
case EINTR:
goto tryagain;
break;
case ETIMEDOUT:
retval = SDL_MUTEX_TIMEDOUT;
break;
case 0:
break;
default:
SDL_SetError("pthread_cond_timedwait() failed");
retval = -1;
break;
}
return retval;
140
141
142
143
144
}
/* Wait on the condition variable, unlocking the provided mutex.
The mutex must be locked before entering this function!
*/
145
146
int
SDL_CondWait(SDL_cond * cond, SDL_mutex * mutex)
147
{
148
149
150
151
152
153
154
155
156
157
158
159
160
int retval;
if (!cond) {
SDL_SetError("Passed a NULL condition variable");
return -1;
}
retval = 0;
if (pthread_cond_wait(&cond->cond, &mutex->id) != 0) {
SDL_SetError("pthread_cond_wait() failed");
retval = -1;
}
return retval;
161
}
162
163
/* vi: set ts=4 sw=4 expandtab: */