Skip to content

Commit

Permalink
mm: compaction: refactor __compaction_suitable()
Browse files Browse the repository at this point in the history
__compaction_suitable() is supposed to check for available migration
targets. However, it also checks whether the operation was requested
via /proc/sys/vm/compact_memory, and whether the original allocation
request can already succeed. These don't apply to all callsites.

Move the checks out to the callers, so that later patches can deal
with them one by one. No functional change intended.

Signed-off-by: Johannes Weiner <[email protected]>
  • Loading branch information
hnaz committed Mar 9, 2023
1 parent ad60dfc commit 124a390
Show file tree
Hide file tree
Showing 3 changed files with 72 additions and 41 deletions.
4 changes: 2 additions & 2 deletions include/linux/compaction.h
Original file line number Diff line number Diff line change
Expand Up @@ -98,7 +98,7 @@ extern enum compact_result try_to_compact_pages(gfp_t gfp_mask,
struct capture_control *capc);
extern void reset_isolation_suitable(pg_data_t *pgdat);
extern enum compact_result compaction_suitable(struct zone *zone, int order,
unsigned int alloc_flags, int highest_zoneidx);
int highest_zoneidx);

extern void compaction_defer_reset(struct zone *zone, int order,
bool alloc_success);
Expand Down Expand Up @@ -188,7 +188,7 @@ static inline void reset_isolation_suitable(pg_data_t *pgdat)
}

static inline enum compact_result compaction_suitable(struct zone *zone, int order,
int alloc_flags, int highest_zoneidx)
int highest_zoneidx)
{
return COMPACT_SKIPPED;
}
Expand Down
74 changes: 49 additions & 25 deletions mm/compaction.c
Original file line number Diff line number Diff line change
Expand Up @@ -2173,24 +2173,10 @@ static enum compact_result compact_finished(struct compact_control *cc)
}

static enum compact_result __compaction_suitable(struct zone *zone, int order,
unsigned int alloc_flags,
int highest_zoneidx,
unsigned long wmark_target)
{
unsigned long watermark;

if (is_via_compact_memory(order))
return COMPACT_CONTINUE;

watermark = wmark_pages(zone, alloc_flags & ALLOC_WMARK_MASK);
/*
* If watermarks for high-order allocation are already met, there
* should be no need for compaction at all.
*/
if (zone_watermark_ok(zone, order, watermark, highest_zoneidx,
alloc_flags))
return COMPACT_SUCCESS;

/*
* Watermarks for order-0 must be met for compaction to be able to
* isolate free pages for migration targets. This means that the
Expand Down Expand Up @@ -2223,7 +2209,6 @@ static enum compact_result __compaction_suitable(struct zone *zone, int order,
* COMPACT_CONTINUE - If compaction should run now
*/
enum compact_result compaction_suitable(struct zone *zone, int order,
unsigned int alloc_flags,
int highest_zoneidx)
{
unsigned long free_pages;
Expand Down Expand Up @@ -2278,6 +2263,16 @@ bool compaction_zonelist_suitable(struct alloc_context *ac, int order,
for_each_zone_zonelist_nodemask(zone, z, ac->zonelist,
ac->highest_zoneidx, ac->nodemask) {
unsigned long available;
unsigned long watermark;

if (is_via_compact_memory(order))
return true;

/* Allocation can already succeed, nothing to do */
watermark = wmark_pages(zone, alloc_flags & ALLOC_WMARK_MASK);
if (zone_watermark_ok(zone, order, watermark,
ac->highest_zoneidx, alloc_flags))
continue;

available = zone_page_state_snapshot(zone, NR_FREE_MOVABLE);
available += zone_page_state_snapshot(zone, NR_FREE_CMA_PAGES);
Expand Down Expand Up @@ -2320,14 +2315,26 @@ compact_zone(struct compact_control *cc, struct capture_control *capc)
INIT_LIST_HEAD(&cc->migratepages);

cc->migratetype = gfp_migratetype(cc->gfp_mask);
ret = compaction_suitable(cc->zone, cc->order, cc->alloc_flags,
cc->highest_zoneidx);
/* Compaction is likely to fail */
if (ret == COMPACT_SUCCESS || ret == COMPACT_SKIPPED)
return ret;

/* huh, compaction_suitable is returning something unexpected */
VM_BUG_ON(ret != COMPACT_CONTINUE);
if (!is_via_compact_memory(cc->order)) {
unsigned long watermark;

/* Allocation can already succeed, nothing to do */
watermark = wmark_pages(cc->zone,
cc->alloc_flags & ALLOC_WMARK_MASK);
if (zone_watermark_ok(cc->zone, cc->order, watermark,
cc->highest_zoneidx, cc->alloc_flags))
return COMPACT_SUCCESS;

ret = compaction_suitable(cc->zone, cc->order,
cc->highest_zoneidx);
/* Compaction is likely to fail */
if (ret == COMPACT_SKIPPED)
return ret;

/* huh, compaction_suitable is returning something unexpected */
VM_BUG_ON(ret != COMPACT_CONTINUE);
}

/*
* Clear pageblock skip if there were failures recently and compaction
Expand Down Expand Up @@ -2805,7 +2812,16 @@ static bool kcompactd_node_suitable(pg_data_t *pgdat)
if (!populated_zone(zone))
continue;

if (compaction_suitable(zone, pgdat->kcompactd_max_order, 0,
if (is_via_compact_memory(pgdat->kcompactd_max_order))
return true;

/* Allocation can already succeed, check other zones */
if (zone_watermark_ok(zone, pgdat->kcompactd_max_order,
min_wmark_pages(zone),
highest_zoneidx, 0))
continue;

if (compaction_suitable(zone, pgdat->kcompactd_max_order,
highest_zoneidx) == COMPACT_CONTINUE)
return true;
}
Expand Down Expand Up @@ -2843,10 +2859,18 @@ static void kcompactd_do_work(pg_data_t *pgdat)
if (compaction_deferred(zone, cc.order))
continue;

if (compaction_suitable(zone, cc.order, 0, zoneid) !=
COMPACT_CONTINUE)
if (is_via_compact_memory(cc.order))
goto compact;

/* Allocation can already succeed, nothing to do */
if (zone_watermark_ok(zone, cc.order,
min_wmark_pages(zone), zoneid, 0))
continue;

if (compaction_suitable(zone, cc.order,
zoneid) != COMPACT_CONTINUE)
continue;
compact:
if (kthread_should_stop())
return;

Expand Down
35 changes: 21 additions & 14 deletions mm/vmscan.c
Original file line number Diff line number Diff line change
Expand Up @@ -6076,14 +6076,17 @@ static inline bool should_continue_reclaim(struct pglist_data *pgdat,
if (!managed_zone(zone))
continue;

switch (compaction_suitable(zone, sc->order, 0, sc->reclaim_idx)) {
case COMPACT_SUCCESS:
case COMPACT_CONTINUE:
if (sc->order == -1) /* is_via_compact_memory() */
return false;

/* Allocation can already succeed, nothing to do */
if (zone_watermark_ok(zone, sc->order, min_wmark_pages(zone),
sc->reclaim_idx, 0))
return false;

if (compaction_suitable(zone, sc->order,
sc->reclaim_idx) == COMPACT_CONTINUE)
return false;
default:
/* check next zone */
;
}
}

/*
Expand Down Expand Up @@ -6271,16 +6274,20 @@ static inline bool compaction_ready(struct zone *zone, struct scan_control *sc)
{
unsigned long watermark;
unsigned long free_pages;
enum compact_result suitable;

suitable = compaction_suitable(zone, sc->order, 0, sc->reclaim_idx);
if (suitable == COMPACT_SUCCESS)
/* Allocation should succeed already. Don't reclaim. */
if (sc->order == -1) /* is_via_compact_memory() */
goto suitable;

/* Allocation can already succeed, nothing to do */
if (zone_watermark_ok(zone, sc->order, min_wmark_pages(zone),
sc->reclaim_idx, 0))
return true;
if (suitable == COMPACT_SKIPPED)
/* Compaction cannot yet proceed. Do reclaim. */
return false;

/* Compaction cannot yet proceed. Do reclaim. */
if (compaction_suitable(zone, sc->order,
sc->reclaim_idx) == COMPACT_SKIPPED)
return false;
suitable:
/*
* Compaction is already possible, but it takes time to run and there
* are potentially other callers using the pages just freed. So proceed
Expand Down

0 comments on commit 124a390

Please sign in to comment.