Imdroid/security-monitor
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Revert "fix: 尝试修复断联问题"

Browse Source 
This reverts commit 0b7789838bb6cc63d4d6775ef764b7073d451ca6.
This commit is contained in:
yarnom 2025-10-29 10:34:55 +08:00
parent 2a9ab127c5
commit c252b11d3c
1 changed files with 4 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/rtkcluster/RtkClusterService.java
View File

@ -250,30 +250,21 @@ public class RtkClusterService implements ApplicationRunner {
} }
if (n > 0 && isLikelyText(probe, n)) { if (n > 0 && isLikelyText(probe, n)) {
Socket previous = outConn; if (!isSocketAlive(outConn)) {
if (!isSocketAlive(previous)) {
outConn = s; outConn = s;
assigned = true; assigned = true;
LOGGER.debug("Endpoint {} OUT connected", port); LOGGER.debug("Endpoint {} OUT connected", port);
pumpOut(s, probe, n); pumpOut(s, probe, n);
} else { } else {
LOGGER.info("Endpoint {} replacing existing OUT connection", port); LOGGER.info("Endpoint {} additional OUT connection detected; keeping existing", port);
closeQuietly(previous);
outConn = s;
assigned = true;
pumpOut(s, probe, n);
} }
} else { } else {
Socket previous = inConn; if (!isSocketAlive(inConn)) {
if (!isSocketAlive(previous)) {
inConn = s; inConn = s;
assigned = true; assigned = true;
LOGGER.debug("Endpoint {} IN connected", port); LOGGER.debug("Endpoint {} IN connected", port);
} else { } else {
LOGGER.info("Endpoint {} replacing existing IN connection", port); LOGGER.info("Endpoint {} additional IN connection detected; keeping existing", port);
closeQuietly(previous);
inConn = s;
assigned = true;
} }
} }
} catch (IOException e) { } catch (IOException e) {