public class Scatter extends SocketBase
| Modifier and Type | Field and Description |
|---|---|
private LB |
lb |
connectRid| Modifier and Type | Method and Description |
|---|---|
protected void |
xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected boolean |
xhasOut() |
protected void |
xpipeTerminated(Pipe pipe) |
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, 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, xhasIn, xhiccuped, xjoin, xleave, xreadActivated, xrecv, xsetsockoptincSeqnum, 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 LB lb
public Scatter(Ctx parent, int tid, int sid)
protected void xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
xattachPipe in class SocketBaseprotected boolean xsend(Msg msg)
xsend in class SocketBaseprotected boolean xhasOut()
xhasOut in class SocketBaseprotected void xwriteActivated(Pipe pipe)
xwriteActivated in class SocketBaseprotected void xpipeTerminated(Pipe pipe)
xpipeTerminated in class SocketBase