Package org.apache.hadoop.hbase.io.asyncfs

Class FanOutOneBlockAsyncDFSOutputSaslHelper.SaslWrapHandler

java.lang.Object

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

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

org.apache.hadoop.hbase.io.asyncfs.FanOutOneBlockAsyncDFSOutputSaslHelper.SaslWrapHandler

All Implemented Interfaces:

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

Enclosing class:

FanOutOneBlockAsyncDFSOutputSaslHelper

private static final class FanOutOneBlockAsyncDFSOutputSaslHelper.SaslWrapHandler
extends org.apache.hbase.thirdparty.io.netty.channel.ChannelOutboundHandlerAdapter

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	Description
private org.apache.hbase.thirdparty.io.netty.buffer.CompositeByteBuf	cBuf
private final SaslClient	saslClient

Constructor Summary

Constructors

Constructor	Description
SaslWrapHandler(SaslClient saslClient)

Method Summary

Modifier and Type	Method	Description
void	flush(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx)
void	handlerAdded(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx)
void	handlerRemoved(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx)
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.ChannelOutboundHandlerAdapter

bind, close, connect, deregister, disconnect, read

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

ensureNotSharable, exceptionCaught, 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

Field Details

saslClient

private final SaslClient saslClient

cBuf

private org.apache.hbase.thirdparty.io.netty.buffer.CompositeByteBuf cBuf

Constructor Details

SaslWrapHandler

public SaslWrapHandler(SaslClient saslClient)

Method Details

handlerAdded

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

Specified by:

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

Overrides:

handlerAdded in class org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerAdapter

Throws:

Exception

write

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

Specified by:

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

Overrides:

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

Throws:

Exception

flush

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

Specified by:

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

Overrides:

flush in class org.apache.hbase.thirdparty.io.netty.channel.ChannelOutboundHandlerAdapter

Throws:

Exception

handlerRemoved

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

Specified by:

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

Overrides:

handlerRemoved in class org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerAdapter

Throws:

Exception