org.apache.hadoop.hbase.ipc

Class BufferCallBeforeInitHandler

java.lang.Object

org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerAdapter

org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandlerAdapter

org.apache.hbase.thirdparty.io.netty.channel.ChannelDuplexHandler

org.apache.hadoop.hbase.ipc.BufferCallBeforeInitHandler

All Implemented Interfaces:

org.apache.hbase.thirdparty.io.netty.channel.ChannelHandler, org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandler, org.apache.hbase.thirdparty.io.netty.channel.ChannelOutboundHandler

@InterfaceAudience.Private
class BufferCallBeforeInitHandler
extends org.apache.hbase.thirdparty.io.netty.channel.ChannelDuplexHandler

We will expose the connection to upper layer before initialized, so we need to buffer the calls passed in and write them out once the connection is established.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private static class	BufferCallBeforeInitHandler.BufferCallAction
static class	BufferCallBeforeInitHandler.BufferCallEvent

Nested classes/interfaces inherited from interface org.apache.hbase.thirdparty.io.netty.channel.ChannelHandler

org.apache.hbase.thirdparty.io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
private Map<Integer,Call>	id2Call
private static BufferCallBeforeInitHandler.BufferCallEvent	SUCCESS_EVENT

Constructor Summary

Constructors

Constructor and Description
BufferCallBeforeInitHandler()

Method Summary

Modifier and Type	Method and Description
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)

Methods inherited from class org.apache.hbase.thirdparty.io.netty.channel.ChannelDuplexHandler

bind, close, connect, deregister, disconnect, flush, read

Methods inherited from class org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelRead, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, exceptionCaught

Methods inherited from class org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, handlerAdded, handlerRemoved, isSharable

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.hbase.thirdparty.io.netty.channel.ChannelHandler

exceptionCaught, handlerAdded, handlerRemoved

Field Detail

SUCCESS_EVENT

private static final BufferCallBeforeInitHandler.BufferCallEvent SUCCESS_EVENT

id2Call

private final Map<Integer,Call> id2Call

Constructor Detail

BufferCallBeforeInitHandler

BufferCallBeforeInitHandler()

Method Detail

write

public void write(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
                  Object msg,
                  org.apache.hbase.thirdparty.io.netty.channel.ChannelPromise promise)

Specified by:

write in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelOutboundHandler

Overrides:

write in class org.apache.hbase.thirdparty.io.netty.channel.ChannelDuplexHandler

userEventTriggered

public void userEventTriggered(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
                               Object evt)
                        throws Exception

Specified by:

userEventTriggered in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandler

Overrides:

userEventTriggered in class org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandlerAdapter

Throws:

Exception