org.apache.hadoop.hbase.http.log

Class TestLogLevel

java.lang.Object

org.apache.hadoop.hbase.http.log.TestLogLevel

public class TestLogLevel
extends Object

Test LogLevel.

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.conf.Configuration	clientConf
private static String	clientPrincipal
private static String	HTTP_PRINCIPAL
private static HBaseCommonTestingUtility	HTU
private static org.apache.hadoop.minikdc.MiniKdc	kdc
private static String	keystoresDir
private static String	KEYTAB
private static File	keyTabFile
private static String	LOCALHOST
private static org.apache.logging.log4j.Logger	log
private static String	logName
private static String	PRINCIPAL
private static String	protectedLogName
private static String	protectedPrefix
private static org.apache.hadoop.conf.Configuration	serverConf
private static org.apache.hadoop.conf.Configuration	sslConf
private static String	sslConfDir

Constructor Summary

Constructors

Constructor and Description
TestLogLevel()

Method Summary

Modifier and Type	Method and Description
private org.apache.hadoop.hbase.http.HttpServer	createServer(String protocol, boolean isSpnego) Creates and starts a Jetty server binding at an ephemeral port to run LogLevel servlet.
private static void	exceptionShouldContains(String substr, Throwable throwable) Assert that a throwable or one of its causes should contain the substr in its message.
private void	getLevel(String protocol, String authority, String logName) Run LogLevel command line to start a client to get log level of this test class.
private static org.apache.hadoop.conf.Configuration	getSslConfig(org.apache.hadoop.conf.Configuration conf) Get the SSL configuration.
private void	setLevel(String protocol, String authority, String logName, String newLevel) Run LogLevel command line to start a client to set log level of this test class to debug.
static void	setUp()
private static org.apache.hadoop.minikdc.MiniKdc	setupMiniKdc() Sets up MiniKdc for testing security.
private static void	setupSSL(File base)
static void	tearDown()
void	testCommandOptions() Test client command line options.
private void	testDynamicLogLevel(String bindProtocol, String connectProtocol, boolean isSpnego)
private void	testDynamicLogLevel(String bindProtocol, String connectProtocol, boolean isSpnego, String newLevel)
private void	testDynamicLogLevel(String bindProtocol, String connectProtocol, boolean isSpnego, String loggerName, String newLevel) Run both client and server using the given protocol.
void	testErrorLogLevel() Test setting log level to "Error".
void	testInfoLogLevel() Test setting log level to "Info".
void	testLogLevelByHttp() Server runs HTTP, no SPNEGO.
void	testLogLevelByHttps() Server runs HTTPS, no SPNEGO.
void	testLogLevelByHttpsWithSpnego() Server runs HTTPS + SPNEGO.
void	testLogLevelByHttpWithSpnego() Server runs HTTP + SPNEGO.
void	testSettingProtectedLogLevel()
private boolean	validateCommand(String[] args) Check to see if a command can be accepted.

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

keystoresDir

private static String keystoresDir

sslConfDir

private static String sslConfDir

serverConf

private static org.apache.hadoop.conf.Configuration serverConf

clientConf

private static org.apache.hadoop.conf.Configuration clientConf

sslConf

private static org.apache.hadoop.conf.Configuration sslConf

logName

private static final String logName

protectedPrefix

private static final String protectedPrefix

See Also:

Constant Field Values

protectedLogName

private static final String protectedLogName

log

private static final org.apache.logging.log4j.Logger log

PRINCIPAL

private static final String PRINCIPAL

See Also:

Constant Field Values

KEYTAB

private static final String KEYTAB

See Also:

Constant Field Values

kdc

private static org.apache.hadoop.minikdc.MiniKdc kdc

LOCALHOST

private static final String LOCALHOST

See Also:

Constant Field Values

clientPrincipal

private static final String clientPrincipal

See Also:

Constant Field Values

HTTP_PRINCIPAL

private static String HTTP_PRINCIPAL

HTU

private static HBaseCommonTestingUtility HTU

keyTabFile

private static File keyTabFile

Constructor Detail

TestLogLevel

public TestLogLevel()

Method Detail

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

setupMiniKdc

private static org.apache.hadoop.minikdc.MiniKdc setupMiniKdc()
                                                       throws Exception

Sets up MiniKdc for testing security. Copied from HBaseTestingUtility#setupMiniKdc().

Throws:

Exception

setupSSL

private static void setupSSL(File base)
                      throws Exception

Throws:

Exception

getSslConfig

private static org.apache.hadoop.conf.Configuration getSslConfig(org.apache.hadoop.conf.Configuration conf)

Get the SSL configuration. This method is copied from KeyStoreTestUtil#getSslConfig() in Hadoop.

Parameters:

conf - to pull client/server SSL settings filename from

Returns:

Configuration instance with ssl configs loaded.

tearDown

public static void tearDown()

testCommandOptions

public void testCommandOptions()
                        throws Exception

Test client command line options. Does not validate server behavior.

Throws:

Exception - if commands return unexpected results.

validateCommand

private boolean validateCommand(String[] args)

Check to see if a command can be accepted.

Parameters:

args - a String array of arguments

Returns:

true if the command can be accepted, false if not.

createServer

private org.apache.hadoop.hbase.http.HttpServer createServer(String protocol,
                                                             boolean isSpnego)
                                                      throws Exception

Creates and starts a Jetty server binding at an ephemeral port to run LogLevel servlet.

Parameters:

protocol - "http" or "https"

isSpnego - true if SPNEGO is enabled

Returns:

a created HttpServer object

Throws:

Exception - if unable to create or start a Jetty server

testDynamicLogLevel

private void testDynamicLogLevel(String bindProtocol,
                                 String connectProtocol,
                                 boolean isSpnego)
                          throws Exception

Throws:

Exception

testDynamicLogLevel

private void testDynamicLogLevel(String bindProtocol,
                                 String connectProtocol,
                                 boolean isSpnego,
                                 String newLevel)
                          throws Exception

Throws:

Exception

testDynamicLogLevel

private void testDynamicLogLevel(String bindProtocol,
                                 String connectProtocol,
                                 boolean isSpnego,
                                 String loggerName,
                                 String newLevel)
                          throws Exception

Run both client and server using the given protocol.

Parameters:

bindProtocol - specify either http or https for server

connectProtocol - specify either http or https for client

isSpnego - true if SPNEGO is enabled

Throws:

Exception - if client can't accesss server.

getLevel

private void getLevel(String protocol,
                      String authority,
                      String logName)
               throws Exception

Run LogLevel command line to start a client to get log level of this test class.

Parameters:

protocol - specify either http or https

authority - daemon's web UI address

Throws:

Exception - if unable to connect

setLevel

private void setLevel(String protocol,
                      String authority,
                      String logName,
                      String newLevel)
               throws Exception

Run LogLevel command line to start a client to set log level of this test class to debug.

Parameters:

protocol - specify either http or https

authority - daemon's web UI address

Throws:

Exception - if unable to run or log level does not change as expected

testSettingProtectedLogLevel

public void testSettingProtectedLogLevel()
                                  throws Exception

Throws:

Exception

testInfoLogLevel

public void testInfoLogLevel()
                      throws Exception

Test setting log level to "Info".

Throws:

Exception - if client can't set log level to INFO.

testErrorLogLevel

public void testErrorLogLevel()
                       throws Exception

Test setting log level to "Error".

Throws:

Exception - if client can't set log level to ERROR.

testLogLevelByHttp

public void testLogLevelByHttp()
                        throws Exception

Server runs HTTP, no SPNEGO.

Throws:

Exception - if http client can't access http server, or http client can access https server.

testLogLevelByHttpWithSpnego

public void testLogLevelByHttpWithSpnego()
                                  throws Exception

Server runs HTTP + SPNEGO.

Throws:

Exception - if http client can't access http server, or http client can access https server.

testLogLevelByHttps

public void testLogLevelByHttps()
                         throws Exception

Server runs HTTPS, no SPNEGO.

Throws:

Exception - if https client can't access https server, or https client can access http server.

testLogLevelByHttpsWithSpnego

public void testLogLevelByHttpsWithSpnego()
                                   throws Exception

Server runs HTTPS + SPNEGO.

Throws:

Exception - if https client can't access https server, or https client can access http server.

exceptionShouldContains

private static void exceptionShouldContains(String substr,
                                            Throwable throwable)

Assert that a throwable or one of its causes should contain the substr in its message. Ideally we should use GenericTestUtils.assertExceptionContains(String, Throwable) util method which asserts t.toString() contains the substr. As the original throwable may have been wrapped in Hadoop3 because of HADOOP-12897, it's required to check all the wrapped causes. After stop supporting Hadoop2, this method can be removed and assertion in tests can use t.getCause() directly, similar to HADOOP-15280.