Eclipse
/
jetty.project
mirror of https://github.com/jetty/jetty.project.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Merged branch 'jetty-10.0.x' into 'jetty-11.0.x'. 

Signed-off-by: Simone Bordet <simone.bordet@gmail.com>
This commit is contained in:
Simone Bordet 2024-05-13 09:16:17 +02:00
parent b7765730f4 1995b5ea59
commit ab3c6e91e3
No known key found for this signature in database
GPG Key ID: 1677D141BCF3584D
1 changed files with 1 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
jetty-client/src/main/java/org/eclipse/jetty/client/http/HttpSenderOverHTTP.java
View File

@ -39,7 +39,6 @@ public class HttpSenderOverHTTP extends HttpSender
private final IteratingCallback headersCallback = new HeadersCallback(); private final IteratingCallback headersCallback = new HeadersCallback();
private final IteratingCallback contentCallback = new ContentCallback(); private final IteratingCallback contentCallback = new ContentCallback();
private final HttpGenerator generator = new HttpGenerator(); private final HttpGenerator generator = new HttpGenerator();
private HttpExchange exchange;
private MetaData.Request metaData; private MetaData.Request metaData;
private ByteBuffer contentBuffer; private ByteBuffer contentBuffer;
private boolean lastContent; private boolean lastContent;
@ -62,7 +61,6 @@ public class HttpSenderOverHTTP extends HttpSender
{ {
try try
{ {
this.exchange = exchange;
this.contentBuffer = contentBuffer; this.contentBuffer = contentBuffer;
this.lastContent = lastContent; this.lastContent = lastContent;
this.callback = callback; this.callback = callback;
@ -91,7 +89,6 @@ public class HttpSenderOverHTTP extends HttpSender
{ {
try try
{ {
this.exchange = exchange;
this.contentBuffer = contentBuffer; this.contentBuffer = contentBuffer;
this.lastContent = lastContent; this.lastContent = lastContent;
this.callback = callback; this.callback = callback;
@ -157,6 +154,7 @@ public class HttpSenderOverHTTP extends HttpSender
protected Action process() throws Exception protected Action process() throws Exception
{ {
HttpClient httpClient = getHttpChannel().getHttpDestination().getHttpClient(); HttpClient httpClient = getHttpChannel().getHttpDestination().getHttpClient();
HttpExchange exchange = getHttpExchange();
ByteBufferPool byteBufferPool = httpClient.getByteBufferPool(); ByteBufferPool byteBufferPool = httpClient.getByteBufferPool();
boolean useDirectByteBuffers = httpClient.isUseOutputDirectByteBuffers(); boolean useDirectByteBuffers = httpClient.isUseOutputDirectByteBuffers();
while (true) while (true)