Throwing exception if TLS.keystore_path doesn't exist

belaban · Jan 25, 2024 · 172adba · 172adba
1 parent e0cf7b2
commit 172adba
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 1 deletion.
diff --git a/src/org/jgroups/stack/GossipRouter.java b/src/org/jgroups/stack/GossipRouter.java
@@ -170,7 +170,6 @@ public GossipRouter init() throws Exception {
           .registerProbeHandler(this)
           .printHeaders(b -> String.format("GossipRouter [addr=%s, cluster=GossipRouter, version=%s]\n",
                                            localAddress(), Version.description));
-        tls.init();
         return this;
     }
 
@@ -919,6 +918,7 @@ public static void main(String[] args) throws Exception {
           .setPasscode(diag_passcode);
         String type="";
         if(tls.enabled()) {
+            tls.init();
             SSLContext context=tls.createContext();
             SocketFactory socket_factory=tls.createSocketFactory(context);
             router.socketFactory(socket_factory);

diff --git a/src/org/jgroups/util/TLS.java b/src/org/jgroups/util/TLS.java
@@ -8,6 +8,8 @@
 import javax.net.ssl.SSLContext;
 import javax.net.ssl.SSLParameters;
 import javax.net.ssl.SSLServerSocket;
+import java.io.File;
+import java.io.FileNotFoundException;
 import java.util.ArrayList;
 import java.util.List;
 
@@ -111,6 +113,11 @@ public void init() throws Exception {
             truststore_type=keystore_type;
             truststore_password=keystore_password;
         }
+        if(keystore_path != null) {
+            File tmp=new File(keystore_path);
+            if(!tmp.exists())
+                throw new FileNotFoundException(keystore_path);
+        }
     }
 
     public SSLContext createContext() {