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- Author:
- dennis
-
-
Field Summary
Fields Modifier and Type Field Description static StringREACTOR_ATTRIBUTE
-
Constructor Summary
Constructors Constructor Description SelectorManager(int selectorPoolSize, NioController controller, Configuration conf)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description NioControllergetController()ReactorgetReactorByIndex(int index)Find reactor by indexintgetSelectorCount()booleanisStarted()ReactornextReactor()Get next reactorReactorregisterChannel(SelectableChannel channel, int ops, Object attachment)Register channelvoidregisterSession(Session session, EventType event)Register sessionvoidstart()voidstop()
-
-
-
Field Detail
-
REACTOR_ATTRIBUTE
public static final String REACTOR_ATTRIBUTE
-
-
Constructor Detail
-
SelectorManager
public SelectorManager(int selectorPoolSize, NioController controller, Configuration conf) throws IOException- Throws:
IOException
-
-
Method Detail
-
getSelectorCount
public int getSelectorCount()
-
start
public void start()
-
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:
-
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()
-
isStarted
public final boolean isStarted()
-
-