Wait indefinitely on server for connections.

mnellemann · Jul 14, 2023 · 77b7984 · 77b7984
1 parent 9f67f98
commit 77b7984
Show file tree

Hide file tree

Showing 3 changed files with 12 additions and 7 deletions.
diff --git a/gradle.properties b/gradle.properties
@@ -1,3 +1,3 @@
 projectId               = jnetperf
 projectGroup            = biz.nellemann.jnetperf
-projectVersion          = 0.0.6
+projectVersion          = 0.0.7
diff --git a/src/main/java/biz/nellemann/jnetperf/Application.java b/src/main/java/biz/nellemann/jnetperf/Application.java
@@ -54,12 +54,16 @@ static class RunMode {
 
 
     @Override
-    public Integer call() throws Exception {
+    public Integer call() {
 
-        if(runMode.runServer) {
-            runServer();
-        } else if(runMode.remoteServer != null) {
-            runClient(runMode.remoteServer);
+        try {
+            if (runMode.runServer) {
+                runServer();
+            } else if (runMode.remoteServer != null) {
+                runClient(runMode.remoteServer);
+            }
+        } catch (IOException | InterruptedException e) {
+            System.err.println(e.getMessage());
         }
 
         return 0;

diff --git a/src/main/java/biz/nellemann/jnetperf/TcpServer.java b/src/main/java/biz/nellemann/jnetperf/TcpServer.java
@@ -22,7 +22,8 @@ public TcpServer(int port) throws IOException {
         log.info("TcpServer()");
 
         socket = new ServerSocket(port);
-        socket.setSoTimeout(10000);
+        socket.setSoTimeout(0); // Wait indefinitely
+
     }