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