diff options
Diffstat (limited to 'src/mongo/s/config_server_client.cpp')
-rw-r--r-- | src/mongo/s/config_server_client.cpp | 14 |
1 files changed, 7 insertions, 7 deletions
diff --git a/src/mongo/s/config_server_client.cpp b/src/mongo/s/config_server_client.cpp index 22dcff95810..ba3e09f3292 100644 --- a/src/mongo/s/config_server_client.cpp +++ b/src/mongo/s/config_server_client.cpp @@ -51,7 +51,7 @@ Status moveChunk(OperationContext* txn, bool waitForDelete) { auto shardRegistry = Grid::get(txn)->shardRegistry(); auto shard = shardRegistry->getConfigShard(); - auto cmdResponseStatus = shard->runCommand( + auto cmdResponseStatus = shard->runCommandWithFixedRetryAttempts( txn, kPrimaryOnlyReadPreference, "admin", @@ -68,12 +68,12 @@ Status moveChunk(OperationContext* txn, Status rebalanceChunk(OperationContext* txn, const ChunkType& chunk) { auto shardRegistry = Grid::get(txn)->shardRegistry(); auto shard = shardRegistry->getConfigShard(); - auto cmdResponseStatus = - shard->runCommand(txn, - kPrimaryOnlyReadPreference, - "admin", - BalanceChunkRequest::serializeToRebalanceCommandForConfig(chunk), - Shard::RetryPolicy::kNotIdempotent); + auto cmdResponseStatus = shard->runCommandWithFixedRetryAttempts( + txn, + kPrimaryOnlyReadPreference, + "admin", + BalanceChunkRequest::serializeToRebalanceCommandForConfig(chunk), + Shard::RetryPolicy::kNotIdempotent); if (!cmdResponseStatus.isOK()) { return cmdResponseStatus.getStatus(); } |