public class SessionBase extends Own implements Pipe.IPipeEvents, IPollEvents
Modifier and Type | Field and 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 and Description |
---|
SessionBase(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
Modifier and Type | Method and 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() |
isTerminating, launchChild, processDestroy, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminate
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
acceptEvent, connectEvent, inEvent, outEvent
private final boolean active
private Pipe pipe
private Pipe zapPipe
private final java.util.Set<Pipe> terminatingPipes
private boolean incompleteIn
private boolean pending
private IEngine engine
protected final SocketBase socket
private final IOThread ioThread
private static final int LINGER_TIMER_ID
private boolean hasLingerTimer
private final Address addr
private final IOObject ioObject
public SessionBase(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)
public void attachPipe(Pipe pipe)
protected Msg pullMsg()
protected boolean pushMsg(Msg msg)
public Msg readZapMsg()
public boolean writeZapMsg(Msg msg)
protected void reset()
public void flush()
private void cleanPipes()
public void pipeTerminated(Pipe pipe)
pipeTerminated
in interface Pipe.IPipeEvents
public void readActivated(Pipe pipe)
readActivated
in interface Pipe.IPipeEvents
public void writeActivated(Pipe pipe)
writeActivated
in interface Pipe.IPipeEvents
public void hiccuped(Pipe pipe)
hiccuped
in interface Pipe.IPipeEvents
public SocketBase getSocket()
protected void processPlug()
processPlug
in class ZObject
public int zapConnect()
protected boolean zapEnabled()
protected void processAttach(IEngine engine)
processAttach
in class ZObject
public void engineError(boolean handshaked, StreamEngine.ErrorReason reason)
protected void processTerm(int linger)
processTerm
in class Own
public void timerEvent(int id)
IPollEvents
timerEvent
in interface IPollEvents
id
- the ID of the expired timer.private void reconnect()
private void startConnecting(boolean wait)
public java.lang.String getEndpoint()
public java.lang.String toString()
toString
in class java.lang.Object