aboutsummaryrefslogtreecommitdiffstats
path: root/searchcore/src/tests/proton/documentdb/documentbucketmover/bucketmover_common.h
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-03-05 19:14:25 +0100
committerGitHub <noreply@github.com>2021-03-05 19:14:25 +0100
commit71be2715b86b6181a5bf8a8a12c3ea2b78446479 (patch)
treee78d44b1548b599ce4120d9de5221ca3d155fb91 /searchcore/src/tests/proton/documentdb/documentbucketmover/bucketmover_common.h
parentba715525826666a104a6dd9914ae7582a784f4d7 (diff)
Revert "If a document was removed or moved between th emove started and the d…"
Diffstat (limited to 'searchcore/src/tests/proton/documentdb/documentbucketmover/bucketmover_common.h')
-rw-r--r--searchcore/src/tests/proton/documentdb/documentbucketmover/bucketmover_common.h15
1 files changed, 2 insertions, 13 deletions
diff --git a/searchcore/src/tests/proton/documentdb/documentbucketmover/bucketmover_common.h b/searchcore/src/tests/proton/documentdb/documentbucketmover/bucketmover_common.h
index f70a4bfad11..e955f017d67 100644
--- a/searchcore/src/tests/proton/documentdb/documentbucketmover/bucketmover_common.h
+++ b/searchcore/src/tests/proton/documentdb/documentbucketmover/bucketmover_common.h
@@ -64,13 +64,8 @@ struct MyDocumentRetriever : public DocumentRetrieverBaseForTest {
using DocumentVector = std::vector<Document::SP>;
std::shared_ptr<const DocumentTypeRepo> _repo;
DocumentVector _docs;
- uint32_t _lid2Fail;
- MyDocumentRetriever(std::shared_ptr<const DocumentTypeRepo> repo)
- : _repo(std::move(repo)),
- _docs(),
- _lid2Fail(0)
- {
+ MyDocumentRetriever(std::shared_ptr<const DocumentTypeRepo> repo) : _repo(std::move(repo)), _docs() {
_docs.push_back(Document::UP()); // lid 0 invalid
}
@@ -81,11 +76,9 @@ struct MyDocumentRetriever : public DocumentRetrieverBaseForTest {
DocumentMetaData getDocumentMetaData(const DocumentId &) const override { return DocumentMetaData(); }
Document::UP getFullDocument(DocumentIdT lid) const override {
- return (lid != _lid2Fail) ? Document::UP(_docs[lid]->clone()) : Document::UP();
+ return Document::UP(_docs[lid]->clone());
}
- void failRetrieveForLid(uint32_t lid) { _lid2Fail = lid; }
-
CachedSelect::SP parseSelect(const vespalib::string &) const override {
return {};
}
@@ -122,10 +115,6 @@ struct MySubDb {
void insertDocs(const UserDocuments &docs_);
- void failRetrieveForLid(uint32_t lid) {
- _realRetriever->failRetrieveForLid(lid);
- }
-
BucketId bucket(uint32_t userId) const {
return _docs.getBucket(userId);
}