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 2017/05/01 23:56:40 UTC
mesos git commit: Update SlaveRecoveryTest to send libprocess
messages from a real UPID.
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 <jp...@apache.org>
Authored: Mon May 1 16:46:55 2017 -0700
Committer: Benjamin Mahler <bm...@apache.org>
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();