diff options
| author | Spencer T Brody <spencer@mongodb.com> | 2016-04-27 17:38:50 -0400 |
|---|---|---|
| committer | Spencer T Brody <spencer@mongodb.com> | 2016-05-02 18:45:07 -0400 |
| commit | 52d9ecc1106023bb3e749ac7368391d780d3b3a2 (patch) | |
| tree | 9ab26e92490727787c0ef7a7278d7d6862d89f21 /src/mongo/s/chunk_manager.cpp | |
| parent | 070f32758b680425b0a6995b881fcb843a7db6cf (diff) | |
| download | mongo-52d9ecc1106023bb3e749ac7368391d780d3b3a2.tar.gz | |
SERVER-23211 Remove all callers of ShardRegistry::runIdempotentCommandOnShard
Diffstat (limited to 'src/mongo/s/chunk_manager.cpp')
| -rw-r--r-- | src/mongo/s/chunk_manager.cpp | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/mongo/s/chunk_manager.cpp b/src/mongo/s/chunk_manager.cpp index 99ecefa4d31..cb2e0055e31 100644 --- a/src/mongo/s/chunk_manager.cpp +++ b/src/mongo/s/chunk_manager.cpp @@ -357,17 +357,17 @@ void ChunkManager::calcInitSplitsAndShards(OperationContext* txn, // discover split points const auto primaryShard = grid.shardRegistry()->getShard(txn, primaryShardId); const NamespaceString nss{getns()}; - auto result = grid.shardRegistry()->runIdempotentCommandOnShard( - txn, - primaryShard, - ReadPreferenceSetting{ReadPreference::PrimaryPreferred}, - nss.db().toString(), - BSON("count" << nss.coll())); + + auto result = uassertStatusOK( + primaryShard->runCommand(txn, + ReadPreferenceSetting{ReadPreference::PrimaryPreferred}, + nss.db().toString(), + BSON("count" << nss.coll()), + Shard::RetryPolicy::kIdempotent)); long long numObjects = 0; - uassertStatusOK(result.getStatus()); - uassertStatusOK(getStatusFromCommandResult(result.getValue())); - uassertStatusOK(bsonExtractIntegerField(result.getValue(), "n", &numObjects)); + uassertStatusOK(result.commandStatus); + uassertStatusOK(bsonExtractIntegerField(result.response, "n", &numObjects)); if (numObjects > 0) { *splitPoints = uassertStatusOK(shardutil::selectChunkSplitPoints( |