summaryrefslogtreecommitdiffstats
path: root/searchcore/src/tests/proton/documentdb/combiningfeedview
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-11-30 11:22:25 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2021-11-30 11:50:05 +0000
commit2b3b0052992c9f8548ddd27fa0658da165b23b9f (patch)
tree491af6cc10204b3dbe46b6666dc22e050c868e4c /searchcore/src/tests/proton/documentdb/combiningfeedview
parent60fe9565af131821bc100af2e5c4d5852bc0f04a (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.cpp19
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);