diff options
Diffstat (limited to 'src/mongo/db/op_observer_registry.h')
| -rw-r--r-- | src/mongo/db/op_observer_registry.h | 13 |
1 files changed, 8 insertions, 5 deletions
diff --git a/src/mongo/db/op_observer_registry.h b/src/mongo/db/op_observer_registry.h index 8da173e1c91..2470baa74cc 100644 --- a/src/mongo/db/op_observer_registry.h +++ b/src/mongo/db/op_observer_registry.h @@ -268,11 +268,12 @@ public: o->onEmptyCapped(opCtx, collectionName, uuid); } - void onUnpreparedTransactionCommit( - OperationContext* opCtx, const std::vector<repl::ReplOperation>& statements) override { + void onUnpreparedTransactionCommit(OperationContext* opCtx, + std::vector<repl::ReplOperation>* statements, + size_t numberOfPreImagesToWrite) override { ReservedTimes times{opCtx}; for (auto& o : _observers) - o->onUnpreparedTransactionCommit(opCtx, statements); + o->onUnpreparedTransactionCommit(opCtx, statements, numberOfPreImagesToWrite); } void onPreparedTransactionCommit( @@ -288,10 +289,12 @@ public: void onTransactionPrepare(OperationContext* opCtx, const std::vector<OplogSlot>& reservedSlots, - std::vector<repl::ReplOperation>& statements) override { + std::vector<repl::ReplOperation>* statements, + size_t numberOfPreImagesToWrite) override { ReservedTimes times{opCtx}; for (auto& observer : _observers) { - observer->onTransactionPrepare(opCtx, reservedSlots, statements); + observer->onTransactionPrepare( + opCtx, reservedSlots, statements, numberOfPreImagesToWrite); } } |