You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by vi...@apache.org on 2016/03/16 01:03:39 UTC

[4/5] mesos git commit: Modified `FaultToleranceTest.SchedulerExit` to wait for shutdown.

Modified `FaultToleranceTest.SchedulerExit` to wait for shutdown.

This change modified the existing test to wait for the shutdown
message instead of making a best-effort `AtMost` check for
the message.

Review: https://reviews.apache.org/r/44731/


Project: http://git-wip-us.apache.org/repos/asf/mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/8c35ee31
Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/8c35ee31
Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/8c35ee31

Branch: refs/heads/master
Commit: 8c35ee31a9320acd829b35a6f7c7b189becd385c
Parents: 92b3541
Author: Anand Mazumdar <ma...@gmail.com>
Authored: Tue Mar 15 17:03:11 2016 -0700
Committer: Vinod Kone <vi...@gmail.com>
Committed: Tue Mar 15 17:03:11 2016 -0700

----------------------------------------------------------------------
 src/tests/fault_tolerance_tests.cpp | 7 ++++++-
 1 file changed, 6 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/mesos/blob/8c35ee31/src/tests/fault_tolerance_tests.cpp
----------------------------------------------------------------------
diff --git a/src/tests/fault_tolerance_tests.cpp b/src/tests/fault_tolerance_tests.cpp
index 349669d..67f3627 100644
--- a/src/tests/fault_tolerance_tests.cpp
+++ b/src/tests/fault_tolerance_tests.cpp
@@ -1580,12 +1580,17 @@ TEST_F(FaultToleranceTest, SchedulerExit)
   AWAIT_READY(status);
   EXPECT_EQ(TASK_RUNNING, status.get().state());
 
+  Future<Nothing> shutdown;
   EXPECT_CALL(exec, shutdown(_))
-    .Times(AtMost(1));
+    .WillOnce(FutureSatisfy(&shutdown));
 
   driver.stop();
   driver.join();
 
+  // Ensure that the executor receives a shutdown message after the
+  // scheduler exit.
+  AWAIT_READY(shutdown);
+
   Shutdown();
 }