Lines Matching refs:ublk_queue

65 	struct ublk_queue *ubq;
115 struct ublk_queue { struct
274 static inline bool ublk_can_use_task_work(const struct ublk_queue *ubq) in ublk_can_use_task_work()
282 static inline bool ublk_need_get_data(const struct ublk_queue *ubq) in ublk_need_get_data()
301 static inline struct ublk_queue *ublk_get_queue(struct ublk_device *dev, in ublk_get_queue()
304 return (struct ublk_queue *)&(dev->__queues[qid * dev->queue_size]); in ublk_get_queue()
312 static inline struct ublksrv_io_desc *ublk_get_iod(struct ublk_queue *ubq, in ublk_get_iod()
326 struct ublk_queue *ubq = ublk_get_queue(ub, q_id); in ublk_queue_cmd_buf_size()
333 struct ublk_queue *ubq) in ublk_queue_can_use_recovery_reissue()
342 struct ublk_queue *ubq) in ublk_queue_can_use_recovery()
372 const struct ublk_queue *ubq;
469 static int ublk_map_io(const struct ublk_queue *ubq, const struct request *req, in ublk_map_io()
496 static int ublk_unmap_io(const struct ublk_queue *ubq, in ublk_unmap_io()
547 static blk_status_t ublk_setup_iod(struct ublk_queue *ubq, struct request *req) in ublk_setup_iod()
588 static inline bool ubq_daemon_is_dying(struct ublk_queue *ubq) in ubq_daemon_is_dying()
596 struct ublk_queue *ubq = req->mq_hctx->driver_data; in ublk_complete_rq()
645 static void __ublk_fail_req(struct ublk_queue *ubq, struct ublk_io *io, in __ublk_fail_req()
676 static inline void __ublk_abort_rq(struct ublk_queue *ubq, in __ublk_abort_rq()
690 struct ublk_queue *ubq = req->mq_hctx->driver_data; in __ublk_rq_task_work()
767 static inline void ublk_forward_io_cmds(struct ublk_queue *ubq) in ublk_forward_io_cmds()
777 static inline void ublk_abort_io_cmds(struct ublk_queue *ubq) in ublk_abort_io_cmds()
789 struct ublk_queue *ubq = pdu->ubq; in ublk_rq_task_work_cb()
799 struct ublk_queue *ubq = req->mq_hctx->driver_data; in ublk_rq_task_work_fn()
804 static void ublk_queue_cmd(struct ublk_queue *ubq, struct request *rq) in ublk_queue_cmd()
843 struct ublk_queue *ubq = hctx->driver_data; in ublk_queue_rq()
880 struct ublk_queue *ubq = ublk_get_queue(ub, hctx->queue_num); in ublk_init_hctx()
962 struct ublk_queue *ubq = ublk_get_queue(ub, qid); in ublk_commit_completion()
982 static void ublk_abort_queue(struct ublk_device *ub, struct ublk_queue *ubq) in ublk_abort_queue()
1014 struct ublk_queue *ubq = ublk_get_queue(ub, i); in ublk_daemon_monitor_work()
1039 static inline bool ublk_queue_ready(struct ublk_queue *ubq) in ublk_queue_ready()
1044 static void ublk_cancel_queue(struct ublk_queue *ubq) in ublk_cancel_queue()
1174 static void ublk_mark_io_ready(struct ublk_device *ub, struct ublk_queue *ubq) in ublk_mark_io_ready()
1191 struct ublk_queue *ubq = ublk_get_queue(ub, q_id); in ublk_handle_need_get_data()
1201 struct ublk_queue *ubq; in ublk_ch_uring_cmd()
1308 struct ublk_queue *ubq = ublk_get_queue(ub, q_id); in ublk_deinit_queue()
1318 struct ublk_queue *ubq = ublk_get_queue(ub, q_id); in ublk_init_queue()
1354 int ubq_size = sizeof(struct ublk_queue) + depth * sizeof(struct ublk_io); in ublk_init_queues()
1879 static void ublk_queue_reinit(struct ublk_device *ub, struct ublk_queue *ubq) in ublk_queue_reinit()