Skip to content

Commit

Permalink
---
Browse files Browse the repository at this point in the history
yaml
---
r: 242299
b: refs/heads/master
c: eda5e0c
h: refs/heads/master
i:
  242297: 8714ed2
  242295: 19fd935
v: v3
  • Loading branch information
Justin TerAvest authored and Jens Axboe committed Mar 22, 2011
1 parent 4721358 commit f0ea02f
Show file tree
Hide file tree
Showing 2 changed files with 24 additions and 17 deletions.
2 changes: 1 addition & 1 deletion [refs]
Original file line number Diff line number Diff line change
@@ -1,2 +1,2 @@
---
refs/heads/master: 1e9bb8808ac11094d711d20d580e7b45a4992d0c
refs/heads/master: eda5e0c91fed2d2a38a341b0957263406d330274
39 changes: 23 additions & 16 deletions trunk/block/cfq-iosched.c
Original file line number Diff line number Diff line change
Expand Up @@ -1620,27 +1620,33 @@ static inline void cfq_del_timer(struct cfq_data *cfqd, struct cfq_queue *cfqq)
cfq_blkiocg_update_idle_time_stats(&cfqq->cfqg->blkg);
}

static void cfq_clear_queue_stats(struct cfq_data *cfqd,
struct cfq_queue *cfqq)
{
cfq_blkiocg_update_avg_queue_size_stats(&cfqq->cfqg->blkg);
cfqq->slice_start = 0;
cfqq->dispatch_start = jiffies;
cfqq->allocated_slice = 0;
cfqq->slice_end = 0;
cfqq->slice_dispatch = 0;
cfqq->nr_sectors = 0;

cfq_clear_cfqq_wait_request(cfqq);
cfq_clear_cfqq_must_dispatch(cfqq);
cfq_clear_cfqq_must_alloc_slice(cfqq);
cfq_clear_cfqq_fifo_expire(cfqq);
cfq_mark_cfqq_slice_new(cfqq);

cfq_del_timer(cfqd, cfqq);
}

static void __cfq_set_active_queue(struct cfq_data *cfqd,
struct cfq_queue *cfqq)
{
if (cfqq) {
cfq_log_cfqq(cfqd, cfqq, "set_active wl_prio:%d wl_type:%d",
cfqd->serving_prio, cfqd->serving_type);
cfq_blkiocg_update_avg_queue_size_stats(&cfqq->cfqg->blkg);
cfqq->slice_start = 0;
cfqq->dispatch_start = jiffies;
cfqq->allocated_slice = 0;
cfqq->slice_end = 0;
cfqq->slice_dispatch = 0;
cfqq->nr_sectors = 0;

cfq_clear_cfqq_wait_request(cfqq);
cfq_clear_cfqq_must_dispatch(cfqq);
cfq_clear_cfqq_must_alloc_slice(cfqq);
cfq_clear_cfqq_fifo_expire(cfqq);
cfq_mark_cfqq_slice_new(cfqq);

cfq_del_timer(cfqd, cfqq);
cfq_clear_queue_stats(cfqd, cfqq);
}

cfqd->active_queue = cfqq;
Expand Down Expand Up @@ -3332,7 +3338,8 @@ static void cfq_preempt_queue(struct cfq_data *cfqd, struct cfq_queue *cfqq)
BUG_ON(!cfq_cfqq_on_rr(cfqq));

cfq_service_tree_add(cfqd, cfqq, 1);
__cfq_set_active_queue(cfqd, cfqq);

cfq_clear_queue_stats(cfqd, cfqq);
}

/*
Expand Down

0 comments on commit f0ea02f

Please sign in to comment.