@InterfaceAudience.Private class BufferCallBeforeInitHandler extends org.apache.hbase.thirdparty.io.netty.channel.ChannelDuplexHandler
Modifier and Type | Class and Description |
---|---|
private static class |
BufferCallBeforeInitHandler.BufferCallAction |
static class |
BufferCallBeforeInitHandler.BufferCallEvent |
Modifier and Type | Field and Description |
---|---|
private Map<Integer,Call> |
id2Call |
private static org.slf4j.Logger |
LOG |
(package private) static String |
NAME |
private static BufferCallBeforeInitHandler.BufferCallEvent |
SUCCESS_EVENT |
Constructor and Description |
---|
BufferCallBeforeInitHandler() |
Modifier and Type | Method and Description |
---|---|
void |
exceptionCaught(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
Throwable cause) |
void |
flush(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) |
private boolean |
isSslError(Throwable cause) |
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) |
bind, close, connect, deregister, disconnect, read
channelActive, channelInactive, channelRead, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
private static final org.slf4j.Logger LOG
static final String NAME
private static final BufferCallBeforeInitHandler.BufferCallEvent SUCCESS_EVENT
BufferCallBeforeInitHandler()
public void write(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, Object msg, org.apache.hbase.thirdparty.io.netty.channel.ChannelPromise promise)
write
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelOutboundHandler
write
in class org.apache.hbase.thirdparty.io.netty.channel.ChannelDuplexHandler
public void flush(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) throws Exception
flush
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelOutboundHandler
flush
in class org.apache.hbase.thirdparty.io.netty.channel.ChannelDuplexHandler
Exception
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
private boolean isSslError(Throwable cause)
public void exceptionCaught(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, Throwable cause) throws Exception
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
Exception
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.