public class Rep extends Router
| Modifier and Type | Class and Description |
|---|---|
static class |
Rep.RepSession |
Router.Outpipe, Router.RouterSession| Modifier and Type | Field and Description |
|---|---|
private boolean |
requestBegins |
private boolean |
sendingReply |
errno| Modifier and Type | Method and Description |
|---|---|
protected boolean |
xhasIn() |
protected boolean |
xhasOut() |
protected Msg |
xrecv() |
protected boolean |
xsend(Msg msg) |
rollback, xattachPipe, xpipeTerminated, xreadActivated, xsetsockopt, xwriteActivatedacceptEvent, bind, checkTag, close, connect, connectEvent, create, destroy, errno, eventAccepted, eventAcceptFailed, eventBindFailed, eventClosed, eventCloseFailed, eventConnectDelayed, eventConnected, eventConnectRetried, eventDisconnected, eventListening, getFD, getMailbox, getSocketOpt, getsockoptx, hasIn, hasOut, hiccuped, inEvent, monitor, monitorEvent, outEvent, pipeTerminated, processBind, processDestroy, processStop, processTerm, readActivated, recv, send, setSocketOpt, startReaping, stop, stopMonitor, termEndpoint, timerEvent, toString, typeString, writeActivated, xhiccupedincSeqnum, isTerminating, launchChild, processOwn, processSeqnum, processTermAck, processTermReq, registerTermAcks, termChild, terminate, unregisterTermAckchooseIoThread, destroySocket, findEndpoint, getCtx, getTid, processActivateRead, processActivateWrite, processAttach, processCommand, processHiccup, processPipeTerm, processPipeTermAck, processPlug, processReap, processReaped, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, unregisterEndpointspublic Rep(Ctx parent, int tid, int sid)