diff options
author | Simone Bordet | 2011-11-24 09:16:19 +0000 |
---|---|---|
committer | Simone Bordet | 2011-11-24 09:16:19 +0000 |
commit | 8f1fff78c0a722e0712b9d5cf2f5b83d02059dcb (patch) | |
tree | c341a278f9e943c46cf4058ebc7c42b7c71b9275 /jetty-client/src/main/java/org/eclipse/jetty | |
parent | eaa83f29d1b70779aec5cbd706c1e2442b500b0a (diff) | |
download | org.eclipse.jetty.project-8f1fff78c0a722e0712b9d5cf2f5b83d02059dcb.tar.gz org.eclipse.jetty.project-8f1fff78c0a722e0712b9d5cf2f5b83d02059dcb.tar.xz org.eclipse.jetty.project-8f1fff78c0a722e0712b9d5cf2f5b83d02059dcb.zip |
Improved dumping capabilities of HttpClient, and rewritten toString() methods using String.format().
Diffstat (limited to 'jetty-client/src/main/java/org/eclipse/jetty')
-rw-r--r-- | jetty-client/src/main/java/org/eclipse/jetty/client/HttpClient.java | 6 | ||||
-rw-r--r-- | jetty-client/src/main/java/org/eclipse/jetty/client/SelectConnector.java | 16 |
2 files changed, 18 insertions, 4 deletions
diff --git a/jetty-client/src/main/java/org/eclipse/jetty/client/HttpClient.java b/jetty-client/src/main/java/org/eclipse/jetty/client/HttpClient.java index 0b168be513..b454955642 100644 --- a/jetty-client/src/main/java/org/eclipse/jetty/client/HttpClient.java +++ b/jetty-client/src/main/java/org/eclipse/jetty/client/HttpClient.java @@ -16,12 +16,12 @@ package org.eclipse.jetty.client; import java.io.IOException; import java.io.InputStream; import java.net.UnknownHostException; +import java.util.Arrays; import java.util.Enumeration; import java.util.LinkedList; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; - import javax.net.ssl.SSLContext; import org.eclipse.jetty.client.security.Authentication; @@ -164,7 +164,7 @@ public class HttpClient extends HttpBuffers implements Attributes, Dumpable public void dump(Appendable out, String indent) throws IOException { out.append(String.valueOf(this)).append("\n"); - AggregateLifeCycle.dump(out,indent,_destinations.values()); + AggregateLifeCycle.dump(out,indent,Arrays.asList(_threadPool,_connector),_destinations.values()); } /* ------------------------------------------------------------------------------- */ @@ -190,7 +190,7 @@ public class HttpClient extends HttpBuffers implements Attributes, Dumpable pool.setName("HttpClient"); _threadPool = pool; } - + return _threadPool; } diff --git a/jetty-client/src/main/java/org/eclipse/jetty/client/SelectConnector.java b/jetty-client/src/main/java/org/eclipse/jetty/client/SelectConnector.java index 33585f9d05..a52ff7ffd8 100644 --- a/jetty-client/src/main/java/org/eclipse/jetty/client/SelectConnector.java +++ b/jetty-client/src/main/java/org/eclipse/jetty/client/SelectConnector.java @@ -18,6 +18,7 @@ import java.net.SocketTimeoutException; import java.nio.channels.SelectionKey; import java.nio.channels.SocketChannel; import java.nio.channels.UnresolvedAddressException; +import java.util.Arrays; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import javax.net.ssl.SSLEngine; @@ -31,13 +32,15 @@ import org.eclipse.jetty.io.nio.SelectChannelEndPoint; import org.eclipse.jetty.io.nio.SelectorManager; import org.eclipse.jetty.io.nio.SslConnection; import org.eclipse.jetty.util.component.AbstractLifeCycle; +import org.eclipse.jetty.util.component.AggregateLifeCycle; +import org.eclipse.jetty.util.component.Dumpable; import org.eclipse.jetty.util.log.Log; import org.eclipse.jetty.util.log.Logger; import org.eclipse.jetty.util.ssl.SslContextFactory; import org.eclipse.jetty.util.thread.Timeout; import org.eclipse.jetty.util.thread.Timeout.Task; -class SelectConnector extends AbstractLifeCycle implements HttpClient.Connector +class SelectConnector extends AbstractLifeCycle implements HttpClient.Connector, Dumpable { private static final Logger LOG = Log.getLogger(SelectConnector.class); @@ -69,6 +72,17 @@ class SelectConnector extends AbstractLifeCycle implements HttpClient.Connector _selectorManager.stop(); } + public String dump() + { + return AggregateLifeCycle.dump(this); + } + + public void dump(Appendable out, String indent) throws IOException + { + out.append(String.valueOf(this)).append("\n"); + AggregateLifeCycle.dump(out, indent, Arrays.asList(_selectorManager)); + } + /* ------------------------------------------------------------ */ public void startConnection( HttpDestination destination ) throws IOException |