diff --git a/src/mongo/db/s/shardsvr_check_metadata_consistency_command.cpp b/src/mongo/db/s/shardsvr_check_metadata_consistency_command.cpp index 80723c14bba..65122a7ae41 100644 --- a/src/mongo/db/s/shardsvr_check_metadata_consistency_command.cpp +++ b/src/mongo/db/s/shardsvr_check_metadata_consistency_command.cpp @@ -211,10 +211,14 @@ public: std::vector cursors; + logd("SSS Going to execute checkMetadatatConsistency on a shard"); + // Need to retrieve a list of databases which this shard is primary for and run the // command on each of them. for (const auto& db : getDatabasesThisShardIsPrimaryFor(opCtx)) { const auto dbNss = NamespaceStringUtil::deserialize(db.getDbName(), nss.coll()); + logd("SSS checking db {}", db.getDbName()); + ScopedSetShardRole scopedSetShardRole(opCtx, dbNss, boost::none /* shardVersion */, diff --git a/src/mongo/s/commands/cluster_check_metadata_consistency_cmd.cpp b/src/mongo/s/commands/cluster_check_metadata_consistency_cmd.cpp index bed40815bb1..fa694c86747 100644 --- a/src/mongo/s/commands/cluster_check_metadata_consistency_cmd.cpp +++ b/src/mongo/s/commands/cluster_check_metadata_consistency_cmd.cpp @@ -95,6 +95,8 @@ namespace mongo { namespace { +MONGO_FAIL_POINT_DEFINE(hangBeforeSendingCheckMetadataConsistencyCmdToShards); + /* * Return the set of shards that are primaries for at least one database */ @@ -186,6 +188,8 @@ public: requests.emplace_back(std::move(shardId), shardRequestWithOpKey.getOwned()); } + hangBeforeSendingCheckMetadataConsistencyCmdToShards.pauseWhileSet(); + // Send a request to the configsvr to check cluster metadata consistency. const auto configOpKey = UUID::gen(); ConfigsvrCheckClusterMetadataConsistency configsvrRequest;