Package org.apache.hadoop.hbase.replication.master

Class TestReplicationLogCleaner

java.lang.Object

org.apache.hadoop.hbase.replication.master.TestReplicationLogCleaner

public class TestReplicationLogCleaner
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.hbase.replication.master.ReplicationLogCleaner	cleaner
private static final org.apache.hadoop.conf.Configuration	CONF
private org.apache.hadoop.hbase.master.MasterServices	services

Constructor Summary

Constructors

Constructor	Description
TestReplicationLogCleaner()

Method Summary

Modifier and Type	Method	Description
private void	addPeer(String... peerIds)
private void	addQueueData(org.apache.hadoop.hbase.replication.ReplicationQueueData... datas)
private void	addSCP(org.apache.hadoop.hbase.ServerName serverName, boolean finished)
private void	addServer(org.apache.hadoop.hbase.ServerName serverName)
private static org.apache.hadoop.fs.FileStatus	createFileStatus(org.apache.hadoop.fs.Path path)
private static org.apache.hadoop.fs.FileStatus	createFileStatus(org.apache.hadoop.hbase.ServerName sn, int number)
private static org.apache.hadoop.hbase.replication.ReplicationPeerDescription	createPeer(String peerId)
private static Iterable<org.apache.hadoop.fs.FileStatus>	runCleaner(org.apache.hadoop.hbase.replication.master.ReplicationLogCleaner cleaner, Iterable<org.apache.hadoop.fs.FileStatus> files)
void	setUp()
void	tearDown()
void	testCanNotFilter()
void	testDeadRegionServerMissingQueue()
void	testDeadRegionServerNoQueues()
void	testDeadRegionServerShouldDelete()
void	testDeadRegionServerShouldDeleteTwoPeers()
void	testDeadRegionServerShouldNotDelete()
void	testDeadRegionServerShouldNotDeleteTwoPeers()
void	testDeadRegionServerWithSCPNoQueues()
void	testLiveRegionServerMissingQueue()
void	testLiveRegionServerNoQueues()
void	testLiveRegionServerShouldDelete()
void	testLiveRegionServerShouldDeleteTwoPeers()
void	testLiveRegionServerShouldNotDelete()
void	testLiveRegionServerShouldNotDeleteTwoPeers()
void	testLiveRegionServerWithSCPNoQueues()
void	testMetaWalFile()
void	testNoConf()
void	testNoPeer()
void	testNotValidWalFile()

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

CONF

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

services

private org.apache.hadoop.hbase.master.MasterServices services

cleaner

private org.apache.hadoop.hbase.replication.master.ReplicationLogCleaner cleaner

Constructor Details

TestReplicationLogCleaner

public TestReplicationLogCleaner()

Method Details

setUp

public void setUp()
           throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

tearDown

public void tearDown()

runCleaner

private static Iterable<org.apache.hadoop.fs.FileStatus> runCleaner(org.apache.hadoop.hbase.replication.master.ReplicationLogCleaner cleaner,
 Iterable<org.apache.hadoop.fs.FileStatus> files)

createFileStatus

private static org.apache.hadoop.fs.FileStatus createFileStatus(org.apache.hadoop.fs.Path path)

createFileStatus

private static org.apache.hadoop.fs.FileStatus createFileStatus(org.apache.hadoop.hbase.ServerName sn,
 int number)

createPeer

private static org.apache.hadoop.hbase.replication.ReplicationPeerDescription createPeer(String peerId)

addServer

private void addServer(org.apache.hadoop.hbase.ServerName serverName)

addSCP

private void addSCP(org.apache.hadoop.hbase.ServerName serverName,
 boolean finished)

addPeer

private void addPeer(String... peerIds)

addQueueData

private void addQueueData(org.apache.hadoop.hbase.replication.ReplicationQueueData... datas)
                   throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

testNoConf

public void testNoConf()

testCanNotFilter

public void testCanNotFilter()

testNoPeer

public void testNoPeer()

testNotValidWalFile

public void testNotValidWalFile()

testMetaWalFile

public void testMetaWalFile()

testLiveRegionServerNoQueues

public void testLiveRegionServerNoQueues()

testLiveRegionServerWithSCPNoQueues

public void testLiveRegionServerWithSCPNoQueues()

testDeadRegionServerNoQueues

public void testDeadRegionServerNoQueues()

testDeadRegionServerWithSCPNoQueues

public void testDeadRegionServerWithSCPNoQueues()

testLiveRegionServerMissingQueue

public void testLiveRegionServerMissingQueue()
                                      throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

testLiveRegionServerShouldNotDelete

public void testLiveRegionServerShouldNotDelete()
                                         throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

testLiveRegionServerShouldNotDeleteTwoPeers

public void testLiveRegionServerShouldNotDeleteTwoPeers()
                                                 throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

testLiveRegionServerShouldDelete

public void testLiveRegionServerShouldDelete()
                                      throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

testLiveRegionServerShouldDeleteTwoPeers

public void testLiveRegionServerShouldDeleteTwoPeers()
                                              throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

testDeadRegionServerMissingQueue

public void testDeadRegionServerMissingQueue()
                                      throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

testDeadRegionServerShouldNotDelete

public void testDeadRegionServerShouldNotDelete()
                                         throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

testDeadRegionServerShouldNotDeleteTwoPeers

public void testDeadRegionServerShouldNotDeleteTwoPeers()
                                                 throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

testDeadRegionServerShouldDelete

public void testDeadRegionServerShouldDelete()
                                      throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

testDeadRegionServerShouldDeleteTwoPeers

public void testDeadRegionServerShouldDeleteTwoPeers()
                                              throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException