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

merge branch jetty-9.4.x into jetty-10.0.x 

Signed-off-by: Ludovic Orban <lorban@bitronix.be>
This commit is contained in:
Ludovic Orban 2020-11-30 18:49:37 +01:00
parent 1333bbc55c df3a32601a
commit 1092085c8d
1 changed files with 20 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
jetty-http2/http2-http-client-transport/src/test/java/org/eclipse/jetty/http2/client/http/MaxConcurrentStreamsTest.java
View File

@ -37,6 +37,7 @@ import org.eclipse.jetty.client.AbstractConnectionPool;
import org.eclipse.jetty.client.HttpClient; import org.eclipse.jetty.client.HttpClient;
import org.eclipse.jetty.client.HttpDestination; import org.eclipse.jetty.client.HttpDestination;
import org.eclipse.jetty.client.HttpResponseException; import org.eclipse.jetty.client.HttpResponseException;
import org.eclipse.jetty.client.MultiplexConnectionPool;
import org.eclipse.jetty.client.api.ContentResponse; import org.eclipse.jetty.client.api.ContentResponse;
import org.eclipse.jetty.client.api.Response; import org.eclipse.jetty.client.api.Response;
import org.eclipse.jetty.client.api.Result; import org.eclipse.jetty.client.api.Result;
@ -336,12 +337,28 @@ public class MaxConcurrentStreamsTest extends AbstractTest
} }
}); });
int parallelism = 4;
int runs = 1;
int iterations = 32;
client.setMaxConnectionsPerDestination(32768); client.setMaxConnectionsPerDestination(32768);
client.setMaxRequestsQueuedPerDestination(1024 * 1024); client.setMaxRequestsQueuedPerDestination(1024 * 1024);
client.getTransport().setConnectionPoolFactory(destination ->
{
try
{
MultiplexConnectionPool pool = new MultiplexConnectionPool(destination, client.getMaxConnectionsPerDestination(), false, destination, 1);
pool.preCreateConnections(parallelism * 2).get();
return pool;
}
catch (Exception e)
{
throw new RuntimeException(e);
}
});
// Prime the destination to pre-create connections.
client.GET("http://localhost:" + connector.getLocalPort());
int parallelism = 16;
int runs = 1;
int iterations = 256;
int total = parallelism * runs * iterations; int total = parallelism * runs * iterations;
CountDownLatch latch = new CountDownLatch(total); CountDownLatch latch = new CountDownLatch(total);
Queue<Result> failures = new ConcurrentLinkedQueue<>(); Queue<Result> failures = new ConcurrentLinkedQueue<>();