aboutsummaryrefslogtreecommitdiffstats
path: root/server/sonar-process-monitor
diff options
context:
space:
mode:
authorSimon Brandhof <simon.brandhof@sonarsource.com>2014-09-12 21:25:46 +0200
committerSimon Brandhof <simon.brandhof@sonarsource.com>2014-09-12 21:25:46 +0200
commit3f8e453d9e817f76f0c5b7749a115e2d4a7b6faf (patch)
treebe4a4a4fe3c920b496c78eb465007f52ba6fb8c3 /server/sonar-process-monitor
parentc84e6f8d5f1a891033717c3df712a22167bcd1e3 (diff)
parent5de5566591c3fa67edee667e482cbde9312227ee (diff)
downloadsonarqube-3f8e453d9e817f76f0c5b7749a115e2d4a7b6faf.tar.gz
sonarqube-3f8e453d9e817f76f0c5b7749a115e2d4a7b6faf.zip
Merge remote-tracking branch 'origin/branch-4.5'
Conflicts: server/sonar-process-monitor/src/test/java/org/sonar/process/monitor/WatcherThreadTest.java
Diffstat (limited to 'server/sonar-process-monitor')
-rw-r--r--server/sonar-process-monitor/src/test/java/org/sonar/process/monitor/WatcherThreadTest.java16
1 files changed, 2 insertions, 14 deletions
diff --git a/server/sonar-process-monitor/src/test/java/org/sonar/process/monitor/WatcherThreadTest.java b/server/sonar-process-monitor/src/test/java/org/sonar/process/monitor/WatcherThreadTest.java
index 251dcdb21ea..5c953c1fef9 100644
--- a/server/sonar-process-monitor/src/test/java/org/sonar/process/monitor/WatcherThreadTest.java
+++ b/server/sonar-process-monitor/src/test/java/org/sonar/process/monitor/WatcherThreadTest.java
@@ -24,35 +24,23 @@ import org.mockito.Mockito;
import org.mockito.invocation.InvocationOnMock;
import org.mockito.stubbing.Answer;
-import java.util.concurrent.atomic.AtomicBoolean;
-
-import static org.mockito.Mockito.mock;
-import static org.mockito.Mockito.verify;
-import static org.mockito.Mockito.when;
+import static org.mockito.Mockito.*;
public class WatcherThreadTest {
@Test(timeout = 10000L)
public void kill_process_if_watcher_is_interrupted() throws Exception {
ProcessRef ref = mock(ProcessRef.class, Mockito.RETURNS_DEEP_STUBS);
- final AtomicBoolean waiting = new AtomicBoolean(false);
when(ref.getProcess().waitFor()).thenAnswer(new Answer<Object>() {
@Override
public Object answer(InvocationOnMock invocationOnMock) throws Throwable {
- waiting.set(true);
- Thread.sleep(Long.MAX_VALUE);
- return 0;
+ throw new InterruptedException();
}
});
Monitor monitor = mock(Monitor.class);
WatcherThread watcher = new WatcherThread(ref, monitor);
watcher.start();
-
- while (!waiting.get()) {
- Thread.sleep(50L);
- }
- watcher.interrupt();
verify(ref).hardKill();
}
}