public class Stream extends SocketBase
Modifier and Type | Class and Description |
---|---|
private class |
Stream.Outpipe |
Modifier and Type | Field and Description |
---|---|
private Pipe |
currentOut |
private FQ |
fq |
private boolean |
identitySent |
private boolean |
moreOut |
private int |
nextRid |
private java.util.Map<Blob,Stream.Outpipe> |
outpipes |
private boolean |
prefetched |
private Msg |
prefetchedId |
private Msg |
prefetchedMsg |
connectRid
Modifier and Type | Method and Description |
---|---|
private void |
identifyPeer(Pipe pipe,
boolean isLocallyInitiated) |
protected void |
xattachPipe(Pipe pipe,
boolean icanhasall,
boolean isLocallyInitiated) |
protected boolean |
xhasIn() |
protected boolean |
xhasOut() |
protected void |
xpipeTerminated(Pipe pipe) |
protected void |
xreadActivated(Pipe pipe) |
Msg |
xrecv() |
protected boolean |
xsend(Msg msg) |
protected boolean |
xsetsockopt(int option,
java.lang.Object optval) |
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, xhiccuped, xjoin, xleave
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
private boolean prefetched
private boolean identitySent
private Msg prefetchedId
private Msg prefetchedMsg
private java.util.Map<Blob,Stream.Outpipe> outpipes
private Pipe currentOut
private boolean moreOut
private int nextRid
public Stream(Ctx parent, int tid, int sid)
protected void xattachPipe(Pipe pipe, boolean icanhasall, boolean isLocallyInitiated)
xattachPipe
in class SocketBase
protected void xpipeTerminated(Pipe pipe)
xpipeTerminated
in class SocketBase
protected void xreadActivated(Pipe pipe)
xreadActivated
in class SocketBase
protected void xwriteActivated(Pipe pipe)
xwriteActivated
in class SocketBase
protected boolean xsend(Msg msg)
xsend
in class SocketBase
protected boolean xsetsockopt(int option, java.lang.Object optval)
xsetsockopt
in class SocketBase
public Msg xrecv()
xrecv
in class SocketBase
protected boolean xhasIn()
xhasIn
in class SocketBase
protected boolean xhasOut()
xhasOut
in class SocketBase
private void identifyPeer(Pipe pipe, boolean isLocallyInitiated)