zmq

Class SessionBase

java.lang.Object

zmq.ZObject

zmq.Own

zmq.SessionBase

All Implemented Interfaces:

IMsgSink, IMsgSource, IPollEvents, Pipe.IPipeEvents

Direct Known Subclasses:

Dealer.DealerSession, Pair.PairSession, Pull.PullSession, Push.PushSession, Router.RouterSession, XPub.XPubSession, XSub.XSubSession

class SessionBase
extends Own
implements Pipe.IPipeEvents, IPollEvents, IMsgSink, IMsgSource

Field Summary

Fields

Modifier and Type	Field and Description
private Address	addr
private boolean	connect
private IEngine	engine
private boolean	hasLingerTimer
private boolean	identityReceived
private boolean	identitySent
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

Fields inherited from class zmq.Own

options

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and Description
void	acceptEvent()
void	attachPipe(Pipe pipe)
private void	cleanPipes()
void	connectEvent()
static SessionBase	create(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)
void	destroy()
void	detach()
private void	detached()
void	flush()
SocketBase	getSocket()
void	hiccuped(Pipe pipe)
void	inEvent()
void	outEvent()
void	pipeTerminated(Pipe pipe)
protected void	processAttach(IEngine engine)
protected void	processPlug()
protected void	processTerm(int linger)
Msg	pullMsg()
int	pushMsg(Msg msg)
void	readActivated(Pipe pipe)
protected void	reset()
private void	startConnecting(boolean wait)
void	timerEvent(int id)
java.lang.String	toString()
void	writeActivated(Pipe pipe)

Methods inherited from class zmq.Own

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

Methods inherited from class zmq.ZObject

chooseIoThread, destroySocket, findEndpoint, getCtx, getTid, processActivateRead, processActivateWrite, processBind, processCommand, processHiccup, processPipeTerm, processPipeTermAck, processReap, processReaped, processStop, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, unregisterEndpoints

Methods inherited from class java.lang.Object

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

Field Detail

connect

private boolean connect

pipe

private Pipe pipe

terminatingPipes

private final java.util.Set<Pipe> terminatingPipes

incompleteIn

private boolean incompleteIn

pending

private boolean pending

engine

private IEngine engine

socket

protected SocketBase socket

ioThread

private IOThread ioThread

LINGER_TIMER_ID

private static final int LINGER_TIMER_ID

See Also:

Constant Field Values

hasLingerTimer

private boolean hasLingerTimer

identitySent

private boolean identitySent

identityReceived

private boolean identityReceived

addr

private final Address addr

ioObject

private IOObject ioObject

Constructor Detail

SessionBase

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

Method Detail

create

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

destroy

public void destroy()

Specified by:

destroy in class Own

attachPipe

public void attachPipe(Pipe pipe)

pullMsg

public Msg pullMsg()

Specified by:

pullMsg in interface IMsgSource

pushMsg

public int pushMsg(Msg msg)

Specified by:

pushMsg in interface IMsgSink

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

processAttach

protected void processAttach(IEngine engine)

Overrides:

processAttach in class ZObject

detach

public void detach()

processTerm

protected void processTerm(int linger)

Overrides:

processTerm in class Own

timerEvent

public void timerEvent(int id)

Specified by:

timerEvent in interface IPollEvents

detached

private void detached()

startConnecting

private void startConnecting(boolean wait)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

inEvent

public void inEvent()

Specified by:

inEvent in interface IPollEvents

outEvent

public void outEvent()

Specified by:

outEvent in interface IPollEvents

connectEvent

public void connectEvent()

Specified by:

connectEvent in interface IPollEvents

acceptEvent

public void acceptEvent()

Specified by:

acceptEvent in interface IPollEvents