Package org.apache.cassandra.net
Class FrameEncoder
- java.lang.Object
-
- io.netty.channel.ChannelHandlerAdapter
-
- io.netty.channel.ChannelOutboundHandlerAdapter
-
- org.apache.cassandra.net.FrameEncoder
-
- All Implemented Interfaces:
io.netty.channel.ChannelHandler,io.netty.channel.ChannelOutboundHandler
- Direct Known Subclasses:
FrameEncoderCrc,FrameEncoderLZ4
public abstract class FrameEncoder extends io.netty.channel.ChannelOutboundHandlerAdapter
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static classFrameEncoder.PayloadAn abstraction useful for transparently allocating buffers that can be written to upstream of theFrameEncoderwithout knowledge of the encoder's frame layout, while ensuring enough space to write the remainder of the frame's contents is reserved.static interfaceFrameEncoder.PayloadAllocator
-
Field Summary
Fields Modifier and Type Field Description protected static BufferPoolbufferPool
-
Constructor Summary
Constructors Constructor Description FrameEncoder()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description FrameEncoder.PayloadAllocatorallocator()voidwrite(io.netty.channel.ChannelHandlerContext ctx, java.lang.Object msg, io.netty.channel.ChannelPromise promise)-
Methods inherited from class io.netty.channel.ChannelOutboundHandlerAdapter
bind, close, connect, deregister, disconnect, flush, read
-
Methods inherited from class io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, exceptionCaught, handlerAdded, handlerRemoved, isSharable
-
-
-
-
Field Detail
-
bufferPool
protected static final BufferPool bufferPool
-
-
Method Detail
-
allocator
public FrameEncoder.PayloadAllocator allocator()
-
write
public void write(io.netty.channel.ChannelHandlerContext ctx, java.lang.Object msg, io.netty.channel.ChannelPromise promise) throws java.lang.Exception- Specified by:
writein interfaceio.netty.channel.ChannelOutboundHandler- Overrides:
writein classio.netty.channel.ChannelOutboundHandlerAdapter- Throws:
java.lang.Exception
-
-