public class Push extends SocketBase
| Modifier and Type | Class and Description |
|---|---|
static class |
Push.PushSession |
| Modifier and Type | Field and Description |
|---|---|
private LB |
lb |
errno| Modifier and Type | Method and Description |
|---|---|
protected void |
xattachPipe(Pipe pipe,
boolean icanhasall) |
protected boolean |
xhasOut() |
protected void |
xpipeTerminated(Pipe pipe) |
boolean |
xsend(Msg msg) |
protected void |
xwriteActivated(Pipe pipe) |
acceptEvent, bind, checkTag, close, connect, connectEvent, create, destroy, errno, eventAccepted, eventAcceptFailed, eventBindFailed, eventClosed, eventCloseFailed, eventConnectDelayed, eventConnected, eventConnectRetried, eventDisconnected, eventListening, getFD, getMailbox, getSocketOpt, getsockoptx, hasIn, hasOut, hiccuped, inEvent, monitor, monitorEvent, outEvent, pipeTerminated, processBind, processDestroy, processStop, processTerm, readActivated, recv, send, setSocketOpt, startReaping, stop, stopMonitor, termEndpoint, timerEvent, toString, typeString, writeActivated, xhasIn, xhiccuped, xreadActivated, xrecv, xsetsockoptincSeqnum, isTerminating, launchChild, processOwn, processSeqnum, processTermAck, processTermReq, registerTermAcks, termChild, terminate, unregisterTermAckchooseIoThread, destroySocket, findEndpoint, getCtx, getTid, processActivateRead, processActivateWrite, processAttach, processCommand, processHiccup, processPipeTerm, processPipeTermAck, processPlug, processReap, processReaped, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, unregisterEndpointsprivate final LB lb
public Push(Ctx parent, int tid, int sid)
protected void xattachPipe(Pipe pipe, boolean icanhasall)
xattachPipe in class SocketBaseprotected void xwriteActivated(Pipe pipe)
xwriteActivated in class SocketBaseprotected void xpipeTerminated(Pipe pipe)
xpipeTerminated in class SocketBasepublic boolean xsend(Msg msg)
xsend in class SocketBaseprotected boolean xhasOut()
xhasOut in class SocketBase