diff --git a/rt/transports/http-hc5/src/main/java/org/apache/cxf/transport/http/asyncclient/hc5/AsyncHTTPConduit.java b/rt/transports/http-hc5/src/main/java/org/apache/cxf/transport/http/asyncclient/hc5/AsyncHTTPConduit.java index 2181e67dccb..a773347bd84 100644 --- a/rt/transports/http-hc5/src/main/java/org/apache/cxf/transport/http/asyncclient/hc5/AsyncHTTPConduit.java +++ b/rt/transports/http-hc5/src/main/java/org/apache/cxf/transport/http/asyncclient/hc5/AsyncHTTPConduit.java @@ -313,7 +313,7 @@ public AsyncWrappedOutputStream(Message message, boolean needToCacheRequest, boo basicEntity = (MutableHttpEntity)entity.getEntity(); basicEntity.setChunked(isChunking); - final int bufSize = csPolicy.getChunkLength() > 0 ? csPolicy.getChunkLength() : 16320; + final int bufSize = csPolicy.getChunkLength() > 0 ? csPolicy.getChunkLength() : 32 * 1024; inbuf = new SharedInputBuffer(bufSize); outbuf = new SharedOutputBuffer(bufSize); isAsync = outMessage != null && outMessage.getExchange() != null diff --git a/rt/transports/http-hc5/src/main/java/org/apache/cxf/transport/http/asyncclient/hc5/AsyncHTTPConduitFactory.java b/rt/transports/http-hc5/src/main/java/org/apache/cxf/transport/http/asyncclient/hc5/AsyncHTTPConduitFactory.java index 63f9eb0a62c..1a69cc562a0 100644 --- a/rt/transports/http-hc5/src/main/java/org/apache/cxf/transport/http/asyncclient/hc5/AsyncHTTPConduitFactory.java +++ b/rt/transports/http-hc5/src/main/java/org/apache/cxf/transport/http/asyncclient/hc5/AsyncHTTPConduitFactory.java @@ -159,7 +159,7 @@ public PoolingAsyncClientConnectionManager getConnectionManager() { private int soTimeout = IOReactorConfig.DEFAULT.getSoTimeout().toMillisecondsIntBound(); private boolean soKeepalive = IOReactorConfig.DEFAULT.isSoKeepAlive(); private boolean tcpNoDelay = true; - private int bufferSize = 16 * 1024; + private int bufferSize = 32 * 1024; // Http1Config::INIT_BUF_SIZE AsyncHTTPConduitFactory() { super(); diff --git a/rt/transports/http-hc5/src/main/java/org/apache/cxf/transport/http/asyncclient/hc5/URLConnectionAsyncHTTPConduit.java b/rt/transports/http-hc5/src/main/java/org/apache/cxf/transport/http/asyncclient/hc5/URLConnectionAsyncHTTPConduit.java index d6767317402..71d1539dbfe 100644 --- a/rt/transports/http-hc5/src/main/java/org/apache/cxf/transport/http/asyncclient/hc5/URLConnectionAsyncHTTPConduit.java +++ b/rt/transports/http-hc5/src/main/java/org/apache/cxf/transport/http/asyncclient/hc5/URLConnectionAsyncHTTPConduit.java @@ -310,7 +310,7 @@ public AsyncWrappedOutputStream(Message message, boolean needToCacheRequest, boo basicEntity = (MutableHttpEntity)entity.getEntity(); basicEntity.setChunked(isChunking); - final int bufSize = csPolicy.getChunkLength() > 0 ? csPolicy.getChunkLength() : 16320; + final int bufSize = csPolicy.getChunkLength() > 0 ? csPolicy.getChunkLength() : 32 * 1024; inbuf = new SharedInputBuffer(bufSize); outbuf = new SharedOutputBuffer(bufSize); isAsync = outMessage != null && outMessage.getExchange() != null @@ -885,7 +885,7 @@ protected void setupNewConnection(String newURL) throws IOException { sslURL = null; //reset the buffers - int bufSize = csPolicy.getChunkLength() > 0 ? csPolicy.getChunkLength() : 16320; + int bufSize = csPolicy.getChunkLength() > 0 ? csPolicy.getChunkLength() : 32 * 1024; inbuf = new SharedInputBuffer(bufSize); outbuf = new SharedOutputBuffer(bufSize); try {