public static class Radio.RadioSession extends SessionBase
Modifier and Type | Class and Description |
---|---|
(package private) static class |
Radio.RadioSession.State |
Modifier and Type | Field and Description |
---|---|
private Msg |
pending |
private Radio.RadioSession.State |
state |
socket
Constructor and Description |
---|
RadioSession(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
private Radio.RadioSession.State state
private Msg pending
public RadioSession(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