File tree Expand file tree Collapse file tree 2 files changed +6
-3
lines changed
Expand file tree Collapse file tree 2 files changed +6
-3
lines changed Original file line number Diff line number Diff line change @@ -697,8 +697,10 @@ void MetricAggregator::handle_mds_metrics(const cref_t<MMDSMetrics> &m) {
697697 auto seq = metrics_message.seq ;
698698 auto rank = metrics_message.rank ;
699699 auto &client_metrics_map = metrics_message.client_metrics_map ;
700+ auto &subvolume_metrics = metrics_message.subvolume_metrics ;
700701
701- dout (20 ) << " : applying " << client_metrics_map.size () << " updates for rank="
702+ dout (20 ) << " : applying " << client_metrics_map.size () << " +"
703+ << subvolume_metrics.size () << " updates for rank="
702704 << rank << " with sequence number " << seq << dendl;
703705
704706 std::scoped_lock locker (lock);
@@ -723,7 +725,7 @@ void MetricAggregator::handle_mds_metrics(const cref_t<MMDSMetrics> &m) {
723725 }
724726 }
725727
726- refresh_subvolume_metrics_for_rank (rank, metrics_message. subvolume_metrics );
728+ refresh_subvolume_metrics_for_rank (rank, subvolume_metrics);
727729}
728730
729731void MetricAggregator::cull_metrics_for_rank (mds_rank_t rank) {
Original file line number Diff line number Diff line change @@ -31,7 +31,8 @@ class MMDSMetrics final : public MMDSOp {
3131
3232 void print (std::ostream &out) const override {
3333 out << " mds_metrics from rank=" << metrics_message.rank << " carrying "
34- << metrics_message.client_metrics_map .size () << " metric updates" ;
34+ << metrics_message.client_metrics_map .size () << " +"
35+ << metrics_message.subvolume_metrics .size () << " metric updates" ;
3536 }
3637
3738 void encode_payload (uint64_t features) override {
You can’t perform that action at this time.
0 commit comments