diff options
| author | Benety Goh <benety@mongodb.com> | 2018-05-17 10:50:43 -0400 |
|---|---|---|
| committer | Benety Goh <benety@mongodb.com> | 2018-05-17 10:50:43 -0400 |
| commit | bd105e30805b88477452127c726ae2156296efd1 (patch) | |
| tree | e38fa3349f4df9cbbfbee25ed03fa3881793a1aa /src/mongo/db/repl/oplog_applier.cpp | |
| parent | 664e1d9b01dccddeec072b7746d7d4c62931716d (diff) | |
| download | mongo-bd105e30805b88477452127c726ae2156296efd1.tar.gz | |
SERVER-32334 add OplogApplier::Observer implementation for debug logging during recovery oplog application
Diffstat (limited to 'src/mongo/db/repl/oplog_applier.cpp')
| -rw-r--r-- | src/mongo/db/repl/oplog_applier.cpp | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/mongo/db/repl/oplog_applier.cpp b/src/mongo/db/repl/oplog_applier.cpp index ea449a3f7ca..ace3eef5144 100644 --- a/src/mongo/db/repl/oplog_applier.cpp +++ b/src/mongo/db/repl/oplog_applier.cpp @@ -135,7 +135,10 @@ StatusWith<OplogApplier::Operations> OplogApplier::getNextApplierBatch( } StatusWith<OpTime> OplogApplier::multiApply(OperationContext* opCtx, Operations ops) { - return _syncTail->multiApply(opCtx, std::move(ops)); + _observer->onBatchBegin(ops); + auto lastApplied = _syncTail->multiApply(opCtx, std::move(ops)); + _observer->onBatchEnd(lastApplied, {}); + return lastApplied; } } // namespace repl |