Class CopyBytesServerSocketChannel
java.lang.Object
io.netty.util.DefaultAttributeMap
io.netty.channel.AbstractChannel
io.netty.channel.nio.AbstractNioChannel
io.netty.channel.nio.AbstractNioMessageChannel
io.netty.channel.socket.nio.NioServerSocketChannel
org.elasticsearch.transport.netty4.CopyBytesServerSocketChannel
- All Implemented Interfaces:
io.netty.channel.Channel,io.netty.channel.ChannelOutboundInvoker,io.netty.channel.ServerChannel,io.netty.channel.socket.ServerSocketChannel,io.netty.util.AttributeMap,Comparable<io.netty.channel.Channel>
public class CopyBytesServerSocketChannel
extends io.netty.channel.socket.nio.NioServerSocketChannel
This class is adapted from
NioServerSocketChannel class in the Netty project. It overrides the
channel read messages behavior to ensure that a CopyBytesSocketChannel socket channel is created.-
Nested Class Summary
Nested classes/interfaces inherited from class io.netty.channel.nio.AbstractNioChannel
io.netty.channel.nio.AbstractNioChannel.AbstractNioUnsafe, io.netty.channel.nio.AbstractNioChannel.NioUnsafeNested classes/interfaces inherited from class io.netty.channel.AbstractChannel
io.netty.channel.AbstractChannel.AbstractUnsafeNested classes/interfaces inherited from interface io.netty.channel.Channel
io.netty.channel.Channel.Unsafe -
Field Summary
Fields inherited from class io.netty.channel.nio.AbstractNioChannel
readInterestOp -
Constructor Summary
Constructors -
Method Summary
Methods inherited from class io.netty.channel.socket.nio.NioServerSocketChannel
closeOnReadError, config, doBind, doClose, doConnect, doDisconnect, doFinishConnect, doWriteMessage, filterOutboundMessage, isActive, javaChannel, localAddress, localAddress0, metadata, remoteAddress, remoteAddress0Methods inherited from class io.netty.channel.nio.AbstractNioMessageChannel
continueOnWriteError, continueReading, doBeginRead, doWrite, newUnsafeMethods inherited from class io.netty.channel.nio.AbstractNioChannel
clearReadPending, doDeregister, doRegister, eventLoop, isCompatible, isOpen, isReadPending, newDirectBuffer, newDirectBuffer, selectionKey, setReadPending, unsafeMethods inherited from class io.netty.channel.AbstractChannel
alloc, bind, bind, bytesBeforeUnwritable, bytesBeforeWritable, close, close, closeFuture, compareTo, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, doShutdownOutput, equals, flush, hashCode, id, invalidateLocalAddress, invalidateRemoteAddress, isRegistered, isWritable, maxMessagesPerWrite, newChannelPipeline, newFailedFuture, newId, newProgressivePromise, newPromise, newSucceededFuture, parent, pipeline, read, toString, validateFileRegion, voidPromise, write, write, writeAndFlush, writeAndFlushMethods inherited from class io.netty.util.DefaultAttributeMap
attr, hasAttrMethods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, waitMethods inherited from interface io.netty.util.AttributeMap
attr, hasAttrMethods inherited from interface io.netty.channel.Channel
alloc, bytesBeforeUnwritable, bytesBeforeWritable, closeFuture, eventLoop, flush, id, isOpen, isRegistered, isWritable, parent, pipeline, read, unsafeMethods inherited from interface io.netty.channel.ChannelOutboundInvoker
bind, bind, close, close, connect, connect, connect, connect, deregister, deregister, disconnect, disconnect, newFailedFuture, newProgressivePromise, newPromise, newSucceededFuture, voidPromise, write, write, writeAndFlush, writeAndFlushMethods inherited from interface java.lang.Comparable
compareTo
-
Constructor Details
-
CopyBytesServerSocketChannel
public CopyBytesServerSocketChannel()
-
-
Method Details
-
doReadMessages
- Overrides:
doReadMessagesin classio.netty.channel.socket.nio.NioServerSocketChannel- Throws:
Exception
-