summaryrefslogtreecommitdiffstats
path: root/memfilepersistence/src/tests/spi/memfileautorepairtest.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'memfilepersistence/src/tests/spi/memfileautorepairtest.cpp')
-rw-r--r--memfilepersistence/src/tests/spi/memfileautorepairtest.cpp9
1 files changed, 6 insertions, 3 deletions
diff --git a/memfilepersistence/src/tests/spi/memfileautorepairtest.cpp b/memfilepersistence/src/tests/spi/memfileautorepairtest.cpp
index 9984452caed..1bae9d929e3 100644
--- a/memfilepersistence/src/tests/spi/memfileautorepairtest.cpp
+++ b/memfilepersistence/src/tests/spi/memfileautorepairtest.cpp
@@ -4,6 +4,9 @@
#include <vespa/memfilepersistence/mapper/memfile_v1_serializer.h>
#include <vespa/memfilepersistence/mapper/memfile_v1_verifier.h>
#include <tests/spi/memfiletestutils.h>
+#include <vespa/persistence/spi/test.h>
+
+using storage::spi::test::makeBucket;
namespace storage {
namespace memfile {
@@ -223,7 +226,7 @@ MemFileAutoRepairTest::testRepairFailureInMaintainEvictsBucketFromCache()
prepareBucket(*this, *_file);
corruptBodyBlock();
spi::Result result(getPersistenceProvider().maintain(
- spi::Bucket(_bucket, spi::PartitionId(0)), spi::HIGH));
+ makeBucket(_bucket), spi::HIGH));
// File being successfully repaired does not constitute a failure of
// the maintain() call.
CPPUNIT_ASSERT_EQUAL(spi::Result::NONE, result.getErrorCode());
@@ -240,7 +243,7 @@ MemFileAutoRepairTest::testZeroLengthFileIsDeleted()
// No way to deal with zero-length files aside from deleting them.
spi::Result result(getPersistenceProvider().maintain(
- spi::Bucket(_bucket, spi::PartitionId(0)), spi::HIGH));
+ makeBucket(_bucket), spi::HIGH));
CPPUNIT_ASSERT_EQUAL(spi::Result::NONE, result.getErrorCode());
CPPUNIT_ASSERT(!env()._cache.contains(_bucket));
CPPUNIT_ASSERT(!vespalib::fileExists(_file->getPath()));
@@ -272,7 +275,7 @@ MemFileAutoRepairTest::assertDocumentIsSilentlyRemoved(
{
// Corrupted (truncated) slot should be transparently removed during
// loadFile and it should be as if it was never there!
- spi::Bucket spiBucket(bucket, spi::PartitionId(0));
+ spi::Bucket spiBucket(makeBucket(bucket));
spi::GetResult res(doGet(spiBucket, docId, document::AllFields()));
CPPUNIT_ASSERT_EQUAL(spi::Result::NONE, res.getErrorCode());
CPPUNIT_ASSERT(!res.hasDocument());