to be used in director and managed connections
git-svn-id: https://svn.apache.org/repos/asf/jakarta/httpcomponents/httpclient/trunk@505006 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
4205d7ad28
commit
29ede44699
|
@ -0,0 +1,284 @@
|
|||
/*
|
||||
* $HeadURL$
|
||||
* $Revision$
|
||||
* $Date$
|
||||
*
|
||||
* ====================================================================
|
||||
* Licensed to the Apache Software Foundation (ASF) under one
|
||||
* or more contributor license agreements. See the NOTICE file
|
||||
* distributed with this work for additional information
|
||||
* regarding copyright ownership. The ASF licenses this file
|
||||
* to you under the Apache License, Version 2.0 (the
|
||||
* "License"); you may not use this file except in compliance
|
||||
* with the License. You may obtain a copy of the License at
|
||||
*
|
||||
* http://www.apache.org/licenses/LICENSE-2.0
|
||||
*
|
||||
* Unless required by applicable law or agreed to in writing,
|
||||
* software distributed under the License is distributed on an
|
||||
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
|
||||
* KIND, either express or implied. See the License for the
|
||||
* specific language governing permissions and limitations
|
||||
* under the License.
|
||||
* ====================================================================
|
||||
*
|
||||
* This software consists of voluntary contributions made by many
|
||||
* individuals on behalf of the Apache Software Foundation. For more
|
||||
* information on the Apache Software Foundation, please see
|
||||
* <http://www.apache.org/>.
|
||||
*
|
||||
*/
|
||||
|
||||
package org.apache.http.conn;
|
||||
|
||||
import java.net.InetAddress;
|
||||
|
||||
import org.apache.http.HttpHost;
|
||||
//import org.apache.http.util.LangUtils;
|
||||
import org.apache.http.util.CharArrayBuffer;
|
||||
|
||||
|
||||
/**
|
||||
* Helps tracking the steps in establishing a route.
|
||||
*
|
||||
* @author <a href="mailto:rolandw at apache.org">Roland Weber</a>
|
||||
*
|
||||
*
|
||||
* <!-- empty lines to avoid svn diff problems -->
|
||||
* @version $Revision$ $Date$
|
||||
*
|
||||
* @since 4.0
|
||||
*/
|
||||
public final class RouteTracker implements Cloneable {
|
||||
|
||||
/** The target host to connect to. */
|
||||
private final HttpHost targetHost;
|
||||
|
||||
/**
|
||||
* The local address to connect from.
|
||||
* <code>null</code> indicates that the default should be used.
|
||||
*/
|
||||
private final InetAddress localAddress;
|
||||
|
||||
// the attributes above are fixed at construction time
|
||||
// now follow attributes that indicate the established route
|
||||
|
||||
/** Whether the first hop of the route is established. */
|
||||
private boolean connected;
|
||||
|
||||
/** The proxy server, if any. */
|
||||
private HttpHost proxyHost;
|
||||
|
||||
/** Whether the the route is tunnelled through the proxy. */
|
||||
private boolean tunnelled;
|
||||
|
||||
/** Whether the route is layered over a tunnel. */
|
||||
private boolean layered;
|
||||
|
||||
/** Whether the route is secure. */
|
||||
private boolean secure;
|
||||
|
||||
|
||||
/**
|
||||
* Creates a new route tracker.
|
||||
* The target and origin need to be specified at creation time.
|
||||
*
|
||||
* @param target the host to which to route
|
||||
* @param local the local address to route from, or
|
||||
* <code>null</code> for the default
|
||||
*/
|
||||
public RouteTracker(HttpHost target, InetAddress local) {
|
||||
if (target == null) {
|
||||
throw new IllegalArgumentException("Target host may not be null.");
|
||||
}
|
||||
this.targetHost = target;
|
||||
this.localAddress = local;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Tracks connecting to the target.
|
||||
*
|
||||
* @param secure <code>true</code> if the connection is secure,
|
||||
* <code>false</code> otherwise
|
||||
*/
|
||||
public final void connectTarget(boolean secure) {
|
||||
this.connected = true;
|
||||
this.secure = secure;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Tracks connecting to a proxy.
|
||||
*
|
||||
* @param proxy the proxy connected to
|
||||
*/
|
||||
public final void connectProxy(HttpHost proxy) {
|
||||
if (proxy == null) {
|
||||
throw new IllegalArgumentException("Proxy host may not be null.");
|
||||
}
|
||||
this.connected = true;
|
||||
this.proxyHost = proxy;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Tracks tunnelling through the proxy.
|
||||
*/
|
||||
public final void establishTunnel() {
|
||||
if (this.proxyHost == null) {
|
||||
throw new IllegalStateException("No tunnel without proxy.");
|
||||
}
|
||||
if (!this.connected) {
|
||||
throw new IllegalStateException("No tunnel unless connected.");
|
||||
}
|
||||
this.tunnelled = true;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Tracks layering a protocol.
|
||||
*
|
||||
* @param secure <code>true</code> if the route is secure,
|
||||
* <code>false</code> otherwise
|
||||
*/
|
||||
public final void layerProtocol(boolean secure) {
|
||||
// it is possible to layer a protocol over a direct connection,
|
||||
// although this case is probably not considered elsewhere
|
||||
if (!this.connected) {
|
||||
throw new IllegalStateException
|
||||
("No layered protocol unless connected.");
|
||||
}
|
||||
this.layered = true;
|
||||
this.secure = secure;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Obtains the target host.
|
||||
*
|
||||
* @return the target host
|
||||
*/
|
||||
public final HttpHost getTargetHost() {
|
||||
return this.targetHost;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Obtains the local address to connect from.
|
||||
*
|
||||
* @return the local address,
|
||||
* or <code>null</code>
|
||||
*/
|
||||
public final InetAddress getLocalAddress() {
|
||||
return this.localAddress;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Obtains the proxy host.
|
||||
*
|
||||
* @return the proxy host, or <code>null</code> if not tracked
|
||||
*/
|
||||
public final HttpHost getProxyHost() {
|
||||
return this.proxyHost;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Checks whether this route is connected to it's first hop.
|
||||
*
|
||||
* @return <code>true</code> if connected,
|
||||
* <code>false</code> otherwise
|
||||
*/
|
||||
public final boolean isConnected() {
|
||||
return this.connected;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Checks whether this route is tunnelled through a proxy.
|
||||
*
|
||||
* @return <code>true</code> if tunnelled,
|
||||
* <code>false</code> otherwise
|
||||
*/
|
||||
public final boolean isTunnelled() {
|
||||
return this.tunnelled;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Checks whether this route includes a layered protocol.
|
||||
*
|
||||
* @return <code>true</code> if layered,
|
||||
* <code>false</code> otherwise
|
||||
*/
|
||||
public final boolean isLayered() {
|
||||
return this.layered;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Checks whether this route is secure.
|
||||
*
|
||||
* @return <code>true</code> if secure,
|
||||
* <code>false</code> otherwise
|
||||
*/
|
||||
public final boolean isSecure() {
|
||||
return this.secure;
|
||||
}
|
||||
|
||||
|
||||
/**
|
||||
* Obtains the tracked route.
|
||||
* <br/><b>Note:</b>
|
||||
* Currently, {@link HostConfiguration HostConfiguration} is used to
|
||||
* represent the route. It does not cover all tracked attributes.
|
||||
* In particular, it can not represent intermediate steps in establishing
|
||||
* a route.
|
||||
*
|
||||
* @return a representation of the route tracked so far
|
||||
*/
|
||||
public final HostConfiguration toRoute() {
|
||||
return new HostConfiguration
|
||||
(this.targetHost, this.proxyHost, this.localAddress);
|
||||
}
|
||||
|
||||
|
||||
//@@@ ? equals + hashCode
|
||||
|
||||
|
||||
/**
|
||||
* Obtains a description of this route.
|
||||
*
|
||||
* @return a human-readable representation of this route
|
||||
*/
|
||||
public final String toString() {
|
||||
CharArrayBuffer cab = new CharArrayBuffer(80);
|
||||
|
||||
cab.append("RouteTracker[");
|
||||
if (this.localAddress != null) {
|
||||
cab.append(this.localAddress);
|
||||
cab.append("->");
|
||||
}
|
||||
cab.append('{');
|
||||
if (this.connected)
|
||||
cab.append('c');
|
||||
if (this.tunnelled)
|
||||
cab.append('t');
|
||||
if (this.layered)
|
||||
cab.append('l');
|
||||
if (this.secure)
|
||||
cab.append('s');
|
||||
cab.append("}->");
|
||||
if (this.proxyHost != null) {
|
||||
cab.append(this.proxyHost);
|
||||
cab.append("->");
|
||||
}
|
||||
cab.append(this.targetHost);
|
||||
cab.append(']');
|
||||
|
||||
return cab.toString();
|
||||
}
|
||||
|
||||
} // class RouteTracker
|
Loading…
Reference in New Issue