Commit 7ea62160 authored by Dan Williams's avatar Dan Williams Committed by Linus Torvalds

mm/sparsemem: prepare for sub-section ranges

Prepare the memory hot-{add,remove} paths for handling sub-section
ranges by plumbing the starting page frame and number of pages being
handled through arch_{add,remove}_memory() to
sparse_{add,remove}_one_section().

This is simply plumbing, small cleanups, and some identifier renames.
No intended functional changes.

Link: http://lkml.kernel.org/r/156092353780.979959.9713046515562743194.stgit@dwillia2-desk3.amr.corp.intel.comSigned-off-by: default avatarDan Williams <dan.j.williams@intel.com>
Reviewed-by: default avatarPavel Tatashin <pasha.tatashin@soleen.com>
Tested-by: Aneesh Kumar K.V <aneesh.kumar@linux.ibm.com>	[ppc64]
Reviewed-by: default avatarOscar Salvador <osalvador@suse.de>
Cc: Michal Hocko <mhocko@suse.com>
Cc: Vlastimil Babka <vbabka@suse.cz>
Cc: Logan Gunthorpe <logang@deltatee.com>
Cc: David Hildenbrand <david@redhat.com>
Cc: Jane Chu <jane.chu@oracle.com>
Cc: Jeff Moyer <jmoyer@redhat.com>
Cc: Jérôme Glisse <jglisse@redhat.com>
Cc: Jonathan Corbet <corbet@lwn.net>
Cc: Mike Rapoport <rppt@linux.ibm.com>
Cc: Toshi Kani <toshi.kani@hpe.com>
Cc: Wei Yang <richardw.yang@linux.intel.com>
Cc: Jason Gunthorpe <jgg@mellanox.com>
Cc: Christoph Hellwig <hch@lst.de>
Signed-off-by: default avatarAndrew Morton <akpm@linux-foundation.org>
Signed-off-by: default avatarLinus Torvalds <torvalds@linux-foundation.org>
parent 46d945ae
...@@ -346,9 +346,10 @@ extern int add_memory_resource(int nid, struct resource *resource); ...@@ -346,9 +346,10 @@ extern int add_memory_resource(int nid, struct resource *resource);
extern void move_pfn_range_to_zone(struct zone *zone, unsigned long start_pfn, extern void move_pfn_range_to_zone(struct zone *zone, unsigned long start_pfn,
unsigned long nr_pages, struct vmem_altmap *altmap); unsigned long nr_pages, struct vmem_altmap *altmap);
extern bool is_memblock_offlined(struct memory_block *mem); extern bool is_memblock_offlined(struct memory_block *mem);
extern int sparse_add_one_section(int nid, unsigned long start_pfn, extern int sparse_add_section(int nid, unsigned long pfn,
struct vmem_altmap *altmap); unsigned long nr_pages, struct vmem_altmap *altmap);
extern void sparse_remove_one_section(struct mem_section *ms, extern void sparse_remove_one_section(struct mem_section *ms,
unsigned long pfn, unsigned long nr_pages,
unsigned long map_offset, struct vmem_altmap *altmap); unsigned long map_offset, struct vmem_altmap *altmap);
extern struct page *sparse_decode_mem_map(unsigned long coded_mem_map, extern struct page *sparse_decode_mem_map(unsigned long coded_mem_map,
unsigned long pnum); unsigned long pnum);
......
...@@ -252,51 +252,84 @@ void __init register_page_bootmem_info_node(struct pglist_data *pgdat) ...@@ -252,51 +252,84 @@ void __init register_page_bootmem_info_node(struct pglist_data *pgdat)
} }
#endif /* CONFIG_HAVE_BOOTMEM_INFO_NODE */ #endif /* CONFIG_HAVE_BOOTMEM_INFO_NODE */
static int __meminit __add_section(int nid, unsigned long phys_start_pfn, static int __meminit __add_section(int nid, unsigned long pfn,
struct vmem_altmap *altmap) unsigned long nr_pages, struct vmem_altmap *altmap)
{ {
int ret; int ret;
if (pfn_valid(phys_start_pfn)) if (pfn_valid(pfn))
return -EEXIST; return -EEXIST;
ret = sparse_add_one_section(nid, phys_start_pfn, altmap); ret = sparse_add_section(nid, pfn, nr_pages, altmap);
return ret < 0 ? ret : 0; return ret < 0 ? ret : 0;
} }
static int check_pfn_span(unsigned long pfn, unsigned long nr_pages,
const char *reason)
{
/*
* Disallow all operations smaller than a sub-section and only
* allow operations smaller than a section for
* SPARSEMEM_VMEMMAP. Note that check_hotplug_memory_range()
* enforces a larger memory_block_size_bytes() granularity for
* memory that will be marked online, so this check should only
* fire for direct arch_{add,remove}_memory() users outside of
* add_memory_resource().
*/
unsigned long min_align;
if (IS_ENABLED(CONFIG_SPARSEMEM_VMEMMAP))
min_align = PAGES_PER_SUBSECTION;
else
min_align = PAGES_PER_SECTION;
if (!IS_ALIGNED(pfn, min_align)
|| !IS_ALIGNED(nr_pages, min_align)) {
WARN(1, "Misaligned __%s_pages start: %#lx end: #%lx\n",
reason, pfn, pfn + nr_pages - 1);
return -EINVAL;
}
return 0;
}
/* /*
* Reasonably generic function for adding memory. It is * Reasonably generic function for adding memory. It is
* expected that archs that support memory hotplug will * expected that archs that support memory hotplug will
* call this function after deciding the zone to which to * call this function after deciding the zone to which to
* add the new pages. * add the new pages.
*/ */
int __ref __add_pages(int nid, unsigned long phys_start_pfn, int __ref __add_pages(int nid, unsigned long pfn, unsigned long nr_pages,
unsigned long nr_pages, struct mhp_restrictions *restrictions) struct mhp_restrictions *restrictions)
{ {
unsigned long i; unsigned long i;
int err = 0; int start_sec, end_sec, err;
int start_sec, end_sec;
struct vmem_altmap *altmap = restrictions->altmap; struct vmem_altmap *altmap = restrictions->altmap;
/* during initialize mem_map, align hot-added range to section */
start_sec = pfn_to_section_nr(phys_start_pfn);
end_sec = pfn_to_section_nr(phys_start_pfn + nr_pages - 1);
if (altmap) { if (altmap) {
/* /*
* Validate altmap is within bounds of the total request * Validate altmap is within bounds of the total request
*/ */
if (altmap->base_pfn != phys_start_pfn if (altmap->base_pfn != pfn
|| vmem_altmap_offset(altmap) > nr_pages) { || vmem_altmap_offset(altmap) > nr_pages) {
pr_warn_once("memory add fail, invalid altmap\n"); pr_warn_once("memory add fail, invalid altmap\n");
err = -EINVAL; return -EINVAL;
goto out;
} }
altmap->alloc = 0; altmap->alloc = 0;
} }
err = check_pfn_span(pfn, nr_pages, "add");
if (err)
return err;
start_sec = pfn_to_section_nr(pfn);
end_sec = pfn_to_section_nr(pfn + nr_pages - 1);
for (i = start_sec; i <= end_sec; i++) { for (i = start_sec; i <= end_sec; i++) {
err = __add_section(nid, section_nr_to_pfn(i), altmap); unsigned long pfns;
pfns = min(nr_pages, PAGES_PER_SECTION
- (pfn & ~PAGE_SECTION_MASK));
err = __add_section(nid, pfn, pfns, altmap);
pfn += pfns;
nr_pages -= pfns;
/* /*
* EEXIST is finally dealt with by ioresource collision * EEXIST is finally dealt with by ioresource collision
...@@ -309,7 +342,6 @@ int __ref __add_pages(int nid, unsigned long phys_start_pfn, ...@@ -309,7 +342,6 @@ int __ref __add_pages(int nid, unsigned long phys_start_pfn,
cond_resched(); cond_resched();
} }
vmemmap_populate_print_last(); vmemmap_populate_print_last();
out:
return err; return err;
} }
...@@ -487,10 +519,10 @@ static void shrink_pgdat_span(struct pglist_data *pgdat, ...@@ -487,10 +519,10 @@ static void shrink_pgdat_span(struct pglist_data *pgdat,
pgdat->node_spanned_pages = 0; pgdat->node_spanned_pages = 0;
} }
static void __remove_zone(struct zone *zone, unsigned long start_pfn) static void __remove_zone(struct zone *zone, unsigned long start_pfn,
unsigned long nr_pages)
{ {
struct pglist_data *pgdat = zone->zone_pgdat; struct pglist_data *pgdat = zone->zone_pgdat;
int nr_pages = PAGES_PER_SECTION;
unsigned long flags; unsigned long flags;
pgdat_resize_lock(zone->zone_pgdat, &flags); pgdat_resize_lock(zone->zone_pgdat, &flags);
...@@ -499,27 +531,23 @@ static void __remove_zone(struct zone *zone, unsigned long start_pfn) ...@@ -499,27 +531,23 @@ static void __remove_zone(struct zone *zone, unsigned long start_pfn)
pgdat_resize_unlock(zone->zone_pgdat, &flags); pgdat_resize_unlock(zone->zone_pgdat, &flags);
} }
static void __remove_section(struct zone *zone, struct mem_section *ms, static void __remove_section(struct zone *zone, unsigned long pfn,
unsigned long map_offset, unsigned long nr_pages, unsigned long map_offset,
struct vmem_altmap *altmap) struct vmem_altmap *altmap)
{ {
unsigned long start_pfn; struct mem_section *ms = __nr_to_section(pfn_to_section_nr(pfn));
int scn_nr;
if (WARN_ON_ONCE(!valid_section(ms))) if (WARN_ON_ONCE(!valid_section(ms)))
return; return;
scn_nr = __section_nr(ms); __remove_zone(zone, pfn, nr_pages);
start_pfn = section_nr_to_pfn((unsigned long)scn_nr); sparse_remove_one_section(ms, pfn, nr_pages, map_offset, altmap);
__remove_zone(zone, start_pfn);
sparse_remove_one_section(ms, map_offset, altmap);
} }
/** /**
* __remove_pages() - remove sections of pages from a zone * __remove_pages() - remove sections of pages from a zone
* @zone: zone from which pages need to be removed * @zone: zone from which pages need to be removed
* @phys_start_pfn: starting pageframe (must be aligned to start of a section) * @pfn: starting pageframe (must be aligned to start of a section)
* @nr_pages: number of pages to remove (must be multiple of section size) * @nr_pages: number of pages to remove (must be multiple of section size)
* @altmap: alternative device page map or %NULL if default memmap is used * @altmap: alternative device page map or %NULL if default memmap is used
* *
...@@ -528,30 +556,30 @@ static void __remove_section(struct zone *zone, struct mem_section *ms, ...@@ -528,30 +556,30 @@ static void __remove_section(struct zone *zone, struct mem_section *ms,
* sure that pages are marked reserved and zones are adjust properly by * sure that pages are marked reserved and zones are adjust properly by
* calling offline_pages(). * calling offline_pages().
*/ */
void __remove_pages(struct zone *zone, unsigned long phys_start_pfn, void __remove_pages(struct zone *zone, unsigned long pfn,
unsigned long nr_pages, struct vmem_altmap *altmap) unsigned long nr_pages, struct vmem_altmap *altmap)
{ {
unsigned long i;
unsigned long map_offset = 0; unsigned long map_offset = 0;
int sections_to_remove; int i, start_sec, end_sec;
map_offset = vmem_altmap_offset(altmap); map_offset = vmem_altmap_offset(altmap);
clear_zone_contiguous(zone); clear_zone_contiguous(zone);
/* if (check_pfn_span(pfn, nr_pages, "remove"))
* We can only remove entire sections return;
*/
BUG_ON(phys_start_pfn & ~PAGE_SECTION_MASK);
BUG_ON(nr_pages % PAGES_PER_SECTION);
sections_to_remove = nr_pages / PAGES_PER_SECTION; start_sec = pfn_to_section_nr(pfn);
for (i = 0; i < sections_to_remove; i++) { end_sec = pfn_to_section_nr(pfn + nr_pages - 1);
unsigned long pfn = phys_start_pfn + i*PAGES_PER_SECTION; for (i = start_sec; i <= end_sec; i++) {
unsigned long pfns;
cond_resched(); cond_resched();
__remove_section(zone, __pfn_to_section(pfn), map_offset, pfns = min(nr_pages, PAGES_PER_SECTION
altmap); - (pfn & ~PAGE_SECTION_MASK));
__remove_section(zone, pfn, pfns, map_offset, altmap);
pfn += pfns;
nr_pages -= pfns;
map_offset = 0; map_offset = 0;
} }
......
...@@ -728,8 +728,8 @@ static void free_map_bootmem(struct page *memmap) ...@@ -728,8 +728,8 @@ static void free_map_bootmem(struct page *memmap)
* * -EEXIST - Section has been present. * * -EEXIST - Section has been present.
* * -ENOMEM - Out of memory. * * -ENOMEM - Out of memory.
*/ */
int __meminit sparse_add_one_section(int nid, unsigned long start_pfn, int __meminit sparse_add_section(int nid, unsigned long start_pfn,
struct vmem_altmap *altmap) unsigned long nr_pages, struct vmem_altmap *altmap)
{ {
unsigned long section_nr = pfn_to_section_nr(start_pfn); unsigned long section_nr = pfn_to_section_nr(start_pfn);
struct mem_section_usage *usage; struct mem_section_usage *usage;
...@@ -835,8 +835,9 @@ static void free_section_usage(struct mem_section *ms, struct page *memmap, ...@@ -835,8 +835,9 @@ static void free_section_usage(struct mem_section *ms, struct page *memmap,
free_map_bootmem(memmap); free_map_bootmem(memmap);
} }
void sparse_remove_one_section(struct mem_section *ms, unsigned long map_offset, void sparse_remove_one_section(struct mem_section *ms, unsigned long pfn,
struct vmem_altmap *altmap) unsigned long nr_pages, unsigned long map_offset,
struct vmem_altmap *altmap)
{ {
struct page *memmap = NULL; struct page *memmap = NULL;
struct mem_section_usage *usage = NULL; struct mem_section_usage *usage = NULL;
...@@ -849,10 +850,7 @@ void sparse_remove_one_section(struct mem_section *ms, unsigned long map_offset, ...@@ -849,10 +850,7 @@ void sparse_remove_one_section(struct mem_section *ms, unsigned long map_offset,
ms->usage = NULL; ms->usage = NULL;
} }
clear_hwpoisoned_pages(memmap + map_offset, clear_hwpoisoned_pages(memmap + map_offset, nr_pages - map_offset);
PAGES_PER_SECTION - map_offset); free_section_usage(ms, memmap, usage, pfn, nr_pages, altmap);
free_section_usage(ms, memmap, usage,
section_nr_to_pfn(__section_nr(ms)),
PAGES_PER_SECTION, altmap);
} }
#endif /* CONFIG_MEMORY_HOTPLUG */ #endif /* CONFIG_MEMORY_HOTPLUG */
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