zmq

Class Poller

java.lang.Object

zmq.Poller

All Implemented Interfaces:

Runnable

public class Poller
extends Object
implements Runnable

Constructor Summary

Constructors

Constructor and Description
Poller()
Poller(String name)

Method Summary

Methods

Modifier and Type	Method and Description
void	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(SelectableChannel handle)
void	resetPollOn(SelectableChannel handle)
void	resetPollOut(SelectableChannel handle)
void	run()
void	setPollAccept(SelectableChannel handle)
void	setPollConnect(SelectableChannel handle)
void	setPollIn(SelectableChannel handle)
void	setPollOut(SelectableChannel handle)
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Constructor Detail

Poller

public Poller()

Poller

public Poller(String name)

Method Detail

destroy

public void destroy()

addHandle

public final void addHandle(SelectableChannel fd,
             IPollEvents events)

removeHandle

public final void removeHandle(SelectableChannel handle)

setPollIn

public final void setPollIn(SelectableChannel handle)

resetPollOn

public final void resetPollOn(SelectableChannel handle)

setPollOut

public final void setPollOut(SelectableChannel handle)

resetPollOut

public final void resetPollOut(SelectableChannel handle)

setPollConnect

public final void setPollConnect(SelectableChannel handle)

setPollAccept

public final void setPollAccept(SelectableChannel 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()