summaryrefslogtreecommitdiffstats
path: root/storage
diff options
context:
space:
mode:
authorTor Egge <Tor.Egge@oath.com>2018-01-30 15:34:01 +0000
committerTor Egge <Tor.Egge@oath.com>2018-01-31 10:31:29 +0000
commit2a949b1cf65bb3f506cef14ec7682cb61ff56be1 (patch)
tree7ce84a1373e80e86587b2bda5ae2fab5f7222c2e /storage
parentc2793807b7ba3214100f27734140e3f4ad3a304c (diff)
Reduce use of document::BucketSpace::placeHolder().
Diffstat (limited to 'storage')
-rw-r--r--storage/src/tests/common/teststorageapp.h3
-rw-r--r--storage/src/vespa/storage/bucketmover/bucketmover.cpp7
-rw-r--r--storage/src/vespa/storage/bucketmover/move.cpp3
-rw-r--r--storage/src/vespa/storage/distributor/maintenance/maintenancescanner.h2
-rw-r--r--storage/src/vespa/storage/distributor/pendingclusterstate.cpp3
-rw-r--r--storage/src/vespa/storage/persistence/filestorage/modifiedbucketchecker.cpp2
6 files changed, 11 insertions, 9 deletions
diff --git a/storage/src/tests/common/teststorageapp.h b/storage/src/tests/common/teststorageapp.h
index 46744ecb3c6..64572b8ef8d 100644
--- a/storage/src/tests/common/teststorageapp.h
+++ b/storage/src/tests/common/teststorageapp.h
@@ -27,6 +27,7 @@
#include <vespa/storageframework/defaultimplementation/clock/realclock.h>
#include <vespa/storageframework/defaultimplementation/component/testcomponentregister.h>
#include <vespa/persistence/spi/persistenceprovider.h>
+#include <vespa/persistence/spi/fixed_bucket_spaces.h>
#include <vespa/document/base/testdocman.h>
namespace storage {
@@ -125,7 +126,7 @@ public:
uint16_t getPartition(const document::BucketId&);
StorBucketDatabase& getStorageBucketDatabase() override {
- return _compReg.getBucketSpaceRepo().get(document::BucketSpace::placeHolder()).bucketDatabase();
+ return _compReg.getBucketSpaceRepo().get(spi::FixedBucketSpaces::default_space()).bucketDatabase();
}
private:
diff --git a/storage/src/vespa/storage/bucketmover/bucketmover.cpp b/storage/src/vespa/storage/bucketmover/bucketmover.cpp
index bc9a8b0c428..94db4ee9f32 100644
--- a/storage/src/vespa/storage/bucketmover/bucketmover.cpp
+++ b/storage/src/vespa/storage/bucketmover/bucketmover.cpp
@@ -9,13 +9,12 @@
#include <vespa/storage/storageutil/log.h>
#include <vespa/config/common/exceptions.h>
#include <vespa/vespalib/util/stringfmt.h>
+#include <vespa/persistence/spi/fixed_bucket_spaces.h>
#include <thread>
#include <vespa/log/bufferedlogger.h>
LOG_SETUP(".bucketmover");
-using document::BucketSpace;
-
namespace storage::bucketmover {
BucketMover::BucketMover(const config::ConfigUri & configUri,
@@ -116,7 +115,7 @@ BucketMover::startNewRun()
// If so, we have to spawn off an individual Run per space, as it encompasses
// both a (disk) distribution and a bucket database.
_currentRun = std::make_unique<bucketmover::Run>(
- _component.getBucketSpaceRepo().get(document::BucketSpace::placeHolder()),
+ _component.getBucketSpaceRepo().get(spi::FixedBucketSpaces::default_space()),
*_component.getStateUpdater().getReportedNodeState(),
_component.getIndex(),
_component.getClock());
@@ -364,7 +363,7 @@ BucketMover::storageDistributionChanged()
}
lib::Distribution::DiskDistribution BucketMover::currentDiskDistribution() const {
- auto distribution = _component.getBucketSpaceRepo().get(document::BucketSpace::placeHolder()).getDistribution();
+ auto distribution = _component.getBucketSpaceRepo().get(spi::FixedBucketSpaces::default_space()).getDistribution();
return distribution->getDiskDistribution();
}
diff --git a/storage/src/vespa/storage/bucketmover/move.cpp b/storage/src/vespa/storage/bucketmover/move.cpp
index b91329fad36..28ab48223e8 100644
--- a/storage/src/vespa/storage/bucketmover/move.cpp
+++ b/storage/src/vespa/storage/bucketmover/move.cpp
@@ -1,6 +1,7 @@
// Copyright 2017 Yahoo Holdings. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
#include "move.h"
+#include <vespa/persistence/spi/fixed_bucket_spaces.h>
#include <ostream>
namespace storage {
@@ -9,7 +10,7 @@ namespace bucketmover {
Move::Move()
: _sourceDisk(0),
_targetDisk(0),
- _bucket(document::BucketSpace::placeHolder(), document::BucketId(0)),
+ _bucket(),
_totalDocSize(0),
_priority(255)
{
diff --git a/storage/src/vespa/storage/distributor/maintenance/maintenancescanner.h b/storage/src/vespa/storage/distributor/maintenance/maintenancescanner.h
index c1d76b57c7c..f329133f2c4 100644
--- a/storage/src/vespa/storage/distributor/maintenance/maintenancescanner.h
+++ b/storage/src/vespa/storage/distributor/maintenance/maintenancescanner.h
@@ -28,7 +28,7 @@ public:
}
private:
- ScanResult(bool done) : _done(done), _bucketSpace(document::BucketSpace::placeHolder()), _entry() {}
+ ScanResult(bool done) : _done(done), _bucketSpace(document::BucketSpace::invalid()), _entry() {}
ScanResult(document::BucketSpace bucketSpace, const BucketDatabase::Entry& e) : _done(false), _bucketSpace(bucketSpace), _entry(e) {}
};
diff --git a/storage/src/vespa/storage/distributor/pendingclusterstate.cpp b/storage/src/vespa/storage/distributor/pendingclusterstate.cpp
index 71684db5527..19257192022 100644
--- a/storage/src/vespa/storage/distributor/pendingclusterstate.cpp
+++ b/storage/src/vespa/storage/distributor/pendingclusterstate.cpp
@@ -7,6 +7,7 @@
#include "distributor_bucket_space.h"
#include <vespa/storageframework/defaultimplementation/clock/realclock.h>
#include <vespa/storage/common/bucketoperationlogger.h>
+#include <vespa/persistence/spi/fixed_bucket_spaces.h>
#include <vespa/vespalib/util/xmlstream.hpp>
#include <climits>
@@ -92,7 +93,7 @@ PendingClusterState::initializeBucketSpaceTransitions(bool distributionChanged,
void
PendingClusterState::logConstructionInformation() const
{
- const auto &distributorBucketSpace(_bucketSpaceRepo.get(BucketSpace::placeHolder()));
+ const auto &distributorBucketSpace(_bucketSpaceRepo.get(spi::FixedBucketSpaces::default_space()));
const auto &distribution(distributorBucketSpace.getDistribution());
LOG(debug,
"New PendingClusterState constructed with previous cluster "
diff --git a/storage/src/vespa/storage/persistence/filestorage/modifiedbucketchecker.cpp b/storage/src/vespa/storage/persistence/filestorage/modifiedbucketchecker.cpp
index 1834c93209d..3db3ec5dfcd 100644
--- a/storage/src/vespa/storage/persistence/filestorage/modifiedbucketchecker.cpp
+++ b/storage/src/vespa/storage/persistence/filestorage/modifiedbucketchecker.cpp
@@ -21,7 +21,7 @@ CyclicBucketSpaceIterator(const ContentBucketSpaceRepo::BucketSpaces &bucketSpac
}
ModifiedBucketChecker::BucketIdListResult::BucketIdListResult()
- : _bucketSpace(document::BucketSpace::placeHolder()),
+ : _bucketSpace(document::BucketSpace::invalid()),
_buckets()
{
}