SERVER-39819 SERVER-39820 Add HostGroup Controller impl to tie together replSets

1 files changed, 36 insertions, 19 deletions

diff --git a/src/mongo/s/sharding_task_executor_pool.idl b/src/mongo/s/sharding_task_executor_pool.idl
index 390dbc5a17b..dbced832b1b 100644
--- a/src/mongo/s/sharding_task_executor_pool.idl
+++ b/src/mongo/s/sharding_task_executor_pool.idl
@@ -28,49 +28,66 @@
 
 global:
   cpp_namespace: "mongo"
+  cpp_includes:
+    - "mongo/s/sharding_task_executor_pool_controller.h"
 
 server_parameters:
   ShardingTaskExecutorPoolMinSize:
     description: <-
         The minimum number of connections for each executor in the pool for the sharding grid.
-    set_at: [ startup ]
-    cpp_vartype: "int"
-    cpp_varname: "gShardingTaskExecutorPoolMinConnections"
+    set_at: [ startup, runtime ]
+    cpp_varname: "ShardingTaskExecutorPoolController::gParameters.minConnections"
+    validator:
+        gte: 0
     default: 1
   ShardingTaskExecutorPoolMaxSize:
     description: <-
         The maximum number of connections for each executor in the pool for the sharding grid.
-    set_at: [ startup ]
-    cpp_vartype: "int"
-    cpp_varname: "gShardingTaskExecutorPoolMaxConnections"
-    default: -1
+    set_at: [ startup, runtime ]
+    cpp_varname: "ShardingTaskExecutorPoolController::gParameters.maxConnections"
+    validator:
+        gte: 1
+    default: 32767
   ShardingTaskExecutorPoolMaxConnecting:
     description: <-
         The maximum number of in-flight connections for each executor
         in the pool for the sharding grid.
-    set_at: [ startup ]
-    cpp_vartype: "int"
-    cpp_varname: "gShardingTaskExecutorPoolMaxConnecting"
+    set_at: [ startup, runtime ]
+    cpp_varname: "ShardingTaskExecutorPoolController::gParameters.maxConnecting"
+    validator:
+        gte: 1
     default: 2
   ShardingTaskExecutorPoolHostTimeoutMS:
     description: <-
         The timeout for dropping a host for each executor in the pool for the sharding grid.
-    set_at: [ startup ]
-    cpp_vartype: "int"
-    cpp_varname: "gShardingTaskExecutorPoolHostTimeoutMS"
+    set_at: [ startup, runtime ]
+    cpp_varname: "ShardingTaskExecutorPoolController::gParameters.hostTimeoutMS"
+    validator:
+        callback: "ShardingTaskExecutorPoolController::validateHostTimeout"
+        gte: 1
     default: 300000 # 5mins
   ShardingTaskExecutorPoolRefreshRequirementMS:
     description: <-
         The timeout before a connection needs to be refreshed for each executor
         in the pool for the sharding grid.
-    set_at: [ startup ]
-    cpp_vartype: "int"
-    cpp_varname: "gShardingTaskExecutorPoolRefreshRequirementMS"
+    set_at: [ startup, runtime ]
+    cpp_varname: "ShardingTaskExecutorPoolController::gParameters.toRefreshTimeoutMS"
+    validator:
+        gte: 1
     default: 60000 # 1min
   ShardingTaskExecutorPoolRefreshTimeoutMS:
     description: <-
         The timeout for refreshing a connection for each executor in the pool for the sharding grid.
-    set_at: [ startup ]
-    cpp_vartype: "int"
-    cpp_varname: "gShardingTaskExecutorPoolRefreshTimeoutMS"
+    set_at: [ startup, runtime ]
+    cpp_varname: "ShardingTaskExecutorPoolController::gParameters.pendingTimeoutMS"
+    validator:
+        callback: "ShardingTaskExecutorPoolController::validatePendingTimeout"
+        gte: 1
     default: 20000 # 20secs
+  ShardingTaskExecutorPoolReplicaSetMatching:
+    description: <-
+        Enables ReplicaSet member connection matching.
+    set_at: [ startup, runtime ]
+    cpp_varname: "ShardingTaskExecutorPoolController::gParameters.matchingStrategyString"
+    on_update: "ShardingTaskExecutorPoolController::onUpdateMatchingStrategy"
+    default: "disabled"