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
|
#include "../config-host.h"
/* SPDX-License-Identifier: MIT */
/*
* Description: test if issuing IO from thread and immediately exiting will
* proceed correctly.
*
* Original test case from: https://github.com/axboe/liburing/issues/582
*/
#include <unistd.h>
#include <pthread.h>
#include <sys/timerfd.h>
#include <string.h>
#include <stdio.h>
#include "liburing.h"
#include "helpers.h"
static int no_iopoll;
struct data {
struct io_uring *ring;
int timer_fd1;
int timer_fd2;
uint64_t buf1;
uint64_t buf2;
};
static void *submit(void *data)
{
struct io_uring_sqe *sqe;
struct data *d = data;
int ret;
sqe = io_uring_get_sqe(d->ring);
io_uring_prep_read(sqe, d->timer_fd1, &d->buf1, sizeof(d->buf1), 0);
sqe = io_uring_get_sqe(d->ring);
io_uring_prep_read(sqe, d->timer_fd2, &d->buf2, sizeof(d->buf2), 0);
ret = io_uring_submit(d->ring);
if (ret != 2) {
struct io_uring_cqe *cqe;
/*
* Kernels without submit-all-on-error behavior will
* fail submitting all, check if that's the case and
* don't error
*/
ret = io_uring_peek_cqe(d->ring, &cqe);
if (!ret && cqe->res == -EOPNOTSUPP) {
no_iopoll = 1;
return NULL;
}
return (void *) (uintptr_t) 1;
}
/* Exit suddenly. */
return NULL;
}
static int test(int flags)
{
struct io_uring_params params = { .flags = flags, };
struct io_uring ring;
struct data d = { .ring = &ring, };
pthread_t thread;
void *res;
int ret;
ret = t_create_ring_params(8, &ring, ¶ms);
if (ret == T_SETUP_SKIP)
return 0;
else if (ret != T_SETUP_OK)
return 1;
d.timer_fd1 = timerfd_create(CLOCK_MONOTONIC, TFD_CLOEXEC);
if (d.timer_fd1 < 0) {
perror("timerfd_create");
return 1;
}
d.timer_fd2 = timerfd_create(CLOCK_MONOTONIC, TFD_CLOEXEC);
if (d.timer_fd2 < 0) {
perror("timerfd_create");
return 1;
}
pthread_create(&thread, NULL, submit, &d);
pthread_join(thread, &res);
/** Wait for completions and do stuff ... **/
io_uring_queue_exit(&ring);
close(d.timer_fd1);
close(d.timer_fd2);
return !!res;
}
int main(int argc, char *argv[])
{
int ret, i;
for (i = 0; i < 1000; i++) {
ret = test(0);
if (ret) {
fprintf(stderr, "Test failed\n");
return ret;
}
}
for (i = 0; i < 1000; i++) {
ret = test(IORING_SETUP_IOPOLL);
if (ret) {
fprintf(stderr, "Test IOPOLL failed loop %d\n", ret);
return ret;
}
if (no_iopoll)
break;
}
for (i = 0; i < 100; i++) {
ret = test(IORING_SETUP_SQPOLL);
if (ret) {
fprintf(stderr, "Test SQPOLL failed\n");
return ret;
}
}
return 0;
}
|
