Package org.elasticsearch.transport.nio.channel

Class NioSocketChannel

java.lang.Object

org.elasticsearch.transport.nio.channel.AbstractNioChannel<java.nio.channels.SocketChannel>

org.elasticsearch.transport.nio.channel.NioSocketChannel

All Implemented Interfaces:

NioChannel

Direct Known Subclasses:

TcpNioSocketChannel

public class NioSocketChannel
extends AbstractNioChannel<java.nio.channels.SocketChannel>

Constructor Summary

Constructors

Constructor	Description
NioSocketChannel(java.nio.channels.SocketChannel socketChannel, SocketSelector selector)

Method Summary

Modifier and Type	Method	Description
void	addConnectListener(ActionListener<java.lang.Void> listener)
void	closeFromSelector()	Closes the channel synchronously.
boolean	finishConnect()	This method will attempt to complete the connection process for this channel.
java.util.function.BiConsumer<NioSocketChannel,java.lang.Exception>	getExceptionContext()
ReadContext	getReadContext()
java.net.InetSocketAddress	getRemoteAddress()
SocketSelector	getSelector()
WriteContext	getWriteContext()
boolean	isConnectComplete()
boolean	isReadable()
boolean	isWritable()
int	read(InboundChannelBuffer buffer)
void	setContexts(ReadContext readContext, WriteContext writeContext, java.util.function.BiConsumer<NioSocketChannel,java.lang.Exception> exceptionContext)
java.lang.String	toString()
int	write(java.nio.ByteBuffer[] buffers)

Methods inherited from class org.elasticsearch.transport.nio.channel.AbstractNioChannel

addCloseListener, close, getLocalAddress, getRawChannel, getSelectionKey, isOpen, register

Methods inherited from class java.lang.Object

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

Constructor Detail

NioSocketChannel

public NioSocketChannel(java.nio.channels.SocketChannel socketChannel,
                        SocketSelector selector)
                 throws java.io.IOException

Throws:

java.io.IOException

Method Detail

closeFromSelector

public void closeFromSelector()
                       throws java.io.IOException

Description copied from class: AbstractNioChannel

Closes the channel synchronously. This method should only be called from the selector thread.

Once this method returns, the channel will be closed.

Specified by:

closeFromSelector in interface NioChannel

Overrides:

closeFromSelector in class AbstractNioChannel<java.nio.channels.SocketChannel>

Throws:

java.io.IOException

getSelector

public SocketSelector getSelector()

Specified by:

getSelector in interface NioChannel

Overrides:

getSelector in class AbstractNioChannel<java.nio.channels.SocketChannel>

write

public int write(java.nio.ByteBuffer[] buffers)
          throws java.io.IOException

Throws:

java.io.IOException

read

public int read(InboundChannelBuffer buffer)
         throws java.io.IOException

Throws:

java.io.IOException

setContexts

public void setContexts(ReadContext readContext,
                        WriteContext writeContext,
                        java.util.function.BiConsumer<NioSocketChannel,java.lang.Exception> exceptionContext)

getWriteContext

public WriteContext getWriteContext()

getReadContext

public ReadContext getReadContext()

getExceptionContext

public java.util.function.BiConsumer<NioSocketChannel,java.lang.Exception> getExceptionContext()

getRemoteAddress

public java.net.InetSocketAddress getRemoteAddress()

isConnectComplete

public boolean isConnectComplete()

isWritable

public boolean isWritable()

isReadable

public boolean isReadable()

finishConnect

public boolean finishConnect()
                      throws java.io.IOException

This method will attempt to complete the connection process for this channel. It should be called for new channels or for a channel that has produced a OP_CONNECT event. If this method returns true then the connection is complete and the channel is ready for reads and writes. If it returns false, the channel is not yet connected and this method should be called again when a OP_CONNECT event is received.

Returns:

true if the connection process is complete

Throws:

java.io.IOException - if an I/O error occurs

addConnectListener

public void addConnectListener(ActionListener<java.lang.Void> listener)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object