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
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
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
177
178
179
180
181
|
/* pthread_hurd_cond_timedwait_np. Hurd-specific wait on a condition.
Copyright (C) 2012-2020 Free Software Foundation, Inc.
This file is part of the GNU C Library.
The GNU C Library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or (at your option) any later version.
The GNU C 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
Lesser General Public License for more details.
You should have received a copy of the GNU Lesser General Public
License along with the GNU C Library; if not, see
<https://www.gnu.org/licenses/>. */
#include <pthread.h>
#include <assert.h>
#include <hurd/signal.h>
#include <time.h>
#include <pt-internal.h>
extern int __pthread_hurd_cond_timedwait_internal (pthread_cond_t *cond,
pthread_mutex_t *mutex,
const struct timespec
*abstime);
int
__pthread_hurd_cond_timedwait_np (pthread_cond_t *cond,
pthread_mutex_t *mutex,
const struct timespec *abstime)
{
return __pthread_hurd_cond_timedwait_internal (cond, mutex, abstime);
}
strong_alias (__pthread_hurd_cond_timedwait_np, pthread_hurd_cond_timedwait_np);
int
__pthread_hurd_cond_timedwait_internal (pthread_cond_t *cond,
pthread_mutex_t *mutex,
const struct timespec *abstime)
{
struct hurd_sigstate *ss = _hurd_self_sigstate ();
struct __pthread *self = _pthread_self ();
error_t err = 0;
int cancel, drain;
clockid_t clock_id = __pthread_default_condattr.__clock;
/* This function will be called by hurd_thread_cancel while we are blocked
We wake up our thread if it's still blocking or about to block, so it will
progress and notice the cancellation flag. */
void cancel_me (void)
{
int unblock;
__pthread_spin_wait (&cond->__lock);
/* The thread only needs to be awaken if it's blocking or about to block.
If it was already unblocked, it's not queued any more. */
unblock = self->prevp != NULL;
if (unblock)
__pthread_dequeue (self);
__pthread_spin_unlock (&cond->__lock);
if (unblock)
__pthread_wakeup (self);
}
assert (ss->intr_port == MACH_PORT_NULL); /* Sanity check for signal bugs. */
if (abstime != NULL && ! valid_nanoseconds (abstime->tv_nsec))
return EINVAL;
/* Atomically enqueue our thread on the condition variable's queue of
waiters, and mark our sigstate to indicate that `cancel_me' must be
called to wake us up. We must hold the sigstate lock while acquiring
the condition variable's lock and tweaking it, so that
hurd_thread_cancel can never suspend us and then deadlock waiting for
the condition variable's lock. */
__spin_lock (&ss->lock);
__pthread_spin_wait (&cond->__lock);
cancel = ss->cancel;
if (cancel)
/* We were cancelled before doing anything. Don't block at all. */
ss->cancel = 0;
else
{
/* Put us on the queue so that pthread_cond_broadcast will know to wake
us up. */
__pthread_enqueue (&cond->__queue, self);
if (cond->__attr)
clock_id = cond->__attr->__clock;
/* Tell hurd_thread_cancel how to unblock us. */
ss->cancel_hook = &cancel_me;
}
__pthread_spin_unlock (&cond->__lock);
__spin_unlock (&ss->lock);
if (cancel)
{
/* Cancelled on entry. Just leave the mutex locked. */
mutex = NULL;
__spin_lock (&ss->lock);
}
else
{
/* Release MUTEX before blocking. */
__pthread_mutex_unlock (mutex);
/* Increase the waiter reference count. Relaxed MO is sufficient because
we only need to synchronize when decrementing the reference count. */
atomic_fetch_add_relaxed (&cond->__wrefs, 2);
/* Block the thread. */
if (abstime != NULL)
err = __pthread_timedblock (self, abstime, clock_id);
else
{
err = 0;
__pthread_block (self);
}
/* As it was done when enqueueing, prevent hurd_thread_cancel from
suspending us while the condition lock is held. */
__spin_lock (&ss->lock);
__pthread_spin_wait (&cond->__lock);
if (self->prevp == NULL)
/* Another thread removed us from the list of waiters, which means
a wakeup message has been sent. It was either consumed while
we were blocking, or queued after we timed out and before we
acquired the condition lock, in which case the message queue
must be drained. */
drain = err ? 1 : 0;
else
{
/* We're still in the list of waiters. Noone attempted to wake us
up, i.e. we timed out. */
__pthread_dequeue (self);
drain = 0;
}
__pthread_spin_unlock (&cond->__lock);
if (drain)
__pthread_block (self);
}
/* If destruction is pending (i.e., the wake-request flag is nonzero) and we
are the last waiter (prior value of __wrefs was 1 << 1), then wake any
threads waiting in pthread_cond_destroy. Release MO to synchronize with
these threads. Don't bother clearing the wake-up request flag. */
if ((atomic_fetch_add_release (&cond->__wrefs, -2)) == 3)
__gsync_wake (__mach_task_self (), (vm_offset_t) &cond->__wrefs, 0, 0);
/* Clear the hook, now that we are done blocking. */
ss->cancel_hook = NULL;
/* Check the cancellation flag; we might have unblocked due to
cancellation rather than a normal pthread_cond_signal or
pthread_cond_broadcast (or we might have just happened to get cancelled
right after waking up). */
cancel |= ss->cancel;
ss->cancel = 0;
__spin_unlock (&ss->lock);
if (mutex != NULL)
/* Reacquire the mutex and return. */
__pthread_mutex_lock (mutex);
if (cancel)
return EINTR;
else if (err)
{
assert (err == ETIMEDOUT);
return err;
}
return 0;
}
|
