You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by ji...@apache.org on 2017/10/30 15:18:49 UTC
[03/15] mesos git commit: Added stub handler in agent for
ApplyOfferOperationMessage.
Added stub handler in agent for ApplyOfferOperationMessage.
Review: https://reviews.apache.org/r/63399
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/6c2c7d0a
Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/6c2c7d0a
Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/6c2c7d0a
Branch: refs/heads/master
Commit: 6c2c7d0ad9018e0b9050831aa7d9621b6c37fc03
Parents: e582318
Author: Jie Yu <yu...@gmail.com>
Authored: Thu Oct 26 12:19:56 2017 +0200
Committer: Jie Yu <yu...@gmail.com>
Committed: Mon Oct 30 16:18:31 2017 +0100
----------------------------------------------------------------------
src/slave/slave.cpp | 9 +++++++++
src/slave/slave.hpp | 2 ++
2 files changed, 11 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mesos/blob/6c2c7d0a/src/slave/slave.cpp
----------------------------------------------------------------------
diff --git a/src/slave/slave.cpp b/src/slave/slave.cpp
index 8e4785f..817dca4 100644
--- a/src/slave/slave.cpp
+++ b/src/slave/slave.cpp
@@ -668,6 +668,9 @@ void Slave::initialize()
&Slave::checkpointResources,
&CheckpointResourcesMessage::resources);
+ install<ApplyOfferOperationMessage>(
+ &Slave::applyOfferOperation);
+
install<StatusUpdateAcknowledgementMessage>(
&Slave::statusUpdateAcknowledgement,
&StatusUpdateAcknowledgementMessage::slave_id,
@@ -3625,6 +3628,12 @@ Try<Nothing> Slave::syncCheckpointedResources(
}
+void Slave::applyOfferOperation(const ApplyOfferOperationMessage& message)
+{
+ // TODO(nfnt): Provide implementation here.
+}
+
+
void Slave::statusUpdateAcknowledgement(
const UPID& from,
const SlaveID& slaveId,
http://git-wip-us.apache.org/repos/asf/mesos/blob/6c2c7d0a/src/slave/slave.hpp
----------------------------------------------------------------------
diff --git a/src/slave/slave.hpp b/src/slave/slave.hpp
index aea1e94..1b7f616 100644
--- a/src/slave/slave.hpp
+++ b/src/slave/slave.hpp
@@ -197,6 +197,8 @@ public:
void checkpointResources(std::vector<Resource> checkpointedResources);
+ void applyOfferOperation(const ApplyOfferOperationMessage& message);
+
void subscribe(
HttpConnection http,
const executor::Call::Subscribe& subscribe,