You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hc.apache.org by ol...@apache.org on 2010/11/24 17:17:45 UTC
svn commit: r1038670 - in
/httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http:
impl/nio/client/ impl/nio/conn/ impl/nio/pool/ nio/client/
Author: olegk
Date: Wed Nov 24 16:17:45 2010
New Revision: 1038670
URL: http://svn.apache.org/viewvc?rev=1038670&view=rev
Log:
TABS -> SPACES
Modified:
httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/BasicAsyncHttpClient.java
httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/HttpExchangeImpl.java
httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/InternalClientEventDispatch.java
httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/InternalRequestExecutionHandler.java
httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/BasicIOSessionManager.java
httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/BasicManagedIOSession.java
httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/HttpSessionPool.java
httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/LoggingIOSession.java
httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/Wire.java
httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/pool/PoolEntry.java
httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/pool/PoolEntryCallback.java
httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/pool/SessionPool.java
httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/nio/client/AsyncHttpClient.java
httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/nio/client/HttpExchange.java
Modified: httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/BasicAsyncHttpClient.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/BasicAsyncHttpClient.java?rev=1038670&r1=1038669&r2=1038670&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/BasicAsyncHttpClient.java (original)
+++ httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/BasicAsyncHttpClient.java Wed Nov 24 16:17:45 2010
@@ -62,10 +62,10 @@ public class BasicAsyncHttpClient implem
private final Log log;
private final HttpParams params;
private final ConnectingIOReactor ioReactor;
- private final IOSessionManager<HttpRoute> sessmrg;
-
+ private final IOSessionManager<HttpRoute> sessmrg;
+
private Thread reactorThread;
-
+
public BasicAsyncHttpClient(
final ConnectingIOReactor ioReactor,
final IOSessionManager<HttpRoute> sessmrg,
@@ -80,7 +80,7 @@ public class BasicAsyncHttpClient implem
this.ioReactor = ioReactor;
this.sessmrg = sessmrg;
}
-
+
public BasicAsyncHttpClient(final HttpParams params) throws IOReactorException {
super();
this.log = LogFactory.getLog(getClass());
@@ -92,7 +92,7 @@ public class BasicAsyncHttpClient implem
this.ioReactor = new DefaultConnectingIOReactor(2, this.params);
this.sessmrg = new BasicIOSessionManager(this.ioReactor);
}
-
+
protected HttpParams createDefaultHttpParams() {
HttpParams params = new SyncBasicHttpParams();
params
@@ -103,7 +103,7 @@ public class BasicAsyncHttpClient implem
.setParameter(CoreProtocolPNames.USER_AGENT, "HttpComponents/1.1");
return params;
}
-
+
protected HttpProcessor createHttpProcessor() {
HttpRequestInterceptor[] interceptors = new HttpRequestInterceptor[] {
new RequestContent(),
@@ -112,14 +112,14 @@ public class BasicAsyncHttpClient implem
new RequestUserAgent(),
new RequestExpectContinue()
};
- ImmutableHttpProcessor httpProcessor = new ImmutableHttpProcessor(interceptors);
+ ImmutableHttpProcessor httpProcessor = new ImmutableHttpProcessor(interceptors);
return httpProcessor;
}
-
+
protected ConnectionReuseStrategy createConnectionReuseStrategy() {
return new DefaultConnectionReuseStrategy();
}
-
+
public IOSessionManager<HttpRoute> getSessionManager() {
return this.sessmrg;
}
@@ -137,11 +137,11 @@ public class BasicAsyncHttpClient implem
this.log.error("I/O reactor terminated abnormally", ex);
}
}
-
+
public IOReactorStatus getStatus() {
return this.ioReactor.getStatus();
}
-
+
public synchronized void start() {
this.reactorThread = new Thread() {
@@ -149,7 +149,7 @@ public class BasicAsyncHttpClient implem
public void run() {
doExecute();
}
-
+
};
this.reactorThread.start();
}
@@ -165,10 +165,10 @@ public class BasicAsyncHttpClient implem
this.reactorThread.join();
}
}
-
+
public HttpExchange execute(final HttpHost target, final HttpRequest request) {
HttpRoute route = new HttpRoute(target);
return new HttpExchangeImpl(request, route, null, this.sessmrg);
}
-
+
}
Modified: httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/HttpExchangeImpl.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/HttpExchangeImpl.java?rev=1038670&r1=1038669&r2=1038670&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/HttpExchangeImpl.java (original)
+++ httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/HttpExchangeImpl.java Wed Nov 24 16:17:45 2010
@@ -47,7 +47,7 @@ class HttpExchangeImpl implements HttpEx
private final BasicFuture<HttpResponse> responseFuture;
private ManagedIOSession managedSession;
-
+
public HttpExchangeImpl(
final HttpRequest request,
final HttpRoute route,
@@ -62,11 +62,11 @@ class HttpExchangeImpl implements HttpEx
public boolean isCompleted() {
return this.responseFuture.isDone();
}
-
+
public HttpRequest getRequest() {
return this.request;
}
-
+
public HttpResponse awaitResponse() throws ExecutionException, InterruptedException {
return this.responseFuture.get();
}
@@ -77,7 +77,7 @@ class HttpExchangeImpl implements HttpEx
}
this.responseFuture.completed(response);
}
-
+
public synchronized void cancel() {
this.sessionFuture.cancel(true);
if (this.managedSession != null) {
@@ -92,15 +92,15 @@ class HttpExchangeImpl implements HttpEx
iosession.setAttribute(InternalRequestExecutionHandler.HTTP_EXCHANGE, this);
iosession.setEvent(SelectionKey.OP_WRITE);
}
-
+
private synchronized void requestFailed(final Exception ex) {
this.responseFuture.failed(ex);
}
-
+
private synchronized void requestCancelled() {
this.responseFuture.cancel(true);
}
-
+
class InternalFutureCallback implements FutureCallback<ManagedIOSession> {
public void completed(final ManagedIOSession session) {
@@ -110,11 +110,11 @@ class HttpExchangeImpl implements HttpEx
public void failed(final Exception ex) {
requestFailed(ex);
}
-
+
public void cancelled() {
- requestCancelled();
+ requestCancelled();
}
}
-
+
}
Modified: httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/InternalClientEventDispatch.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/InternalClientEventDispatch.java?rev=1038670&r1=1038669&r2=1038670&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/InternalClientEventDispatch.java (original)
+++ httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/InternalClientEventDispatch.java Wed Nov 24 16:17:45 2010
@@ -40,11 +40,11 @@ class InternalClientEventDispatch extend
private static final String HEADERS = "org.apache.http.headers";
private static final String WIRE = "org.apache.http.wire";
-
+
private Log log;
-
+
InternalClientEventDispatch(
- final NHttpClientHandler handler,
+ final NHttpClientHandler handler,
final HttpParams params) {
super(handler, params);
this.log = LogFactory.getLog(getClass());
@@ -60,11 +60,11 @@ class InternalClientEventDispatch extend
}
if (headerlog.isDebugEnabled()) {
return new LoggingNHttpClientConnection(
- headerlog,
+ headerlog,
session,
createHttpResponseFactory(),
this.allocator,
- this.params);
+ this.params);
} else {
return super.createConnection(session);
}
@@ -109,5 +109,5 @@ class InternalClientEventDispatch extend
}
super.timeout(session);
}
-
+
}
\ No newline at end of file
Modified: httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/InternalRequestExecutionHandler.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/InternalRequestExecutionHandler.java?rev=1038670&r1=1038669&r2=1038670&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/InternalRequestExecutionHandler.java (original)
+++ httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/client/InternalRequestExecutionHandler.java Wed Nov 24 16:17:45 2010
@@ -39,7 +39,7 @@ import org.apache.http.protocol.HttpCont
class InternalRequestExecutionHandler implements NHttpRequestExecutionHandler {
protected static final String HTTP_EXCHANGE = "http.async.http-exchange";
-
+
InternalRequestExecutionHandler() {
super();
}
@@ -62,7 +62,7 @@ class InternalRequestExecutionHandler im
return null;
}
}
-
+
public ConsumingNHttpEntity responseEntity(
final HttpResponse response, final HttpContext context) throws IOException {
return new BufferingNHttpEntity(
Modified: httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/BasicIOSessionManager.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/BasicIOSessionManager.java?rev=1038670&r1=1038669&r2=1038670&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/BasicIOSessionManager.java (original)
+++ httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/BasicIOSessionManager.java Wed Nov 24 16:17:45 2010
@@ -110,7 +110,7 @@ public class BasicIOSessionManager imple
public PoolStats getStats(final HttpRoute route) {
return this.pool.getStats(route);
}
-
+
public void setTotalMax(int max) {
this.pool.setTotalMax(max);
}
@@ -122,28 +122,28 @@ public class BasicIOSessionManager imple
public void setMaxPerHost(final HttpRoute route, int max) {
this.pool.setMaxPerHost(route, max);
}
-
+
public synchronized void shutdown() {
- this.log.debug("I/O session manager shut down");
+ this.log.debug("I/O session manager shut down");
this.pool.shutdown();
}
class InternalPoolEntryCallback implements PoolEntryCallback<HttpRoute> {
private final BasicFuture<ManagedIOSession> future;
-
+
public InternalPoolEntryCallback(
final BasicFuture<ManagedIOSession> future) {
super();
this.future = future;
}
-
+
public void completed(final PoolEntry<HttpRoute> entry) {
if (log.isDebugEnabled()) {
log.debug("I/O session allocated: " + entry);
}
BasicManagedIOSession result = new BasicManagedIOSession(
- BasicIOSessionManager.this,
+ BasicIOSessionManager.this,
entry);
if (!this.future.completed(result)) {
pool.release(entry, true);
Modified: httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/BasicManagedIOSession.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/BasicManagedIOSession.java?rev=1038670&r1=1038669&r2=1038670&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/BasicManagedIOSession.java (original)
+++ httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/BasicManagedIOSession.java Wed Nov 24 16:17:45 2010
@@ -56,7 +56,7 @@ public class BasicManagedIOSession imple
protected PoolEntry<HttpRoute> getEntry() {
return this.entry;
}
-
+
public IOSession getSession() {
if (this.released) {
return null;
@@ -136,5 +136,5 @@ public class BasicManagedIOSession imple
}
return buffer.toString();
}
-
+
}
Modified: httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/HttpSessionPool.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/HttpSessionPool.java?rev=1038670&r1=1038669&r2=1038670&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/HttpSessionPool.java (original)
+++ httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/HttpSessionPool.java Wed Nov 24 16:17:45 2010
@@ -40,7 +40,7 @@ class HttpSessionPool extends SessionPoo
public HttpSessionPool(final ConnectingIOReactor ioreactor) {
super(ioreactor, new InternalRouteResolver(), 20, 50);
}
-
+
static class InternalRouteResolver implements RouteResolver<HttpRoute> {
public SocketAddress resolveLocalAddress(final HttpRoute route) {
@@ -53,5 +53,5 @@ class HttpSessionPool extends SessionPoo
}
}
-
+
}
Modified: httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/LoggingIOSession.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/LoggingIOSession.java?rev=1038670&r1=1038669&r2=1038670&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/LoggingIOSession.java (original)
+++ httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/LoggingIOSession.java Wed Nov 24 16:17:45 2010
@@ -41,13 +41,13 @@ import org.apache.http.nio.reactor.Sessi
public class LoggingIOSession implements IOSession {
private static AtomicLong COUNT = new AtomicLong(0);
-
+
private final Log log;
private final Wire wirelog;
private final IOSession session;
private final ByteChannel channel;
private final String id;
-
+
public LoggingIOSession(final IOSession session, final Log log, final Log wirelog) {
super();
if (session == null) {
@@ -94,10 +94,10 @@ public class LoggingIOSession implements
buffer.append(']');
return buffer.toString();
}
-
+
public void setEventMask(int ops) {
if (this.log.isDebugEnabled()) {
- this.log.debug("I/O session " + this.id + " " + this.session + ": Set event mask "
+ this.log.debug("I/O session " + this.id + " " + this.session + ": Set event mask "
+ formatOps(ops));
}
this.session.setEventMask(ops);
@@ -105,7 +105,7 @@ public class LoggingIOSession implements
public void setEvent(int op) {
if (this.log.isDebugEnabled()) {
- this.log.debug("I/O session " + this.id + " " + this.session + ": Set event "
+ this.log.debug("I/O session " + this.id + " " + this.session + ": Set event "
+ formatOps(op));
}
this.session.setEvent(op);
@@ -113,7 +113,7 @@ public class LoggingIOSession implements
public void clearEvent(int op) {
if (this.log.isDebugEnabled()) {
- this.log.debug("I/O session " + this.id + " " + this.session + ": Clear event "
+ this.log.debug("I/O session " + this.id + " " + this.session + ": Clear event "
+ formatOps(op));
}
this.session.clearEvent(op);
@@ -147,7 +147,7 @@ public class LoggingIOSession implements
public void setSocketTimeout(int timeout) {
if (this.log.isDebugEnabled()) {
- this.log.debug("I/O session " + this.id + " " + this.session + ": Set timeout "
+ this.log.debug("I/O session " + this.id + " " + this.session + ": Set timeout "
+ timeout);
}
this.session.setSocketTimeout(timeout);
@@ -171,7 +171,7 @@ public class LoggingIOSession implements
public void setAttribute(final String name, final Object obj) {
if (this.log.isDebugEnabled()) {
- this.log.debug("I/O session " + this.id + " " + this.session + ": Set attribute "
+ this.log.debug("I/O session " + this.id + " " + this.session + ": Set attribute "
+ name);
}
this.session.setAttribute(name, obj);
@@ -179,7 +179,7 @@ public class LoggingIOSession implements
public Object removeAttribute(final String name) {
if (this.log.isDebugEnabled()) {
- this.log.debug("I/O session " + this.id + " " + this.session + ": Remove attribute "
+ this.log.debug("I/O session " + this.id + " " + this.session + ": Remove attribute "
+ name);
}
return this.session.removeAttribute(name);
@@ -227,7 +227,7 @@ public class LoggingIOSession implements
public boolean isOpen() {
return session.channel().isOpen();
}
-
- }
-
+
+ }
+
}
\ No newline at end of file
Modified: httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/Wire.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/Wire.java?rev=1038670&r1=1038669&r2=1038670&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/Wire.java (original)
+++ httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/conn/Wire.java Wed Nov 24 16:17:45 2010
@@ -7,12 +7,12 @@ import org.apache.commons.logging.Log;
class Wire {
private final Log log;
-
+
public Wire(final Log log) {
super();
this.log = log;
}
-
+
private void wire(final String header, final byte[] b, int pos, int off) {
StringBuilder buffer = new StringBuilder();
for (int i = 0; i < off; i++) {
@@ -32,7 +32,7 @@ class Wire {
} else {
buffer.append((char) ch);
}
- }
+ }
if (buffer.length() > 0) {
buffer.append('\"');
buffer.insert(0, '\"');
@@ -44,8 +44,8 @@ class Wire {
public boolean isEnabled() {
return this.log.isDebugEnabled();
- }
-
+ }
+
public void output(final byte[] b, int pos, int off) {
wire(">> ", b, pos, off);
}
Modified: httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/pool/PoolEntry.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/pool/PoolEntry.java?rev=1038670&r1=1038669&r2=1038670&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/pool/PoolEntry.java (original)
+++ httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/pool/PoolEntry.java Wed Nov 24 16:17:45 2010
@@ -32,8 +32,8 @@ import org.apache.http.nio.reactor.IOSes
public class PoolEntry<T> {
- private static AtomicLong COUNTER = new AtomicLong();
-
+ private static AtomicLong COUNTER = new AtomicLong();
+
private final long id;
private final T route;
private final IOSession session;
@@ -73,5 +73,5 @@ public class PoolEntry<T> {
buffer.append("]");
return buffer.toString();
}
-
+
}
Modified: httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/pool/PoolEntryCallback.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/pool/PoolEntryCallback.java?rev=1038670&r1=1038669&r2=1038670&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/pool/PoolEntryCallback.java (original)
+++ httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/pool/PoolEntryCallback.java Wed Nov 24 16:17:45 2010
@@ -29,9 +29,9 @@ package org.apache.http.impl.nio.pool;
public interface PoolEntryCallback<T> {
void completed(PoolEntry<T> entry);
-
+
void failed(Exception ex);
-
+
void cancelled();
-
+
}
Modified: httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/pool/SessionPool.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/pool/SessionPool.java?rev=1038670&r1=1038669&r2=1038670&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/pool/SessionPool.java (original)
+++ httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/impl/nio/pool/SessionPool.java Wed Nov 24 16:17:45 2010
@@ -345,7 +345,7 @@ public class SessionPool<T> {
this.lock.unlock();
}
}
-
+
@Override
public String toString() {
StringBuilder buffer = new StringBuilder();
Modified: httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/nio/client/AsyncHttpClient.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/nio/client/AsyncHttpClient.java?rev=1038670&r1=1038669&r2=1038670&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/nio/client/AsyncHttpClient.java (original)
+++ httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/nio/client/AsyncHttpClient.java Wed Nov 24 16:17:45 2010
@@ -37,7 +37,7 @@ public interface AsyncHttpClient {
void shutdown() throws InterruptedException;
IOReactorStatus getStatus();
-
+
HttpExchange execute(HttpHost target, HttpRequest request);
-
+
}
Modified: httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/nio/client/HttpExchange.java
URL: http://svn.apache.org/viewvc/httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/nio/client/HttpExchange.java?rev=1038670&r1=1038669&r2=1038670&view=diff
==============================================================================
--- httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/nio/client/HttpExchange.java (original)
+++ httpcomponents/httpasyncclient/trunk/src/main/java/org/apache/http/nio/client/HttpExchange.java Wed Nov 24 16:17:45 2010
@@ -36,9 +36,9 @@ public interface HttpExchange {
boolean isCompleted();
void cancel();
-
+
HttpRequest getRequest();
-
+
HttpResponse awaitResponse() throws ExecutionException, InterruptedException;
-
+
}