| /linux/block/ |
| H A D | blk-mq-sched.c | 56 static bool blk_mq_dispatch_hctx_list(struct list_head *rq_list) in blk_mq_dispatch_hctx_list() argument
59 list_first_entry(rq_list, struct request, queuelist)->mq_hctx; in blk_mq_dispatch_hctx_list()
63 list_for_each_entry(rq, rq_list, queuelist) { in blk_mq_dispatch_hctx_list()
65 list_cut_before(&hctx_list, rq_list, &rq->queuelist); in blk_mq_dispatch_hctx_list()
69 list_splice_tail_init(rq_list, &hctx_list); in blk_mq_dispatch_hctx_list()
92 LIST_HEAD(rq_list); in __blk_mq_do_dispatch_sched()
137 list_add_tail(&rq->queuelist, &rq_list); in __blk_mq_do_dispatch_sched()
163 list_sort(NULL, &rq_list, sched_rq_cmp); in __blk_mq_do_dispatch_sched()
165 dispatched |= blk_mq_dispatch_hctx_list(&rq_list); in __blk_mq_do_dispatch_sched()
166 } while (!list_empty(&rq_list)); in __blk_mq_do_dispatch_sched()
[all …]
|
| H A D | kyber-iosched.c | 146 struct list_head rq_list[KYBER_NUM_DOMAINS]; member
455 INIT_LIST_HEAD(&kcq->rq_list[i]); in kyber_ctx_queue_init()
561 struct list_head *rq_list = &kcq->rq_list[sched_domain]; in kyber_bio_merge() local
565 merged = blk_bio_list_merge(hctx->queue, rq_list, bio, nr_segs); in kyber_bio_merge()
577 struct list_head *rq_list, in kyber_insert_requests() argument
583 list_for_each_entry_safe(rq, next, rq_list, queuelist) { in kyber_insert_requests()
586 struct list_head *head = &kcq->rq_list[sched_domain]; in kyber_insert_requests()
659 list_splice_tail_init(&kcq->rq_list[flush_data->sched_domain], in flush_busy_kcq()
|
| H A D | blk-mq.c | 1541 LIST_HEAD(rq_list); in blk_mq_requeue_work()
1546 list_splice_init(&q->requeue_list, &rq_list); in blk_mq_requeue_work()
1550 while (!list_empty(&rq_list)) { in blk_mq_requeue_work()
1551 rq = list_entry(rq_list.next, struct request, queuelist); in blk_mq_requeue_work()
2784 static void blk_mq_issue_direct(struct rq_list *rqs) in blk_mq_issue_direct()
2823 static void __blk_mq_flush_list(struct request_queue *q, struct rq_list *rqs) in __blk_mq_flush_list()
2830 static unsigned blk_mq_extract_queue_requests(struct rq_list *rqs, in blk_mq_extract_queue_requests()
2831 struct rq_list *queue_rqs) in blk_mq_extract_queue_requests()
2836 struct rq_list matched_rqs = {}; in blk_mq_extract_queue_requests()
2859 static void blk_mq_dispatch_queue_requests(struct rq_list *rqs, unsigned depth) in blk_mq_dispatch_queue_requests()
[all …]
|
| H A D | blk-mq.h | 170 struct rq_list *cached_rqs;
|
| /linux/include/linux/ |
| H A D | blk_plug.h | 10 struct rq_list { struct
28 struct rq_list mq_list; /* blk-mq requests */ argument
31 struct rq_list cached_rqs;
|
| H A D | blkdev.h | 1753 struct rq_list req_list;
|
| /linux/include/linux/mtd/ |
| H A D | blktrans.h | 33 struct list_head rq_list; member
|
| /linux/drivers/scsi/ |
| H A D | sg.c | 149 struct list_head rq_list; /* head of request list */ member
862 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_fill_request_table()
999 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_ioctl_common()
1011 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_ioctl_common()
1181 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_poll()
2062 list_for_each_entry(resp, &sfp->rq_list, entry) { in sg_get_rq_mark()
2092 if (!list_empty(&sfp->rq_list)) { in sg_add_request()
2106 list_add_tail(&rp->entry, &sfp->rq_list); in sg_add_request()
2121 if (!sfp || !srp || list_empty(&sfp->rq_list)) in sg_remove_request()
2155 INIT_LIST_HEAD(&sfp->rq_list); in sg_add_sfp()
[all …]
|
| /linux/drivers/mtd/ |
| H A D | mtd_blkdevs.c | 110 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/drivers/block/aoe/ |
| H A D | aoe.h | 174 struct list_head rq_list; member
|
| H A D | aoedev.c | 231 list_for_each_entry_safe(rq, rqnext, &d->rq_list, queuelist) { in aoedev_downdev()
486 INIT_LIST_HEAD(&d->rq_list); in aoedev_by_aoeaddr()
|
| H A D | aoecmd.c | 858 rq = list_first_entry_or_null(&d->rq_list, struct request, in nextbuf()
|
| /linux/net/sunrpc/ |
| H A D | xprt.c | 1754 req = list_entry(xprt->free.next, struct rpc_rqst, rq_list); in xprt_alloc_slot()
1755 list_del(&req->rq_list); in xprt_alloc_slot()
1792 list_add(&req->rq_list, &xprt->free); in xprt_free_slot()
1802 req = list_first_entry(&xprt->free, struct rpc_rqst, rq_list); in xprt_free_all_slots()
1803 list_del(&req->rq_list); in xprt_free_all_slots()
1851 list_add(&req->rq_list, &xprt->free); in xprt_alloc()
|
| /linux/include/linux/sunrpc/ |
| H A D | xprt.h | 79 struct list_head rq_list; /* Slot allocation list */ member
|
| /linux/drivers/nvme/host/ |
| H A D | pci.c | 1471 static void nvme_submit_cmds(struct nvme_queue *nvmeq, struct rq_list *rqlist) in nvme_submit_cmds()
1502 static void nvme_queue_rqs(struct rq_list *rqlist) in nvme_queue_rqs()
1504 struct rq_list submit_list = { }; in nvme_queue_rqs()
1505 struct rq_list requeue_list = { }; in nvme_queue_rqs()
|
| /linux/drivers/block/null_blk/ |
| H A D | main.c | 1715 static void null_queue_rqs(struct rq_list *rqlist) in null_queue_rqs()
1717 struct rq_list requeue_list = {}; in null_queue_rqs()
|