close adapter on connection rpc loss

FAForever · Oct 21, 2018 · 2bf2ce9 · 2bf2ce9
1 parent 822d9c3
commit 2bf2ce9
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 1 deletion.
diff --git a/ice-adapter/build.gradle b/ice-adapter/build.gradle
@@ -31,7 +31,7 @@ dependencies {
 //    implementation "org.jitsi:ice4j:1.0"
 //    implementation 'com.github.jitsi:ice4j:59693a4894'
     implementation 'com.github.Geosearchef:ice4j:52c8e4bcef'
-    implementation 'com.github.Geosearchef:JJsonRpc:master'
+    implementation 'com.github.Geosearchef:JJsonRpc:10a8fbaa26'
     implementation "com.google.code.gson:gson:2.7"
     implementation "com.google.guava:guava:18.0"
     implementation "org.slf4j:slf4j-api:1.7.25"

diff --git a/ice-adapter/src/main/java/com/faforever/iceadapter/rpc/RPCService.java b/ice-adapter/src/main/java/com/faforever/iceadapter/rpc/RPCService.java
@@ -32,6 +32,12 @@ public static void init() {
         tcpServer.start();
 
         debug().rpcStarted(tcpServer.getFirstPeer());
+        tcpServer.getFirstPeer().thenAccept(firstPeer -> {
+            firstPeer.onConnectionLost(() -> {
+                log.info("Lost connection to first RPC Peer. Stopping adapter...");
+                IceAdapter.close();
+            });
+        });
     }
 
     public static void onConnectionStateChanged(String newState) {