]> 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>
Wed, 15 May 2024 20:12:15 +0000 (16:12 -0400)
For order checking.

Signed-off-by: Patrick Donnelly <pdonnell@redhat.com>
src/mds/Beacon.cc
src/mds/MDSDaemon.cc
src/mds/MetricAggregator.cc
src/mon/MonClient.cc

index 10f2b79e66419f8e3b1be3a720aa93d6b87403bf..0fd5f7f1760fcf66f85f7cb28f787504381d5b92 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 f2e520792b5a1e04a2574d16e5b71e7c907dd68a..cd9392c98a214b21313af8774235704f7e290143 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: