Package org.apache.hadoop.hbase.replication.regionserver

Class TestReplicationSourceManager

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.TestReplicationSourceManager

public class TestReplicationSourceManager
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TestReplicationSourceManager.ReplicationEndpointForTest

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.conf.Configuration	CONF
private static final byte[]	F1
private static final byte[]	F2
private static org.apache.hadoop.fs.FileSystem	FS
private org.apache.hadoop.fs.Path	logDir
private org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager	manager
final org.junit.rules.TestName	name
private org.apache.hadoop.fs.Path	oldLogDir
private org.apache.hadoop.fs.Path	remoteLogDir
private org.apache.hadoop.hbase.replication.regionserver.Replication	replication
private static org.apache.hadoop.hbase.client.RegionInfo	RI
private static NavigableMap<byte[],Integer>	SCOPES
private org.apache.hadoop.hbase.Server	server
private static final org.apache.hadoop.hbase.TableName	TABLE_NAME
private static final HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
TestReplicationSourceManager()

Method Summary

Modifier and Type	Method	Description
private void	addPeerAndWait(String peerId, String clusterKey, boolean syncRep)	Add a peer and wait for it to initialize
private void	createWALFile(org.apache.hadoop.fs.Path file)
private org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationSourceSource	getGlobalSource()
private void	removePeerAndWait(String peerId)	Remove a peer and wait for it to get cleaned up
void	setUp()
static void	setUpBeforeClass()
void	tearDown()
static void	tearDownAfterClass()
void	testClaimQueue()
void	testDisablePeerMetricsCleanup()
void	testRemovePeerMetricsCleanup()
void	testRemoveRemoteWALs()
void	testSameWALPrefix()

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

UTIL

private static final HBaseTestingUtil UTIL

CONF

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

FS

private static org.apache.hadoop.fs.FileSystem FS

F1

private static final byte[] F1

F2

private static final byte[] F2

TABLE_NAME

private static final org.apache.hadoop.hbase.TableName TABLE_NAME

RI

private static org.apache.hadoop.hbase.client.RegionInfo RI

SCOPES

private static NavigableMap<byte[],Integer> SCOPES

name

public final org.junit.rules.TestName name

oldLogDir

private org.apache.hadoop.fs.Path oldLogDir

logDir

private org.apache.hadoop.fs.Path logDir

remoteLogDir

private org.apache.hadoop.fs.Path remoteLogDir

server

private org.apache.hadoop.hbase.Server server

replication

private org.apache.hadoop.hbase.replication.regionserver.Replication replication

manager

private org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceManager manager

Constructor Details

TestReplicationSourceManager

public TestReplicationSourceManager()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws IOException

Throws:

IOException

setUp

public void setUp()
           throws Exception

Throws:

Exception

tearDown

public void tearDown()

addPeerAndWait

private void addPeerAndWait(String peerId,
 String clusterKey,
 boolean syncRep)
                     throws org.apache.hadoop.hbase.replication.ReplicationException,
IOException

Add a peer and wait for it to initialize

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

IOException

removePeerAndWait

private void removePeerAndWait(String peerId)
                        throws Exception

Remove a peer and wait for it to get cleaned up

Throws:

Exception

createWALFile

private void createWALFile(org.apache.hadoop.fs.Path file)
                    throws Exception

Throws:

Exception

testClaimQueue

public void testClaimQueue()
                    throws Exception

Throws:

Exception

testSameWALPrefix

public void testSameWALPrefix()
                       throws IOException

Throws:

IOException

getGlobalSource

private org.apache.hadoop.hbase.replication.regionserver.MetricsReplicationSourceSource getGlobalSource()

testRemovePeerMetricsCleanup

public void testRemovePeerMetricsCleanup()
                                  throws Exception

Throws:

Exception

testDisablePeerMetricsCleanup

public void testDisablePeerMetricsCleanup()
                                   throws Exception

Throws:

Exception

testRemoveRemoteWALs

public void testRemoveRemoteWALs()
                          throws Exception

Throws:

Exception