public class HelloMsgSession extends SessionBase
Modifier and Type | Field and Description |
---|---|
(package private) boolean |
newPipe |
socket
Constructor and Description |
---|
HelloMsgSession(IOThread ioThread,
boolean connect,
SocketBase socket,
Options options,
Address addr) |
Modifier and Type | Method and Description |
---|---|
protected Msg |
pullMsg() |
protected void |
reset() |
attachPipe, destroy, engineError, flush, getEndpoint, getSocket, hiccuped, incSeqnum, pipeTerminated, processAttach, processPlug, processTerm, pushMsg, 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
public HelloMsgSession(IOThread ioThread, boolean connect, SocketBase socket, Options options, Address addr)
protected Msg pullMsg()
pullMsg
in class SessionBase
protected void reset()
reset
in class SessionBase