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
|
/* Copyright (C) 2006-2021 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/>. */
/* We define a special synchronization primitive for AIO. POSIX
conditional variables would be ideal but the pthread_cond_*wait
operations do not return on EINTR. This is a requirement for
correct aio_suspend and lio_listio implementations. */
#include <assert.h>
#include <pthreadP.h>
#include <futex-internal.h>
#define DONT_NEED_AIO_MISC_COND 1
#define AIO_MISC_NOTIFY(waitlist) \
do { \
if (*waitlist->counterp > 0 && --*waitlist->counterp == 0) \
futex_wake ((unsigned int *) waitlist->counterp, 1, FUTEX_PRIVATE); \
} while (0)
#define AIO_MISC_WAIT(result, futex, timeout, cancel) \
do { \
volatile unsigned int *futexaddr = &futex; \
unsigned int oldval = futex; \
\
if (oldval != 0) \
{ \
__pthread_mutex_unlock (&__aio_requests_mutex); \
\
int status; \
do \
{ \
if (cancel) \
status = __futex_abstimed_wait_cancelable64 ( \
(unsigned int *) futexaddr, oldval, CLOCK_MONOTONIC, timeout, \
FUTEX_PRIVATE); \
else \
status = __futex_abstimed_wait64 ((unsigned int *) futexaddr, \
oldval, CLOCK_REALTIME, timeout, FUTEX_PRIVATE); \
if (status != EAGAIN) \
break; \
\
oldval = *futexaddr; \
} \
while (oldval != 0); \
\
if (status == EINTR) \
result = EINTR; \
else if (status == ETIMEDOUT) \
result = EAGAIN; \
else if (status == EOVERFLOW) \
result = EOVERFLOW; \
else \
assert (status == 0 || status == EAGAIN); \
\
__pthread_mutex_lock (&__aio_requests_mutex); \
} \
} while (0)
#include_next <aio_misc.h>
|
