Aggregate distributor metrics when adding to snapshot.

2 files changed, 12 insertions, 0 deletions

diff --git a/storage/src/vespa/storage/distributor/distributor_total_metrics.cpp b/storage/src/vespa/storage/distributor/distributor_total_metrics.cpp
index 543712cc4d2..fff996958b3 100644
--- a/storage/src/vespa/storage/distributor/distributor_total_metrics.cpp
+++ b/storage/src/vespa/storage/distributor/distributor_total_metrics.cpp
@@ -28,6 +28,17 @@ DistributorTotalMetrics::aggregate()
 }
 
 void
+DistributorTotalMetrics::addToSnapshot(Metric& m, std::vector<Metric::UP> &ownerList) const
+{
+    DistributorMetricSet total;
+    _bucket_db_updater_metrics.addToPart(total);
+    for (auto &stripe_metrics : _stripes_metrics) {
+        stripe_metrics->addToPart(total);
+    }
+    total.addToSnapshot(m, ownerList);
+}
+
+void
 DistributorTotalMetrics::reset()
 {
     DistributorMetricSet::reset();
diff --git a/storage/src/vespa/storage/distributor/distributor_total_metrics.h b/storage/src/vespa/storage/distributor/distributor_total_metrics.h
index 14116af3d3b..7b4f705a6fe 100644
--- a/storage/src/vespa/storage/distributor/distributor_total_metrics.h
+++ b/storage/src/vespa/storage/distributor/distributor_total_metrics.h
@@ -19,6 +19,7 @@ public:
     explicit DistributorTotalMetrics(uint32_t num_distributor_stripes);
     ~DistributorTotalMetrics() override;
     void aggregate();
+    void addToSnapshot(Metric& m, std::vector<Metric::UP> &ownerList) const override;
     void reset() override;
     DistributorMetricSet& stripe(uint32_t stripe_index) { return *_stripes_metrics[stripe_index]; }
     DistributorMetricSet& bucket_db_updater_metrics() { return _bucket_db_updater_metrics; }