public class Push 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) |
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, 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 LB lb
public Push(Ctx parent, int tid, int sid)
protected void xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
xattachPipe
in class SocketBase
protected void xwriteActivated(Pipe pipe)
xwriteActivated
in class SocketBase
protected void xpipeTerminated(Pipe pipe)
xpipeTerminated
in class SocketBase
public boolean xsend(Msg msg)
xsend
in class SocketBase
protected boolean xhasOut()
xhasOut
in class SocketBase