public class XSub extends SocketBase
Modifier and Type | Class and Description |
---|---|
private class |
XSub.SendSubscription |
Modifier and Type | Field and Description |
---|---|
private Dist |
dist |
private FQ |
fq |
private boolean |
hasMessage |
private Msg |
message |
private boolean |
more |
private Trie.ITrieHandler |
sendSubscription |
private Trie |
subscriptions |
connectRid
Modifier and Type | Method and Description |
---|---|
protected Blob |
getCredential() |
private boolean |
match(Msg msg) |
private boolean |
sendSubscription(byte[] data,
int size,
Pipe pipe) |
protected void |
xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected boolean |
xhasIn() |
protected boolean |
xhasOut() |
protected void |
xhiccuped(Pipe pipe) |
protected void |
xpipeTerminated(Pipe pipe) |
protected void |
xreadActivated(Pipe pipe) |
protected Msg |
xrecv() |
protected boolean |
xsend(Msg msg) |
protected void |
xwriteActivated(Pipe pipe) |
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, xjoin, xleave, xsetsockopt
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 final Dist dist
private final Trie subscriptions
private boolean hasMessage
private Msg message
private boolean more
private final Trie.ITrieHandler sendSubscription
public XSub(Ctx parent, int tid, int sid)
protected void xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
xattachPipe
in class SocketBase
protected void xreadActivated(Pipe pipe)
xreadActivated
in class SocketBase
protected void xwriteActivated(Pipe pipe)
xwriteActivated
in class SocketBase
protected void xpipeTerminated(Pipe pipe)
xpipeTerminated
in class SocketBase
protected void xhiccuped(Pipe pipe)
xhiccuped
in class SocketBase
protected boolean xsend(Msg msg)
xsend
in class SocketBase
protected boolean xhasOut()
xhasOut
in class SocketBase
protected Msg xrecv()
xrecv
in class SocketBase
protected boolean xhasIn()
xhasIn
in class SocketBase
protected Blob getCredential()
getCredential
in class SocketBase
private boolean match(Msg msg)
private boolean sendSubscription(byte[] data, int size, Pipe pipe)