jensandClaude Sonnet 5
b3447a28c5
A struct size-mismatch or any other parse error in a listener could propagate uncaught out of the socket-reading thread and silently kill it. Catch broadly in the event loop and per-listener in call_listener, and make the NAV-SAT/NAV-SIG/RXM-RAWX group parsers tolerate a payload length that isn't an exact multiple of the group size instead of crashing on a short struct.unpack. Also wire NetworkBackend's socket-loss detection through to ReceiverManager (via a queued signal, since the callback fires from the backend thread) so the GUI reflects a peer-initiated disconnect instead of leaving the row stuck showing "connected". Verified against a real ZED-X20P: it drops the TCP session on its own after ~20-28s regardless of traffic; the GUI now marks the receiver disconnected and frees its ID for reconnecting. Co-Authored-By: Claude Sonnet 5 <noreply@anthropic.com> Claude-Session: https://claude.ai/code/session_01AzmCaNjDb3TAqPpTwunKTY
19 lines
462 B
Python
19 lines
462 B
Python
from abc import ABC
|
|
from msg.container import MsgContainer
|
|
from msg.listener import MsgListener
|
|
|
|
class MsgTalker(ABC):
|
|
def __init__(self):
|
|
self.sinks = []
|
|
|
|
def register_listener(self, sink: MsgListener):
|
|
self.sinks.append(sink)
|
|
|
|
def call_listener(self, msg: MsgContainer):
|
|
for sink in self.sinks:
|
|
try:
|
|
if sink.is_msg(msg):
|
|
sink.on_recv(msg)
|
|
except Exception as exc:
|
|
print(f"Listener {sink.__class__.__name__} failed on {msg}: {exc}")
|