Skip to content

Commit

Permalink
Merge PR ceph#60653 into main
Browse files Browse the repository at this point in the history
* refs/pull/60653/head:
	mds: do not process client metrics message with fast dispatch

Reviewed-by: Patrick Donnelly <[email protected]>
Reviewed-by: Jos Collin <[email protected]>
Reviewed-by: Dhairya Parmar <[email protected]>
  • Loading branch information
vshankar committed Dec 26, 2024
2 parents 7870d7f + ba0d989 commit afcd6a7
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 14 deletions.
9 changes: 0 additions & 9 deletions src/mds/MetricsHandler.cc
Original file line number Diff line number Diff line change
Expand Up @@ -20,15 +20,6 @@ MetricsHandler::MetricsHandler(CephContext *cct, MDSRank *mds)
mds(mds) {
}

bool MetricsHandler::ms_can_fast_dispatch2(const cref_t<Message> &m) const {
return m->get_type() == CEPH_MSG_CLIENT_METRICS || m->get_type() == MSG_MDS_PING;
}

void MetricsHandler::ms_fast_dispatch2(const ref_t<Message> &m) {
bool handled = ms_dispatch2(m);
ceph_assert(handled);
}

bool MetricsHandler::ms_dispatch2(const ref_t<Message> &m) {
if (m->get_type() == CEPH_MSG_CLIENT_METRICS &&
m->get_connection()->get_peer_type() == CEPH_ENTITY_TYPE_CLIENT) {
Expand Down
5 changes: 0 additions & 5 deletions src/mds/MetricsHandler.h
Original file line number Diff line number Diff line change
Expand Up @@ -25,11 +25,6 @@ class MetricsHandler : public Dispatcher {
public:
MetricsHandler(CephContext *cct, MDSRank *mds);

bool ms_can_fast_dispatch_any() const override {
return true;
}
bool ms_can_fast_dispatch2(const cref_t<Message> &m) const override;
void ms_fast_dispatch2(const ref_t<Message> &m) override;
bool ms_dispatch2(const ref_t<Message> &m) override;

void ms_handle_connect(Connection *c) override {
Expand Down

0 comments on commit afcd6a7

Please sign in to comment.