Package zmq.io.net.tcp
Class SocksConnecter
java.lang.Object
zmq.ZObject
zmq.Own
zmq.io.net.tcp.TcpConnecter
zmq.io.net.tcp.SocksConnecter
- All Implemented Interfaces:
IPollEvents
-
Nested Class Summary
Nested Classes -
Field Summary
FieldsModifier and TypeFieldDescription(package private) String
private Address
(package private) SocksConnecter.Status
Fields inherited from class zmq.io.net.tcp.TcpConnecter
delayedStart, ioObject, RECONNECT_TIMER_ID
-
Constructor Summary
ConstructorsConstructorDescriptionSocksConnecter
(IOThread ioThread, SessionBase session, Options options, Address addr, Address proxyAddr, boolean delayedStart) -
Method Summary
Modifier and TypeMethodDescription(package private) void
(package private) void
(package private) void
error()
(package private) int
void
inEvent()
Called by I/O thread when file descriptor is ready for reading.(package private) void
(package private) int
open()
void
outEvent()
Called by I/O thread when file descriptor is ready for writing.(package private) void
parseAddress
(String address, String hostname, int port) protected void
(package private) int
protected void
processTerm
(int linger) (package private) void
void
timerEvent
(int id) Called when timer expires.Methods inherited from class zmq.io.net.tcp.TcpConnecter
close, connectEvent, destroy, toString
Methods inherited from class zmq.Own
incSeqnum, isTerminating, launchChild, processDestroy, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminate
Methods inherited from class zmq.ZObject
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
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
Methods inherited from interface zmq.poll.IPollEvents
acceptEvent
-
Field Details
-
proxyAddress
-
status
SocksConnecter.Status status -
endpoint
String endpoint
-
-
Constructor Details
-
SocksConnecter
public SocksConnecter(IOThread ioThread, SessionBase session, Options options, Address addr, Address proxyAddr, boolean delayedStart)
-
-
Method Details
-
processPlug
protected void processPlug()- Overrides:
processPlug
in classTcpConnecter
-
processTerm
protected void processTerm(int linger) - Overrides:
processTerm
in classTcpConnecter
-
inEvent
public void inEvent()Description copied from interface:IPollEvents
Called by I/O thread when file descriptor is ready for reading.- Specified by:
inEvent
in interfaceIPollEvents
- Overrides:
inEvent
in classTcpConnecter
-
outEvent
public void outEvent()Description copied from interface:IPollEvents
Called by I/O thread when file descriptor is ready for writing.- Specified by:
outEvent
in interfaceIPollEvents
- Overrides:
outEvent
in classTcpConnecter
-
timerEvent
public void timerEvent(int id) Description copied from interface:IPollEvents
Called when timer expires.- Specified by:
timerEvent
in interfaceIPollEvents
- Overrides:
timerEvent
in classTcpConnecter
- Parameters:
id
- the ID of the expired timer.
-
initiateConnect
void initiateConnect() -
processServerResponse
int processServerResponse() -
parseAddress
-
connectToProxy
void connectToProxy() -
error
void error() -
startTimer
void startTimer() -
getNewReconnectIvl
int getNewReconnectIvl() -
open
int open() -
checkProxyConnection
void checkProxyConnection()
-