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

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()

Methods inherited from class java.lang.Object

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

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 interface IPollEvents

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 interface IPollEvents

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 interface IPollEvents

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 interface IPollEvents

timerEvent

public final void timerEvent(int id)

Description copied from interface: IPollEvents

Called when timer expires.

Specified by:

timerEvent in interface IPollEvents

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 class java.lang.Object