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