public class XPub extends SocketBase
Modifier and Type | Class and Description |
---|---|
private static class |
XPub.MarkAsMatching |
private static class |
XPub.SendUnsubscription |
Modifier and Type | Field and Description |
---|---|
private Dist |
dist |
private Pipe |
lastPipe |
private boolean |
lossy |
private boolean |
manual |
private Mtrie |
manualSubscriptions |
private static Mtrie.IMtrieHandler |
markAsMatching |
private boolean |
more |
private java.util.Deque<Blob> |
pendingData |
private java.util.Deque<java.lang.Integer> |
pendingFlags |
private java.util.Deque<Pipe> |
pendingPipes |
private static Mtrie.IMtrieHandler |
sendUnsubscription |
private Mtrie |
subscriptions |
private boolean |
verboseSubs |
private boolean |
verboseUnsubs |
connectRid
Modifier and Type | Method and Description |
---|---|
private void |
markAsMatching(Pipe pipe) |
private void |
sendUnsubscription(byte[] data,
int size) |
protected void |
xattachPipe(Pipe pipe,
boolean subscribeToAll,
boolean isLocallyInitiated) |
protected boolean |
xhasIn() |
protected boolean |
xhasOut() |
protected void |
xpipeTerminated(Pipe pipe) |
protected void |
xreadActivated(Pipe pipe) |
protected Msg |
xrecv() |
protected boolean |
xsend(Msg msg) |
boolean |
xsetsockopt(int option,
java.lang.Object optval) |
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, getCredential, 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 Mtrie subscriptions
private final Mtrie manualSubscriptions
private final Dist dist
private boolean verboseSubs
private boolean verboseUnsubs
private boolean more
private boolean lossy
private boolean manual
private Pipe lastPipe
private final java.util.Deque<Pipe> pendingPipes
private final java.util.Deque<Blob> pendingData
private final java.util.Deque<java.lang.Integer> pendingFlags
private static final Mtrie.IMtrieHandler markAsMatching
private static final Mtrie.IMtrieHandler sendUnsubscription
public XPub(Ctx parent, int tid, int sid)
protected void xattachPipe(Pipe pipe, boolean subscribeToAll, boolean isLocallyInitiated)
xattachPipe
in class SocketBase
protected void xreadActivated(Pipe pipe)
xreadActivated
in class SocketBase
protected void xwriteActivated(Pipe pipe)
xwriteActivated
in class SocketBase
public boolean xsetsockopt(int option, java.lang.Object optval)
xsetsockopt
in class SocketBase
protected void xpipeTerminated(Pipe pipe)
xpipeTerminated
in class SocketBase
private void markAsMatching(Pipe pipe)
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
private void sendUnsubscription(byte[] data, int size)