diff options
-rw-r--r-- | mm/readahead.c | 12 |
1 files changed, 10 insertions, 2 deletions
diff --git a/mm/readahead.c b/mm/readahead.c index 9f62b7151100..a59ea70527b9 100644 --- a/mm/readahead.c +++ b/mm/readahead.c | |||
@@ -386,6 +386,7 @@ ondemand_readahead(struct address_space *mapping, | |||
386 | { | 386 | { |
387 | struct backing_dev_info *bdi = inode_to_bdi(mapping->host); | 387 | struct backing_dev_info *bdi = inode_to_bdi(mapping->host); |
388 | unsigned long max_pages = ra->ra_pages; | 388 | unsigned long max_pages = ra->ra_pages; |
389 | unsigned long add_pages; | ||
389 | pgoff_t prev_offset; | 390 | pgoff_t prev_offset; |
390 | 391 | ||
391 | /* | 392 | /* |
@@ -475,10 +476,17 @@ readit: | |||
475 | * Will this read hit the readahead marker made by itself? | 476 | * Will this read hit the readahead marker made by itself? |
476 | * If so, trigger the readahead marker hit now, and merge | 477 | * If so, trigger the readahead marker hit now, and merge |
477 | * the resulted next readahead window into the current one. | 478 | * the resulted next readahead window into the current one. |
479 | * Take care of maximum IO pages as above. | ||
478 | */ | 480 | */ |
479 | if (offset == ra->start && ra->size == ra->async_size) { | 481 | if (offset == ra->start && ra->size == ra->async_size) { |
480 | ra->async_size = get_next_ra_size(ra, max_pages); | 482 | add_pages = get_next_ra_size(ra, max_pages); |
481 | ra->size += ra->async_size; | 483 | if (ra->size + add_pages <= max_pages) { |
484 | ra->async_size = add_pages; | ||
485 | ra->size += add_pages; | ||
486 | } else { | ||
487 | ra->size = max_pages; | ||
488 | ra->async_size = max_pages >> 1; | ||
489 | } | ||
482 | } | 490 | } |
483 | 491 | ||
484 | return ra_submit(ra, mapping, filp); | 492 | return ra_submit(ra, mapping, filp); |