public class Pipe extends ZObject
Modifier and Type | Class and Description |
---|---|
static interface |
Pipe.IPipeEvents |
(package private) static class |
Pipe.State |
Modifier and Type | Field and Description |
---|---|
private boolean |
conflate |
private Blob |
credential |
private boolean |
delay |
private Msg |
disconnectMsg |
private int |
hwm |
private Blob |
identity |
private boolean |
inActive |
private YPipeBase<Msg> |
inpipe |
private int |
lwm |
private long |
msgsRead |
private long |
msgsWritten |
private boolean |
outActive |
private YPipeBase<Msg> |
outpipe |
private ZObject |
parent |
private Pipe |
peer |
private long |
peersMsgsRead |
private int |
routingId |
private Pipe.IPipeEvents |
sink |
private Pipe.State |
state |
Modifier | Constructor and Description |
---|---|
private |
Pipe(ZObject parent,
YPipeBase<Msg> inpipe,
YPipeBase<Msg> outpipe,
int inhwm,
int outhwm,
boolean conflate) |
Modifier and Type | Method and Description |
---|---|
boolean |
checkHwm() |
boolean |
checkRead() |
boolean |
checkWrite() |
private static int |
computeLwm(int hwm) |
void |
flush() |
Blob |
getCredential() |
Blob |
getIdentity() |
int |
getRoutingId() |
void |
hiccup() |
private static boolean |
isDelimiter(Msg msg) |
static Pipe[] |
pair(ZObject[] parents,
int[] hwms,
boolean[] conflates) |
protected void |
processActivateRead() |
protected void |
processActivateWrite(long msgsRead) |
private void |
processDelimiter() |
protected void |
processHiccup(YPipeBase<Msg> pipe) |
protected void |
processPipeTerm() |
protected void |
processPipeTermAck() |
Msg |
read() |
void |
rollback() |
void |
sendDisconnectMsg() |
void |
sendHiccupMsg(Msg hiccupMsg) |
void |
setDisconnectMsg(Msg msg) |
void |
setEventSink(Pipe.IPipeEvents sink) |
void |
setHwms(int inhwm,
int outhwm) |
void |
setIdentity(Blob identity) |
void |
setNoDelay() |
private void |
setPeer(Pipe peer) |
void |
setRoutingId(int routingId) |
void |
terminate(boolean delay) |
java.lang.String |
toString() |
boolean |
write(Msg msg) |
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processAttach, processBind, processCancel, processOwn, processPlug, processReap, processReapAck, processReaped, processSeqnum, processStop, processTerm, processTermAck, processTermReq, 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
private boolean inActive
private boolean outActive
private int hwm
private int lwm
private long msgsRead
private long msgsWritten
private long peersMsgsRead
private Pipe peer
private Pipe.IPipeEvents sink
private Pipe.State state
private boolean delay
private Blob identity
private int routingId
private Blob credential
private final boolean conflate
private Msg disconnectMsg
private final ZObject parent
private void setPeer(Pipe peer)
public void setEventSink(Pipe.IPipeEvents sink)
public void setIdentity(Blob identity)
public Blob getIdentity()
public void setRoutingId(int routingId)
public int getRoutingId()
public Blob getCredential()
public boolean checkRead()
public Msg read()
public boolean checkWrite()
public boolean write(Msg msg)
public void rollback()
public void flush()
protected void processActivateRead()
processActivateRead
in class ZObject
protected void processActivateWrite(long msgsRead)
processActivateWrite
in class ZObject
protected void processHiccup(YPipeBase<Msg> pipe)
processHiccup
in class ZObject
protected void processPipeTerm()
processPipeTerm
in class ZObject
protected void processPipeTermAck()
processPipeTermAck
in class ZObject
public void setNoDelay()
public void terminate(boolean delay)
private static boolean isDelimiter(Msg msg)
private static int computeLwm(int hwm)
private void processDelimiter()
public void hiccup()
public void setHwms(int inhwm, int outhwm)
public boolean checkHwm()
public void setDisconnectMsg(Msg msg)
public void sendDisconnectMsg()
public void sendHiccupMsg(Msg hiccupMsg)
public java.lang.String toString()
toString
in class java.lang.Object