Home
last modified time | relevance | path

Searched refs:sqe (Results 1 – 13 of 13) sorted by relevance

/tools/testing/selftests/ublk/
A Dnull.c46 struct io_uring_sqe *sqe, int q_id) in __setup_nop_io() argument
50 io_uring_prep_nop(sqe); in __setup_nop_io()
51 sqe->buf_index = tag; in __setup_nop_io()
52 sqe->flags |= IOSQE_FIXED_FILE; in __setup_nop_io()
62 struct io_uring_sqe *sqe[3]; in null_queue_zc_io() local
64 ublk_io_alloc_sqes(t, sqe, 3); in null_queue_zc_io()
67 sqe[0]->user_data = build_user_data(tag, in null_queue_zc_io()
72 sqe[1]->flags |= IOSQE_IO_HARDLINK; in null_queue_zc_io()
75 sqe[2]->user_data = build_user_data(tag, ublk_cmd_op_nr(sqe[2]->cmd_op), 0, q->q_id, 1); in null_queue_zc_io()
85 struct io_uring_sqe *sqe[1]; in null_queue_auto_zc_io() local
[all …]
A Dfile_backed.c20 struct io_uring_sqe *sqe[1]; in loop_queue_flush_io() local
22 ublk_io_alloc_sqes(t, sqe, 1); in loop_queue_flush_io()
37 struct io_uring_sqe *sqe[3]; in loop_queue_tgt_rw_io() local
41 ublk_io_alloc_sqes(t, sqe, 1); in loop_queue_tgt_rw_io()
42 if (!sqe[0]) in loop_queue_tgt_rw_io()
45 io_uring_prep_rw(op, sqe[0], 1 /*fds[1]*/, in loop_queue_tgt_rw_io()
50 sqe[0]->buf_index = tag; in loop_queue_tgt_rw_io()
57 ublk_io_alloc_sqes(t, sqe, 3); in loop_queue_tgt_rw_io()
61 sqe[0]->user_data = build_user_data(tag, in loop_queue_tgt_rw_io()
67 sqe[1]->buf_index = tag; in loop_queue_tgt_rw_io()
[all …]
A Dkublk.h279 struct ublksrv_io_cmd *cmd = (struct ublksrv_io_cmd *)sqe->cmd; in io_uring_prep_buf_register()
281 io_uring_prep_read(sqe, dev_fd, 0, 0, 0); in io_uring_prep_buf_register()
282 sqe->opcode = IORING_OP_URING_CMD; in io_uring_prep_buf_register()
283 sqe->flags |= IOSQE_FIXED_FILE; in io_uring_prep_buf_register()
284 sqe->cmd_op = UBLK_U_IO_REGISTER_IO_BUF; in io_uring_prep_buf_register()
296 io_uring_prep_read(sqe, dev_fd, 0, 0, 0); in io_uring_prep_buf_unregister()
297 sqe->opcode = IORING_OP_URING_CMD; in io_uring_prep_buf_unregister()
298 sqe->flags |= IOSQE_FIXED_FILE; in io_uring_prep_buf_unregister()
299 sqe->cmd_op = UBLK_U_IO_UNREGISTER_IO_BUF; in io_uring_prep_buf_unregister()
308 return (void *)&sqe->cmd; in ublk_get_sqe_cmd()
[all …]
A Dstripe.c133 struct io_uring_sqe *sqe[NR_STRIPE]; in stripe_queue_tgt_rw_io() local
142 ublk_io_alloc_sqes(t, sqe, s->nr + extra); in stripe_queue_tgt_rw_io()
147 sqe[0]->user_data = build_user_data(tag, in stripe_queue_tgt_rw_io()
148 ublk_cmd_op_nr(sqe[0]->cmd_op), 0, q->q_id, 1); in stripe_queue_tgt_rw_io()
154 io_uring_prep_rw(op, sqe[i], in stripe_queue_tgt_rw_io()
159 io_uring_sqe_set_flags(sqe[i], IOSQE_FIXED_FILE); in stripe_queue_tgt_rw_io()
161 sqe[i]->buf_index = tag; in stripe_queue_tgt_rw_io()
163 sqe[i]->flags |= IOSQE_IO_HARDLINK; in stripe_queue_tgt_rw_io()
169 struct io_uring_sqe *unreg = sqe[s->nr + 1]; in stripe_queue_tgt_rw_io()
184 struct io_uring_sqe *sqe[NR_STRIPE]; in handle_flush() local
[all …]
A Dfault_inject.c45 struct io_uring_sqe *sqe; in ublk_fault_inject_queue_io() local
50 ublk_io_alloc_sqes(t, &sqe, 1); in ublk_fault_inject_queue_io()
51 io_uring_prep_timeout(sqe, &ts, 1, 0); in ublk_fault_inject_queue_io()
52 sqe->user_data = build_user_data(tag, ublksrv_get_op(iod), 0, q->q_id, 1); in ublk_fault_inject_queue_io()
A Dkublk.c44 struct io_uring_sqe *sqe, in ublk_ctrl_init_cmd() argument
50 sqe->fd = dev->ctrl_fd; in ublk_ctrl_init_cmd()
51 sqe->opcode = IORING_OP_URING_CMD; in ublk_ctrl_init_cmd()
52 sqe->ioprio = 0; in ublk_ctrl_init_cmd()
67 io_uring_sqe_set_data(sqe, cmd); in ublk_ctrl_init_cmd()
73 struct io_uring_sqe *sqe; in __ublk_ctrl_cmd() local
78 if (!sqe) { in __ublk_ctrl_cmd()
569 struct io_uring_sqe *sqe, in ublk_set_auto_buf_reg() argument
589 struct io_uring_sqe *sqe[1]; in ublk_queue_io_cmd() local
616 if (!sqe[0]) { in ublk_queue_io_cmd()
[all …]
/tools/include/io_uring/
A Dmini_liburing.h236 memset(sqe, 0, sizeof(*sqe)); in io_uring_prep_cmd()
238 sqe->fd = sockfd; in io_uring_prep_cmd()
239 sqe->cmd_op = op; in io_uring_prep_cmd()
241 sqe->level = level; in io_uring_prep_cmd()
242 sqe->optname = optname; in io_uring_prep_cmd()
244 sqe->optlen = optlen; in io_uring_prep_cmd()
261 memset(sqe, 0, sizeof(*sqe)); in io_uring_prep_send()
263 sqe->fd = sockfd; in io_uring_prep_send()
265 sqe->len = len; in io_uring_prep_send()
266 sqe->msg_flags = (__u32)flags; in io_uring_prep_send()
[all …]
/tools/testing/selftests/drivers/net/hw/
A Diou-zcrx.c183 struct io_uring_sqe *sqe; in add_accept() local
185 sqe = io_uring_get_sqe(ring); in add_accept()
188 sqe->user_data = 1; in add_accept()
193 struct io_uring_sqe *sqe; in add_recvzc() local
195 sqe = io_uring_get_sqe(ring); in add_recvzc()
198 sqe->ioprio |= IORING_RECV_MULTISHOT; in add_recvzc()
199 sqe->user_data = 2; in add_recvzc()
204 struct io_uring_sqe *sqe; in add_recvzc_oneshot() local
206 sqe = io_uring_get_sqe(ring); in add_recvzc_oneshot()
210 sqe->user_data = 2; in add_recvzc_oneshot()
[all …]
/tools/testing/selftests/net/
A Dio_uring_zerocopy_tx.c96 struct io_uring_sqe *sqe; in do_tx() local
132 sqe = io_uring_get_sqe(&ring); in do_tx()
135 io_uring_prep_send(sqe, fd, payload, in do_tx()
137 sqe->user_data = NONZC_TAG; in do_tx()
139 io_uring_prep_sendzc(sqe, fd, payload, in do_tx()
143 sqe->ioprio |= IORING_RECVSEND_FIXED_BUF; in do_tx()
144 sqe->buf_index = buf_idx; in do_tx()
146 sqe->user_data = ZC_TAG; in do_tx()
/tools/testing/vsock/
A Dvsock_uring_test.c62 struct io_uring_sqe *sqe; in vsock_io_uring_client() local
89 sqe = io_uring_get_sqe(&ring); in vsock_io_uring_client()
92 io_uring_prep_sendmsg_zc(sqe, fd, &msg, 0); in vsock_io_uring_client()
94 io_uring_prep_sendmsg(sqe, fd, &msg, 0); in vsock_io_uring_client()
143 struct io_uring_sqe *sqe; in vsock_io_uring_server() local
147 sqe = io_uring_get_sqe(&ring); in vsock_io_uring_server()
151 io_uring_prep_readv(sqe, fd, &iovec, 1, 0); in vsock_io_uring_server()
/tools/testing/selftests/x86/
A Dlam.c610 struct io_uring_sqe *sqe; in handle_uring_sq() local
640 sqe = &ring->sq_ring.queue.sqes[index]; in handle_uring_sq()
641 sqe->fd = file_fd; in handle_uring_sq()
642 sqe->flags = 0; in handle_uring_sq()
643 sqe->opcode = IORING_OP_READV; in handle_uring_sq()
644 sqe->addr = (unsigned long)fi->iovecs; in handle_uring_sq()
645 sqe->len = blocks; in handle_uring_sq()
646 sqe->off = 0; in handle_uring_sq()
647 sqe->user_data = (uint64_t)fi; in handle_uring_sq()
/tools/testing/selftests/bpf/prog_tests/
A Dsockopt.c996 struct io_uring_sqe *sqe; in uring_sockopt() local
1004 sqe = io_uring_get_sqe(&ring); in uring_sockopt()
1005 if (!ASSERT_NEQ(sqe, NULL, "Get an SQE")) { in uring_sockopt()
1010 io_uring_prep_cmd(sqe, op, fd, level, optname, optval, optlen); in uring_sockopt()
/tools/testing/selftests/mm/
A Dcow.c408 struct io_uring_sqe *sqe; in do_test_iouring() local
510 sqe = io_uring_get_sqe(&ring); in do_test_iouring()
511 if (!sqe) { in do_test_iouring()
516 io_uring_prep_write_fixed(sqe, fd, mem, size, 0, 0); in do_test_iouring()

Completed in 24 milliseconds