Commit c89511ab authored by Mel Gorman's avatar Mel Gorman Committed by Linus Torvalds

mm: compaction: Restart compaction from near where it left off

This is almost entirely based on Rik's previous patches and discussions
with him about how this might be implemented.

Order > 0 compaction stops when enough free pages of the correct page
order have been coalesced.  When doing subsequent higher order
allocations, it is possible for compaction to be invoked many times.

However, the compaction code always starts out looking for things to
compact at the start of the zone, and for free pages to compact things to
at the end of the zone.

This can cause quadratic behaviour, with isolate_freepages starting at the
end of the zone each time, even though previous invocations of the
compaction code already filled up all free memory on that end of the zone.
 This can cause isolate_freepages to take enormous amounts of CPU with
certain workloads on larger memory systems.

This patch caches where the migration and free scanner should start from
on subsequent compaction invocations using the pageblock-skip information.
 When compaction starts it begins from the cached restart points and will
update the cached restart points until a page is isolated or a pageblock
is skipped that would have been scanned by synchronous compaction.
Signed-off-by: default avatarMel Gorman <mgorman@suse.de>
Acked-by: default avatarRik van Riel <riel@redhat.com>
Cc: Richard Davies <richard@arachsys.com>
Cc: Shaohua Li <shli@kernel.org>
Cc: Avi Kivity <avi@redhat.com>
Acked-by: default avatarRafael Aquini <aquini@redhat.com>
Cc: Fengguang Wu <fengguang.wu@intel.com>
Signed-off-by: default avatarAndrew Morton <akpm@linux-foundation.org>
Signed-off-by: default avatarLinus Torvalds <torvalds@linux-foundation.org>
parent bb13ffeb
...@@ -371,6 +371,10 @@ struct zone { ...@@ -371,6 +371,10 @@ struct zone {
int all_unreclaimable; /* All pages pinned */ int all_unreclaimable; /* All pages pinned */
#if defined CONFIG_COMPACTION || defined CONFIG_CMA #if defined CONFIG_COMPACTION || defined CONFIG_CMA
unsigned long compact_blockskip_expire; unsigned long compact_blockskip_expire;
/* pfns where compaction scanners should start */
unsigned long compact_cached_free_pfn;
unsigned long compact_cached_migrate_pfn;
#endif #endif
#ifdef CONFIG_MEMORY_HOTPLUG #ifdef CONFIG_MEMORY_HOTPLUG
/* see spanned/present_pages for more description */ /* see spanned/present_pages for more description */
......
...@@ -80,6 +80,9 @@ static void reset_isolation_suitable(struct zone *zone) ...@@ -80,6 +80,9 @@ static void reset_isolation_suitable(struct zone *zone)
*/ */
if (time_before(jiffies, zone->compact_blockskip_expire)) if (time_before(jiffies, zone->compact_blockskip_expire))
return; return;
zone->compact_cached_migrate_pfn = start_pfn;
zone->compact_cached_free_pfn = end_pfn;
zone->compact_blockskip_expire = jiffies + (HZ * 5); zone->compact_blockskip_expire = jiffies + (HZ * 5);
/* Walk the zone and mark every pageblock as suitable for isolation */ /* Walk the zone and mark every pageblock as suitable for isolation */
...@@ -103,13 +106,29 @@ static void reset_isolation_suitable(struct zone *zone) ...@@ -103,13 +106,29 @@ static void reset_isolation_suitable(struct zone *zone)
* If no pages were isolated then mark this pageblock to be skipped in the * If no pages were isolated then mark this pageblock to be skipped in the
* future. The information is later cleared by reset_isolation_suitable(). * future. The information is later cleared by reset_isolation_suitable().
*/ */
static void update_pageblock_skip(struct page *page, unsigned long nr_isolated) static void update_pageblock_skip(struct compact_control *cc,
struct page *page, unsigned long nr_isolated,
bool migrate_scanner)
{ {
struct zone *zone = cc->zone;
if (!page) if (!page)
return; return;
if (!nr_isolated) if (!nr_isolated) {
unsigned long pfn = page_to_pfn(page);
set_pageblock_skip(page); set_pageblock_skip(page);
/* Update where compaction should restart */
if (migrate_scanner) {
if (!cc->finished_update_migrate &&
pfn > zone->compact_cached_migrate_pfn)
zone->compact_cached_migrate_pfn = pfn;
} else {
if (!cc->finished_update_free &&
pfn < zone->compact_cached_free_pfn)
zone->compact_cached_free_pfn = pfn;
}
}
} }
#else #else
static inline bool isolation_suitable(struct compact_control *cc, static inline bool isolation_suitable(struct compact_control *cc,
...@@ -118,7 +137,9 @@ static inline bool isolation_suitable(struct compact_control *cc, ...@@ -118,7 +137,9 @@ static inline bool isolation_suitable(struct compact_control *cc,
return true; return true;
} }
static void update_pageblock_skip(struct page *page, unsigned long nr_isolated) static void update_pageblock_skip(struct compact_control *cc,
struct page *page, unsigned long nr_isolated,
bool migrate_scanner)
{ {
} }
#endif /* CONFIG_COMPACTION */ #endif /* CONFIG_COMPACTION */
...@@ -327,7 +348,7 @@ static unsigned long isolate_freepages_block(struct compact_control *cc, ...@@ -327,7 +348,7 @@ static unsigned long isolate_freepages_block(struct compact_control *cc,
/* Update the pageblock-skip if the whole pageblock was scanned */ /* Update the pageblock-skip if the whole pageblock was scanned */
if (blockpfn == end_pfn) if (blockpfn == end_pfn)
update_pageblock_skip(valid_page, total_isolated); update_pageblock_skip(cc, valid_page, total_isolated, false);
return total_isolated; return total_isolated;
} }
...@@ -533,6 +554,7 @@ isolate_migratepages_range(struct zone *zone, struct compact_control *cc, ...@@ -533,6 +554,7 @@ isolate_migratepages_range(struct zone *zone, struct compact_control *cc,
*/ */
if (!cc->sync && last_pageblock_nr != pageblock_nr && if (!cc->sync && last_pageblock_nr != pageblock_nr &&
!migrate_async_suitable(get_pageblock_migratetype(page))) { !migrate_async_suitable(get_pageblock_migratetype(page))) {
cc->finished_update_migrate = true;
goto next_pageblock; goto next_pageblock;
} }
...@@ -583,6 +605,7 @@ isolate_migratepages_range(struct zone *zone, struct compact_control *cc, ...@@ -583,6 +605,7 @@ isolate_migratepages_range(struct zone *zone, struct compact_control *cc,
VM_BUG_ON(PageTransCompound(page)); VM_BUG_ON(PageTransCompound(page));
/* Successfully isolated */ /* Successfully isolated */
cc->finished_update_migrate = true;
del_page_from_lru_list(page, lruvec, page_lru(page)); del_page_from_lru_list(page, lruvec, page_lru(page));
list_add(&page->lru, migratelist); list_add(&page->lru, migratelist);
cc->nr_migratepages++; cc->nr_migratepages++;
...@@ -609,7 +632,7 @@ isolate_migratepages_range(struct zone *zone, struct compact_control *cc, ...@@ -609,7 +632,7 @@ isolate_migratepages_range(struct zone *zone, struct compact_control *cc,
/* Update the pageblock-skip if the whole pageblock was scanned */ /* Update the pageblock-skip if the whole pageblock was scanned */
if (low_pfn == end_pfn) if (low_pfn == end_pfn)
update_pageblock_skip(valid_page, nr_isolated); update_pageblock_skip(cc, valid_page, nr_isolated, true);
trace_mm_compaction_isolate_migratepages(nr_scanned, nr_isolated); trace_mm_compaction_isolate_migratepages(nr_scanned, nr_isolated);
...@@ -690,9 +713,11 @@ static void isolate_freepages(struct zone *zone, ...@@ -690,9 +713,11 @@ static void isolate_freepages(struct zone *zone,
* looking for free pages, the search will restart here as * looking for free pages, the search will restart here as
* page migration may have returned some pages to the allocator * page migration may have returned some pages to the allocator
*/ */
if (isolated) if (isolated) {
cc->finished_update_free = true;
high_pfn = max(high_pfn, pfn); high_pfn = max(high_pfn, pfn);
} }
}
/* split_free_page does not map the pages */ /* split_free_page does not map the pages */
map_pages(freelist); map_pages(freelist);
...@@ -888,6 +913,8 @@ unsigned long compaction_suitable(struct zone *zone, int order) ...@@ -888,6 +913,8 @@ unsigned long compaction_suitable(struct zone *zone, int order)
static int compact_zone(struct zone *zone, struct compact_control *cc) static int compact_zone(struct zone *zone, struct compact_control *cc)
{ {
int ret; int ret;
unsigned long start_pfn = zone->zone_start_pfn;
unsigned long end_pfn = zone->zone_start_pfn + zone->spanned_pages;
ret = compaction_suitable(zone, cc->order); ret = compaction_suitable(zone, cc->order);
switch (ret) { switch (ret) {
...@@ -900,10 +927,21 @@ static int compact_zone(struct zone *zone, struct compact_control *cc) ...@@ -900,10 +927,21 @@ static int compact_zone(struct zone *zone, struct compact_control *cc)
; ;
} }
/* Setup to move all movable pages to the end of the zone */ /*
cc->migrate_pfn = zone->zone_start_pfn; * Setup to move all movable pages to the end of the zone. Used cached
cc->free_pfn = cc->migrate_pfn + zone->spanned_pages; * information on where the scanners should start but check that it
cc->free_pfn &= ~(pageblock_nr_pages-1); * is initialised by ensuring the values are within zone boundaries.
*/
cc->migrate_pfn = zone->compact_cached_migrate_pfn;
cc->free_pfn = zone->compact_cached_free_pfn;
if (cc->free_pfn < start_pfn || cc->free_pfn > end_pfn) {
cc->free_pfn = end_pfn & ~(pageblock_nr_pages-1);
zone->compact_cached_free_pfn = cc->free_pfn;
}
if (cc->migrate_pfn < start_pfn || cc->migrate_pfn > end_pfn) {
cc->migrate_pfn = start_pfn;
zone->compact_cached_migrate_pfn = cc->migrate_pfn;
}
/* Clear pageblock skip if there are numerous alloc failures */ /* Clear pageblock skip if there are numerous alloc failures */
if (zone->compact_defer_shift == COMPACT_MAX_DEFER_SHIFT) if (zone->compact_defer_shift == COMPACT_MAX_DEFER_SHIFT)
......
...@@ -121,6 +121,10 @@ struct compact_control { ...@@ -121,6 +121,10 @@ struct compact_control {
unsigned long migrate_pfn; /* isolate_migratepages search base */ unsigned long migrate_pfn; /* isolate_migratepages search base */
bool sync; /* Synchronous migration */ bool sync; /* Synchronous migration */
bool ignore_skip_hint; /* Scan blocks even if marked skip */ bool ignore_skip_hint; /* Scan blocks even if marked skip */
bool finished_update_free; /* True when the zone cached pfns are
* no longer being updated
*/
bool finished_update_migrate;
int order; /* order a direct compactor needs */ int order; /* order a direct compactor needs */
int migratetype; /* MOVABLE, RECLAIMABLE etc */ int migratetype; /* MOVABLE, RECLAIMABLE etc */
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment