MemoryPressure: add dedicated memory pressure settings for service worker process

Author: filipe-norte-red

Source/WTF/wtf/MemoryPressureHandler.cpp

@@ -308,7 +308,7 @@ void MemoryPressureHandler::setMemoryUsagePolicyBasedOnFootprints(size_t footpri
     if (newPolicy == m_memoryUsagePolicy)
         return;
 
-    RELEASE_LOG(MemoryPressure, "Memory usage policy changed: %s -> %s", toString(m_memoryUsagePolicy).characters(), toString(newPolicy).characters());
+    RELEASE_LOG(MemoryPressure, "Memory usage policy changed (PID=%d): %s -> %s", getpid(), toString(m_memoryUsagePolicy).characters(), toString(newPolicy).characters());
     m_memoryUsagePolicy = newPolicy;
     memoryPressureStatusChanged();
 }
@@ -329,7 +329,7 @@ void MemoryPressureHandler::measurementTimerFired()
     size_t footprint = memoryFootprint();
     size_t footprintVideo = memoryFootprintVideo();
 #if PLATFORM(COCOA)
-    RELEASE_LOG(MemoryPressure, "Current memory footprint: %zu MB", footprint / MB);
+    RELEASE_LOG(MemoryPressure, "Current memory footprint (PID=%d): %zu MB", getpid(), footprint / MB);
 #endif
 
     while (m_memoryFootprintNotificationThresholds.size() && footprint > m_memoryFootprintNotificationThresholds.last()) {
@@ -424,13 +424,31 @@ void MemoryPressureHandler::setConfiguration(Configuration&& configuration)
     m_configuration = WTFMove(configuration);
     if (s_envBaseThresholdVideo)
         m_configuration.baseThresholdVideo = s_envBaseThresholdVideo;
+
+    RELEASE_LOG(MemoryPressure, "New memory pressure settings (PID=%d): bt=%u, btv=%u, ctf=%lf, stf=%lf, ktf=%lf, pi=%lf",
+        getpid(),
+        m_configuration.baseThreshold,
+        m_configuration.baseThresholdVideo,
+        m_configuration.conservativeThresholdFraction,
+        m_configuration.strictThresholdFraction,
+        m_configuration.killThresholdFraction ? *(m_configuration.killThresholdFraction) : -1.0,
+        m_configuration.pollInterval.value());
 }
 
 void MemoryPressureHandler::setConfiguration(const Configuration& configuration)
 {
     m_configuration = configuration;
     if (s_envBaseThresholdVideo)
         m_configuration.baseThresholdVideo = s_envBaseThresholdVideo;
+
+    RELEASE_LOG(MemoryPressure, "New memory pressure settings (PID=%d): bt=%u, btv=%u, ctf=%lf, stf=%lf, ktf=%lf, pi=%lf",
+        getpid(),
+        m_configuration.baseThreshold,
+        m_configuration.baseThresholdVideo,
+        m_configuration.conservativeThresholdFraction,
+        m_configuration.strictThresholdFraction,
+        m_configuration.killThresholdFraction ? *(m_configuration.killThresholdFraction) : -1.0,
+        m_configuration.pollInterval.value());
 }
 
 void MemoryPressureHandler::releaseMemory(Critical critical, Synchronous synchronous)

Source/WebKit/UIProcess/API/APIProcessPoolConfiguration.cpp

@@ -77,6 +77,7 @@ Ref<ProcessPoolConfiguration> ProcessPoolConfiguration::copy()
 #if PLATFORM(GTK) || PLATFORM(WPE)
     copy->m_memoryPressureHandlerConfiguration = this->m_memoryPressureHandlerConfiguration;
     copy->m_disableFontHintingForTesting = this->m_disableFontHintingForTesting;
+    copy->m_serviceWorkerMemoryPressureHandlerConfiguration = this->m_serviceWorkerMemoryPressureHandlerConfiguration;
 #endif
 #if HAVE(AUDIT_TOKEN)
     copy->m_presentingApplicationProcessToken = this->m_presentingApplicationProcessToken;

Source/WebKit/UIProcess/API/APIProcessPoolConfiguration.h

@@ -153,6 +153,9 @@ class ProcessPoolConfiguration final : public ObjectImpl<Object::Type::ProcessPo
 
     bool disableFontHintingForTesting() const { return m_disableFontHintingForTesting; }
     void setDisableFontHintingForTesting(bool override) { m_disableFontHintingForTesting = override; }
+
+    void setServiceWorkerMemoryPressureHandlerConfiguration(const MemoryPressureHandler::Configuration& configuration) { m_serviceWorkerMemoryPressureHandlerConfiguration = configuration; }
+    const std::optional<MemoryPressureHandler::Configuration>& serviceWorkerMemoryPressureHandlerConfiguration() const { return m_serviceWorkerMemoryPressureHandlerConfiguration; }
 #endif
 
     void setTimeZoneOverride(const WTF::String& timeZoneOverride) { m_timeZoneOverride = timeZoneOverride; }
@@ -204,6 +207,7 @@ class ProcessPoolConfiguration final : public ObjectImpl<Object::Type::ProcessPo
 #if PLATFORM(GTK) || PLATFORM(WPE)
     std::optional<MemoryPressureHandler::Configuration> m_memoryPressureHandlerConfiguration;
     bool m_disableFontHintingForTesting { false };
+    std::optional<MemoryPressureHandler::Configuration> m_serviceWorkerMemoryPressureHandlerConfiguration;
 #endif
 #if HAVE(AUDIT_TOKEN)
     std::optional<audit_token_t> m_presentingApplicationProcessToken;

Source/WebKit/UIProcess/API/glib/WebKitWebContext.cpp

@@ -135,6 +135,7 @@ enum {
 #endif
     PROP_MEMORY_PRESSURE_SETTINGS,
     PROP_TIME_ZONE_OVERRIDE,
+    PROP_SERVICE_WORKER_MEMORY_PRESSURE_SETTINGS,
     N_PROPERTIES,
 };
 
@@ -292,6 +293,7 @@ struct _WebKitWebContextPrivate {
 #endif
 
     WebKitMemoryPressureSettings* memoryPressureSettings;
+    WebKitMemoryPressureSettings* serviceWorkerMemoryPressureSettings;
 
     CString timeZoneOverride;
 };
@@ -419,6 +421,11 @@ static void webkitWebContextSetProperty(GObject* object, guint propID, const GVa
         context->priv->memoryPressureSettings = settings ? webkit_memory_pressure_settings_copy(static_cast<WebKitMemoryPressureSettings*>(settings)) : nullptr;
         break;
     }
+    case PROP_SERVICE_WORKER_MEMORY_PRESSURE_SETTINGS: {
+        gpointer settings = g_value_get_boxed(value);
+        context->priv->serviceWorkerMemoryPressureSettings = settings ? webkit_memory_pressure_settings_copy(static_cast<WebKitMemoryPressureSettings*>(settings)) : nullptr;
+        break;
+    }
     case PROP_TIME_ZONE_OVERRIDE: {
         const auto* timeZone = g_value_get_string(value);
         if (isTimeZoneValid(StringView::fromLatin1(timeZone)))
@@ -460,6 +467,11 @@ static void webkitWebContextConstructed(GObject* object)
         g_clear_pointer(&priv->memoryPressureSettings, webkit_memory_pressure_settings_free);
     }
     configuration.setTimeZoneOverride(String::fromUTF8(priv->timeZoneOverride.span()));
+    if (priv->serviceWorkerMemoryPressureSettings) {
+        configuration.setServiceWorkerMemoryPressureHandlerConfiguration(webkitMemoryPressureSettingsGetMemoryPressureHandlerConfiguration(priv->serviceWorkerMemoryPressureSettings));
+        // Once the settings have been passed to the ProcessPoolConfiguration, we don't need them anymore so we can free them.
+        g_clear_pointer(&priv->serviceWorkerMemoryPressureSettings, webkit_memory_pressure_settings_free);
+    }
 
 #if !ENABLE(2022_GLIB_API)
     if (!priv->websiteDataManager)
@@ -623,6 +635,21 @@ static void webkit_web_context_class_init(WebKitWebContextClass* webContextClass
             WEBKIT_TYPE_MEMORY_PRESSURE_SETTINGS,
             static_cast<GParamFlags>(WEBKIT_PARAM_WRITABLE | G_PARAM_CONSTRUCT_ONLY));
 
+    /**
+     * WebKitWebContext:service-worker-memory-pressure-settings:
+     *
+     * The #WebKitMemoryPressureSettings applied to the service worker web processes created by this context.
+     *
+     * Since: 2.38
+     */
+    sObjProperties[PROP_SERVICE_WORKER_MEMORY_PRESSURE_SETTINGS] =
+        g_param_spec_boxed(
+            "service-worker-memory-pressure-settings",
+            _("Service Worker Memory Pressure Settings"),
+            _("The WebKitMemoryPressureSettings applied to the service worker web processes created by this context"),
+            WEBKIT_TYPE_MEMORY_PRESSURE_SETTINGS,
+            static_cast<GParamFlags>(WEBKIT_PARAM_WRITABLE | G_PARAM_CONSTRUCT_ONLY));
+
     /**
      * WebKitWebContext:time-zone-override:
      *

Source/WebKit/UIProcess/glib/WebProcessPoolGLib.cpp

@@ -231,7 +231,10 @@ void WebProcessPool::platformInitializeWebProcess(const WebProcessProxy& process
     parameters.useSystemAppearanceForScrollbars = m_configuration->useSystemAppearanceForScrollbars();
 #endif
 
-    parameters.memoryPressureHandlerConfiguration = m_configuration->memoryPressureHandlerConfiguration();
+    if (process.isRunningServiceWorkers() && m_configuration->serviceWorkerMemoryPressureHandlerConfiguration())
+        parameters.memoryPressureHandlerConfiguration = m_configuration->serviceWorkerMemoryPressureHandlerConfiguration();
+    else
+        parameters.memoryPressureHandlerConfiguration = m_configuration->memoryPressureHandlerConfiguration();
 
     parameters.disableFontHintingForTesting = m_configuration->disableFontHintingForTesting();