public class Reaper extends ZObject implements IPollEvents, Closeable
Modifier and Type | Method and Description |
---|---|
void |
acceptEvent() |
void |
close() |
void |
connectEvent() |
Mailbox |
getMailbox() |
void |
inEvent() |
void |
outEvent() |
protected void |
processReap(SocketBase socket) |
protected void |
processReaped() |
protected void |
processStop() |
void |
start() |
void |
stop() |
void |
timerEvent(int id) |
chooseIoThread, destroySocket, findEndpoint, getCtx, getTid, processActivateRead, processActivateWrite, processAttach, processBind, processCommand, processHiccup, processOwn, processPipeTerm, processPipeTermAck, processPlug, processSeqnum, processTerm, processTermAck, processTermReq, registerEndpoint, sendActivateRead, sendActivateWrite, sendAttach, sendAttach, sendBind, sendBind, sendDone, sendHiccup, sendOwn, sendPipeTerm, sendPipeTermAck, sendPlug, sendPlug, sendReap, sendReaped, sendStop, sendTerm, sendTermAck, sendTermReq, unregisterEndpoints
public Reaper(Ctx ctx, int tid)
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
public Mailbox getMailbox()
public void start()
public void stop()
public void inEvent()
inEvent
in interface IPollEvents
public void outEvent()
outEvent
in interface IPollEvents
public void connectEvent()
connectEvent
in interface IPollEvents
public void acceptEvent()
acceptEvent
in interface IPollEvents
public void timerEvent(int id)
timerEvent
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
Copyright © 2024. All rights reserved.