Package org.elasticsearch.transport.nio

Class SocketSelector

java.lang.Object

org.elasticsearch.transport.nio.ESSelector

org.elasticsearch.transport.nio.SocketSelector

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class SocketSelector
extends ESSelector

Selector implementation that handles NioSocketChannel. It's main piece of functionality is handling connect, read, and write events.

Constructor Summary

Constructors

Constructor	Description
SocketSelector(SocketEventHandler eventHandler)
SocketSelector(SocketEventHandler eventHandler, java.nio.channels.Selector selector)

Method Summary

Modifier and Type	Method	Description
<V> void	executeFailedListener(ActionListener<V> listener, java.lang.Exception exception)	Executes a failed listener with consistent exception handling.
<V> void	executeListener(ActionListener<V> listener, V value)	Executes a success listener with consistent exception handling.
void	queueWrite(WriteOperation writeOperation)	Queues a write operation to be handled by the event loop.
void	queueWriteInChannelBuffer(WriteOperation writeOperation)	Queues a write operation directly in a channel's buffer.
void	scheduleForRegistration(NioSocketChannel nioSocketChannel)	Schedules a NioSocketChannel to be registered by this selector.

Methods inherited from class org.elasticsearch.transport.nio.ESSelector

close, isOnCurrentThread, isOpen, isRunning, isRunningFuture, queueChannelClose, rawSelector, runLoop

Methods inherited from class java.lang.Object

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

Constructor Detail

SocketSelector

public SocketSelector(SocketEventHandler eventHandler)
               throws java.io.IOException

Throws:

java.io.IOException

SocketSelector

public SocketSelector(SocketEventHandler eventHandler,
                      java.nio.channels.Selector selector)
               throws java.io.IOException

Throws:

java.io.IOException

Method Detail

scheduleForRegistration

public void scheduleForRegistration(NioSocketChannel nioSocketChannel)

Schedules a NioSocketChannel to be registered by this selector. The channel will by queued and eventually registered next time through the event loop.

Parameters:

nioSocketChannel - the channel to register

queueWrite

public void queueWrite(WriteOperation writeOperation)

Queues a write operation to be handled by the event loop. This can be called by any thread and is the api available for non-selector threads to schedule writes.

Parameters:

writeOperation - to be queued

queueWriteInChannelBuffer

public void queueWriteInChannelBuffer(WriteOperation writeOperation)

Queues a write operation directly in a channel's buffer. Channel buffers are only safe to be accessed by the selector thread. As a result, this method should only be called by the selector thread.

Parameters:

writeOperation - to be queued in a channel's buffer

executeListener

public <V> void executeListener(ActionListener<V> listener,
                                V value)

Executes a success listener with consistent exception handling. This can only be called from current selector thread.

Parameters:

listener - to be executed

value - to provide to listener

executeFailedListener

public <V> void executeFailedListener(ActionListener<V> listener,
                                      java.lang.Exception exception)

Executes a failed listener with consistent exception handling. This can only be called from current selector thread.

Parameters:

listener - to be executed

exception - to provide to listener