Merge pull request #11 from avarlamov87/feature/termnate_existing_conns

terminate existing connections, usually after stop.

build/jrpip-config.xml

@@ -14,6 +14,6 @@
   under the License.
   -->
 <project name="jrpip-config">
-    <property name="jrpip.version" value="5.1.2"/>
+    <property name="jrpip.version" value="5.1.3"/>
     <property name="snapshot" value=""/>
 </project>

dco/avarlamov.dco

@@ -0,0 +1,9 @@
+1) I, Alexandr Varlamov, certify that all work committed with the commit message 
+"covered by: avarlamov.dco" is my original work and I own the copyright 
+to this work. I agree to contribute this code under the Apache 2.0 license.
+
+2) I understand and agree all contribution including all personal 
+information I submit with it is maintained indefinitely and may be 
+redistributed consistent with the open source license(s) involved. 
+
+This certification is effective for all code contributed from 2022-07-23 to 9999-01-01.

src/main/java/com/gs/jrpip/server/SocketServer.java

@@ -13,6 +13,7 @@
   specific language governing permissions and limitations
   under the License.
  */
+//Portions copyright Alexandr Varlamov. Licensed under Apache 2.0 license
 
 package com.gs.jrpip.server;
 
@@ -73,6 +74,8 @@ public class SocketServer
     private SocketServerThread socketServerThread;
     private ConcurrentHashMap<String, UserNonces> userNonces = new ConcurrentHashMap<>();
 
+    private ConcurrentHashMap<ServerSocketHandler, Object> hanlders = new ConcurrentHashMap();
+
     public SocketServer(SocketServerConfig config)
     {
         this.config = config;
@@ -147,6 +150,20 @@ public void stop()
         }
     }
 
+    public void terminateConnections()
+    {
+        for (ServerSocketHandler ssh: this.hanlders.keySet())
+        {
+            try
+            {
+                ssh.socket.close();
+            } catch (Exception ignore)
+            {
+
+            }
+        }
+    }
+
     public synchronized void waitForStartup()
     {
         while(!listening)
@@ -237,6 +254,7 @@ public void run()
                     incoming = serverSocket.accept();
                     ServerSocketHandler serverSocketHandler = new ServerSocketHandler(incoming);
                     serverSocketHandler.start();
+                    SocketServer.this.hanlders.put(serverSocketHandler, "1");
                 }
                 catch (SocketTimeoutException e)
                 {
@@ -343,6 +361,14 @@ public void run()
             finally
             {
                 quietlyClose(socket);
+                try
+                {
+                    SocketServer.this.hanlders.remove(this);
+                }
+                catch (Throwable ignore)
+                {
+
+                }
             }
         }