diff options
| author | Pavi Vetriselvan <pvselvan@umich.edu> | 2019-06-19 14:00:25 -0400 |
|---|---|---|
| committer | Pavi Vetriselvan <pvselvan@umich.edu> | 2019-06-19 14:03:34 -0400 |
| commit | d3c0e4ad46fcba5aac61ecec1409e9df6e11f66e (patch) | |
| tree | 21232be9fb836878507588e11a435d1f9193af7e /src/mongo/db/repl/oplog_applier.cpp | |
| parent | 5f21969e6ca6c7805df0165ff81677aed1199958 (diff) | |
| download | mongo-d3c0e4ad46fcba5aac61ecec1409e9df6e11f66e.tar.gz | |
SERVER-41163 apply operations separately during initial sync commit transaction oplog application
Diffstat (limited to 'src/mongo/db/repl/oplog_applier.cpp')
| -rw-r--r-- | src/mongo/db/repl/oplog_applier.cpp | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/mongo/db/repl/oplog_applier.cpp b/src/mongo/db/repl/oplog_applier.cpp index 61b5d790bf5..24a484f1362 100644 --- a/src/mongo/db/repl/oplog_applier.cpp +++ b/src/mongo/db/repl/oplog_applier.cpp @@ -289,9 +289,11 @@ StatusWith<OplogApplier::Operations> OplogApplier::getNextApplierBatch( return std::move(ops); } -StatusWith<OpTime> OplogApplier::multiApply(OperationContext* opCtx, Operations ops) { +StatusWith<OpTime> OplogApplier::multiApply(OperationContext* opCtx, + Operations ops, + boost::optional<repl::OplogApplication::Mode> mode) { _observer->onBatchBegin(ops); - auto lastApplied = _multiApply(opCtx, std::move(ops)); + auto lastApplied = _multiApply(opCtx, std::move(ops), mode); _observer->onBatchEnd(lastApplied, {}); return lastApplied; } |