Clarified a log message. Review: https://reviews.apache.org/r/51020/
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/df037de6 Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/df037de6 Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/df037de6 Branch: refs/heads/master Commit: df037de65facd02ac179cecd7dc5c62243694fc5 Parents: 3cecdbd Author: Neil Conway <neil.con...@gmail.com> Authored: Mon Sep 19 15:47:41 2016 -0700 Committer: Vinod Kone <vinodk...@gmail.com> Committed: Mon Sep 19 15:47:41 2016 -0700 ---------------------------------------------------------------------- src/master/master.cpp | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/mesos/blob/df037de6/src/master/master.cpp ---------------------------------------------------------------------- diff --git a/src/master/master.cpp b/src/master/master.cpp index 34de462..008ff32 100644 --- a/src/master/master.cpp +++ b/src/master/master.cpp @@ -5835,8 +5835,8 @@ void Master::_markUnreachable( // Notify all frameworks of the lost slave. foreachvalue (Framework* framework, frameworks.registered) { LOG(INFO) << "Notifying framework " << *framework << " of lost agent " - << slaveInfo.id() << " (" << slaveInfo.hostname() << ") " - << "after recovering"; + << slaveInfo.id() << " (" << slaveInfo.hostname() << ")"; + LostSlaveMessage message; message.mutable_slave_id()->MergeFrom(slaveInfo.id()); framework->send(message); @@ -7295,8 +7295,8 @@ void Master::_removeSlave( // Notify all frameworks of the lost slave. foreachvalue (Framework* framework, frameworks.registered) { LOG(INFO) << "Notifying framework " << *framework << " of lost agent " - << slaveInfo.id() << " (" << slaveInfo.hostname() << ") " - << "after recovering"; + << slaveInfo.id() << " (" << slaveInfo.hostname() << ")"; + LostSlaveMessage message; message.mutable_slave_id()->MergeFrom(slaveInfo.id()); framework->send(message);
