Lines Matching refs:plug

703 	struct blk_plug *plug;  in submit_bio_noacct()  local
707 plug = blk_mq_plug(bio); in submit_bio_noacct()
708 if (plug && plug->nowait) in submit_bio_noacct()
858 blk_flush_plug(current->plug, false); in bio_poll()
1035 void blk_start_plug_nr_ios(struct blk_plug *plug, unsigned short nr_ios) in blk_start_plug_nr_ios() argument
1042 if (tsk->plug) in blk_start_plug_nr_ios()
1045 plug->mq_list = NULL; in blk_start_plug_nr_ios()
1046 plug->cached_rq = NULL; in blk_start_plug_nr_ios()
1047 plug->nr_ios = min_t(unsigned short, nr_ios, BLK_MAX_REQUEST_COUNT); in blk_start_plug_nr_ios()
1048 plug->rq_count = 0; in blk_start_plug_nr_ios()
1049 plug->multiple_queues = false; in blk_start_plug_nr_ios()
1050 plug->has_elevator = false; in blk_start_plug_nr_ios()
1051 plug->nowait = false; in blk_start_plug_nr_ios()
1052 INIT_LIST_HEAD(&plug->cb_list); in blk_start_plug_nr_ios()
1058 tsk->plug = plug; in blk_start_plug_nr_ios()
1084 void blk_start_plug(struct blk_plug *plug) in blk_start_plug() argument
1086 blk_start_plug_nr_ios(plug, 1); in blk_start_plug()
1090 static void flush_plug_callbacks(struct blk_plug *plug, bool from_schedule) in flush_plug_callbacks() argument
1094 while (!list_empty(&plug->cb_list)) { in flush_plug_callbacks()
1095 list_splice_init(&plug->cb_list, &callbacks); in flush_plug_callbacks()
1110 struct blk_plug *plug = current->plug; in blk_check_plugged() local
1113 if (!plug) in blk_check_plugged()
1116 list_for_each_entry(cb, &plug->cb_list, list) in blk_check_plugged()
1126 list_add(&cb->list, &plug->cb_list); in blk_check_plugged()
1132 void __blk_flush_plug(struct blk_plug *plug, bool from_schedule) in __blk_flush_plug() argument
1134 if (!list_empty(&plug->cb_list)) in __blk_flush_plug()
1135 flush_plug_callbacks(plug, from_schedule); in __blk_flush_plug()
1136 if (!rq_list_empty(plug->mq_list)) in __blk_flush_plug()
1137 blk_mq_flush_plug_list(plug, from_schedule); in __blk_flush_plug()
1144 if (unlikely(!rq_list_empty(plug->cached_rq))) in __blk_flush_plug()
1145 blk_mq_free_plug_rqs(plug); in __blk_flush_plug()
1158 void blk_finish_plug(struct blk_plug *plug) in blk_finish_plug() argument
1160 if (plug == current->plug) { in blk_finish_plug()
1161 __blk_flush_plug(plug, false); in blk_finish_plug()
1162 current->plug = NULL; in blk_finish_plug()