summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/transaction_oplog_application.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/transaction_oplog_application.cpp')
-rw-r--r--src/mongo/db/repl/transaction_oplog_application.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/repl/transaction_oplog_application.cpp b/src/mongo/db/repl/transaction_oplog_application.cpp
index 4d887c90e27..71b344f7ac5 100644
--- a/src/mongo/db/repl/transaction_oplog_application.cpp
+++ b/src/mongo/db/repl/transaction_oplog_application.cpp
@@ -59,7 +59,7 @@ MONGO_FAIL_POINT_DEFINE(skipReconstructPreparedTransactions);
// Apply the oplog entries for a prepare or a prepared commit during recovery/initial sync.
Status _applyOperationsForTransaction(OperationContext* opCtx,
- const repl::MultiApplier::Operations& ops,
+ const std::vector<OplogEntry>& ops,
repl::OplogApplication::Mode oplogApplicationMode) {
// Apply each the operations via repl::applyOperation.
for (const auto& op : ops) {
@@ -228,14 +228,14 @@ Status applyAbortTransaction(OperationContext* opCtx,
MONGO_UNREACHABLE;
}
-repl::MultiApplier::Operations readTransactionOperationsFromOplogChain(
+std::vector<OplogEntry> readTransactionOperationsFromOplogChain(
OperationContext* opCtx,
const OplogEntry& lastEntryInTxn,
const std::vector<OplogEntry*>& cachedOps) noexcept {
// Traverse the oplog chain with its own snapshot and read timestamp.
ReadSourceScope readSourceScope(opCtx);
- repl::MultiApplier::Operations ops;
+ std::vector<OplogEntry> ops;
// The cachedOps are the ops for this transaction that are from the same oplog application batch
// as the commit or prepare, those which have not necessarily been written to the oplog. These