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

#10543 handle review comments 

Signed-off-by: Ludovic Orban <lorban@bitronix.be>
This commit is contained in:
Ludovic Orban 2023-09-22 10:43:19 +02:00
parent 1286f91b1c
commit b25dc8183b
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
jetty-core/jetty-tests/jetty-test-client-transports/src/test/java/org/eclipse/jetty/test/client/transport/HttpClientStreamTest.java
View File

@ -1201,13 +1201,14 @@ public class HttpClientStreamTest extends AbstractTest
@ParameterizedTest @ParameterizedTest
@MethodSource("transports") @MethodSource("transports")
@Tag("DisableLeakTracking:server") @Tag("DisableLeakTracking:server")
public void testUploadWithRetainedData(Transport transport) throws Exception public void testHttpStreamConsumeAvailableUponClientTimeout(Transport transport) throws Exception
{ {
start(transport, new Handler.Abstract() start(transport, new Handler.Abstract()
{ {
@Override @Override
public boolean handle(Request request, org.eclipse.jetty.server.Response response, Callback callback) public boolean handle(Request request, org.eclipse.jetty.server.Response response, Callback callback)
{ {
// Consume the uploaded data very slowly to make the client timeout.
new Runnable() new Runnable()
{ {
@Override @Override
@ -1251,6 +1252,8 @@ public class HttpClientStreamTest extends AbstractTest
} }
}); });
// Upload a large amount of data to the server with a timeout small enough
// that the client will timeout during the transfer.
byte[] data = new byte[16 * 1024 * 1024]; byte[] data = new byte[16 * 1024 * 1024];
new Random().nextBytes(data); new Random().nextBytes(data);
ByteBufferRequestContent content = new ByteBufferRequestContent(ByteBuffer.wrap(data)); ByteBufferRequestContent content = new ByteBufferRequestContent(ByteBuffer.wrap(data));