com.twitter.heron.common.basics

Class NIOLooper

java.lang.Object

com.twitter.heron.common.basics.WakeableLooper

com.twitter.heron.common.basics.NIOLooper

public class NIOLooper
extends WakeableLooper

A NIOLooper, implementing WakeableLooper, is a class wrapping a Java NIO selector to dispatch events. It extends WakeableLooper, so it will execute in a while loop unless the exitLoop() is called. And in every execution, in tasksOnWakeup(), it will handle the selected keys. The NIOLooper should start by calling loop()

Constructor Summary

Constructors

Constructor and Description
NIOLooper()

Method Summary

Modifier and Type	Method and Description
void	doWait()
boolean	isAcceptRegistered(java.nio.channels.SelectableChannel channel)
boolean	isChannelValid(java.nio.channels.SelectableChannel channel)
boolean	isConnectRegistered(java.nio.channels.SelectableChannel channel)
boolean	isReadRegistered(java.nio.channels.SelectableChannel channel)
boolean	isWriteRegistered(java.nio.channels.SelectableChannel channel)
void	registerAccept(java.nio.channels.SelectableChannel channel, ISelectHandler callback)
void	registerConnect(java.nio.channels.SelectableChannel channel, ISelectHandler callback)
void	registerRead(java.nio.channels.SelectableChannel channel, ISelectHandler callback) Followings are the register, unregister, isRegister for different operations for the selector and channel
void	registerWrite(java.nio.channels.SelectableChannel channel, ISelectHandler callback)
void	removeAllInterest(java.nio.channels.SelectableChannel channel)
void	unregisterAccept(java.nio.channels.SelectableChannel channel)
void	unregisterConnect(java.nio.channels.SelectableChannel channel)
void	unregisterRead(java.nio.channels.SelectableChannel channel)
void	unregisterWrite(java.nio.channels.SelectableChannel channel)
void	wakeUp()

Methods inherited from class com.twitter.heron.common.basics.WakeableLooper

addTasksOnExit, addTasksOnWakeup, exitLoop, getNextTimeoutIntervalMs, loop, registerTimerEventInNanoSeconds, registerTimerEventInSeconds

Methods inherited from class java.lang.Object

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

Constructor Detail

NIOLooper

public NIOLooper()
          throws java.io.IOException

Throws:

java.io.IOException

Method Detail

doWait

public void doWait()

Specified by:

doWait in class WakeableLooper

wakeUp

public void wakeUp()

Specified by:

wakeUp in class WakeableLooper

removeAllInterest

public void removeAllInterest(java.nio.channels.SelectableChannel channel)

isChannelValid

public boolean isChannelValid(java.nio.channels.SelectableChannel channel)

registerRead

public void registerRead(java.nio.channels.SelectableChannel channel,
                         ISelectHandler callback)
                  throws java.nio.channels.ClosedChannelException

Followings are the register, unregister, isRegister for different operations for the selector and channel

Throws:

java.nio.channels.ClosedChannelException

unregisterRead

public void unregisterRead(java.nio.channels.SelectableChannel channel)

isReadRegistered

public boolean isReadRegistered(java.nio.channels.SelectableChannel channel)

registerConnect

public void registerConnect(java.nio.channels.SelectableChannel channel,
                            ISelectHandler callback)
                     throws java.nio.channels.ClosedChannelException

Throws:

java.nio.channels.ClosedChannelException

unregisterConnect

public void unregisterConnect(java.nio.channels.SelectableChannel channel)

isConnectRegistered

public boolean isConnectRegistered(java.nio.channels.SelectableChannel channel)

registerAccept

public void registerAccept(java.nio.channels.SelectableChannel channel,
                           ISelectHandler callback)
                    throws java.nio.channels.ClosedChannelException

Throws:

java.nio.channels.ClosedChannelException

unregisterAccept

public void unregisterAccept(java.nio.channels.SelectableChannel channel)

isAcceptRegistered

public boolean isAcceptRegistered(java.nio.channels.SelectableChannel channel)

registerWrite

public void registerWrite(java.nio.channels.SelectableChannel channel,
                          ISelectHandler callback)
                   throws java.nio.channels.ClosedChannelException

Throws:

java.nio.channels.ClosedChannelException

unregisterWrite

public void unregisterWrite(java.nio.channels.SelectableChannel channel)

isWriteRegistered

public boolean isWriteRegistered(java.nio.channels.SelectableChannel channel)