From: Mika Penttilä <[email protected]>

Implement the needed hmm_vma_handle_migrate_prepare_pmd() function
which is mostly carried over from migrate_device.c's
migrate_vma_collect_huge_pmd() function.

With HMM pagewalk based migration, the idea is that
hmm_vma_handle_*() are responsible for faulting,
and the pfn collecting part. hmm_vma_handle_migrate_prepare*()
do the migration decisions (with HMM_PFN_MIGRATE), possibly split
folios, and insert migration ptes/pmds.

HMM pagewalk based migration is enabled in later commit, for now
now hmm_select_migrate() returns 0.

Cc: David Hildenbrand <[email protected]>
Cc: Jason Gunthorpe <[email protected]>
Cc: Leon Romanovsky <[email protected]>
Cc: Alistair Popple <[email protected]>
Cc: Balbir Singh <[email protected]>
Cc: Zi Yan <[email protected]>
Cc: Matthew Brost <[email protected]>
Suggested-by: Alistair Popple <[email protected]>
Signed-off-by: Mika Penttilä <[email protected]>
---
 mm/hmm.c | 96 ++++++++++++++++++++++++++++++++++++++++++++++++++++++--
 1 file changed, 94 insertions(+), 2 deletions(-)

diff --git a/mm/hmm.c b/mm/hmm.c
index 2d902b8bcd58..61b9147fd8ed 100644
--- a/mm/hmm.c
+++ b/mm/hmm.c
@@ -549,8 +549,100 @@ static int hmm_vma_handle_migrate_prepare_pmd(const 
struct mm_walk *walk,
                                              unsigned long end,
                                              unsigned long *hmm_pfn)
 {
-       // TODO: implement migration entry insertion
-       return 0;
+       struct hmm_vma_walk *hmm_vma_walk = walk->private;
+       struct hmm_range *range = hmm_vma_walk->range;
+       struct migrate_vma *migrate = range->migrate;
+       struct folio *fault_folio = NULL;
+       enum migrate_vma_info minfo;
+       struct folio *folio;
+       unsigned long i;
+       int r = 0;
+
+       // Do we want to migrate at all?
+       minfo = hmm_select_migrate(range);
+       if (!minfo)
+               return r;
+
+       WARN_ON_ONCE(!migrate);
+       HMM_ASSERT_PMD_LOCKED(hmm_vma_walk, true);
+
+       fault_folio = migrate->fault_page ?
+               page_folio(migrate->fault_page) : NULL;
+
+       if (pmd_none(*pmdp))
+               return hmm_pfns_fill(start, end, hmm_vma_walk, 0);
+
+       if (!(hmm_pfn[0] & HMM_PFN_VALID))
+               goto out;
+
+       if (pmd_trans_huge(*pmdp)) {
+               if (!(minfo & MIGRATE_VMA_SELECT_SYSTEM))
+                       goto out;
+
+               folio = pmd_folio(*pmdp);
+               if (is_huge_zero_folio(folio))
+                       return hmm_pfns_fill(start, end, hmm_vma_walk, 0);
+
+       } else if (!pmd_present(*pmdp)) {
+               const softleaf_t entry = softleaf_from_pmd(*pmdp);
+
+               if (!softleaf_is_device_private(entry))
+                       goto out;
+
+               if (!(minfo & MIGRATE_VMA_SELECT_DEVICE_PRIVATE))
+                       goto out;
+
+               folio = softleaf_to_folio(entry);
+               if (folio->pgmap->owner != migrate->pgmap_owner)
+                       goto out;
+       } else {
+               hmm_vma_walk->last = start;
+               return -EBUSY;
+       }
+
+       folio_get(folio);
+
+       if (folio != fault_folio && unlikely(!folio_trylock(folio))) {
+               folio_put(folio);
+               hmm_pfns_fill(start, end, hmm_vma_walk, HMM_PFN_ERROR);
+               return 0;
+       }
+
+       if (thp_migration_supported() &&
+           (migrate->flags & MIGRATE_VMA_SELECT_COMPOUND) &&
+           (IS_ALIGNED(start, HPAGE_PMD_SIZE) &&
+            IS_ALIGNED(end, HPAGE_PMD_SIZE))) {
+               struct page_vma_mapped_walk pvmw = {
+                       .ptl = hmm_vma_walk->ptl,
+                       .address = start,
+                       .pmd = pmdp,
+                       .vma = walk->vma,
+               };
+
+               hmm_pfn[0] |= HMM_PFN_MIGRATE | HMM_PFN_COMPOUND;
+
+               r = set_pmd_migration_entry(&pvmw, folio_page(folio, 0));
+               if (r) {
+                       hmm_pfn[0] &= ~(HMM_PFN_MIGRATE | HMM_PFN_COMPOUND);
+                       r = -ENOENT;  // fallback
+                       goto unlock_out;
+               }
+               for (i = 1, start += PAGE_SIZE; start < end; start += 
PAGE_SIZE, i++)
+                       hmm_pfn[i] &= HMM_PFN_INOUT_FLAGS;
+
+       } else {
+               r = -ENOENT;  // fallback
+               goto unlock_out;
+       }
+
+out:
+       return r;
+
+unlock_out:
+       if (folio != fault_folio)
+               folio_unlock(folio);
+       folio_put(folio);
+       goto out;
 }
 
 /*
-- 
2.55.0

Reply via email to