diff options
-rw-r--r-- | block/cfq-iosched.c | 18 |
1 files changed, 16 insertions, 2 deletions
diff --git a/block/cfq-iosched.c b/block/cfq-iosched.c index 8917f2b3a783..70b48ea0e3e9 100644 --- a/block/cfq-iosched.c +++ b/block/cfq-iosched.c | |||
@@ -181,6 +181,8 @@ struct cfq_data { | |||
181 | * Fallback dummy cfqq for extreme OOM conditions | 181 | * Fallback dummy cfqq for extreme OOM conditions |
182 | */ | 182 | */ |
183 | struct cfq_queue oom_cfqq; | 183 | struct cfq_queue oom_cfqq; |
184 | |||
185 | unsigned long last_end_sync_rq; | ||
184 | }; | 186 | }; |
185 | 187 | ||
186 | enum cfqq_state_flags { | 188 | enum cfqq_state_flags { |
@@ -1314,6 +1316,8 @@ static int cfq_dispatch_requests(struct request_queue *q, int force) | |||
1314 | * Does this cfqq already have too much IO in flight? | 1316 | * Does this cfqq already have too much IO in flight? |
1315 | */ | 1317 | */ |
1316 | if (cfqq->dispatched >= max_dispatch) { | 1318 | if (cfqq->dispatched >= max_dispatch) { |
1319 | unsigned long load_at = cfqd->last_end_sync_rq + cfq_slice_sync; | ||
1320 | |||
1317 | /* | 1321 | /* |
1318 | * idle queue must always only have a single IO in flight | 1322 | * idle queue must always only have a single IO in flight |
1319 | */ | 1323 | */ |
@@ -1327,6 +1331,14 @@ static int cfq_dispatch_requests(struct request_queue *q, int force) | |||
1327 | return 0; | 1331 | return 0; |
1328 | 1332 | ||
1329 | /* | 1333 | /* |
1334 | * If a sync request has completed recently, don't overload | ||
1335 | * the dispatch queue yet with async requests. | ||
1336 | */ | ||
1337 | if (cfqd->cfq_desktop && !cfq_cfqq_sync(cfqq) | ||
1338 | && time_before(jiffies, load_at)) | ||
1339 | return 0; | ||
1340 | |||
1341 | /* | ||
1330 | * we are the only queue, allow up to 4 times of 'quantum' | 1342 | * we are the only queue, allow up to 4 times of 'quantum' |
1331 | */ | 1343 | */ |
1332 | if (cfqq->dispatched >= 4 * max_dispatch) | 1344 | if (cfqq->dispatched >= 4 * max_dispatch) |
@@ -2158,8 +2170,10 @@ static void cfq_completed_request(struct request_queue *q, struct request *rq) | |||
2158 | if (cfq_cfqq_sync(cfqq)) | 2170 | if (cfq_cfqq_sync(cfqq)) |
2159 | cfqd->sync_flight--; | 2171 | cfqd->sync_flight--; |
2160 | 2172 | ||
2161 | if (sync) | 2173 | if (sync) { |
2162 | RQ_CIC(rq)->last_end_request = now; | 2174 | RQ_CIC(rq)->last_end_request = now; |
2175 | cfqd->last_end_sync_rq = now; | ||
2176 | } | ||
2163 | 2177 | ||
2164 | /* | 2178 | /* |
2165 | * If this is the active queue, check if it needs to be expired, | 2179 | * If this is the active queue, check if it needs to be expired, |
@@ -2483,7 +2497,7 @@ static void *cfq_init_queue(struct request_queue *q) | |||
2483 | cfqd->cfq_slice_idle = cfq_slice_idle; | 2497 | cfqd->cfq_slice_idle = cfq_slice_idle; |
2484 | cfqd->cfq_desktop = 1; | 2498 | cfqd->cfq_desktop = 1; |
2485 | cfqd->hw_tag = 1; | 2499 | cfqd->hw_tag = 1; |
2486 | 2500 | cfqd->last_end_sync_rq = jiffies; | |
2487 | return cfqd; | 2501 | return cfqd; |
2488 | } | 2502 | } |
2489 | 2503 | ||