SERVER-55151 Implement rename participant primary only service

1 files changed, 11 insertions, 1 deletions

diff --git a/src/mongo/db/s/shardsvr_rename_collection_command.cpp b/src/mongo/db/s/shardsvr_rename_collection_command.cpp
index f8d2c5f6471..63c315b23d4 100644
--- a/src/mongo/db/s/shardsvr_rename_collection_command.cpp
+++ b/src/mongo/db/s/shardsvr_rename_collection_command.cpp
@@ -38,7 +38,7 @@
 #include "mongo/db/s/collection_sharding_state.h"
 #include "mongo/db/s/dist_lock_manager.h"
 #include "mongo/db/s/rename_collection_coordinator.h"
-#include "mongo/db/s/rename_collection_coordinator_document_gen.h"
+#include "mongo/db/s/sharded_rename_collection_gen.h"
 #include "mongo/db/s/sharding_ddl_50_upgrade_downgrade.h"
 #include "mongo/db/s/sharding_ddl_coordinator_service.h"
 #include "mongo/db/s/sharding_ddl_util.h"
@@ -141,6 +141,16 @@ public:
                                   << opCtx->getWriteConcern().wMode,
                     opCtx->getWriteConcern().wMode == WriteConcernOptions::kMajority);
 
+            // TODO SERVER-56296 Uniform `fromNss == toNss` behavior between RS and sharded cluster
+            if (fromNss == toNss) {
+                // Simply return the current collection version
+                const auto catalog = Grid::get(opCtx)->catalogCache();
+                const auto cm =
+                    uassertStatusOK(catalog->getCollectionRoutingInfoWithRefresh(opCtx, fromNss));
+                return RenameCollectionResponse(cm.isSharded() ? cm.getVersion()
+                                                               : ChunkVersion::UNSHARDED());
+            }
+
             validateNamespacesForRenameCollection(opCtx, fromNss, toNss);
 
             auto coordinatorDoc = RenameCollectionCoordinatorDocument();