Skip to main content
summaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorSimone Bordet2011-11-24 09:16:19 +0000
committerSimone Bordet2011-11-24 09:16:19 +0000
commit8f1fff78c0a722e0712b9d5cf2f5b83d02059dcb (patch)
treec341a278f9e943c46cf4058ebc7c42b7c71b9275 /jetty-client/src/main/java/org/eclipse/jetty
parenteaa83f29d1b70779aec5cbd706c1e2442b500b0a (diff)
downloadorg.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.java6
-rw-r--r--jetty-client/src/main/java/org/eclipse/jetty/client/SelectConnector.java16
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

Back to the top