Updated scheduler driver to send REVIVE call. Review: https://reviews.apache.org/r/36465
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/90ed30d4 Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/90ed30d4 Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/90ed30d4 Branch: refs/heads/master Commit: 90ed30d4d9f99ad9a469e6aaf9fd0fc2ea781772 Parents: 0981c8d Author: Vinod Kone <[email protected]> Authored: Fri Jul 10 12:59:51 2015 -0700 Committer: Vinod Kone <[email protected]> Committed: Fri Jul 17 10:43:59 2015 -0700 ---------------------------------------------------------------------- src/sched/sched.cpp | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mesos/blob/90ed30d4/src/sched/sched.cpp ---------------------------------------------------------------------- diff --git a/src/sched/sched.cpp b/src/sched/sched.cpp index 9da0782..4099bce 100644 --- a/src/sched/sched.cpp +++ b/src/sched/sched.cpp @@ -1167,10 +1167,14 @@ protected: return; } - ReviveOffersMessage message; - message.mutable_framework_id()->MergeFrom(framework.id()); + Call call; + + CHECK(framework.has_id()); + call.mutable_framework_id()->CopyFrom(framework.id()); + call.set_type(Call::REVIVE); + CHECK_SOME(master); - send(master.get(), message); + send(master.get(), call); } void acknowledgeStatusUpdate(
