org.apache.hadoop.hbase.security

Class HBaseSaslRpcClient

java.lang.Object

org.apache.hadoop.hbase.security.AbstractHBaseSaslRpcClient

org.apache.hadoop.hbase.security.HBaseSaslRpcClient

@InterfaceAudience.Private
public class HBaseSaslRpcClient
extends AbstractHBaseSaslRpcClient

A utility class that encapsulates SASL logic for RPC client. Copied from org.apache.hadoop.security

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	HBaseSaslRpcClient.WrappedInputStream
(package private) class	HBaseSaslRpcClient.WrappedOutputStream

Field Summary

Fields

Modifier and Type	Field and Description
private CryptoAES	cryptoAES
private boolean	cryptoAesEnable
private InputStream	cryptoInputStream
private OutputStream	cryptoOutputStream
private boolean	initStreamForCrypto
private static org.slf4j.Logger	LOG
private InputStream	saslInputStream
private OutputStream	saslOutputStream

Fields inherited from class org.apache.hadoop.hbase.security.AbstractHBaseSaslRpcClient

fallbackAllowed, saslClient, saslProps

Constructor Summary

Constructors

Constructor and Description
HBaseSaslRpcClient(org.apache.hadoop.conf.Configuration conf, SaslClientAuthenticationProvider provider, org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> token, InetAddress serverAddr, SecurityInfo securityInfo, boolean fallbackAllowed)
HBaseSaslRpcClient(org.apache.hadoop.conf.Configuration conf, SaslClientAuthenticationProvider provider, org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> token, InetAddress serverAddr, SecurityInfo securityInfo, boolean fallbackAllowed, String rpcProtection, boolean initStreamForCrypto)

Method Summary

Modifier and Type	Method and Description
InputStream	getInputStream() Get a SASL wrapped InputStream.
OutputStream	getOutputStream() Get a SASL wrapped OutputStream.
String	getSaslQOP()
void	initCryptoCipher(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.CryptoCipherMeta cryptoCipherMeta, org.apache.hadoop.conf.Configuration conf)
private static void	readStatus(DataInputStream inStream)
boolean	saslConnect(InputStream inS, OutputStream outS) Do client side SASL authentication with server via the given InputStream and OutputStream

Methods inherited from class org.apache.hadoop.hbase.security.AbstractHBaseSaslRpcClient

dispose, evaluateChallenge, getInitialResponse, isComplete

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

cryptoAesEnable

private boolean cryptoAesEnable

cryptoAES

private CryptoAES cryptoAES

saslInputStream

private InputStream saslInputStream

cryptoInputStream

private InputStream cryptoInputStream

saslOutputStream

private OutputStream saslOutputStream

cryptoOutputStream

private OutputStream cryptoOutputStream

initStreamForCrypto

private boolean initStreamForCrypto

Constructor Detail

HBaseSaslRpcClient

public HBaseSaslRpcClient(org.apache.hadoop.conf.Configuration conf,
                          SaslClientAuthenticationProvider provider,
                          org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> token,
                          InetAddress serverAddr,
                          SecurityInfo securityInfo,
                          boolean fallbackAllowed)
                   throws IOException

Throws:

IOException

HBaseSaslRpcClient

public HBaseSaslRpcClient(org.apache.hadoop.conf.Configuration conf,
                          SaslClientAuthenticationProvider provider,
                          org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> token,
                          InetAddress serverAddr,
                          SecurityInfo securityInfo,
                          boolean fallbackAllowed,
                          String rpcProtection,
                          boolean initStreamForCrypto)
                   throws IOException

Throws:

IOException

Method Detail

readStatus

private static void readStatus(DataInputStream inStream)
                        throws IOException

Throws:

IOException

saslConnect

public boolean saslConnect(InputStream inS,
                           OutputStream outS)
                    throws IOException

Do client side SASL authentication with server via the given InputStream and OutputStream

Parameters:

inS - InputStream to use

outS - OutputStream to use

Returns:

true if connection is set up, or false if needs to switch to simple Auth.

Throws:

IOException

getSaslQOP

public String getSaslQOP()

initCryptoCipher

public void initCryptoCipher(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.CryptoCipherMeta cryptoCipherMeta,
                             org.apache.hadoop.conf.Configuration conf)
                      throws IOException

Throws:

IOException

getInputStream

public InputStream getInputStream()
                           throws IOException

Get a SASL wrapped InputStream. Can be called only after saslConnect() has been called.

Returns:

a SASL wrapped InputStream

Throws:

IOException

getOutputStream

public OutputStream getOutputStream()
                             throws IOException

Get a SASL wrapped OutputStream. Can be called only after saslConnect() has been called.

Returns:

a SASL wrapped OutputStream

Throws:

IOException