summaryrefslogtreecommitdiffstats
path: root/searchcore/src/tests/proton/documentdb/maintenancecontroller
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2020-04-08 22:35:52 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2020-04-08 22:35:52 +0000
commitb971dbe48ad2111f24e7b953eaf351e9a0bb4ea1 (patch)
treed300b3d83395c6e89d395f00a7d34a772b616aee /searchcore/src/tests/proton/documentdb/maintenancecontroller
parent78298d9906f214fc9e096df782bfb7ee5fa1e76d (diff)
Make RemoveOperation an interface and move implmentation to RemoveOperationWithDocId
Diffstat (limited to 'searchcore/src/tests/proton/documentdb/maintenancecontroller')
-rw-r--r--searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp b/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp
index d4aebd0b8a7..7e2e258476f 100644
--- a/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp
+++ b/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp
@@ -110,7 +110,7 @@ public:
MaintenanceDocumentSubDB getSubDB();
void handlePruneRemovedDocuments(const PruneRemovedDocumentsOperation &op);
void handlePut(PutOperation &op);
- void handleRemove(RemoveOperation &op);
+ void handleRemove(RemoveOperationWithDocId &op);
void prepareMove(MoveOperation &op);
void handleMove(const MoveOperation &op);
uint32_t getNumUsedLids() const;
@@ -565,11 +565,11 @@ MyDocumentSubDB::handlePut(PutOperation &op)
void
-MyDocumentSubDB::handleRemove(RemoveOperation &op)
+MyDocumentSubDB::handleRemove(RemoveOperationWithDocId &op)
{
const SerialNum serialNum = op.getSerialNum();
const DocumentId &docId = op.getDocumentId();
- const document::GlobalId &gid = docId.getGlobalId();
+ const document::GlobalId &gid = op.getGlobalId();
bool needCommit = false;
if (op.getValidDbdId(_subDBId)) {
@@ -584,7 +584,7 @@ MyDocumentSubDB::handleRemove(RemoveOperation &op)
assert(op.getLid() == putRes._lid);
const document::DocumentType *docType =
_repo->getDocumentType(_docTypeName.getName());
- Document::UP doc(new Document(*docType, docId));
+ auto doc = std::make_unique<Document>(*docType, docId);
doc->setRepo(*_repo);
_docs[op.getLid()] = std::move(doc);
needCommit = true;
@@ -948,7 +948,7 @@ MaintenanceControllerFixture::removeDocs(const test::UserDocuments &docs,
const test::BucketDocuments &bucketDocs = itr->second;
for (size_t i = 0; i < bucketDocs.getDocs().size(); ++i) {
const test::Document &testDoc = bucketDocs.getDocs()[i];
- RemoveOperation op(testDoc.getBucket(), timestamp, testDoc.getDoc()->getId());
+ RemoveOperationWithDocId op(testDoc.getBucket(), timestamp, testDoc.getDoc()->getId());
op.setDbDocumentId(DbDocumentId(_removed.getSubDBId(), testDoc.getLid()));
_fh.storeOperation(op, std::make_shared<search::IgnoreCallback>());
_removed.handleRemove(op);