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-9.4.x' into 'master'.

This commit is contained in:
Simone Bordet 2016-08-14 23:29:58 +02:00
parent 0e28febfd7 13f638f710
commit a99be6de1c
1 changed files with 12 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -52,7 +52,7 @@ public class MaxConcurrentStreamsTest extends AbstractTest
@Test
public void testOneConcurrentStream() throws Exception
{
long sleep = 2000;
long sleep = 1000;
start(1, new AbstractHandler()
{
@Override
@ -65,8 +65,7 @@ public class MaxConcurrentStreamsTest extends AbstractTest
});
client.setMaxConnectionsPerDestination(1);
// Prime the connection so that the maxConcurrentStream setting arrives to the client.
client.newRequest("localhost", connector.getLocalPort()).path("/prime").send();
primeConnection();
CountDownLatch latch = new CountDownLatch(2);
@ -108,8 +107,7 @@ public class MaxConcurrentStreamsTest extends AbstractTest
});
client.setMaxConnectionsPerDestination(1);
// Prime the connection so that the maxConcurrentStream setting arrives to the client.
client.newRequest("localhost", connector.getLocalPort()).path("/prime").send();
primeConnection();
// Send requests up to the max allowed.
for (int i = 0; i < maxStreams; ++i)
@ -153,8 +151,7 @@ public class MaxConcurrentStreamsTest extends AbstractTest
});
client.setMaxConnectionsPerDestination(1);
// Prime the connection so that the maxConcurrentStream setting arrives to the client.
client.newRequest("localhost", connector.getLocalPort()).path("/prime").send();
primeConnection();
// Send a request that is aborted while queued.
client.newRequest("localhost", connector.getLocalPort())
@ -197,6 +194,14 @@ public class MaxConcurrentStreamsTest extends AbstractTest
Assert.assertTrue(latch.await(maxConcurrent * sleep / 2, TimeUnit.MILLISECONDS));
}
private void primeConnection() throws Exception
{
// Prime the connection so that the maxConcurrentStream setting arrives to the client.
client.newRequest("localhost", connector.getLocalPort()).path("/prime").send();
// Wait for the server to clean up and remove the stream that primes the connection.
sleep(1000);
}
private void sleep(long time)
{
try