summaryrefslogtreecommitdiff
path: root/src/mongo/s/config_server_client.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/s/config_server_client.cpp')
-rw-r--r--src/mongo/s/config_server_client.cpp14
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();
}