Home
last modified time | relevance | path

Searched refs:rq_list (Results 1 – 23 of 23) sorted by relevance

/linux-6.15/block/
H A Dblk-mq-sched.c64 list_for_each_entry(rq, rq_list, queuelist) { in blk_mq_dispatch_hctx_list()
71 list_splice_tail_init(rq_list, &hctx_list); in blk_mq_dispatch_hctx_list()
94 LIST_HEAD(rq_list); in __blk_mq_do_dispatch_sched()
139 list_add_tail(&rq->queuelist, &rq_list); in __blk_mq_do_dispatch_sched()
165 list_sort(NULL, &rq_list, sched_rq_cmp); in __blk_mq_do_dispatch_sched()
168 } while (!list_empty(&rq_list)); in __blk_mq_do_dispatch_sched()
218 LIST_HEAD(rq_list); in blk_mq_do_dispatch_ctx()
259 list_add(&rq->queuelist, &rq_list); in blk_mq_do_dispatch_ctx()
273 LIST_HEAD(rq_list); in __blk_mq_sched_dispatch_requests()
299 if (!list_empty(&rq_list)) { in __blk_mq_sched_dispatch_requests()
[all …]
H A Dkyber-iosched.c147 struct list_head rq_list[KYBER_NUM_DOMAINS]; member
450 INIT_LIST_HEAD(&kcq->rq_list[i]); in kyber_ctx_queue_init()
575 struct list_head *rq_list = &kcq->rq_list[sched_domain]; in kyber_bio_merge() local
579 merged = blk_bio_list_merge(hctx->queue, rq_list, bio, nr_segs); in kyber_bio_merge()
591 struct list_head *rq_list, in kyber_insert_requests() argument
597 list_for_each_entry_safe(rq, next, rq_list, queuelist) { in kyber_insert_requests()
600 struct list_head *head = &kcq->rq_list[sched_domain]; in kyber_insert_requests()
673 list_splice_tail_init(&kcq->rq_list[flush_data->sched_domain], in flush_busy_kcq()
H A Dblk-mq.h156 struct rq_list *cached_rqs;
H A Dblk-mq.c1538 LIST_HEAD(rq_list); in blk_mq_requeue_work()
1543 list_splice_init(&q->requeue_list, &rq_list); in blk_mq_requeue_work()
1547 while (!list_empty(&rq_list)) { in blk_mq_requeue_work()
1548 rq = list_entry(rq_list.next, struct request, queuelist); in blk_mq_requeue_work()
2832 struct rq_list requeue_list = {}; in blk_mq_dispatch_plug_list()
/linux-6.15/include/linux/
H A Dblk-mq.h232 static inline int rq_list_empty(const struct rq_list *rl) in rq_list_empty()
237 static inline void rq_list_init(struct rq_list *rl) in rq_list_init()
243 static inline void rq_list_add_tail(struct rq_list *rl, struct request *rq) in rq_list_add_tail()
253 static inline void rq_list_add_head(struct rq_list *rl, struct request *rq) in rq_list_add_head()
261 static inline struct request *rq_list_pop(struct rq_list *rl) in rq_list_pop()
275 static inline struct request *rq_list_peek(struct rq_list *rl) in rq_list_peek()
571 void (*queue_rqs)(struct rq_list *rqlist);
H A Dblkdev.h1061 struct rq_list { struct
1079 struct rq_list mq_list; /* blk-mq requests */ argument
1082 struct rq_list cached_rqs;
1744 struct rq_list req_list;
/linux-6.15/include/linux/mtd/
H A Dblktrans.h33 struct list_head rq_list; member
/linux-6.15/drivers/scsi/
H A Dsg.c149 struct list_head rq_list; /* head of request list */ member
860 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_fill_request_table()
998 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_ioctl_common()
1010 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_ioctl_common()
1180 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_poll()
2102 if (!list_empty(&sfp->rq_list)) { in sg_add_request()
2116 list_add_tail(&rp->entry, &sfp->rq_list); in sg_add_request()
2131 if (!sfp || !srp || list_empty(&sfp->rq_list)) in sg_remove_request()
2165 INIT_LIST_HEAD(&sfp->rq_list); in sg_add_sfp()
2211 while (!list_empty(&sfp->rq_list)) { in sg_remove_sfp_usercontext()
[all …]
/linux-6.15/drivers/mtd/
H A Dmtd_blkdevs.c110 rq = list_first_entry_or_null(&dev->rq_list, struct request, queuelist); in mtd_next_request()
178 list_add_tail(&bd->rq->queuelist, &dev->rq_list); in mtd_queue_rq()
376 INIT_LIST_HEAD(&new->rq_list); in add_mtd_blktrans_dev()
/linux-6.15/drivers/block/aoe/
H A Daoe.h173 struct list_head rq_list; member
H A Daoedev.c475 INIT_LIST_HEAD(&d->rq_list); in aoedev_by_aoeaddr()
H A Daoeblk.c265 list_add_tail(&bd->rq->queuelist, &d->rq_list); in aoeblk_queue_rq()
H A Daoecmd.c857 rq = list_first_entry_or_null(&d->rq_list, struct request, in nextbuf()
/linux-6.15/net/sunrpc/
H A Dxprt.c1738 req = list_entry(xprt->free.next, struct rpc_rqst, rq_list); in xprt_alloc_slot()
1739 list_del(&req->rq_list); in xprt_alloc_slot()
1776 list_add(&req->rq_list, &xprt->free); in xprt_free_slot()
1786 req = list_first_entry(&xprt->free, struct rpc_rqst, rq_list); in xprt_free_all_slots()
1787 list_del(&req->rq_list); in xprt_free_all_slots()
1835 list_add(&req->rq_list, &xprt->free); in xprt_alloc()
/linux-6.15/drivers/block/
H A Dvirtio_blk.c474 struct rq_list *rqlist) in virtblk_add_req_batch()
501 static void virtio_queue_rqs(struct rq_list *rqlist) in virtio_queue_rqs()
503 struct rq_list submit_list = { }; in virtio_queue_rqs()
504 struct rq_list requeue_list = { }; in virtio_queue_rqs()
H A Dublk_drv.c1270 static void ublk_queue_cmd_list(struct ublk_queue *ubq, struct rq_list *l) in ublk_queue_cmd_list()
1354 static void ublk_queue_rqs(struct rq_list *rqlist) in ublk_queue_rqs()
1356 struct rq_list requeue_list = { }; in ublk_queue_rqs()
1357 struct rq_list submit_list = { }; in ublk_queue_rqs()
/linux-6.15/include/linux/sunrpc/
H A Dxprt.h76 struct list_head rq_list; /* Slot allocation list */ member
/linux-6.15/drivers/infiniband/hw/hns/
H A Dhns_roce_cq.c326 INIT_LIST_HEAD(&hr_cq->rq_list); in set_cq_param()
H A Dhns_roce_device.h442 struct list_head rq_list; /* all qps on this recv cq */ member
H A Dhns_roce_qp.c299 list_add_tail(&hr_qp->rq_node, &hr_recv_cq->rq_list); in add_qp_to_list()
H A Dhns_roce_hw_v2.c3725 list_for_each_entry(hr_qp, &hr_cq->rq_list, rq_node) { in hns_roce_v2_sw_poll_cq()
/linux-6.15/drivers/nvme/host/
H A Dpci.c985 static void nvme_submit_cmds(struct nvme_queue *nvmeq, struct rq_list *rqlist) in nvme_submit_cmds()
1016 static void nvme_queue_rqs(struct rq_list *rqlist) in nvme_queue_rqs()
1018 struct rq_list submit_list = { }; in nvme_queue_rqs()
1019 struct rq_list requeue_list = { }; in nvme_queue_rqs()
/linux-6.15/drivers/block/null_blk/
H A Dmain.c1697 static void null_queue_rqs(struct rq_list *rqlist) in null_queue_rqs()
1699 struct rq_list requeue_list = {}; in null_queue_rqs()