| /linux-6.3-rc2/block/ |
| A D | blk-mq-sched.c | 66 list_for_each_entry(rq, rq_list, queuelist) { in blk_mq_dispatch_hctx_list()
73 list_splice_tail_init(rq_list, &hctx_list); in blk_mq_dispatch_hctx_list()
96 LIST_HEAD(rq_list); in __blk_mq_do_dispatch_sched()
141 list_add_tail(&rq->queuelist, &rq_list); in __blk_mq_do_dispatch_sched()
167 list_sort(NULL, &rq_list, sched_rq_cmp); in __blk_mq_do_dispatch_sched()
170 } while (!list_empty(&rq_list)); in __blk_mq_do_dispatch_sched()
220 LIST_HEAD(rq_list); in blk_mq_do_dispatch_ctx()
261 list_add(&rq->queuelist, &rq_list); in blk_mq_do_dispatch_ctx()
277 LIST_HEAD(rq_list); in __blk_mq_sched_dispatch_requests()
303 if (!list_empty(&rq_list)) { in __blk_mq_sched_dispatch_requests()
[all …]
|
| A D | kyber-iosched.c | 149 struct list_head rq_list[KYBER_NUM_DOMAINS]; member
452 INIT_LIST_HEAD(&kcq->rq_list[i]); in kyber_ctx_queue_init()
577 struct list_head *rq_list = &kcq->rq_list[sched_domain]; in kyber_bio_merge() local
581 merged = blk_bio_list_merge(hctx->queue, rq_list, bio, nr_segs); in kyber_bio_merge()
593 struct list_head *rq_list, bool at_head) in kyber_insert_requests() argument
598 list_for_each_entry_safe(rq, next, rq_list, queuelist) { in kyber_insert_requests()
601 struct list_head *head = &kcq->rq_list[sched_domain]; in kyber_insert_requests()
674 list_splice_tail_init(&kcq->rq_list[flush_data->sched_domain], in flush_busy_kcq()
|
| A D | blk-mq.c | 1452 LIST_HEAD(rq_list); in blk_mq_requeue_work()
1456 list_splice_init(&q->requeue_list, &rq_list); in blk_mq_requeue_work()
1459 list_for_each_entry_safe(rq, next, &rq_list, queuelist) { in blk_mq_requeue_work()
1476 while (!list_empty(&rq_list)) { in blk_mq_requeue_work()
1477 rq = list_entry(rq_list.next, struct request, queuelist); in blk_mq_requeue_work()
|
| /linux-6.3-rc2/include/linux/mtd/ |
| A D | blktrans.h | 33 struct list_head rq_list; member
|
| /linux-6.3-rc2/drivers/scsi/ |
| A D | sg.c | 149 struct list_head rq_list; /* head of request list */ member
864 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_fill_request_table()
1002 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_ioctl_common()
1014 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_ioctl_common()
1183 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_poll()
2097 if (!list_empty(&sfp->rq_list)) { in sg_add_request()
2111 list_add_tail(&rp->entry, &sfp->rq_list); in sg_add_request()
2126 if (!sfp || !srp || list_empty(&sfp->rq_list)) in sg_remove_request()
2160 INIT_LIST_HEAD(&sfp->rq_list); in sg_add_sfp()
2205 while (!list_empty(&sfp->rq_list)) { in sg_remove_sfp_usercontext()
[all …]
|
| /linux-6.3-rc2/drivers/mtd/ |
| 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()
369 INIT_LIST_HEAD(&new->rq_list); in add_mtd_blktrans_dev()
|
| /linux-6.3-rc2/drivers/block/aoe/ |
| A D | aoe.h | 173 struct list_head rq_list; member
|
| A D | aoedev.c | 474 INIT_LIST_HEAD(&d->rq_list); in aoedev_by_aoeaddr()
|
| A D | aoeblk.c | 265 list_add_tail(&bd->rq->queuelist, &d->rq_list); in aoeblk_queue_rq()
|
| A D | aoecmd.c | 849 rq = list_first_entry_or_null(&d->rq_list, struct request, in nextbuf()
|
| /linux-6.3-rc2/net/sunrpc/ |
| A D | xprt.c | 1726 req = list_entry(xprt->free.next, struct rpc_rqst, rq_list); in xprt_alloc_slot()
1727 list_del(&req->rq_list); in xprt_alloc_slot()
1764 list_add(&req->rq_list, &xprt->free); in xprt_free_slot()
1774 req = list_first_entry(&xprt->free, struct rpc_rqst, rq_list); in xprt_free_all_slots()
1775 list_del(&req->rq_list); in xprt_free_all_slots()
1823 list_add(&req->rq_list, &xprt->free); in xprt_alloc()
|
| /linux-6.3-rc2/include/linux/sunrpc/ |
| A D | xprt.h | 86 struct list_head rq_list; /* Slot allocation list */ member
|
| /linux-6.3-rc2/drivers/infiniband/hw/hns/ |
| A D | hns_roce_cq.c | 327 INIT_LIST_HEAD(&hr_cq->rq_list); in set_cq_param()
|
| A D | hns_roce_device.h | 421 struct list_head rq_list; /* all qps on this recv cq */ member
|
| A D | hns_roce_qp.c | 260 list_add_tail(&hr_qp->rq_node, &hr_recv_cq->rq_list); in add_qp_to_list()
|
| A D | hns_roce_hw_v2.c | 3759 list_for_each_entry(hr_qp, &hr_cq->rq_list, rq_node) { in hns_roce_v2_sw_poll_cq()
|