diff options
author | Tor Egge <Tor.Egge@online.no> | 2021-06-14 14:26:38 +0200 |
---|---|---|
committer | Tor Egge <Tor.Egge@online.no> | 2021-06-14 14:27:03 +0200 |
commit | 86be1befadd23afb27b76d2f4f7b4d4d0fb2b1fe (patch) | |
tree | d02de205c7e8149b1d45d4409baf1f85afb5694e | |
parent | 8baa49d8dd42e882f489429c7dcf93e0e2371e2d (diff) |
Aggregate distributor metrics when adding to snapshot.
-rw-r--r-- | storage/src/vespa/storage/distributor/distributor_total_metrics.cpp | 11 | ||||
-rw-r--r-- | storage/src/vespa/storage/distributor/distributor_total_metrics.h | 1 |
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; } |