fix(multiplayer): broadcast port wrong.

This commit is contained in:
huanghongxun
2021-10-06 03:21:47 +08:00
parent 4201ac9203
commit 3a2f5a77ef

View File

@@ -116,7 +116,6 @@ public final class MultiplayerManager {
} }
CatoSession session = new CatoSession(sessionName, State.SLAVE, process, Arrays.asList(commands)); CatoSession session = new CatoSession(sessionName, State.SLAVE, process, Arrays.asList(commands));
session.addRelatedThread(Lang.thread(new LocalServerBroadcaster(localPort, session), "LocalServerBroadcaster", true));
CompletableFuture<CatoSession> future = new CompletableFuture<>(); CompletableFuture<CatoSession> future = new CompletableFuture<>();
@@ -137,8 +136,9 @@ public final class MultiplayerManager {
client.onConnected().register(connectedEvent -> { client.onConnected().register(connectedEvent -> {
try { try {
int port = findAvailablePort(); int port = findAvailablePort();
String command = String.format("net add %s %s:%d %s:%d %s\n", peer, LOCAL_ADDRESS, port, REMOTE_ADDRESS, connectedEvent.getPort(), mode.getName()); String command = String.format("net add %s %s:%d %s:%d %s", peer, LOCAL_ADDRESS, port, REMOTE_ADDRESS, connectedEvent.getPort(), mode.getName());
LOG.info("Invoking cato: " + command); LOG.info("Invoking cato: " + command);
session.addRelatedThread(Lang.thread(new LocalServerBroadcaster(port, session), "LocalServerBroadcaster", true));
client.setGamePort(port); client.setGamePort(port);
writer.write(command); writer.write(command);
writer.newLine(); writer.newLine();