com.gigaspaces.lrmi.nio.selector.handler

Class ReadSelectorThread

java.lang.Object

com.j_spaces.kernel.ManagedRunnable

com.gigaspaces.lrmi.nio.selector.handler.AbstractSelectorThread

com.gigaspaces.lrmi.nio.selector.handler.ReadSelectorThread

All Implemented Interfaces:

Runnable

public class ReadSelectorThread
extends AbstractSelectorThread

Handle read events from selector.

Since:

6.0.4, 6.5

Author:

Guy Korland

Field Summary

Fields inherited from class com.gigaspaces.lrmi.nio.selector.handler.AbstractSelectorThread

_logger, ownerThread

Constructor Summary

Constructors

Constructor and Description
ReadSelectorThread(Pivot pivot, String name)

Method Summary

Modifier and Type	Method and Description
void	createKey(SocketChannel channel) called after the reading has finished
protected void	enableSelectionKeys()
protected void	handleConnection(SelectionKey key)
void	registerKey(SelectionKey key) called after the reading has finished

Methods inherited from class com.gigaspaces.lrmi.nio.selector.handler.AbstractSelectorThread

cancelKey, closeChannel, getSelector, register, run, waitWhileFinish

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

ReadSelectorThread

public ReadSelectorThread(Pivot pivot,
                          String name)
                   throws IOException

Throws:

IOException

Method Detail

handleConnection

protected void handleConnection(SelectionKey key)
                         throws IOException,
                                InterruptedException

Specified by:

handleConnection in class AbstractSelectorThread

Throws:

IOException

InterruptedException

enableSelectionKeys

protected void enableSelectionKeys()

Specified by:

enableSelectionKeys in class AbstractSelectorThread

registerKey

public void registerKey(SelectionKey key)

called after the reading has finished

createKey

public void createKey(SocketChannel channel)

called after the reading has finished