TCPStreamPusherSockets: Improve handling of existing connection

2026-03-01 20:31:09 +01:00
parent 38d8491c2b
commit 2967bcac42
2 changed files with 15 additions and 3 deletions
@@ -99,8 +99,14 @@ void TCPStreamPusherSocket::CloseDataSocket() {
 bool TCPStreamPusherSocket::AcceptConnection(std::chrono::milliseconds timeout) {
    std::unique_lock ul(send_mutex);

-    CloseDataSocket();
+    // Reuse existing healthy connection instead of always forcing reconnect.
+    if (fd.load() >= 0 && IsConnectionAlive()) {
+        broken = false;
+        logger.Info("TCP peer already connected on " + endpoint + ", reusing existing connection");
+        return true;
+    }

+    CloseDataSocket();
    broken = false;

    pollfd pfd{};