From: Venky Shankar <vshankar@redhat.com>
Date: Fri, 29 Aug 2025 17:59:05 +0000 (+0000)
Subject: mds, messages: include subvolume metric count in log dumps and message exchanges
X-Git-Url: http://git-server-git.apps.pok.os.sepia.ceph.com/?a=commitdiff_plain;h=bbc141e8dcb209450e63581e815339aba1f71929;p=ceph.git

mds, messages: include subvolume metric count in log dumps and message exchanges

Signed-off-by: Venky Shankar <vshankar@redhat.com>
---

diff --git a/src/mds/MetricAggregator.cc b/src/mds/MetricAggregator.cc
index 5cd7919434a0..aa1ae380357a 100644
--- a/src/mds/MetricAggregator.cc
+++ b/src/mds/MetricAggregator.cc
@@ -697,8 +697,10 @@ void MetricAggregator::handle_mds_metrics(const cref_t<MMDSMetrics> &m) {
   auto seq = metrics_message.seq;
   auto rank = metrics_message.rank;
   auto &client_metrics_map = metrics_message.client_metrics_map;
+  auto &subvolume_metrics = metrics_message.subvolume_metrics;
 
-  dout(20) << ": applying " << client_metrics_map.size() << " updates for rank="
+  dout(20) << ": applying " << client_metrics_map.size() << "+"
+	   << subvolume_metrics.size() << " updates for rank="
            << rank << " with sequence number " << seq << dendl;
 
   std::scoped_lock locker(lock);
@@ -723,7 +725,7 @@ void MetricAggregator::handle_mds_metrics(const cref_t<MMDSMetrics> &m) {
     }
   }
 
-  refresh_subvolume_metrics_for_rank(rank, metrics_message.subvolume_metrics);
+  refresh_subvolume_metrics_for_rank(rank, subvolume_metrics);
 }
 
 void MetricAggregator::cull_metrics_for_rank(mds_rank_t rank) {
diff --git a/src/messages/MMDSMetrics.h b/src/messages/MMDSMetrics.h
index 4a8e036eb0a7..724ac90b0025 100644
--- a/src/messages/MMDSMetrics.h
+++ b/src/messages/MMDSMetrics.h
@@ -31,7 +31,8 @@ public:
 
   void print(std::ostream &out) const override {
     out << "mds_metrics from rank=" << metrics_message.rank << " carrying "
-        << metrics_message.client_metrics_map.size() << " metric updates";
+        << metrics_message.client_metrics_map.size() << "+"
+	<< metrics_message.subvolume_metrics.size() << " metric updates";
   }
 
   void encode_payload(uint64_t features) override {