summaryrefslogtreecommitdiff
path: root/src/mongo/s/sharding_initialization.cpp
diff options
context:
space:
mode:
authorKaloian Manassiev <kaloian.manassiev@mongodb.com>2017-07-12 15:59:59 -0400
committerKaloian Manassiev <kaloian.manassiev@mongodb.com>2017-07-13 09:19:05 -0400
commitfc300ed58b943b93a3164103e4a767e3f81d1c3b (patch)
tree2ff6a0e61b4b1c40a93e83dd063f6ee3ea9ec8ca /src/mongo/s/sharding_initialization.cpp
parent98bb1900c5aa0c8f7ede0b9df201f9cd9b7c9da5 (diff)
downloadmongo-fc300ed58b943b93a3164103e4a767e3f81d1c3b.tar.gz
SERVER-30053 Remove 'opCtx' parameter from Grid::catalogClient()
This method is now just a simple getter and doesn't require operation context.
Diffstat (limited to 'src/mongo/s/sharding_initialization.cpp')
-rw-r--r--src/mongo/s/sharding_initialization.cpp13
1 files changed, 5 insertions, 8 deletions
diff --git a/src/mongo/s/sharding_initialization.cpp b/src/mongo/s/sharding_initialization.cpp
index 7c1dddb4e2f..3dbaf4f19ea 100644
--- a/src/mongo/s/sharding_initialization.cpp
+++ b/src/mongo/s/sharding_initialization.cpp
@@ -210,7 +210,7 @@ Status initializeGlobalShardingState(OperationContext* opCtx,
makeTaskExecutor(executor::makeNetworkInterface("AddShard-TaskExecutor")));
auto rawCatalogManager = catalogManager.get();
- auto grid = Grid::get(opCtx);
+ auto const grid = Grid::get(opCtx);
grid->init(
std::move(catalogClient),
std::move(catalogManager),
@@ -221,24 +221,21 @@ Status initializeGlobalShardingState(OperationContext* opCtx,
std::move(executorPool),
networkPtr);
- // must be started once the grid is initialized
+ // The shard registry must be started once the grid is initialized
grid->shardRegistry()->startup(opCtx);
- auto status = rawCatalogClient->startup();
- if (!status.isOK()) {
- return status;
- }
+ grid->catalogClient()->startup();
if (serverGlobalParams.clusterRole == ClusterRole::ConfigServer) {
// Only config servers get a ShardingCatalogManager.
- status = rawCatalogManager->startup();
+ Status status = rawCatalogManager->startup();
if (!status.isOK()) {
return status;
}
}
auto keyManager = stdx::make_unique<KeysCollectionManager>(
- kKeyManagerPurposeString, grid->catalogClient(opCtx), Seconds(KeysRotationIntervalSec));
+ kKeyManagerPurposeString, grid->catalogClient(), Seconds(KeysRotationIntervalSec));
keyManager->startMonitoring(opCtx->getServiceContext());
LogicalTimeValidator::set(opCtx->getServiceContext(),