mirror of
https://github.com/ChuckBuilds/LEDMatrix.git
synced 2026-10-04 22:35:08 +00:00
Compare commits
1
Commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
caec9f5bf5 |
@@ -19,6 +19,18 @@ accepts both, but the store flags the old spelling as deprecated
|
|||||||
|
|
||||||
## Unreleased
|
## Unreleased
|
||||||
|
|
||||||
|
### A scrolling screen held by its plugin's update() is reported
|
||||||
|
|
||||||
|
- While a plugin's `update()` runs it holds the plugin's lock, and that
|
||||||
|
plugin's frames are skipped: on a scroller, a frozen strip, with nothing
|
||||||
|
logged (and a freeze of 5 s or more is a gap, not a freeze, to the frame
|
||||||
|
stats). The high-FPS loop now times each run of skipped frames; one of
|
||||||
|
250 ms or more logs `Display of <plugin> held N ms by its update()`
|
||||||
|
(rate-limited per plugin) when it ends, and is recorded on the plugin's
|
||||||
|
health as a `display hold` busy skip, which never counts toward the
|
||||||
|
circuit breaker. The 1 Hz loop is left out: its frames are a second apart,
|
||||||
|
so one skipped frame there measures nothing and freezes nothing visible.
|
||||||
|
|
||||||
### Fixed
|
### Fixed
|
||||||
|
|
||||||
- The web preview and `/api/v3/display/current` no longer stay black for a
|
- The web preview and `/api/v3/display/current` no longer stay black for a
|
||||||
|
|||||||
@@ -1164,6 +1164,55 @@ class DisplayController:
|
|||||||
except Exception: # pylint: disable=broad-except
|
except Exception: # pylint: disable=broad-except
|
||||||
logger.exception("Error running scheduled plugin updates")
|
logger.exception("Error running scheduled plugin updates")
|
||||||
|
|
||||||
|
#: A run of frames skipped because a plugin's update() held its lock is
|
||||||
|
#: reported once it has lasted this long.
|
||||||
|
DISPLAY_HOLD_REPORT_SECONDS = 0.25
|
||||||
|
|
||||||
|
#: (plugin_id, monotonic start) of the current run of skipped frames.
|
||||||
|
_display_hold: Optional[Tuple[str, float]] = None
|
||||||
|
|
||||||
|
def _note_display_hold(self, plugin_id: str, held: bool) -> None:
|
||||||
|
"""Report how long a plugin's update() kept its display() from drawing.
|
||||||
|
|
||||||
|
While update() runs on the worker it holds the plugin's lock, and every
|
||||||
|
frame of that plugin's screen is skipped: the panel keeps showing the
|
||||||
|
last frame, which on a scroller is a frozen strip. Nothing said so --
|
||||||
|
the frames are not failures, and a scroll freeze of 5 s or more is a
|
||||||
|
gap to the frame stats, not a freeze. This times each such run and,
|
||||||
|
when it ends after DISPLAY_HOLD_REPORT_SECONDS or more, logs it
|
||||||
|
(rate-limited per plugin) and records it on the plugin's health as a
|
||||||
|
busy skip, which never touches the circuit breaker. Only frames of the
|
||||||
|
high-FPS loop are timed (see _display_once's ``report_hold``).
|
||||||
|
"""
|
||||||
|
# The clock is read only when a run starts or ends: on a frame that
|
||||||
|
# draws with no run open, this is one attribute check.
|
||||||
|
current = self._display_hold
|
||||||
|
if held:
|
||||||
|
if current is None or current[0] != plugin_id:
|
||||||
|
self._display_hold = (plugin_id, time.monotonic())
|
||||||
|
return
|
||||||
|
if current is None:
|
||||||
|
return
|
||||||
|
self._display_hold = None
|
||||||
|
if current[0] != plugin_id:
|
||||||
|
return
|
||||||
|
seconds = time.monotonic() - current[1]
|
||||||
|
if seconds < self.DISPLAY_HOLD_REPORT_SECONDS:
|
||||||
|
return
|
||||||
|
pm = self.plugin_manager
|
||||||
|
warn = getattr(pm, '_warn_rate_limited', None)
|
||||||
|
if warn is not None:
|
||||||
|
warn(f"display-hold:{plugin_id}",
|
||||||
|
"Display of %s held %.0f ms by its update()",
|
||||||
|
plugin_id, seconds * 1000.0)
|
||||||
|
tracker = getattr(pm, 'health_tracker', None)
|
||||||
|
record = getattr(tracker, 'record_busy_skip', None)
|
||||||
|
if record is not None:
|
||||||
|
try:
|
||||||
|
record(plugin_id, "display hold", seconds)
|
||||||
|
except Exception: # pylint: disable=broad-except
|
||||||
|
logger.debug("Could not record a display hold", exc_info=True)
|
||||||
|
|
||||||
@contextmanager
|
@contextmanager
|
||||||
def _display_lock_or_skip(self, plugin_id):
|
def _display_lock_or_skip(self, plugin_id):
|
||||||
"""Try-lock guard keeping a plugin's display() off its in-flight update().
|
"""Try-lock guard keeping a plugin's display() off its in-flight update().
|
||||||
@@ -1189,7 +1238,7 @@ class DisplayController:
|
|||||||
lock.release()
|
lock.release()
|
||||||
|
|
||||||
def _display_once(self, plugin, mode: str, accepts_display_mode: bool,
|
def _display_once(self, plugin, mode: str, accepts_display_mode: bool,
|
||||||
force_clear: bool = False):
|
force_clear: bool = False, report_hold: bool = False):
|
||||||
"""Call ``plugin.display()`` directly for one frame of a render loop.
|
"""Call ``plugin.display()`` directly for one frame of a render loop.
|
||||||
|
|
||||||
Frames after a screen's first dispatch come through here rather than
|
Frames after a screen's first dispatch come through here rather than
|
||||||
@@ -1205,6 +1254,12 @@ class DisplayController:
|
|||||||
``display_mode`` so plugins with several modes stay on it.
|
``display_mode`` so plugins with several modes stay on it.
|
||||||
accepts_display_mode: Whether display() takes ``display_mode``.
|
accepts_display_mode: Whether display() takes ``display_mode``.
|
||||||
force_clear: Passed through to display().
|
force_clear: Passed through to display().
|
||||||
|
report_hold: Time runs of frames skipped because update() holds
|
||||||
|
the plugin's lock (see _note_display_hold). Only the high-FPS
|
||||||
|
loop asks: its frames are ~8 ms apart, so a run measures the
|
||||||
|
hold, and a held scroller is a frozen strip. The 1 Hz loop's
|
||||||
|
frames are a second apart, so one skipped frame there would
|
||||||
|
read as a 1 s hold of a screen that did not visibly change.
|
||||||
|
|
||||||
Each call is timed (two monotonic reads) and handed to
|
Each call is timed (two monotonic reads) and handed to
|
||||||
PluginManager.note_display_duration, which logs and records slow
|
PluginManager.note_display_duration, which logs and records slow
|
||||||
@@ -1219,6 +1274,12 @@ class DisplayController:
|
|||||||
display_watchdog.watchdog.beat()
|
display_watchdog.watchdog.beat()
|
||||||
plugin_id = getattr(plugin, 'plugin_id', None)
|
plugin_id = getattr(plugin, 'plugin_id', None)
|
||||||
with self._display_lock_or_skip(plugin_id) as can_display:
|
with self._display_lock_or_skip(plugin_id) as can_display:
|
||||||
|
if report_hold and plugin_id:
|
||||||
|
self._note_display_hold(plugin_id, held=not can_display)
|
||||||
|
elif can_display and self._display_hold is not None:
|
||||||
|
# A drawn frame outside the high-FPS loop: whatever run was
|
||||||
|
# open is over, unreported.
|
||||||
|
self._display_hold = None
|
||||||
if not can_display:
|
if not can_display:
|
||||||
return True
|
return True
|
||||||
started = time.monotonic()
|
started = time.monotonic()
|
||||||
@@ -3987,7 +4048,8 @@ class DisplayController:
|
|||||||
_frame_start = time.perf_counter()
|
_frame_start = time.perf_counter()
|
||||||
try:
|
try:
|
||||||
result = self._display_once(
|
result = self._display_once(
|
||||||
manager_to_display, active_mode, _accepts_display_mode)
|
manager_to_display, active_mode, _accepts_display_mode,
|
||||||
|
report_hold=True)
|
||||||
if isinstance(result, bool) and not result:
|
if isinstance(result, bool) and not result:
|
||||||
logger.debug("Display returned False, breaking early")
|
logger.debug("Display returned False, breaking early")
|
||||||
break
|
break
|
||||||
|
|||||||
@@ -0,0 +1,142 @@
|
|||||||
|
"""The report of a scrolling screen held by its plugin's update().
|
||||||
|
|
||||||
|
While a plugin's update() runs it holds the plugin's lock, and its screen's
|
||||||
|
frames are skipped -- on a scroller, a frozen strip -- with nothing logged.
|
||||||
|
_note_display_hold times each such run and reports one of
|
||||||
|
DISPLAY_HOLD_REPORT_SECONDS or more.
|
||||||
|
"""
|
||||||
|
|
||||||
|
import threading
|
||||||
|
import types
|
||||||
|
from unittest.mock import MagicMock
|
||||||
|
|
||||||
|
import pytest
|
||||||
|
|
||||||
|
|
||||||
|
class _Clock:
|
||||||
|
"""display_controller's clock: moves only when run() sleeps or a test says."""
|
||||||
|
|
||||||
|
def __init__(self, start=10_000.0):
|
||||||
|
self.t = start
|
||||||
|
|
||||||
|
def now(self):
|
||||||
|
return self.t
|
||||||
|
|
||||||
|
def sleep(self, seconds):
|
||||||
|
self.t += max(seconds, 0.0005)
|
||||||
|
|
||||||
|
def module(self):
|
||||||
|
return types.SimpleNamespace(time=self.now, monotonic=self.now,
|
||||||
|
perf_counter=self.now, sleep=self.sleep)
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.fixture
|
||||||
|
def clock(monkeypatch):
|
||||||
|
c = _Clock()
|
||||||
|
monkeypatch.setattr("src.display_controller.time", c.module())
|
||||||
|
return c
|
||||||
|
|
||||||
|
|
||||||
|
class _Locks:
|
||||||
|
"""get_plugin_lock for one plugin, whose lock the test can hold."""
|
||||||
|
|
||||||
|
def __init__(self):
|
||||||
|
self.lock = threading.Lock()
|
||||||
|
|
||||||
|
def __call__(self, plugin_id):
|
||||||
|
return self.lock
|
||||||
|
|
||||||
|
|
||||||
|
@pytest.fixture
|
||||||
|
def held(test_display_controller):
|
||||||
|
c = test_display_controller
|
||||||
|
locks = _Locks()
|
||||||
|
c.plugin_manager.get_plugin_lock = locks
|
||||||
|
c.plugin_manager._warn_rate_limited = MagicMock()
|
||||||
|
c.plugin_manager.health_tracker = MagicMock()
|
||||||
|
c._display_hold = None
|
||||||
|
return c, locks.lock
|
||||||
|
|
||||||
|
|
||||||
|
def _plugin(plugin_id):
|
||||||
|
p = MagicMock()
|
||||||
|
p.plugin_id = plugin_id
|
||||||
|
p.display.return_value = True
|
||||||
|
return p
|
||||||
|
|
||||||
|
|
||||||
|
class TestTheDisplayHoldReport:
|
||||||
|
def test_a_long_hold_is_reported_when_it_ends(self, held, clock):
|
||||||
|
c, lock = held
|
||||||
|
ticker = _plugin("ticker")
|
||||||
|
lock.acquire() # update() running
|
||||||
|
assert c._display_once(ticker, "ticker", False, report_hold=True) is True
|
||||||
|
clock.t += 0.2
|
||||||
|
assert c._display_once(ticker, "ticker", False, report_hold=True) is True
|
||||||
|
assert ticker.display.call_count == 0
|
||||||
|
c.plugin_manager._warn_rate_limited.assert_not_called()
|
||||||
|
clock.t += 0.2
|
||||||
|
lock.release() # update() done
|
||||||
|
c._display_once(ticker, "ticker", False, report_hold=True)
|
||||||
|
assert ticker.display.call_count == 1
|
||||||
|
key, message, plugin_id, ms = c.plugin_manager._warn_rate_limited.call_args[0]
|
||||||
|
assert key == "display-hold:ticker" and plugin_id == "ticker"
|
||||||
|
assert "held" in message and ms == pytest.approx(400.0)
|
||||||
|
c.plugin_manager.health_tracker.record_busy_skip.assert_called_once_with(
|
||||||
|
"ticker", "display hold", pytest.approx(0.4))
|
||||||
|
|
||||||
|
def test_a_short_hold_is_not(self, held, clock):
|
||||||
|
c, lock = held
|
||||||
|
ticker = _plugin("ticker")
|
||||||
|
lock.acquire()
|
||||||
|
c._display_once(ticker, "ticker", False, report_hold=True)
|
||||||
|
clock.t += 0.1
|
||||||
|
lock.release()
|
||||||
|
c._display_once(ticker, "ticker", False, report_hold=True)
|
||||||
|
c.plugin_manager._warn_rate_limited.assert_not_called()
|
||||||
|
c.plugin_manager.health_tracker.record_busy_skip.assert_not_called()
|
||||||
|
|
||||||
|
def test_a_hold_that_ends_on_another_plugins_screen_is_not_blamed_on_it(
|
||||||
|
self, held, clock):
|
||||||
|
c, lock = held
|
||||||
|
lock.acquire()
|
||||||
|
c._display_once(_plugin("ticker"), "ticker", False, report_hold=True)
|
||||||
|
clock.t += 1.0
|
||||||
|
lock.release()
|
||||||
|
c._display_once(_plugin("clock"), "clock", False, report_hold=True)
|
||||||
|
c.plugin_manager._warn_rate_limited.assert_not_called()
|
||||||
|
assert c._display_hold is None
|
||||||
|
|
||||||
|
def test_frames_that_draw_report_nothing(self, held, clock):
|
||||||
|
c, _lock = held
|
||||||
|
ticker = _plugin("ticker")
|
||||||
|
for _ in range(5):
|
||||||
|
c._display_once(ticker, "ticker", False, report_hold=True)
|
||||||
|
clock.t += 0.5
|
||||||
|
c.plugin_manager._warn_rate_limited.assert_not_called()
|
||||||
|
|
||||||
|
def test_the_1hz_loop_reports_no_holds(self, held, clock):
|
||||||
|
# A static screen's frames are a second apart: one skipped frame is
|
||||||
|
# not a measured hold, and nothing on the panel froze. (On ledpi the
|
||||||
|
# first version reported every such skip as "held 1000 ms".)
|
||||||
|
c, lock = held
|
||||||
|
board = _plugin("board")
|
||||||
|
lock.acquire()
|
||||||
|
c._display_once(board, "board", False)
|
||||||
|
clock.t += 1.0
|
||||||
|
lock.release()
|
||||||
|
c._display_once(board, "board", False)
|
||||||
|
c.plugin_manager._warn_rate_limited.assert_not_called()
|
||||||
|
c.plugin_manager.health_tracker.record_busy_skip.assert_not_called()
|
||||||
|
|
||||||
|
def test_a_run_left_open_is_dropped_by_a_1hz_frame(self, held, clock):
|
||||||
|
c, lock = held
|
||||||
|
ticker = _plugin("ticker")
|
||||||
|
lock.acquire()
|
||||||
|
c._display_once(ticker, "ticker", False, report_hold=True)
|
||||||
|
lock.release()
|
||||||
|
c._display_once(ticker, "ticker", False) # the 1 Hz loop draws
|
||||||
|
assert c._display_hold is None
|
||||||
|
clock.t += 5.0
|
||||||
|
c._display_once(ticker, "ticker", False, report_hold=True)
|
||||||
|
c.plugin_manager._warn_rate_limited.assert_not_called()
|
||||||
Reference in New Issue
Block a user