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 2015/10/15 20:13:37 UTC
mesos git commit: Updated scheduler driver to use Call::REQUEST to
request resource.
Repository: mesos
Updated Branches:
refs/heads/master afee34c2e -> bad9760fa
Updated scheduler driver to use Call::REQUEST to request resource.
Review: https://reviews.apache.org/r/39259
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/bad9760f
Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/bad9760f
Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/bad9760f
Branch: refs/heads/master
Commit: bad9760fafea80032623360d149b4310164153da
Parents: afee34c
Author: Guangya Liu <gy...@gmail.com>
Authored: Thu Oct 15 11:09:43 2015 -0700
Committer: Vinod Kone <vi...@gmail.com>
Committed: Thu Oct 15 11:09:43 2015 -0700
----------------------------------------------------------------------
src/sched/sched.cpp | 16 +++++++++++-----
1 file changed, 11 insertions(+), 5 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mesos/blob/bad9760f/src/sched/sched.cpp
----------------------------------------------------------------------
diff --git a/src/sched/sched.cpp b/src/sched/sched.cpp
index 724d7c0..9c5e3b8 100644
--- a/src/sched/sched.cpp
+++ b/src/sched/sched.cpp
@@ -1114,13 +1114,19 @@ protected:
return;
}
- ResourceRequestMessage message;
- message.mutable_framework_id()->MergeFrom(framework.id());
- foreach (const Request& request, requests) {
- message.add_requests()->MergeFrom(request);
+ Call call;
+
+ CHECK(framework.has_id());
+ call.mutable_framework_id()->CopyFrom(framework.id());
+ call.set_type(Call::REQUEST);
+
+ Call::Request* request = call.mutable_request();
+ foreach (const Request& _request, requests) {
+ request->add_requests()->CopyFrom(_request);
}
+
CHECK_SOME(master);
- send(master.get().pid(), message);
+ send(master.get().pid(), call);
}
void launchTasks(const vector<OfferID>& offerIds,