diff options
Diffstat (limited to 'core/signal_processor.py')
| -rw-r--r-- | core/signal_processor.py | 17 |
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: |
