diff options
Diffstat (limited to 'src/mongo/db/s/sharding_initialization_mongod.h')
| -rw-r--r-- | src/mongo/db/s/sharding_initialization_mongod.h | 11 |
1 files changed, 9 insertions, 2 deletions
diff --git a/src/mongo/db/s/sharding_initialization_mongod.h b/src/mongo/db/s/sharding_initialization_mongod.h index e26302b4bb2..a205d68d1b2 100644 --- a/src/mongo/db/s/sharding_initialization_mongod.h +++ b/src/mongo/db/s/sharding_initialization_mongod.h @@ -30,6 +30,7 @@ #pragma once #include "mongo/base/string_data.h" +#include "mongo/client/replica_set_change_notifier.h" #include "mongo/db/s/sharding_state.h" #include "mongo/db/s/type_shard_identity.h" #include "mongo/stdx/functional.h" @@ -60,6 +61,10 @@ public: static ShardingInitializationMongoD* get(OperationContext* opCtx); static ShardingInitializationMongoD* get(ServiceContext* service); + void initializeShardingEnvironmentOnShardServer(OperationContext* opCtx, + const ShardIdentity& shardIdentity, + StringData distLockProcessId); + /** * If started with --shardsvr, initializes sharding awareness from the shardIdentity document on * disk, if there is one. @@ -94,8 +99,8 @@ public: * Updates the config server field of the shardIdentity document with the given connection * string. */ - static Status updateShardIdentityConfigString(OperationContext* opCtx, - const ConnectionString& newConnectionString); + static void updateShardIdentityConfigString(OperationContext* opCtx, + const ConnectionString& newConnectionString); /** * For testing only. Mock the initialization method used by initializeFromConfigConnString and @@ -112,6 +117,8 @@ private: // Function for initializing the sharding environment components (i.e. everything on the Grid) ShardingEnvironmentInitFunc _initFunc; + + ReplicaSetChangeListenerHandle _replicaSetChangeListener; }; /** |