summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/sharding_state.cpp
diff options
context:
space:
mode:
authorMatthew Saltz <matthew.saltz@mongodb.com>2018-06-07 14:35:58 -0400
committerMatthew Saltz <matthew.saltz@mongodb.com>2018-06-13 17:02:08 -0400
commit09919208ae16cd44f3ca3e98220e1cc322419a8a (patch)
treee0830b8d56407a2131f0b5e09bf489ea42d848e7 /src/mongo/db/s/sharding_state.cpp
parent85477a157ab217912eec55422a9d7b2d0e7b0d47 (diff)
downloadmongo-09919208ae16cd44f3ca3e98220e1cc322419a8a.tar.gz
SERVER-35486 Create _addShard command on shard to drive shard initialization
Diffstat (limited to 'src/mongo/db/s/sharding_state.cpp')
-rw-r--r--src/mongo/db/s/sharding_state.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/mongo/db/s/sharding_state.cpp b/src/mongo/db/s/sharding_state.cpp
index 3850454d36f..c45ddb1e71d 100644
--- a/src/mongo/db/s/sharding_state.cpp
+++ b/src/mongo/db/s/sharding_state.cpp
@@ -190,7 +190,7 @@ Status ShardingState::initializeFromShardIdentity(OperationContext* opCtx,
stdx::unique_lock<stdx::mutex> lk(_mutex);
- auto configSvrConnStr = shardIdentity.getConfigsvrConnString();
+ const auto& configSvrConnStr = shardIdentity.getConfigsvrConnectionString();
if (enabled()) {
invariant(!_shardName.empty());
@@ -241,7 +241,7 @@ Status ShardingState::initializeFromShardIdentity(OperationContext* opCtx,
_initializationStatus = status;
_setInitializationState(InitializationState::kError);
}
- _shardName = shardIdentity.getShardName();
+ _shardName = shardIdentity.getShardName().toString();
_clusterId = shardIdentity.getClusterId();
return status;
@@ -275,8 +275,8 @@ StatusWith<bool> ShardingState::initializeShardingAwarenessIfNeeded(OperationCon
"If started with --shardsvr in queryableBackupMode, a shardIdentity "
"document must be provided through --overrideShardIdentity"};
}
- auto swOverrideShardIdentity =
- ShardIdentityType::fromBSON(serverGlobalParams.overrideShardIdentity);
+ auto swOverrideShardIdentity = ShardIdentityType::fromShardIdentityDocument(
+ serverGlobalParams.overrideShardIdentity);
if (!swOverrideShardIdentity.isOK()) {
return swOverrideShardIdentity.getStatus();
}
@@ -345,7 +345,7 @@ StatusWith<bool> ShardingState::initializeShardingAwarenessIfNeeded(OperationCon
invariant(!shardIdentityBSON.isEmpty());
- auto swShardIdentity = ShardIdentityType::fromBSON(shardIdentityBSON);
+ auto swShardIdentity = ShardIdentityType::fromShardIdentityDocument(shardIdentityBSON);
if (!swShardIdentity.isOK()) {
return swShardIdentity.getStatus();
}