Package zmq.poll

Class Poller

java.lang.Object

zmq.poll.PollerBase

zmq.poll.Poller

All Implemented Interfaces:

java.lang.Runnable

public final class Poller
extends PollerBase
implements java.lang.Runnable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Poller.Handle

Field Summary

Fields

Modifier and Type	Field	Description
private Ctx	ctx
private java.lang.Thread.UncaughtExceptionHandler	exnotification
private java.util.Set<Poller.Handle>	fdTable
private boolean	retired
private java.nio.channels.Selector	selector
private java.util.concurrent.CountDownLatch	stopped
private java.util.concurrent.atomic.AtomicBoolean	stopping

Fields inherited from class zmq.poll.PollerBase

worker

Constructor Summary

Constructors

Constructor	Description
Poller(Ctx ctx, java.lang.String name)

Method Summary

Modifier and Type	Method	Description
Poller.Handle	addHandle(java.nio.channels.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 zmq.poll.PollerBase

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

Methods inherited from class java.lang.Object

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

Field Detail

ctx

private final Ctx ctx

fdTable

private final java.util.Set<Poller.Handle> fdTable

retired

private boolean retired

stopping

private final java.util.concurrent.atomic.AtomicBoolean stopping

stopped

private final java.util.concurrent.CountDownLatch stopped

exnotification

private final java.lang.Thread.UncaughtExceptionHandler exnotification

selector

private java.nio.channels.Selector selector

Constructor Detail

Poller

public Poller(Ctx ctx,
              java.lang.String name)

Method Detail

destroy

public void destroy()

addHandle

public Poller.Handle addHandle(java.nio.channels.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 java.lang.Runnable

maybeRebuildSelector

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

rebuildSelector

private void rebuildSelector()