summaryrefslogtreecommitdiff
path: root/src/mongo/s/catalog/catalog_manager_common.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/s/catalog/catalog_manager_common.cpp')
-rw-r--r--src/mongo/s/catalog/catalog_manager_common.cpp18
1 files changed, 9 insertions, 9 deletions
diff --git a/src/mongo/s/catalog/catalog_manager_common.cpp b/src/mongo/s/catalog/catalog_manager_common.cpp
index 82c2a863fa9..d8943f626d3 100644
--- a/src/mongo/s/catalog/catalog_manager_common.cpp
+++ b/src/mongo/s/catalog/catalog_manager_common.cpp
@@ -111,7 +111,7 @@ StatusWith<ShardType> validateHostAsShard(OperationContext* txn,
const ReadPreferenceSetting readPref{ReadPreference::PrimaryOnly};
// Is it mongos?
- auto cmdStatus = shardRegistry->runIdempotentCommandForAddShard(
+ auto cmdStatus = shardRegistry->runCommandForAddShard(
txn, shardConn, readPref, "admin", BSON("isdbgrid" << 1));
if (!cmdStatus.isOK()) {
return cmdStatus.getStatus();
@@ -123,7 +123,7 @@ StatusWith<ShardType> validateHostAsShard(OperationContext* txn,
}
// Is it a replica set?
- cmdStatus = shardRegistry->runIdempotentCommandForAddShard(
+ cmdStatus = shardRegistry->runCommandForAddShard(
txn, shardConn, readPref, "admin", BSON("isMaster" << 1));
if (!cmdStatus.isOK()) {
return cmdStatus.getStatus();
@@ -157,7 +157,7 @@ StatusWith<ShardType> validateHostAsShard(OperationContext* txn,
}
// Is it a mongos config server?
- cmdStatus = shardRegistry->runIdempotentCommandForAddShard(
+ cmdStatus = shardRegistry->runCommandForAddShard(
txn, shardConn, readPref, "admin", BSON("replSetGetStatus" << 1));
if (!cmdStatus.isOK()) {
return cmdStatus.getStatus();
@@ -260,12 +260,12 @@ StatusWith<std::vector<std::string>> getDBNamesListFromShard(
shardRegistry->createConnection(connectionString).release()};
invariant(shardConn);
- auto cmdStatus = shardRegistry->runIdempotentCommandForAddShard(
- txn,
- shardConn,
- ReadPreferenceSetting{ReadPreference::PrimaryOnly},
- "admin",
- BSON("listDatabases" << 1));
+ auto cmdStatus =
+ shardRegistry->runCommandForAddShard(txn,
+ shardConn,
+ ReadPreferenceSetting{ReadPreference::PrimaryOnly},
+ "admin",
+ BSON("listDatabases" << 1));
if (!cmdStatus.isOK()) {
return cmdStatus.getStatus();
}