From 70d57b75689e06a286715818968b069e01ed6648 Mon Sep 17 00:00:00 2001 From: Jason Tedor Date: Thu, 23 Feb 2017 09:13:29 -0500 Subject: [PATCH] Revert "Keep the pipeline handler queue small initially" This reverts commit 30cdefc714c6223cc3ae2391aedbd356fa66cf88. --- .../http/netty4/pipelining/HttpPipeliningHandler.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/modules/transport-netty4/src/main/java/org/elasticsearch/http/netty4/pipelining/HttpPipeliningHandler.java b/modules/transport-netty4/src/main/java/org/elasticsearch/http/netty4/pipelining/HttpPipeliningHandler.java index 6102bf1ab9d84..4796ff23bc127 100644 --- a/modules/transport-netty4/src/main/java/org/elasticsearch/http/netty4/pipelining/HttpPipeliningHandler.java +++ b/modules/transport-netty4/src/main/java/org/elasticsearch/http/netty4/pipelining/HttpPipeliningHandler.java @@ -33,8 +33,7 @@ */ public class HttpPipeliningHandler extends ChannelDuplexHandler { - // we use a priority queue so that responses are ordered by their sequence number - private final PriorityQueue holdingQueue; + private static final int INITIAL_EVENTS_HELD = 8; private final int maxEventsHeld; @@ -46,6 +45,9 @@ public class HttpPipeliningHandler extends ChannelDuplexHandler { private int readSequence; private int writeSequence; + // we use a priority queue so that responses are ordered by their sequence number + private final PriorityQueue holdingQueue; + /** * Construct a new pipelining handler; this handler should be used downstream of HTTP decoding/aggregation. * @@ -54,7 +56,7 @@ public class HttpPipeliningHandler extends ChannelDuplexHandler { */ public HttpPipeliningHandler(final int maxEventsHeld) { this.maxEventsHeld = maxEventsHeld; - this.holdingQueue = new PriorityQueue<>(1); + this.holdingQueue = new PriorityQueue<>(INITIAL_EVENTS_HELD); } @Override