Package org.apache.hadoop.hbase.security

Class HBaseSaslRpcClient

java.lang.Object

org.apache.hadoop.hbase.security.AbstractHBaseSaslRpcClient

org.apache.hadoop.hbase.security.HBaseSaslRpcClient

@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	Description
(package private) class	HBaseSaslRpcClient.WrappedInputStream
(package private) class	HBaseSaslRpcClient.WrappedOutputStream

Field Summary

Fields

Modifier and Type	Field	Description
private CryptoAES	cryptoAES
private boolean	cryptoAesEnable
private InputStream	cryptoInputStream
private OutputStream	cryptoOutputStream
private boolean	initStreamForCrypto
private static final 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	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, String servicePrincipal, 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, String servicePrincipal, boolean fallbackAllowed, String rpcProtection, boolean initStreamForCrypto)

Method Summary

Modifier and Type	Method	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 Details

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 Details

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,
 String servicePrincipal,
 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,
 String servicePrincipal,
 boolean fallbackAllowed,
 String rpcProtection,
 boolean initStreamForCrypto)
                   throws IOException

Throws:

IOException

Method Details

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