From c252b11d3c5f14212d2cfab85d628d24fe174163 Mon Sep 17 00:00:00 2001
From: yarnom <admin@yarnom.com>
Date: Wed, 29 Oct 2025 10:34:55 +0800
Subject: [PATCH] =?UTF-8?q?Revert=20"fix:=20=E5=B0=9D=E8=AF=95=E4=BF=AE?=
 =?UTF-8?q?=E5=A4=8D=E6=96=AD=E8=81=94=E9=97=AE=E9=A2=98"?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

This reverts commit 0b7789838bb6cc63d4d6775ef764b7073d451ca6.
---
 .../sideslope/rtkcluster/RtkClusterService.java | 17 ++++-------------
 1 file changed, 4 insertions(+), 13 deletions(-)

diff --git a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/rtkcluster/RtkClusterService.java b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/rtkcluster/RtkClusterService.java
index d048c800..1361042f 100644
--- a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/rtkcluster/RtkClusterService.java
+++ b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/rtkcluster/RtkClusterService.java
@@ -250,30 +250,21 @@ public class RtkClusterService implements ApplicationRunner {
                     }
 
                     if (n > 0 && isLikelyText(probe, n)) {
-                        Socket previous = outConn;
-                        if (!isSocketAlive(previous)) {
+                        if (!isSocketAlive(outConn)) {
                             outConn = s;
                             assigned = true;
                             LOGGER.debug("Endpoint {} OUT connected", port);
                             pumpOut(s, probe, n);
                         } else {
-                            LOGGER.info("Endpoint {} replacing existing OUT connection", port);
-                            closeQuietly(previous);
-                            outConn = s;
-                            assigned = true;
-                            pumpOut(s, probe, n);
+                            LOGGER.info("Endpoint {} additional OUT connection detected; keeping existing", port);
                         }
                     } else {
-                        Socket previous = inConn;
-                        if (!isSocketAlive(previous)) {
+                        if (!isSocketAlive(inConn)) {
                             inConn = s;
                             assigned = true;
                             LOGGER.debug("Endpoint {} IN connected", port);
                         } else {
-                            LOGGER.info("Endpoint {} replacing existing IN connection", port);
-                            closeQuietly(previous);
-                            inConn = s;
-                            assigned = true;
+                            LOGGER.info("Endpoint {} additional IN connection detected; keeping existing", port);
                         }
                     }
                 } catch (IOException e) {