summaryrefslogtreecommitdiffstats
path: root/storage
diff options
context:
space:
mode:
authorTor Egge <Tor.Egge@oath.com>2017-11-22 10:05:25 +0000
committerTor Egge <Tor.Egge@oath.com>2017-11-22 10:05:25 +0000
commitd96b67a27b0c2b45e99c8fab25fae983df8d843a (patch)
treee5f635bd9f73b42bee4bb11f976a357f15c454e1 /storage
parent14d093023d5a664ef399919b467014b85633b61c (diff)
Use DistributorBucketSpace to get Distribution in Distributor.
Diffstat (limited to 'storage')
-rw-r--r--storage/src/vespa/storage/distributor/distributor.cpp4
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;
}