Krakatoa-Earth
/
ProxySystem
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

auto restart system

master
Alex 2021-12-27 23:52:22 +01:00
parent 589c84117e
commit 2f2f4fa44f
1 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
src/main/java/net/krakatoa/proxy/listener/SocketClientMessageListener.java
View File

@ -73,11 +73,9 @@ public class SocketClientMessageListener implements KraSocketClientEventInterfac
ServiceTask serviceTask = CloudNetDriver.getInstance().getServiceTaskProvider()
.getServiceTask("Lobby");
if (!playersAutoRestartServerSystem.containsKey("lobby")) {
playersAutoRestartServerSystem.put("lobby", null);
}
if (serviceTask != null) {
playersAutoRestartServerSystem.put(serviceTask.getName(), null);
ServiceInfoSnapshot serviceInfoSnapshot = ServiceConfiguration.builder(serviceTask)
.build().createNewService();
@ -106,8 +104,6 @@ public class SocketClientMessageListener implements KraSocketClientEventInterfac
// stop target server
CloudNetDriver.getInstance().getCloudServiceProvider(serviceInfoSnapshot).stop();
}
}
break;
}
@ -115,15 +111,14 @@ public class SocketClientMessageListener implements KraSocketClientEventInterfac
String serverName = kraProtocolMessage.getArgs().toLowerCase();
if (serverName.startsWith("lobby") && playersAutoRestartServerSystem.containsKey(
"lobby")) { // close old lobbies
kraProtocolMessage.getArgs())) { // close old lobbies
Collection<ServiceInfoSnapshot> serviceInfoSnapshots = CloudNetDriver.getInstance()
.getCloudServiceProvider()
.getCloudServices("Lobby");
if (serviceInfoSnapshots != null) {
serviceInfoSnapshots.forEach(serviceInfoSnapshot -> {
System.out.println("lobby " + serviceInfoSnapshot.getName());
if (!serverName.equals(serviceInfoSnapshot.getName())) {
if (!playersAutoRestartServerSystem.containsKey(serviceInfoSnapshot.getName())) {
serviceInfoSnapshot.provider().stop();
}
});