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

Port jetty-client IdleTimeoutTest to jetty-9

This commit is contained in:
Jan Bartel 2013-01-25 14:33:09 +11:00
parent 1843976b30
commit ae644581dd
1 changed files with 6 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
jetty-client/src/test/java/org/eclipse/jetty/client/IdleTimeoutTest.java
View File

@ -21,6 +21,8 @@ package org.eclipse.jetty.client;
import java.util.concurrent.CountDownLatch; import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import org.eclipse.jetty.client.api.ContentResponse;
import org.eclipse.jetty.toolchain.test.annotation.Slow;
import org.junit.Assert; import org.junit.Assert;
import org.junit.Ignore; import org.junit.Ignore;
import org.junit.Test; import org.junit.Test;
@ -35,15 +37,13 @@ public class IdleTimeoutTest
{ {
public int _repetitions = 30; public int _repetitions = 30;
@Slow
@Ignore @Ignore
@Test
public void testIdleTimeoutOnBlockingConnector() throws Exception public void testIdleTimeoutOnBlockingConnector() throws Exception
{ {
/* TODO port to new client
final HttpClient client = new HttpClient(); final HttpClient client = new HttpClient();
client.setMaxConnectionsPerAddress(4); client.setMaxConnectionsPerDestination(4);
client.setConnectorType(HttpClient.CONNECTOR_SOCKET);
client.setTimeout(TimeUnit.SECONDS.toMillis(86400)); // very long timeout on data
client.setIdleTimeout(500); // very short idle timeout client.setIdleTimeout(500); // very short idle timeout
client.start(); client.start();
@ -57,10 +57,7 @@ public class IdleTimeoutTest
{ {
for (int i=0; i<_repetitions; i++) for (int i=0; i<_repetitions; i++)
{ {
ContentExchange exchange = new ContentExchange(); ContentResponse response = client.GET("http://www.google.com/?i="+i);
exchange.setURL("http://www.google.com/?i="+i);
client.send(exchange);
exchange.waitForDone();
counter.countDown(); counter.countDown();
System.err.println(counter.getCount()); System.err.println(counter.getCount());
Thread.sleep(1000); //wait long enough for idle timeout to expire Thread.sleep(1000); //wait long enough for idle timeout to expire
@ -76,8 +73,5 @@ public class IdleTimeoutTest
runner.start(); runner.start();
if (!counter.await(80, TimeUnit.SECONDS)) if (!counter.await(80, TimeUnit.SECONDS))
Assert.fail("Test did not complete in time"); Assert.fail("Test did not complete in time");
*/
} }
} }