FreeDV
/
FreeDATA
mirror of https://github.com/DJ2LS/FreeDATA.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

start sending after 6 sec idle

pull/976/head
DJ2LS 2025-05-01 23:08:28 +02:00
parent 6da8be56f9
commit 48e74a95b9
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
freedata_server/p2p_connection.py
View File

@ -121,6 +121,10 @@ class P2PConnection:
self.disconnect() self.disconnect()
return return
if time.time() > self.last_data_timestamp + 6 and self.state is States.CONNECTED:
# start sending data
self.iss_buffer_empty.set()
if not self.p2p_data_tx_queue.empty() and self.state == States.CONNECTED: if not self.p2p_data_tx_queue.empty() and self.state == States.CONNECTED:
self.process_data_queue() self.process_data_queue()
threading.Event().wait(0.500) threading.Event().wait(0.500)
@ -225,7 +229,7 @@ class P2PConnection:
self.set_state(States.CONNECTED) self.set_state(States.CONNECTED)
self.is_ISS = True self.is_ISS = True
# iss starts sending data # start sending data
self.iss_buffer_empty.set() self.iss_buffer_empty.set()
self.log(frame) self.log(frame)
@ -252,7 +256,6 @@ class P2PConnection:
session_open_frame = self.frame_factory.build_p2p_connection_connect_ack(self.destination, self.origin, self.session_id) session_open_frame = self.frame_factory.build_p2p_connection_connect_ack(self.destination, self.origin, self.session_id)
self.launch_twr_irs(session_open_frame, self.ENTIRE_CONNECTION_TIMEOUT, mode=FREEDV_MODE.signalling) self.launch_twr_irs(session_open_frame, self.ENTIRE_CONNECTION_TIMEOUT, mode=FREEDV_MODE.signalling)
def session_failed(self): def session_failed(self):
self.set_state(States.FAILED) self.set_state(States.FAILED)
if self.ctx.socket_interface_manager and hasattr(self.ctx.socket_interface_manager.command_server, "command_handler"): if self.ctx.socket_interface_manager and hasattr(self.ctx.socket_interface_manager.command_server, "command_handler"):