Package 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	Description
protected static final String	ID_ONE
protected static final String	ID_TWO
protected static String	KEY_ONE
protected static String	KEY_TWO
private static final org.slf4j.Logger	LOG
protected String	OUR_KEY
protected org.apache.hadoop.hbase.replication.ReplicationPeers	rp
protected org.apache.hadoop.hbase.ServerName	server1
protected org.apache.hadoop.hbase.ServerName	server2
protected org.apache.hadoop.hbase.ServerName	server3
protected static final int	ZK_MAX_COUNT
protected static final int	ZK_SLEEP_INTERVAL
protected static int	zkTimeoutCount

Constructor Summary

Constructors

Constructor	Description
TestReplicationStateBasic()

Method Summary

Modifier and Type	Method	Description
private void	assertConnectedPeerStatus(boolean status, String peerId)
private void	assertNumberOfPeers(int total)
void	testReplicationPeers()

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

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 Details

TestReplicationStateBasic

public TestReplicationStateBasic()

Method Details

testReplicationPeers

public void testReplicationPeers()
                          throws Exception

Throws:

Exception

assertConnectedPeerStatus

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

Throws:

Exception

assertNumberOfPeers

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

Throws:

org.apache.hadoop.hbase.replication.ReplicationException