public class Req extends Dealer
| Modifier and Type | Class and Description |
|---|---|
static class |
Req.ReqSession |
Dealer.DealerSession| Modifier and Type | Field and Description |
|---|---|
private boolean |
messageBegins |
private boolean |
receivingReply |
errno| Modifier and Type | Method and Description |
|---|---|
boolean |
xhasIn() |
boolean |
xhasOut() |
protected Msg |
xrecv() |
boolean |
xsend(Msg msg) |
xattachPipe, xpipeTerminated, xreadActivated, 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, xhiccuped, xsetsockoptincSeqnum, 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, unregisterEndpointsprivate boolean receivingReply
private boolean messageBegins
public Req(Ctx parent, int tid, int sid)