Repository: mesos Updated Branches: refs/heads/master bf3c96743 -> d99427159
Update SlaveRecoveryTest to send libprocess messages from a real UPID. Review: https://reviews.apache.org/r/58517/ Project: http://git-wip-us.apache.org/repos/asf/mesos/repo Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/d9942715 Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/d9942715 Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/d9942715 Branch: refs/heads/master Commit: d99427159fb4f98ca43ba008bac31850bd666f58 Parents: bf3c967 Author: James Peach <[email protected]> Authored: Mon May 1 16:46:55 2017 -0700 Committer: Benjamin Mahler <[email protected]> Committed: Mon May 1 16:56:31 2017 -0700 ---------------------------------------------------------------------- src/tests/slave_recovery_tests.cpp | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mesos/blob/d9942715/src/tests/slave_recovery_tests.cpp ---------------------------------------------------------------------- diff --git a/src/tests/slave_recovery_tests.cpp b/src/tests/slave_recovery_tests.cpp index 53f33a2..52e78b6 100644 --- a/src/tests/slave_recovery_tests.cpp +++ b/src/tests/slave_recovery_tests.cpp @@ -339,7 +339,7 @@ TYPED_TEST(SlaveRecoveryTest, RecoverSlaveState) // Shut down the executor manually so that it doesn't hang around // after the test finishes. - process::post(libprocessPid, ShutdownExecutorMessage()); + process::post(slave.get()->pid, libprocessPid, ShutdownExecutorMessage()); driver.stop(); driver.join(); @@ -2346,7 +2346,7 @@ TYPED_TEST(SlaveRecoveryTest, Reboot) Future<Option<int>> executorStatus = process::reap(pid.get()); // Shut down the executor manually and wait until it's been reaped. - process::post(executorPid, ShutdownExecutorMessage()); + process::post(slave.get()->pid, executorPid, ShutdownExecutorMessage()); AWAIT_READY(executorStatus); @@ -2601,7 +2601,7 @@ TYPED_TEST(SlaveRecoveryTest, ShutdownSlave) // We shut down the executor here so that a shutting down slave // does not spend too much time waiting for the executor to exit. - process::post(executorPid, ShutdownExecutorMessage()); + process::post(slave.get()->pid, executorPid, ShutdownExecutorMessage()); Clock::pause();
