public static class Dish.DishSession extends SessionBase
Modifier and Type | Class and Description |
---|---|
(package private) static class |
Dish.DishSession.State |
Modifier and Type | Field and Description |
---|---|
private java.lang.String |
group |
(package private) static byte[] |
JOIN_BYTES |
(package private) static byte[] |
LEAVE_BYTES |
private Dish.DishSession.State |
state |
socket
Constructor and Description |
---|
DishSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
Modifier and Type | Method and Description |
---|---|
protected Msg |
pullMsg() |
boolean |
pushMsg(Msg msg) |
protected void |
reset() |
attachPipe, destroy, engineError, flush, getEndpoint, getSocket, hiccuped, incSeqnum, pipeTerminated, processAttach, processPlug, processTerm, readActivated, readZapMsg, timerEvent, toString, writeActivated, writeZapMsg, zapConnect, 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
static final byte[] JOIN_BYTES
static final byte[] LEAVE_BYTES
private Dish.DishSession.State state
private java.lang.String group
public DishSession(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)
public boolean pushMsg(Msg msg)
pushMsg
in class SessionBase
protected Msg pullMsg()
pullMsg
in class SessionBase
protected void reset()
reset
in class SessionBase