SERVER-39818 Split RSM notification functionality into a new class

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;
 };
 
 /**