Lines Matching +full:async +full:- +full:io
1 /* SPDX-License-Identifier: MIT */
18 static int test_sync_cancel_timeout(struct io_uring *ring, int async) in test_sync_cancel_timeout() argument
34 sqe->user_data = 0x89; in test_sync_cancel_timeout()
35 if (async) in test_sync_cancel_timeout()
36 sqe->flags |= IOSQE_ASYNC; in test_sync_cancel_timeout()
49 if (async) { in test_sync_cancel_timeout()
50 /* we expect -ETIME here, but can race and get 0 */ in test_sync_cancel_timeout()
51 if (ret != -ETIME && ret != 0) { in test_sync_cancel_timeout()
64 * a small gap where io-wq is done with the request and on in test_sync_cancel_timeout()
66 * yet. the request is canceled and won't be doing any IO in test_sync_cancel_timeout()
74 if (cqe->res >= 0) { in test_sync_cancel_timeout()
75 fprintf(stderr, "cqe->res=%d\n", cqe->res); in test_sync_cancel_timeout()
82 static int test_sync_cancel(struct io_uring *ring, int async, int nr_all, in test_sync_cancel() argument
102 sqe->user_data = 0x89; in test_sync_cancel()
103 if (async) in test_sync_cancel()
104 sqe->flags |= IOSQE_ASYNC; in test_sync_cancel()
126 if (ret == -EINVAL && !no_sync_cancel) { in test_sync_cancel()
137 * a small gap where io-wq is done with the request and on in test_sync_cancel()
139 * yet. the request is canceled and won't be doing any IO in test_sync_cancel()
147 if (cqe->res >= 0) { in test_sync_cancel()
148 fprintf(stderr, "cqe->res=%d\n", cqe->res); in test_sync_cancel()