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
public class SocksConnecter extends TcpConnecter
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description private static class
SocksConnecter.Status
-
Field Summary
Fields Modifier and Type Field Description (package private) java.lang.String
endpoint
private Address
proxyAddress
(package private) SocksConnecter.Status
status
-
Fields inherited from class zmq.io.net.tcp.TcpConnecter
delayedStart, ioObject, RECONNECT_TIMER_ID
-
-
Constructor Summary
Constructors Constructor Description SocksConnecter(IOThread ioThread, SessionBase session, Options options, Address addr, Address proxyAddr, boolean delayedStart)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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.-
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 Detail
-
proxyAddress
private Address proxyAddress
-
status
SocksConnecter.Status status
-
endpoint
java.lang.String endpoint
-
-
Constructor Detail
-
SocksConnecter
public SocksConnecter(IOThread ioThread, SessionBase session, Options options, Address addr, Address proxyAddr, boolean delayedStart)
-
-
Method Detail
-
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
void parseAddress(java.lang.String address, java.lang.String hostname, int port)
-
connectToProxy
void connectToProxy()
-
error
void error()
-
startTimer
void startTimer()
-
getNewReconnectIvl
int getNewReconnectIvl()
-
open
int open()
-
checkProxyConnection
void checkProxyConnection()
-
-