server timeout to free the listening port after 50sec, and allow another model instance to run

Signed-off-by: Julien Veyssier <eneiluj@posteo.net>

jams/Whatasit.java

@@ -71,15 +71,15 @@ public class Whatasit extends JAMSComponent {
     }
 
     public void run() {
-        System.out.println("WHATASIT begin run "+i);
+        System.out.println("WHATASIT waiting permission to launch run "+i);
         try {
             sOkStep.acquire();
         } catch (InterruptedException exc) {
             System.out.println(exc);
         }
-        System.out.println("WHATASIT !!DOING!! run "+i);
+        System.out.println("WHATASIT !!DOING!! 2sec run "+i);
         try {
-            Thread.sleep(5000);
+            Thread.sleep(2000);
         } catch (InterruptedException exc) {
             System.out.println(exc);
         }
@@ -91,7 +91,7 @@ public class Whatasit extends JAMSComponent {
     }
     
     public void cleanup() throws JAMSEntity.NoSuchAttributeException {
-        System.out.println("STOPPING THREAD");
+        System.out.println("STOPPING THREAD at simulation end");
         comServer.stop();
     }
 
@@ -99,30 +99,69 @@ public class Whatasit extends JAMSComponent {
         comServer = new ComServer(9999, "WhatasitThread");
         comServer.start();
     }
+    
+    private class TimeoutProcess extends Thread {
+        private int nbSec;
+        private ComServer server;
+        public TimeoutProcess(int nbSec, ComServer server) {
+            this.nbSec = nbSec;
+            this.server = server;
+        }
+        
+        @Override
+        public void run() {
+            try {
+                Thread.sleep(nbSec * 1000);
+            } catch (InterruptedException exc) {
+                System.out.println(exc);
+            }
+            System.out.println("timeout reached, KILLING server");
+            // kill socket
+            server.stopServer();
+            // stop the thread
+            server.stop();
+        }
+    }
 
     private class ComServer extends Thread {
 
         String threadName;
         int port;
+        TimeoutProcess timeoutProcess = null;
+        ServerSocket ss;
 
         public ComServer(int port, String threadName) {
             super(threadName);
             this.threadName = threadName;
             this.port = port;
+            try {
+                this.ss = new ServerSocket(port);
+            } catch (Exception e) {
+                System.err.println(e);
+            }
+        }
+        
+        public void stopServer() {
+            try {
+                ss.close();
+            } catch (Exception e) {
+                System.err.println(e);
+            }
         }
 
         @Override
         public void run() {
 
             try {
-                ServerSocket ss = new ServerSocket(port);
-
                 for (;;) {
                     System.out.println("server starting LISTENING on port "+port);
 
                     // Wait for a client to connect.
                     Socket client = ss.accept();
                     System.out.println("connection received");
+                    if (timeoutProcess != null) {
+                        timeoutProcess.stop();
+                    }
 
                     // wait for component to tell us it has finished a step to process
                     // further resquest
@@ -156,6 +195,11 @@ public class Whatasit extends JAMSComponent {
                     in.close(); // Close the input stream
                     client.close(); // Close the socket itself
                     
+                    // launch timeout
+                    System.out.println("launching timeout");
+                    timeoutProcess = new TimeoutProcess(50, this);
+                    timeoutProcess.start();
+                    
                     sOkStep.release();
 
                 } // Now loop again, waiting for the next connection