]> git-server-git.apps.pok.os.sepia.ceph.com Git - ceph.git/commitdiff
mds: note when dispatcher is called
authorPatrick Donnelly <pdonnell@redhat.com>
Tue, 14 May 2024 19:28:43 +0000 (15:28 -0400)
committerPatrick Donnelly <pdonnell@redhat.com>
Thu, 23 May 2024 19:38:36 +0000 (15:38 -0400)
For order checking.

Signed-off-by: Patrick Donnelly <pdonnell@redhat.com>
(cherry picked from commit 1b93fd5f8d52caa056b55f9c330296909f39486c)

src/mds/Beacon.cc
src/mds/MDSDaemon.cc
src/mds/MetricAggregator.cc
src/mon/MonClient.cc

index f4d762d4f8dfba4422dfca2bfa3620b505c9b9f1..798b6e8f42222f6c237bdf2296b6e52d16f5f90c 100644 (file)
@@ -115,6 +115,7 @@ void Beacon::ms_fast_dispatch2(const ref_t<Message>& m)
 
 bool Beacon::ms_dispatch2(const ref_t<Message>& m)
 {
+  dout(25) << __func__ << ": processing " << m << dendl;
   if (m->get_type() == MSG_MDS_BEACON) {
     if (m->get_connection()->get_peer_type() == CEPH_ENTITY_TYPE_MON) {
       handle_mds_beacon(ref_cast<MMDSBeacon>(m));
index 1ea641cf3ba7852ce8586823364a8dcf6c359198..cf9a572d4c025f50a77c192eff100fa053636fde 100644 (file)
@@ -976,6 +976,7 @@ void MDSDaemon::respawn()
 
 bool MDSDaemon::ms_dispatch2(const ref_t<Message> &m)
 {
+  dout(25) << __func__ << ": processing " << m << dendl;
   std::lock_guard l(mds_lock);
   if (stopping) {
     return false;
index 9765d4d5b5175bd444d6239bbf80ed66f6293d9a..0ae8d2d1b95babf1b01f2ec628114200dc24ee3c 100644 (file)
@@ -136,6 +136,7 @@ void MetricAggregator::ms_fast_dispatch2(const ref_t<Message> &m) {
 }
 
 bool MetricAggregator::ms_dispatch2(const ref_t<Message> &m) {
+  dout(25) << " processing " << m << dendl;
   if (m->get_type() == MSG_MDS_METRICS &&
       m->get_connection()->get_peer_type() == CEPH_ENTITY_TYPE_MDS) {
     const Message *msg = m.get();
index 909d964c6658ac0f79d23d64d9a95f194a8ee106..4c74b107e750ea0e76a5a5df3e1b5284d9bd025a 100644 (file)
@@ -295,6 +295,7 @@ int MonClient::ping_monitor(const string &mon_id, string *result_reply)
 
 bool MonClient::ms_dispatch(Message *m)
 {
+  ldout(cct, 25) << __func__ << " processing " << m << dendl;
   // we only care about these message types
   switch (m->get_type()) {
   case CEPH_MSG_MON_MAP: