diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-08-22 16:35:07 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2020-08-22 16:35:07 +0000 |
commit | ae0edb00cf0f11f5d2b07cf29a90c2f1f7d136f4 (patch) | |
tree | 415bfd665a8e628a29e2de31f5a50fe7da3239cd /searchcore/src/tests/proton/document_iterator | |
parent | 81e7965cf9d52869a6d524cc6ebf4ae3f7687906 (diff) |
Wire in interfaces for lid based wait.
Diffstat (limited to 'searchcore/src/tests/proton/document_iterator')
-rw-r--r-- | searchcore/src/tests/proton/document_iterator/document_iterator_test.cpp | 9 |
1 files changed, 8 insertions, 1 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 44ce55edfbd..d8da0b5eb4c 100644 --- a/searchcore/src/tests/proton/document_iterator/document_iterator_test.cpp +++ b/searchcore/src/tests/proton/document_iterator/document_iterator_test.cpp @@ -280,6 +280,12 @@ struct Committer : public ICommitable { Committer() : _commitCount(0), _commitAndWaitCount(0) { } void commit() override { _commitCount++; } void commitAndWait() override { _commitAndWaitCount++; } + void commitAndWait(PendingLidTracker & , uint32_t ) override { + commitAndWait(); + } + void commitAndWait(PendingLidTracker & , const std::vector<uint32_t> & ) override { + commitAndWait(); + } }; size_t getSize() { @@ -497,8 +503,9 @@ TEST("require that iterator ignoring maxbytes stops at the end, and does not aut } void verifyReadConsistency(DocumentIterator & itr, Committer & committer) { + PendingLidTracker lidTracker; IDocumentRetriever::SP retriever = doc("id:ns:document::1", Timestamp(2), bucket(5)); - auto commitAndWaitRetriever = std::make_shared<CommitAndWaitDocumentRetriever>(retriever, committer); + auto commitAndWaitRetriever = std::make_shared<CommitAndWaitDocumentRetriever>(retriever, committer, lidTracker); itr.add(commitAndWaitRetriever); IterateResult res = itr.iterate(largeNum); |