com.gigaspaces.lrmi.nio.selector.handler

Class WriteSelectorThread

java.lang.Object

com.j_spaces.kernel.ManagedRunnable

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

com.gigaspaces.lrmi.nio.selector.handler.WriteSelectorThread

All Implemented Interfaces:

Runnable

public class WriteSelectorThread
extends AbstractSelectorThread

selector thread that deals with server side writes that could not complete in one go.

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 and Description
WriteSelectorThread(Pivot pivot, String name)

Method Summary

Modifier and Type	Method and Description
protected void	enableSelectionKeys()
protected void	handleConnection(SelectionKey key)
void	removeWriteInterest(SelectionKey key)
void	setWriteInterest(ChannelEntry channelEntry)

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

WriteSelectorThread

public WriteSelectorThread(Pivot pivot,
                           String name)
                    throws IOException

Throws:

IOException

Method Detail

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

setWriteInterest

public void setWriteInterest(ChannelEntry channelEntry)

removeWriteInterest

public void removeWriteInterest(SelectionKey key)