mirror of
https://github.com/BobTheBlinker/android_kernel_motorola_sm6375.git
synced 2026-10-29 03:01:39 -04:00
Merge branch 'akpm' (patches from Andrew)
Merge more updates from Andrew Morton: - a few misc things - kexec updates - DMA-mapping updates to better support networking DMA operations - IPC updates - various MM changes to improve DAX fault handling - lots of radix-tree changes, mainly to the test suite. All leading up to reimplementing the IDA/IDR code to be a wrapper layer over the radix-tree. However the final trigger-pulling patch is held off for 4.11. * emailed patches from Andrew Morton <[email protected]>: (114 commits) radix tree test suite: delete unused rcupdate.c radix tree test suite: add new tag check radix-tree: ensure counts are initialised radix tree test suite: cache recently freed objects radix tree test suite: add some more functionality idr: reduce the number of bits per level from 8 to 6 rxrpc: abstract away knowledge of IDR internals tpm: use idr_find(), not idr_find_slowpath() idr: add ida_is_empty radix tree test suite: check multiorder iteration radix-tree: fix replacement for multiorder entries radix-tree: add radix_tree_split_preload() radix-tree: add radix_tree_split radix-tree: add radix_tree_join radix-tree: delete radix_tree_range_tag_if_tagged() radix-tree: delete radix_tree_locate_item() radix-tree: improve multiorder iterators btrfs: fix race in btrfs_free_dummy_fs_info() radix-tree: improve dump output radix-tree: make radix_tree_find_next_bit more useful ...
This commit is contained in:
commit
a57cb1c1d7
140 changed files with 3428 additions and 2218 deletions
|
|
@ -818,6 +818,13 @@ isolate_migratepages_block(struct compact_control *cc, unsigned long low_pfn,
|
|||
page_count(page) > page_mapcount(page))
|
||||
goto isolate_fail;
|
||||
|
||||
/*
|
||||
* Only allow to migrate anonymous pages in GFP_NOFS context
|
||||
* because those do not depend on fs locks.
|
||||
*/
|
||||
if (!(cc->gfp_mask & __GFP_FS) && page_mapping(page))
|
||||
goto isolate_fail;
|
||||
|
||||
/* If we already hold the lock, we can skip some rechecking */
|
||||
if (!locked) {
|
||||
locked = compact_trylock_irqsave(zone_lru_lock(zone),
|
||||
|
|
@ -1677,14 +1684,16 @@ enum compact_result try_to_compact_pages(gfp_t gfp_mask, unsigned int order,
|
|||
unsigned int alloc_flags, const struct alloc_context *ac,
|
||||
enum compact_priority prio)
|
||||
{
|
||||
int may_enter_fs = gfp_mask & __GFP_FS;
|
||||
int may_perform_io = gfp_mask & __GFP_IO;
|
||||
struct zoneref *z;
|
||||
struct zone *zone;
|
||||
enum compact_result rc = COMPACT_SKIPPED;
|
||||
|
||||
/* Check if the GFP flags allow compaction */
|
||||
if (!may_enter_fs || !may_perform_io)
|
||||
/*
|
||||
* Check if the GFP flags allow compaction - GFP_NOIO is really
|
||||
* tricky context because the migration might require IO
|
||||
*/
|
||||
if (!may_perform_io)
|
||||
return COMPACT_SKIPPED;
|
||||
|
||||
trace_mm_compaction_try_to_compact_pages(order, gfp_mask, prio);
|
||||
|
|
@ -1751,6 +1760,7 @@ static void compact_node(int nid)
|
|||
.mode = MIGRATE_SYNC,
|
||||
.ignore_skip_hint = true,
|
||||
.whole_zone = true,
|
||||
.gfp_mask = GFP_KERNEL,
|
||||
};
|
||||
|
||||
|
||||
|
|
@ -1876,6 +1886,7 @@ static void kcompactd_do_work(pg_data_t *pgdat)
|
|||
.classzone_idx = pgdat->kcompactd_classzone_idx,
|
||||
.mode = MIGRATE_SYNC_LIGHT,
|
||||
.ignore_skip_hint = true,
|
||||
.gfp_mask = GFP_KERNEL,
|
||||
|
||||
};
|
||||
trace_mm_compaction_kcompactd_wake(pgdat->node_id, cc.order,
|
||||
|
|
|
|||
14
mm/filemap.c
14
mm/filemap.c
|
|
@ -2164,12 +2164,12 @@ page_not_uptodate:
|
|||
}
|
||||
EXPORT_SYMBOL(filemap_fault);
|
||||
|
||||
void filemap_map_pages(struct fault_env *fe,
|
||||
void filemap_map_pages(struct vm_fault *vmf,
|
||||
pgoff_t start_pgoff, pgoff_t end_pgoff)
|
||||
{
|
||||
struct radix_tree_iter iter;
|
||||
void **slot;
|
||||
struct file *file = fe->vma->vm_file;
|
||||
struct file *file = vmf->vma->vm_file;
|
||||
struct address_space *mapping = file->f_mapping;
|
||||
pgoff_t last_pgoff = start_pgoff;
|
||||
loff_t size;
|
||||
|
|
@ -2225,11 +2225,11 @@ repeat:
|
|||
if (file->f_ra.mmap_miss > 0)
|
||||
file->f_ra.mmap_miss--;
|
||||
|
||||
fe->address += (iter.index - last_pgoff) << PAGE_SHIFT;
|
||||
if (fe->pte)
|
||||
fe->pte += iter.index - last_pgoff;
|
||||
vmf->address += (iter.index - last_pgoff) << PAGE_SHIFT;
|
||||
if (vmf->pte)
|
||||
vmf->pte += iter.index - last_pgoff;
|
||||
last_pgoff = iter.index;
|
||||
if (alloc_set_pte(fe, NULL, page))
|
||||
if (alloc_set_pte(vmf, NULL, page))
|
||||
goto unlock;
|
||||
unlock_page(page);
|
||||
goto next;
|
||||
|
|
@ -2239,7 +2239,7 @@ skip:
|
|||
put_page(page);
|
||||
next:
|
||||
/* Huge page is mapped? No need to proceed. */
|
||||
if (pmd_trans_huge(*fe->pmd))
|
||||
if (pmd_trans_huge(*vmf->pmd))
|
||||
break;
|
||||
if (iter.index == end_pgoff)
|
||||
break;
|
||||
|
|
|
|||
20
mm/gup.c
20
mm/gup.c
|
|
@ -865,9 +865,10 @@ EXPORT_SYMBOL(get_user_pages_locked);
|
|||
* caller if required (just like with __get_user_pages). "FOLL_GET"
|
||||
* is set implicitly if "pages" is non-NULL.
|
||||
*/
|
||||
__always_inline long __get_user_pages_unlocked(struct task_struct *tsk, struct mm_struct *mm,
|
||||
unsigned long start, unsigned long nr_pages,
|
||||
struct page **pages, unsigned int gup_flags)
|
||||
static __always_inline long __get_user_pages_unlocked(struct task_struct *tsk,
|
||||
struct mm_struct *mm, unsigned long start,
|
||||
unsigned long nr_pages, struct page **pages,
|
||||
unsigned int gup_flags)
|
||||
{
|
||||
long ret;
|
||||
int locked = 1;
|
||||
|
|
@ -879,7 +880,6 @@ __always_inline long __get_user_pages_unlocked(struct task_struct *tsk, struct m
|
|||
up_read(&mm->mmap_sem);
|
||||
return ret;
|
||||
}
|
||||
EXPORT_SYMBOL(__get_user_pages_unlocked);
|
||||
|
||||
/*
|
||||
* get_user_pages_unlocked() is suitable to replace the form:
|
||||
|
|
@ -917,6 +917,9 @@ EXPORT_SYMBOL(get_user_pages_unlocked);
|
|||
* only intends to ensure the pages are faulted in.
|
||||
* @vmas: array of pointers to vmas corresponding to each page.
|
||||
* Or NULL if the caller does not require them.
|
||||
* @locked: pointer to lock flag indicating whether lock is held and
|
||||
* subsequently whether VM_FAULT_RETRY functionality can be
|
||||
* utilised. Lock must initially be held.
|
||||
*
|
||||
* Returns number of pages pinned. This may be fewer than the number
|
||||
* requested. If nr_pages is 0 or negative, returns 0. If no pages
|
||||
|
|
@ -960,10 +963,10 @@ EXPORT_SYMBOL(get_user_pages_unlocked);
|
|||
long get_user_pages_remote(struct task_struct *tsk, struct mm_struct *mm,
|
||||
unsigned long start, unsigned long nr_pages,
|
||||
unsigned int gup_flags, struct page **pages,
|
||||
struct vm_area_struct **vmas)
|
||||
struct vm_area_struct **vmas, int *locked)
|
||||
{
|
||||
return __get_user_pages_locked(tsk, mm, start, nr_pages, pages, vmas,
|
||||
NULL, false,
|
||||
locked, true,
|
||||
gup_flags | FOLL_TOUCH | FOLL_REMOTE);
|
||||
}
|
||||
EXPORT_SYMBOL(get_user_pages_remote);
|
||||
|
|
@ -971,8 +974,9 @@ EXPORT_SYMBOL(get_user_pages_remote);
|
|||
/*
|
||||
* This is the same as get_user_pages_remote(), just with a
|
||||
* less-flexible calling convention where we assume that the task
|
||||
* and mm being operated on are the current task's. We also
|
||||
* obviously don't pass FOLL_REMOTE in here.
|
||||
* and mm being operated on are the current task's and don't allow
|
||||
* passing of a locked parameter. We also obviously don't pass
|
||||
* FOLL_REMOTE in here.
|
||||
*/
|
||||
long get_user_pages(unsigned long start, unsigned long nr_pages,
|
||||
unsigned int gup_flags, struct page **pages,
|
||||
|
|
|
|||
173
mm/huge_memory.c
173
mm/huge_memory.c
|
|
@ -542,13 +542,13 @@ unsigned long thp_get_unmapped_area(struct file *filp, unsigned long addr,
|
|||
}
|
||||
EXPORT_SYMBOL_GPL(thp_get_unmapped_area);
|
||||
|
||||
static int __do_huge_pmd_anonymous_page(struct fault_env *fe, struct page *page,
|
||||
static int __do_huge_pmd_anonymous_page(struct vm_fault *vmf, struct page *page,
|
||||
gfp_t gfp)
|
||||
{
|
||||
struct vm_area_struct *vma = fe->vma;
|
||||
struct vm_area_struct *vma = vmf->vma;
|
||||
struct mem_cgroup *memcg;
|
||||
pgtable_t pgtable;
|
||||
unsigned long haddr = fe->address & HPAGE_PMD_MASK;
|
||||
unsigned long haddr = vmf->address & HPAGE_PMD_MASK;
|
||||
|
||||
VM_BUG_ON_PAGE(!PageCompound(page), page);
|
||||
|
||||
|
|
@ -573,9 +573,9 @@ static int __do_huge_pmd_anonymous_page(struct fault_env *fe, struct page *page,
|
|||
*/
|
||||
__SetPageUptodate(page);
|
||||
|
||||
fe->ptl = pmd_lock(vma->vm_mm, fe->pmd);
|
||||
if (unlikely(!pmd_none(*fe->pmd))) {
|
||||
spin_unlock(fe->ptl);
|
||||
vmf->ptl = pmd_lock(vma->vm_mm, vmf->pmd);
|
||||
if (unlikely(!pmd_none(*vmf->pmd))) {
|
||||
spin_unlock(vmf->ptl);
|
||||
mem_cgroup_cancel_charge(page, memcg, true);
|
||||
put_page(page);
|
||||
pte_free(vma->vm_mm, pgtable);
|
||||
|
|
@ -586,11 +586,11 @@ static int __do_huge_pmd_anonymous_page(struct fault_env *fe, struct page *page,
|
|||
if (userfaultfd_missing(vma)) {
|
||||
int ret;
|
||||
|
||||
spin_unlock(fe->ptl);
|
||||
spin_unlock(vmf->ptl);
|
||||
mem_cgroup_cancel_charge(page, memcg, true);
|
||||
put_page(page);
|
||||
pte_free(vma->vm_mm, pgtable);
|
||||
ret = handle_userfault(fe, VM_UFFD_MISSING);
|
||||
ret = handle_userfault(vmf, VM_UFFD_MISSING);
|
||||
VM_BUG_ON(ret & VM_FAULT_FALLBACK);
|
||||
return ret;
|
||||
}
|
||||
|
|
@ -600,11 +600,11 @@ static int __do_huge_pmd_anonymous_page(struct fault_env *fe, struct page *page,
|
|||
page_add_new_anon_rmap(page, vma, haddr, true);
|
||||
mem_cgroup_commit_charge(page, memcg, false, true);
|
||||
lru_cache_add_active_or_unevictable(page, vma);
|
||||
pgtable_trans_huge_deposit(vma->vm_mm, fe->pmd, pgtable);
|
||||
set_pmd_at(vma->vm_mm, haddr, fe->pmd, entry);
|
||||
pgtable_trans_huge_deposit(vma->vm_mm, vmf->pmd, pgtable);
|
||||
set_pmd_at(vma->vm_mm, haddr, vmf->pmd, entry);
|
||||
add_mm_counter(vma->vm_mm, MM_ANONPAGES, HPAGE_PMD_NR);
|
||||
atomic_long_inc(&vma->vm_mm->nr_ptes);
|
||||
spin_unlock(fe->ptl);
|
||||
spin_unlock(vmf->ptl);
|
||||
count_vm_event(THP_FAULT_ALLOC);
|
||||
}
|
||||
|
||||
|
|
@ -651,12 +651,12 @@ static bool set_huge_zero_page(pgtable_t pgtable, struct mm_struct *mm,
|
|||
return true;
|
||||
}
|
||||
|
||||
int do_huge_pmd_anonymous_page(struct fault_env *fe)
|
||||
int do_huge_pmd_anonymous_page(struct vm_fault *vmf)
|
||||
{
|
||||
struct vm_area_struct *vma = fe->vma;
|
||||
struct vm_area_struct *vma = vmf->vma;
|
||||
gfp_t gfp;
|
||||
struct page *page;
|
||||
unsigned long haddr = fe->address & HPAGE_PMD_MASK;
|
||||
unsigned long haddr = vmf->address & HPAGE_PMD_MASK;
|
||||
|
||||
if (haddr < vma->vm_start || haddr + HPAGE_PMD_SIZE > vma->vm_end)
|
||||
return VM_FAULT_FALLBACK;
|
||||
|
|
@ -664,7 +664,7 @@ int do_huge_pmd_anonymous_page(struct fault_env *fe)
|
|||
return VM_FAULT_OOM;
|
||||
if (unlikely(khugepaged_enter(vma, vma->vm_flags)))
|
||||
return VM_FAULT_OOM;
|
||||
if (!(fe->flags & FAULT_FLAG_WRITE) &&
|
||||
if (!(vmf->flags & FAULT_FLAG_WRITE) &&
|
||||
!mm_forbids_zeropage(vma->vm_mm) &&
|
||||
transparent_hugepage_use_zero_page()) {
|
||||
pgtable_t pgtable;
|
||||
|
|
@ -680,22 +680,22 @@ int do_huge_pmd_anonymous_page(struct fault_env *fe)
|
|||
count_vm_event(THP_FAULT_FALLBACK);
|
||||
return VM_FAULT_FALLBACK;
|
||||
}
|
||||
fe->ptl = pmd_lock(vma->vm_mm, fe->pmd);
|
||||
vmf->ptl = pmd_lock(vma->vm_mm, vmf->pmd);
|
||||
ret = 0;
|
||||
set = false;
|
||||
if (pmd_none(*fe->pmd)) {
|
||||
if (pmd_none(*vmf->pmd)) {
|
||||
if (userfaultfd_missing(vma)) {
|
||||
spin_unlock(fe->ptl);
|
||||
ret = handle_userfault(fe, VM_UFFD_MISSING);
|
||||
spin_unlock(vmf->ptl);
|
||||
ret = handle_userfault(vmf, VM_UFFD_MISSING);
|
||||
VM_BUG_ON(ret & VM_FAULT_FALLBACK);
|
||||
} else {
|
||||
set_huge_zero_page(pgtable, vma->vm_mm, vma,
|
||||
haddr, fe->pmd, zero_page);
|
||||
spin_unlock(fe->ptl);
|
||||
haddr, vmf->pmd, zero_page);
|
||||
spin_unlock(vmf->ptl);
|
||||
set = true;
|
||||
}
|
||||
} else
|
||||
spin_unlock(fe->ptl);
|
||||
spin_unlock(vmf->ptl);
|
||||
if (!set)
|
||||
pte_free(vma->vm_mm, pgtable);
|
||||
return ret;
|
||||
|
|
@ -707,7 +707,7 @@ int do_huge_pmd_anonymous_page(struct fault_env *fe)
|
|||
return VM_FAULT_FALLBACK;
|
||||
}
|
||||
prep_transhuge_page(page);
|
||||
return __do_huge_pmd_anonymous_page(fe, page, gfp);
|
||||
return __do_huge_pmd_anonymous_page(vmf, page, gfp);
|
||||
}
|
||||
|
||||
static void insert_pfn_pmd(struct vm_area_struct *vma, unsigned long addr,
|
||||
|
|
@ -879,30 +879,30 @@ out:
|
|||
return ret;
|
||||
}
|
||||
|
||||
void huge_pmd_set_accessed(struct fault_env *fe, pmd_t orig_pmd)
|
||||
void huge_pmd_set_accessed(struct vm_fault *vmf, pmd_t orig_pmd)
|
||||
{
|
||||
pmd_t entry;
|
||||
unsigned long haddr;
|
||||
|
||||
fe->ptl = pmd_lock(fe->vma->vm_mm, fe->pmd);
|
||||
if (unlikely(!pmd_same(*fe->pmd, orig_pmd)))
|
||||
vmf->ptl = pmd_lock(vmf->vma->vm_mm, vmf->pmd);
|
||||
if (unlikely(!pmd_same(*vmf->pmd, orig_pmd)))
|
||||
goto unlock;
|
||||
|
||||
entry = pmd_mkyoung(orig_pmd);
|
||||
haddr = fe->address & HPAGE_PMD_MASK;
|
||||
if (pmdp_set_access_flags(fe->vma, haddr, fe->pmd, entry,
|
||||
fe->flags & FAULT_FLAG_WRITE))
|
||||
update_mmu_cache_pmd(fe->vma, fe->address, fe->pmd);
|
||||
haddr = vmf->address & HPAGE_PMD_MASK;
|
||||
if (pmdp_set_access_flags(vmf->vma, haddr, vmf->pmd, entry,
|
||||
vmf->flags & FAULT_FLAG_WRITE))
|
||||
update_mmu_cache_pmd(vmf->vma, vmf->address, vmf->pmd);
|
||||
|
||||
unlock:
|
||||
spin_unlock(fe->ptl);
|
||||
spin_unlock(vmf->ptl);
|
||||
}
|
||||
|
||||
static int do_huge_pmd_wp_page_fallback(struct fault_env *fe, pmd_t orig_pmd,
|
||||
static int do_huge_pmd_wp_page_fallback(struct vm_fault *vmf, pmd_t orig_pmd,
|
||||
struct page *page)
|
||||
{
|
||||
struct vm_area_struct *vma = fe->vma;
|
||||
unsigned long haddr = fe->address & HPAGE_PMD_MASK;
|
||||
struct vm_area_struct *vma = vmf->vma;
|
||||
unsigned long haddr = vmf->address & HPAGE_PMD_MASK;
|
||||
struct mem_cgroup *memcg;
|
||||
pgtable_t pgtable;
|
||||
pmd_t _pmd;
|
||||
|
|
@ -921,7 +921,7 @@ static int do_huge_pmd_wp_page_fallback(struct fault_env *fe, pmd_t orig_pmd,
|
|||
for (i = 0; i < HPAGE_PMD_NR; i++) {
|
||||
pages[i] = alloc_page_vma_node(GFP_HIGHUSER_MOVABLE |
|
||||
__GFP_OTHER_NODE, vma,
|
||||
fe->address, page_to_nid(page));
|
||||
vmf->address, page_to_nid(page));
|
||||
if (unlikely(!pages[i] ||
|
||||
mem_cgroup_try_charge(pages[i], vma->vm_mm,
|
||||
GFP_KERNEL, &memcg, false))) {
|
||||
|
|
@ -952,15 +952,15 @@ static int do_huge_pmd_wp_page_fallback(struct fault_env *fe, pmd_t orig_pmd,
|
|||
mmun_end = haddr + HPAGE_PMD_SIZE;
|
||||
mmu_notifier_invalidate_range_start(vma->vm_mm, mmun_start, mmun_end);
|
||||
|
||||
fe->ptl = pmd_lock(vma->vm_mm, fe->pmd);
|
||||
if (unlikely(!pmd_same(*fe->pmd, orig_pmd)))
|
||||
vmf->ptl = pmd_lock(vma->vm_mm, vmf->pmd);
|
||||
if (unlikely(!pmd_same(*vmf->pmd, orig_pmd)))
|
||||
goto out_free_pages;
|
||||
VM_BUG_ON_PAGE(!PageHead(page), page);
|
||||
|
||||
pmdp_huge_clear_flush_notify(vma, haddr, fe->pmd);
|
||||
pmdp_huge_clear_flush_notify(vma, haddr, vmf->pmd);
|
||||
/* leave pmd empty until pte is filled */
|
||||
|
||||
pgtable = pgtable_trans_huge_withdraw(vma->vm_mm, fe->pmd);
|
||||
pgtable = pgtable_trans_huge_withdraw(vma->vm_mm, vmf->pmd);
|
||||
pmd_populate(vma->vm_mm, &_pmd, pgtable);
|
||||
|
||||
for (i = 0; i < HPAGE_PMD_NR; i++, haddr += PAGE_SIZE) {
|
||||
|
|
@ -969,20 +969,20 @@ static int do_huge_pmd_wp_page_fallback(struct fault_env *fe, pmd_t orig_pmd,
|
|||
entry = maybe_mkwrite(pte_mkdirty(entry), vma);
|
||||
memcg = (void *)page_private(pages[i]);
|
||||
set_page_private(pages[i], 0);
|
||||
page_add_new_anon_rmap(pages[i], fe->vma, haddr, false);
|
||||
page_add_new_anon_rmap(pages[i], vmf->vma, haddr, false);
|
||||
mem_cgroup_commit_charge(pages[i], memcg, false, false);
|
||||
lru_cache_add_active_or_unevictable(pages[i], vma);
|
||||
fe->pte = pte_offset_map(&_pmd, haddr);
|
||||
VM_BUG_ON(!pte_none(*fe->pte));
|
||||
set_pte_at(vma->vm_mm, haddr, fe->pte, entry);
|
||||
pte_unmap(fe->pte);
|
||||
vmf->pte = pte_offset_map(&_pmd, haddr);
|
||||
VM_BUG_ON(!pte_none(*vmf->pte));
|
||||
set_pte_at(vma->vm_mm, haddr, vmf->pte, entry);
|
||||
pte_unmap(vmf->pte);
|
||||
}
|
||||
kfree(pages);
|
||||
|
||||
smp_wmb(); /* make pte visible before pmd */
|
||||
pmd_populate(vma->vm_mm, fe->pmd, pgtable);
|
||||
pmd_populate(vma->vm_mm, vmf->pmd, pgtable);
|
||||
page_remove_rmap(page, true);
|
||||
spin_unlock(fe->ptl);
|
||||
spin_unlock(vmf->ptl);
|
||||
|
||||
mmu_notifier_invalidate_range_end(vma->vm_mm, mmun_start, mmun_end);
|
||||
|
||||
|
|
@ -993,7 +993,7 @@ out:
|
|||
return ret;
|
||||
|
||||
out_free_pages:
|
||||
spin_unlock(fe->ptl);
|
||||
spin_unlock(vmf->ptl);
|
||||
mmu_notifier_invalidate_range_end(vma->vm_mm, mmun_start, mmun_end);
|
||||
for (i = 0; i < HPAGE_PMD_NR; i++) {
|
||||
memcg = (void *)page_private(pages[i]);
|
||||
|
|
@ -1005,23 +1005,23 @@ out_free_pages:
|
|||
goto out;
|
||||
}
|
||||
|
||||
int do_huge_pmd_wp_page(struct fault_env *fe, pmd_t orig_pmd)
|
||||
int do_huge_pmd_wp_page(struct vm_fault *vmf, pmd_t orig_pmd)
|
||||
{
|
||||
struct vm_area_struct *vma = fe->vma;
|
||||
struct vm_area_struct *vma = vmf->vma;
|
||||
struct page *page = NULL, *new_page;
|
||||
struct mem_cgroup *memcg;
|
||||
unsigned long haddr = fe->address & HPAGE_PMD_MASK;
|
||||
unsigned long haddr = vmf->address & HPAGE_PMD_MASK;
|
||||
unsigned long mmun_start; /* For mmu_notifiers */
|
||||
unsigned long mmun_end; /* For mmu_notifiers */
|
||||
gfp_t huge_gfp; /* for allocation and charge */
|
||||
int ret = 0;
|
||||
|
||||
fe->ptl = pmd_lockptr(vma->vm_mm, fe->pmd);
|
||||
vmf->ptl = pmd_lockptr(vma->vm_mm, vmf->pmd);
|
||||
VM_BUG_ON_VMA(!vma->anon_vma, vma);
|
||||
if (is_huge_zero_pmd(orig_pmd))
|
||||
goto alloc;
|
||||
spin_lock(fe->ptl);
|
||||
if (unlikely(!pmd_same(*fe->pmd, orig_pmd)))
|
||||
spin_lock(vmf->ptl);
|
||||
if (unlikely(!pmd_same(*vmf->pmd, orig_pmd)))
|
||||
goto out_unlock;
|
||||
|
||||
page = pmd_page(orig_pmd);
|
||||
|
|
@ -1034,13 +1034,13 @@ int do_huge_pmd_wp_page(struct fault_env *fe, pmd_t orig_pmd)
|
|||
pmd_t entry;
|
||||
entry = pmd_mkyoung(orig_pmd);
|
||||
entry = maybe_pmd_mkwrite(pmd_mkdirty(entry), vma);
|
||||
if (pmdp_set_access_flags(vma, haddr, fe->pmd, entry, 1))
|
||||
update_mmu_cache_pmd(vma, fe->address, fe->pmd);
|
||||
if (pmdp_set_access_flags(vma, haddr, vmf->pmd, entry, 1))
|
||||
update_mmu_cache_pmd(vma, vmf->address, vmf->pmd);
|
||||
ret |= VM_FAULT_WRITE;
|
||||
goto out_unlock;
|
||||
}
|
||||
get_page(page);
|
||||
spin_unlock(fe->ptl);
|
||||
spin_unlock(vmf->ptl);
|
||||
alloc:
|
||||
if (transparent_hugepage_enabled(vma) &&
|
||||
!transparent_hugepage_debug_cow()) {
|
||||
|
|
@ -1053,12 +1053,12 @@ alloc:
|
|||
prep_transhuge_page(new_page);
|
||||
} else {
|
||||
if (!page) {
|
||||
split_huge_pmd(vma, fe->pmd, fe->address);
|
||||
split_huge_pmd(vma, vmf->pmd, vmf->address);
|
||||
ret |= VM_FAULT_FALLBACK;
|
||||
} else {
|
||||
ret = do_huge_pmd_wp_page_fallback(fe, orig_pmd, page);
|
||||
ret = do_huge_pmd_wp_page_fallback(vmf, orig_pmd, page);
|
||||
if (ret & VM_FAULT_OOM) {
|
||||
split_huge_pmd(vma, fe->pmd, fe->address);
|
||||
split_huge_pmd(vma, vmf->pmd, vmf->address);
|
||||
ret |= VM_FAULT_FALLBACK;
|
||||
}
|
||||
put_page(page);
|
||||
|
|
@ -1070,7 +1070,7 @@ alloc:
|
|||
if (unlikely(mem_cgroup_try_charge(new_page, vma->vm_mm,
|
||||
huge_gfp, &memcg, true))) {
|
||||
put_page(new_page);
|
||||
split_huge_pmd(vma, fe->pmd, fe->address);
|
||||
split_huge_pmd(vma, vmf->pmd, vmf->address);
|
||||
if (page)
|
||||
put_page(page);
|
||||
ret |= VM_FAULT_FALLBACK;
|
||||
|
|
@ -1090,11 +1090,11 @@ alloc:
|
|||
mmun_end = haddr + HPAGE_PMD_SIZE;
|
||||
mmu_notifier_invalidate_range_start(vma->vm_mm, mmun_start, mmun_end);
|
||||
|
||||
spin_lock(fe->ptl);
|
||||
spin_lock(vmf->ptl);
|
||||
if (page)
|
||||
put_page(page);
|
||||
if (unlikely(!pmd_same(*fe->pmd, orig_pmd))) {
|
||||
spin_unlock(fe->ptl);
|
||||
if (unlikely(!pmd_same(*vmf->pmd, orig_pmd))) {
|
||||
spin_unlock(vmf->ptl);
|
||||
mem_cgroup_cancel_charge(new_page, memcg, true);
|
||||
put_page(new_page);
|
||||
goto out_mn;
|
||||
|
|
@ -1102,12 +1102,12 @@ alloc:
|
|||
pmd_t entry;
|
||||
entry = mk_huge_pmd(new_page, vma->vm_page_prot);
|
||||
entry = maybe_pmd_mkwrite(pmd_mkdirty(entry), vma);
|
||||
pmdp_huge_clear_flush_notify(vma, haddr, fe->pmd);
|
||||
pmdp_huge_clear_flush_notify(vma, haddr, vmf->pmd);
|
||||
page_add_new_anon_rmap(new_page, vma, haddr, true);
|
||||
mem_cgroup_commit_charge(new_page, memcg, false, true);
|
||||
lru_cache_add_active_or_unevictable(new_page, vma);
|
||||
set_pmd_at(vma->vm_mm, haddr, fe->pmd, entry);
|
||||
update_mmu_cache_pmd(vma, fe->address, fe->pmd);
|
||||
set_pmd_at(vma->vm_mm, haddr, vmf->pmd, entry);
|
||||
update_mmu_cache_pmd(vma, vmf->address, vmf->pmd);
|
||||
if (!page) {
|
||||
add_mm_counter(vma->vm_mm, MM_ANONPAGES, HPAGE_PMD_NR);
|
||||
} else {
|
||||
|
|
@ -1117,13 +1117,13 @@ alloc:
|
|||
}
|
||||
ret |= VM_FAULT_WRITE;
|
||||
}
|
||||
spin_unlock(fe->ptl);
|
||||
spin_unlock(vmf->ptl);
|
||||
out_mn:
|
||||
mmu_notifier_invalidate_range_end(vma->vm_mm, mmun_start, mmun_end);
|
||||
out:
|
||||
return ret;
|
||||
out_unlock:
|
||||
spin_unlock(fe->ptl);
|
||||
spin_unlock(vmf->ptl);
|
||||
return ret;
|
||||
}
|
||||
|
||||
|
|
@ -1196,12 +1196,12 @@ out:
|
|||
}
|
||||
|
||||
/* NUMA hinting page fault entry point for trans huge pmds */
|
||||
int do_huge_pmd_numa_page(struct fault_env *fe, pmd_t pmd)
|
||||
int do_huge_pmd_numa_page(struct vm_fault *vmf, pmd_t pmd)
|
||||
{
|
||||
struct vm_area_struct *vma = fe->vma;
|
||||
struct vm_area_struct *vma = vmf->vma;
|
||||
struct anon_vma *anon_vma = NULL;
|
||||
struct page *page;
|
||||
unsigned long haddr = fe->address & HPAGE_PMD_MASK;
|
||||
unsigned long haddr = vmf->address & HPAGE_PMD_MASK;
|
||||
int page_nid = -1, this_nid = numa_node_id();
|
||||
int target_nid, last_cpupid = -1;
|
||||
bool page_locked;
|
||||
|
|
@ -1209,8 +1209,8 @@ int do_huge_pmd_numa_page(struct fault_env *fe, pmd_t pmd)
|
|||
bool was_writable;
|
||||
int flags = 0;
|
||||
|
||||
fe->ptl = pmd_lock(vma->vm_mm, fe->pmd);
|
||||
if (unlikely(!pmd_same(pmd, *fe->pmd)))
|
||||
vmf->ptl = pmd_lock(vma->vm_mm, vmf->pmd);
|
||||
if (unlikely(!pmd_same(pmd, *vmf->pmd)))
|
||||
goto out_unlock;
|
||||
|
||||
/*
|
||||
|
|
@ -1218,9 +1218,9 @@ int do_huge_pmd_numa_page(struct fault_env *fe, pmd_t pmd)
|
|||
* without disrupting NUMA hinting information. Do not relock and
|
||||
* check_same as the page may no longer be mapped.
|
||||
*/
|
||||
if (unlikely(pmd_trans_migrating(*fe->pmd))) {
|
||||
page = pmd_page(*fe->pmd);
|
||||
spin_unlock(fe->ptl);
|
||||
if (unlikely(pmd_trans_migrating(*vmf->pmd))) {
|
||||
page = pmd_page(*vmf->pmd);
|
||||
spin_unlock(vmf->ptl);
|
||||
wait_on_page_locked(page);
|
||||
goto out;
|
||||
}
|
||||
|
|
@ -1253,7 +1253,7 @@ int do_huge_pmd_numa_page(struct fault_env *fe, pmd_t pmd)
|
|||
|
||||
/* Migration could have started since the pmd_trans_migrating check */
|
||||
if (!page_locked) {
|
||||
spin_unlock(fe->ptl);
|
||||
spin_unlock(vmf->ptl);
|
||||
wait_on_page_locked(page);
|
||||
page_nid = -1;
|
||||
goto out;
|
||||
|
|
@ -1264,12 +1264,12 @@ int do_huge_pmd_numa_page(struct fault_env *fe, pmd_t pmd)
|
|||
* to serialises splits
|
||||
*/
|
||||
get_page(page);
|
||||
spin_unlock(fe->ptl);
|
||||
spin_unlock(vmf->ptl);
|
||||
anon_vma = page_lock_anon_vma_read(page);
|
||||
|
||||
/* Confirm the PMD did not change while page_table_lock was released */
|
||||
spin_lock(fe->ptl);
|
||||
if (unlikely(!pmd_same(pmd, *fe->pmd))) {
|
||||
spin_lock(vmf->ptl);
|
||||
if (unlikely(!pmd_same(pmd, *vmf->pmd))) {
|
||||
unlock_page(page);
|
||||
put_page(page);
|
||||
page_nid = -1;
|
||||
|
|
@ -1287,9 +1287,9 @@ int do_huge_pmd_numa_page(struct fault_env *fe, pmd_t pmd)
|
|||
* Migrate the THP to the requested node, returns with page unlocked
|
||||
* and access rights restored.
|
||||
*/
|
||||
spin_unlock(fe->ptl);
|
||||
spin_unlock(vmf->ptl);
|
||||
migrated = migrate_misplaced_transhuge_page(vma->vm_mm, vma,
|
||||
fe->pmd, pmd, fe->address, page, target_nid);
|
||||
vmf->pmd, pmd, vmf->address, page, target_nid);
|
||||
if (migrated) {
|
||||
flags |= TNF_MIGRATED;
|
||||
page_nid = target_nid;
|
||||
|
|
@ -1304,18 +1304,19 @@ clear_pmdnuma:
|
|||
pmd = pmd_mkyoung(pmd);
|
||||
if (was_writable)
|
||||
pmd = pmd_mkwrite(pmd);
|
||||
set_pmd_at(vma->vm_mm, haddr, fe->pmd, pmd);
|
||||
update_mmu_cache_pmd(vma, fe->address, fe->pmd);
|
||||
set_pmd_at(vma->vm_mm, haddr, vmf->pmd, pmd);
|
||||
update_mmu_cache_pmd(vma, vmf->address, vmf->pmd);
|
||||
unlock_page(page);
|
||||
out_unlock:
|
||||
spin_unlock(fe->ptl);
|
||||
spin_unlock(vmf->ptl);
|
||||
|
||||
out:
|
||||
if (anon_vma)
|
||||
page_unlock_anon_vma_read(anon_vma);
|
||||
|
||||
if (page_nid != -1)
|
||||
task_numa_fault(last_cpupid, page_nid, HPAGE_PMD_NR, fe->flags);
|
||||
task_numa_fault(last_cpupid, page_nid, HPAGE_PMD_NR,
|
||||
vmf->flags);
|
||||
|
||||
return 0;
|
||||
}
|
||||
|
|
|
|||
|
|
@ -36,7 +36,7 @@
|
|||
/* Do not use these with a slab allocator */
|
||||
#define GFP_SLAB_BUG_MASK (__GFP_DMA32|__GFP_HIGHMEM|~__GFP_BITS_MASK)
|
||||
|
||||
int do_swap_page(struct fault_env *fe, pte_t orig_pte);
|
||||
int do_swap_page(struct vm_fault *vmf);
|
||||
|
||||
void free_pgtables(struct mmu_gather *tlb, struct vm_area_struct *start_vma,
|
||||
unsigned long floor, unsigned long ceiling);
|
||||
|
|
|
|||
|
|
@ -875,13 +875,13 @@ static bool __collapse_huge_page_swapin(struct mm_struct *mm,
|
|||
unsigned long address, pmd_t *pmd,
|
||||
int referenced)
|
||||
{
|
||||
pte_t pteval;
|
||||
int swapped_in = 0, ret = 0;
|
||||
struct fault_env fe = {
|
||||
struct vm_fault vmf = {
|
||||
.vma = vma,
|
||||
.address = address,
|
||||
.flags = FAULT_FLAG_ALLOW_RETRY,
|
||||
.pmd = pmd,
|
||||
.pgoff = linear_page_index(vma, address),
|
||||
};
|
||||
|
||||
/* we only decide to swapin, if there is enough young ptes */
|
||||
|
|
@ -889,19 +889,19 @@ static bool __collapse_huge_page_swapin(struct mm_struct *mm,
|
|||
trace_mm_collapse_huge_page_swapin(mm, swapped_in, referenced, 0);
|
||||
return false;
|
||||
}
|
||||
fe.pte = pte_offset_map(pmd, address);
|
||||
for (; fe.address < address + HPAGE_PMD_NR*PAGE_SIZE;
|
||||
fe.pte++, fe.address += PAGE_SIZE) {
|
||||
pteval = *fe.pte;
|
||||
if (!is_swap_pte(pteval))
|
||||
vmf.pte = pte_offset_map(pmd, address);
|
||||
for (; vmf.address < address + HPAGE_PMD_NR*PAGE_SIZE;
|
||||
vmf.pte++, vmf.address += PAGE_SIZE) {
|
||||
vmf.orig_pte = *vmf.pte;
|
||||
if (!is_swap_pte(vmf.orig_pte))
|
||||
continue;
|
||||
swapped_in++;
|
||||
ret = do_swap_page(&fe, pteval);
|
||||
ret = do_swap_page(&vmf);
|
||||
|
||||
/* do_swap_page returns VM_FAULT_RETRY with released mmap_sem */
|
||||
if (ret & VM_FAULT_RETRY) {
|
||||
down_read(&mm->mmap_sem);
|
||||
if (hugepage_vma_revalidate(mm, address, &fe.vma)) {
|
||||
if (hugepage_vma_revalidate(mm, address, &vmf.vma)) {
|
||||
/* vma is no longer available, don't continue to swapin */
|
||||
trace_mm_collapse_huge_page_swapin(mm, swapped_in, referenced, 0);
|
||||
return false;
|
||||
|
|
@ -915,10 +915,10 @@ static bool __collapse_huge_page_swapin(struct mm_struct *mm,
|
|||
return false;
|
||||
}
|
||||
/* pte is unmapped now, we need to map it */
|
||||
fe.pte = pte_offset_map(pmd, fe.address);
|
||||
vmf.pte = pte_offset_map(pmd, vmf.address);
|
||||
}
|
||||
fe.pte--;
|
||||
pte_unmap(fe.pte);
|
||||
vmf.pte--;
|
||||
pte_unmap(vmf.pte);
|
||||
trace_mm_collapse_huge_page_swapin(mm, swapped_in, referenced, 1);
|
||||
return true;
|
||||
}
|
||||
|
|
@ -1446,7 +1446,7 @@ static void collapse_shmem(struct mm_struct *mm,
|
|||
radix_tree_replace_slot(&mapping->page_tree, slot,
|
||||
new_page + (index % HPAGE_PMD_NR));
|
||||
|
||||
slot = radix_tree_iter_next(&iter);
|
||||
slot = radix_tree_iter_resume(slot, &iter);
|
||||
index++;
|
||||
continue;
|
||||
out_lru:
|
||||
|
|
@ -1546,7 +1546,6 @@ tree_unlocked:
|
|||
/* Put holes back where they were */
|
||||
radix_tree_delete(&mapping->page_tree,
|
||||
iter.index);
|
||||
slot = radix_tree_iter_next(&iter);
|
||||
continue;
|
||||
}
|
||||
|
||||
|
|
@ -1557,11 +1556,11 @@ tree_unlocked:
|
|||
page_ref_unfreeze(page, 2);
|
||||
radix_tree_replace_slot(&mapping->page_tree,
|
||||
slot, page);
|
||||
slot = radix_tree_iter_resume(slot, &iter);
|
||||
spin_unlock_irq(&mapping->tree_lock);
|
||||
putback_lru_page(page);
|
||||
unlock_page(page);
|
||||
spin_lock_irq(&mapping->tree_lock);
|
||||
slot = radix_tree_iter_next(&iter);
|
||||
}
|
||||
VM_BUG_ON(nr_none);
|
||||
spin_unlock_irq(&mapping->tree_lock);
|
||||
|
|
@ -1641,8 +1640,8 @@ static void khugepaged_scan_shmem(struct mm_struct *mm,
|
|||
present++;
|
||||
|
||||
if (need_resched()) {
|
||||
slot = radix_tree_iter_resume(slot, &iter);
|
||||
cond_resched_rcu();
|
||||
slot = radix_tree_iter_next(&iter);
|
||||
}
|
||||
}
|
||||
rcu_read_unlock();
|
||||
|
|
|
|||
859
mm/memory.c
859
mm/memory.c
File diff suppressed because it is too large
Load diff
10
mm/nommu.c
10
mm/nommu.c
|
|
@ -176,9 +176,10 @@ long get_user_pages_locked(unsigned long start, unsigned long nr_pages,
|
|||
}
|
||||
EXPORT_SYMBOL(get_user_pages_locked);
|
||||
|
||||
long __get_user_pages_unlocked(struct task_struct *tsk, struct mm_struct *mm,
|
||||
unsigned long start, unsigned long nr_pages,
|
||||
struct page **pages, unsigned int gup_flags)
|
||||
static long __get_user_pages_unlocked(struct task_struct *tsk,
|
||||
struct mm_struct *mm, unsigned long start,
|
||||
unsigned long nr_pages, struct page **pages,
|
||||
unsigned int gup_flags)
|
||||
{
|
||||
long ret;
|
||||
down_read(&mm->mmap_sem);
|
||||
|
|
@ -187,7 +188,6 @@ long __get_user_pages_unlocked(struct task_struct *tsk, struct mm_struct *mm,
|
|||
up_read(&mm->mmap_sem);
|
||||
return ret;
|
||||
}
|
||||
EXPORT_SYMBOL(__get_user_pages_unlocked);
|
||||
|
||||
long get_user_pages_unlocked(unsigned long start, unsigned long nr_pages,
|
||||
struct page **pages, unsigned int gup_flags)
|
||||
|
|
@ -1801,7 +1801,7 @@ int filemap_fault(struct vm_area_struct *vma, struct vm_fault *vmf)
|
|||
}
|
||||
EXPORT_SYMBOL(filemap_fault);
|
||||
|
||||
void filemap_map_pages(struct fault_env *fe,
|
||||
void filemap_map_pages(struct vm_fault *vmf,
|
||||
pgoff_t start_pgoff, pgoff_t end_pgoff)
|
||||
{
|
||||
BUG();
|
||||
|
|
|
|||
|
|
@ -2106,18 +2106,26 @@ void tag_pages_for_writeback(struct address_space *mapping,
|
|||
pgoff_t start, pgoff_t end)
|
||||
{
|
||||
#define WRITEBACK_TAG_BATCH 4096
|
||||
unsigned long tagged;
|
||||
unsigned long tagged = 0;
|
||||
struct radix_tree_iter iter;
|
||||
void **slot;
|
||||
|
||||
do {
|
||||
spin_lock_irq(&mapping->tree_lock);
|
||||
tagged = radix_tree_range_tag_if_tagged(&mapping->page_tree,
|
||||
&start, end, WRITEBACK_TAG_BATCH,
|
||||
PAGECACHE_TAG_DIRTY, PAGECACHE_TAG_TOWRITE);
|
||||
spin_lock_irq(&mapping->tree_lock);
|
||||
radix_tree_for_each_tagged(slot, &mapping->page_tree, &iter, start,
|
||||
PAGECACHE_TAG_DIRTY) {
|
||||
if (iter.index > end)
|
||||
break;
|
||||
radix_tree_iter_tag_set(&mapping->page_tree, &iter,
|
||||
PAGECACHE_TAG_TOWRITE);
|
||||
tagged++;
|
||||
if ((tagged % WRITEBACK_TAG_BATCH) != 0)
|
||||
continue;
|
||||
slot = radix_tree_iter_resume(slot, &iter);
|
||||
spin_unlock_irq(&mapping->tree_lock);
|
||||
WARN_ON_ONCE(tagged > WRITEBACK_TAG_BATCH);
|
||||
cond_resched();
|
||||
/* We check 'start' to handle wrapping when end == ~0UL */
|
||||
} while (tagged >= WRITEBACK_TAG_BATCH && start);
|
||||
spin_lock_irq(&mapping->tree_lock);
|
||||
}
|
||||
spin_unlock_irq(&mapping->tree_lock);
|
||||
}
|
||||
EXPORT_SYMBOL(tag_pages_for_writeback);
|
||||
|
||||
|
|
|
|||
|
|
@ -3925,6 +3925,20 @@ static struct page *__page_frag_refill(struct page_frag_cache *nc,
|
|||
return page;
|
||||
}
|
||||
|
||||
void __page_frag_drain(struct page *page, unsigned int order,
|
||||
unsigned int count)
|
||||
{
|
||||
VM_BUG_ON_PAGE(page_ref_count(page) == 0, page);
|
||||
|
||||
if (page_ref_sub_and_test(page, count)) {
|
||||
if (order == 0)
|
||||
free_hot_cold_page(page, false);
|
||||
else
|
||||
__free_pages_ok(page, order);
|
||||
}
|
||||
}
|
||||
EXPORT_SYMBOL(__page_frag_drain);
|
||||
|
||||
void *__alloc_page_frag(struct page_frag_cache *nc,
|
||||
unsigned int fragsz, gfp_t gfp_mask)
|
||||
{
|
||||
|
|
|
|||
|
|
@ -88,7 +88,7 @@ static int process_vm_rw_single_vec(unsigned long addr,
|
|||
ssize_t rc = 0;
|
||||
unsigned long max_pages_per_loop = PVM_MAX_KMALLOC_PAGES
|
||||
/ sizeof(struct pages *);
|
||||
unsigned int flags = FOLL_REMOTE;
|
||||
unsigned int flags = 0;
|
||||
|
||||
/* Work out address and page range required */
|
||||
if (len == 0)
|
||||
|
|
@ -100,15 +100,19 @@ static int process_vm_rw_single_vec(unsigned long addr,
|
|||
|
||||
while (!rc && nr_pages && iov_iter_count(iter)) {
|
||||
int pages = min(nr_pages, max_pages_per_loop);
|
||||
int locked = 1;
|
||||
size_t bytes;
|
||||
|
||||
/*
|
||||
* Get the pages we're interested in. We must
|
||||
* add FOLL_REMOTE because task/mm might not
|
||||
* access remotely because task/mm might not
|
||||
* current/current->mm
|
||||
*/
|
||||
pages = __get_user_pages_unlocked(task, mm, pa, pages,
|
||||
process_pages, flags);
|
||||
down_read(&mm->mmap_sem);
|
||||
pages = get_user_pages_remote(task, mm, pa, pages, flags,
|
||||
process_pages, NULL, &locked);
|
||||
if (locked)
|
||||
up_read(&mm->mmap_sem);
|
||||
if (pages <= 0)
|
||||
return -EFAULT;
|
||||
|
||||
|
|
|
|||
32
mm/shmem.c
32
mm/shmem.c
|
|
@ -661,8 +661,8 @@ unsigned long shmem_partial_swap_usage(struct address_space *mapping,
|
|||
swapped++;
|
||||
|
||||
if (need_resched()) {
|
||||
slot = radix_tree_iter_resume(slot, &iter);
|
||||
cond_resched_rcu();
|
||||
slot = radix_tree_iter_next(&iter);
|
||||
}
|
||||
}
|
||||
|
||||
|
|
@ -1049,6 +1049,30 @@ static void shmem_evict_inode(struct inode *inode)
|
|||
clear_inode(inode);
|
||||
}
|
||||
|
||||
static unsigned long find_swap_entry(struct radix_tree_root *root, void *item)
|
||||
{
|
||||
struct radix_tree_iter iter;
|
||||
void **slot;
|
||||
unsigned long found = -1;
|
||||
unsigned int checked = 0;
|
||||
|
||||
rcu_read_lock();
|
||||
radix_tree_for_each_slot(slot, root, &iter, 0) {
|
||||
if (*slot == item) {
|
||||
found = iter.index;
|
||||
break;
|
||||
}
|
||||
checked++;
|
||||
if ((checked % 4096) != 0)
|
||||
continue;
|
||||
slot = radix_tree_iter_resume(slot, &iter);
|
||||
cond_resched_rcu();
|
||||
}
|
||||
|
||||
rcu_read_unlock();
|
||||
return found;
|
||||
}
|
||||
|
||||
/*
|
||||
* If swap found in inode, free it and move page from swapcache to filecache.
|
||||
*/
|
||||
|
|
@ -1062,7 +1086,7 @@ static int shmem_unuse_inode(struct shmem_inode_info *info,
|
|||
int error = 0;
|
||||
|
||||
radswap = swp_to_radix_entry(swap);
|
||||
index = radix_tree_locate_item(&mapping->page_tree, radswap);
|
||||
index = find_swap_entry(&mapping->page_tree, radswap);
|
||||
if (index == -1)
|
||||
return -EAGAIN; /* tell shmem_unuse we found nothing */
|
||||
|
||||
|
|
@ -2447,8 +2471,8 @@ static void shmem_tag_pins(struct address_space *mapping)
|
|||
}
|
||||
|
||||
if (need_resched()) {
|
||||
slot = radix_tree_iter_resume(slot, &iter);
|
||||
cond_resched_rcu();
|
||||
slot = radix_tree_iter_next(&iter);
|
||||
}
|
||||
}
|
||||
rcu_read_unlock();
|
||||
|
|
@ -2517,8 +2541,8 @@ static int shmem_wait_for_pins(struct address_space *mapping)
|
|||
spin_unlock_irq(&mapping->tree_lock);
|
||||
continue_resched:
|
||||
if (need_resched()) {
|
||||
slot = radix_tree_iter_resume(slot, &iter);
|
||||
cond_resched_rcu();
|
||||
slot = radix_tree_iter_next(&iter);
|
||||
}
|
||||
}
|
||||
rcu_read_unlock();
|
||||
|
|
|
|||
Loading…
Reference in a new issue