I2PTunnelConnectClient

net.i2p.i2ptunnel.I2PTunnelConnectClient

All Implemented Interfaces:: Runnable, EventDispatcher

public class I2PTunnelConnectClientextends I2PTunnelHTTPClientBase implements Runnable

SSL tunnel through HTTP proxy using CONNECT method.

Supports various host formats (example.i2p, .b32.i2p, base64, external domains) and CONNECT syntax variations. Protocol ignored for I2P destinations.

Additional lines after CONNECT are stripped. CONNECT line removed for .i2p accesses, passed through for outproxy accesses.

Reference: RFC draft-luotonen-ssl-tunneling-03.txt (1997) "Tunneling SSL Through a WWW Proxy".

Nested Class Summary
Nested classes/interfaces inherited from class I2PTunnelHTTPClientBase
I2PTunnelHTTPClientBase.AuthResult, I2PTunnelHTTPClientBase.OnProxySuccess, I2PTunnelHTTPClientBase.OnTimeout
Modifier and Type
Class
Description
protected static enum
I2PTunnelHTTPClientBase.AuthResult
Authentication result status for HTTP client connections.
protected class
I2PTunnelHTTPClientBase.OnProxySuccess
Callback for successful proxy connections.
protected class
I2PTunnelHTTPClientBase.OnTimeout
Callback for timeout events.
Field Summary
Modifier and Type
Field
Description
static final String
AUTH_REALM
HTTP authentication realm for SSL CONNECT proxy.
private static final String
ERR_BAD_PROTOCOL
SOCKS reply refusing an unsupported version.
private static final String
ERR_LOCALHOST
SOCKS reply refusing a connection to localhost.
Fields inherited from class I2PTunnelHTTPClientBase
__requestId, _proxyList, BASIC_AUTH, BROWSER_READ_TIMEOUT, DEFAULT_READ_TIMEOUT, DIGEST_AUTH, ERR_DESTINATION_UNKNOWN, ERR_NO_OUTPROXY, INITIAL_SO_TIMEOUT, PROP_AUTH, PROP_OUTPROXY_AUTH, PROP_OUTPROXY_PW, PROP_OUTPROXY_PW_PREFIX, PROP_OUTPROXY_USER, PROP_OUTPROXY_USER_PREFIX, PROP_PROXY_DIGEST_PREFIX, PROP_PROXY_DIGEST_SHA256_SUFFIX, PROP_PROXY_DIGEST_SUFFIX, PROP_PW, PROP_PW_PREFIX, PROP_SSL_OUTPROXIES, PROP_USE_OUTPROXY_PLUGIN, PROP_USER, SHED_COOKIE, SHED_MAX_REFRESH, SHED_READ_TIMEOUT_MS, SHED_REFRESH_SECONDS, SUCCESS_RESPONSE
Modifier and Type
Field
Description
protected static final AtomicLong
__requestId
Counter for unique request IDs.
protected final List<String>
_proxyList
List of configured outproxies.
static final String
BASIC_AUTH
Basic auth type constant.
protected static final int
BROWSER_READ_TIMEOUT
Socket read timeout for a browser fetch, four hours as a failsafe.
protected static final int
DEFAULT_READ_TIMEOUT
-1 (forever) as of 0.9.36, so that large POSTs won't timeout on the read side.
static final String
DIGEST_AUTH
Digest auth type constant.
protected static final String
ERR_DESTINATION_UNKNOWN
Error response when destination is not found.
protected static final String
ERR_NO_OUTPROXY
Error response when no outproxy is configured.
protected static final int
INITIAL_SO_TIMEOUT
This is a standard soTimeout, not a total timeout.
static final String
PROP_AUTH
All auth.
static final String
PROP_OUTPROXY_AUTH
Outproxy auth property.
static final String
PROP_OUTPROXY_PW
Outproxy password property.
static final String
PROP_OUTPROXY_PW_PREFIX
Outproxy password property prefix.
static final String
PROP_OUTPROXY_USER
Outproxy username property.
static final String
PROP_OUTPROXY_USER_PREFIX
Passwords for specific outproxies may be added with outproxyUsername.fooproxy.i2p=user and outproxyPassword.fooproxy.i2p=pw.
static final String
PROP_PROXY_DIGEST_PREFIX
New style MD5 auth.
static final String
PROP_PROXY_DIGEST_SHA256_SUFFIX
SHA-256 digest suffix.
static final String
PROP_PROXY_DIGEST_SUFFIX
MD5 digest suffix.
static final String
PROP_PW
Proxy password property.
static final String
PROP_PW_PREFIX
Additional users may be added with proxyPassword.user=pw.
static final String
PROP_SSL_OUTPROXIES
Property for SSL outproxies.
static final String
PROP_USE_OUTPROXY_PLUGIN
Property to use local outproxy plugin.
static final String
PROP_USER
Proxy username property.
(package private) static final String
SHED_COOKIE
Cookie that counts meta-refresh retries on a shed connection.
(package private) static final int
SHED_MAX_REFRESH
How many meta-refresh pages to serve before the final 503.
(package private) static final int
SHED_READ_TIMEOUT_MS
Short SO_TIMEOUT while reading the shed request head (never on the hot path).
(package private) static final int
SHED_REFRESH_SECONDS
Refresh delay in seconds for the intermediate shed page.
protected static final String
SUCCESS_RESPONSE
HTTP 200 response for established CONNECT tunnels.
Fields inherited from class I2PTunnelClientBase
_clientId, _context, _executor, _log, _ownDest, DEFAULT_CONNECT_TIMEOUT, DEFAULT_MAX_CONNECTIONS, DEFAULT_SOCKET_OPEN_TIMEOUT, dest, l, listenerReady, MAX_TIMEOUT_FAILOVER, MIN_CONNECT_LEG_MS, mySockets, NO_DEADLINE, POOL_BUILD_DEADLINE_GRACE_MS, PROP_MAX_CONNECTIONS, PROP_USE_SSL, REQUEST_CONNECT_DEADLINE_MS, sockLock, sockMgr, ss
Modifier and Type
Field
Description
protected long
_clientId
This client's ID.
protected final I2PAppContext
_context
The application context.
protected ThreadPoolExecutor
_executor
Thread pool executor.
protected final Log
_log
The logger.
protected boolean
_ownDest
Whether we own our destination.
(package private) static final long
DEFAULT_CONNECT_TIMEOUT
Default connect timeout.
static final int
DEFAULT_MAX_CONNECTIONS
Default cap on concurrently handled client connections.
static final long
DEFAULT_SOCKET_OPEN_TIMEOUT
Default socket open timeout in ms, after which I2PTunnelClientBase.close(boolean) will proceed even with active sockets.
protected Destination
dest
The destination.
protected final Logging
l
The logging instance.
protected boolean
listenerReady
Protected for I2Ping since 0.9.11.
(package private) static final int
MAX_TIMEOUT_FAILOVER
Legacy cap on consecutive connect timeouts before abandoning tunnel failover.
(package private) static final long
MIN_CONNECT_LEG_MS
Minimum remaining budget for starting one connect leg.
protected final List<I2PSocket>
mySockets
List of active sockets.
(package private) static final long
NO_DEADLINE
Deadline sentinel for callers that have not adopted the shared request budget (SOCKS, IRC, DCC, raw createI2PSocket): they keep their original per-call limits because this sentinel never reads as expired and never clamps.
(package private) static final long
POOL_BUILD_DEADLINE_GRACE_MS
One-shot deadline extension granted while the outbound tunnel pool is still building (poolState() == 0) when the shared budget runs out.
static final String
PROP_MAX_CONNECTIONS
Property name: max concurrently active client connections handled by one client tunnel.
static final String
PROP_USE_SSL
Property turning on SSL between the proxy and the client.
(package private) static final long
REQUEST_CONNECT_DEADLINE_MS
Single wall-clock budget for establishing one proxied request.
protected final Object
sockLock
Guards sockMgr and mySockets.
protected I2PSocketManager
sockMgr
The socket manager.
protected ServerSocket
ss
Server socket.
Fields inherited from class I2PTunnelTask
open, tunnel
Modifier and Type
Field
Description
protected boolean
open
True while the tunnel is running and accepting connections.
I2PTunnel
tunnel
The I2PTunnel this task runs inside.
Constructor Summary
Constructors
Constructor
Description
I2PTunnelConnectClient(int localPort, Logging l, boolean ownDest, String wwwProxy, EventDispatcher notifyThis, I2PTunnel tunnel)
Create an HTTPS proxy tunnel for connecting out to arbitrary destinations, with optional outproxy chaining.
Method Summary
Modifier and Type
Method
Description
protected void
clientConnectionRun(Socket s)
Handle an incoming CONNECT proxy connection.
boolean
close(boolean forced)
Closes the CONNECT proxy and unregisters from port mapper.
private void
executeTask(Runnable task)
Execute a runnable task on the thread pool, freeing the accept thread to handle the next connection.
protected I2PSocketOptions
getDefaultOptions()
Create the default options (using the default timeout, etc).
protected String
getRealm()
Authentication realm for the HTTP proxy.
void
startRunning()
Starts the CONNECT proxy and registers with port mapper.
private static void
writeErrorMessage(String errMessage, OutputStream out)
Write an error message to the output stream and close it.
Methods inherited from class I2PTunnelHTTPClientBase
_t, _t, _t, addrAndPort, authorize, buildShed503Response, buildShedRefreshResponse, decodeIDNHost, getAuthError, getErrorPage, getErrorPage, getPrefix, handleClientException, handleI2PSocketException, isBlockedIPv4Address, isBlockedLocalAddress, isDigestAuthRequired, noteProxyResult, optionsUpdated, parseShedAttempt, sanitizeAuthArgs, sanitizeLogValue, selectProxy, selectSSLProxy, shouldMetaRefresh, summarizeAuthorization, writeErrorMessage, writeErrorMessage, writeErrorMessage, writeErrorMessage, writeFooter, writeFooter, writeShedResponse
Modifier and Type
Method
Description
protected String
_t(String key)
Look up a translation key in this class's resource bundle.
protected String
_t(String key, Object o)
Translate with one parameter {0}.
protected String
_t(String key, Object o, Object o2)
Translate with two parameters {0} and {1}.
(package private) static String
addrAndPort(Socket s)
Format the remote address as IP:PORT for ban and failure logging.
protected I2PTunnelHTTPClientBase.AuthResult
authorize(Socket s, long requestId, String method, String authorization)
Authorization Ref: RFC 2617 If the socket is an InternalSocket, no auth required.
(package private) static String
buildShed503Response()
Final shed response after refresh budget is exhausted (or non-HTML).
(package private) static String
buildShedRefreshResponse(int nextAttempt)
Intermediate shed page: unquoted meta refresh (no nested quotes in the tag) plus a Set-Cookie bump so the browser retries at most I2PTunnelHTTPClientBase.SHED_MAX_REFRESH times before the final 503.
static String
decodeIDNHost(String host)
Decode a hostname for display.
protected String
getAuthError(boolean isStale)
What to send if digest auth fails.
protected String
getErrorPage(String base, String backup)
Load the error page header file, e.g.
protected static String
getErrorPage(I2PAppContext ctx, String base, String backup)
Load the error page header file, e.g.
protected String
getPrefix(long requestId)
Generates a unique log prefix for request tracking.
protected void
handleClientException(Exception ex, OutputStream out, String targetRequest, boolean usingWWWProxy, String wwwProxy, long requestId)
Handle an exception from a client connection.
protected void
handleI2PSocketException(I2PSocketException ise, OutputStream out, String targetRequest, boolean usingWWWProxy, String wwwProxy)
Generate an error page based on the status code in our custom exception.
static boolean
isBlockedIPv4Address(String host)
Determine whether an IPv4 host is in a blocked non-routable block: loopback, "this network", RFC 1918 private, link-local, carrier-grade NAT, benchmarking, documentation, multicast, and reserved space.
static boolean
isBlockedLocalAddress(String host)
Determine whether a proxy request target is a loopback, private, link-local, shared, or otherwise non-routable address that must not be reached through the proxy.
protected boolean
isDigestAuthRequired()
Checks if HTTP Digest authentication is required by the outproxy.
protected void
noteProxyResult(String proxy, String host, boolean isSSL, boolean ok)
Update the cache and note if failed.
void
optionsUpdated(I2PTunnel tunnel)
Update the outproxy list then call super.
(package private) static int
parseShedAttempt(String cookie)
How many shed meta-refresh attempts the request's Cookie header already used.
(package private) static Map<String,String>
sanitizeAuthArgs(Map<String,String> args)
Copy digest request arguments into a form safe to log: credential material is redacted, and every remaining value is stripped of line breaks and capped, so a hostile upstream cannot forge extra log lines or grow the log without bound.
(package private) static String
sanitizeLogValue(String value)
Strip line breaks and cap the length of an attacker-supplied value before it is written to the log, so a hostile username cannot forge extra log lines.
protected String
selectProxy(String host)
Selects an appropriate outproxy for the given host from the proxy pool.
protected String
selectSSLProxy(String host)
Selects an SSL-capable outproxy for HTTPS connections.
(package private) static boolean
shouldMetaRefresh(String method, String accept, int attempt)
Whether a shed connection should get a meta-refresh page instead of a 503.
(package private) static String
summarizeAuthorization(String authorization)
Summarize an Authorization header for logging without disclosing credential material.
protected void
writeErrorMessage(String errMessage, OutputStream out, String targetRequest, boolean usingWWWProxy, String wwwProxy)
No jump servers or extra message.
protected void
writeErrorMessage(String errMessage, OutputStream out, String targetRequest, boolean usingWWWProxy, String wwwProxy, String jumpServers)
No extra message.
protected void
writeErrorMessage(String errMessage, String extraMessage, OutputStream out, String targetRequest, boolean usingWWWProxy, String wwwProxy)
No jump servers.
protected void
writeErrorMessage(String errMessage, String extraMessage, OutputStream outs, String targetRequest, boolean usingWWWProxy, String wwwProxy, String jumpServers)
Write the complete error message to the output stream.
static void
writeFooter(OutputStream out)
Write the closing HTML footer and flush it down the stream.
static void
writeFooter(Writer out)
Write the closing HTML footer and flush it down the writer.
protected void
writeShedResponse(Socket s)
Write a real HTTP status on a shed connection so the browser never sees an empty response: HTML GET navigations get a cookie-capped meta-refresh page (up to I2PTunnelHTTPClientBase.SHED_MAX_REFRESH times), everything else gets a 503.
Methods inherited from class I2PTunnelClientBase
buildSocketManager, buildSocketManager, buildSocketManager, buildSocketManager, clampToDeadlineMs, closeSocket, connectDeadlineFrom, createI2PSocket, createI2PSocket, createI2PSocket, createI2PSocket, destroy, extendDeadlineForBuildingPool, getDefaultOptions, getEffectiveMaxConnections, getListenHost, getLocalPort, getSocketManager, getSocketManager, getSocketOpenTimeout, isConnectTimeout, isDeadlineExpired, legConnectTimeoutMs, manageConnection, poolIsDefinitivelyDown, poolState, resolveEffectiveMaxConnections, resolveMaxConnections, resolveRunnerCeiling, run, shouldContinueFailover, shouldContinueFailover, shouldOuterRetryConnect, shouldOuterRetryConnect, verifySocketManager
Modifier and Type
Method
Description
protected I2PSocketManager
buildSocketManager()
For NON-SHARED clients (ownDest = true).
protected static I2PSocketManager
buildSocketManager(I2PTunnel tunnel)
Create a disconnected socket manager for the tunnel, with no private key file.
protected static I2PSocketManager
buildSocketManager(I2PTunnel tunnel, String pkf)
Create a disconnected socket manager for the tunnel, loading the persistent client dest from pkf if it is non-null.
protected static I2PSocketManager
buildSocketManager(I2PTunnel tunnel, String pkf, Logging log)
Create a disconnected socket manager for the tunnel, loading the persistent client dest from pkf if it is non-null, and logging any key file error to log.
(package private) static long
clampToDeadlineMs(long requestedMs, long deadlineMs, long nowMs)
Clamp a requested timeout to the time left before a shared deadline.
static void
closeSocket(Socket s)
Close a socket silently.
(package private) static long
connectDeadlineFrom(long nowMs)
Compute the shared connect deadline for a request starting now.
I2PSocket
createI2PSocket(Destination dest)
Create a new I2PSocket towards to the specified destination, adding it to the list of connections actually managed by this tunnel.
I2PSocket
createI2PSocket(Destination dest, int port)
Create a new I2PSocket towards to the specified destination, adding it to the list of connections actually managed by this tunnel.
I2PSocket
createI2PSocket(Destination dest, I2PSocketOptions opt)
Create a new I2PSocket towards to the specified destination, adding it to the list of connections actually managed by this tunnel.
(package private) I2PSocket
createI2PSocket(Destination dest, I2PSocketOptions opt, long deadlineMs)
Create a new I2PSocket bounded by a shared request deadline.
boolean
destroy()
Note that the tunnel cannot be reopened after this by calling startRunning(), as it will destroy the underlying socket manager.
(package private) static long
extendDeadlineForBuildingPool(long deadlineMs, long nowMs, int poolState, boolean alreadyExtended)
One-shot deadline extension for a request whose outbound tunnel pool is still building when the shared deadline runs out.
protected I2PSocketOptions
getDefaultOptions(Properties overrides)
Create the default options (using the default timeout, etc).
(package private) int
getEffectiveMaxConnections()
The effective concurrent-connection cap for this tunnel at the moment the accept loop admits a connection.
protected final InetAddress
getListenHost(Logging l)
Get the listen host address.
final int
getLocalPort()
Get the local port.
I2PSocketManager
getSocketManager()
Returns the I2PSocketManager for this task.
protected static I2PSocketManager
getSocketManager(I2PTunnel tunnel, String pkf)
This is ONLY for shared clients.
long
getSocketOpenTimeout()
Returns the socket open timeout in ms; close() will proceed after this even with active sockets.
(package private) static boolean
isConnectTimeout(Throwable e)
For timeout wording.
(package private) static boolean
isDeadlineExpired(long deadlineMs, long nowMs)
Whether a shared connect deadline has passed.
(package private) static long
legConnectTimeoutMs(long requestedMs, long deadlineMs, long nowMs)
Compute the connect timeout to apply to one failover leg under a shared deadline.
protected void
manageConnection(Socket s)
Manage the connection just opened on the specified socket.
protected boolean
poolIsDefinitivelyDown()
And none are being built, so further connect retries cannot succeed.
protected int
poolState()
Router-context only, best-effort check of the client outbound tunnel pool.
(package private) static int
resolveEffectiveMaxConnections(boolean customized, int ownCap, int globalDefault)
Pure decision helper for I2PTunnelClientBase.getEffectiveMaxConnections(): pick the per-tunnel override when one was explicitly configured, otherwise the Tuner-managed default cap.
(package private) static int
resolveMaxConnections(String configured)
Resolve the max-concurrent-connections cap from the tunnel's configured value.
(package private) static int
resolveRunnerCeiling(boolean customized, int effectiveMax)
Ceiling to pin on this tunnel's runner pool at creation time.
void
run()
Non-final since 0.9.11.
(package private) static boolean
shouldContinueFailover(int tunnelCount, int attemptsMade, int timeoutFailures, boolean poolDown)
Whether another tunnel-failover attempt is worthwhile after a connect failure.
(package private) static boolean
shouldContinueFailover(int tunnelCount, int attemptsMade, int timeoutFailures, boolean poolDown, boolean poolBuilding)
Whether another tunnel-failover attempt is worthwhile after a connect failure.
(package private) static boolean
shouldOuterRetryConnect(int connectAttempts, int timeoutConnectAttempts, boolean timedOut, boolean poolDown, boolean poolBuilding, boolean browserClosed)
Whether the outer HTTP connect loop should retry after a failure.
(package private) static boolean
shouldOuterRetryConnect(int connectAttempts, int timeoutConnectAttempts, boolean timedOut, int poolState, boolean deadlineExpired)
Whether the outer HTTP connect loop should retry after a failure, given the single pool-state snapshot taken for that failure.
protected void
verifySocketManager()
Create the manager if it doesn't exist, AND connect it to the router and build tunnels.
Methods inherited from class I2PTunnelTask
connected, disconnected, errorOccurred, getBooleanOption, getId, getTunnel, isOpen, reportAbuse, routerDisconnected, setId, setName, setTunnel, toString
Modifier and Type
Method
Description
void
connected(I2PSession session)
For tasks that don't call I2PTunnel.addSession(I2PSession) directly.
void
disconnected(I2PSession session)
Called when a session is disconnected.
void
errorOccurred(I2PSession session, String message, Throwable error)
Does nothing here.
protected boolean
getBooleanOption(String opt, boolean dflt)
Read a boolean client option from the tunnel's properties.
int
getId()
The id of the client list entry for this task.
I2PTunnel
getTunnel()
The I2PTunnel this task runs inside.
boolean
isOpen()
Whether the tunnel is running and accepting connections.
void
reportAbuse(I2PSession session, int severity)
Does nothing here.
protected void
routerDisconnected()
Tell the tunnel that the router connection has dropped.
void
setId(int id)
Record the client list entry id for this task.
protected void
setName(String name)
Record the display name for this task.
void
setTunnel(I2PTunnel pTunnel)
Rebind this task to a different tunnel.
String
toString()
The display name given to this task when it was constructed.
Methods inherited from class EventDispatcherImpl
attachEventDispatcher, detachEventDispatcher, getEventDispatcher, getEvents, getEventValue, ignoreEvents, notifyEvent, unIgnoreEvents, waitEventValue
Modifier and Type
Method
Description
void
attachEventDispatcher(EventDispatcher ev)
Attach an EventDispatcher object to the events dispatching chain.
void
detachEventDispatcher(EventDispatcher ev)
Detach the specified EventDispatcher object from the events dispatching chain.
EventDispatcher
getEventDispatcher()
Object to be used to deliver events (usually this, but YMMV).
Set<String>
getEvents()
Retrieve the names of all the events that have been received.
Object
getEventValue(String name)
Retrieve the value currently associated with the specified event value.
void
ignoreEvents()
Ignore further event notifications.
void
notifyEvent(String eventName, Object args)
Deliver an event.
void
unIgnoreEvents()
Almost like the method above :-).
Object
waitEventValue(String name)
Wait until the given event has received a value.
Methods inherited from class Object
clone, equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Field Details
- AUTH_REALM
  public static final String AUTH_REALM
  HTTP authentication realm for SSL CONNECT proxy.
  See Also:
  Constant Field Values
- ERR_BAD_PROTOCOL
  private static final String ERR_BAD_PROTOCOL
  SOCKS reply refusing an unsupported version.
  See Also:
  Constant Field Values
- ERR_LOCALHOST
  private static final String ERR_LOCALHOST
  SOCKS reply refusing a connection to localhost.
  See Also:
  Constant Field Values
Constructor Details
- I2PTunnelConnectClient
  public I2PTunnelConnectClient(int localPort, Logging l, boolean ownDest, String wwwProxy, EventDispatcher notifyThis, I2PTunnel tunnel) throws IllegalArgumentException
  Create an HTTPS proxy tunnel for connecting out to arbitrary destinations, with optional outproxy chaining. As of 0.9.20 this is fast, and does NOT connect the manager to the router, or open the local socket. You MUST call startRunning() for that.
  Parameters:
  localPort - the local port to bind to
  l - the Logging instance this tunnel's status messages are sent to
  ownDest - whether to use our own destination
  wwwProxy - the outproxy destinations, separated by commas or spaces, or null for none
  notifyThis - event dispatcher for notifications
  tunnel - the parent I2PTunnel instance, supplying the listening host and client options
  Throws:
  IllegalArgumentException - if the I2PTunnel does not contain valid config to contact the router
Method Details
- getDefaultOptions
  protected I2PSocketOptions getDefaultOptions()
  Create the default options (using the default timeout, etc). Warning, this does not make a copy of I2PTunnel's client options, it modifies them directly.
  Overrides:
  getDefaultOptions in class I2PTunnelClientBase
  Returns:
  the default options
- executeTask
  private void executeTask(Runnable task)
  Execute a runnable task on the thread pool, freeing the accept thread to handle the next connection.
  Both I2PTunnelRunner and I2PTunnelOutproxyRunner manage their own socket cleanup in their finally blocks, so the caller no longer needs to close sockets after this returns.
  Parameters:
  task - Runnable task to execute
- startRunning
  public void startRunning()
  Starts the CONNECT proxy and registers with port mapper.
  Overrides:
  startRunning in class I2PTunnelClientBase
- close
  public boolean close(boolean forced)
  Closes the CONNECT proxy and unregisters from port mapper.
  Overrides:
  close in class I2PTunnelClientBase
  Parameters:
  forced - true to interrupt an in-progress build, false to close gracefully
  Returns:
  true if the tunnel is closed, or false if connections were still active and the close was refused
- getRealm
  protected String getRealm()
  Authentication realm for the HTTP proxy.
  Specified by:
  getRealm in class I2PTunnelHTTPClientBase
  Returns:
  AUTH_REALM, the realm this client sends in its Digest authentication challenge to the proxy
- clientConnectionRun
  protected void clientConnectionRun(Socket s)
  Handle an incoming CONNECT proxy connection. Parses the CONNECT request, resolves the destination, and forwards data.
  Specified by:
  clientConnectionRun in class I2PTunnelClientBase
  Parameters:
  s - the local client socket connection
- writeErrorMessage
  private static void writeErrorMessage(String errMessage, OutputStream out) throws IOException
  Write an error message to the output stream and close it.
  Parameters:
  errMessage - the HTML error response to send
  out - the output stream to write to, may be null
  Throws:
  IOException - if an I/O error occurs

Nested Class Summary

Nested classes/interfaces inherited from class I2PTunnelHTTPClientBase

Field Summary

Fields inherited from class I2PTunnelHTTPClientBase

Fields inherited from class I2PTunnelClientBase

Fields inherited from class I2PTunnelTask

Constructor Summary

Method Summary

Methods inherited from class I2PTunnelHTTPClientBase

Methods inherited from class I2PTunnelClientBase

Methods inherited from class I2PTunnelTask

Methods inherited from class EventDispatcherImpl

Methods inherited from class Object

Field Details

AUTH_REALM

ERR_BAD_PROTOCOL

ERR_LOCALHOST

Constructor Details

Method Details

getDefaultOptions

executeTask

startRunning

close

getRealm

clientConnectionRun

writeErrorMessage