1 /* SPDX-License-Identifier: MIT */
2 #include <stdio.h>
3 #include <time.h>
4 #include <sys/time.h>
5 #include "liburing.h"
6 #include "helpers.h"
7
mtime_since(const struct timeval * s,const struct timeval * e)8 static unsigned long long mtime_since(const struct timeval *s,
9 const struct timeval *e)
10 {
11 long long sec, usec;
12
13 sec = e->tv_sec - s->tv_sec;
14 usec = (e->tv_usec - s->tv_usec);
15 if (sec > 0 && usec < 0) {
16 sec--;
17 usec += 1000000;
18 }
19
20 sec *= 1000;
21 usec /= 1000;
22 return sec + usec;
23 }
24
mtime_since_now(struct timeval * tv)25 static unsigned long long mtime_since_now(struct timeval *tv)
26 {
27 struct timeval end;
28
29 gettimeofday(&end, NULL);
30 return mtime_since(tv, &end);
31 }
32
main(int argc,char * argv[])33 int main(int argc, char *argv[])
34 {
35 struct __kernel_timespec ts1, ts2;
36 struct io_uring_cqe *cqe;
37 struct io_uring_sqe *sqe;
38 struct io_uring ring;
39 unsigned long msec;
40 struct timeval tv;
41 int ret;
42
43 if (argc > 1)
44 return T_EXIT_SKIP;
45
46 ret = io_uring_queue_init(32, &ring, 0);
47 if (ret) {
48 fprintf(stderr, "io_uring_queue_init=%d\n", ret);
49 return T_EXIT_FAIL;
50 }
51
52 sqe = io_uring_get_sqe(&ring);
53 io_uring_prep_nop(sqe);
54 ret = io_uring_submit(&ring);
55 if (ret != 1) {
56 fprintf(stderr, "io_uring_submit1=%d\n", ret);
57 return T_EXIT_FAIL;
58 }
59
60
61 ts1.tv_sec = 5,
62 ts1.tv_nsec = 0;
63 ret = io_uring_wait_cqe_timeout(&ring, &cqe, &ts1);
64 if (ret) {
65 fprintf(stderr, "io_uring_wait_cqe_timeout=%d\n", ret);
66 return T_EXIT_FAIL;
67 }
68 io_uring_cqe_seen(&ring, cqe);
69 gettimeofday(&tv, NULL);
70
71 ts2.tv_sec = 1;
72 ts2.tv_nsec = 0;
73 sqe = io_uring_get_sqe(&ring);
74 io_uring_prep_timeout(sqe, &ts2, 0, 0);
75 sqe->user_data = 89;
76 ret = io_uring_submit(&ring);
77 if (ret != 1) {
78 fprintf(stderr, "io_uring_submit2=%d\n", ret);
79 return T_EXIT_FAIL;
80 }
81
82 io_uring_wait_cqe(&ring, &cqe);
83 io_uring_cqe_seen(&ring, cqe);
84 msec = mtime_since_now(&tv);
85 if (msec >= 900 && msec <= 1100) {
86 io_uring_queue_exit(&ring);
87 return T_EXIT_PASS;
88 }
89
90 fprintf(stderr, "%s: Timeout seems wonky (got %lu)\n", __FUNCTION__,
91 msec);
92 io_uring_queue_exit(&ring);
93 return T_EXIT_FAIL;
94 }
95