selftests/mm: rename uffd_stats to uffd_args
authorPeter Xu <peterx@redhat.com>
Wed, 12 Apr 2023 16:43:37 +0000 (12:43 -0400)
committerAndrew Morton <akpm@linux-foundation.org>
Tue, 18 Apr 2023 23:30:06 +0000 (16:30 -0700)
Prepare for adding more fields into the struct.

Link: https://lkml.kernel.org/r/20230412164337.328607-1-peterx@redhat.com
Signed-off-by: Peter Xu <peterx@redhat.com>
Suggested-by: Mike Rapoport (IBM) <rppt@kernel.org>
Cc: Axel Rasmussen <axelrasmussen@google.com>
Cc: David Hildenbrand <david@redhat.com>
Cc: Dmitry Safonov <0x7f454c46@gmail.com>
Cc: Mike Kravetz <mike.kravetz@oracle.com>
Cc: Zach O'Keefe <zokeefe@google.com>
Signed-off-by: Andrew Morton <akpm@linux-foundation.org>
tools/testing/selftests/mm/uffd-common.c
tools/testing/selftests/mm/uffd-common.h
tools/testing/selftests/mm/uffd-stress.c

index f02dfcf107149b69536a1840ea1f7469c23a30ef..e746405aa8f37ad69071ba32c27018580198e948 100644 (file)
@@ -186,34 +186,34 @@ struct uffd_test_ops hugetlb_uffd_test_ops = {
        .check_pmd_mapping = NULL,
 };
 
-void uffd_stats_report(struct uffd_stats *stats, int n_cpus)
+void uffd_stats_report(struct uffd_args *args, int n_cpus)
 {
        int i;
        unsigned long long miss_total = 0, wp_total = 0, minor_total = 0;
 
        for (i = 0; i < n_cpus; i++) {
-               miss_total += stats[i].missing_faults;
-               wp_total += stats[i].wp_faults;
-               minor_total += stats[i].minor_faults;
+               miss_total += args[i].missing_faults;
+               wp_total += args[i].wp_faults;
+               minor_total += args[i].minor_faults;
        }
 
        printf("userfaults: ");
        if (miss_total) {
                printf("%llu missing (", miss_total);
                for (i = 0; i < n_cpus; i++)
-                       printf("%lu+", stats[i].missing_faults);
+                       printf("%lu+", args[i].missing_faults);
                printf("\b) ");
        }
        if (wp_total) {
                printf("%llu wp (", wp_total);
                for (i = 0; i < n_cpus; i++)
-                       printf("%lu+", stats[i].wp_faults);
+                       printf("%lu+", args[i].wp_faults);
                printf("\b) ");
        }
        if (minor_total) {
                printf("%llu minor (", minor_total);
                for (i = 0; i < n_cpus; i++)
-                       printf("%lu+", stats[i].minor_faults);
+                       printf("%lu+", args[i].minor_faults);
                printf("\b)");
        }
        printf("\n");
@@ -397,7 +397,7 @@ int uffd_read_msg(int ufd, struct uffd_msg *msg)
        return 0;
 }
 
-void uffd_handle_page_fault(struct uffd_msg *msg, struct uffd_stats *stats)
+void uffd_handle_page_fault(struct uffd_msg *msg, struct uffd_args *args)
 {
        unsigned long offset;
 
@@ -407,7 +407,7 @@ void uffd_handle_page_fault(struct uffd_msg *msg, struct uffd_stats *stats)
        if (msg->arg.pagefault.flags & UFFD_PAGEFAULT_FLAG_WP) {
                /* Write protect page faults */
                wp_range(uffd, msg->arg.pagefault.address, page_size, false);
-               stats->wp_faults++;
+               args->wp_faults++;
        } else if (msg->arg.pagefault.flags & UFFD_PAGEFAULT_FLAG_MINOR) {
                uint8_t *area;
                int b;
@@ -430,7 +430,7 @@ void uffd_handle_page_fault(struct uffd_msg *msg, struct uffd_stats *stats)
                for (b = 0; b < page_size; ++b)
                        area[b] = ~area[b];
                continue_range(uffd, msg->arg.pagefault.address, page_size);
-               stats->minor_faults++;
+               args->minor_faults++;
        } else {
                /*
                 * Missing page faults.
@@ -460,14 +460,14 @@ void uffd_handle_page_fault(struct uffd_msg *msg, struct uffd_stats *stats)
                offset &= ~(page_size-1);
 
                if (copy_page(uffd, offset))
-                       stats->missing_faults++;
+                       args->missing_faults++;
        }
 }
 
 void *uffd_poll_thread(void *arg)
 {
-       struct uffd_stats *stats = (struct uffd_stats *)arg;
-       unsigned long cpu = stats->cpu;
+       struct uffd_args *args = (struct uffd_args *)arg;
+       unsigned long cpu = args->cpu;
        struct pollfd pollfd[2];
        struct uffd_msg msg;
        struct uffdio_register uffd_reg;
@@ -502,7 +502,7 @@ void *uffd_poll_thread(void *arg)
                        err("unexpected msg event %u\n", msg.event);
                        break;
                case UFFD_EVENT_PAGEFAULT:
-                       uffd_handle_page_fault(&msg, stats);
+                       uffd_handle_page_fault(&msg, args);
                        break;
                case UFFD_EVENT_FORK:
                        close(uffd);
index 47565b2f2dee11b21e01b70ef543544a2c1707f1..f8d2ad178827b3738e3ae7b9d733a3c41e1e4bfb 100644 (file)
@@ -70,7 +70,7 @@
                                                  -  1)))
 
 /* Userfaultfd test statistics */
-struct uffd_stats {
+struct uffd_args {
        int cpu;
        unsigned long missing_faults;
        unsigned long wp_faults;
@@ -98,12 +98,12 @@ extern uffd_test_ops_t shmem_uffd_test_ops;
 extern uffd_test_ops_t hugetlb_uffd_test_ops;
 extern uffd_test_ops_t *uffd_test_ops;
 
-void uffd_stats_report(struct uffd_stats *stats, int n_cpus);
+void uffd_stats_report(struct uffd_args *args, int n_cpus);
 void uffd_test_ctx_init(uint64_t features);
 void userfaultfd_open(uint64_t *features);
 int uffd_read_msg(int ufd, struct uffd_msg *msg);
 void wp_range(int ufd, __u64 start, __u64 len, bool wp);
-void uffd_handle_page_fault(struct uffd_msg *msg, struct uffd_stats *stats);
+void uffd_handle_page_fault(struct uffd_msg *msg, struct uffd_args *args);
 int __copy_page(int ufd, unsigned long offset, bool retry);
 int copy_page(int ufd, unsigned long offset);
 void *uffd_poll_thread(void *arg);
index 54fc9b4ffa3c26652ab67eba53e8eed4fa15ea64..ce7251ab93efa5038ddcde0ff32190013b4061a3 100644 (file)
@@ -90,16 +90,15 @@ static void usage(void)
        exit(1);
 }
 
-static void uffd_stats_reset(struct uffd_stats *uffd_stats,
-                            unsigned long n_cpus)
+static void uffd_stats_reset(struct uffd_args *args, unsigned long n_cpus)
 {
        int i;
 
        for (i = 0; i < n_cpus; i++) {
-               uffd_stats[i].cpu = i;
-               uffd_stats[i].missing_faults = 0;
-               uffd_stats[i].wp_faults = 0;
-               uffd_stats[i].minor_faults = 0;
+               args[i].cpu = i;
+               args[i].missing_faults = 0;
+               args[i].wp_faults = 0;
+               args[i].minor_faults = 0;
        }
 }
 
@@ -163,7 +162,7 @@ pthread_mutex_t uffd_read_mutex = PTHREAD_MUTEX_INITIALIZER;
 
 static void *uffd_read_thread(void *arg)
 {
-       struct uffd_stats *stats = (struct uffd_stats *)arg;
+       struct uffd_args *args = (struct uffd_args *)arg;
        struct uffd_msg msg;
 
        pthread_mutex_unlock(&uffd_read_mutex);
@@ -172,7 +171,7 @@ static void *uffd_read_thread(void *arg)
        for (;;) {
                if (uffd_read_msg(uffd, &msg))
                        continue;
-               uffd_handle_page_fault(&msg, stats);
+               uffd_handle_page_fault(&msg, args);
        }
 
        return NULL;
@@ -210,7 +209,7 @@ static void *background_thread(void *arg)
        return NULL;
 }
 
-static int stress(struct uffd_stats *uffd_stats)
+static int stress(struct uffd_args *args)
 {
        unsigned long cpu;
        pthread_t locking_threads[nr_cpus];
@@ -225,12 +224,12 @@ static int stress(struct uffd_stats *uffd_stats)
                if (bounces & BOUNCE_POLL) {
                        if (pthread_create(&uffd_threads[cpu], &attr,
                                           uffd_poll_thread,
-                                          (void *)&uffd_stats[cpu]))
+                                          (void *)&args[cpu]))
                                return 1;
                } else {
                        if (pthread_create(&uffd_threads[cpu], &attr,
                                           uffd_read_thread,
-                                          (void *)&uffd_stats[cpu]))
+                                          (void *)&args[cpu]))
                                return 1;
                        pthread_mutex_lock(&uffd_read_mutex);
                }
@@ -264,7 +263,7 @@ static int stress(struct uffd_stats *uffd_stats)
                        if (write(pipefd[cpu*2+1], &c, 1) != 1)
                                err("pipefd write error");
                        if (pthread_join(uffd_threads[cpu],
-                                        (void *)&uffd_stats[cpu]))
+                                        (void *)&args[cpu]))
                                return 1;
                } else {
                        if (pthread_cancel(uffd_threads[cpu]))
@@ -493,7 +492,7 @@ static int userfaultfd_events_test(void)
        int err, features;
        pid_t pid;
        char c;
-       struct uffd_stats stats = { 0 };
+       struct uffd_args args = { 0 };
 
        printf("testing events (fork, remap, remove): ");
        fflush(stdout);
@@ -508,7 +507,7 @@ static int userfaultfd_events_test(void)
                          true, test_uffdio_wp, false))
                err("register failure");
 
-       if (pthread_create(&uffd_mon, &attr, uffd_poll_thread, &stats))
+       if (pthread_create(&uffd_mon, &attr, uffd_poll_thread, &args))
                err("uffd_poll_thread create");
 
        pid = fork();
@@ -526,9 +525,9 @@ static int userfaultfd_events_test(void)
        if (pthread_join(uffd_mon, NULL))
                return 1;
 
-       uffd_stats_report(&stats, 1);
+       uffd_stats_report(&args, 1);
 
-       return stats.missing_faults != nr_pages;
+       return args.missing_faults != nr_pages;
 }
 
 static int userfaultfd_sig_test(void)
@@ -538,7 +537,7 @@ static int userfaultfd_sig_test(void)
        int err, features;
        pid_t pid;
        char c;
-       struct uffd_stats stats = { 0 };
+       struct uffd_args args = { 0 };
 
        printf("testing signal delivery: ");
        fflush(stdout);
@@ -557,7 +556,7 @@ static int userfaultfd_sig_test(void)
 
        uffd_test_ops->release_pages(area_dst);
 
-       if (pthread_create(&uffd_mon, &attr, uffd_poll_thread, &stats))
+       if (pthread_create(&uffd_mon, &attr, uffd_poll_thread, &args))
                err("uffd_poll_thread create");
 
        pid = fork();
@@ -606,7 +605,7 @@ static int userfaultfd_minor_test(void)
        unsigned long p;
        pthread_t uffd_mon;
        char c;
-       struct uffd_stats stats = { 0 };
+       struct uffd_args args = { 0 };
 
        if (!test_uffdio_minor)
                return 0;
@@ -629,7 +628,7 @@ static int userfaultfd_minor_test(void)
                       page_size);
        }
 
-       if (pthread_create(&uffd_mon, &attr, uffd_poll_thread, &stats))
+       if (pthread_create(&uffd_mon, &attr, uffd_poll_thread, &args))
                err("uffd_poll_thread create");
 
        /*
@@ -645,7 +644,7 @@ static int userfaultfd_minor_test(void)
        if (pthread_join(uffd_mon, NULL))
                return 1;
 
-       uffd_stats_report(&stats, 1);
+       uffd_stats_report(&args, 1);
 
        if (test_collapse) {
                printf("testing collapse of uffd memory into PMD-mapped THPs:");
@@ -664,7 +663,7 @@ static int userfaultfd_minor_test(void)
                printf(" done.\n");
        }
 
-       return stats.missing_faults != 0 || stats.minor_faults != nr_pages;
+       return args.missing_faults != 0 || args.minor_faults != nr_pages;
 }
 
 static int pagemap_open(void)
@@ -822,7 +821,7 @@ static int userfaultfd_stress(void)
 {
        void *area;
        unsigned long nr;
-       struct uffd_stats uffd_stats[nr_cpus];
+       struct uffd_args args[nr_cpus];
        uint64_t mem_size = nr_pages * page_size;
 
        uffd_test_ctx_init(UFFD_FEATURE_WP_UNPOPULATED);
@@ -894,10 +893,10 @@ static int userfaultfd_stress(void)
                 */
                uffd_test_ops->release_pages(area_dst);
 
-               uffd_stats_reset(uffd_stats, nr_cpus);
+               uffd_stats_reset(args, nr_cpus);
 
                /* bounce pass */
-               if (stress(uffd_stats))
+               if (stress(args))
                        return 1;
 
                /* Clear all the write protections if there is any */
@@ -926,7 +925,7 @@ static int userfaultfd_stress(void)
 
                swap(area_src_alias, area_dst_alias);
 
-               uffd_stats_report(uffd_stats, nr_cpus);
+               uffd_stats_report(args, nr_cpus);
        }
 
        if (test_type == TEST_ANON) {