Class Poller

java.lang.Object

zmq.poll.PollerBase

zmq.poll.Poller

All Implemented Interfaces:

Runnable

public final class Poller
extends PollerBase
implements Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	Poller.Handle

Field Summary

Fields

Modifier and Type	Field	Description
private final Ctx	ctx
private final Thread.UncaughtExceptionHandler	exnotification
private final Set<Poller.Handle>	fdTable
private boolean	retired
private Selector	selector
private final CountDownLatch	stopped
private final AtomicBoolean	stopping

Fields inherited from class PollerBase

worker

Constructor Summary

Constructors

Constructor	Description
Poller(Ctx ctx, String name)

Method Summary

Modifier and Type	Method	Description
Poller.Handle	addHandle(SelectableChannel fd, IPollEvents events)
void	destroy()
private int	maybeRebuildSelector(int returnsImmediately, long timeout, long start)
private void	rebuildSelector()
private void	register(Poller.Handle handle, int ops, boolean add)
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 PollerBase

addTimer, adjustLoad, cancelTimer, clock, createWorker, executeTimers, getLoad, isEmpty

Methods inherited from class Object

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

Field Details

ctx

private final Ctx ctx

fdTable

private final Set<Poller.Handle> fdTable

retired

private boolean retired

stopping

private final AtomicBoolean stopping

stopped

private final CountDownLatch stopped

exnotification

private final Thread.UncaughtExceptionHandler exnotification

selector

private Selector selector

Constructor Details

Poller

public Poller(Ctx ctx,
 String name)

Method Details

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)

register

private void register(Poller.Handle handle,
 int ops,
 boolean add)

start

public void start()

stop

public void stop()

run

public void run()

Specified by:

run in interface Runnable

maybeRebuildSelector

private int maybeRebuildSelector(int returnsImmediately,
 long timeout,
 long start)

rebuildSelector

private void rebuildSelector()