zmq.poll

Class Poller

java.lang.Object

zmq.poll.Poller

All Implemented Interfaces:

Runnable

public final class Poller
extends Object
implements Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	Poller.Handle

Field Summary

Fields

Modifier and Type	Field and Description
protected Thread	worker

Constructor Summary

Constructors

Constructor and Description
Poller(Ctx ctx, String name)

Method Summary

Modifier and Type	Method and Description
Poller.Handle	addHandle(SelectableChannel fd, IPollEvents events)
void	addTimer(long timeout, IPollEvents sink, int id)
protected void	adjustLoad(int amount)
void	cancelTimer(IPollEvents sink, int id)
void	destroy()
protected long	executeTimers()
int	getLoad()
void	removeHandle(Poller.Handle handle)
void	resetPollIn(Poller.Handle handle)
void	resetPollOut(Poller.Handle handle)
void	run()
void	setPollAccept(Poller.Handle handle)
void	setPollConnect(Poller.Handle handle)
void	setPollIn(Poller.Handle handle)
void	setPollOut(Poller.Handle handle)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

worker

protected final Thread worker

Constructor Detail

Poller

public Poller(Ctx ctx,
              String name)

Method Detail

destroy

public void destroy()

addHandle

public Poller.Handle addHandle(SelectableChannel fd,
                               IPollEvents events)

removeHandle

public void removeHandle(Poller.Handle handle)

setPollIn

public void setPollIn(Poller.Handle handle)

resetPollIn

public void resetPollIn(Poller.Handle handle)

setPollOut

public void setPollOut(Poller.Handle handle)

resetPollOut

public void resetPollOut(Poller.Handle handle)

setPollConnect

public void setPollConnect(Poller.Handle handle)

setPollAccept

public void setPollAccept(Poller.Handle handle)

start

public void start()

stop

public void stop()

run

public void run()

Specified by:

run in interface Runnable

getLoad

public final int getLoad()

adjustLoad

protected void adjustLoad(int amount)

addTimer

public void addTimer(long timeout,
                     IPollEvents sink,
                     int id)

cancelTimer

public void cancelTimer(IPollEvents sink,
                        int id)

executeTimers

protected long executeTimers()