@InterfaceAudience.Private class NettyRpcServerRequestDecoder extends org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandlerAdapter
Modifier and Type | Field and Description |
---|---|
private org.apache.hbase.thirdparty.io.netty.channel.group.ChannelGroup |
allChannels |
private NettyServerRpcConnection |
connection |
private MetricsHBaseServer |
metrics |
Constructor and Description |
---|
NettyRpcServerRequestDecoder(org.apache.hbase.thirdparty.io.netty.channel.group.ChannelGroup allChannels,
MetricsHBaseServer metrics) |
Modifier and Type | Method and Description |
---|---|
void |
channelActive(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) |
void |
channelInactive(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) |
void |
channelRead(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
Object msg) |
void |
exceptionCaught(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
Throwable e) |
(package private) void |
setConnection(NettyServerRpcConnection connection) |
channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
private final org.apache.hbase.thirdparty.io.netty.channel.group.ChannelGroup allChannels
private final MetricsHBaseServer metrics
private NettyServerRpcConnection connection
public NettyRpcServerRequestDecoder(org.apache.hbase.thirdparty.io.netty.channel.group.ChannelGroup allChannels, MetricsHBaseServer metrics)
void setConnection(NettyServerRpcConnection connection)
public void channelActive(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) throws Exception
channelActive
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandler
channelActive
in class org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandlerAdapter
Exception
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
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 e)
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
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.