|
@@ -66,14 +66,14 @@ queue_requests_store(struct request_queue *q, const char *page, size_t count)
|
|
|
|
|
|
if (rl->count[BLK_RW_SYNC] >= q->nr_requests) {
|
|
|
blk_set_queue_full(q, BLK_RW_SYNC);
|
|
|
- } else if (rl->count[BLK_RW_SYNC]+1 <= q->nr_requests) {
|
|
|
+ } else {
|
|
|
blk_clear_queue_full(q, BLK_RW_SYNC);
|
|
|
wake_up(&rl->wait[BLK_RW_SYNC]);
|
|
|
}
|
|
|
|
|
|
if (rl->count[BLK_RW_ASYNC] >= q->nr_requests) {
|
|
|
blk_set_queue_full(q, BLK_RW_ASYNC);
|
|
|
- } else if (rl->count[BLK_RW_ASYNC]+1 <= q->nr_requests) {
|
|
|
+ } else {
|
|
|
blk_clear_queue_full(q, BLK_RW_ASYNC);
|
|
|
wake_up(&rl->wait[BLK_RW_ASYNC]);
|
|
|
}
|