class Pull extends SocketBase
| Modifier and Type | Class and Description |
|---|---|
static class |
Pull.PullSession |
| Modifier and Type | Field and Description |
|---|---|
private FQ |
fq |
errno| Modifier and Type | Method and Description |
|---|---|
protected void |
xattachPipe(Pipe pipe,
boolean icanhasall) |
protected boolean |
xhasIn() |
protected void |
xpipeTerminated(Pipe pipe) |
protected void |
xreadActivated(Pipe pipe) |
Msg |
xrecv() |
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, xhasOut, xhiccuped, xsend, xsetsockopt, xwriteActivatedincSeqnum, 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 FQ fq
public Pull(Ctx parent, int tid, int sid)
protected void xattachPipe(Pipe pipe, boolean icanhasall)
xattachPipe in class SocketBaseprotected void xreadActivated(Pipe pipe)
xreadActivated in class SocketBaseprotected void xpipeTerminated(Pipe pipe)
xpipeTerminated in class SocketBasepublic Msg xrecv()
xrecv in class SocketBaseprotected boolean xhasIn()
xhasIn in class SocketBase