Package zmq.io

Class SessionBase

java.lang.Object

zmq.ZObject

zmq.Own

zmq.io.SessionBase

All Implemented Interfaces:

Pipe.IPipeEvents, IPollEvents

Direct Known Subclasses:

Dish.DishSession, HelloMsgSession, Radio.RadioSession, Req.ReqSession

public class SessionBase
extends Own
implements Pipe.IPipeEvents, IPollEvents

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	active
private Address	addr
private IEngine	engine
private boolean	hasLingerTimer
private boolean	incompleteIn
private IOObject	ioObject
private IOThread	ioThread
private static int	LINGER_TIMER_ID
private boolean	pending
private Pipe	pipe
protected SocketBase	socket
private java.util.Set<Pipe>	terminatingPipes
private Pipe	zapPipe

Fields inherited from class zmq.Own

errno, options

Constructor Summary

Constructors

Constructor	Description
SessionBase(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)

Method Summary

Modifier and Type	Method	Description
void	attachPipe(Pipe pipe)
private void	cleanPipes()
void	destroy()
void	engineError(boolean handshaked, StreamEngine.ErrorReason reason)
void	flush()
java.lang.String	getEndpoint()
SocketBase	getSocket()
void	hiccuped(Pipe pipe)
void	incSeqnum()
void	pipeTerminated(Pipe pipe)
protected void	processAttach(IEngine engine)
protected void	processPlug()
protected void	processTerm(int linger)
protected Msg	pullMsg()
protected boolean	pushMsg(Msg msg)
void	readActivated(Pipe pipe)
Msg	readZapMsg()
private void	reconnect()
protected void	reset()
private void	startConnecting(boolean wait)
void	timerEvent(int id)	Called when timer expires.
java.lang.String	toString()
void	writeActivated(Pipe pipe)
boolean	writeZapMsg(Msg msg)
int	zapConnect()
protected boolean	zapEnabled()

Methods inherited from class zmq.Own

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

Methods inherited from class zmq.ZObject

chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, 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, connectEvent, inEvent, outEvent

Field Detail

active

private final boolean active

pipe

private Pipe pipe

zapPipe

private Pipe zapPipe

terminatingPipes

private final java.util.Set<Pipe> terminatingPipes

incompleteIn

private boolean incompleteIn

pending

private boolean pending

engine

private IEngine engine

socket

protected final SocketBase socket

ioThread

private final IOThread ioThread

LINGER_TIMER_ID

private static final int LINGER_TIMER_ID

See Also:

Constant Field Values

hasLingerTimer

private boolean hasLingerTimer

addr

private final Address addr

ioObject

private final IOObject ioObject

Constructor Detail

SessionBase

public SessionBase(IOThread ioThread,
                   boolean connect,
                   SocketBase socket,
                   Options options,
                   Address addr)

Method Detail

destroy

public void destroy()

Specified by:

destroy in class Own

attachPipe

public void attachPipe(Pipe pipe)

pullMsg

protected Msg pullMsg()

pushMsg

protected boolean pushMsg(Msg msg)

readZapMsg

public Msg readZapMsg()

writeZapMsg

public boolean writeZapMsg(Msg msg)

reset

protected void reset()

flush

public void flush()

cleanPipes

private void cleanPipes()

pipeTerminated

public void pipeTerminated(Pipe pipe)

Specified by:

pipeTerminated in interface Pipe.IPipeEvents

readActivated

public void readActivated(Pipe pipe)

Specified by:

readActivated in interface Pipe.IPipeEvents

writeActivated

public void writeActivated(Pipe pipe)

Specified by:

writeActivated in interface Pipe.IPipeEvents

hiccuped

public void hiccuped(Pipe pipe)

Specified by:

hiccuped in interface Pipe.IPipeEvents

getSocket

public SocketBase getSocket()

processPlug

protected void processPlug()

Overrides:

processPlug in class ZObject

zapConnect

public int zapConnect()

zapEnabled

protected boolean zapEnabled()

processAttach

protected void processAttach(IEngine engine)

Overrides:

processAttach in class ZObject

engineError

public void engineError(boolean handshaked,
                        StreamEngine.ErrorReason reason)

processTerm

protected void processTerm(int linger)

Overrides:

processTerm in class Own

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.

reconnect

private void reconnect()

startConnecting

private void startConnecting(boolean wait)

getEndpoint

public java.lang.String getEndpoint()

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

incSeqnum

public final void incSeqnum()

Overrides:

incSeqnum in class Own