diff options
| author | William Schultz <william.schultz@mongodb.com> | 2018-02-21 11:49:25 -0500 |
|---|---|---|
| committer | William Schultz <william.schultz@mongodb.com> | 2018-02-21 11:53:14 -0500 |
| commit | 788369eb773eede21ee0f492363bb7e64054ffd3 (patch) | |
| tree | 85e2c2420d5f041ced1a55c68bcd2ae64269a6d0 /src/mongo/db/op_observer_registry.h | |
| parent | 298dae8fed97e950b2633c32829ccd85bad204f1 (diff) | |
| download | mongo-788369eb773eede21ee0f492363bb7e64054ffd3.tar.gz | |
SERVER-29933 Add onReplicationRollback OpObserver method
Diffstat (limited to 'src/mongo/db/op_observer_registry.h')
| -rw-r--r-- | src/mongo/db/op_observer_registry.h | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/src/mongo/db/op_observer_registry.h b/src/mongo/db/op_observer_registry.h index e08477610a3..30a1dcd5de5 100644 --- a/src/mongo/db/op_observer_registry.h +++ b/src/mongo/db/op_observer_registry.h @@ -183,6 +183,12 @@ public: o->onTransactionAbort(opCtx); } + void onReplicationRollback(OperationContext* opCtx, + const RollbackObserverInfo& rbInfo) override { + for (auto& o : _observers) + o->onReplicationRollback(opCtx, rbInfo); + } + private: repl::OpTime _forEachObserver(stdx::function<repl::OpTime(OpObserver&)> f) { repl::OpTime opTime; |