Package zmq.io
Class IOObject
- java.lang.Object
-
- zmq.io.IOObject
-
- All Implemented Interfaces:
IPollEvents
public class IOObject extends java.lang.Object implements IPollEvents
-
-
Field Summary
Fields Modifier and Type Field Description private boolean
alive
private IPollEvents
handler
private Poller
poller
-
Constructor Summary
Constructors Constructor Description IOObject(IOThread ioThread, IPollEvents handler)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
acceptEvent()
Called by I/O thread when file descriptor is ready for accept.Poller.Handle
addFd(java.nio.channels.SelectableChannel fd)
void
addTimer(long timeout, int id)
void
cancelTimer(int id)
void
connectEvent()
Called by I/O thread when file descriptor might be ready for connecting.void
inEvent()
Called by I/O thread when file descriptor is ready for reading.void
outEvent()
Called by I/O thread when file descriptor is ready for writing.void
plug()
void
removeHandle(Poller.Handle handle)
void
resetPollIn(Poller.Handle handle)
void
resetPollOut(Poller.Handle handle)
void
setPollAccept(Poller.Handle handle)
void
setPollConnect(Poller.Handle handle)
void
setPollIn(Poller.Handle handle)
void
setPollOut(Poller.Handle handle)
void
timerEvent(int id)
Called when timer expires.java.lang.String
toString()
void
unplug()
-
-
-
Field Detail
-
poller
private final Poller poller
-
handler
private final IPollEvents handler
-
alive
private boolean alive
-
-
Constructor Detail
-
IOObject
public IOObject(IOThread ioThread, IPollEvents handler)
-
-
Method Detail
-
plug
public final void plug()
-
unplug
public final void unplug()
-
addFd
public final Poller.Handle addFd(java.nio.channels.SelectableChannel fd)
-
removeHandle
public final void removeHandle(Poller.Handle handle)
-
setPollIn
public final void setPollIn(Poller.Handle handle)
-
setPollOut
public final void setPollOut(Poller.Handle handle)
-
setPollConnect
public final void setPollConnect(Poller.Handle handle)
-
setPollAccept
public final void setPollAccept(Poller.Handle handle)
-
resetPollIn
public final void resetPollIn(Poller.Handle handle)
-
resetPollOut
public final void resetPollOut(Poller.Handle handle)
-
inEvent
public final void inEvent()
Description copied from interface:IPollEvents
Called by I/O thread when file descriptor is ready for reading.- Specified by:
inEvent
in interfaceIPollEvents
-
outEvent
public final void outEvent()
Description copied from interface:IPollEvents
Called by I/O thread when file descriptor is ready for writing.- Specified by:
outEvent
in interfaceIPollEvents
-
connectEvent
public final void connectEvent()
Description copied from interface:IPollEvents
Called by I/O thread when file descriptor might be ready for connecting.- Specified by:
connectEvent
in interfaceIPollEvents
-
acceptEvent
public final void acceptEvent()
Description copied from interface:IPollEvents
Called by I/O thread when file descriptor is ready for accept.- Specified by:
acceptEvent
in interfaceIPollEvents
-
timerEvent
public final void timerEvent(int id)
Description copied from interface:IPollEvents
Called when timer expires.- Specified by:
timerEvent
in interfaceIPollEvents
- Parameters:
id
- the ID of the expired timer.
-
addTimer
public final void addTimer(long timeout, int id)
-
cancelTimer
public final void cancelTimer(int id)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-