org.apache.hadoop.hbase.io.asyncfs

Class FanOutOneBlockAsyncDFSOutput.AckHandler

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.SimpleChannelInboundHandler<org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.PipelineAckProto>

org.apache.hadoop.hbase.io.asyncfs.FanOutOneBlockAsyncDFSOutput.AckHandler

All Implemented Interfaces:

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

Enclosing class:

FanOutOneBlockAsyncDFSOutput

@ChannelHandler.Sharable
private final class FanOutOneBlockAsyncDFSOutput.AckHandler
extends org.apache.hbase.thirdparty.io.netty.channel.SimpleChannelInboundHandler<org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.PipelineAckProto>

Nested Class Summary

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 int	timeoutMs

Constructor Summary

Constructors

Constructor and Description
AckHandler(int timeoutMs)

Method Summary

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.hadoop.hdfs.protocol.proto.DataTransferProtos.PipelineAckProto ack)
void	exceptionCaught(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, Throwable cause)
void	userEventTriggered(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, Object evt)

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

acceptInboundMessage, channelRead

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

channelActive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged

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

handlerAdded, handlerRemoved

Field Detail

timeoutMs

private final int timeoutMs

Constructor Detail

AckHandler

public AckHandler(int timeoutMs)

Method Detail

channelRead0

protected void channelRead0(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
                            org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.PipelineAckProto ack)
                     throws Exception

Specified by:

channelRead0 in class org.apache.hbase.thirdparty.io.netty.channel.SimpleChannelInboundHandler<org.apache.hadoop.hdfs.protocol.proto.DataTransferProtos.PipelineAckProto>

Throws:

Exception

channelInactive

public void channelInactive(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx)
                     throws Exception

Specified by:

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

Overrides:

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

Throws:

Exception

exceptionCaught

public void exceptionCaught(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
                            Throwable cause)
                     throws Exception

Specified by:

exceptionCaught in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelHandler

Specified by:

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

Overrides:

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

Throws:

Exception

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