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

Fields inherited from class zmq.Own

errno, options

Constructor Summary

Constructors

Constructor	Description
SocksConnecter(IOThread ioThread, SessionBase session, Options options, Address addr, Address proxyAddr, boolean delayedStart)

Method Summary

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 class TcpConnecter

processTerm

protected void processTerm(int linger)

Overrides:

processTerm in class TcpConnecter

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 interface IPollEvents

Overrides:

inEvent in class TcpConnecter

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 interface IPollEvents

Overrides:

outEvent in class TcpConnecter

timerEvent

public void timerEvent(int id)

Description copied from interface: IPollEvents

Called when timer expires.

Specified by:

timerEvent in interface IPollEvents

Overrides:

timerEvent in class TcpConnecter

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()