From 1b3d61aa6998911317faf41b3d7bd13b7b4b71bd Mon Sep 17 00:00:00 2001 From: dj2ls Date: Mon, 1 Apr 2024 11:18:45 +0200 Subject: [PATCH] ARQ WIP --- modem/arq_session_iss.py | 7 ++++++- 1 file changed, 6 insertions(+), 1 deletion(-) diff --git a/modem/arq_session_iss.py b/modem/arq_session_iss.py index 3119c428..451f191a 100644 --- a/modem/arq_session_iss.py +++ b/modem/arq_session_iss.py @@ -152,9 +152,14 @@ class ARQSessionISS(arq_session.ARQSession): return None, None def send_data(self, irs_frame, fallback=None): + + # interrupt transmission when aborting + if self.state in [ISS_State.ABORTED, ISS_State.ABORTING]: + self.event_frame_received.set() + return + # update statistics self.update_histograms(self.confirmed_bytes, self.total_length) - self.update_speed_level(irs_frame) #if 'offset' in irs_frame: # self.confirmed_bytes = irs_frame['offset']