SERVER-58184 Move getOldestActiveTimestamp after prepare reconstruction

(cherry picked from commit 841cff317bf34a320f9b8be24cdf27faf4393cbb)

1 files changed, 11 insertions, 4 deletions

diff --git a/src/mongo/db/mongod_main.cpp b/src/mongo/db/mongod_main.cpp
index da733aa10ae..b2c6a2a9f4b 100644
--- a/src/mongo/db/mongod_main.cpp
+++ b/src/mongo/db/mongod_main.cpp
@@ -658,10 +658,6 @@ ExitCode _initAndListen(ServiceContext* serviceContext, int listenPort) {
 
         auto replCoord = repl::ReplicationCoordinator::get(startupOpCtx.get());
         invariant(replCoord);
-        if (replCoord->isReplEnabled()) {
-            storageEngine->setOldestActiveTransactionTimestampCallback(
-                TransactionParticipant::getOldestActiveTimestamp);
-        }
 
         if (serverGlobalParams.clusterRole == ClusterRole::ShardServer) {
             // Note: For replica sets, ShardingStateRecovery happens on transition to primary.
@@ -694,6 +690,17 @@ ExitCode _initAndListen(ServiceContext* serviceContext, int listenPort) {
         }
 
         replCoord->startup(startupOpCtx.get(), lastShutdownState);
+        // 'getOldestActiveTimestamp', which is called in the background by the checkpoint thread,
+        // requires a read on 'config.transactions' at the stableTimestamp. If this read occurs
+        // while applying prepared transactions at the end of replication recovery, it's possible to
+        // prepare a transaction at timestamp earlier than the stableTimestamp. This will result in
+        // a WiredTiger invariant. Register the callback after the call to 'startup' to ensure we've
+        // finished applying prepared transactions.
+        if (replCoord->isReplEnabled()) {
+            storageEngine->setOldestActiveTransactionTimestampCallback(
+                TransactionParticipant::getOldestActiveTimestamp);
+        }
+
         if (getReplSetMemberInStandaloneMode(serviceContext)) {
             LOGV2_WARNING_OPTIONS(
                 20547,