Class TcpConnecter

java.lang.Object

zmq.ZObject

zmq.Own

zmq.io.net.tcp.TcpConnecter

All Implemented Interfaces:

IPollEvents

Direct Known Subclasses:

IpcConnecter, SocksConnecter, TipcConnecter

public class TcpConnecter
extends Own
implements IPollEvents

Field Summary

Fields

Modifier and Type	Field	Description
private final Address	addr
private int	currentReconnectIvl
protected final boolean	delayedStart
private SocketChannel	fd
private Poller.Handle	handle
protected final IOObject	ioObject
protected static final int	RECONNECT_TIMER_ID
private final SessionBase	session
private final SocketBase	socket
private boolean	timerStarted

Fields inherited from class Own

errno, options

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
private void	addReconnectTimer()
protected void	close()
private SocketChannel	connect()
void	connectEvent()	Called by I/O thread when file descriptor might be ready for connecting.
protected void	destroy()
private int	getNewReconnectIvl()
void	inEvent()	Called by I/O thread when file descriptor is ready for reading.
private boolean	open()
void	outEvent()	Called by I/O thread when file descriptor is ready for writing.
protected void	processPlug()
protected void	processTerm(int linger)
private void	startConnecting()
void	timerEvent(int id)	Called when timer expires.
String	toString()

Methods inherited from class Own

incSeqnum, isTerminating, launchChild, processDestroy, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminate

Methods inherited from class 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 Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface IPollEvents

acceptEvent

Field Details

RECONNECT_TIMER_ID

protected static final int RECONNECT_TIMER_ID

See Also:

• Constant Field Values

ioObject

protected final IOObject ioObject

addr

private final Address addr

fd

private SocketChannel fd

handle

private Poller.Handle handle

delayedStart

protected final boolean delayedStart

timerStarted

private boolean timerStarted

session

private final SessionBase session

currentReconnectIvl

private int currentReconnectIvl

socket

private final SocketBase socket

Constructor Details

TcpConnecter

public TcpConnecter(IOThread ioThread,
 SessionBase session,
 Options options,
 Address addr,
 boolean delayedStart)

Method Details

destroy

protected void destroy()

Specified by:

destroy in class Own

processPlug

protected void processPlug()

Overrides:

processPlug in class ZObject

processTerm

protected void processTerm(int linger)

Overrides:

processTerm in class Own

connectEvent

public void connectEvent()

Description copied from interface: IPollEvents

Called by I/O thread when file descriptor might be ready for connecting.

Specified by:

connectEvent in interface IPollEvents

timerEvent

public void timerEvent(int id)

Description copied from interface: IPollEvents

Called when timer expires.

Specified by:

timerEvent in interface IPollEvents

Parameters:

id - the ID of the expired timer.

startConnecting

private void startConnecting()

addReconnectTimer

private void addReconnectTimer()

getNewReconnectIvl

private int getNewReconnectIvl()

open

private boolean open()
              throws IOException

Throws:

IOException

connect

private SocketChannel connect()

close

protected void close()

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

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

toString

public String toString()

Overrides:

toString in class Object