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 2016/12/02 21:29:16 UTC
[09/10] mesos git commit: Avoided sending `LostSlaveMessage` to
disconnected frameworks.
Avoided sending `LostSlaveMessage` to disconnected frameworks.
Since we don't attempt to send messages to disconnected frameworks, this
would only have resulted in a warning message in the master logs anyway.
Review: https://reviews.apache.org/r/53893/
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/d73cc381
Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/d73cc381
Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/d73cc381
Branch: refs/heads/master
Commit: d73cc381b60c13d2055e57a8a58e639d8ec4385c
Parents: 9b6ebc3
Author: Neil Conway <ne...@gmail.com>
Authored: Fri Dec 2 13:28:42 2016 -0800
Committer: Vinod Kone <vi...@gmail.com>
Committed: Fri Dec 2 13:28:42 2016 -0800
----------------------------------------------------------------------
src/master/master.cpp | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mesos/blob/d73cc381/src/master/master.cpp
----------------------------------------------------------------------
diff --git a/src/master/master.cpp b/src/master/master.cpp
index 999c2c4..203567c 100644
--- a/src/master/master.cpp
+++ b/src/master/master.cpp
@@ -1953,6 +1953,10 @@ void Master::_markUnreachableAfterFailover(
void Master::sendSlaveLost(const SlaveInfo& slaveInfo)
{
foreachvalue (Framework* framework, frameworks.registered) {
+ if (!framework->connected) {
+ continue;
+ }
+
LOG(INFO) << "Notifying framework " << *framework << " of lost agent "
<< slaveInfo.id() << " (" << slaveInfo.hostname() << ")";