public class SocksConnecter extends TcpConnecter
Modifier and Type | Class and Description |
---|---|
private static class |
SocksConnecter.Status |
Modifier and Type | Field and Description |
---|---|
(package private) java.lang.String |
endpoint |
private Address |
proxyAddress |
(package private) SocksConnecter.Status |
status |
delayedStart, ioObject, RECONNECT_TIMER_ID
Constructor and Description |
---|
SocksConnecter(IOThread ioThread,
SessionBase session,
Options options,
Address addr,
Address proxyAddr,
boolean delayedStart) |
Modifier and Type | Method and Description |
---|---|
(package private) void |
checkProxyConnection() |
(package private) void |
connectToProxy() |
(package private) void |
error() |
(package private) int |
getNewReconnectIvl() |
void |
inEvent()
Called by I/O thread when file descriptor is ready for reading.
|
(package private) void |
initiateConnect() |
(package private) int |
open() |
void |
outEvent()
Called by I/O thread when file descriptor is ready for writing.
|
(package private) void |
parseAddress(java.lang.String address,
java.lang.String hostname,
int port) |
protected void |
processPlug() |
(package private) int |
processServerResponse() |
protected void |
processTerm(int linger) |
(package private) void |
startTimer() |
void |
timerEvent(int id)
Called when timer expires.
|
close, connectEvent, destroy, toString
incSeqnum, isTerminating, launchChild, processDestroy, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminate
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processAttach, processBind, processCancel, processHiccup, processPipeTerm, processPipeTermAck, processReap, processReapAck, processReaped, processStop, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendCancel, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReapAck, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, setTid, unregisterEndpoint, unregisterEndpoints
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
acceptEvent
private Address proxyAddress
SocksConnecter.Status status
java.lang.String endpoint
public SocksConnecter(IOThread ioThread, SessionBase session, Options options, Address addr, Address proxyAddr, boolean delayedStart)
protected void processPlug()
processPlug
in class TcpConnecter
protected void processTerm(int linger)
processTerm
in class TcpConnecter
public void inEvent()
IPollEvents
inEvent
in interface IPollEvents
inEvent
in class TcpConnecter
public void outEvent()
IPollEvents
outEvent
in interface IPollEvents
outEvent
in class TcpConnecter
public void timerEvent(int id)
IPollEvents
timerEvent
in interface IPollEvents
timerEvent
in class TcpConnecter
id
- the ID of the expired timer.void initiateConnect()
int processServerResponse()
void parseAddress(java.lang.String address, java.lang.String hostname, int port)
void connectToProxy()
void error()
void startTimer()
int getNewReconnectIvl()
int open()
void checkProxyConnection()