From 8890408f38996cc85a2f6c8e5068a77019b810a9 Mon Sep 17 00:00:00 2001 From: Ace Date: Wed, 14 Jun 2017 12:37:46 +0530 Subject: [PATCH] Optimizing server start up time when running integration tests --- .../CarbonServerManagerExtension.java | 36 ++++++++++--------- 1 file changed, 20 insertions(+), 16 deletions(-) diff --git a/modules/integration/tests-common/integration-common/src/main/java/org/wso2/iot/integration/common/extensions/CarbonServerManagerExtension.java b/modules/integration/tests-common/integration-common/src/main/java/org/wso2/iot/integration/common/extensions/CarbonServerManagerExtension.java index cbf21428..cc7f1576 100644 --- a/modules/integration/tests-common/integration-common/src/main/java/org/wso2/iot/integration/common/extensions/CarbonServerManagerExtension.java +++ b/modules/integration/tests-common/integration-common/src/main/java/org/wso2/iot/integration/common/extensions/CarbonServerManagerExtension.java @@ -106,16 +106,20 @@ public class CarbonServerManagerExtension { .automationContext.getInstance().getHosts().get("default")); long time = System.currentTimeMillis() + 60000L; - while(true) { - if(this.inputStreamHandler.getOutput().contains("Mgt Console URL") || System.currentTimeMillis() >= time) { - int httpsPort = defaultHttpsPort + this.portOffset; - String backendURL = this.automationContext.getContextUrls().getSecureServiceUrl().replaceAll("(:\\d+)", ":" + httpsPort); - User superUser = this.automationContext.getSuperTenant().getTenantAdmin(); - ClientConnectionUtil.waitForLogin(backendURL, superUser); - log.info("Server started successfully."); - break; - } - } +// while(true) { +// if(this.inputStreamHandler.getOutput().contains("Mgt Console URL") || System.currentTimeMillis() >= time) { +// int httpsPort = defaultHttpsPort + this.portOffset; +// String backendURL = this.automationContext.getContextUrls().getSecureServiceUrl().replaceAll("(:\\d+)", ":" + httpsPort); +// User superUser = this.automationContext.getSuperTenant().getTenantAdmin(); +// ClientConnectionUtil.waitForLogin(backendURL, superUser); +// log.info("Server started successfully."); +// break; +// } +// } + int httpsPort = defaultHttpsPort + this.portOffset; + String backendURL = this.automationContext.getContextUrls().getSecureServiceUrl().replaceAll("(:\\d+)", ":" + httpsPort); + User superUser = this.automationContext.getSuperTenant().getTenantAdmin(); + ClientConnectionUtil.waitForLogin(backendURL, superUser); } catch (XPathExpressionException | IOException var13) { throw new IllegalStateException("Unable to start server", var13); } @@ -212,9 +216,9 @@ public class CarbonServerManagerExtension { long time = System.currentTimeMillis() + 300000L; - while(!this.inputStreamHandler.getOutput().contains("Halting JVM") && System.currentTimeMillis() < time) { - ; - } +// while(!this.inputStreamHandler.getOutput().contains("Halting JVM") && System.currentTimeMillis() < time) { +// ; +// } log.info("Server stopped successfully..."); } @@ -261,9 +265,9 @@ public class CarbonServerManagerExtension { long time = System.currentTimeMillis() + 300000L; - while(!this.inputStreamHandler.getOutput().contains("Halting JVM") && System.currentTimeMillis() < time) { - ; - } +// while(!this.inputStreamHandler.getOutput().contains("Halting JVM") && System.currentTimeMillis() < time) { +// ; +// } time = System.currentTimeMillis();