SERVER-41949 Attach the databaseVersion on the write path on mongos"

1 files changed, 8 insertions, 0 deletions

diff --git a/src/mongo/db/s/scoped_operation_completion_sharding_actions.cpp b/src/mongo/db/s/scoped_operation_completion_sharding_actions.cpp
index c75cba94c62..625f62a51f3 100644
--- a/src/mongo/db/s/scoped_operation_completion_sharding_actions.cpp
+++ b/src/mongo/db/s/scoped_operation_completion_sharding_actions.cpp
@@ -78,6 +78,14 @@ ScopedOperationCompletionShardingActions::~ScopedOperationCompletionShardingActi
         if (!handleMismatchStatus.isOK())
             log() << "Failed to handle stale version exception"
                   << causedBy(redact(handleMismatchStatus));
+    } else if (auto staleInfo = status->extraInfo<StaleDbRoutingVersion>()) {
+        auto handleMismatchStatus = onDbVersionMismatchNoExcept(_opCtx,
+                                                                staleInfo->getDb(),
+                                                                staleInfo->getVersionReceived(),
+                                                                staleInfo->getVersionWanted());
+        if (!handleMismatchStatus.isOK())
+            log() << "Failed to handle database version exception"
+                  << causedBy(redact(handleMismatchStatus));
     } else if (auto cannotImplicitCreateCollInfo =
                    status->extraInfo<CannotImplicitlyCreateCollectionInfo>()) {
         if (ShardingState::get(_opCtx)->enabled()) {