You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mesos.apache.org by al...@apache.org on 2017/07/04 13:07:26 UTC
mesos git commit: Cleaned up logging around subscribers in master.
Repository: mesos
Updated Branches:
refs/heads/master ced7d6976 -> 21de4b671
Cleaned up logging around subscribers in master.
Project: http://git-wip-us.apache.org/repos/asf/mesos/repo
Commit: http://git-wip-us.apache.org/repos/asf/mesos/commit/21de4b67
Tree: http://git-wip-us.apache.org/repos/asf/mesos/tree/21de4b67
Diff: http://git-wip-us.apache.org/repos/asf/mesos/diff/21de4b67
Branch: refs/heads/master
Commit: 21de4b671709e6379a9f47d5ed4007e7f2b1b6bf
Parents: ced7d69
Author: Alexander Rukletsov <al...@apache.org>
Authored: Tue Jul 4 15:07:03 2017 +0200
Committer: Alexander Rukletsov <al...@apache.org>
Committed: Tue Jul 4 15:07:03 2017 +0200
----------------------------------------------------------------------
src/master/master.cpp | 14 +++++++-------
1 file changed, 7 insertions(+), 7 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/mesos/blob/21de4b67/src/master/master.cpp
----------------------------------------------------------------------
diff --git a/src/master/master.cpp b/src/master/master.cpp
index 95e9691..9d5566b 100644
--- a/src/master/master.cpp
+++ b/src/master/master.cpp
@@ -9380,8 +9380,8 @@ static bool isValidFailoverTimeout(const FrameworkInfo& frameworkInfo)
void Master::Subscribers::send(const mesos::master::Event& event)
{
- VLOG(1) << "Notifying all active subscribers about " << event.type() << " "
- << "event";
+ VLOG(1) << "Notifying all active subscribers about " << event.type()
+ << " event";
foreachvalue (const Owned<Subscriber>& subscriber, subscribed) {
subscriber->http.send<mesos::master::Event, v1::master::Event>(event);
@@ -9392,12 +9392,12 @@ void Master::Subscribers::send(const mesos::master::Event& event)
void Master::exited(const UUID& id)
{
if (!subscribers.subscribed.contains(id)) {
- LOG(WARNING) << "Unknown subscriber" << id << " disconnected";
+ LOG(WARNING) << "Unknown subscriber " << id << " disconnected";
return;
}
- LOG(INFO) << "Removed subscriber: " << id << " from the "
- << "list of active subscribers";
+ LOG(INFO) << "Removed subscriber " << id
+ << " from the list of active subscribers";
subscribers.subscribed.erase(id);
}
@@ -9405,8 +9405,8 @@ void Master::exited(const UUID& id)
void Master::subscribe(const HttpConnection& http)
{
- LOG(INFO) << "Added subscriber: " << http.streamId << " to the "
- << "list of active subscribers";
+ LOG(INFO) << "Added subscriber " << http.streamId
+ << " to the list of active subscribers";
http.closed()
.onAny(defer(self(),