]> 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:39:02 +0000 (15:39 -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 b67e0a31b40735e84e73b1517603366139285cc6..484ef806b7ebf3183da1e08e7547b36b119264ba 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 e97fd2cf83f8f8b8e34eccba881c552e6a9262c6..c1acb1ae3621ab3787bb44210d6496b6ab3a6aae 100644 (file)
@@ -920,6 +920,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 ab3d116978fc19b2adcdc0711e02119b88e05e31..f0f567c287d23afb79e28840895aa8495ee5cfe9 100644 (file)
@@ -293,6 +293,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: