diff --git a/modem/arq_session_irs.py b/modem/arq_session_irs.py index 4a2cfe3e..99ff6dcd 100644 --- a/modem/arq_session_irs.py +++ b/modem/arq_session_irs.py @@ -56,15 +56,13 @@ class ARQSessionIRS(arq_session.ARQSession): self.log("Timeout waiting for data") self.state = self.STATE_FAILED return - else: - print("data received") - print(self.frame) - + self.log("Finished ARQ IRS session") def run(self): self.thread = threading.Thread(target=self.runner, name=f"ARQ IRS Session {self.id}", daemon=True) - self.thread.run() + self.thread.start() + def on_data_received(self, data_frame): if self.state != self.STATE_WAITING_DATA: diff --git a/modem/frame_handler_arq_session.py b/modem/frame_handler_arq_session.py index df5e41d7..d6a37eec 100644 --- a/modem/frame_handler_arq_session.py +++ b/modem/frame_handler_arq_session.py @@ -24,7 +24,6 @@ class ARQFrameHandler(frame_handler.FrameHandler): iss_session:ARQSessionISS = self.states.get_arq_iss_session(frame['session_id']) iss_session.on_connection_ack_received(frame) - # ARQ session data frame received if frame['frame_type_int'] in [FR.BURST_01.value, FR.BURST_02.value, FR.BURST_03.value, FR.BURST_04.value, FR.BURST_05.value]: print("received data frame....")