(cxf) branch main updated: Adjust buffer sizes to accomodate changes in org.apache.hc.core5.http.config.Http1Config (#3676)

[reta.apache.org via commits]

This is an automated email from the ASF dual-hosted git repository.

reta pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/cxf.git


The following commit(s) were added to refs/heads/main by this push:
     new 9eeb9f8174f Adjust buffer sizes to accomodate changes in 
org.apache.hc.core5.http.config.Http1Config (#3676)
9eeb9f8174f is described below

commit 9eeb9f8174f83f997e43ea00753475147175e0be
Author: Andriy Redko <drr...@gmail.com>
AuthorDate: Wed Nov 4 09:54:50 2026 -0500

    Adjust buffer sizes to accomodate changes in 
org.apache.hc.core5.http.config.Http1Config (#3676)
    
    * Adjust buffer sizes to accomodate changes in 
org.apache.hc.core5.http.config.Http1Config
    
    * Address code review comments
---
 .../apache/cxf/transport/http/asyncclient/hc5/AsyncHTTPConduit.java   | 2 +-
 .../cxf/transport/http/asyncclient/hc5/AsyncHTTPConduitFactory.java   | 2 +-
 .../transport/http/asyncclient/hc5/URLConnectionAsyncHTTPConduit.java | 4 ++--
 3 files changed, 4 insertions(+), 4 deletions(-)

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 class AsyncHTTPConduit extends HttpClientHTTPConduit 
{
             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 class AsyncHTTPConduitFactory implements 
HTTPConduitFactory {
     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 class URLConnectionAsyncHTTPConduit extends 
URLConnectionHTTPConduit {
             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 @@ public class URLConnectionAsyncHTTPConduit extends 
URLConnectionHTTPConduit {
             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 {