Lines Matching refs:q_id
131 int q_id;
681 static inline char *ublk_queue_cmd_buf(struct ublk_device *ub, int q_id)
683 return ublk_get_queue(ub, q_id)->io_cmd_buf;
686 static inline int ublk_queue_cmd_buf_size(struct ublk_device *ub, int q_id)
688 struct ublk_queue *ubq = ublk_get_queue(ub, q_id);
1138 __func__, io->cmd->cmd_op, ubq->q_id, req->tag, io->flags,
1164 __func__, io->cmd->cmd_op, ubq->q_id,
1178 __func__, io->cmd->cmd_op, ubq->q_id, req->tag, io->flags,
1362 int q_id, ret = 0;
1381 q_id = (phys_off - UBLKSRV_CMD_BUF_OFFSET) / max_sz;
1383 __func__, q_id, current->pid, vma->vm_start,
1386 if (sz != ublk_queue_cmd_buf_size(ub, q_id))
1389 pfn = virt_to_phys(ublk_queue_cmd_buf(ub, q_id)) >> PAGE_SHIFT;
1396 u32 qid = ub_cmd->q_id, tag = ub_cmd->tag;
1439 rq = blk_mq_tag_to_rq(ub->tag_set.tags[ubq->q_id], i);
1637 static void ublk_handle_need_get_data(struct ublk_device *ub, int q_id,
1640 struct ublk_queue *ubq = ublk_get_queue(ub, q_id);
1641 struct request *req = blk_mq_tag_to_rq(ub->tag_set.tags[q_id], tag);
1680 __func__, cmd->cmd_op, ub_cmd->q_id, tag,
1683 if (ub_cmd->q_id >= ub->dev_info.nr_hw_queues)
1686 ubq = ublk_get_queue(ub, ub_cmd->q_id);
1687 if (!ubq || ub_cmd->q_id != ubq->q_id)
1748 req = blk_mq_tag_to_rq(ub->tag_set.tags[ub_cmd->q_id], tag);
1777 ublk_handle_need_get_data(ub, ub_cmd->q_id, ub_cmd->tag);
1799 req = blk_mq_tag_to_rq(ub->tag_set.tags[ubq->q_id], tag);
1829 .q_id = READ_ONCE(ub_src->q_id),
1862 u16 tag, q_id;
1874 q_id = ublk_pos_to_hwq(iocb->ki_pos);
1877 if (q_id >= ub->dev_info.nr_hw_queues)
1880 ubq = ublk_get_queue(ub, q_id);
1951 static void ublk_deinit_queue(struct ublk_device *ub, int q_id)
1953 int size = ublk_queue_cmd_buf_size(ub, q_id);
1954 struct ublk_queue *ubq = ublk_get_queue(ub, q_id);
1962 static int ublk_init_queue(struct ublk_device *ub, int q_id)
1964 struct ublk_queue *ubq = ublk_get_queue(ub, q_id);
1971 ubq->q_id = q_id;
1973 size = ublk_queue_cmd_buf_size(ub, q_id);