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 java.lang.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 java.lang.String	ID_ONE
protected static java.lang.String	ID_TWO
protected static java.lang.String	KEY_ONE
protected static java.lang.String	KEY_TWO
protected java.lang.String	OUR_ID
protected java.lang.String	OUR_KEY
protected ReplicationPeers	rp
protected ReplicationQueues	rq1
protected ReplicationQueues	rq2
protected ReplicationQueues	rq3
protected ReplicationQueuesClient	rqc
protected java.lang.String	server1
protected java.lang.String	server2
protected java.lang.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, java.lang.String peerId)
protected void	assertNumberOfPeers(int total)
protected void	populateQueues()
void	setUp()
void	testHfileRefsReplicationQueues()
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 java.lang.String server1

server2

protected java.lang.String server2

server3

protected java.lang.String server3

rp

protected ReplicationPeers rp

ID_ONE

protected static final java.lang.String ID_ONE

See Also:

Constant Field Values

ID_TWO

protected static final java.lang.String ID_TWO

See Also:

Constant Field Values

KEY_ONE

protected static java.lang.String KEY_ONE

KEY_TWO

protected static java.lang.String KEY_TWO

OUR_ID

protected java.lang.String OUR_ID

OUR_KEY

protected java.lang.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,
                                        KeeperException

Throws:

ReplicationException

KeeperException

testReplicationQueues

public void testReplicationQueues()
                           throws ReplicationException

Throws:

ReplicationException

testHfileRefsReplicationQueues

public void testHfileRefsReplicationQueues()
                                    throws ReplicationException,
                                           KeeperException

Throws:

ReplicationException

KeeperException

testRemovePeerForHFileRefs

public void testRemovePeerForHFileRefs()
                                throws ReplicationException,
                                       KeeperException

Throws:

ReplicationException

KeeperException

testReplicationPeers

public void testReplicationPeers()
                          throws java.lang.Exception

Throws:

java.lang.Exception

assertConnectedPeerStatus

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

Throws:

java.lang.Exception

assertNumberOfPeers

protected void assertNumberOfPeers(int total)

populateQueues

protected void populateQueues()
                       throws ReplicationException

Throws:

ReplicationException