Improved handling of early response messages by the classic client pr…

…otocol handler (corrections)
ok2c · May 26, 2020 · 39f6d69 · 39f6d69
1 parent e64bab5
commit 39f6d69
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/httpcore5/src/main/java/org/apache/hc/core5/http/impl/io/HttpRequestExecutor.java b/httpcore5/src/main/java/org/apache/hc/core5/http/impl/io/HttpRequestExecutor.java
@@ -74,7 +74,7 @@
 public class HttpRequestExecutor {
 
     public static final Timeout DEFAULT_WAIT_FOR_CONTINUE = Timeout.ofSeconds(3);
-    public static final Timeout DEFAULT_WAIT_FOR_EARLY_RESPONSE = Timeout.ofMilliseconds(5);
+    public static final Timeout DEFAULT_WAIT_FOR_EARLY_RESPONSE = Timeout.ofMilliseconds(50);
     public static final long LARGE_MESSAGE_LEN = 64 * 1024;
 
     private final Timeout waitForContinue;
@@ -162,7 +162,11 @@ public ClassicHttpResponse execute(
                 final Header expect = request.getFirstHeader(HttpHeaders.EXPECT);
                 expectContinue = expect != null && HeaderElements.CONTINUE.equalsIgnoreCase(expect.getValue());
                 if (!expectContinue) {
-                    if (entity.getContentLength() > LARGE_MESSAGE_LEN && conn.isDataAvailable(waitForEarlyResponse)) {
+                    final boolean largeEntity = entity.getContentLength() > LARGE_MESSAGE_LEN;
+                    if (largeEntity) {
+                        conn.flush();
+                    }
+                    if (largeEntity && conn.isDataAvailable(waitForEarlyResponse)) {
                         conn.terminateRequest(request);
                     } else {
                         conn.sendRequestEntity(request);