final class Reaper extends ZObject implements IPollEvents, java.io.Closeable
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 |
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() |
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
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
acceptEvent, connectEvent, outEvent, timerEvent
private final Mailbox mailbox
private final Poller.Handle mailboxHandle
private final Poller poller
private int socketsReaping
private final java.util.concurrent.atomic.AtomicBoolean terminating
private final java.lang.String name
Reaper(Ctx ctx, int tid)
public void close() throws java.io.IOException
close
in interface java.io.Closeable
close
in interface java.lang.AutoCloseable
java.io.IOException
Mailbox getMailbox()
void start()
void stop()
public void inEvent()
IPollEvents
inEvent
in interface IPollEvents
protected void processStop()
processStop
in class ZObject
protected void processReap(SocketBase socket)
processReap
in class ZObject
protected void processReaped()
processReaped
in class ZObject
private void finishTerminating()