public abstract class Own extends ZObject
Modifier and Type | Field and Description |
---|---|
Errno |
errno |
protected Options |
options |
private java.util.Set<Own> |
owned |
private Own |
owner |
private long |
processedSeqnum |
private java.util.concurrent.atomic.AtomicLong |
sendSeqnum |
private int |
termAcks |
private boolean |
terminating |
Modifier | Constructor and Description |
---|---|
protected |
Own(Ctx parent,
int tid) |
protected |
Own(IOThread ioThread,
Options options) |
Modifier and Type | Method and Description |
---|---|
private void |
checkTermAcks() |
protected abstract void |
destroy() |
protected void |
incSeqnum() |
protected boolean |
isTerminating() |
protected void |
launchChild(Own object) |
protected void |
processDestroy() |
protected void |
processOwn(Own object) |
protected void |
processSeqnum() |
protected void |
processTerm(int linger) |
protected void |
processTermAck() |
protected void |
processTermReq(Own object) |
(package private) void |
registerTermAcks(int count) |
private void |
setOwner(Own owner) |
protected void |
termChild(Own object) |
protected void |
terminate() |
(package private) void |
unregisterTermAck() |
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processAttach, processBind, processCancel, processCommand, processHiccup, processPipeTerm, processPipeTermAck, processPlug, processReap, processReapAck, processReaped, processStop, 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
protected final Options options
private boolean terminating
private final java.util.concurrent.atomic.AtomicLong sendSeqnum
private long processedSeqnum
private Own owner
private final java.util.Set<Own> owned
private int termAcks
public final Errno errno
protected Own(Ctx parent, int tid)
protected abstract void destroy()
protected void processDestroy()
private void setOwner(Own owner)
protected void incSeqnum()
protected final void processSeqnum()
processSeqnum
in class ZObject
protected final void launchChild(Own object)
protected final void termChild(Own object)
protected final void processTermReq(Own object)
processTermReq
in class ZObject
protected final void processOwn(Own object)
processOwn
in class ZObject
protected final void terminate()
protected final boolean isTerminating()
protected void processTerm(int linger)
processTerm
in class ZObject
final void registerTermAcks(int count)
final void unregisterTermAck()
protected final void processTermAck()
processTermAck
in class ZObject
private void checkTermAcks()