提交 f6603783 编写于 作者: J Jens Axboe

block: only force kblockd unplugging from the schedule() path

For the explicit unplugging, we'd prefer to kick things off
immediately and not pay the penalty of the latency to switch
to kblockd. So let blk_finish_plug() do the run inline, while
the implicit-on-schedule-out unplug will punt to kblockd.
Signed-off-by: NJens Axboe <jaxboe@fusionio.com>
上级 88b996cd
...@@ -2662,16 +2662,17 @@ static int plug_rq_cmp(void *priv, struct list_head *a, struct list_head *b) ...@@ -2662,16 +2662,17 @@ static int plug_rq_cmp(void *priv, struct list_head *a, struct list_head *b)
return !(rqa->q <= rqb->q); return !(rqa->q <= rqb->q);
} }
static void queue_unplugged(struct request_queue *q, unsigned int depth) static void queue_unplugged(struct request_queue *q, unsigned int depth,
bool force_kblockd)
{ {
trace_block_unplug_io(q, depth); trace_block_unplug_io(q, depth);
__blk_run_queue(q, true); __blk_run_queue(q, force_kblockd);
if (q->unplugged_fn) if (q->unplugged_fn)
q->unplugged_fn(q); q->unplugged_fn(q);
} }
void blk_flush_plug_list(struct blk_plug *plug) void blk_flush_plug_list(struct blk_plug *plug, bool force_kblockd)
{ {
struct request_queue *q; struct request_queue *q;
unsigned long flags; unsigned long flags;
...@@ -2706,7 +2707,7 @@ void blk_flush_plug_list(struct blk_plug *plug) ...@@ -2706,7 +2707,7 @@ void blk_flush_plug_list(struct blk_plug *plug)
BUG_ON(!rq->q); BUG_ON(!rq->q);
if (rq->q != q) { if (rq->q != q) {
if (q) { if (q) {
queue_unplugged(q, depth); queue_unplugged(q, depth, force_kblockd);
spin_unlock(q->queue_lock); spin_unlock(q->queue_lock);
} }
q = rq->q; q = rq->q;
...@@ -2727,7 +2728,7 @@ void blk_flush_plug_list(struct blk_plug *plug) ...@@ -2727,7 +2728,7 @@ void blk_flush_plug_list(struct blk_plug *plug)
} }
if (q) { if (q) {
queue_unplugged(q, depth); queue_unplugged(q, depth, force_kblockd);
spin_unlock(q->queue_lock); spin_unlock(q->queue_lock);
} }
...@@ -2737,7 +2738,7 @@ EXPORT_SYMBOL(blk_flush_plug_list); ...@@ -2737,7 +2738,7 @@ EXPORT_SYMBOL(blk_flush_plug_list);
void blk_finish_plug(struct blk_plug *plug) void blk_finish_plug(struct blk_plug *plug)
{ {
blk_flush_plug_list(plug); blk_flush_plug_list(plug, false);
if (plug == current->plug) if (plug == current->plug)
current->plug = NULL; current->plug = NULL;
......
...@@ -865,14 +865,14 @@ struct blk_plug { ...@@ -865,14 +865,14 @@ struct blk_plug {
extern void blk_start_plug(struct blk_plug *); extern void blk_start_plug(struct blk_plug *);
extern void blk_finish_plug(struct blk_plug *); extern void blk_finish_plug(struct blk_plug *);
extern void blk_flush_plug_list(struct blk_plug *); extern void blk_flush_plug_list(struct blk_plug *, bool);
static inline void blk_flush_plug(struct task_struct *tsk) static inline void blk_flush_plug(struct task_struct *tsk)
{ {
struct blk_plug *plug = tsk->plug; struct blk_plug *plug = tsk->plug;
if (plug) if (plug)
blk_flush_plug_list(plug); blk_flush_plug_list(plug, true);
} }
static inline bool blk_needs_flush_plug(struct task_struct *tsk) static inline bool blk_needs_flush_plug(struct task_struct *tsk)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册