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, xleaveincSeqnum, isTerminating, launchChild, processOwn, processSeqnum, processTermAck, processTermReq, termChild, terminatechooseIoThread, 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, unregisterEndpointsclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitacceptEvent, connectEvent, outEvent, timerEventprivate 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 SocketBaseprotected void xreadActivated(Pipe pipe)
xreadActivated in class SocketBaseprotected void xwriteActivated(Pipe pipe)
xwriteActivated in class SocketBasepublic boolean xsetsockopt(int option,
java.lang.Object optval)
xsetsockopt in class SocketBaseprotected void xpipeTerminated(Pipe pipe)
xpipeTerminated in class SocketBaseprivate void markAsMatching(Pipe pipe)
protected boolean xsend(Msg msg)
xsend in class SocketBaseprotected boolean xhasOut()
xhasOut in class SocketBaseprotected Msg xrecv()
xrecv in class SocketBaseprotected boolean xhasIn()
xhasIn in class SocketBaseprivate void sendUnsubscription(byte[] data,
int size)