summaryrefslogtreecommitdiff
path: root/src/mongo/db/s/sharding_state.cpp
diff options
context:
space:
mode:
authorSpencer T Brody <spencer@mongodb.com>2015-07-14 19:43:14 -0400
committerSpencer T Brody <spencer@mongodb.com>2015-07-16 11:37:38 -0400
commitca7c55af9d787cd8456a313a2d5e7bf56cadf36e (patch)
tree78166ae17e9e138ff9b0c85f3a33850251abdf94 /src/mongo/db/s/sharding_state.cpp
parent2689d44d91d9d9e4dcbdb442d788adcc10ab49dd (diff)
downloadmongo-ca7c55af9d787cd8456a313a2d5e7bf56cadf36e.tar.gz
SERVER-19414 Unify global sharding state initialization between mongos and mongod
Diffstat (limited to 'src/mongo/db/s/sharding_state.cpp')
-rw-r--r--src/mongo/db/s/sharding_state.cpp19
1 files changed, 2 insertions, 17 deletions
diff --git a/src/mongo/db/s/sharding_state.cpp b/src/mongo/db/s/sharding_state.cpp
index b0acbada38e..92f68371dac 100644
--- a/src/mongo/db/s/sharding_state.cpp
+++ b/src/mongo/db/s/sharding_state.cpp
@@ -36,18 +36,15 @@
#include "mongo/db/client.h"
#include "mongo/db/concurrency/lock_state.h"
#include "mongo/db/operation_context.h"
-#include "mongo/db/repl/replication_executor.h"
#include "mongo/db/s/collection_metadata.h"
#include "mongo/db/s/metadata_loader.h"
#include "mongo/db/s/sharded_connection_info.h"
-#include "mongo/executor/network_interface_factory.h"
-#include "mongo/executor/task_executor.h"
#include "mongo/s/catalog/catalog_manager.h"
#include "mongo/s/catalog/type_chunk.h"
-#include "mongo/s/catalog/legacy/catalog_manager_legacy.h"
#include "mongo/s/client/shard_registry.h"
#include "mongo/s/chunk_version.h"
#include "mongo/s/grid.h"
+#include "mongo/s/sharding_initialization.h"
#include "mongo/util/log.h"
#include "mongo/util/mongoutils/str.h"
#include "mongo/util/net/sock.h"
@@ -122,19 +119,7 @@ void ShardingState::initialize(const string& server) {
str::stream() << "Invalid config server connection string: " << errmsg,
configServerCS.isValid());
- auto catalogManager = stdx::make_unique<CatalogManagerLegacy>();
- uassertStatusOK(catalogManager->init(configServerCS));
-
- auto network = executor::makeNetworkInterface();
- auto networkPtr = network.get();
- auto shardRegistry(stdx::make_unique<ShardRegistry>(
- stdx::make_unique<RemoteCommandTargeterFactoryImpl>(),
- stdx::make_unique<repl::ReplicationExecutor>(network.release(), nullptr, 0),
- networkPtr));
- shardRegistry->init(catalogManager.get());
- shardRegistry->startup();
-
- grid.init(std::move(catalogManager), std::move(shardRegistry));
+ uassertStatusOK(initializeGlobalShardingState(configServerCS));
_enabled = true;
}