diff options
Diffstat (limited to 'src/mongo/s/config_server_test_fixture.cpp')
| -rw-r--r-- | src/mongo/s/config_server_test_fixture.cpp | 24 |
1 files changed, 13 insertions, 11 deletions
diff --git a/src/mongo/s/config_server_test_fixture.cpp b/src/mongo/s/config_server_test_fixture.cpp index 70b391e7077..f984886e004 100644 --- a/src/mongo/s/config_server_test_fixture.cpp +++ b/src/mongo/s/config_server_test_fixture.cpp @@ -348,12 +348,13 @@ Status ConfigServerTestFixture::insertToConfigCollection(OperationContext* txn, auto config = getConfigShard(); invariant(config); - auto insertResponse = config->runCommand(txn, - kReadPref, - ns.db().toString(), - request.toBSON(), - Shard::kDefaultConfigCommandTimeout, - Shard::RetryPolicy::kNoRetry); + auto insertResponse = + config->runCommandWithFixedRetryAttempts(txn, + kReadPref, + ns.db().toString(), + request.toBSON(), + Shard::kDefaultConfigCommandTimeout, + Shard::RetryPolicy::kNoRetry); BatchedCommandResponse batchResponse; auto status = Shard::CommandResponse::processBatchWriteResponse(insertResponse, &batchResponse); @@ -433,11 +434,12 @@ StatusWith<std::vector<BSONObj>> ConfigServerTestFixture::getIndexes(OperationCo const NamespaceString& ns) { auto configShard = getConfigShard(); - auto response = configShard->runCommand(txn, - ReadPreferenceSetting{ReadPreference::PrimaryOnly}, - ns.db().toString(), - BSON("listIndexes" << ns.coll().toString()), - Shard::RetryPolicy::kIdempotent); + auto response = configShard->runCommandWithFixedRetryAttempts( + txn, + ReadPreferenceSetting{ReadPreference::PrimaryOnly}, + ns.db().toString(), + BSON("listIndexes" << ns.coll().toString()), + Shard::RetryPolicy::kIdempotent); if (!response.isOK()) { return response.getStatus(); } |