org.apache.hadoop.hbase.security.token

Class TestTokenAuthentication.TokenServer

java.lang.Object

org.apache.hadoop.hbase.security.token.TokenProvider

org.apache.hadoop.hbase.security.token.TestTokenAuthentication.TokenServer

All Implemented Interfaces:

Runnable, org.apache.hadoop.hbase.Abortable, org.apache.hadoop.hbase.Coprocessor, org.apache.hadoop.hbase.coprocessor.RegionCoprocessor, org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.AuthenticationService.BlockingInterface, org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.AuthenticationService.Interface, org.apache.hadoop.hbase.Server, org.apache.hadoop.hbase.Stoppable

Enclosing class:

TestTokenAuthentication

private static class TestTokenAuthentication.TokenServer
extends org.apache.hadoop.hbase.security.token.TokenProvider
implements org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.AuthenticationService.BlockingInterface, Runnable, org.apache.hadoop.hbase.Server

Basic server process for RPC authentication testing

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.Coprocessor

org.apache.hadoop.hbase.Coprocessor.State

Field Summary

Fields

Modifier and Type	Field and Description
private boolean	aborted
private org.apache.hadoop.conf.Configuration	conf
private InetSocketAddress	isa
private static org.slf4j.Logger	LOG
private org.apache.hadoop.hbase.ipc.RpcServerInterface	rpcServer
private org.apache.hadoop.hbase.util.Sleeper	sleeper
private long	startcode
private boolean	started
private boolean	stopped
private HBaseTestingUtility	TEST_UTIL
private org.apache.hadoop.hbase.zookeeper.ZKWatcher	zookeeper

Fields inherited from interface org.apache.hadoop.hbase.Coprocessor

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor and Description
TokenServer(org.apache.hadoop.conf.Configuration conf, HBaseTestingUtility TEST_UTIL)

Method Summary

Modifier and Type	Method and Description
void	abort(String reason, Throwable error)
org.apache.hadoop.hbase.client.Connection	createConnection(org.apache.hadoop.conf.Configuration conf)
InetSocketAddress	getAddress()
org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.GetAuthenticationTokenResponse	getAuthenticationToken(com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.GetAuthenticationTokenRequest request)
org.apache.hadoop.hbase.ChoreService	getChoreService()
org.apache.hadoop.hbase.client.ClusterConnection	getClusterConnection()
org.apache.hadoop.conf.Configuration	getConfiguration()
org.apache.hadoop.hbase.client.ClusterConnection	getConnection()
org.apache.hadoop.hbase.CoordinatedStateManager	getCoordinatedStateManager()
org.apache.hadoop.fs.FileSystem	getFileSystem()
org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier>	getSecretManager()
org.apache.hadoop.hbase.ServerName	getServerName()
org.apache.hadoop.hbase.zookeeper.ZKWatcher	getZooKeeper()
private void	initialize()
boolean	isAborted()
boolean	isStarted()
boolean	isStopped()
boolean	isStopping()
void	run()
void	stop(String reason)
org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.WhoAmIResponse	whoAmI(com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.WhoAmIRequest request)

Methods inherited from class org.apache.hadoop.hbase.security.token.TokenProvider

getAuthenticationToken, getServices, start, stop, whoAmI

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionCoprocessor

getBulkLoadObserver, getEndpointObserver, getRegionObserver

Field Detail

LOG

private static final org.slf4j.Logger LOG

conf

private org.apache.hadoop.conf.Configuration conf

TEST_UTIL

private HBaseTestingUtility TEST_UTIL

rpcServer

private org.apache.hadoop.hbase.ipc.RpcServerInterface rpcServer

isa

private InetSocketAddress isa

zookeeper

private org.apache.hadoop.hbase.zookeeper.ZKWatcher zookeeper

sleeper

private org.apache.hadoop.hbase.util.Sleeper sleeper

started

private boolean started

aborted

private boolean aborted

stopped

private boolean stopped

startcode

private long startcode

Constructor Detail

TokenServer

public TokenServer(org.apache.hadoop.conf.Configuration conf,
                   HBaseTestingUtility TEST_UTIL)
            throws IOException

Throws:

IOException

Method Detail

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

Specified by:

getConfiguration in interface org.apache.hadoop.hbase.Server

getConnection

public org.apache.hadoop.hbase.client.ClusterConnection getConnection()

Specified by:

getConnection in interface org.apache.hadoop.hbase.Server

getZooKeeper

public org.apache.hadoop.hbase.zookeeper.ZKWatcher getZooKeeper()

Specified by:

getZooKeeper in interface org.apache.hadoop.hbase.Server

getCoordinatedStateManager

public org.apache.hadoop.hbase.CoordinatedStateManager getCoordinatedStateManager()

Specified by:

getCoordinatedStateManager in interface org.apache.hadoop.hbase.Server

isAborted

public boolean isAborted()

Specified by:

isAborted in interface org.apache.hadoop.hbase.Abortable

getServerName

public org.apache.hadoop.hbase.ServerName getServerName()

Specified by:

getServerName in interface org.apache.hadoop.hbase.Server

getFileSystem

public org.apache.hadoop.fs.FileSystem getFileSystem()

Specified by:

getFileSystem in interface org.apache.hadoop.hbase.Server

isStopping

public boolean isStopping()

Specified by:

isStopping in interface org.apache.hadoop.hbase.Server

abort

public void abort(String reason,
                  Throwable error)

Specified by:

abort in interface org.apache.hadoop.hbase.Abortable

initialize

private void initialize()
                 throws IOException

Throws:

IOException

run

public void run()

Specified by:

run in interface Runnable

isStarted

public boolean isStarted()

stop

public void stop(String reason)

Specified by:

stop in interface org.apache.hadoop.hbase.Stoppable

isStopped

public boolean isStopped()

Specified by:

isStopped in interface org.apache.hadoop.hbase.Stoppable

getAddress

public InetSocketAddress getAddress()

getSecretManager

public org.apache.hadoop.security.token.SecretManager<? extends org.apache.hadoop.security.token.TokenIdentifier> getSecretManager()

getAuthenticationToken

public org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.GetAuthenticationTokenResponse getAuthenticationToken(com.google.protobuf.RpcController controller,
                                                                                                                             org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.GetAuthenticationTokenRequest request)
                                                                                                                      throws com.google.protobuf.ServiceException

Specified by:

getAuthenticationToken in interface org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.AuthenticationService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

whoAmI

public org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.WhoAmIResponse whoAmI(com.google.protobuf.RpcController controller,
                                                                                             org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.WhoAmIRequest request)
                                                                                      throws com.google.protobuf.ServiceException

Specified by:

whoAmI in interface org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.AuthenticationService.BlockingInterface

Throws:

com.google.protobuf.ServiceException

getChoreService

public org.apache.hadoop.hbase.ChoreService getChoreService()

Specified by:

getChoreService in interface org.apache.hadoop.hbase.Server

getClusterConnection

public org.apache.hadoop.hbase.client.ClusterConnection getClusterConnection()

Specified by:

getClusterConnection in interface org.apache.hadoop.hbase.Server

createConnection

public org.apache.hadoop.hbase.client.Connection createConnection(org.apache.hadoop.conf.Configuration conf)
                                                           throws IOException

Specified by:

createConnection in interface org.apache.hadoop.hbase.Server

Throws:

IOException