chg: containers (podman) - stats iteration interval longer

fix #2390 note: tmp fix Proper sol - containers/podman-py#266
nicolargo · May 13, 2023 · 83fc2a2 · 83fc2a2
1 parent b1da4f6
commit 83fc2a2
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 3 deletions.
diff --git a/glances/plugins/containers/glances_podman.py b/glances/plugins/containers/glances_podman.py
@@ -91,7 +91,7 @@ def __init__(self, pod_manager):
         # Threaded Streamer
         # Temporary patch to get podman extension working
         stats_iterable = (pod_manager.stats(decode=True) for _ in iter(int, 1))
-        self._streamer = StatsStreamer(stats_iterable, initial_stream_value={})
+        self._streamer = StatsStreamer(stats_iterable, initial_stream_value={}, sleep_duration=2)
 
     def _log_debug(self, msg, exception=None):
         logger.debug("containers (Podman): Pod Manager - {} ({})".format(msg, exception))

diff --git a/glances/plugins/containers/stats_streamer.py b/glances/plugins/containers/stats_streamer.py
@@ -19,7 +19,7 @@ class StatsStreamer:
     Use `StatsStreamer.stats` to access the latest streamed results
     """
 
-    def __init__(self, iterable, initial_stream_value=None):
+    def __init__(self, iterable, initial_stream_value=None, sleep_duration=0.1):
         """
         iterable: an Iterable instance that needs to be streamed
         """
@@ -34,6 +34,8 @@ def __init__(self, iterable, initial_stream_value=None):
         self.result_lock = threading.Lock()
         # Last result streamed time (initial val 0)
         self._last_update_time = 0
+        # Time to sleep before next iteration
+        self._sleep_duration = sleep_duration
 
         self._thread.start()
 
@@ -56,7 +58,7 @@ def _stream_results(self):
                 self._raw_result = res
                 self._post_update_hook()
 
-                time.sleep(0.1)
+                time.sleep(self._sleep_duration)
                 if self.stopped():
                     break