diff options
author | Sébastien Lesaint <sebastien.lesaint@sonarsource.com> | 2017-02-20 17:55:57 +0100 |
---|---|---|
committer | Sébastien Lesaint <sebastien.lesaint@sonarsource.com> | 2017-02-24 20:27:07 +0100 |
commit | f8304edef63a6648ab1f05843a6be4e99af9dc71 (patch) | |
tree | c3cfec3c536d2318613fd6ae5bf8bcef93402a88 /server/sonar-ce | |
parent | f874edc25c9217cd7e2ccbf3c849efb55ccfb231 (diff) | |
download | sonarqube-f8304edef63a6648ab1f05843a6be4e99af9dc71.tar.gz sonarqube-f8304edef63a6648ab1f05843a6be4e99af9dc71.zip |
SONAR-7500 remove useless Monitored WARN log when web fails to start
by replacing Monitored#isUp() by Monitored#getStatus()
Diffstat (limited to 'server/sonar-ce')
-rw-r--r-- | server/sonar-ce/src/main/java/org/sonar/ce/app/CeServer.java | 7 | ||||
-rw-r--r-- | server/sonar-ce/src/test/java/org/sonar/ce/app/CeServerTest.java | 19 |
2 files changed, 15 insertions, 11 deletions
diff --git a/server/sonar-ce/src/main/java/org/sonar/ce/app/CeServer.java b/server/sonar-ce/src/main/java/org/sonar/ce/app/CeServer.java index 360d7409e16..1ae2b34143e 100644 --- a/server/sonar-ce/src/main/java/org/sonar/ce/app/CeServer.java +++ b/server/sonar-ce/src/main/java/org/sonar/ce/app/CeServer.java @@ -78,10 +78,13 @@ public class CeServer implements Monitored { } @Override - public boolean isUp() { + public Status getStatus() { checkState(ceMainThread != null, "isUp() can not be called before start()"); - return ceMainThread.isStarted(); + if (ceMainThread.isStarted()) { + return Status.UP; + } + return Status.DOWN; } @Override diff --git a/server/sonar-ce/src/test/java/org/sonar/ce/app/CeServerTest.java b/server/sonar-ce/src/test/java/org/sonar/ce/app/CeServerTest.java index 4393a5c2062..0a4f46caab0 100644 --- a/server/sonar-ce/src/test/java/org/sonar/ce/app/CeServerTest.java +++ b/server/sonar-ce/src/test/java/org/sonar/ce/app/CeServerTest.java @@ -32,6 +32,7 @@ import org.junit.rules.Timeout; import org.mockito.Mockito; import org.sonar.ce.ComputeEngine; import org.sonar.process.MinimumViableSystem; +import org.sonar.process.Monitored; import static com.google.common.base.Preconditions.checkState; import static java.util.concurrent.TimeUnit.MILLISECONDS; @@ -97,7 +98,7 @@ public class CeServerTest { expectedException.expect(IllegalStateException.class); expectedException.expectMessage("isUp() can not be called before start()"); - ceServer.isUp(); + ceServer.getStatus(); } @Test @@ -107,15 +108,15 @@ public class CeServerTest { ceServer.start(); - assertThat(ceServer.isUp()).isFalse(); + assertThat(ceServer.getStatus()).isEqualTo(Monitored.Status.DOWN); // release ComputeEngine startup method computeEngine.releaseStartup(); - while (!ceServer.isUp()) { + while (ceServer.getStatus() == Monitored.Status.DOWN) { // wait for isReady to change to true, otherwise test will fail with timeout } - assertThat(ceServer.isUp()).isTrue(); + assertThat(ceServer.getStatus()).isEqualTo(Monitored.Status.UP); } @Test @@ -127,15 +128,15 @@ public class CeServerTest { ceServer.start(); - assertThat(ceServer.isUp()).isFalse(); + assertThat(ceServer.getStatus()).isEqualTo(Monitored.Status.DOWN); // release ComputeEngine startup method which will throw startupException computeEngine.releaseStartup(); - while (!ceServer.isUp()) { + while (ceServer.getStatus() == Monitored.Status.DOWN) { // wait for isReady to change to true, otherwise test will fail with timeout } - assertThat(ceServer.isUp()).isTrue(); + assertThat(ceServer.getStatus()).isEqualTo(Monitored.Status.UP); } @Test @@ -148,7 +149,7 @@ public class CeServerTest { ceServer.start(); ceServer.awaitStop(); - assertThat(ceServer.isUp()).isTrue(); + assertThat(ceServer.getStatus()).isEqualTo(Monitored.Status.UP); } @Test @@ -186,7 +187,7 @@ public class CeServerTest { } @Test - public void awaitStop_keeps_blocking_calling_thread_even_if_calling_thread_is_interrupted_but_until_stop_is_called() throws InterruptedException, IOException { + public void awaitStop_keeps_blocking_calling_thread_even_if_calling_thread_is_interrupted_but_until_stop_is_called() throws Exception { final CeServer ceServer = newCeServer(); Thread waitingThread = newWaitingThread(ceServer::awaitStop); |