org.apache.hadoop.hbase.regionserver

Class TestRegionServerNoMaster

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestRegionServerNoMaster

public class TestRegionServerNoMaster
extends Object

Tests on the region server, without the master.

Constructor Summary

Constructors

Constructor and Description
TestRegionServerNoMaster()

Method Summary

Modifier and Type	Method and Description
void	after()
static void	afterClass()
static void	before()
static void	checkRegionIsClosed(HBaseTestingUtility HTU, HRegionServer rs, HRegionInfo hri)
static void	checkRegionIsOpened(HBaseTestingUtility HTU, HRegionServer rs, HRegionInfo hri)
static void	closeRegion(HBaseTestingUtility HTU, HRegionServer rs, HRegionInfo hri)
static void	flushRegion(HBaseTestingUtility HTU, HRegionInfo regionInfo) Flush the given region in the mini cluster.
static void	openRegion(HBaseTestingUtility HTU, HRegionServer rs, HRegionInfo hri)
static void	stopMasterAndAssignMeta(HBaseTestingUtility HTU)
void	testCancelOpeningWithoutZK() Test that if we do a close while opening it stops the opening.
void	testCancelOpeningWithZK() Test an open then a close with ZK.
void	testCloseByMasterWithoutZNode()
void	testCloseByRegionServer()
void	testMultipleCloseFromMaster()
void	testMultipleOpen() Test that we can send multiple openRegion to the region server.
void	testOpenCloseByMasterWithZNode()
void	testOpenCloseRegionRPCIntendedForPreviousServer() Tests an on-the-fly RPC that was scheduled for the earlier RS on the same port for openRegion.
void	testOpenClosingRegion()

Methods inherited from class java.lang.Object

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

Constructor Detail

TestRegionServerNoMaster

public TestRegionServerNoMaster()

Method Detail

before

public static void before()
                   throws Exception

Throws:

Exception

stopMasterAndAssignMeta

public static void stopMasterAndAssignMeta(HBaseTestingUtility HTU)
                                    throws NodeExistsException,
                                           KeeperException,
                                           IOException,
                                           InterruptedException

Throws:

NodeExistsException

KeeperException

IOException

InterruptedException

flushRegion

public static void flushRegion(HBaseTestingUtility HTU,
                               HRegionInfo regionInfo)
                        throws IOException

Flush the given region in the mini cluster. Since no master, we cannot use HBaseAdmin.flush()

Throws:

IOException

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

after

public void after()
           throws Exception

Throws:

Exception

openRegion

public static void openRegion(HBaseTestingUtility HTU,
                              HRegionServer rs,
                              HRegionInfo hri)
                       throws Exception

Throws:

Exception

checkRegionIsOpened

public static void checkRegionIsOpened(HBaseTestingUtility HTU,
                                       HRegionServer rs,
                                       HRegionInfo hri)
                                throws Exception

Throws:

Exception

closeRegion

public static void closeRegion(HBaseTestingUtility HTU,
                               HRegionServer rs,
                               HRegionInfo hri)
                        throws Exception

Throws:

Exception

checkRegionIsClosed

public static void checkRegionIsClosed(HBaseTestingUtility HTU,
                                       HRegionServer rs,
                                       HRegionInfo hri)
                                throws Exception

Throws:

Exception

testCloseByRegionServer

public void testCloseByRegionServer()
                             throws Exception

Throws:

Exception

testCloseByMasterWithoutZNode

public void testCloseByMasterWithoutZNode()
                                   throws Exception

Throws:

Exception

testOpenCloseByMasterWithZNode

public void testOpenCloseByMasterWithZNode()
                                    throws Exception

Throws:

Exception

testMultipleOpen

public void testMultipleOpen()
                      throws Exception

Test that we can send multiple openRegion to the region server. This is used when: - there is a SocketTimeout: in this case, the master does not know if the region server received the request before the timeout. - We have a socket error during the operation: same stuff: we don't know - a master failover: if we find a znode in thz M_ZK_REGION_OFFLINE, we don't know if the region server has received the query or not. Only solution to be efficient: re-ask immediately.

Throws:

Exception

testOpenClosingRegion

public void testOpenClosingRegion()
                           throws Exception

Throws:

Exception

testMultipleCloseFromMaster

public void testMultipleCloseFromMaster()
                                 throws Exception

Throws:

Exception

testCancelOpeningWithoutZK

public void testCancelOpeningWithoutZK()
                                throws Exception

Test that if we do a close while opening it stops the opening.

Throws:

Exception

testCancelOpeningWithZK

public void testCancelOpeningWithZK()
                             throws Exception

Test an open then a close with ZK. This is going to mess-up the ZK states, so the opening will fail as well because it doesn't find what it expects in ZK.

Throws:

Exception

testOpenCloseRegionRPCIntendedForPreviousServer

public void testOpenCloseRegionRPCIntendedForPreviousServer()
                                                     throws Exception

Tests an on-the-fly RPC that was scheduled for the earlier RS on the same port for openRegion. The region server should reject this RPC. (HBASE-9721)

Throws:

Exception