Package org.apache.hadoop.hbase.security

Class HBaseSaslRpcServer

java.lang.Object

org.apache.hadoop.hbase.security.HBaseSaslRpcServer

@Private
public class HBaseSaslRpcServer
extends Object

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

Field Summary

Fields

Modifier and Type	Field	Description
private CryptoAES	cryptoAES
private final SaslServer	saslServer
private final AttemptingUserProvidingSaslServer	serverWithProvider

Constructor Summary

Constructors

Constructor	Description
HBaseSaslRpcServer(SaslServerAuthenticationProvider provider, Map<String,String> saslProps, org.apache.hadoop.security.token.SecretManager<org.apache.hadoop.security.token.TokenIdentifier> secretManager)

Method Summary

Modifier and Type	Method	Description
void	dispose()	Release resources used by wrapped saslServer
byte[]	evaluateResponse(byte[] response)
String	getAttemptingUser()
String	getAuthorizationID()
static <T extends org.apache.hadoop.security.token.TokenIdentifier> T	getIdentifier(String id, org.apache.hadoop.security.token.SecretManager<T> secretManager)
String	getNegotiatedQop()
boolean	isComplete()
void	switchToCryptoAES(CryptoAES cryptoAES)
byte[]	unwrap(byte[] buf, int off, int len)
static Throwable	unwrap(Throwable e)	Unwrap InvalidToken exception, otherwise return the one passed in.
byte[]	wrap(byte[] buf, int off, int len)

Methods inherited from class java.lang.Object

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

Field Details

serverWithProvider

private final AttemptingUserProvidingSaslServer serverWithProvider

saslServer

private final SaslServer saslServer

cryptoAES

private CryptoAES cryptoAES

Constructor Details

HBaseSaslRpcServer

public HBaseSaslRpcServer(SaslServerAuthenticationProvider provider,
 Map<String,String> saslProps,
 org.apache.hadoop.security.token.SecretManager<org.apache.hadoop.security.token.TokenIdentifier> secretManager)
                   throws IOException

Throws:

IOException

Method Details

isComplete

public boolean isComplete()

evaluateResponse

public byte[] evaluateResponse(byte[] response)
                        throws SaslException

Throws:

SaslException

dispose

public void dispose()

Release resources used by wrapped saslServer

switchToCryptoAES

public void switchToCryptoAES(CryptoAES cryptoAES)

getAttemptingUser

public String getAttemptingUser()

wrap

public byte[] wrap(byte[] buf,
 int off,
 int len)
            throws SaslException

Throws:

SaslException

unwrap

public byte[] unwrap(byte[] buf,
 int off,
 int len)
              throws SaslException

Throws:

SaslException

getNegotiatedQop

public String getNegotiatedQop()

getAuthorizationID

public String getAuthorizationID()

getIdentifier

public static <T extends org.apache.hadoop.security.token.TokenIdentifier>
T getIdentifier(String id,
 org.apache.hadoop.security.token.SecretManager<T> secretManager)
         throws org.apache.hadoop.security.token.SecretManager.InvalidToken

Throws:

org.apache.hadoop.security.token.SecretManager.InvalidToken

unwrap

public static Throwable unwrap(Throwable e)

Unwrap InvalidToken exception, otherwise return the one passed in.