summaryrefslogtreecommitdiffstats
path: root/storage/src/tests/persistence/persistencetestutils.cpp
diff options
context:
space:
mode:
authorTor Egge <Tor.Egge@oath.com>2017-10-25 18:48:28 +0000
committerTor Egge <Tor.Egge@oath.com>2017-10-26 08:55:20 +0000
commit235b2756cc0af34dc968ff4cb4b5fc4455240547 (patch)
tree23b80b9518282b981bd5a6100d5eabeb2fcc10be /storage/src/tests/persistence/persistencetestutils.cpp
parent106567609a5b0efc3285187582acf45a0899b5ef (diff)
Make document::BucketSpace a mandatory argument to
PersistenceUtil::getBucketDatabase().
Diffstat (limited to 'storage/src/tests/persistence/persistencetestutils.cpp')
-rw-r--r--storage/src/tests/persistence/persistencetestutils.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/storage/src/tests/persistence/persistencetestutils.cpp b/storage/src/tests/persistence/persistencetestutils.cpp
index fb6bc298b08..fcfbcd0a78b 100644
--- a/storage/src/tests/persistence/persistencetestutils.cpp
+++ b/storage/src/tests/persistence/persistencetestutils.cpp
@@ -271,17 +271,17 @@ PersistenceTestUtils::createHeaderUpdate(
}
uint16_t
-PersistenceTestUtils::getDiskFromBucketDatabaseIfUnset(const document::BucketId& bucket,
+PersistenceTestUtils::getDiskFromBucketDatabaseIfUnset(const document::Bucket& bucket,
uint16_t disk)
{
if (disk == 0xffff) {
StorBucketDatabase::WrappedEntry entry(
- getEnv().getBucketDatabase().get(bucket, "createTestBucket"));
+ getEnv().getBucketDatabase(bucket.getBucketSpace()).get(bucket.getBucketId(), "createTestBucket"));
if (entry.exist()) {
return entry->disk;
} else {
std::ostringstream error;
- error << bucket << " not in db and disk unset";
+ error << bucket.toString() << " not in db and disk unset";
throw vespalib::IllegalStateException(error.str(), VESPA_STRLOC);
}
}
@@ -297,7 +297,7 @@ PersistenceTestUtils::doPut(const document::Document::SP& doc,
document::BucketId bucket(
_env->_component.getBucketIdFactory().getBucketId(doc->getId()));
bucket.setUsedBits(usedBits);
- disk = getDiskFromBucketDatabaseIfUnset(bucket, disk);
+ disk = getDiskFromBucketDatabaseIfUnset(makeDocumentBucket(bucket), disk);
doPut(doc, bucket, time, disk);
}
@@ -335,7 +335,7 @@ PersistenceTestUtils::doRemove(const document::DocumentId& id, spi::Timestamp ti
document::BucketId bucket(
_env->_component.getBucketIdFactory().getBucketId(id));
bucket.setUsedBits(usedBits);
- disk = getDiskFromBucketDatabaseIfUnset(bucket, disk);
+ disk = getDiskFromBucketDatabaseIfUnset(makeDocumentBucket(bucket), disk);
spi::Context context(defaultLoadType, spi::Priority(0),
spi::Trace::TraceLevel(0));
if (unrevertableRemove) {