From: Xiubo Li Date: Tue, 16 Jul 2024 05:54:17 +0000 (+0800) Subject: Merge pull request #57683 from batrick/wip-66194-reef X-Git-Tag: v18.2.5~533 X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=b3e662a36fb18bf3a73945dd1244023370bd9af1;p=ceph.git Merge pull request #57683 from batrick/wip-66194-reef reef: mds: use regular dispatch for processing beacons --- b3e662a36fb18bf3a73945dd1244023370bd9af1 diff --cc src/mds/MetricAggregator.cc index d8bfdc4e7d05,0ae8d2d1b95b..6cdc3ab193e9 --- a/src/mds/MetricAggregator.cc +++ b/src/mds/MetricAggregator.cc @@@ -126,7 -126,17 +126,8 @@@ void MetricAggregator::shutdown() } } -bool MetricAggregator::ms_can_fast_dispatch2(const cref_t &m) const { - return m->get_type() == MSG_MDS_METRICS; -} - -void MetricAggregator::ms_fast_dispatch2(const ref_t &m) { - bool handled = ms_dispatch2(m); - ceph_assert(handled); -} - bool MetricAggregator::ms_dispatch2(const ref_t &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();