| /tools/testing/selftests/net/ |
| A D | io_uring_zerocopy_tx.c | 97 struct io_uring_cqe *cqe; in do_tx() local
161 if (cqe->user_data != NONZC_TAG && in do_tx()
162 cqe->user_data != ZC_TAG) in do_tx()
166 if (cqe->flags & IORING_CQE_F_MORE) in do_tx()
176 if (cqe->user_data != ZC_TAG) in do_tx()
180 if (cqe->res >= 0) { in do_tx()
182 bytes += cqe->res; in do_tx()
183 } else if (cqe->res != -EAGAIN) { in do_tx()
184 error(1, cqe->res, "send failed"); in do_tx()
191 ret = io_uring_wait_cqe(&ring, &cqe); in do_tx()
[all …]
|
| /tools/testing/selftests/drivers/net/hw/ |
| A D | iou-zcrx.c | 215 if (cqe->res < 0) in process_accept()
220 connfd = cqe->res; in process_accept()
238 if (cqe->res == 0 && cqe->flags == 0 && cfg_oneshot_recvs == 0) { in process_recvzc()
243 if (cqe->res < 0) in process_recvzc()
247 if (cqe->res == 0 && cqe->flags == 0 && cfg_oneshot_recvs) { in process_recvzc()
257 n = cqe->res; in process_recvzc()
269 rqe->len = cqe->res; in process_recvzc()
275 struct io_uring_cqe *cqe; in server_loop() local
283 if (cqe->user_data == 1) in server_loop()
284 process_accept(ring, cqe); in server_loop()
[all …]
|
| /tools/testing/selftests/ublk/ |
| A D | null.c | 93 const struct io_uring_cqe *cqe) in ublk_null_io_done() argument
95 unsigned tag = user_data_to_tag(cqe->user_data); in ublk_null_io_done()
96 unsigned op = user_data_to_op(cqe->user_data); in ublk_null_io_done()
99 if (cqe->res < 0 || op != ublk_cmd_op_nr(UBLK_U_IO_UNREGISTER_IO_BUF)) { in ublk_null_io_done()
101 io->result = cqe->res; in ublk_null_io_done()
102 if (cqe->res < 0) in ublk_null_io_done()
104 __func__, op, cqe->user_data); in ublk_null_io_done()
|
| A D | file_backed.c | 115 const struct io_uring_cqe *cqe) in ublk_loop_io_done() argument
117 unsigned tag = user_data_to_tag(cqe->user_data); in ublk_loop_io_done()
118 unsigned op = user_data_to_op(cqe->user_data); in ublk_loop_io_done()
121 if (cqe->res < 0 || op != ublk_cmd_op_nr(UBLK_U_IO_UNREGISTER_IO_BUF)) { in ublk_loop_io_done()
123 io->result = cqe->res; in ublk_loop_io_done()
124 if (cqe->res < 0) in ublk_loop_io_done()
126 __func__, op, cqe->user_data); in ublk_loop_io_done()
|
| A D | fault_inject.c | 61 const struct io_uring_cqe *cqe) in ublk_fault_inject_tgt_io_done() argument
63 unsigned tag = user_data_to_tag(cqe->user_data); in ublk_fault_inject_tgt_io_done()
66 if (cqe->res != -ETIME) in ublk_fault_inject_tgt_io_done()
67 ublk_err("%s: unexpected cqe res %d\n", __func__, cqe->res); in ublk_fault_inject_tgt_io_done()
|
| A D | kublk.c | 74 struct io_uring_cqe *cqe; in __ublk_ctrl_cmd() local
96 io_uring_cqe_seen(&dev->ring, cqe); in __ublk_ctrl_cmd()
98 return cqe->res; in __ublk_ctrl_cmd()
709 struct io_uring_cqe *cqe) in ublksrv_handle_tgt_cqe() argument
711 if (cqe->res < 0 && cqe->res != -EAGAIN) in ublksrv_handle_tgt_cqe()
713 __func__, cqe->res, q->q_id, in ublksrv_handle_tgt_cqe()
763 if (cqe->res < 0 && cqe->res != -ENODEV) in ublk_handle_cqe()
765 cqe->res, cqe->user_data, q->flags); in ublk_handle_cqe()
768 __func__, cqe->res, q->q_id, user_data_to_tag(cqe->user_data), in ublk_handle_cqe()
786 struct io_uring_cqe *cqe; in ublk_reap_events_uring() local
[all …]
|
| A D | stripe.c | 234 const struct io_uring_cqe *cqe) in ublk_stripe_io_done() argument
236 unsigned tag = user_data_to_tag(cqe->user_data); in ublk_stripe_io_done()
238 unsigned op = user_data_to_op(cqe->user_data); in ublk_stripe_io_done()
240 int res = cqe->res; in ublk_stripe_io_done()
255 unsigned seq = user_data_to_tgt_data(cqe->user_data); in ublk_stripe_io_done()
|
| /tools/testing/vsock/ |
| A D | vsock_uring_test.c | 63 struct io_uring_cqe *cqe; in vsock_io_uring_client() local
99 if (io_uring_wait_cqe(&ring, &cqe)) in vsock_io_uring_client()
102 io_uring_cqe_seen(&ring, cqe); in vsock_io_uring_client()
144 struct io_uring_cqe *cqe; in vsock_io_uring_server() local
156 if (io_uring_wait_cqe(&ring, &cqe)) in vsock_io_uring_server()
159 recv_len += cqe->res; in vsock_io_uring_server()
160 io_uring_cqe_seen(&ring, cqe); in vsock_io_uring_server()
|
| /tools/testing/selftests/x86/ |
| A D | lam.c | 571 struct io_uring_cqe *cqe; in handle_uring_cq() local
582 cqe = &cring->queue.cqes[head & *s->cq_ring.ring_mask]; in handle_uring_cq()
583 fi = (struct file_io *)cqe->user_data; in handle_uring_cq()
584 if (cqe->res < 0) in handle_uring_cq()
|
| /tools/testing/selftests/bpf/prog_tests/ |
| A D | sockopt.c | 995 struct io_uring_cqe *cqe; in uring_sockopt() local
1016 err = io_uring_wait_cqe(&ring, &cqe); in uring_sockopt()
1020 err = cqe->res; in uring_sockopt()
|
| /tools/testing/selftests/mm/ |
| A D | cow.c | 407 struct io_uring_cqe *cqe; in do_test_iouring() local
525 ret = io_uring_wait_cqe(&ring, &cqe); in do_test_iouring()
532 if (cqe->res != size) { in do_test_iouring()
537 io_uring_cqe_seen(&ring, cqe); in do_test_iouring()
|