Package org.apache.hadoop.hbase.security
Class NettyHBaseRpcConnectionHeaderHandler
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.hbase.thirdparty.io.netty.buffer.ByteBuf>
org.apache.hadoop.hbase.security.NettyHBaseRpcConnectionHeaderHandler
- All Implemented Interfaces:
org.apache.hbase.thirdparty.io.netty.channel.ChannelHandler
,org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandler
@Private
public class NettyHBaseRpcConnectionHeaderHandler
extends org.apache.hbase.thirdparty.io.netty.channel.SimpleChannelInboundHandler<org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf>
Implement logic to deal with the rpc connection header.
- Since:
- 2.0.0
-
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
Modifier and TypeFieldDescriptionprivate final org.apache.hadoop.conf.Configuration
private final org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf
private final org.apache.hbase.thirdparty.io.netty.util.concurrent.Promise<Boolean>
-
Constructor Summary
ConstructorDescriptionNettyHBaseRpcConnectionHeaderHandler
(org.apache.hbase.thirdparty.io.netty.util.concurrent.Promise<Boolean> saslPromise, org.apache.hadoop.conf.Configuration conf, org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf connectionHeaderWithLength) -
Method Summary
Modifier and TypeMethodDescriptionprotected void
channelRead0
(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf msg) void
exceptionCaught
(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, Throwable cause) void
handlerAdded
(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) private void
setupCryptoAESHandler
(org.apache.hbase.thirdparty.io.netty.channel.ChannelPipeline p, CryptoAES cryptoAES) Remove handlers for sasl encryption and add handlers for Crypto AES encryptionMethods 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, channelInactive, channelReadComplete, channelRegistered, channelUnregistered, channelWritabilityChanged, userEventTriggered
Methods inherited from class org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerAdapter
ensureNotSharable, 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
handlerRemoved
-
Field Details
-
saslPromise
-
conf
-
connectionHeaderWithLength
-
-
Constructor Details
-
NettyHBaseRpcConnectionHeaderHandler
public NettyHBaseRpcConnectionHeaderHandler(org.apache.hbase.thirdparty.io.netty.util.concurrent.Promise<Boolean> saslPromise, org.apache.hadoop.conf.Configuration conf, org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf connectionHeaderWithLength)
-
-
Method Details
-
channelRead0
protected void channelRead0(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf msg) throws Exception - Specified by:
channelRead0
in classorg.apache.hbase.thirdparty.io.netty.channel.SimpleChannelInboundHandler<org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf>
- Throws:
Exception
-
handlerAdded
- Specified by:
handlerAdded
in interfaceorg.apache.hbase.thirdparty.io.netty.channel.ChannelHandler
- Overrides:
handlerAdded
in classorg.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerAdapter
-
exceptionCaught
public void exceptionCaught(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, Throwable cause) - Specified by:
exceptionCaught
in interfaceorg.apache.hbase.thirdparty.io.netty.channel.ChannelHandler
- Specified by:
exceptionCaught
in interfaceorg.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandler
- Overrides:
exceptionCaught
in classorg.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandlerAdapter
-
setupCryptoAESHandler
private void setupCryptoAESHandler(org.apache.hbase.thirdparty.io.netty.channel.ChannelPipeline p, CryptoAES cryptoAES) Remove handlers for sasl encryption and add handlers for Crypto AES encryption
-