@InterfaceAudience.Private class NettyRpcDuplexHandler extends org.apache.hbase.thirdparty.io.netty.channel.ChannelDuplexHandler
Modifier and Type | Field and Description |
---|---|
private CellBlockBuilder |
cellBlockBuilder |
private Codec |
codec |
private org.apache.hadoop.io.compress.CompressionCodec |
compressor |
private NettyRpcConnection |
conn |
private Map<Integer,Call> |
id2Call |
private static org.slf4j.Logger |
LOG |
Constructor and Description |
---|
NettyRpcDuplexHandler(NettyRpcConnection conn,
CellBlockBuilder cellBlockBuilder,
Codec codec,
org.apache.hadoop.io.compress.CompressionCodec compressor) |
Modifier and Type | Method and Description |
---|---|
void |
channelInactive(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) |
void |
channelRead(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
Object msg) |
private void |
cleanupCalls(IOException error) |
void |
exceptionCaught(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
Throwable cause) |
private void |
readResponse(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf buf) |
void |
userEventTriggered(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
Object evt) |
void |
write(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
Object msg,
org.apache.hbase.thirdparty.io.netty.channel.ChannelPromise promise) |
private void |
writeRequest(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
Call call,
org.apache.hbase.thirdparty.io.netty.channel.ChannelPromise promise) |
bind, close, connect, deregister, disconnect, flush, read
channelActive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
private static final org.slf4j.Logger LOG
private final NettyRpcConnection conn
private final CellBlockBuilder cellBlockBuilder
private final org.apache.hadoop.io.compress.CompressionCodec compressor
public NettyRpcDuplexHandler(NettyRpcConnection conn, CellBlockBuilder cellBlockBuilder, Codec codec, org.apache.hadoop.io.compress.CompressionCodec compressor)
private void writeRequest(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, Call call, org.apache.hbase.thirdparty.io.netty.channel.ChannelPromise promise) throws IOException
IOException
public void write(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, Object msg, org.apache.hbase.thirdparty.io.netty.channel.ChannelPromise promise) throws Exception
write
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelOutboundHandler
write
in class org.apache.hbase.thirdparty.io.netty.channel.ChannelDuplexHandler
Exception
private void readResponse(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf buf) throws IOException
IOException
public void channelRead(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, Object msg) throws Exception
channelRead
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandler
channelRead
in class org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandlerAdapter
Exception
private void cleanupCalls(IOException error)
public void channelInactive(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) throws Exception
channelInactive
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandler
channelInactive
in class org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandlerAdapter
Exception
public void exceptionCaught(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
exceptionCaught
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelHandler
exceptionCaught
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandler
exceptionCaught
in class org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandlerAdapter
public void userEventTriggered(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, Object evt) throws Exception
userEventTriggered
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandler
userEventTriggered
in class org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandlerAdapter
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.