Package zmq
Class Own
java.lang.Object
zmq.ZObject
zmq.Own
- Direct Known Subclasses:
SessionBase
,SocketBase
,TcpConnecter
,TcpListener
-
Field Summary
FieldsModifier and TypeFieldDescriptionfinal Errno
protected final Options
private Own
private long
private final AtomicLong
private int
private boolean
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate void
protected abstract void
destroy()
protected void
protected final boolean
protected final void
launchChild
(Own object) protected void
protected final void
processOwn
(Own object) protected final void
protected void
processTerm
(int linger) protected final void
protected final void
processTermReq
(Own object) (package private) final void
registerTermAcks
(int count) private void
protected final void
protected final void
(package private) final void
Methods inherited from class zmq.ZObject
chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processAttach, processBind, processCommand, processHiccup, processPipeTerm, processPipeTermAck, processPlug, processReap, processReaped, processStop, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendInprocConnected, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, setTid, unregisterEndpoint, unregisterEndpoints
-
Field Details
-
options
-
terminating
private boolean terminating -
sendSeqnum
-
processedSeqnum
private long processedSeqnum -
owner
-
owned
-
termAcks
private int termAcks -
errno
-
-
Constructor Details
-
Own
-
Own
-
-
Method Details
-
destroy
protected abstract void destroy() -
processDestroy
protected void processDestroy() -
setOwner
-
incSeqnum
protected void incSeqnum() -
processSeqnum
protected final void processSeqnum()- Overrides:
processSeqnum
in classZObject
-
launchChild
-
termChild
-
processTermReq
- Overrides:
processTermReq
in classZObject
-
processOwn
- 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()
-