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 2013/06/24 20:44:41 UTC

git commit: Fixed flaky FaultToleranceTest.ReconcileIncompleteTasks test.

Updated Branches:
  refs/heads/master ad198fe48 -> dd25b2de9


Fixed flaky FaultToleranceTest.ReconcileIncompleteTasks test.

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


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

Branch: refs/heads/master
Commit: dd25b2de9d8ff55d316d1cba6efad7f574a9973e
Parents: ad198fe
Author: Vinod Kone <vi...@twitter.com>
Authored: Mon Jun 24 11:15:38 2013 -0700
Committer: Vinod Kone <vi...@twitter.com>
Committed: Mon Jun 24 11:16:06 2013 -0700

----------------------------------------------------------------------
 src/tests/fault_tolerance_tests.cpp | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-mesos/blob/dd25b2de/src/tests/fault_tolerance_tests.cpp
----------------------------------------------------------------------
diff --git a/src/tests/fault_tolerance_tests.cpp b/src/tests/fault_tolerance_tests.cpp
index 4afbbec..414c648 100644
--- a/src/tests/fault_tolerance_tests.cpp
+++ b/src/tests/fault_tolerance_tests.cpp
@@ -1523,10 +1523,12 @@ TEST_F(FaultToleranceTest, ReconcileIncompleteTasks)
   AWAIT_READY(slaveReregisteredMessage);
 
   // The master should not send a TASK_LOST after the slave
-  // re-registers. We check this by advancing the clock so that
+  // re-registers. We check this by calling Clock::settle() so that
   // the only update the scheduler receives is the retried
   // TASK_FINISHED update.
-  Clock::advance(STATUS_UPDATE_RETRY_INTERVAL);
+  // NOTE: The status update manager resends the status update when
+  // it receives a NewMasterDetected message.
+  Clock::settle();
 
   AWAIT_READY(status);
   ASSERT_EQ(TASK_FINISHED, status.get().state());