From 48e74a95b9d94c320ca9c0b2c932bca706ecc1f2 Mon Sep 17 00:00:00 2001
From: DJ2LS <75909252+DJ2LS@users.noreply.github.com>
Date: Thu, 1 May 2025 23:08:28 +0200
Subject: [PATCH] start sending after 6 sec idle

---
 freedata_server/p2p_connection.py | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/freedata_server/p2p_connection.py b/freedata_server/p2p_connection.py
index 31cbfece..fda91989 100644
--- a/freedata_server/p2p_connection.py
+++ b/freedata_server/p2p_connection.py
@@ -121,6 +121,10 @@ class P2PConnection:
                     self.disconnect()
                     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:
                     self.process_data_queue()
                 threading.Event().wait(0.500)
@@ -225,7 +229,7 @@ class P2PConnection:
         self.set_state(States.CONNECTED)
         self.is_ISS = True
 
-        # iss starts sending data
+        # start sending data
         self.iss_buffer_empty.set()
 
         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)
         self.launch_twr_irs(session_open_frame, self.ENTIRE_CONNECTION_TIMEOUT, mode=FREEDV_MODE.signalling)
 
-
     def session_failed(self):
         self.set_state(States.FAILED)
         if self.ctx.socket_interface_manager and hasattr(self.ctx.socket_interface_manager.command_server, "command_handler"):