diff options
Diffstat (limited to 'searchcore/src/tests/proton/persistenceengine')
-rw-r--r-- | searchcore/src/tests/proton/persistenceengine/persistence_handler_map/persistence_handler_map_test.cpp | 1 | ||||
-rw-r--r-- | searchcore/src/tests/proton/persistenceengine/persistenceengine_test.cpp | 9 |
2 files changed, 10 insertions, 0 deletions
diff --git a/searchcore/src/tests/proton/persistenceengine/persistence_handler_map/persistence_handler_map_test.cpp b/searchcore/src/tests/proton/persistenceengine/persistence_handler_map/persistence_handler_map_test.cpp index 03fb8ff05a1..13e0c4380a7 100644 --- a/searchcore/src/tests/proton/persistenceengine/persistence_handler_map/persistence_handler_map_test.cpp +++ b/searchcore/src/tests/proton/persistenceengine/persistence_handler_map/persistence_handler_map_test.cpp @@ -18,6 +18,7 @@ struct DummyPersistenceHandler : public IPersistenceHandler { void handlePut(FeedToken, const storage::spi::Bucket &, storage::spi::Timestamp, DocumentSP) override {} void handleUpdate(FeedToken, const storage::spi::Bucket &, storage::spi::Timestamp, DocumentUpdateSP) override {} void handleRemove(FeedToken, const storage::spi::Bucket &, storage::spi::Timestamp, const document::DocumentId &) override {} + void handleRemoveByGid(FeedToken, const storage::spi::Bucket&, storage::spi::Timestamp, vespalib::stringref, const GlobalId&) override { } void handleListBuckets(IBucketIdListResultHandler &) override {} void handleSetClusterState(const storage::spi::ClusterState &, IGenericResultHandler &) override {} void handleSetActiveState(const storage::spi::Bucket &, storage::spi::BucketInfo::ActiveState, std::shared_ptr<IGenericResultHandler>) override {} diff --git a/searchcore/src/tests/proton/persistenceengine/persistenceengine_test.cpp b/searchcore/src/tests/proton/persistenceengine/persistenceengine_test.cpp index e2519933a53..787b0c365e4 100644 --- a/searchcore/src/tests/proton/persistenceengine/persistenceengine_test.cpp +++ b/searchcore/src/tests/proton/persistenceengine/persistenceengine_test.cpp @@ -27,6 +27,7 @@ using document::DocumentId; using document::DocumentType; using document::DocumentTypeRepo; using document::DocumentUpdate; +using document::GlobalId; using document::test::makeBucketSpace; using search::DocumentMetaData; using storage::spi::Bucket; @@ -218,6 +219,14 @@ struct MyHandler : public IPersistenceHandler, IBucketFreezer { handle(token, bucket, timestamp, id); } + void handleRemoveByGid(FeedToken token, const Bucket& bucket, + Timestamp timestamp, + vespalib::stringref, const GlobalId&) override { + bool wasFound = existingTimestamp > 0; + token->setResult(std::make_unique<RemoveResult>(wasFound), wasFound); + handle(token, bucket, timestamp, DocumentId()); + } + void handleListBuckets(IBucketIdListResultHandler &resultHandler) override { resultHandler.handle(BucketIdListResult(BucketId::List(bucketList.begin(), bucketList.end()))); } |