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 9f5788d3989..e07515a62b3 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 @@ -85,7 +85,7 @@ public class HttpClient extends AbstractBuffers implements Attributes private int _connectorType = CONNECTOR_SELECT_CHANNEL; private boolean _useDirectBuffers = true; - private int _maxConnectionsPerAddress = 32; + private int _maxConnectionsPerAddress = Integer.MAX_VALUE; private Map
_destinations = new HashMap(); ThreadPool _threadPool; Connector _connector; @@ -121,12 +121,19 @@ public class HttpClient extends AbstractBuffers implements Attributes private AttributesMap _attributes=new AttributesMap(); /* ------------------------------------------------------------------------------- */ - public void dump() throws IOException + public void dump() { - for (Map.Entry entry : _destinations.entrySet()) + try { - System.err.println("\n" + entry.getKey() + ":"); - entry.getValue().dump(); + for (Map.Entry entry : _destinations.entrySet()) + { + Log.info("\n" + entry.getKey() + ":"); + entry.getValue().dump(); + } + } + catch(Exception e) + { + Log.warn(e); } } diff --git a/jetty-client/src/main/java/org/eclipse/jetty/client/HttpConnection.java b/jetty-client/src/main/java/org/eclipse/jetty/client/HttpConnection.java index 1031bfe2443..3db6db700a9 100644 --- a/jetty-client/src/main/java/org/eclipse/jetty/client/HttpConnection.java +++ b/jetty-client/src/main/java/org/eclipse/jetty/client/HttpConnection.java @@ -61,10 +61,10 @@ public class HttpConnection implements Connection public void dump() throws IOException { - System.err.println("endp=" + _endp + " " + _endp.isBufferingInput() + " " + _endp.isBufferingOutput()); - System.err.println("generator=" + _generator); - System.err.println("parser=" + _parser.getState() + " " + _parser.isMoreInBuffer()); - System.err.println("exchange=" + _exchange); + Log.info("endp=" + _endp + " " + _endp.isBufferingInput() + " " + _endp.isBufferingOutput()); + Log.info("generator=" + _generator); + Log.info("parser=" + _parser.getState() + " " + _parser.isMoreInBuffer()); + Log.info("exchange=" + _exchange); if (_endp instanceof SslSelectChannelEndPoint) ((SslSelectChannelEndPoint)_endp).dump(); } @@ -296,6 +296,7 @@ public class HttpConnection implements Connection } } failed = true; + Log.warn("IOE on "+_exchange); throw e; } finally diff --git a/jetty-client/src/main/java/org/eclipse/jetty/client/HttpDestination.java b/jetty-client/src/main/java/org/eclipse/jetty/client/HttpDestination.java index 9dd43482e3c..e8b071d6679 100644 --- a/jetty-client/src/main/java/org/eclipse/jetty/client/HttpDestination.java +++ b/jetty-client/src/main/java/org/eclipse/jetty/client/HttpDestination.java @@ -35,13 +35,13 @@ import org.eclipse.jetty.util.log.Log; */ public class HttpDestination { - private ByteArrayBuffer _hostHeader; + private final ByteArrayBuffer _hostHeader; private final Address _address; private final LinkedList