Home
last modified time | relevance | path

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

/linux/block/
A Dblk-mq-sched.c93 list_for_each_entry(rq, rq_list, queuelist) { in blk_mq_dispatch_hctx_list()
100 list_splice_tail_init(rq_list, &hctx_list); in blk_mq_dispatch_hctx_list()
123 LIST_HEAD(rq_list); in __blk_mq_do_dispatch_sched()
168 list_add_tail(&rq->queuelist, &rq_list); in __blk_mq_do_dispatch_sched()
194 list_sort(NULL, &rq_list, sched_rq_cmp); in __blk_mq_do_dispatch_sched()
197 } while (!list_empty(&rq_list)); in __blk_mq_do_dispatch_sched()
240 LIST_HEAD(rq_list); in blk_mq_do_dispatch_ctx()
281 list_add(&rq->queuelist, &rq_list); in blk_mq_do_dispatch_ctx()
297 LIST_HEAD(rq_list); in __blk_mq_sched_dispatch_requests()
323 if (!list_empty(&rq_list)) { in __blk_mq_sched_dispatch_requests()
[all …]
A Dkyber-iosched.c149 struct list_head rq_list[KYBER_NUM_DOMAINS]; member
449 INIT_LIST_HEAD(&kcq->rq_list[i]); in kyber_ctx_queue_init()
574 struct list_head *rq_list = &kcq->rq_list[sched_domain]; in kyber_bio_merge() local
578 merged = blk_bio_list_merge(hctx->queue, rq_list, bio, nr_segs); in kyber_bio_merge()
590 struct list_head *rq_list, bool at_head) in kyber_insert_requests() argument
595 list_for_each_entry_safe(rq, next, rq_list, queuelist) { in kyber_insert_requests()
598 struct list_head *head = &kcq->rq_list[sched_domain]; in kyber_insert_requests()
671 list_splice_tail_init(&kcq->rq_list[flush_data->sched_domain], in flush_busy_kcq()
A Dblk-mq.c1091 LIST_HEAD(rq_list); in blk_mq_requeue_work()
1095 list_splice_init(&q->requeue_list, &rq_list); in blk_mq_requeue_work()
1098 list_for_each_entry_safe(rq, next, &rq_list, queuelist) { in blk_mq_requeue_work()
1115 while (!list_empty(&rq_list)) { in blk_mq_requeue_work()
1116 rq = list_entry(rq_list.next, struct request, queuelist); in blk_mq_requeue_work()
/linux/drivers/block/paride/
A Dpd.c240 struct list_head rq_list; member
411 if (list_empty(&disk->rq_list)) in set_next_request()
414 pd_req = list_first_entry(&disk->rq_list, in set_next_request()
765 list_add_tail(&bd->rq->queuelist, &disk->rq_list); in pd_queue_rq()
894 INIT_LIST_HEAD(&disk->rq_list); in pd_probe_drive()
A Dpf.c242 struct list_head rq_list; member
719 if (pf->present && !list_empty(&pf->rq_list)) { in set_next_request()
720 pf_req = list_first_entry(&pf->rq_list, struct request, in set_next_request()
781 list_add_tail(&bd->rq->queuelist, &pf->rq_list); in pf_queue_rq()
951 INIT_LIST_HEAD(&pf->rq_list); in pf_init_unit()
A Dpcd.c202 struct list_head rq_list; member
671 if (cd->present && !list_empty(&cd->rq_list)) { in set_next_request()
672 pcd_req = list_first_entry(&cd->rq_list, struct request, in set_next_request()
715 list_add_tail(&bd->rq->queuelist, &cd->rq_list); in pcd_queue_rq()
910 INIT_LIST_HEAD(&cd->rq_list); in pcd_init_unit()
/linux/drivers/scsi/
A Dsg.c145 struct list_head rq_list; /* head of request list */ member
868 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_fill_request_table()
1008 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_ioctl_common()
1020 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_ioctl_common()
1189 list_for_each_entry(srp, &sfp->rq_list, entry) { in sg_poll()
2087 if (!list_empty(&sfp->rq_list)) { in sg_add_request()
2101 list_add_tail(&rp->entry, &sfp->rq_list); in sg_add_request()
2116 if (!sfp || !srp || list_empty(&sfp->rq_list)) in sg_remove_request()
2141 INIT_LIST_HEAD(&sfp->rq_list); in sg_add_sfp()
2186 while (!list_empty(&sfp->rq_list)) { in sg_remove_sfp_usercontext()
[all …]
/linux/include/linux/mtd/
A Dblktrans.h33 struct list_head rq_list; member
/linux/drivers/mtd/
A Dmtd_blkdevs.c110 rq = list_first_entry_or_null(&dev->rq_list, struct request, queuelist); in mtd_next_request()
177 list_add_tail(&bd->rq->queuelist, &dev->rq_list); in mtd_queue_rq()
366 INIT_LIST_HEAD(&new->rq_list); in add_mtd_blktrans_dev()
/linux/net/sunrpc/
A Dxprt.c1721 req = list_entry(xprt->free.next, struct rpc_rqst, rq_list); in xprt_alloc_slot()
1722 list_del(&req->rq_list); in xprt_alloc_slot()
1759 list_add(&req->rq_list, &xprt->free); in xprt_free_slot()
1769 req = list_first_entry(&xprt->free, struct rpc_rqst, rq_list); in xprt_free_all_slots()
1770 list_del(&req->rq_list); in xprt_free_all_slots()
1818 list_add(&req->rq_list, &xprt->free); in xprt_alloc()
/linux/drivers/block/aoe/
A Daoe.h173 struct list_head rq_list; member
A Daoedev.c474 INIT_LIST_HEAD(&d->rq_list); in aoedev_by_aoeaddr()
A Daoeblk.c277 list_add_tail(&bd->rq->queuelist, &d->rq_list); in aoeblk_queue_rq()
A Daoecmd.c850 rq = list_first_entry_or_null(&d->rq_list, struct request, in nextbuf()
/linux/include/linux/sunrpc/
A Dxprt.h86 struct list_head rq_list; /* Slot allocation list */ member
/linux/drivers/infiniband/hw/hns/
A Dhns_roce_cq.c326 INIT_LIST_HEAD(&hr_cq->rq_list); in set_cq_param()
A Dhns_roce_device.h464 struct list_head rq_list; /* all qps on this recv cq */ member
A Dhns_roce_qp.c291 list_add_tail(&hr_qp->rq_node, &hr_recv_cq->rq_list); in add_qp_to_list()
A Dhns_roce_hw_v2.c3473 list_for_each_entry(hr_qp, &hr_cq->rq_list, rq_node) { in hns_roce_v2_sw_poll_cq()

Completed in 80 milliseconds