rename to max_pending_connection_listeners

Author: dnhatn

server/src/main/java/org/elasticsearch/transport/RemoteConnectionStrategy.java

@@ -106,10 +106,10 @@ public Writeable.Reader<RemoteConnectionInfo.ModeInfo> getReader() {
             Setting.Property.Dynamic));
 
     // this setting is intentionally not registered, it is only used in tests
-    public static final Setting<Integer> REMOTE_MAX_CONNECTION_QUEUE_SIZE =
-        Setting.intSetting("cluster.remote.max_connection_queue_size", 100, Setting.Property.NodeScope);
+    public static final Setting<Integer> REMOTE_MAX_PENDING_CONNECTION_LISTENERS =
+        Setting.intSetting("cluster.remote.max_pending_connection_listeners", 100, Setting.Property.NodeScope);
 
-    private final int maxConnectionQueueSize;
+    private final int maxPendingConnectionListeners;
 
     private static final Logger logger = LogManager.getLogger(RemoteConnectionStrategy.class);
 
@@ -126,7 +126,7 @@ public Writeable.Reader<RemoteConnectionInfo.ModeInfo> getReader() {
         this.clusterAlias = clusterAlias;
         this.transportService = transportService;
         this.connectionManager = connectionManager;
-        this.maxConnectionQueueSize = REMOTE_MAX_CONNECTION_QUEUE_SIZE.get(settings);
+        this.maxPendingConnectionListeners = REMOTE_MAX_PENDING_CONNECTION_LISTENERS.get(settings);
         connectionManager.addListener(this);
     }
 
@@ -243,8 +243,8 @@ void connect(ActionListener<Void> connectListener) {
             if (closed) {
                 assert listeners.isEmpty();
             } else {
-                if (listeners.size() >= maxConnectionQueueSize) {
-                    assert listeners.size() == maxConnectionQueueSize;
+                if (listeners.size() >= maxPendingConnectionListeners) {
+                    assert listeners.size() == maxPendingConnectionListeners;
                     listener.onFailure(new EsRejectedExecutionException("connect listener queue is full"));
                     return;
                 } else {

test/framework/src/main/java/org/elasticsearch/test/InternalSettingsPlugin.java

@@ -51,7 +51,7 @@ public List<Setting<?>> getSettings() {
                 INDEX_CREATION_DATE_SETTING,
                 PROVIDED_NAME_SETTING,
                 TRANSLOG_RETENTION_CHECK_INTERVAL_SETTING,
-                RemoteConnectionStrategy.REMOTE_MAX_CONNECTION_QUEUE_SIZE,
+                RemoteConnectionStrategy.REMOTE_MAX_PENDING_CONNECTION_LISTENERS,
                 IndexService.GLOBAL_CHECKPOINT_SYNC_INTERVAL_SETTING,
                 IndexService.RETENTION_LEASE_SYNC_INTERVAL_SETTING,
                 IndexSettings.FILE_BASED_RECOVERY_THRESHOLD_SETTING,

x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/CcrIntegTestCase.java

@@ -136,7 +136,7 @@ protected Settings leaderClusterSettings() {
     protected Settings followerClusterSettings() {
         final Settings.Builder builder = Settings.builder();
         if (randomBoolean()) {
-            builder.put(RemoteConnectionStrategy.REMOTE_MAX_CONNECTION_QUEUE_SIZE.getKey(), randomIntBetween(1, 100));
+            builder.put(RemoteConnectionStrategy.REMOTE_MAX_PENDING_CONNECTION_LISTENERS.getKey(), randomIntBetween(1, 100));
         }
         return builder.build();
     }

x-pack/plugin/ccr/src/test/java/org/elasticsearch/xpack/ccr/RestartIndexFollowingIT.java

@@ -39,7 +39,7 @@ protected boolean configureRemoteClusterViaNodeSettings() {
     protected Settings followerClusterSettings() {
         final Settings.Builder settings = Settings.builder().put(super.followerClusterSettings());
         if (randomBoolean()) {
-            settings.put(RemoteConnectionStrategy.REMOTE_MAX_CONNECTION_QUEUE_SIZE.getKey(), 1);
+            settings.put(RemoteConnectionStrategy.REMOTE_MAX_PENDING_CONNECTION_LISTENERS.getKey(), 1);
         }
         return settings.build();
     }