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

Class FanOutOneBlockAsyncDFSOutputSaslHelper

java.lang.Object

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

@Private
public final class FanOutOneBlockAsyncDFSOutputSaslHelper
extends Object

Helper class for adding sasl support for FanOutOneBlockAsyncDFSOutput.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static final class	FanOutOneBlockAsyncDFSOutputSaslHelper.DecryptHandler
private static final class	FanOutOneBlockAsyncDFSOutputSaslHelper.EncryptHandler
private static interface	FanOutOneBlockAsyncDFSOutputSaslHelper.SaslAdaptor
private static final class	FanOutOneBlockAsyncDFSOutputSaslHelper.SaslClientCallbackHandler	Sets user name and password when asked by the client-side SASL object.
private static final class	FanOutOneBlockAsyncDFSOutputSaslHelper.SaslNegotiateHandler
private static final class	FanOutOneBlockAsyncDFSOutputSaslHelper.SaslUnwrapHandler
private static final class	FanOutOneBlockAsyncDFSOutputSaslHelper.SaslWrapHandler
private static interface	FanOutOneBlockAsyncDFSOutputSaslHelper.TransparentCryptoHelper

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.slf4j.Logger	LOG
private static final String	MECHANISM
private static final String	NAME_DELIMITER
private static final String	PROTOCOL
private static final FanOutOneBlockAsyncDFSOutputSaslHelper.SaslAdaptor	SASL_ADAPTOR
private static final int	SASL_TRANSFER_MAGIC_NUMBER
private static final String	SERVER_NAME
private static final FanOutOneBlockAsyncDFSOutputSaslHelper.TransparentCryptoHelper	TRANSPARENT_CRYPTO_HELPER

Constructor Summary

Constructors

Modifier	Constructor	Description
private	FanOutOneBlockAsyncDFSOutputSaslHelper()

Method Summary

Modifier and Type	Method	Description
private static char[]	buildClientPassword(org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.block.BlockTokenIdentifier> blockToken)
private static String	buildUsername(org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.block.BlockTokenIdentifier> blockToken)
(package private) static org.apache.hadoop.crypto.Encryptor	createEncryptor(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hdfs.protocol.HdfsFileStatus stat, org.apache.hadoop.hdfs.DFSClient client)
private static FanOutOneBlockAsyncDFSOutputSaslHelper.SaslAdaptor	createSaslAdaptor()
private static Map<String,String>	createSaslPropertiesForEncryption(String encryptionAlgorithm)
private static FanOutOneBlockAsyncDFSOutputSaslHelper.TransparentCryptoHelper	createTransparentCryptoHelper()
private static FanOutOneBlockAsyncDFSOutputSaslHelper.TransparentCryptoHelper	createTransparentCryptoHelperWithHDFS12396()
private static FanOutOneBlockAsyncDFSOutputSaslHelper.TransparentCryptoHelper	createTransparentCryptoHelperWithoutHDFS12396()
private static void	doSaslNegotiation(org.apache.hadoop.conf.Configuration conf, org.apache.hbase.thirdparty.io.netty.channel.Channel channel, int timeoutMs, String username, char[] password, Map<String,String> saslProps, org.apache.hbase.thirdparty.io.netty.util.concurrent.Promise<Void> saslPromise, org.apache.hadoop.hdfs.DFSClient dfsClient)
private static char[]	encryptionKeyToPassword(byte[] encryptionKey)
private static String	getUserNameFromEncryptionKey(org.apache.hadoop.hdfs.security.token.block.DataEncryptionKey encryptionKey)
(package private) static void	trySaslNegotiate(org.apache.hadoop.conf.Configuration conf, org.apache.hbase.thirdparty.io.netty.channel.Channel channel, org.apache.hadoop.hdfs.protocol.DatanodeInfo dnInfo, int timeoutMs, org.apache.hadoop.hdfs.DFSClient client, org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.block.BlockTokenIdentifier> accessToken, org.apache.hbase.thirdparty.io.netty.util.concurrent.Promise<Void> saslPromise)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

SERVER_NAME

private static final String SERVER_NAME

See Also:

• Constant Field Values

PROTOCOL

private static final String PROTOCOL

See Also:

• Constant Field Values

MECHANISM

private static final String MECHANISM

SASL_TRANSFER_MAGIC_NUMBER

private static final int SASL_TRANSFER_MAGIC_NUMBER

See Also:

• Constant Field Values

NAME_DELIMITER

private static final String NAME_DELIMITER

See Also:

• Constant Field Values

SASL_ADAPTOR

private static final FanOutOneBlockAsyncDFSOutputSaslHelper.SaslAdaptor SASL_ADAPTOR

TRANSPARENT_CRYPTO_HELPER

private static final FanOutOneBlockAsyncDFSOutputSaslHelper.TransparentCryptoHelper TRANSPARENT_CRYPTO_HELPER

Constructor Details

FanOutOneBlockAsyncDFSOutputSaslHelper

private FanOutOneBlockAsyncDFSOutputSaslHelper()

Method Details

createSaslAdaptor

private static FanOutOneBlockAsyncDFSOutputSaslHelper.SaslAdaptor createSaslAdaptor()
                                                                             throws NoSuchFieldException,
NoSuchMethodException

Throws:

NoSuchFieldException

NoSuchMethodException

createTransparentCryptoHelperWithoutHDFS12396

private static FanOutOneBlockAsyncDFSOutputSaslHelper.TransparentCryptoHelper createTransparentCryptoHelperWithoutHDFS12396()
                                                                                                                     throws NoSuchMethodException

Throws:

NoSuchMethodException

createTransparentCryptoHelperWithHDFS12396

private static FanOutOneBlockAsyncDFSOutputSaslHelper.TransparentCryptoHelper createTransparentCryptoHelperWithHDFS12396()
                                                                                                                  throws ClassNotFoundException,
NoSuchMethodException

Throws:

ClassNotFoundException

NoSuchMethodException

createTransparentCryptoHelper

private static FanOutOneBlockAsyncDFSOutputSaslHelper.TransparentCryptoHelper createTransparentCryptoHelper()
                                                                                                     throws NoSuchMethodException,
ClassNotFoundException

Throws:

NoSuchMethodException

ClassNotFoundException

getUserNameFromEncryptionKey

private static String getUserNameFromEncryptionKey(org.apache.hadoop.hdfs.security.token.block.DataEncryptionKey encryptionKey)

encryptionKeyToPassword

private static char[] encryptionKeyToPassword(byte[] encryptionKey)

buildUsername

private static String buildUsername(org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.block.BlockTokenIdentifier> blockToken)

buildClientPassword

private static char[] buildClientPassword(org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.block.BlockTokenIdentifier> blockToken)

createSaslPropertiesForEncryption

private static Map<String,String> createSaslPropertiesForEncryption(String encryptionAlgorithm)

doSaslNegotiation

private static void doSaslNegotiation(org.apache.hadoop.conf.Configuration conf,
 org.apache.hbase.thirdparty.io.netty.channel.Channel channel,
 int timeoutMs,
 String username,
 char[] password,
 Map<String,String> saslProps,
 org.apache.hbase.thirdparty.io.netty.util.concurrent.Promise<Void> saslPromise,
 org.apache.hadoop.hdfs.DFSClient dfsClient)

trySaslNegotiate

static void trySaslNegotiate(org.apache.hadoop.conf.Configuration conf,
 org.apache.hbase.thirdparty.io.netty.channel.Channel channel,
 org.apache.hadoop.hdfs.protocol.DatanodeInfo dnInfo,
 int timeoutMs,
 org.apache.hadoop.hdfs.DFSClient client,
 org.apache.hadoop.security.token.Token<org.apache.hadoop.hdfs.security.token.block.BlockTokenIdentifier> accessToken,
 org.apache.hbase.thirdparty.io.netty.util.concurrent.Promise<Void> saslPromise)
                      throws IOException

Throws:

IOException

createEncryptor

static org.apache.hadoop.crypto.Encryptor createEncryptor(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.hdfs.protocol.HdfsFileStatus stat,
 org.apache.hadoop.hdfs.DFSClient client)
                                                   throws IOException

Throws:

IOException