Lines Matching full:plug
810 struct blk_plug *plug; in submit_bio_checks() local
814 plug = blk_mq_plug(q, bio); in submit_bio_checks()
815 if (plug && plug->nowait) in submit_bio_checks()
1668 * @plug: The &struct blk_plug that needs to be initialized
1686 * plug. By flushing the pending I/O when the process goes to sleep, we avoid
1689 void blk_start_plug(struct blk_plug *plug) in blk_start_plug() argument
1694 * If this is a nested plug, don't actually assign it. in blk_start_plug()
1696 if (tsk->plug) in blk_start_plug()
1699 INIT_LIST_HEAD(&plug->mq_list); in blk_start_plug()
1700 INIT_LIST_HEAD(&plug->cb_list); in blk_start_plug()
1701 plug->rq_count = 0; in blk_start_plug()
1702 plug->multiple_queues = false; in blk_start_plug()
1703 plug->nowait = false; in blk_start_plug()
1709 tsk->plug = plug; in blk_start_plug()
1713 static void flush_plug_callbacks(struct blk_plug *plug, bool from_schedule) in flush_plug_callbacks() argument
1717 while (!list_empty(&plug->cb_list)) { in flush_plug_callbacks()
1718 list_splice_init(&plug->cb_list, &callbacks); in flush_plug_callbacks()
1733 struct blk_plug *plug = current->plug; in blk_check_plugged() local
1736 if (!plug) in blk_check_plugged()
1739 list_for_each_entry(cb, &plug->cb_list, list) in blk_check_plugged()
1749 list_add(&cb->list, &plug->cb_list); in blk_check_plugged()
1755 void blk_flush_plug_list(struct blk_plug *plug, bool from_schedule) in blk_flush_plug_list() argument
1757 flush_plug_callbacks(plug, from_schedule); in blk_flush_plug_list()
1759 if (!list_empty(&plug->mq_list)) in blk_flush_plug_list()
1760 blk_mq_flush_plug_list(plug, from_schedule); in blk_flush_plug_list()
1765 * @plug: The &struct blk_plug passed to blk_start_plug()
1773 void blk_finish_plug(struct blk_plug *plug) in blk_finish_plug() argument
1775 if (plug != current->plug) in blk_finish_plug()
1777 blk_flush_plug_list(plug, false); in blk_finish_plug()
1779 current->plug = NULL; in blk_finish_plug()