You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by bm...@apache.org on 2013/12/06 02:34:25 UTC

git commit: Fixed the flaky FaultToleranceTest.SlaveReregisterOnZKExpiration test.

Updated Branches:
  refs/heads/master fa14ea423 -> e5cf7360a


Fixed the flaky FaultToleranceTest.SlaveReregisterOnZKExpiration test.


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

Branch: refs/heads/master
Commit: e5cf7360ab634954ae349ee1341b74f125c0f4dd
Parents: fa14ea4
Author: Benjamin Mahler <bm...@twitter.com>
Authored: Thu Dec 5 17:11:05 2013 -0800
Committer: Benjamin Mahler <bm...@twitter.com>
Committed: Thu Dec 5 17:28:47 2013 -0800

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


http://git-wip-us.apache.org/repos/asf/mesos/blob/e5cf7360/src/tests/fault_tolerance_tests.cpp
----------------------------------------------------------------------
diff --git a/src/tests/fault_tolerance_tests.cpp b/src/tests/fault_tolerance_tests.cpp
index 7157292..74d3447 100644
--- a/src/tests/fault_tolerance_tests.cpp
+++ b/src/tests/fault_tolerance_tests.cpp
@@ -1616,10 +1616,15 @@ TEST_F(FaultToleranceTest, SlaveReregisterOnZKExpiration)
   Try<PID<Master> > master = StartMaster();
   ASSERT_SOME(master);
 
+  Future<SlaveRegisteredMessage> slaveRegisteredMessage =
+    FUTURE_PROTOBUF(SlaveRegisteredMessage(), _, _);
+
   StandaloneMasterDetector* detector = new StandaloneMasterDetector(master.get());
   Try<PID<Slave> > slave = StartSlave(Owned<MasterDetector>(detector));
   ASSERT_SOME(slave);
 
+  AWAIT_READY(slaveRegisteredMessage);
+
   MockScheduler sched;
   MesosSchedulerDriver driver(
       &sched, DEFAULT_FRAMEWORK_INFO, master.get(), DEFAULT_CREDENTIAL);