summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/type_shard_identity.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/s/type_shard_identity.cpp')
-rw-r--r--src/mongo/db/s/type_shard_identity.cpp35
1 files changed, 3 insertions, 32 deletions
diff --git a/src/mongo/db/s/type_shard_identity.cpp b/src/mongo/db/s/type_shard_identity.cpp
index 6188f08a109..3eef36c9a22 100644
--- a/src/mongo/db/s/type_shard_identity.cpp
+++ b/src/mongo/db/s/type_shard_identity.cpp
@@ -40,13 +40,9 @@ namespace mongo {
const std::string ShardIdentityType::IdName("shardIdentity");
-namespace {
-
-const BSONField<std::string> configsvrConnString("configsvrConnectionString");
-const BSONField<std::string> shardName("shardName");
-const BSONField<OID> clusterId("clusterId");
-
-} // unnamed namespace
+const BSONField<std::string> ShardIdentityType::configsvrConnString("configsvrConnectionString");
+const BSONField<std::string> ShardIdentityType::shardName("shardName");
+const BSONField<OID> ShardIdentityType::clusterId("clusterId");
StatusWith<ShardIdentityType> ShardIdentityType::fromBSON(const BSONObj& source) {
if (!source.hasField("_id")) {
@@ -206,31 +202,6 @@ void ShardIdentityType::setClusterId(OID clusterId) {
_clusterId = std::move(clusterId);
}
-std::unique_ptr<BatchedUpdateRequest> ShardIdentityType::createUpsertForAddShard() const {
- invariant(validate().isOK());
-
- std::unique_ptr<BatchedUpdateDocument> updateDoc(new BatchedUpdateDocument());
-
- BSONObjBuilder query;
- query.append("_id", "shardIdentity");
- query.append("shardName", getShardName());
- query.append("clusterId", getClusterId());
- updateDoc->setQuery(query.obj());
-
- BSONObjBuilder update;
- BSONObjBuilder setConfigBuilder(update.subobjStart("$set"));
- setConfigBuilder.append(configsvrConnString(), getConfigsvrConnString().toString());
- setConfigBuilder.doneFast();
- updateDoc->setUpdateExpr(update.obj());
-
- updateDoc->setUpsert(true);
-
- std::unique_ptr<BatchedUpdateRequest> updateRequest(new BatchedUpdateRequest());
- updateRequest->addToUpdates(updateDoc.release());
-
- return updateRequest;
-}
-
BSONObj ShardIdentityType::createConfigServerUpdateObject(const std::string& newConnString) {
BSONObjBuilder builder;
BSONObjBuilder setConfigBuilder(builder.subobjStart("$set"));