[Lldb-commits] [lldb] 753d15a - [lldb] Fix Linux memory monitor. (#182011)

[via lldb-commits]

Author: Ebuka Ezike
Date: 2026-02-19T11:12:35Z
New Revision: 753d15a28de1e3170a51a963e600d80449dfd03c

URL: https://github.com/llvm/llvm-project/commit/753d15a28de1e3170a51a963e600d80449dfd03c
DIFF: https://github.com/llvm/llvm-project/commit/753d15a28de1e3170a51a963e600d80449dfd03c.diff

LOG: [lldb] Fix Linux memory monitor. (#182011)

Only call the callback when we are actually low on memory. 
Increase the threshold to 200ms in a 2 second interval to match
systemd's default see

[DefaultMemoryPressureWatch](https://www.freedesktop.org/software/systemd/man/latest/systemd-system.conf.html#DefaultMemoryPressureWatch=).

Added: 
    

Modified: 
    lldb/source/Host/common/MemoryMonitor.cpp

Removed: 
    


################################################################################
diff  --git a/lldb/source/Host/common/MemoryMonitor.cpp b/lldb/source/Host/common/MemoryMonitor.cpp
index 7734be8688675..1bdc0ff2fc7e8 100644
--- a/lldb/source/Host/common/MemoryMonitor.cpp
+++ b/lldb/source/Host/common/MemoryMonitor.cpp
@@ -18,6 +18,8 @@
 #include <cstring>
 
 #if defined(__linux__)
+#include "lldb/Host/posix/Support.h"
+#include "llvm/Support/LineIterator.h"
 #include <fcntl.h>
 #include <poll.h>
 #include <sys/eventfd.h>
@@ -44,7 +46,7 @@ class MemoryMonitorLinux : public MemoryMonitor {
   ~MemoryMonitorLinux() {
     if (m_memory_monitor_thread.IsJoinable())
       m_memory_monitor_thread.Join(nullptr);
-    if (m_stop_fd != 1)
+    if (m_stop_fd != -1)
       ::close(m_stop_fd);
   }
 
@@ -96,8 +98,8 @@ class MemoryMonitorLinux : public MemoryMonitor {
 
     llvm::scope_exit cleanup([&]() { ::close(pfds[pressure_idx].fd); });
 
-    // Detect a 50ms stall in a 2 second time window.
-    constexpr llvm::StringRef trigger = "some 50000 2000000";
+    // Detect a 200ms stall in a 2 second time window.
+    constexpr llvm::StringRef trigger = "some 200000 2000000";
     if (::write(pfds[pressure_idx].fd, trigger.data(), trigger.size() + 1) < 0)
       return {};
 
@@ -109,14 +111,57 @@ class MemoryMonitorLinux : public MemoryMonitor {
         if (pfds[stop_idx].revents & (POLLIN | POLLERR))
           return {};
 
-        if (pfds[pressure_idx].revents & POLLERR)
+        const short pressure_revents = pfds[stop_idx].revents;
+        if (pressure_revents & POLLERR)
           return {};
-        if (pfds[pressure_idx].revents & POLLPRI)
-          m_callback();
+        if (pressure_revents & POLLPRI) {
+          if (const std::optional<bool> is_low_opt = IsLowMemory();
+              is_low_opt && *is_low_opt)
+            m_callback();
+        }
       }
     }
     return {};
   }
+
+  static std::optional<bool> IsLowMemory() {
+    llvm::ErrorOr<std::unique_ptr<llvm::MemoryBuffer>> buffer_or_err =
+        getProcFile("meminfo");
+
+    if (!buffer_or_err)
+      return std::nullopt;
+
+    uint64_t mem_total = 0;
+    uint64_t mem_available = 0;
+    const int radix = 10;
+    bool parse_error = false;
+
+    for (llvm::line_iterator iter(**buffer_or_err, true); !iter.is_at_end();
+         ++iter) {
+      llvm::StringRef line = *iter;
+      if (line.consume_front("MemTotal:"))
+        parse_error = line.ltrim().consumeInteger(radix, mem_total);
+      else if (line.consume_front("MemAvailable:"))
+        parse_error = line.ltrim().consumeInteger(radix, mem_available);
+
+      if (parse_error)
+        return std::nullopt;
+
+      if (mem_total && mem_available)
+        break;
+    }
+
+    if (mem_total == 0)
+      return std::nullopt;
+
+    if (mem_available == 0) // We are actually out of memory.
+      return true;
+
+    const uint64_t approx_memory_percent = (mem_available * 100) / mem_total;
+    const uint64_t low_memory_percent = 20;
+    return approx_memory_percent < low_memory_percent;
+  }
+
   int m_stop_fd = -1;
   HostThread m_memory_monitor_thread;
 };