aboutsummaryrefslogtreecommitdiffstats
path: root/searchcore/src/tests/proton/document_iterator
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2020-08-22 16:35:07 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2020-08-22 16:35:07 +0000
commitae0edb00cf0f11f5d2b07cf29a90c2f1f7d136f4 (patch)
tree415bfd665a8e628a29e2de31f5a50fe7da3239cd /searchcore/src/tests/proton/document_iterator
parent81e7965cf9d52869a6d524cc6ebf4ae3f7687906 (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.cpp9
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);