0002617: Allow user into web console as soon as one engine initializes

JumpMind · May 27, 2016 · 744e10b · 744e10b
1 parent 3df0a2c
commit 744e10b
Showing 1 changed file with 19 additions and 1 deletion.
diff --git a/symmetric-server/src/main/java/org/jumpmind/symmetric/web/SymmetricEngineHolder.java b/symmetric-server/src/main/java/org/jumpmind/symmetric/web/SymmetricEngineHolder.java
@@ -377,6 +377,19 @@ public boolean areEnginesStarting() {
         return !holderHasBeenStarted || enginesStarting.size() > 0;
     }
 
+    public boolean hasAnyEngineInitialized() {
+        if (enginesStarting.size() < engines.size()) {
+            return true;
+        }
+        for (EngineStarter starter : enginesStarting) {
+            ISymmetricEngine engine = starter.getEngine();
+            if (engine != null && engine.isInitialized()) {
+                return true;
+            }
+        }
+        return false;
+    }
+
     public String getEngineName(Properties properties) {
         String engineName = properties.getProperty(ParameterConstants.ENGINE_NAME);
         if (StringUtils.isBlank(engineName)) {
@@ -450,6 +463,7 @@ public static Date getCreateTime() {
     class EngineStarter extends Thread {
 
         String propertiesFile;
+        ISymmetricEngine engine;
 
         public EngineStarter(String propertiesFile) {
             super("symmetric-engine-startup-"+threadNumber++);
@@ -458,12 +472,16 @@ public EngineStarter(String propertiesFile) {
 
         @Override
         public void run() {
-            ISymmetricEngine engine = create(propertiesFile);        	
+            engine = create(propertiesFile);        	
             if (engine != null && autoStart &&
                     engine.getParameterService().is(ParameterConstants.AUTO_START_ENGINE)) {
                 engine.start();
             }
             enginesStarting.remove(this);
         }
+
+        public ISymmetricEngine getEngine() {
+            return engine;
+        }
     }
 }