"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "httpclient/src/test/java/org/apache/http/impl/client/integration/TestIdleConnectionEviction.java" between
httpcomponents-client-4.5.9-src.tar.gz and httpcomponents-client-4.5.10-src.tar.gz

About: HttpComponents is an Apache project responsible for creating and maintaining a toolset of low level Java components focused on HTTP and associated protocols. Java sources.

TestIdleConnectionEviction.java  (httpcomponents-client-4.5.9-src):TestIdleConnectionEviction.java  (httpcomponents-client-4.5.10-src)
skipping to change at line 30 skipping to change at line 30
* *
* This software consists of voluntary contributions made by many * This software consists of voluntary contributions made by many
* individuals on behalf of the Apache Software Foundation. For more * individuals on behalf of the Apache Software Foundation. For more
* information on the Apache Software Foundation, please see * information on the Apache Software Foundation, please see
* <http://www.apache.org/>. * <http://www.apache.org/>.
* *
*/ */
package org.apache.http.impl.client.integration; package org.apache.http.impl.client.integration;
import java.net.URI;
import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeUnit;
import org.apache.http.HttpHost; import org.apache.http.HttpHost;
import org.apache.http.HttpResponse;
import org.apache.http.client.ClientProtocolException; import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient; import org.apache.http.client.methods.CloseableHttpResponse;
import org.apache.http.client.methods.HttpGet; import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpUriRequest; import org.apache.http.impl.client.CloseableHttpClient;
import org.apache.http.impl.client.IdleConnectionEvictor; import org.apache.http.impl.client.IdleConnectionEvictor;
import org.apache.http.localserver.LocalServerTestBase; import org.apache.http.localserver.LocalServerTestBase;
import org.apache.http.util.EntityUtils; import org.apache.http.util.EntityUtils;
import org.junit.Test; import org.junit.Test;
public class TestIdleConnectionEviction extends LocalServerTestBase { public class TestIdleConnectionEviction extends LocalServerTestBase {
@Test @Test
public void testIdleConnectionEviction() throws Exception { public void testIdleConnectionEviction() throws Exception {
this.connManager.setDefaultMaxPerRoute(10); this.connManager.setDefaultMaxPerRoute(10);
this.connManager.setMaxTotal(50); this.connManager.setMaxTotal(50);
final HttpHost target = start(); final HttpHost target = start();
final IdleConnectionEvictor idleConnectionMonitor = new IdleConnectionEv ictor( final IdleConnectionEvictor idleConnectionMonitor = new IdleConnectionEv ictor(
this.connManager, 50, TimeUnit.MILLISECONDS); this.connManager, 50, TimeUnit.MILLISECONDS);
idleConnectionMonitor.start(); idleConnectionMonitor.start();
final HttpGet httpget = new HttpGet("/random/1024"); final URI requestUri = new URI("/random/1024");
final WorkerThread[] workers = new WorkerThread[5]; final WorkerThread[] workers = new WorkerThread[5];
for (int i = 0; i < workers.length; i++) { for (int i = 0; i < workers.length; i++) {
workers[i] = new WorkerThread(httpclient, target, httpget, 200); workers[i] = new WorkerThread(httpclient, target, requestUri, 200);
} }
for (final WorkerThread worker : workers) { for (final WorkerThread worker : workers) {
worker.start(); worker.start();
} }
for (final WorkerThread worker : workers) { for (final WorkerThread worker : workers) {
worker.join(); worker.join();
final Exception ex = worker.getException(); final Exception ex = worker.getException();
if (ex != null) { if (ex != null) {
throw ex; throw ex;
} }
} }
idleConnectionMonitor.shutdown(); idleConnectionMonitor.shutdown();
} }
static class WorkerThread extends Thread { static class WorkerThread extends Thread {
private final HttpClient httpclient; private final CloseableHttpClient httpclient;
private final HttpHost target; private final HttpHost target;
private final HttpUriRequest request; private final URI requestUri;
private final int count; private final int count;
private volatile Exception ex; private volatile Exception ex;
public WorkerThread( public WorkerThread(
final HttpClient httpclient, final CloseableHttpClient httpclient,
final HttpHost target, final HttpHost target,
final HttpUriRequest request, final URI requestUri,
final int count) { final int count) {
super(); super();
this.httpclient = httpclient; this.httpclient = httpclient;
this.target = target; this.target = target;
this.request = request; this.requestUri = requestUri;
this.count = count; this.count = count;
} }
@Override @Override
public void run() { public void run() {
try { try {
for (int i = 0; i < this.count; i++) { for (int i = 0; i < this.count; i++) {
final HttpResponse response = this.httpclient.execute(this.t final HttpGet httpget = new HttpGet(this.requestUri);
arget, this.request); final CloseableHttpResponse response = this.httpclient.execu
final int status = response.getStatusLine().getStatusCode(); te(this.target, httpget);
if (status != 200) { try {
this.request.abort(); final int status = response.getStatusLine().getStatusCod
throw new ClientProtocolException("Unexpected status cod e();
e: " + status); if (status != 200) {
throw new ClientProtocolException("Unexpected status
code: " + status);
}
EntityUtils.consume(response.getEntity());
Thread.sleep(10);
} finally {
response.close();
} }
EntityUtils.consume(response.getEntity());
Thread.sleep(10);
} }
} catch (final Exception ex) { } catch (final Exception ex) {
this.ex = ex; this.ex = ex;
} }
} }
public Exception getException() { public Exception getException() {
return ex; return ex;
} }
 End of changes. 13 change blocks. 
19 lines changed or deleted 24 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)