From 671db819923bfdec5e456964a0e300e3ba38b241 Mon Sep 17 00:00:00 2001 From: kimchy Date: Wed, 20 Jul 2011 00:01:04 +0300 Subject: [PATCH] add transport.connections_per_node prefix setting as well as the netty specific one --- .../org/elasticsearch/transport/netty/NettyTransport.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/transport/netty/NettyTransport.java b/modules/elasticsearch/src/main/java/org/elasticsearch/transport/netty/NettyTransport.java index e09838af25e..d758d8dd4e4 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/transport/netty/NettyTransport.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/transport/netty/NettyTransport.java @@ -183,9 +183,9 @@ public class NettyTransport extends AbstractLifecycleComponent implem this.reuseAddress = componentSettings.getAsBoolean("reuse_address", settings.getAsBoolean(TCP_REUSE_ADDRESS, NetworkUtils.defaultReuseAddress())); this.tcpSendBufferSize = componentSettings.getAsBytesSize("tcp_send_buffer_size", settings.getAsBytesSize(TCP_SEND_BUFFER_SIZE, TCP_DEFAULT_SEND_BUFFER_SIZE)); this.tcpReceiveBufferSize = componentSettings.getAsBytesSize("tcp_receive_buffer_size", settings.getAsBytesSize(TCP_RECEIVE_BUFFER_SIZE, TCP_DEFAULT_RECEIVE_BUFFER_SIZE)); - this.connectionsPerNodeLow = componentSettings.getAsInt("connections_per_node.low", 2); - this.connectionsPerNodeMed = componentSettings.getAsInt("connections_per_node.med", 7); - this.connectionsPerNodeHigh = componentSettings.getAsInt("connections_per_node.high", 1); + this.connectionsPerNodeLow = componentSettings.getAsInt("connections_per_node.low", settings.getAsInt("transport.connections_per_node.low", 2)); + this.connectionsPerNodeMed = componentSettings.getAsInt("connections_per_node.med", settings.getAsInt("transport.connections_per_node.med", 7)); + this.connectionsPerNodeHigh = componentSettings.getAsInt("connections_per_node.high", settings.getAsInt("transport.connections_per_node.high", 1)); } public Settings settings() {