public class Radio extends SocketBase
Modifier and Type | Class and Description |
---|---|
static class |
Radio.RadioSession |
Modifier and Type | Field and Description |
---|---|
private Dist |
dist |
private java.util.Map<java.lang.String,java.util.List<Pipe>> |
subscriptions |
connectRid
Modifier and Type | Method and Description |
---|---|
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) |
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, 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 java.util.Map<java.lang.String,java.util.List<Pipe>> subscriptions
private final Dist dist
public Radio(Ctx parent, int tid, int sid)
public void xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
xattachPipe
in class SocketBase
public void xreadActivated(Pipe pipe)
xreadActivated
in class SocketBase
public void xwriteActivated(Pipe pipe)
xwriteActivated
in class SocketBase
public void xpipeTerminated(Pipe pipe)
xpipeTerminated
in class SocketBase
protected boolean xsend(Msg msg)
xsend
in class SocketBase
protected Msg xrecv()
xrecv
in class SocketBase
protected boolean xhasIn()
xhasIn
in class SocketBase
protected boolean xhasOut()
xhasOut
in class SocketBase