Package zmq
Class Own
- java.lang.Object
-
- zmq.ZObject
-
- zmq.Own
-
- Direct Known Subclasses:
Listener
,SessionBase
,SocketBase
,TcpConnecter
public abstract class Own extends ZObject
-
-
Field Summary
Fields Modifier and Type Field 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
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method 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()
-
Methods inherited from class zmq.ZObject
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
-
-
-
-
Field Detail
-
options
protected final Options options
-
terminating
private boolean terminating
-
sendSeqnum
private final java.util.concurrent.atomic.AtomicLong sendSeqnum
-
processedSeqnum
private long processedSeqnum
-
owner
private Own owner
-
owned
private final java.util.Set<Own> owned
-
termAcks
private int termAcks
-
errno
public final Errno errno
-
-
Method Detail
-
destroy
protected abstract void destroy()
-
processDestroy
protected void processDestroy()
-
setOwner
private void setOwner(Own owner)
-
incSeqnum
protected void incSeqnum()
-
processSeqnum
protected final void processSeqnum()
- Overrides:
processSeqnum
in classZObject
-
launchChild
protected final void launchChild(Own object)
-
termChild
protected final void termChild(Own object)
-
processTermReq
protected final void processTermReq(Own object)
- Overrides:
processTermReq
in classZObject
-
processOwn
protected final void processOwn(Own object)
- Overrides:
processOwn
in classZObject
-
terminate
protected final void terminate()
-
isTerminating
protected final boolean isTerminating()
-
processTerm
protected void processTerm(int linger)
- Overrides:
processTerm
in classZObject
-
registerTermAcks
final void registerTermAcks(int count)
-
unregisterTermAck
final void unregisterTermAck()
-
processTermAck
protected final void processTermAck()
- Overrides:
processTermAck
in classZObject
-
checkTermAcks
private void checkTermAcks()
-
-