org.apache.hadoop.hbase

Class TestMetaTableLocator

java.lang.Object

org.apache.hadoop.hbase.TestMetaTableLocator

public class TestMetaTableLocator
extends Object

Test MetaTableLocator

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	TestMetaTableLocator.WaitOnMetaThread Wait on META.

Field Summary

Fields

Modifier and Type	Field and Description
private org.apache.hadoop.hbase.Abortable	abortable
static HBaseClassTestRule	CLASS_RULE
private static org.slf4j.Logger	LOG
private static org.apache.hadoop.hbase.ServerName	SN
private static HBaseTestingUtility	UTIL
private org.apache.hadoop.hbase.zookeeper.ZKWatcher	watcher

Constructor Summary

Constructors

Constructor and Description
TestMetaTableLocator()

Method Summary

Modifier and Type	Method and Description
void	after()
static void	afterClass()
void	before()
static void	beforeClass()
private org.apache.hadoop.hbase.client.ClusterConnection	mockConnection(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface admin, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface client)
private void	startWaitAliveThenWaitItLives(Thread t, int ms)
void	testGetMetaServerConnectionFails() Test we survive a connection refused ConnectException
void	testInterruptWaitOnMeta() Test interruptable while blocking wait on meta.
void	testMetaLookup() Test normal operations
void	testNoTimeoutWaitForMeta() Test waiting on meat w/ no timeout specified.
void	testTimeoutWaitForMeta()
void	testVerifyMetaRegionLocationFails() Test get of meta region fails properly if nothing to connect to.
private void	testVerifyMetaRegionLocationWithException(Exception ex)
void	testVerifyMetaRegionServerNotRunning() Test that verifyMetaRegionLocation properly handles getting a ServerNotRunningException.

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

LOG

private static final org.slf4j.Logger LOG

UTIL

private static final HBaseTestingUtility UTIL

SN

private static final org.apache.hadoop.hbase.ServerName SN

watcher

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

abortable

private org.apache.hadoop.hbase.Abortable abortable

Constructor Detail

TestMetaTableLocator

public TestMetaTableLocator()

Method Detail

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws IOException

Throws:

IOException

before

public void before()
            throws IOException

Throws:

IOException

after

public void after()

testMetaLookup

public void testMetaLookup()
                    throws IOException,
                           InterruptedException,
                           org.apache.hbase.thirdparty.com.google.protobuf.ServiceException,
                           org.apache.zookeeper.KeeperException

Test normal operations

Throws:

IOException

InterruptedException

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

org.apache.zookeeper.KeeperException

testInterruptWaitOnMeta

public void testInterruptWaitOnMeta()
                             throws IOException,
                                    InterruptedException,
                                    org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Test interruptable while blocking wait on meta.

Throws:

IOException

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

InterruptedException

testVerifyMetaRegionLocationWithException

private void testVerifyMetaRegionLocationWithException(Exception ex)
                                                throws IOException,
                                                       InterruptedException,
                                                       org.apache.zookeeper.KeeperException,
                                                       org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Throws:

IOException

InterruptedException

org.apache.zookeeper.KeeperException

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

testGetMetaServerConnectionFails

public void testGetMetaServerConnectionFails()
                                      throws IOException,
                                             InterruptedException,
                                             org.apache.zookeeper.KeeperException,
                                             org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Test we survive a connection refused ConnectException

Throws:

IOException

InterruptedException

org.apache.zookeeper.KeeperException

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

testVerifyMetaRegionServerNotRunning

public void testVerifyMetaRegionServerNotRunning()
                                          throws IOException,
                                                 InterruptedException,
                                                 org.apache.zookeeper.KeeperException,
                                                 org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Test that verifyMetaRegionLocation properly handles getting a ServerNotRunningException. See HBASE-4470. Note this doesn't check the exact exception thrown in the HBASE-4470 as there it is thrown from getHConnection() and here it is thrown from get() -- but those are both called from the same function anyway, and this way is less invasive than throwing from getHConnection would be.

Throws:

IOException

InterruptedException

org.apache.zookeeper.KeeperException

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

testVerifyMetaRegionLocationFails

public void testVerifyMetaRegionLocationFails()
                                       throws IOException,
                                              InterruptedException,
                                              org.apache.zookeeper.KeeperException,
                                              org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Test get of meta region fails properly if nothing to connect to.

Throws:

IOException

InterruptedException

org.apache.zookeeper.KeeperException

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

testTimeoutWaitForMeta

public void testTimeoutWaitForMeta()
                            throws IOException,
                                   InterruptedException

Throws:

IOException

InterruptedException

testNoTimeoutWaitForMeta

public void testNoTimeoutWaitForMeta()
                              throws IOException,
                                     InterruptedException,
                                     org.apache.zookeeper.KeeperException

Test waiting on meat w/ no timeout specified.

Throws:

IOException

InterruptedException

org.apache.zookeeper.KeeperException

mockConnection

private org.apache.hadoop.hbase.client.ClusterConnection mockConnection(org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface admin,
                                                                        org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface client)
                                                                 throws IOException

Parameters:

admin - An AdminProtos.AdminService.BlockingInterface instance; you'll likely want to pass a mocked HRS; can be null.

client - A mocked ClientProtocol instance, can be null

Returns:

Mock up a connection that returns a Configuration when Connection.getConfiguration() is called, a 'location' when RegionLocator.getRegionLocation(byte[], boolean) is called, and that returns the passed AdminProtos.AdminService.BlockingInterface instance when ClusterConnection.getAdmin(ServerName) is called, returns the passed ClientProtos.ClientService.BlockingInterface instance when ClusterConnection.getClient(ServerName) is called.

Throws:

IOException

startWaitAliveThenWaitItLives

private void startWaitAliveThenWaitItLives(Thread t,
                                           int ms)