summaryrefslogtreecommitdiffstats
path: root/memfilepersistence
diff options
context:
space:
mode:
authorTor Egge <Tor.Egge@oath.com>2017-10-05 13:12:39 +0000
committerTor Egge <Tor.Egge@oath.com>2017-10-05 13:12:39 +0000
commite158b6e614b4b6a1d4d4a03eeb68e590ddd46ed6 (patch)
tree126a0754fd9425b2b180568517c4fb6587b7b464 /memfilepersistence
parentcf86d459aa9d3d136fd7b4d5de91429165b9a8c3 (diff)
Add BucketSpace parameter to listBuckets() and getModifiedBuckets() SPI
methods.
Diffstat (limited to 'memfilepersistence')
-rw-r--r--memfilepersistence/src/tests/spi/memfiletestutils.cpp3
-rw-r--r--memfilepersistence/src/vespa/memfilepersistence/spi/memfilepersistenceprovider.cpp4
-rw-r--r--memfilepersistence/src/vespa/memfilepersistence/spi/memfilepersistenceprovider.h4
3 files changed, 6 insertions, 5 deletions
diff --git a/memfilepersistence/src/tests/spi/memfiletestutils.cpp b/memfilepersistence/src/tests/spi/memfiletestutils.cpp
index f8e182c1bcb..71a3e6a0999 100644
--- a/memfilepersistence/src/tests/spi/memfiletestutils.cpp
+++ b/memfilepersistence/src/tests/spi/memfiletestutils.cpp
@@ -14,6 +14,7 @@
using document::DocumentType;
using storage::spi::test::makeBucket;
+using storage::spi::test::makeBucketSpace;
namespace storage {
namespace memfile {
@@ -114,7 +115,7 @@ std::string
MemFileTestUtils::getModifiedBuckets()
{
spi::BucketIdListResult result(
- getPersistenceProvider().getModifiedBuckets());
+ getPersistenceProvider().getModifiedBuckets(makeBucketSpace()));
const spi::BucketIdListResult::List& list(result.getList());
std::ostringstream ss;
for (size_t i = 0; i < list.size(); ++i) {
diff --git a/memfilepersistence/src/vespa/memfilepersistence/spi/memfilepersistenceprovider.cpp b/memfilepersistence/src/vespa/memfilepersistence/spi/memfilepersistenceprovider.cpp
index 09d1e46dc27..e75df3fc29f 100644
--- a/memfilepersistence/src/vespa/memfilepersistence/spi/memfilepersistenceprovider.cpp
+++ b/memfilepersistence/src/vespa/memfilepersistence/spi/memfilepersistenceprovider.cpp
@@ -411,7 +411,7 @@ MemFilePersistenceProvider::getPartitionStates() const
}
spi::BucketIdListResult
-MemFilePersistenceProvider::listBuckets(spi::PartitionId partition) const
+MemFilePersistenceProvider::listBuckets(BucketSpace, spi::PartitionId partition) const
{
spi::BucketIdListResult::List buckets;
_fileScanner->buildBucketList(buckets, partition, 0, 1);
@@ -419,7 +419,7 @@ MemFilePersistenceProvider::listBuckets(spi::PartitionId partition) const
}
spi::BucketIdListResult
-MemFilePersistenceProvider::getModifiedBuckets() const
+MemFilePersistenceProvider::getModifiedBuckets(BucketSpace) const
{
document::BucketId::List modified;
_env->swapModifiedBuckets(modified); // Atomic op
diff --git a/memfilepersistence/src/vespa/memfilepersistence/spi/memfilepersistenceprovider.h b/memfilepersistence/src/vespa/memfilepersistence/spi/memfilepersistenceprovider.h
index 28af44c504e..f706fabc20c 100644
--- a/memfilepersistence/src/vespa/memfilepersistence/spi/memfilepersistenceprovider.h
+++ b/memfilepersistence/src/vespa/memfilepersistence/spi/memfilepersistenceprovider.h
@@ -41,8 +41,8 @@ public:
~MemFilePersistenceProvider();
spi::PartitionStateListResult getPartitionStates() const override;
- spi::BucketIdListResult listBuckets(spi::PartitionId) const override;
- spi::BucketIdListResult getModifiedBuckets() const override;
+ spi::BucketIdListResult listBuckets(BucketSpace bucketSpace, spi::PartitionId) const override;
+ spi::BucketIdListResult getModifiedBuckets(BucketSpace bucketSpace) const override;
spi::BucketInfoResult getBucketInfo(const spi::Bucket&) const override;
spi::Result put(const spi::Bucket&, spi::Timestamp,
const spi::DocumentSP&, spi::Context&) override;