Lines Matching refs:q_id
119 int q_id; member
336 static inline char *ublk_queue_cmd_buf(struct ublk_device *ub, int q_id) in ublk_queue_cmd_buf() argument
338 return ublk_get_queue(ub, q_id)->io_cmd_buf; in ublk_queue_cmd_buf()
341 static inline int ublk_queue_cmd_buf_size(struct ublk_device *ub, int q_id) in ublk_queue_cmd_buf_size() argument
343 struct ublk_queue *ubq = ublk_get_queue(ub, q_id); in ublk_queue_cmd_buf_size()
755 __func__, io->cmd->cmd_op, ubq->q_id, req->tag, io->flags, in __ublk_rq_task_work()
783 __func__, io->cmd->cmd_op, ubq->q_id, in __ublk_rq_task_work()
797 __func__, io->cmd->cmd_op, ubq->q_id, req->tag, io->flags, in __ublk_rq_task_work()
986 int q_id, ret = 0; in ublk_ch_mmap() local
1005 q_id = (phys_off - UBLKSRV_CMD_BUF_OFFSET) / max_sz; in ublk_ch_mmap()
1007 __func__, q_id, current->pid, vma->vm_start, in ublk_ch_mmap()
1010 if (sz != ublk_queue_cmd_buf_size(ub, q_id)) in ublk_ch_mmap()
1013 pfn = virt_to_phys(ublk_queue_cmd_buf(ub, q_id)) >> PAGE_SHIFT; in ublk_ch_mmap()
1020 u32 qid = ub_cmd->q_id, tag = ub_cmd->tag; in ublk_commit_completion()
1058 rq = blk_mq_tag_to_rq(ub->tag_set.tags[ubq->q_id], i); in ublk_abort_queue()
1250 static void ublk_handle_need_get_data(struct ublk_device *ub, int q_id, in ublk_handle_need_get_data() argument
1253 struct ublk_queue *ubq = ublk_get_queue(ub, q_id); in ublk_handle_need_get_data()
1254 struct request *req = blk_mq_tag_to_rq(ub->tag_set.tags[q_id], tag); in ublk_handle_need_get_data()
1271 __func__, cmd->cmd_op, ub_cmd->q_id, tag, in ublk_ch_uring_cmd()
1274 if (ub_cmd->q_id >= ub->dev_info.nr_hw_queues) in ublk_ch_uring_cmd()
1277 ubq = ublk_get_queue(ub, ub_cmd->q_id); in ublk_ch_uring_cmd()
1278 if (!ubq || ub_cmd->q_id != ubq->q_id) in ublk_ch_uring_cmd()
1326 req = blk_mq_tag_to_rq(ub->tag_set.tags[ub_cmd->q_id], tag); in ublk_ch_uring_cmd()
1346 ublk_handle_need_get_data(ub, ub_cmd->q_id, ub_cmd->tag); in ublk_ch_uring_cmd()
1369 static void ublk_deinit_queue(struct ublk_device *ub, int q_id) in ublk_deinit_queue() argument
1371 int size = ublk_queue_cmd_buf_size(ub, q_id); in ublk_deinit_queue()
1372 struct ublk_queue *ubq = ublk_get_queue(ub, q_id); in ublk_deinit_queue()
1380 static int ublk_init_queue(struct ublk_device *ub, int q_id) in ublk_init_queue() argument
1382 struct ublk_queue *ubq = ublk_get_queue(ub, q_id); in ublk_init_queue()
1388 ubq->q_id = q_id; in ublk_init_queue()
1390 size = ublk_queue_cmd_buf_size(ub, q_id); in ublk_init_queue()