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

fix: 尝试修复断联问题

Browse Source
This commit is contained in:
yarnom 2025-10-29 09:58:39 +08:00
parent e07250637e
commit 0b7789838b
1 changed files with 13 additions and 4 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,21 +250,30 @@ public class RtkClusterService implements ApplicationRunner {
} }
if (n > 0 && isLikelyText(probe, n)) { if (n > 0 && isLikelyText(probe, n)) {
if (!isSocketAlive(outConn)) { Socket previous = 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 {} additional OUT connection detected; keeping existing", port); LOGGER.info("Endpoint {} replacing existing OUT connection", port);
closeQuietly(previous);
outConn = s;
assigned = true;
pumpOut(s, probe, n);
} }
} else { } else {
if (!isSocketAlive(inConn)) { Socket previous = 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 {} additional IN connection detected; keeping existing", port); LOGGER.info("Endpoint {} replacing existing IN connection", port);
closeQuietly(previous);
inConn = s;
assigned = true;
} }
} }
} catch (IOException e) { } catch (IOException e) {