diff options
Diffstat (limited to 'src/mongo/db/op_observer_impl.h')
| -rw-r--r-- | src/mongo/db/op_observer_impl.h | 9 |
1 files changed, 9 insertions, 0 deletions
diff --git a/src/mongo/db/op_observer_impl.h b/src/mongo/db/op_observer_impl.h index 77676e9548e..55c32faf581 100644 --- a/src/mongo/db/op_observer_impl.h +++ b/src/mongo/db/op_observer_impl.h @@ -209,6 +209,11 @@ public: const ApplyOpsOplogSlotAndOperationAssignment* applyOpsOperationAssignment, size_t numberOfPrePostImagesToWrite, Date_t wallClockTime) final; + + void onTransactionPrepareNonPrimary(OperationContext* opCtx, + const std::vector<repl::OplogEntry>& statements, + const repl::OpTime& prepareOpTime) final; + void onTransactionAbort(OperationContext* opCtx, boost::optional<OplogSlot> abortOplogEntryOpTime) final; void onMajorityCommitPointUpdate(ServiceContext* service, @@ -244,6 +249,10 @@ private: OperationContext* opCtx, const std::vector<repl::ReplOperation>& stmts, const repl::OpTime& prepareOrCommitOptime) {} + virtual void shardObserveNonPrimaryTransactionPrepare( + OperationContext* opCtx, + const std::vector<repl::OplogEntry>& stmts, + const repl::OpTime& prepareOrCommitOptime) {} void _onReplicationRollback(OperationContext* opCtx, const RollbackObserverInfo& rbInfo) final; }; |
