com.gigaspaces.lrmi.nio.selector.handler

Class AcceptSelectorThread

java.lang.Object

com.j_spaces.kernel.ManagedRunnable

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

com.gigaspaces.lrmi.nio.selector.handler.AcceptSelectorThread

All Implemented Interfaces:

Runnable

public class AcceptSelectorThread
extends AbstractSelectorThread

Handle accept 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, _pivot, ownerThread

Constructor Summary

Constructors

Constructor and Description
AcceptSelectorThread(Pivot pivot, ReadSelectorThread[] readHandlers, String hostName, String port)

Method Summary

Modifier and Type	Method and Description
protected void	enableSelectionKeys()
InetSocketAddress	getBindInetSocketAddress()
String	getHostName()
int	getPort()
protected void	handleConnection(SelectionKey key)
protected void	waitWhileFinish() This method will be invoked by requestShutdown().

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

cancelKey, closeChannel, getSelector, register, run

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

AcceptSelectorThread

public AcceptSelectorThread(Pivot pivot,
                            ReadSelectorThread[] readHandlers,
                            String hostName,
                            String port)
                     throws IOException

Throws:

IOException

Method Detail

getPort

public int getPort()

getHostName

public String getHostName()

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

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.

Overrides:

waitWhileFinish in class AbstractSelectorThread

getBindInetSocketAddress

public InetSocketAddress getBindInetSocketAddress()