summaryrefslogtreecommitdiff
path: root/src/mongo/db/op_observer_registry.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/op_observer_registry.h')
-rw-r--r--src/mongo/db/op_observer_registry.h10
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;