public class Pull extends SocketBase
Modifier and Type | Field and Description |
---|---|
private FQ |
fq |
connectRid
Modifier and Type | Method and Description |
---|---|
protected Blob |
getCredential() |
protected void |
xattachPipe(Pipe pipe,
boolean subscribe2all,
boolean isLocallyInitiated) |
protected boolean |
xhasIn() |
protected void |
xpipeTerminated(Pipe pipe) |
protected void |
xreadActivated(Pipe pipe) |
Msg |
xrecv() |
bind, cancel, close, connect, connectPeer, destroy, disconnectPeer, errno, eventAccepted, eventAcceptFailed, eventBindFailed, eventClosed, eventCloseFailed, eventConnectDelayed, eventConnected, eventConnectRetried, eventDisconnected, eventHandshakeFailedAuth, eventHandshakeFailedNoDetail, eventHandshakeFailedProtocol, eventHandshaken, eventHandshakeSucceeded, eventListening, 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, xhasOut, xhiccuped, xjoin, xleave, xsend, xsetsockopt, xwriteActivated
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 FQ fq
public Pull(Ctx parent, int tid, int sid)
protected void xattachPipe(Pipe pipe, boolean subscribe2all, boolean isLocallyInitiated)
xattachPipe
in class SocketBase
protected void xreadActivated(Pipe pipe)
xreadActivated
in class SocketBase
protected void xpipeTerminated(Pipe pipe)
xpipeTerminated
in class SocketBase
public Msg xrecv()
xrecv
in class SocketBase
protected boolean xhasIn()
xhasIn
in class SocketBase
protected Blob getCredential()
getCredential
in class SocketBase