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

Improved test by making requests carry a unique identifier.

This commit is contained in:
Simone Bordet 2016-02-29 11:58:08 +01:00
parent 65b11654c5
commit 8aa3207164
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
tests/test-http-client-transport/src/test/java/org/eclipse/jetty/http/client/HttpClientLoadTest.java
View File

@ -71,6 +71,7 @@ import static org.junit.Assert.assertThat;
public class HttpClientLoadTest extends AbstractTest
{
private final Logger logger = Log.getLogger(HttpClientLoadTest.class);
private final AtomicLong requestCount = new AtomicLong();
private final AtomicLong connectionLeaks = new AtomicLong();
public HttpClientLoadTest(Transport transport)
@ -236,7 +237,7 @@ public class HttpClientLoadTest extends AbstractTest
logger.info("{} requests in {} ms, {} req/s", iterations, elapsed, elapsed > 0 ? iterations * 1000 / elapsed : -1);
for (String failure : failures)
System.err.println("FAILED: "+failure);
logger.info("FAILED: {}", failure);
Assert.assertTrue(failures.toString(), failures.isEmpty());
}
@ -267,8 +268,10 @@ public class HttpClientLoadTest extends AbstractTest
private void test(String scheme, String host, String method, boolean clientClose, boolean serverClose, int contentLength, final boolean checkContentLength, final CountDownLatch latch, final List<String> failures)
{
long requestId = requestCount.incrementAndGet();
Request request = client.newRequest(host, connector.getLocalPort())
.scheme(scheme)
.path("/" + requestId)
.method(method);
if (clientClose)
@ -326,7 +329,8 @@ public class HttpClientLoadTest extends AbstractTest
latch.countDown();
}
});
await(requestLatch, 5, TimeUnit.SECONDS);
if (!await(requestLatch, 5, TimeUnit.SECONDS))
logger.warn("Request {} took too long", requestId);
}
private boolean await(CountDownLatch latch, long time, TimeUnit unit)