summaryrefslogtreecommitdiff
path: root/src/mongo/s/config_server_client.cpp
diff options
context:
space:
mode:
authorSpencer T Brody <spencer@mongodb.com>2016-08-26 17:47:07 -0400
committerSpencer T Brody <spencer@mongodb.com>2016-08-29 18:13:12 -0400
commit973a02dac92d3d192fd5e98011c4c4704356c3e2 (patch)
tree84546958e4e5ba49f4e2a2839e274bbb7233ec3e /src/mongo/s/config_server_client.cpp
parent3f7812c99ded16e6286e1fd40323e57c939797ed (diff)
downloadmongo-973a02dac92d3d192fd5e98011c4c4704356c3e2.tar.gz
SERVER-25832 Rename Shard::runCommand to Shard::runCommandWithFixedRetryAttempts
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();
}