Package org.elasticsearch.transport.nio

Class AcceptingSelector

java.lang.Object

org.elasticsearch.transport.nio.ESSelector

org.elasticsearch.transport.nio.AcceptingSelector

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public class AcceptingSelector
extends ESSelector

Selector implementation that handles NioServerSocketChannel. It's main piece of functionality is accepting new channels.

Constructor Summary

Constructors

Constructor	Description
AcceptingSelector(AcceptorEventHandler eventHandler)
AcceptingSelector(AcceptorEventHandler eventHandler, java.nio.channels.Selector selector)

Method Summary

Modifier and Type	Method	Description
void	scheduleForRegistration(NioServerSocketChannel serverSocketChannel)	Schedules a NioServerSocketChannel to be registered with 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

AcceptingSelector

public AcceptingSelector(AcceptorEventHandler eventHandler)
                  throws java.io.IOException

Throws:

java.io.IOException

AcceptingSelector

public AcceptingSelector(AcceptorEventHandler eventHandler,
                         java.nio.channels.Selector selector)
                  throws java.io.IOException

Throws:

java.io.IOException

Method Detail

scheduleForRegistration

public void scheduleForRegistration(NioServerSocketChannel serverSocketChannel)

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

Parameters:

serverSocketChannel - the channel to register