| /tools/testing/selftests/ublk/ |
| A D | null.c | 46 struct io_uring_sqe *sqe, int q_id) in __setup_nop_io() argument
55 sqe->user_data = build_user_data(tag, ublk_op, 0, q_id, 1); in __setup_nop_io()
66 io_uring_prep_buf_register(sqe[0], 0, tag, q->q_id, ublk_get_io(q, tag)->buf_index); in null_queue_zc_io()
68 ublk_cmd_op_nr(sqe[0]->cmd_op), 0, q->q_id, 1); in null_queue_zc_io()
71 __setup_nop_io(tag, iod, sqe[1], q->q_id); in null_queue_zc_io()
74 io_uring_prep_buf_unregister(sqe[2], 0, tag, q->q_id, ublk_get_io(q, tag)->buf_index); 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()
88 __setup_nop_io(tag, iod, sqe[0], q->q_id); in null_queue_auto_zc_io()
|
| A D | kublk.h | 161 int q_id; member
217 unsigned tgt_data, unsigned q_id, unsigned is_target_io) in build_user_data() argument
221 assert(!(tag >> 16) && !(op >> 8) && !(tgt_data >> 16) && !(q_id >> 7)); in build_user_data()
224 (__u64)q_id << 56 | (__u64)is_target_io << 63; in build_user_data()
277 int dev_fd, int tag, int q_id, __u64 index) in io_uring_prep_buf_register() argument
288 cmd->q_id = q_id; in io_uring_prep_buf_register()
292 int dev_fd, int tag, int q_id, __u64 index) in io_uring_prep_buf_unregister() argument
303 cmd->q_id = q_id; in io_uring_prep_buf_unregister()
|
| A D | file_backed.c | 26 sqe[0]->user_data = build_user_data(tag, ublk_op, 0, q->q_id, 1); in loop_queue_flush_io()
53 sqe[0]->user_data = build_user_data(tag, ublk_op, 0, q->q_id, 1); in loop_queue_tgt_rw_io()
59 io_uring_prep_buf_register(sqe[0], 0, tag, q->q_id, ublk_get_io(q, tag)->buf_index); in loop_queue_tgt_rw_io()
62 ublk_cmd_op_nr(sqe[0]->cmd_op), 0, q->q_id, 1); in loop_queue_tgt_rw_io()
69 sqe[1]->user_data = build_user_data(tag, ublk_op, 0, q->q_id, 1); in loop_queue_tgt_rw_io()
71 io_uring_prep_buf_unregister(sqe[2], 0, tag, q->q_id, ublk_get_io(q, tag)->buf_index); in loop_queue_tgt_rw_io()
72 sqe[2]->user_data = build_user_data(tag, ublk_cmd_op_nr(sqe[2]->cmd_op), 0, q->q_id, 1); in loop_queue_tgt_rw_io()
|
| A D | stripe.c | 145 io_uring_prep_buf_register(sqe[0], 0, tag, q->q_id, io->buf_index); 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()
166 sqe[i]->user_data = build_user_data(tag, ublksrv_get_op(iod), i - zc, q->q_id, 1); in stripe_queue_tgt_rw_io()
171 io_uring_prep_buf_unregister(unreg, 0, tag, q->q_id, io->buf_index); in stripe_queue_tgt_rw_io()
173 tag, ublk_cmd_op_nr(unreg->cmd_op), 0, q->q_id, 1); in stripe_queue_tgt_rw_io()
191 sqe[i]->user_data = build_user_data(tag, UBLK_IO_OP_FLUSH, 0, q->q_id, 1); in handle_flush()
|
| A D | kublk.c | 455 q->dev->dev_info.dev_id, q->q_id); in ublk_queue_init()
471 dev->dev_info.dev_id, q->q_id, i); in ublk_queue_init()
480 dev->dev_info.dev_id, q->q_id); in ublk_queue_init()
634 cmd->q_id = q->q_id; in ublk_queue_io_cmd()
651 __func__, t->idx, q->q_id, io->tag, cmd_op, in ublk_queue_io_cmd()
676 int q_id = i / dinfo->queue_depth; in ublk_submit_fetch_commands() local
678 q = &t->dev->q[q_id]; in ublk_submit_fetch_commands()
713 __func__, cqe->res, q->q_id, in ublksrv_handle_tgt_cqe()
759 unsigned q_id = user_data_to_q_id(cqe->user_data); in ublk_handle_cqe() local
760 struct ublk_queue *q = &dev->q[q_id]; in ublk_handle_cqe()
[all …]
|
| A D | fault_inject.c | 52 sqe->user_data = build_user_data(tag, ublksrv_get_op(iod), 0, q->q_id, 1); in ublk_fault_inject_queue_io()
|
| /tools/cgroup/ |
| A D | iocost_monitor.py | 64 def __init__(self, root_blkcg, q_id, include_dying=False): argument
67 self.walk(root_blkcg, q_id, '')
72 def walk(self, blkcg, q_id, parent_path): argument
80 address=radix_tree_lookup(blkcg.blkg_tree.address_of_(), q_id))
88 self.walk(c, q_id, path)
224 q_id = None variable
232 q_id = blkg.q.id.value_() variable
258 for path, blkg in BlkgIterator(blkcg_root, q_id):
|