1 | #include <aio.h> |
2 | #include <errno.h> |
3 | #include <signal.h> |
4 | #include <stdio.h> |
5 | #include <stdlib.h> |
6 | #include <pthread.h> |
7 | #include <unistd.h> |
8 | |
9 | static pthread_barrier_t b; |
10 | static pthread_t main_thread; |
11 | static int flag; |
12 | |
13 | |
14 | static void * |
15 | tf (void *arg) |
16 | { |
17 | int e = pthread_barrier_wait (barrier: &b); |
18 | if (e != 0 && e != PTHREAD_BARRIER_SERIAL_THREAD) |
19 | { |
20 | puts (s: "child: barrier_wait failed" ); |
21 | exit (1); |
22 | } |
23 | |
24 | /* There is unfortunately no other way to try to make sure the other |
25 | thread reached the aio_suspend call. This test could fail on |
26 | highly loaded machines. */ |
27 | sleep (seconds: 2); |
28 | |
29 | pthread_kill (threadid: main_thread, SIGUSR1); |
30 | |
31 | while (1) |
32 | sleep (seconds: 1000); |
33 | |
34 | return NULL; |
35 | } |
36 | |
37 | |
38 | static void |
39 | sh (int sig) |
40 | { |
41 | flag = 1; |
42 | } |
43 | |
44 | |
45 | static int |
46 | do_test (void) |
47 | { |
48 | main_thread = pthread_self (); |
49 | |
50 | struct sigaction sa; |
51 | |
52 | sa.sa_handler = sh; |
53 | sa.sa_flags = 0; |
54 | sigemptyset (&sa.sa_mask); |
55 | |
56 | if (sigaction (SIGUSR1, act: &sa, NULL) != 0) |
57 | { |
58 | puts (s: "sigaction failed" ); |
59 | return 1; |
60 | } |
61 | |
62 | if (pthread_barrier_init (barrier: &b, NULL, count: 2) != 0) |
63 | { |
64 | puts (s: "barrier_init" ); |
65 | return 1; |
66 | } |
67 | |
68 | int fds[2]; |
69 | if (pipe (pipedes: fds) != 0) |
70 | { |
71 | puts (s: "pipe failed" ); |
72 | return 1; |
73 | } |
74 | |
75 | char buf[42]; |
76 | struct aiocb req; |
77 | req.aio_fildes = fds[0]; |
78 | req.aio_reqprio = 0; |
79 | req.aio_offset = 0; |
80 | req.aio_buf = buf; |
81 | req.aio_nbytes = sizeof (buf); |
82 | req.aio_sigevent.sigev_notify = SIGEV_NONE; |
83 | |
84 | if (aio_read (aiocbp: &req) != 0) |
85 | { |
86 | puts (s: "aio_read failed" ); |
87 | return 1; |
88 | } |
89 | |
90 | pthread_t th; |
91 | if (pthread_create (newthread: &th, NULL, start_routine: tf, NULL) != 0) |
92 | { |
93 | puts (s: "create failed" ); |
94 | return 1; |
95 | } |
96 | |
97 | int e = pthread_barrier_wait (barrier: &b); |
98 | if (e != 0 && e != PTHREAD_BARRIER_SERIAL_THREAD) |
99 | { |
100 | puts (s: "parent: barrier_wait failed" ); |
101 | exit (1); |
102 | } |
103 | |
104 | const struct aiocb *list[1]; |
105 | list[0] = &req; |
106 | |
107 | e = aio_suspend (list: list, nent: 1, NULL); |
108 | if (e != -1) |
109 | { |
110 | puts (s: "aio_suspend succeeded" ); |
111 | return 1; |
112 | } |
113 | if (errno != EINTR) |
114 | { |
115 | puts (s: "aio_suspend did not return EINTR" ); |
116 | return 1; |
117 | } |
118 | |
119 | return 0; |
120 | } |
121 | |
122 | #define TEST_FUNCTION do_test () |
123 | #include "../test-skeleton.c" |
124 | |