|
@@ -561,6 +561,8 @@ public class TestNodeStatusUpdater {
|
|
|
|
|
|
@Override
|
|
@Override
|
|
protected void serviceStop() throws Exception {
|
|
protected void serviceStop() throws Exception {
|
|
|
|
+ // Make sure that all containers are started before starting shutdown
|
|
|
|
+ syncBarrier.await(10000, TimeUnit.MILLISECONDS);
|
|
System.out.println("Called stooppppp");
|
|
System.out.println("Called stooppppp");
|
|
super.serviceStop();
|
|
super.serviceStop();
|
|
isStopped = true;
|
|
isStopped = true;
|
|
@@ -1757,6 +1759,9 @@ public class TestNodeStatusUpdater {
|
|
new File("start_file.txt"), port);
|
|
new File("start_file.txt"), port);
|
|
|
|
|
|
try {
|
|
try {
|
|
|
|
+ // Wait until we start stopping
|
|
|
|
+ syncBarrier.await(10000, TimeUnit.MILLISECONDS);
|
|
|
|
+ // Wait until we finish stopping
|
|
syncBarrier.await(10000, TimeUnit.MILLISECONDS);
|
|
syncBarrier.await(10000, TimeUnit.MILLISECONDS);
|
|
} catch (Exception e) {
|
|
} catch (Exception e) {
|
|
}
|
|
}
|