diff options
Diffstat (limited to 'src/mongo/db/op_observer_registry.h')
-rw-r--r-- | src/mongo/db/op_observer_registry.h | 10 |
1 files changed, 10 insertions, 0 deletions
diff --git a/src/mongo/db/op_observer_registry.h b/src/mongo/db/op_observer_registry.h index f9d5c9bb860..e08477610a3 100644 --- a/src/mongo/db/op_observer_registry.h +++ b/src/mongo/db/op_observer_registry.h @@ -173,6 +173,16 @@ public: o->onEmptyCapped(opCtx, collectionName, uuid); } + void onTransactionCommit(OperationContext* opCtx) override { + for (auto& o : _observers) + o->onTransactionCommit(opCtx); + } + + void onTransactionAbort(OperationContext* opCtx) override { + for (auto& o : _observers) + o->onTransactionAbort(opCtx); + } + private: repl::OpTime _forEachObserver(stdx::function<repl::OpTime(OpObserver&)> f) { repl::OpTime opTime; |