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
protected String	OUR_ID
protected String	OUR_KEY
protected ReplicationPeers	rp
protected ReplicationQueues	rq1
protected ReplicationQueues	rq2
protected ReplicationQueues	rq3
protected ReplicationQueuesClient	rqc
protected String	server1
protected String	server2
protected String	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)
protected void	populateQueues()
void	setUp()
void	testHfileRefsReplicationQueues()
void	testInvalidClusterKeys()
void	testRemovePeerForHFileRefs()
void	testReplicationPeers()
void	testReplicationQueues()
void	testReplicationQueuesClient()

Methods inherited from class java.lang.Object

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

Field Detail

rq1

protected ReplicationQueues rq1

rq2

protected ReplicationQueues rq2

rq3

protected ReplicationQueues rq3

rqc

protected ReplicationQueuesClient rqc

server1

protected String server1

server2

protected String server2

server3

protected String server3

rp

protected 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_ID

protected String OUR_ID

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

setUp

public void setUp()

testReplicationQueuesClient

public void testReplicationQueuesClient()
                                 throws ReplicationException,
                                        org.apache.zookeeper.KeeperException

Throws:

ReplicationException

org.apache.zookeeper.KeeperException

testReplicationQueues

public void testReplicationQueues()
                           throws ReplicationException

Throws:

ReplicationException

testInvalidClusterKeys

public void testInvalidClusterKeys()
                            throws ReplicationException,
                                   org.apache.zookeeper.KeeperException

Throws:

ReplicationException

org.apache.zookeeper.KeeperException

testHfileRefsReplicationQueues

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

Throws:

ReplicationException

org.apache.zookeeper.KeeperException

testRemovePeerForHFileRefs

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

Throws:

ReplicationException

org.apache.zookeeper.KeeperException

testReplicationPeers

public void testReplicationPeers()
                          throws Exception

Throws:

Exception

assertConnectedPeerStatus

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

Throws:

Exception

assertNumberOfPeers

protected void assertNumberOfPeers(int total)

populateQueues

protected void populateQueues()
                       throws ReplicationException

Throws:

ReplicationException