com.gigaspaces.lrmi.nio.selector

Class SelectorManager

java.lang.Object

com.j_spaces.kernel.ManagedRunnable

com.gigaspaces.lrmi.nio.selector.SelectorManager

public class SelectorManager
extends ManagedRunnable

Event queue for I/O events raised by a selector. This class receives the lower level events raised by a Selector and dispatches them to the appropriate handler. The SelectorThread class performs a similar task. In particular: - Listens for connection requests, accepts them and creates new connections in the Pivot Channels Table. - Selects a set of channels available for read. If a channel is available for read, it creates a bus packet with the channel info and dispatches it to a worker thread or handling.

Since:

6.0.4, 6.5

Author:

Guy Korland

Constructor Summary

Constructors

Constructor and Description
SelectorManager(Pivot pivot, String hostName, String port, int readSelectorThreads)

Method Summary

Modifier and Type	Method and Description
InetSocketAddress	getBindInetSocketAddress()
String	getHostName()
int	getPort()
ReadSelectorThread	getReadHandler(SelectableChannel channel)
WriteSelectorThread	getWriteHandler(SelectableChannel channel)
protected void	waitWhileFinish() This method will be invoked by requestShutdown().

Methods inherited from class com.j_spaces.kernel.ManagedRunnable

requestShutdown, shouldShutdown

Methods inherited from class java.lang.Object

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

Constructor Detail

SelectorManager

public SelectorManager(Pivot pivot,
                       String hostName,
                       String port,
                       int readSelectorThreads)
                throws IOException

Throws:

IOException

Method Detail

waitWhileFinish

protected void waitWhileFinish()

Description copied from class: ManagedRunnable

This method will be invoked by requestShutdown(). Request method will be block while waitWhileFinish() will not be finished.

Specified by:

waitWhileFinish in class ManagedRunnable

getPort

public int getPort()

getHostName

public String getHostName()

getBindInetSocketAddress

public InetSocketAddress getBindInetSocketAddress()

getReadHandler

public ReadSelectorThread getReadHandler(SelectableChannel channel)

getWriteHandler

public WriteSelectorThread getWriteHandler(SelectableChannel channel)