From f308134276e143a9e14488e7e6ce3f4f29b9c1d4 Mon Sep 17 00:00:00 2001 From: DJ2LS Date: Tue, 19 Mar 2024 22:16:27 +0100 Subject: [PATCH] added rx part for larger data --- modem/arq_data_type_handler.py | 6 +++++- modem/p2p_connection.py | 8 ++++---- 2 files changed, 9 insertions(+), 5 deletions(-) diff --git a/modem/arq_data_type_handler.py b/modem/arq_data_type_handler.py index d84eb634..a81c63d0 100644 --- a/modem/arq_data_type_handler.py +++ b/modem/arq_data_type_handler.py @@ -181,7 +181,11 @@ class ARQDataTypeHandler: decompressed_data = gzip.decompress(data) self.log(f"Handling gzip compressed P2P_CONNECTION data: {len(decompressed_data)} Bytes from {len(data)} Bytes") print(self.state_manager.p2p_connection_sessions) - return decompressed_data + print(decompressed_data) + print(self.state_manager.p2p_connection_sessions) + for session_id in self.state_manager.p2p_connection_sessions: + print(session_id) + self.state_manager.p2p_connection_sessions[session_id].received_arq(decompressed_data) def failed_p2p_connection(self, data, statistics): decompressed_data = gzip.decompress(data) diff --git a/modem/p2p_connection.py b/modem/p2p_connection.py index 131762e7..17d8fe65 100644 --- a/modem/p2p_connection.py +++ b/modem/p2p_connection.py @@ -308,8 +308,8 @@ class P2PConnection: self.last_data_timestamp = time.time() self.set_state(States.CONNECTED) - - - def received_arq(self): - pass + def received_arq(self, data): + self.last_data_timestamp = time.time() + self.set_state(States.CONNECTED) + self.p2p_data_rx_queue.put(data)