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() << ")";