@InterfaceAudience.Private class PreambleCallHandler extends org.apache.hbase.thirdparty.io.netty.channel.SimpleChannelInboundHandler<org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf>
Modifier and Type | Field and Description |
---|---|
private NettyRpcConnection |
conn |
private Call |
preambleCall |
private byte[] |
preambleHeader |
Constructor and Description |
---|
PreambleCallHandler(NettyRpcConnection conn,
byte[] preambleHeader,
Call preambleCall) |
Modifier and Type | Method and Description |
---|---|
void |
channelInactive(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) |
protected void |
channelRead0(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf buf) |
void |
exceptionCaught(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
Throwable cause) |
void |
handlerAdded(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) |
static void |
setup(org.apache.hbase.thirdparty.io.netty.channel.ChannelPipeline pipeline,
int readTimeoutMs,
NettyRpcConnection conn,
byte[] preambleHeader,
Call preambleCall) |
acceptInboundMessage, channelRead
channelActive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
ensureNotSharable, handlerRemoved, isSharable
private final NettyRpcConnection conn
private final byte[] preambleHeader
private final Call preambleCall
PreambleCallHandler(NettyRpcConnection conn, byte[] preambleHeader, Call preambleCall)
public void handlerAdded(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) throws Exception
handlerAdded
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelHandler
handlerAdded
in class org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerAdapter
Exception
protected void channelRead0(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf buf) throws Exception
channelRead0
in class org.apache.hbase.thirdparty.io.netty.channel.SimpleChannelInboundHandler<org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf>
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 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 static void setup(org.apache.hbase.thirdparty.io.netty.channel.ChannelPipeline pipeline, int readTimeoutMs, NettyRpcConnection conn, byte[] preambleHeader, Call preambleCall)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.