]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
mon/MgrMonitor: debug mgrdigest subscriptions a bit
authorSage Weil <sage@redhat.com>
Fri, 14 Jul 2017 20:06:22 +0000 (16:06 -0400)
committerSage Weil <sage@redhat.com>
Fri, 14 Jul 2017 20:06:22 +0000 (16:06 -0400)
Signed-off-by: Sage Weil <sage@redhat.com>
src/mon/MgrMonitor.cc

index 52e1b0b29f2e67fc757ee7ff424bc4ddc4a9a86a..f06c256b2c6a1706fc86b45d85f571fb7106084b 100644 (file)
@@ -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;