summaryrefslogtreecommitdiff
path: root/core/signal_processor.py
diff options
context:
space:
mode:
Diffstat (limited to 'core/signal_processor.py')
-rw-r--r--core/signal_processor.py17
1 files changed, 17 insertions, 0 deletions
diff --git a/core/signal_processor.py b/core/signal_processor.py
index da615b6..c79ea87 100644
--- a/core/signal_processor.py
+++ b/core/signal_processor.py
@@ -492,6 +492,23 @@ class SignalProcessor(QObject):
def all_virtual_channel_ids(self) -> List[str]:
return list(self._derived_bufs.keys())
+ def on_device_reconfigured(self, device_id: str, current_signal_ids: set) -> List[str]:
+ """Drop cached state for any signal_id a device's Apply & Reconnect
+ just removed — otherwise _latest keeps a stale frozen (timestamp,
+ value) forever (it's only ever written to, never pruned elsewhere),
+ and a derived Channel sourced from that id keeps silently computing
+ off that frozen value instead of skipping like a genuinely-missing
+ source would. Mirrors AcquisitionEngine.on_device_reconfigured().
+ Returns the removed signal_ids (those with a cached entry keyed to
+ this device that's no longer in current_signal_ids), so the caller
+ can flag any still-dangling references without recomputing the diff."""
+ removed = []
+ with self._lock:
+ for key in [k for k in self._latest if k[0] == device_id and k[1] not in current_signal_ids]:
+ self._latest.pop(key, None)
+ removed.append(key[1])
+ return removed
+
def clear_history(self):
"""Clear derived channel buffers and latest-value cache."""
with self._lock: