Lines Matching refs:plug
1901 void blk_mq_flush_plug_list(struct blk_plug *plug, bool from_schedule) in blk_mq_flush_plug_list() argument
1905 if (list_empty(&plug->mq_list)) in blk_mq_flush_plug_list()
1907 list_splice_init(&plug->mq_list, &list); in blk_mq_flush_plug_list()
1909 if (plug->rq_count > 2 && plug->multiple_queues) in blk_mq_flush_plug_list()
1912 plug->rq_count = 0; in blk_mq_flush_plug_list()
2117 static void blk_add_rq_to_plug(struct blk_plug *plug, struct request *rq) in blk_add_rq_to_plug() argument
2119 list_add_tail(&rq->queuelist, &plug->mq_list); in blk_add_rq_to_plug()
2120 plug->rq_count++; in blk_add_rq_to_plug()
2121 if (!plug->multiple_queues && !list_is_singular(&plug->mq_list)) { in blk_add_rq_to_plug()
2124 tmp = list_first_entry(&plug->mq_list, struct request, in blk_add_rq_to_plug()
2127 plug->multiple_queues = true; in blk_add_rq_to_plug()
2155 struct blk_plug *plug; in blk_mq_submit_bio() local
2201 plug = blk_mq_plug(q, bio); in blk_mq_submit_bio()
2206 } else if (plug && (q->nr_hw_queues == 1 || q->mq_ops->commit_rqs || in blk_mq_submit_bio()
2215 unsigned int request_count = plug->rq_count; in blk_mq_submit_bio()
2221 last = list_entry_rq(plug->mq_list.prev); in blk_mq_submit_bio()
2225 blk_flush_plug_list(plug, false); in blk_mq_submit_bio()
2229 blk_add_rq_to_plug(plug, rq); in blk_mq_submit_bio()
2233 } else if (plug && !blk_queue_nomerges(q)) { in blk_mq_submit_bio()
2241 if (list_empty(&plug->mq_list)) in blk_mq_submit_bio()
2245 plug->rq_count--; in blk_mq_submit_bio()
2247 blk_add_rq_to_plug(plug, rq); in blk_mq_submit_bio()
3856 if (current->plug) in blk_poll()
3857 blk_flush_plug_list(current->plug, false); in blk_poll()