Message-ID: <CAD=HUj67pC_0f8LwaD_bcYvtpZ1Wi8Hz2SpZD7eXpBVgmZ3p8g@mail.gmail.com>
Date:   Tue, 7 Feb 2023 12:56:56 +0900
From:   David Stevens <stevensd@...omium.org>
To:     Peter Xu <peterx@...hat.com>
Cc:     linux-mm@...ck.org, Andrew Morton <akpm@...ux-foundation.org>,
        "Kirill A . Shutemov" <kirill@...temov.name>,
        Yang Shi <shy828301@...il.com>,
        David Hildenbrand <david@...hat.com>,
        Hugh Dickins <hughd@...gle.com>, linux-kernel@...r.kernel.org
Subject: Re: [PATCH v2] mm/khugepaged: skip shmem with userfaultfd

On Tue, Feb 7, 2023 at 6:02 AM Peter Xu <peterx@...hat.com> wrote:
>
> On Mon, Feb 06, 2023 at 08:28:56PM +0900, David Stevens wrote:
> > From: David Stevens <stevensd@...omium.org>
> >
> > Collapsing memory will result in any empty pages in the target range
> > being filled by the new THP. If userspace has a userfaultfd registered
> > with MODE_MISSING, for any page which it knows to be missing after
> > registering the userfaultfd, it may expect a UFFD_EVENT_PAGEFAULT.
> > Taking these two facts together, khugepaged needs to take care when
> > collapsing pages in shmem to make sure it doesn't break the userfaultfd
> > API.
> >
> > This change first makes sure that the intermediate page cache state
> > during collapse is not visible by moving when gaps are filled to after
> > the page cache lock is acquired for the final time. This is necessary
> > because the synchronization provided by locking hpage is insufficient
> > for functions which operate on the page cache without actually locking
> > individual pages to examine their content (e.g. shmem_mfill_atomic_pte).
> >
> > This refactoring allows us to iterate over i_mmap to check for any VMAs
> > with userfaultfds and then finalize the collapse if no such VMAs exist,
> > all while holding the page cache lock. Since no mm locks are held, it is
> > necessary to add smb_rmb/smb_wmb to ensure that userfaultfd updates to
> > vm_flags are visible to khugepaged. However, no further locking of
> > userfaultfd state is necessary. Although new userfaultfds can be
> > registered concurrently with finalizing the collapse, any missing pages
> > that are being replaced can no longer be observed by userspace, so there
> > is no data race.
> >
> > This fix is targeted at khugepaged, but the change also applies to
> > MADV_COLLAPSE. The fact that the intermediate page cache state before
> > the rollback of a failed collapse can no longer be observed is
> > technically a userspace-visible change (via at least SEEK_DATA and
> > SEEK_END), but it is exceedingly unlikely that anything relies on being
> > able to observe that transient state.
> >
> > Signed-off-by: David Stevens <stevensd@...omium.org>
> > ---
> >  fs/userfaultfd.c |  2 ++
> >  mm/khugepaged.c  | 67 ++++++++++++++++++++++++++++++++++++++++--------
> >  2 files changed, 59 insertions(+), 10 deletions(-)
> >
> > diff --git a/fs/userfaultfd.c b/fs/userfaultfd.c
> > index cc694846617a..6ddfcff11920 100644
> > --- a/fs/userfaultfd.c
> > +++ b/fs/userfaultfd.c
> > @@ -114,6 +114,8 @@ static void userfaultfd_set_vm_flags(struct vm_area_struct *vma,
> >       const bool uffd_wp_changed = (vma->vm_flags ^ flags) & VM_UFFD_WP;
> >
> >       vma->vm_flags = flags;
> > +     /* Pairs with smp_rmb() in khugepaged's collapse_file() */
> > +     smp_wmb();
>
> Could you help to explain why this is needed?  What's the operation to
> serialize against updating vm_flags?

We need to ensure that any updates to VM_UFFD_MISSING from
UFFDIO_REGISTER are visible to khugepaged before the ioctl returns to
userspace. There aren't any locks that obviously provide that
synchronization, so I added the smp_wmb/smp_rmb pair. It's possible
that page cache lock indirectly provides sufficient synchronization,
though.

> >       /*
> >        * For shared mappings, we want to enable writenotify while
> >        * userfaultfd-wp is enabled (see vma_wants_writenotify()). We'll simply
> > diff --git a/mm/khugepaged.c b/mm/khugepaged.c
> > index 79be13133322..97435c226b18 100644
> > --- a/mm/khugepaged.c
> > +++ b/mm/khugepaged.c
> > @@ -55,6 +55,7 @@ enum scan_result {
> >       SCAN_CGROUP_CHARGE_FAIL,
> >       SCAN_TRUNCATED,
> >       SCAN_PAGE_HAS_PRIVATE,
> > +     SCAN_PAGE_FILLED,
> >  };
> >
> >  #define CREATE_TRACE_POINTS
> > @@ -1725,8 +1726,8 @@ static int retract_page_tables(struct address_space *mapping, pgoff_t pgoff,
> >   *  - allocate and lock a new huge page;
> >   *  - scan page cache replacing old pages with the new one
> >   *    + swap/gup in pages if necessary;
> > - *    + fill in gaps;
> >   *    + keep old pages around in case rollback is required;
> > + *  - finalize updates to the page cache;
> >   *  - if replacing succeeds:
> >   *    + copy data over;
> >   *    + free old pages;
> > @@ -1747,6 +1748,7 @@ static int collapse_file(struct mm_struct *mm, unsigned long addr,
> >       XA_STATE_ORDER(xas, &mapping->i_pages, start, HPAGE_PMD_ORDER);
> >       int nr_none = 0, result = SCAN_SUCCEED;
> >       bool is_shmem = shmem_file(file);
> > +     bool i_mmap_locked = false;
> >       int nr = 0;
> >
> >       VM_BUG_ON(!IS_ENABLED(CONFIG_READ_ONLY_THP_FOR_FS) && !is_shmem);
> > @@ -1780,8 +1782,14 @@ static int collapse_file(struct mm_struct *mm, unsigned long addr,
> >
> >       /*
> >        * At this point the hpage is locked and not up-to-date.
> > -      * It's safe to insert it into the page cache, because nobody would
> > -      * be able to map it or use it in another way until we unlock it.
> > +      *
> > +      * While iterating, we may drop the page cache lock multiple times. It
> > +      * is safe to replace pages in the page cache with hpage while doing so
> > +      * because nobody is able to map or otherwise access the content of
> > +      * hpage until we unlock it. However, we cannot insert hpage into empty
> > +      * indicies until we know we won't have to drop the page cache lock
> > +      * again, as doing so would let things which only check the presence
> > +      * of pages in the page cache see a state that may yet be rolled back.
> >        */
> >
> >       xas_set(&xas, start);
> > @@ -1802,13 +1810,12 @@ static int collapse_file(struct mm_struct *mm, unsigned long addr,
> >                                               result = SCAN_TRUNCATED;
> >                                               goto xa_locked;
> >                                       }
> > -                                     xas_set(&xas, index);
> > +                                     xas_set(&xas, index + 1);
>
> I failed to figure out why this index needs a shift here... It seems to me
> it'll ignore the initial empty page cache, is that what the patch wanted?

This chunk is preceded by a call to xas_next_entry. Previously,
xas_store(hpage) would pair with xas_set(index) to walk the xarray and
prepare xas for the xas_next at the start of the next loop iteration.
Now that we're no longer calling xas_store, xas_set(index+1) is
necessary to prepare xas for the next iteration of the loop.

> >                               }
> >                               if (!shmem_charge(mapping->host, 1)) {
> >                                       result = SCAN_FAIL;
> >                                       goto xa_locked;
> >                               }
> > -                             xas_store(&xas, hpage);
>
> [I raised a question in the other thread on whether it's legal to not
>  populate page cache holes at all.  We can keep the discussion there]
>
> >                               nr_none++;
> >                               continue;
> >                       }
> > @@ -1967,6 +1974,46 @@ static int collapse_file(struct mm_struct *mm, unsigned long addr,
> >               put_page(page);
> >               goto xa_unlocked;
> >       }
> > +
> > +     if (nr_none) {
> > +             struct vm_area_struct *vma;
> > +             int nr_none_check = 0;
> > +
> > +             xas_unlock_irq(&xas);
> > +             i_mmap_lock_read(mapping);
> > +             i_mmap_locked = true;
> > +             xas_lock_irq(&xas);
> > +
> > +             xas_set(&xas, start);
> > +             for (index = start; index < end; index++) {
> > +                     if (!xas_next(&xas))
> > +                             nr_none_check++;
> > +             }
> > +
> > +             if (nr_none != nr_none_check) {
> > +                     result = SCAN_PAGE_FILLED;
> > +                     goto xa_locked;
> > +             }
> > +
> > +             /*
> > +              * If userspace observed a missing page in a VMA with an armed
> > +              * userfaultfd, then it might expect a UFFD_EVENT_PAGEFAULT for
> > +              * that page, so we need to roll back to avoid suppressing such
> > +              * an event. Any userfaultfds armed after this point will not be
> > +              * able to observe any missing pages, since the page cache is
> > +              * locked until after the collapse is completed.
> > +              *
> > +              * Pairs with smp_wmb() in userfaultfd_set_vm_flags().
> > +              */
> > +             smp_rmb();
> > +             vma_interval_tree_foreach(vma, &mapping->i_mmap, start, start) {
> > +                     if (userfaultfd_missing(vma)) {
> > +                             result = SCAN_EXCEED_NONE_PTE;
> > +                             goto xa_locked;
> > +                     }
> > +             }
> > +     }
>
> Thanks for writting the patch, but I am still confused why this can avoid
> race conditions of uffd missing mode.
>
> I assume UFFDIO_REGISTER is defined as: after UFFDIO_REGISTER ioctl
> succeeded on a specific shmem VMA, any page faults due to missing page
> cache on this vma should generate a page fault.  If not, it's violating the
> userfaultfd semantics.
>
> Here, I don't see what stops a new vma from registering MISSING mode right
> away in parallel of collapsing.
>
> When registration completes, it means we should report uffd missing
> messages on the holes that collapse_file() scanned previously.  However
> they'll be filled very possibly later with the thp which means the messages
> can be lost.  Then the issue can still happen, while this patch only makes
> it very unlikely to happen, or am I wrong?

This race can still happen, but I don't think it's actually a problem.
In particular, I think the semantics you've given for UFFDIO_REGISTER
are overly restrictive on the kernel in a way that provides no
meaningful benefit to userspace.

To simplify things a little bit, we only need to consider going from
zero to non-zero (i.e. one) userfaultfd. The case where a userfaultfd
is already registered isn't particularly interesting, since khugepaged
would have seen the existing userfaultfd and given up on the collapse.

When userspace registers the first userfaultfd, it cannot rely on any
knowledge about the presence or absence of pages from before when
UFFDIO_REGISTER completes. This is because, as far as userspace is
concerned, khugepaged could have come along and collapsed every single
page in the shmem right after UFFDIO_REGISTER entered the kernel. So
to properly use the userfaultfd API, userspace must re-examine the
state of memory after UFFDIO_REGISTER completes. Because of that,
having UFFDIO_REGISTER be a complete barrier with regards to
khugepaged is essentially meaningless from the perspective of
userspace. The guarantee might slightly reduce the window for some
races in userspace programs, but there are no userspace races that it
can completely resolve.

Given that, the kernel just needs to guarantee that no missing page
which userspace might have observed after registering a userfaultfd is
filled by khugepaged. This patch takes the page cache lock, checks
that there are no registered userfaultfds, fills the missing pages,
and then releases the page cache lock. That's sufficient to guarantee
that any UFFDIO_REGISTER which occurs after the userfaultfd check but
before we finish the collapse can't actually observe any missing
pages.

-David





> Thanks,
>
> > +
> >       nr = thp_nr_pages(hpage);
> >
> >       if (is_shmem)
> > @@ -2000,6 +2047,8 @@ static int collapse_file(struct mm_struct *mm, unsigned long addr,
> >       xas_store(&xas, hpage);
> >  xa_locked:
> >       xas_unlock_irq(&xas);
> > +     if (i_mmap_locked)
> > +             i_mmap_unlock_read(mapping);
> >  xa_unlocked:
> >
> >       /*
> > @@ -2065,15 +2114,13 @@ static int collapse_file(struct mm_struct *mm, unsigned long addr,
> >               }
> >
> >               xas_set(&xas, start);
> > -             xas_for_each(&xas, page, end - 1) {
> > +             end = index;
> > +             for (index = start; index < end; index++) {
> > +                     xas_next(&xas);
> >                       page = list_first_entry_or_null(&pagelist,
> >                                       struct page, lru);
> >                       if (!page || xas.xa_index < page->index) {
> > -                             if (!nr_none)
> > -                                     break;
> >                               nr_none--;
> > -                             /* Put holes back where they were */
> > -                             xas_store(&xas, NULL);
> >                               continue;
> >                       }
> >
> > --
> > 2.39.1.519.gcb327c4b5f-goog
> >
>
> --
> Peter Xu
>

Powered by blists - more mailing lists