diff --git a/src/display_controller.py b/src/display_controller.py index 6fed01b6..34635f99 100644 --- a/src/display_controller.py +++ b/src/display_controller.py @@ -79,7 +79,7 @@ class DisplayController: logger.info("Display modes initialized in %.3f seconds", time.time() - init_time) self.force_change = False - self._next_live_priority_check = 0.0 # timestamp for throttled live priority checks + self._next_live_priority_check = 0.0 # monotonic timestamp for throttled live priority checks # All sports and content managers now handled via plugins logger.info("All sports and content managers now handled via plugin system") @@ -1727,7 +1727,7 @@ class DisplayController: ) target_duration = max_duration - start_time = time.time() + start_time = time.monotonic() def _should_exit_dynamic(elapsed_time: float) -> bool: if not dynamic_enabled: @@ -1793,8 +1793,8 @@ class DisplayController: # Check for live priority every ~30s so live # games can interrupt long display durations - elapsed = time.time() - start_time - now = time.time() + elapsed = time.monotonic() - start_time + now = time.monotonic() if not self.on_demand_active and now >= self._next_live_priority_check: self._next_live_priority_check = now + 30.0 live_mode = self._check_live_priority() @@ -1843,7 +1843,7 @@ class DisplayController: time.sleep(display_interval) self._tick_plugin_updates() - elapsed = time.time() - start_time + elapsed = time.monotonic() - start_time if elapsed >= target_duration: logger.debug( "Reached standard target duration %.2fs for mode %s", @@ -1875,7 +1875,7 @@ class DisplayController: # Check for live priority every ~30s so live # games can interrupt long display durations - now = time.time() + now = time.monotonic() if not self.on_demand_active and now >= self._next_live_priority_check: self._next_live_priority_check = now + 30.0 live_mode = self._check_live_priority() @@ -1915,13 +1915,13 @@ class DisplayController: and not loop_completed and not needs_high_fps ): - elapsed = time.time() - start_time + elapsed = time.monotonic() - start_time remaining_sleep = max(0.0, max_duration - elapsed) if remaining_sleep > 0: self._sleep_with_plugin_updates(remaining_sleep) if dynamic_enabled: - elapsed_total = time.time() - start_time + elapsed_total = time.monotonic() - start_time cycle_done = self._plugin_cycle_complete(manager_to_display) # Log cycle completion status and metrics diff --git a/src/vegas_mode/render_pipeline.py b/src/vegas_mode/render_pipeline.py index 2b93a07f..138ee1d2 100644 --- a/src/vegas_mode/render_pipeline.py +++ b/src/vegas_mode/render_pipeline.py @@ -265,6 +265,10 @@ class RenderPipeline: if buffer_status['staging_count'] > 0: return True + # Trigger recompose when pending updates affect visible segments + if self.stream_manager.has_pending_updates_for_visible_segments(): + return True + return False def hot_swap_content(self) -> bool: diff --git a/src/vegas_mode/stream_manager.py b/src/vegas_mode/stream_manager.py index 17efc357..06082951 100644 --- a/src/vegas_mode/stream_manager.py +++ b/src/vegas_mode/stream_manager.py @@ -199,6 +199,21 @@ class StreamManager: logger.debug("Plugin %s marked for update", plugin_id) + def has_pending_updates(self) -> bool: + """Check if any plugins have pending updates awaiting processing.""" + with self._buffer_lock: + return len(self._pending_updates) > 0 + + def has_pending_updates_for_visible_segments(self) -> bool: + """Check if pending updates affect plugins currently in the active buffer.""" + with self._buffer_lock: + if not self._pending_updates: + return False + active_ids = { + seg.plugin_id for seg in self._active_buffer if seg.images + } + return bool(active_ids & self._pending_updates.keys()) + def process_updates(self) -> None: """ Process pending plugin updates.