From: Sage Weil <sage@redhat.com>
Date: Fri, 14 Jul 2017 20:06:22 +0000 (-0400)
Subject: mon/MgrMonitor: debug mgrdigest subscriptions a bit
X-Git-Tag: v12.1.1~13^2~1
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=73a5e078cbe2e3fc07d0cc0c48bbf5008ab47d54;p=ceph.git

mon/MgrMonitor: debug mgrdigest subscriptions a bit

Signed-off-by: Sage Weil <sage@redhat.com>
---

diff --git a/src/mon/MgrMonitor.cc b/src/mon/MgrMonitor.cc
index 52e1b0b29f2e..f06c256b2c6a 100644
--- a/src/mon/MgrMonitor.cc
+++ b/src/mon/MgrMonitor.cc
@@ -326,7 +326,8 @@ void MgrMonitor::check_sub(Subscription *sub)
 {
   if (sub->type == "mgrmap") {
     if (sub->next <= map.get_epoch()) {
-      dout(20) << "Sending map to subscriber " << sub->session->con << dendl;
+      dout(20) << "Sending map to subscriber " << sub->session->con
+	       << " " << sub->session->con->get_peer_addr() << dendl;
       sub->session->con->send_message(new MMgrMap(map));
       if (sub->onetime) {
         mon->session_map.remove_sub(sub);
@@ -353,12 +354,15 @@ void MgrMonitor::send_digests()
   if (!is_active()) {
     return;
   }
+  dout(10) << __func__ << dendl;
 
   const std::string type = "mgrdigest";
   if (mon->session_map.subs.count(type) == 0)
     return;
 
   for (auto sub : *(mon->session_map.subs[type])) {
+    dout(10) << __func__ << " sending digest to subscriber " << sub->session->con
+	     << " " << sub->session->con->get_peer_addr() << dendl;
     MMgrDigest *mdigest = new MMgrDigest;
 
     JSONFormatter f;