|
@@ -96,11 +96,6 @@ public class Netty4Transport extends TcpTransport<Channel> {
|
|
|
(s) -> Integer.toString(EsExecutors.numberOfProcessors(s) * 2),
|
|
|
(s) -> Setting.parseInt(s, 1, "transport.netty.worker_count"), Property.NodeScope);
|
|
|
|
|
|
- public static final Setting<ByteSizeValue> NETTY_MAX_CUMULATION_BUFFER_CAPACITY =
|
|
|
- Setting.byteSizeSetting("transport.netty.max_cumulation_buffer_capacity", new ByteSizeValue(-1), Property.NodeScope);
|
|
|
- public static final Setting<Integer> NETTY_MAX_COMPOSITE_BUFFER_COMPONENTS =
|
|
|
- Setting.intSetting("transport.netty.max_composite_buffer_components", -1, -1, Property.NodeScope);
|
|
|
-
|
|
|
public static final Setting<ByteSizeValue> NETTY_RECEIVE_PREDICTOR_SIZE = Setting.byteSizeSetting(
|
|
|
"transport.netty.receive_predictor_size", new ByteSizeValue(64, ByteSizeUnit.KB), Property.NodeScope);
|
|
|
public static final Setting<ByteSizeValue> NETTY_RECEIVE_PREDICTOR_MIN =
|
|
@@ -111,8 +106,6 @@ public class Netty4Transport extends TcpTransport<Channel> {
|
|
|
intSetting("transport.netty.boss_count", 1, 1, Property.NodeScope);
|
|
|
|
|
|
|
|
|
- protected final ByteSizeValue maxCumulationBufferCapacity;
|
|
|
- protected final int maxCompositeBufferComponents;
|
|
|
protected final RecvByteBufAllocator recvByteBufAllocator;
|
|
|
protected final int workerCount;
|
|
|
protected final ByteSizeValue receivePredictorMin;
|
|
@@ -127,8 +120,6 @@ public class Netty4Transport extends TcpTransport<Channel> {
|
|
|
super("netty", settings, threadPool, bigArrays, circuitBreakerService, namedWriteableRegistry, networkService);
|
|
|
Netty4Utils.setAvailableProcessors(EsExecutors.PROCESSORS_SETTING.get(settings));
|
|
|
this.workerCount = WORKER_COUNT.get(settings);
|
|
|
- this.maxCumulationBufferCapacity = NETTY_MAX_CUMULATION_BUFFER_CAPACITY.get(settings);
|
|
|
- this.maxCompositeBufferComponents = NETTY_MAX_COMPOSITE_BUFFER_COMPONENTS.get(settings);
|
|
|
|
|
|
// See AdaptiveReceiveBufferSizePredictor#DEFAULT_XXX for default values in netty..., we can use higher ones for us, even fixed one
|
|
|
this.receivePredictorMin = NETTY_RECEIVE_PREDICTOR_MIN.get(settings);
|