throwaway ContentSender if reset fails

Signed-off-by: Ludovic Orban <[email protected]>
jetty · Aug 27, 2024 · b0ccac3 · b0ccac3
1 parent 457bd7a
commit b0ccac3
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/transport/HttpSender.java b/jetty-core/jetty-client/src/main/java/org/eclipse/jetty/client/transport/HttpSender.java
@@ -49,7 +49,7 @@ public abstract class HttpSender
 {
     private static final Logger LOG = LoggerFactory.getLogger(HttpSender.class);
 
-    private final ContentSender contentSender = new ContentSender();
+    private ContentSender contentSender = new ContentSender();
     private final AtomicReference<RequestState> requestState = new AtomicReference<>(RequestState.QUEUED);
     private final AtomicReference<Throwable> failure = new AtomicReference<>();
     private final HttpChannel channel;
@@ -310,7 +310,8 @@ private void terminateRequest(HttpExchange exchange, Throwable failure, Result r
 
     protected void reset()
     {
-        contentSender.reset();
+        if (!contentSender.reset())
+            contentSender = new ContentSender();
     }
 
     protected void dispose()