public class Req extends Dealer
Modifier and Type | Class and Description |
---|---|
static class |
Req.ReqSession |
Modifier and Type | Field and Description |
---|---|
private boolean |
messageBegins |
private boolean |
receivingReply |
private ValueReference<Pipe> |
replyPipe |
private int |
requestId |
private boolean |
requestIdFramesEnabled |
private boolean |
strict |
connectRid
Modifier and Type | Method and Description |
---|---|
private Msg |
recvReplyPipe() |
boolean |
xhasIn() |
boolean |
xhasOut() |
protected void |
xpipeTerminated(Pipe pipe) |
protected Msg |
xrecv() |
boolean |
xsend(Msg msg) |
protected boolean |
xsetsockopt(int option,
java.lang.Object optval) |
getCredential, recvpipe, sendpipe, xattachPipe, xreadActivated, xwriteActivated
bind, cancel, close, connect, connectPeer, destroy, disconnectPeer, errno, eventAccepted, eventAcceptFailed, eventBindFailed, eventClosed, eventCloseFailed, eventConnectDelayed, eventConnected, eventConnectRetried, eventDisconnected, eventHandshakeFailedAuth, eventHandshakeFailedNoDetail, eventHandshakeFailedProtocol, eventHandshaken, eventHandshakeSucceeded, eventListening, getFD, getSocketOpt, getSocketOptx, hiccuped, inEvent, join, leave, monitor, monitorEvent, pipeTerminated, poll, processBind, processDestroy, processStop, processTerm, readActivated, recv, recv, send, send, setSocketOpt, termEndpoint, toString, typeString, writeActivated, xdisconnectPeer, xhiccuped, xjoin, xleave
incSeqnum, isTerminating, launchChild, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminate
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processAttach, processCancel, processHiccup, processPipeTerm, processPipeTermAck, processPlug, processReap, processReapAck, processReaped, 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, outEvent, timerEvent
private boolean receivingReply
private boolean messageBegins
private final ValueReference<Pipe> replyPipe
private boolean requestIdFramesEnabled
private int requestId
private boolean strict
public Req(Ctx parent, int tid, int sid)
protected boolean xsetsockopt(int option, java.lang.Object optval)
xsetsockopt
in class Dealer
protected void xpipeTerminated(Pipe pipe)
xpipeTerminated
in class Dealer
private Msg recvReplyPipe()