diff options
author | Tor Egge <Tor.Egge@oath.com> | 2017-11-22 10:05:25 +0000 |
---|---|---|
committer | Tor Egge <Tor.Egge@oath.com> | 2017-11-22 10:05:25 +0000 |
commit | d96b67a27b0c2b45e99c8fab25fae983df8d843a (patch) | |
tree | e5f635bd9f73b42bee4bb11f976a357f15c454e1 /storage | |
parent | 14d093023d5a664ef399919b467014b85633b61c (diff) |
Use DistributorBucketSpace to get Distribution in Distributor.
Diffstat (limited to 'storage')
-rw-r--r-- | storage/src/vespa/storage/distributor/distributor.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/storage/src/vespa/storage/distributor/distributor.cpp b/storage/src/vespa/storage/distributor/distributor.cpp index 58e14d654d2..1edcbe75dd6 100644 --- a/storage/src/vespa/storage/distributor/distributor.cpp +++ b/storage/src/vespa/storage/distributor/distributor.cpp @@ -6,6 +6,7 @@ #include "idealstatemetricsset.h" #include "ownership_transfer_safe_time_point_calculator.h" #include "distributor_bucket_space_repo.h" +#include "distributor_bucket_space.h" #include <vespa/storage/bucketdb/mapbucketdatabase.h> #include <vespa/storage/distributor/maintenance/simplemaintenancescanner.h> #include <vespa/storage/distributor/maintenance/simplebucketprioritydatabase.h> @@ -672,9 +673,10 @@ Distributor::scanNextBucket() updateInternalMetricsForCompletedScan(); _scanner->reset(); } else { + const auto &distribution(_bucketSpaceRepo->get(scanResult.getBucketSpace()).getDistribution()); _bucketDBMetricUpdater.visit( scanResult.getEntry(), - _component.getDistribution()->getRedundancy()); + distribution.getRedundancy()); } return scanResult; } |