diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2021-11-30 11:22:25 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2021-11-30 11:50:05 +0000 |
commit | 2b3b0052992c9f8548ddd27fa0658da165b23b9f (patch) | |
tree | 491af6cc10204b3dbe46b6666dc22e050c868e4c /searchcore/src/tests/proton/documentdb/combiningfeedview | |
parent | 60fe9565af131821bc100af2e5c4d5852bc0f04a (diff) |
Add DoneCallback to removeDocuments.
Diffstat (limited to 'searchcore/src/tests/proton/documentdb/combiningfeedview')
-rw-r--r-- | searchcore/src/tests/proton/documentdb/combiningfeedview/combiningfeedview_test.cpp | 19 |
1 files changed, 5 insertions, 14 deletions
diff --git a/searchcore/src/tests/proton/documentdb/combiningfeedview/combiningfeedview_test.cpp b/searchcore/src/tests/proton/documentdb/combiningfeedview/combiningfeedview_test.cpp index dc51d0df8a1..a57787d417e 100644 --- a/searchcore/src/tests/proton/documentdb/combiningfeedview/combiningfeedview_test.cpp +++ b/searchcore/src/tests/proton/documentdb/combiningfeedview/combiningfeedview_test.cpp @@ -23,18 +23,10 @@ using namespace proton; typedef std::vector<IFeedView::SP> FeedViewVector; -struct MyStreamHandler : public NewConfigOperation::IStreamHandler -{ - void serializeConfig(SerialNum, vespalib::nbostream &) override {} - void deserializeConfig(SerialNum, vespalib::nbostream &) override {} -}; - - struct MyFeedView : public test::DummyFeedView { typedef std::shared_ptr<MyFeedView> SP; DocumentMetaStore _metaStore; - MyStreamHandler _streamHandler; uint32_t _preparePut; uint32_t _handlePut; uint32_t _prepareRemove; @@ -56,7 +48,6 @@ struct MyFeedView : public test::DummyFeedView DocumentMetaStore::getFixedName(), search::GrowStrategy(), subDbType), - _streamHandler(), _preparePut(0), _handlePut(0), _prepareRemove(0), @@ -82,11 +73,11 @@ struct MyFeedView : public test::DummyFeedView void prepareRemove(RemoveOperation &) override { ++_prepareRemove; } void handleRemove(FeedToken, const RemoveOperation &) override { ++_handleRemove; } void prepareDeleteBucket(DeleteBucketOperation &) override { ++_prepareDeleteBucket; } - void handleDeleteBucket(const DeleteBucketOperation &) override { ++_handleDeleteBucket; } + void handleDeleteBucket(const DeleteBucketOperation &, DoneCallback) override { ++_handleDeleteBucket; } void prepareMove(MoveOperation &) override { ++_prepareMove; } - void handleMove(const MoveOperation &, IDestructorCallback::SP) override { ++_handleMove; } + void handleMove(const MoveOperation &, DoneCallback) override { ++_handleMove; } void heartBeat(SerialNum, DoneCallback) override { ++_heartBeat; } - void handlePruneRemovedDocuments(const PruneRemovedDocumentsOperation &) override { ++_handlePrune; } + void handlePruneRemovedDocuments(const PruneRemovedDocumentsOperation &, DoneCallback) override { ++_handlePrune; } void handleCompactLidSpace(const CompactLidSpaceOperation &op, DoneCallback) override { _wantedLidLimit = op.getLidLimit(); } @@ -362,7 +353,7 @@ TEST_F("require that delete bucket is sent to all feed views", Fixture) EXPECT_EQUAL(1u, f._ready._view->_prepareDeleteBucket); EXPECT_EQUAL(1u, f._removed._view->_prepareDeleteBucket); EXPECT_EQUAL(1u, f._notReady._view->_prepareDeleteBucket); - f._view.handleDeleteBucket(op); + f._view.handleDeleteBucket(op, IDestructorCallback::SP()); EXPECT_EQUAL(1u, f._ready._view->_handleDeleteBucket); EXPECT_EQUAL(1u, f._removed._view->_handleDeleteBucket); EXPECT_EQUAL(1u, f._notReady._view->_handleDeleteBucket); @@ -381,7 +372,7 @@ TEST_F("require that heart beat is sent to all feed views", Fixture) TEST_F("require that prune removed documents is sent to removed view", Fixture) { PruneRemovedDocumentsOperation op; - f._view.handlePruneRemovedDocuments(op); + f._view.handlePruneRemovedDocuments(op, IDestructorCallback::SP()); EXPECT_EQUAL(0u, f._ready._view->_handlePrune); EXPECT_EQUAL(1u, f._removed._view->_handlePrune); EXPECT_EQUAL(0u, f._notReady._view->_handlePrune); |