org.apache.hadoop.hbase.replication

Class TestReplicationStateBasic

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationStateBasic

Direct Known Subclasses:

TestReplicationStateZKImpl

public abstract class TestReplicationStateBasic
extends Object

White box testing for replication state interfaces. Implementations should extend this class, and initialize the interfaces properly.

Field Summary

Fields

Modifier and Type	Field and Description
protected static String	ID_ONE
protected static String	ID_TWO
protected static String	KEY_ONE
protected static String	KEY_TWO
private static org.slf4j.Logger	LOG
protected String	OUR_KEY
protected org.apache.hadoop.hbase.replication.ReplicationPeers	rp
protected org.apache.hadoop.hbase.replication.ReplicationQueueStorage	rqs
protected org.apache.hadoop.hbase.ServerName	server1
protected org.apache.hadoop.hbase.ServerName	server2
protected org.apache.hadoop.hbase.ServerName	server3
protected static int	ZK_MAX_COUNT
protected static int	ZK_SLEEP_INTERVAL
protected static int	zkTimeoutCount

Constructor Summary

Constructors

Constructor and Description
TestReplicationStateBasic()

Method Summary

Modifier and Type	Method and Description
protected void	assertConnectedPeerStatus(boolean status, String peerId)
protected void	assertNumberOfPeers(int total)
private String	getFileName(String base, int i)
protected void	populateQueues()
private void	removeAllQueues(org.apache.hadoop.hbase.ServerName serverName)
void	testHfileRefsReplicationQueues()
void	testPersistLogPositionAndSeqIdAtomically()
void	testRemovePeerForHFileRefs()
void	testReplicationPeers()
void	testReplicationQueues()
void	testReplicationQueueStorage()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

rqs

protected org.apache.hadoop.hbase.replication.ReplicationQueueStorage rqs

server1

protected org.apache.hadoop.hbase.ServerName server1

server2

protected org.apache.hadoop.hbase.ServerName server2

server3

protected org.apache.hadoop.hbase.ServerName server3

rp

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

ID_ONE

protected static final String ID_ONE

See Also:

Constant Field Values

ID_TWO

protected static final String ID_TWO

See Also:

Constant Field Values

KEY_ONE

protected static String KEY_ONE

KEY_TWO

protected static String KEY_TWO

OUR_KEY

protected String OUR_KEY

zkTimeoutCount

protected static int zkTimeoutCount

ZK_MAX_COUNT

protected static final int ZK_MAX_COUNT

See Also:

Constant Field Values

ZK_SLEEP_INTERVAL

protected static final int ZK_SLEEP_INTERVAL

See Also:

Constant Field Values

Constructor Detail

TestReplicationStateBasic

public TestReplicationStateBasic()

Method Detail

testReplicationQueueStorage

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

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

removeAllQueues

private void removeAllQueues(org.apache.hadoop.hbase.ServerName serverName)
                      throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

testReplicationQueues

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

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

testHfileRefsReplicationQueues

public void testHfileRefsReplicationQueues()
                                    throws org.apache.hadoop.hbase.replication.ReplicationException,
                                           org.apache.zookeeper.KeeperException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

org.apache.zookeeper.KeeperException

testRemovePeerForHFileRefs

public void testRemovePeerForHFileRefs()
                                throws org.apache.hadoop.hbase.replication.ReplicationException,
                                       org.apache.zookeeper.KeeperException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

org.apache.zookeeper.KeeperException

testReplicationPeers

public void testReplicationPeers()
                          throws Exception

Throws:

Exception

getFileName

private String getFileName(String base,
                           int i)

testPersistLogPositionAndSeqIdAtomically

public void testPersistLogPositionAndSeqIdAtomically()
                                              throws Exception

Throws:

Exception

assertConnectedPeerStatus

protected void assertConnectedPeerStatus(boolean status,
                                         String peerId)
                                  throws Exception

Throws:

Exception

assertNumberOfPeers

protected void assertNumberOfPeers(int total)
                            throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

populateQueues

protected void populateQueues()
                       throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException