Package com.gigaspaces.lrmi.nio.selector.handler.client

Class ClientHandler

java.lang.Object

com.j_spaces.kernel.ManagedRunnable

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

com.gigaspaces.lrmi.nio.selector.handler.client.ClientHandler

All Implemented Interfaces:

Runnable

public class ClientHandler
extends AbstractSelectorThread

A client side selector thread that handles Async remote calls. the handler works against a context to support both read and write actions. all channel activities are non blocking.

Since:

6.5

Author:

asy ronen

Field Summary

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

_logger, ownerThread

Constructor Summary

Constructors

Constructor	Description
ClientHandler()

Method Summary

Modifier and Type	Method	Description
void	addChannel(SocketChannel channelSocket, Context ctx)
protected void	cancelKey(SelectionKey key)
protected void	enableSelectionKeys()
protected void	handleConnection(SelectionKey key)
void	removeChannel(SocketChannel channelSocket, Context ctx)
void	setReadInterest(Context ctx)
void	setWriteInterest(Context ctx)
void	shutdown()

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

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 Details

ClientHandler

public ClientHandler()
              throws IOException

Throws:

IOException

Method Details

enableSelectionKeys

protected void enableSelectionKeys()

Specified by:

enableSelectionKeys in class AbstractSelectorThread

handleConnection

protected void handleConnection(SelectionKey key)
                         throws IOException,
InterruptedException

Specified by:

handleConnection in class AbstractSelectorThread

Throws:

IOException

InterruptedException

addChannel

public void addChannel(SocketChannel channelSocket,
 Context ctx)

removeChannel

public void removeChannel(SocketChannel channelSocket,
 Context ctx)

setReadInterest

public void setReadInterest(Context ctx)

setWriteInterest

public void setWriteInterest(Context ctx)

cancelKey

protected void cancelKey(SelectionKey key)

Overrides:

cancelKey in class AbstractSelectorThread

shutdown

public void shutdown()