org.apache.hadoop.hbase.replication

Class TestReplicationTrackerZKImpl

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationTrackerZKImpl

public class TestReplicationTrackerZKImpl
extends Object

This class tests the ReplicationTrackerZKImpl class and ReplicationListener interface. One MiniZKCluster is used throughout the entire class. The cluster is initialized with the creation of the rsZNode. All other znode creation/initialization is handled by the replication state interfaces (i.e. ReplicationPeers, etc.). Each test case in this class should ensure that the MiniZKCluster is cleaned and returned to it's initial state (i.e. nothing but the rsZNode).

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
private class	TestReplicationTrackerZKImpl.DummyReplicationListener
private class	TestReplicationTrackerZKImpl.DummyServer

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.conf.Configuration	conf
private static org.slf4j.Logger	LOG
private AtomicInteger	peerRemovedCount
private String	peerRemovedData
private AtomicInteger	plChangedCount
private List<String>	plChangedData
private org.apache.hadoop.hbase.replication.ReplicationPeers	rp
private AtomicInteger	rsRemovedCount
private String	rsRemovedData
private org.apache.hadoop.hbase.replication.ReplicationTracker	rt
private static HBaseTestingUtility	utility
private org.apache.hadoop.hbase.zookeeper.ZKWatcher	zkw

Constructor Summary

Constructors

Constructor and Description
TestReplicationTrackerZKImpl()

Method Summary

Modifier and Type	Method and Description
void	setUp()
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testGetListOfRegionServers()
void	testPeerListChangedEvent()
void	testPeerNameControl()
void	testPeerRemovedEvent()
void	testRegionServerRemovedEvent()

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

conf

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

utility

private static HBaseTestingUtility utility

zkw

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

rp

private org.apache.hadoop.hbase.replication.ReplicationPeers rp

rt

private org.apache.hadoop.hbase.replication.ReplicationTracker rt

rsRemovedCount

private AtomicInteger rsRemovedCount

rsRemovedData

private String rsRemovedData

plChangedCount

private AtomicInteger plChangedCount

plChangedData

private List<String> plChangedData

peerRemovedCount

private AtomicInteger peerRemovedCount

peerRemovedData

private String peerRemovedData

Constructor Detail

TestReplicationTrackerZKImpl

public TestReplicationTrackerZKImpl()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testGetListOfRegionServers

public void testGetListOfRegionServers()
                                throws Exception

Throws:

Exception

testRegionServerRemovedEvent

public void testRegionServerRemovedEvent()
                                  throws Exception

Throws:

Exception

testPeerRemovedEvent

public void testPeerRemovedEvent()
                          throws Exception

Throws:

Exception

testPeerListChangedEvent

public void testPeerListChangedEvent()
                              throws Exception

Throws:

Exception

testPeerNameControl

public void testPeerNameControl()
                         throws Exception

Throws:

Exception