summaryrefslogtreecommitdiff
path: root/src/mongo/db/user_write_block_mode_op_observer.h
diff options
context:
space:
mode:
authorMindaugas Malinauskas <mindaugas.malinauskas@mongodb.com>2022-02-16 10:57:21 +0000
committerEvergreen Agent <no-reply@evergreen.mongodb.com>2022-03-23 11:27:17 +0000
commitf65692d2b92ecaf505dc73f82d5490f9528f5fe2 (patch)
tree7b460734da63f0e44af88440c78ae0980d2cf4c2 /src/mongo/db/user_write_block_mode_op_observer.h
parentc3fee8287bf070e1fa6309513a4e6d8100c440ee (diff)
downloadmongo-f65692d2b92ecaf505dc73f82d5490f9528f5fe2.tar.gz
SERVER-62785 Write change stream pre-images in the main storage engine transaction for prepared transactions
Diffstat (limited to 'src/mongo/db/user_write_block_mode_op_observer.h')
-rw-r--r--src/mongo/db/user_write_block_mode_op_observer.h20
1 files changed, 16 insertions, 4 deletions
diff --git a/src/mongo/db/user_write_block_mode_op_observer.h b/src/mongo/db/user_write_block_mode_op_observer.h
index d5ad0a2ecaa..adef807ed97 100644
--- a/src/mongo/db/user_write_block_mode_op_observer.h
+++ b/src/mongo/db/user_write_block_mode_op_observer.h
@@ -197,10 +197,22 @@ public:
Timestamp commitTimestamp,
const std::vector<repl::ReplOperation>& statements) noexcept final {}
- void onTransactionPrepare(OperationContext* opCtx,
- const std::vector<OplogSlot>& reservedSlots,
- std::vector<repl::ReplOperation>* statements,
- size_t numberOfPrePostImagesToWrite) final {}
+ std::unique_ptr<ApplyOpsOplogSlotAndOperationAssignment> preTransactionPrepare(
+ OperationContext* opCtx,
+ const std::vector<OplogSlot>& reservedSlots,
+ size_t numberOfPrePostImagesToWrite,
+ Date_t wallClockTime,
+ std::vector<repl::ReplOperation>* statements) final {
+ return nullptr;
+ }
+
+ void onTransactionPrepare(
+ OperationContext* opCtx,
+ const std::vector<OplogSlot>& reservedSlots,
+ std::vector<repl::ReplOperation>* statements,
+ const ApplyOpsOplogSlotAndOperationAssignment* applyOpsOperationAssignment,
+ size_t numberOfPrePostImagesToWrite,
+ Date_t wallClockTime) final {}
void onTransactionAbort(OperationContext* opCtx,
boost::optional<OplogSlot> abortOplogEntryOpTime) final {}