Package zmq.io
Class SessionBase
- java.lang.Object
-
- zmq.ZObject
-
- zmq.Own
-
- zmq.io.SessionBase
-
- All Implemented Interfaces:
Pipe.IPipeEvents
,IPollEvents
- Direct Known Subclasses:
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
-
Constructor Summary
Constructors Constructor Description SessionBase(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
attachPipe(Pipe pipe)
private void
cleanPipes()
void
destroy()
void
engineError(StreamEngine.ErrorReason reason)
void
flush()
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, processHiccup, processPipeTerm, processPipeTermAck, processReap, processReaped, processStop, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, 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
-
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 interfacePipe.IPipeEvents
-
readActivated
public void readActivated(Pipe pipe)
- Specified by:
readActivated
in interfacePipe.IPipeEvents
-
writeActivated
public void writeActivated(Pipe pipe)
- Specified by:
writeActivated
in interfacePipe.IPipeEvents
-
hiccuped
public void hiccuped(Pipe pipe)
- Specified by:
hiccuped
in interfacePipe.IPipeEvents
-
getSocket
public SocketBase getSocket()
-
processPlug
protected void processPlug()
- Overrides:
processPlug
in classZObject
-
zapConnect
public int zapConnect()
-
zapEnabled
protected boolean zapEnabled()
-
processAttach
protected void processAttach(IEngine engine)
- Overrides:
processAttach
in classZObject
-
engineError
public void engineError(StreamEngine.ErrorReason reason)
-
processTerm
protected void processTerm(int linger)
- Overrides:
processTerm
in classOwn
-
timerEvent
public void timerEvent(int id)
Description copied from interface:IPollEvents
Called when timer expires.- Specified by:
timerEvent
in interfaceIPollEvents
- Parameters:
id
- the ID of the expired timer.
-
reconnect
private void reconnect()
-
startConnecting
private void startConnecting(boolean wait)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-