Package com.google.code.yanf4j.nio.impl

Class SelectorManager

java.lang.Object

com.google.code.yanf4j.nio.impl.SelectorManager

public class SelectorManager
extends Object

Selector manager

Field Summary

Fields

Modifier and Type	Field	Description
private final NioController	controller
private final int	dividend
private static final org.slf4j.Logger	log
static final String	REACTOR_ATTRIBUTE
private int	reactorReadyCount	Reactor count which are ready
private final Reactor[]	reactorSet
private final AtomicInteger	sets
private boolean	started

Constructor Summary

Constructors

Constructor	Description
SelectorManager(int selectorPoolSize, NioController controller, Configuration conf)

Method Summary

Modifier and Type	Method	Description
(package private) void	awaitReady()
NioController	getController()
Reactor	getReactorByIndex(int index)	Find reactor by index
(package private) Reactor	getReactorFromSession(Session session)
int	getSelectorCount()
final boolean	isStarted()
final Reactor	nextReactor()	Get next reactor
(package private) void	notifyReady()	Notify all reactor have been ready
final Reactor	registerChannel(SelectableChannel channel, int ops, Object attachment)	Register channel
final void	registerSession(Session session, EventType event)	Register session
void	start()
void	stop()

Methods inherited from class java.lang.Object

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

Field Details

reactorSet

private final Reactor[] reactorSet

sets

private final AtomicInteger sets

controller

private final NioController controller

dividend

private final int dividend

reactorReadyCount

private int reactorReadyCount

Reactor count which are ready

started

private volatile boolean started

REACTOR_ATTRIBUTE

public static final String REACTOR_ATTRIBUTE

log

private static final org.slf4j.Logger log

Constructor Details

SelectorManager

public SelectorManager(int selectorPoolSize,
 NioController controller,
 Configuration conf)
                throws IOException

Throws:

IOException

Method Details

getSelectorCount

public int getSelectorCount()

start

public void start()

getReactorFromSession

Reactor getReactorFromSession(Session session)

getReactorByIndex

public Reactor getReactorByIndex(int index)

Find reactor by index

Parameters:

index -

Returns:

stop

public void stop()

registerChannel

public final Reactor registerChannel(SelectableChannel channel,
 int ops,
 Object attachment)

Register channel

Parameters:

channel -

ops -

attachment -

Returns:

awaitReady

void awaitReady()

nextReactor

public final Reactor nextReactor()

Get next reactor

Returns:

registerSession

public final void registerSession(Session session,
 EventType event)

Register session

Parameters:

session -

event -

getController

public NioController getController()

notifyReady

void notifyReady()

Notify all reactor have been ready

isStarted

public final boolean isStarted()