diff options
Diffstat (limited to 'searchcore/src/tests/proton/document_iterator/document_iterator_test.cpp')
-rw-r--r-- | searchcore/src/tests/proton/document_iterator/document_iterator_test.cpp | 56 |
1 files changed, 0 insertions, 56 deletions
diff --git a/searchcore/src/tests/proton/document_iterator/document_iterator_test.cpp b/searchcore/src/tests/proton/document_iterator/document_iterator_test.cpp index 7ee811e66bf..93ad4cc8324 100644 --- a/searchcore/src/tests/proton/document_iterator/document_iterator_test.cpp +++ b/searchcore/src/tests/proton/document_iterator/document_iterator_test.cpp @@ -488,62 +488,6 @@ TEST("require that iterator ignoring maxbytes stops at the end, and does not aut TEST_DO(verifyIterateIgnoringStopSignal(itr)); } -void verifyReadConsistency(DocumentIterator & itr, ILidCommitState & lidCommitState) { - IDocumentRetriever::SP retriever = doc("id:ns:document::1", Timestamp(2), bucket(5)); - auto commitAndWaitRetriever = std::make_shared<CommitAndWaitDocumentRetriever>(retriever, lidCommitState); - itr.add(commitAndWaitRetriever); - - IterateResult res = itr.iterate(largeNum); - EXPECT_TRUE(res.isCompleted()); - EXPECT_EQUAL(1u, res.getEntries().size()); - TEST_DO(checkEntry(res, 0, Document(*DataType::DOCUMENT, DocumentId("id:ns:document::1")), Timestamp(2))); -} - -class ILidCommitStateProxy : public ILidCommitState { -public: - explicit ILidCommitStateProxy(ILidCommitState & lidState) - : _waitCompleteCount(0), - _lidState(lidState) - {} -private: - State waitState(State state, uint32_t lid) const override { - assert(state == State::COMPLETED); - _lidState.waitComplete(lid); - _waitCompleteCount++; - return state; - } - - State waitState(State state, const LidList &lids) const override { - assert(state == State::COMPLETED); - _lidState.waitComplete(lids); - _waitCompleteCount++; - return state; - } - -public: - mutable size_t _waitCompleteCount; -private: - ILidCommitState & _lidState; -}; - -void verifyStrongReadConsistency(DocumentIterator & itr) { - PendingLidTracker lidTracker; - - ILidCommitStateProxy lidCommitState(lidTracker); - TEST_DO(verifyReadConsistency(itr, lidCommitState)); - EXPECT_EQUAL(1u, lidCommitState._waitCompleteCount); -} - -TEST("require that default readconsistency does commit") { - DocumentIterator itr(bucket(5), std::make_shared<document::AllFields>(), selectAll(), newestV(), -1, false); - TEST_DO(verifyStrongReadConsistency(itr)); -} - -TEST("require that readconsistency::strong does commit") { - DocumentIterator itr(bucket(5), std::make_shared<document::AllFields>(), selectAll(), newestV(), -1, false, storage::spi::ReadConsistency::STRONG); - TEST_DO(verifyStrongReadConsistency(itr)); -} - TEST("require that docid limit is honoured") { IDocumentRetriever::SP retriever = doc("id:ns:document::1", Timestamp(2), bucket(5)); auto & udr = dynamic_cast<UnitDR &>(*retriever); |