public class Router extends SocketBase
Modifier and Type | Class and Description |
---|---|
(package private) class |
Router.Outpipe |
Modifier and Type | Field and Description |
---|---|
private java.util.Set<Pipe> |
anonymousPipes |
private Pipe |
currentOut |
private FQ |
fq |
private boolean |
handover |
private boolean |
identitySent |
private boolean |
mandatory |
private boolean |
moreIn |
private boolean |
moreOut |
private int |
nextRid |
private java.util.Map<Blob,Router.Outpipe> |
outpipes |
private boolean |
prefetched |
private Msg |
prefetchedId |
private Msg |
prefetchedMsg |
private boolean |
probeRouter |
private boolean |
rawSocket |
connectRid
Modifier and Type | Method and Description |
---|---|
protected void |
destroy() |
protected Blob |
getCredential() |
private boolean |
identifyPeer(Pipe pipe,
boolean isLocallyInitiated) |
protected boolean |
rollback() |
void |
xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected boolean |
xhasIn() |
protected boolean |
xhasOut() |
void |
xpipeTerminated(Pipe pipe) |
void |
xreadActivated(Pipe pipe) |
protected Msg |
xrecv() |
protected boolean |
xsend(Msg msg) |
boolean |
xsetsockopt(int option,
java.lang.Object optval) |
void |
xwriteActivated(Pipe pipe) |
bind, cancel, close, connect, connectPeer, 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 final FQ fq
private boolean prefetched
private boolean identitySent
private Msg prefetchedId
private Msg prefetchedMsg
private boolean moreIn
private final java.util.Set<Pipe> anonymousPipes
private final java.util.Map<Blob,Router.Outpipe> outpipes
private Pipe currentOut
private boolean moreOut
private int nextRid
private boolean mandatory
private boolean rawSocket
private boolean probeRouter
private boolean handover
public Router(Ctx parent, int tid, int sid)
protected void destroy()
destroy
in class SocketBase
public void xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
xattachPipe
in class SocketBase
public boolean xsetsockopt(int option, java.lang.Object optval)
xsetsockopt
in class SocketBase
public void xpipeTerminated(Pipe pipe)
xpipeTerminated
in class SocketBase
public void xreadActivated(Pipe pipe)
xreadActivated
in class SocketBase
public void xwriteActivated(Pipe pipe)
xwriteActivated
in class SocketBase
protected boolean xsend(Msg msg)
xsend
in class SocketBase
protected Msg xrecv()
xrecv
in class SocketBase
protected boolean rollback()
protected boolean xhasIn()
xhasIn
in class SocketBase
protected boolean xhasOut()
xhasOut
in class SocketBase
protected Blob getCredential()
getCredential
in class SocketBase
private boolean identifyPeer(Pipe pipe, boolean isLocallyInitiated)