zmq

Class Reaper

java.lang.Object

zmq.ZObject

zmq.Reaper

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, IPollEvents

final class Reaper
extends ZObject
implements IPollEvents, java.io.Closeable

Field Summary

Fields

Modifier and Type	Field and Description
private Mailbox	mailbox
private Poller.Handle	mailboxHandle
private java.lang.String	name
private Poller	poller
private int	socketsReaping
private java.util.concurrent.atomic.AtomicBoolean	terminating

Constructor Summary

Constructors

Constructor and Description
Reaper(Ctx ctx, int tid)

Method Summary

Modifier and Type	Method and Description
void	close()
private void	finishTerminating()
(package private) Mailbox	getMailbox()
void	inEvent() Called by I/O thread when file descriptor is ready for reading.
protected void	processReap(SocketBase socket)
protected void	processReaped()
protected void	processStop()
(package private) void	start()
(package private) void	stop()

Methods inherited from class zmq.ZObject

chooseIoThread, connectPending, destroySocket, findEndpoint, getCtx, getTid, pendConnection, processActivateRead, processActivateWrite, processAttach, processBind, processCancel, processCommand, processHiccup, processOwn, processPipeTerm, processPipeTermAck, processPlug, processReapAck, processSeqnum, 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface zmq.poll.IPollEvents

acceptEvent, connectEvent, outEvent, timerEvent

Field Detail

mailbox

private final Mailbox mailbox

mailboxHandle

private final Poller.Handle mailboxHandle

poller

private final Poller poller

socketsReaping

private int socketsReaping

terminating

private final java.util.concurrent.atomic.AtomicBoolean terminating

name

private final java.lang.String name

Constructor Detail

Reaper

Reaper(Ctx ctx,
       int tid)

Method Detail

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

getMailbox

Mailbox getMailbox()

start

void start()

stop

void stop()

inEvent

public void inEvent()

Description copied from interface: IPollEvents

Called by I/O thread when file descriptor is ready for reading.

Specified by:

inEvent in interface IPollEvents

processStop

protected void processStop()

Overrides:

processStop in class ZObject

processReap

protected void processReap(SocketBase socket)

Overrides:

processReap in class ZObject

processReaped

protected void processReaped()

Overrides:

processReaped in class ZObject

finishTerminating

private void finishTerminating()