summaryrefslogtreecommitdiff
path: root/src/mongo/s
diff options
context:
space:
mode:
authorMax Hirschhorn <max.hirschhorn@mongodb.com>2016-09-04 11:43:00 -0400
committerMax Hirschhorn <max.hirschhorn@mongodb.com>2016-09-04 11:43:00 -0400
commiteea8acf410705f8c25018babdcf4e7861eb7128e (patch)
treed93cc43081b730656951a7570816173717e2b4c8 /src/mongo/s
parent767da33d396fc0d6a13aaff8387ba5a05c8c43b7 (diff)
downloadmongo-eea8acf410705f8c25018babdcf4e7861eb7128e.tar.gz
Revert "SERVER-25935 move ShardRegistry::init() out of Grid::init()"
This reverts commit d1d57b9ebab61ae897aaee624ca8df34399baa01.
Diffstat (limited to 'src/mongo/s')
-rw-r--r--src/mongo/s/grid.cpp2
-rw-r--r--src/mongo/s/sharding_initialization.cpp1
-rw-r--r--src/mongo/s/sharding_mongod_test_fixture.cpp13
-rw-r--r--src/mongo/s/sharding_test_fixture.cpp3
4 files changed, 4 insertions, 15 deletions
diff --git a/src/mongo/s/grid.cpp b/src/mongo/s/grid.cpp
index f6297702989..fbc973788d9 100644
--- a/src/mongo/s/grid.cpp
+++ b/src/mongo/s/grid.cpp
@@ -88,6 +88,8 @@ void Grid::init(std::unique_ptr<ShardingCatalogClient> catalogClient,
_balancerConfig = std::move(balancerConfig);
_executorPool = std::move(executorPool);
_network = network;
+
+ _shardRegistry->init();
}
bool Grid::allowLocalHost() const {
diff --git a/src/mongo/s/sharding_initialization.cpp b/src/mongo/s/sharding_initialization.cpp
index 215c57252f8..0c46df7a3cd 100644
--- a/src/mongo/s/sharding_initialization.cpp
+++ b/src/mongo/s/sharding_initialization.cpp
@@ -154,7 +154,6 @@ Status initializeGlobalShardingState(OperationContext* txn,
executorPool->startup();
auto shardRegistry(stdx::make_unique<ShardRegistry>(std::move(shardFactory), configCS));
- shardRegistry->init();
auto catalogClient =
makeCatalogClient(txn->getServiceContext(), shardRegistry.get(), distLockProcessId);
diff --git a/src/mongo/s/sharding_mongod_test_fixture.cpp b/src/mongo/s/sharding_mongod_test_fixture.cpp
index b8b17d9c843..2c37be980a9 100644
--- a/src/mongo/s/sharding_mongod_test_fixture.cpp
+++ b/src/mongo/s/sharding_mongod_test_fixture.cpp
@@ -209,18 +209,7 @@ std::unique_ptr<ShardRegistry> MongodTestFixture::makeShardRegistry(
auto shardFactory =
stdx::make_unique<ShardFactory>(std::move(buildersMap), std::move(targeterFactory));
- auto shardRegistry = stdx::make_unique<ShardRegistry>(std::move(shardFactory), configConnStr);
- shardRegistry->init();
-
- if (serverGlobalParams.clusterRole == ClusterRole::ShardServer) {
- // Set the ConnectionString return value on the mock targeter so that later calls to
- // the targeter's getConnString() return the appropriate value.
- auto configTargeter =
- RemoteCommandTargeterMock::get(shardRegistry->getConfigShard()->getTargeter());
- configTargeter->setConnectionStringReturnValue(configConnStr);
- }
-
- return shardRegistry;
+ return stdx::make_unique<ShardRegistry>(std::move(shardFactory), configConnStr);
}
std::unique_ptr<DistLockCatalog> MongodTestFixture::makeDistLockCatalog(
diff --git a/src/mongo/s/sharding_test_fixture.cpp b/src/mongo/s/sharding_test_fixture.cpp
index 534c71036c6..9541019e1c6 100644
--- a/src/mongo/s/sharding_test_fixture.cpp
+++ b/src/mongo/s/sharding_test_fixture.cpp
@@ -121,7 +121,6 @@ void ShardingTestFixture::setUp() {
auto executorPool = stdx::make_unique<executor::TaskExecutorPool>();
executorPool->addExecutors(std::move(executorsForPool), std::move(fixedExec));
- executorPool->startup();
auto uniqueDistLockManager = stdx::make_unique<DistLockManagerMock>(nullptr);
_distLockManager = uniqueDistLockManager.get();
@@ -162,7 +161,7 @@ void ShardingTestFixture::setUp() {
stdx::make_unique<ShardFactory>(std::move(buildersMap), std::move(targeterFactory));
auto shardRegistry(stdx::make_unique<ShardRegistry>(std::move(shardFactory), configCS));
- shardRegistry->init();
+ executorPool->startup();
// For now initialize the global grid object. All sharding objects will be accessible from there
// until we get rid of it.