blob: 8db49e840579902577dc3d0f7fdda8ca0852c468 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
|
#include <unistd.h>
#include <errno.h>
#include <pthread.h>
#include "thread_internal.h"
int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex)
{
_pthread_descr tmp;
_pthread_descr this;
__THREAD_INIT();
this=__thread_self();
/* put in wait-chain */
__NO_ASYNC_CANCEL_BEGIN;
__pthread_lock(&(cond->lock));
this->waiting=1;
if (cond->wait_chain) {
for(tmp=cond->wait_chain;tmp->waitnext;tmp=tmp->waitnext);
tmp->waitnext=this;
} else cond->wait_chain=this;
__pthread_unlock(&(cond->lock));
__NO_ASYNC_CANCEL_STOP;
/* Aeh yeah / wait till signal */
pthread_mutex_unlock(mutex);
while (this->waiting) {
__thread_wait_some_time();
if (this->canceled) break; /* we got a cancel signal */
}
pthread_mutex_lock(mutex);
__NO_ASYNC_CANCEL_BEGIN;
__pthread_lock(&(cond->lock));
if (this->waiting) { /* still waiting -> SIGNAL */
_pthread_descr prev;
/* remove from wait-chain */
prev=cond->wait_chain;
if ((prev=cond->wait_chain)==this) {
cond->wait_chain=this->waitnext;
} else {
for (tmp=prev->waitnext;tmp;prev=tmp,tmp=prev->waitnext) {
if (tmp==this) {
prev->waitnext=this->waitnext;
break;
}
}
}
this->waiting=0;
this->waitnext=0;
}
__pthread_unlock(&(cond->lock));
__NO_ASYNC_CANCEL_END;
return 0;
}
|
