Преглед изворни кода

overcommit: introduce mem-lock=on-fault

Locking the memory without MCL_ONFAULT instantly prefaults any mmaped
anonymous memory with a write-fault, which introduces a lot of extra
overhead in terms of memory usage when all you want to do is to prevent
kcompactd from migrating and compacting QEMU pages. Add an option to
only lock pages lazily as they're faulted by the process by using
MCL_ONFAULT if asked.

Reviewed-by: Vladimir Sementsov-Ogievskiy <vsementsov@yandex-team.ru>
Reviewed-by: Peter Xu <peterx@redhat.com>
Signed-off-by: Daniil Tatianin <d-tatianin@yandex-team.ru>
Link: https://lore.kernel.org/r/20250212143920.1269754-5-d-tatianin@yandex-team.ru
Signed-off-by: Peter Xu <peterx@redhat.com>
Daniil Tatianin пре 6 месеци
родитељ
комит
13057e064a
5 измењених фајлова са 45 додато и 14 уклоњено
  1. 2 0
      include/system/system.h
  2. 1 1
      migration/postcopy-ram.c
  3. 9 5
      qemu-options.hx
  4. 6 1
      system/globals.c
  5. 27 7
      system/vl.c

+ 2 - 0
include/system/system.h

@@ -50,9 +50,11 @@ extern QEMUClockType rtc_clock;
 typedef enum {
 typedef enum {
     MLOCK_OFF = 0,
     MLOCK_OFF = 0,
     MLOCK_ON,
     MLOCK_ON,
+    MLOCK_ON_FAULT,
 } MlockState;
 } MlockState;
 
 
 bool should_mlock(MlockState);
 bool should_mlock(MlockState);
+bool is_mlock_on_fault(MlockState);
 
 
 extern MlockState mlock_state;
 extern MlockState mlock_state;
 
 

+ 1 - 1
migration/postcopy-ram.c

@@ -652,7 +652,7 @@ int postcopy_ram_incoming_cleanup(MigrationIncomingState *mis)
     }
     }
 
 
     if (should_mlock(mlock_state)) {
     if (should_mlock(mlock_state)) {
-        if (os_mlock(false) < 0) {
+        if (os_mlock(is_mlock_on_fault(mlock_state)) < 0) {
             error_report("mlock: %s", strerror(errno));
             error_report("mlock: %s", strerror(errno));
             /*
             /*
              * It doesn't feel right to fail at this point, we have a valid
              * It doesn't feel right to fail at this point, we have a valid

+ 9 - 5
qemu-options.hx

@@ -4632,21 +4632,25 @@ SRST
 ERST
 ERST
 
 
 DEF("overcommit", HAS_ARG, QEMU_OPTION_overcommit,
 DEF("overcommit", HAS_ARG, QEMU_OPTION_overcommit,
-    "-overcommit [mem-lock=on|off][cpu-pm=on|off]\n"
+    "-overcommit [mem-lock=on|off|on-fault][cpu-pm=on|off]\n"
     "                run qemu with overcommit hints\n"
     "                run qemu with overcommit hints\n"
-    "                mem-lock=on|off controls memory lock support (default: off)\n"
+    "                mem-lock=on|off|on-fault controls memory lock support (default: off)\n"
     "                cpu-pm=on|off controls cpu power management (default: off)\n",
     "                cpu-pm=on|off controls cpu power management (default: off)\n",
     QEMU_ARCH_ALL)
     QEMU_ARCH_ALL)
 SRST
 SRST
-``-overcommit mem-lock=on|off``
+``-overcommit mem-lock=on|off|on-fault``
   \ 
   \ 
 ``-overcommit cpu-pm=on|off``
 ``-overcommit cpu-pm=on|off``
     Run qemu with hints about host resource overcommit. The default is
     Run qemu with hints about host resource overcommit. The default is
     to assume that host overcommits all resources.
     to assume that host overcommits all resources.
 
 
     Locking qemu and guest memory can be enabled via ``mem-lock=on``
     Locking qemu and guest memory can be enabled via ``mem-lock=on``
-    (disabled by default). This works when host memory is not
-    overcommitted and reduces the worst-case latency for guest.
+    or ``mem-lock=on-fault`` (disabled by default). This works when
+    host memory is not overcommitted and reduces the worst-case latency for
+    guest. The on-fault option is better for reducing the memory footprint
+    since it makes allocations lazy, but the pages still get locked in place
+    once faulted by the guest or QEMU. Note that the two options are mutually
+    exclusive.
 
 
     Guest ability to manage power state of host cpus (increasing latency
     Guest ability to manage power state of host cpus (increasing latency
     for other processes on the same host cpu, but decreasing latency for
     for other processes on the same host cpu, but decreasing latency for

+ 6 - 1
system/globals.c

@@ -33,7 +33,12 @@
 
 
 bool should_mlock(MlockState state)
 bool should_mlock(MlockState state)
 {
 {
-    return state == MLOCK_ON;
+    return state == MLOCK_ON || state == MLOCK_ON_FAULT;
+}
+
+bool is_mlock_on_fault(MlockState state)
+{
+    return state == MLOCK_ON_FAULT;
 }
 }
 
 
 enum vga_retrace_method vga_retrace_method = VGA_RETRACE_DUMB;
 enum vga_retrace_method vga_retrace_method = VGA_RETRACE_DUMB;

+ 27 - 7
system/vl.c

@@ -351,7 +351,7 @@ static QemuOptsList qemu_overcommit_opts = {
     .desc = {
     .desc = {
         {
         {
             .name = "mem-lock",
             .name = "mem-lock",
-            .type = QEMU_OPT_BOOL,
+            .type = QEMU_OPT_STRING,
         },
         },
         {
         {
             .name = "cpu-pm",
             .name = "cpu-pm",
@@ -797,7 +797,7 @@ static QemuOptsList qemu_run_with_opts = {
 static void realtime_init(void)
 static void realtime_init(void)
 {
 {
     if (should_mlock(mlock_state)) {
     if (should_mlock(mlock_state)) {
-        if (os_mlock(false) < 0) {
+        if (os_mlock(is_mlock_on_fault(mlock_state)) < 0) {
             error_report("locking memory failed");
             error_report("locking memory failed");
             exit(1);
             exit(1);
         }
         }
@@ -1878,7 +1878,7 @@ static void object_option_parse(const char *str)
 static void overcommit_parse(const char *str)
 static void overcommit_parse(const char *str)
 {
 {
     QemuOpts *opts;
     QemuOpts *opts;
-    bool enable_mlock;
+    const char *mem_lock_opt;
 
 
     opts = qemu_opts_parse_noisily(qemu_find_opts("overcommit"),
     opts = qemu_opts_parse_noisily(qemu_find_opts("overcommit"),
                                    str, false);
                                    str, false);
@@ -1886,11 +1886,31 @@ static void overcommit_parse(const char *str)
         exit(1);
         exit(1);
     }
     }
 
 
-    enable_mlock = qemu_opt_get_bool(opts, "mem-lock",
-                                     should_mlock(mlock_state));
-    mlock_state = enable_mlock ? MLOCK_ON : MLOCK_OFF;
-
     enable_cpu_pm = qemu_opt_get_bool(opts, "cpu-pm", enable_cpu_pm);
     enable_cpu_pm = qemu_opt_get_bool(opts, "cpu-pm", enable_cpu_pm);
+
+    mem_lock_opt = qemu_opt_get(opts, "mem-lock");
+    if (!mem_lock_opt) {
+        return;
+    }
+
+    if (strcmp(mem_lock_opt, "on") == 0) {
+        mlock_state = MLOCK_ON;
+        return;
+    }
+
+    if (strcmp(mem_lock_opt, "off") == 0) {
+        mlock_state = MLOCK_OFF;
+        return;
+    }
+
+    if (strcmp(mem_lock_opt, "on-fault") == 0) {
+        mlock_state = MLOCK_ON_FAULT;
+        return;
+    }
+
+    error_report("parameter 'mem-lock' expects one of "
+                 "'on', 'off', 'on-fault'");
+    exit(1);
 }
 }
 
 
 /*
 /*