Apache
/
httpcomponents-client
mirror of https://github.com/apache/httpcomponents-client.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

first server-based test case for TSCCM 

git-svn-id: https://svn.apache.org/repos/asf/jakarta/httpcomponents/httpclient/trunk@535592 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
Roland Weber 2007-05-06 10:15:39 +00:00
parent 060a84532e
commit 79402cc117
2 changed files with 78 additions and 26 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

84
src/test/org/apache/http/impl/conn/TestTSCCMWithServer.java
View File

@ -42,6 +42,7 @@ import org.apache.http.conn.HttpRoute;
import org.apache.http.conn.ManagedClientConnection;
import org.apache.http.conn.SchemeRegistry;
import org.apache.http.conn.params.HttpConnectionManagerParams;
import org.apache.http.conn.ConnectionPoolTimeoutException;
import org.apache.http.localserver.ServerTestBase;
import org.apache.http.message.BasicHttpRequest;
import org.apache.http.params.BasicHttpParams;
@ -110,19 +111,18 @@ public class TestTSCCMWithServer extends ServerTestBase {
/**
* Tests releasing and re-using a connection after a response is read.
*/
// public void testReleaseConnection() throws Exception {
public void testSkeleton() throws Exception {
//@@@ this testcase is not yet complete
public void testReleaseConnection() throws Exception {
//public void testSkeleton() throws Exception {
HttpParams mgrpar = createManagerParams();
HttpConnectionManagerParams.setDefaultMaxConnectionsPerHost(mgrpar, 1);
HttpConnectionManagerParams.setMaxTotalConnections(mgrpar, 3);
HttpConnectionManagerParams.setMaxTotalConnections(mgrpar, 1);
ThreadSafeClientConnManager mgr = createTSCCM(mgrpar, null);
HttpHost target = getServerHttp();
final HttpHost target = getServerHttp();
final HttpRoute route = new HttpRoute(target, null, false);
final String uri = "/random/8"; // read 8 bytes
final int rsplen = 8;
final String uri = "/random/" + rsplen;
HttpRequest request =
new BasicHttpRequest("GET", uri, HttpVersion.HTTP_1_1);
@ -130,13 +130,14 @@ public class TestTSCCMWithServer extends ServerTestBase {
ManagedClientConnection conn = mgr.getConnection(route);
conn.open(route, httpContext, defaultParams);
// a new context is created for each testcase, no need to reset
httpContext.setAttribute(
HttpExecutionContext.HTTP_CONNECTION, conn);
HttpExecutionContext.HTTP_CONNECTION, conn);
httpContext.setAttribute(
HttpExecutionContext.HTTP_TARGET_HOST, target);
HttpExecutionContext.HTTP_TARGET_HOST, target);
httpContext.setAttribute(
HttpExecutionContext.HTTP_REQUEST, request);
HttpExecutionContext.HTTP_REQUEST, request);
httpExecutor.preProcess
(request, httpProcessor, httpContext);
HttpResponse response =
@ -144,18 +145,65 @@ public class TestTSCCMWithServer extends ServerTestBase {
httpExecutor.postProcess
(response, httpProcessor, httpContext);
assertEquals("wrong status in response",
assertEquals("wrong status in first response",
HttpStatus.SC_OK,
response.getStatusLine().getStatusCode());
byte[] data = EntityUtils.toByteArray(response.getEntity());
assertEquals("wrong length of first response entity",
rsplen, data.length);
// ignore data, but it must be read
// check that there is no auto-release by default
try {
// this should fail quickly, connection has not been released
mgr.getConnection(route, 10L);
fail("ConnectionPoolTimeoutException should have been thrown");
} catch (ConnectionPoolTimeoutException e) {
// expected
}
// release connection without marking for re-use
// expect the next connection obtained to be closed
mgr.releaseConnection(conn);
conn = mgr.getConnection(route);
assertFalse("connection should have been closed", conn.isOpen());
// repeat the communication, no need to prepare the request again
conn.open(route, httpContext, defaultParams);
httpContext.setAttribute(HttpExecutionContext.HTTP_CONNECTION, conn);
response = httpExecutor.execute(request, conn, httpContext);
httpExecutor.postProcess(response, httpProcessor, httpContext);
assertEquals("wrong status in second response",
HttpStatus.SC_OK,
response.getStatusLine().getStatusCode());
data = EntityUtils.toByteArray(response.getEntity());
assertEquals("wrong length of second response entity",
rsplen, data.length);
// ignore data, but it must be read
// release connection after marking it for re-use
// expect the next connection obtained to be open
conn.markReusable();
mgr.releaseConnection(conn);
conn = mgr.getConnection(route);
assertTrue("connection should have been open", conn.isOpen());
// repeat the communication, no need to prepare the request again
httpContext.setAttribute(HttpExecutionContext.HTTP_CONNECTION, conn);
response = httpExecutor.execute(request, conn, httpContext);
httpExecutor.postProcess(response, httpProcessor, httpContext);
assertEquals("wrong status in third response",
HttpStatus.SC_OK,
response.getStatusLine().getStatusCode());
data = EntityUtils.toByteArray(response.getEntity());
assertEquals("wrong length of third response entity",
rsplen, data.length);
// ignore data, but it must be read
mgr.releaseConnection(conn);
//@@@ to be checked:
// - connection is NOT re-used if not marked before release
// - connection is re-used if marked before release
// - re-using the connections works
mgr.shutdown();
}
@ -166,7 +214,7 @@ public class TestTSCCMWithServer extends ServerTestBase {
// testConnectMethodFailureRelease
// testDroppedThread
// testWriteRequestReleaseConnection, depends on execution framework
// testReleaseConnection, depends on execution framework
// + testReleaseConnection, depends on execution framework
// testResponseAutoRelease
// testMaxConnectionsPerServer - what's the server used/needed for?
// testReclaimUnusedConnection, depends on execution framework

20
src/test/org/apache/http/localserver/ServerTestBase.java
View File

@ -98,15 +98,19 @@ public abstract class ServerTestBase extends TestCase {
* This method will re-use the helper objects from a previous run
* if they are still available. For example, the local test server
* will be re-started rather than re-created.
* Tests that modify the helper objects should afterwards
* set the respective attributes to <code>null</code> to force
* re-creation for subsequent tests. Of course that shouldn't
* be done to the test server, or only after shutting that down.
* {@link #httpContext httpContext} will always be re-created.
* Tests that modify the other helper objects should afterwards
* set the respective attributes to <code>null</code> in a
* <code>finally{}</code> block to force re-creation for
* subsequent tests.
* Of course that shouldn't be done with the test server,
* or only after shutting that down.
*
* @throws Exception in case of a problem
*/
protected void setUp() throws Exception {
boolean newparams = false;
if (defaultParams == null) {
defaultParams = new BasicHttpParams(null);
HttpProtocolParams.setVersion
@ -117,6 +121,7 @@ public abstract class ServerTestBase extends TestCase {
(defaultParams, "Jakarta-HttpComponents-Test/1.1");
HttpProtocolParams.setUseExpectContinue
(defaultParams, false);
newparams = true;
}
if (supportedSchemes == null) {
@ -131,11 +136,10 @@ public abstract class ServerTestBase extends TestCase {
httpProcessor.addInterceptor(new RequestConnControl()); // optional
}
if (httpContext == null) {
httpContext = new HttpExecutionContext(null);
}
// the context is created each time, it may get modified by test cases
httpContext = new HttpExecutionContext(null);
if (httpExecutor == null) {
if ((httpExecutor == null) || newparams) {
httpExecutor = new HttpRequestExecutor(defaultParams);
}