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
|
#include "../config-host.h"
// SPDX-License-Identifier: MIT
/*
* Description: tests bug fixed in
* "io_uring: don't gate task_work run on TIF_NOTIFY_SIGNAL"
*
* See: https://github.com/axboe/liburing/issues/665
*/
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include "helpers.h"
#include "liburing.h"
#define CHECK(x) \
do { \
if (!(x)) { \
fprintf(stderr, "%s:%d %s failed\n", __FILE__, __LINE__, #x); \
return -1; \
} \
} while (0)
static int pipe_bug(void)
{
struct io_uring_params p;
struct io_uring ring;
struct io_uring_sqe *sqe;
struct io_uring_cqe *cqe;
char buf[1024];
int fds[2];
struct __kernel_timespec to = {
.tv_sec = 1
};
CHECK(pipe(fds) == 0);
memset(&p, 0, sizeof(p));
CHECK(t_create_ring_params(8, &ring, &p) == 0);
/* WRITE */
sqe = io_uring_get_sqe(&ring);
CHECK(sqe);
io_uring_prep_write(sqe, fds[1], "foobar", strlen("foobar"), 0); /* or -1 */
CHECK(io_uring_submit(&ring) == 1);
CHECK(io_uring_wait_cqe(&ring, &cqe) == 0);
io_uring_cqe_seen(&ring, cqe);
/* CLOSE */
sqe = io_uring_get_sqe(&ring);
CHECK(sqe);
io_uring_prep_close(sqe, fds[1]);
CHECK(io_uring_submit(&ring) == 1);
CHECK(io_uring_wait_cqe_timeout(&ring, &cqe, &to) == 0);
io_uring_cqe_seen(&ring, cqe);
/* READ */
sqe = io_uring_get_sqe(&ring);
CHECK(sqe);
io_uring_prep_read(sqe, fds[0], buf, sizeof(buf), 0); /* or -1 */
CHECK(io_uring_submit(&ring) == 1);
CHECK(io_uring_wait_cqe_timeout(&ring, &cqe, &to) == 0);
io_uring_cqe_seen(&ring, cqe);
memset(buf, 0, sizeof(buf));
/* READ */
sqe = io_uring_get_sqe(&ring);
CHECK(sqe);
io_uring_prep_read(sqe, fds[0], buf, sizeof(buf), 0); /* or -1 */
CHECK(io_uring_submit(&ring) == 1);
CHECK(io_uring_wait_cqe_timeout(&ring, &cqe, &to) == 0);
io_uring_cqe_seen(&ring, cqe);
close(fds[0]);
io_uring_queue_exit(&ring);
return 0;
}
int main(int argc, char *argv[])
{
int i;
if (argc > 1)
return T_EXIT_SKIP;
for (i = 0; i < 10000; i++) {
if (pipe_bug())
return T_EXIT_FAIL;
}
return T_EXIT_PASS;
}
|
