aboutsummaryrefslogtreecommitdiffstats
path: root/server/sonar-ce
diff options
context:
space:
mode:
authorSébastien Lesaint <sebastien.lesaint@sonarsource.com>2017-02-20 17:55:57 +0100
committerSébastien Lesaint <sebastien.lesaint@sonarsource.com>2017-02-24 20:27:07 +0100
commitf8304edef63a6648ab1f05843a6be4e99af9dc71 (patch)
treec3cfec3c536d2318613fd6ae5bf8bcef93402a88 /server/sonar-ce
parentf874edc25c9217cd7e2ccbf3c849efb55ccfb231 (diff)
downloadsonarqube-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.java7
-rw-r--r--server/sonar-ce/src/test/java/org/sonar/ce/app/CeServerTest.java19
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);