class Pipe extends ZObject
| Modifier and Type | Class and Description |
|---|---|
(package private) static interface |
Pipe.IPipeEvents |
(package private) static class |
Pipe.State |
| Modifier and Type | Field and Description |
|---|---|
private boolean |
delay |
private int |
hwm |
private Blob |
identity |
private boolean |
inActive |
private YPipe<Msg> |
inpipe |
private int |
lwm |
private long |
msgsRead |
private long |
msgsWritten |
private boolean |
outActive |
private YPipe<Msg> |
outpipe |
private ZObject |
parent |
private Pipe |
peer |
private long |
peersMsgsRead |
private Pipe.IPipeEvents |
sink |
private Pipe.State |
state |
| Modifier | Constructor and Description |
|---|---|
private |
Pipe(ZObject parent,
YPipe<Msg> inpipe,
YPipe<Msg> outpipe,
int inhwm,
int outhwm,
boolean delay) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
checkHwm() |
boolean |
checkRead() |
boolean |
checkWrite() |
private static int |
computeLwm(int hwm) |
private void |
delimit() |
void |
flush() |
Blob |
getIdentity() |
void |
hiccup() |
private static boolean |
isDelimiter(Msg msg) |
static void |
pipepair(ZObject[] parents,
Pipe[] pipes,
int[] hwms,
boolean[] delays) |
protected void |
processActivateRead() |
protected void |
processActivateWrite(long msgsRead) |
protected void |
processHiccup(java.lang.Object pipe) |
protected void |
processPipeTerm() |
protected void |
processPipeTermAck() |
Msg |
read() |
void |
rollback() |
void |
setEventSink(Pipe.IPipeEvents sink) |
void |
setIdentity(Blob identity) |
private void |
setPeer(Pipe peer) |
void |
terminate(boolean delay) |
java.lang.String |
toString() |
boolean |
write(Msg msg) |
chooseIoThread, destroySocket, findEndpoint, getCtx, getTid, processAttach, processBind, processCommand, processOwn, processPlug, processReap, processReaped, processSeqnum, processStop, processTerm, processTermAck, processTermReq, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, unregisterEndpointsprivate 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 ZObject parent
private void setPeer(Pipe peer)
public void setEventSink(Pipe.IPipeEvents sink)
public void setIdentity(Blob identity)
public Blob getIdentity()
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 ZObjectprotected void processActivateWrite(long msgsRead)
processActivateWrite in class ZObjectprotected void processHiccup(java.lang.Object pipe)
processHiccup in class ZObjectprotected void processPipeTerm()
processPipeTerm in class ZObjectprotected void processPipeTermAck()
processPipeTermAck in class ZObjectpublic void terminate(boolean delay)
private static boolean isDelimiter(Msg msg)
private static int computeLwm(int hwm)
private void delimit()
public void hiccup()
public boolean checkHwm()
public java.lang.String toString()
toString in class java.lang.Object