summaryrefslogtreecommitdiffstats
path: root/searchcore/src/tests/proton/documentdb/maintenancecontroller
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2021-02-24 12:57:24 +0000
committerHenning Baldersheim <balder@yahoo-inc.com>2021-02-27 21:10:20 +0000
commitd503a0d5ba0bf0af18cc5211e2b6539cc3e922e6 (patch)
treee7dccdeb29ba0dda3baa00ca00e1a0c911aa06f6 /searchcore/src/tests/proton/documentdb/maintenancecontroller
parenta37e1b51351a92b084bbedf5c5225a6d01fc4a44 (diff)
Put all params for commit into a single CommitParam struct
Diffstat (limited to 'searchcore/src/tests/proton/documentdb/maintenancecontroller')
-rw-r--r--searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp b/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp
index 75f1ddd82a1..f76748dc028 100644
--- a/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp
+++ b/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp
@@ -63,6 +63,7 @@ using search::DocumentIdT;
using search::DocumentMetaData;
using vespalib::IDestructorCallback;
using search::SerialNum;
+using search::CommitParam;
using storage::spi::BucketInfo;
using storage::spi::Timestamp;
using vespalib::Slime;
@@ -73,7 +74,6 @@ using storage::spi::dummy::DummyBucketExecutor;
using BlockedReason = IBlockableMaintenanceJob::BlockedReason;
typedef BucketId::List BucketIdVector;
-typedef std::set<BucketId> BucketIdSet;
constexpr vespalib::duration TIMEOUT = 60s;
@@ -560,7 +560,7 @@ MyDocumentSubDB::handlePut(PutOperation &op)
needCommit = true;
}
if (needCommit) {
- _metaStore.commit(serialNum, serialNum);
+ _metaStore.commit(CommitParam(serialNum));
}
}
@@ -606,7 +606,7 @@ MyDocumentSubDB::handleRemove(RemoveOperationWithDocId &op)
needCommit = true;
}
if (needCommit) {
- _metaStore.commit(serialNum, serialNum);
+ _metaStore.commit(CommitParam(serialNum));
}
}
@@ -660,7 +660,7 @@ MyDocumentSubDB::handleMove(const MoveOperation &op)
needCommit = true;
}
if (needCommit) {
- _metaStore.commit(serialNum, serialNum);
+ _metaStore.commit(CommitParam(serialNum));
}
}