public class TestReplicationStateZKImpl extends TestReplicationStateBasic
ID_ONE, ID_TWO, KEY_ONE, KEY_TWO, OUR_ID, OUR_KEY, rp, rq1, rq2, rq3, rqc, server1, server2, server3, ZK_MAX_COUNT, ZK_SLEEP_INTERVAL, zkTimeoutCount| Constructor and Description |
|---|
TestReplicationStateZKImpl() |
| Modifier and Type | Method and Description |
|---|---|
void |
setUp() |
static void |
setUpBeforeClass() |
void |
tearDown() |
static void |
tearDownAfterClass() |
void |
testIsPeerPath_ActualPeerPath() |
void |
testIsPeerPath_PathToChildOfPeerNode() |
void |
testIsPeerPath_PathToParentOfPeerNode() |
assertConnectedPeerStatus, assertNumberOfPeers, populateQueues, testHfileRefsReplicationQueues, testRemovePeerForHFileRefs, testReplicationPeers, testReplicationQueues, testReplicationQueuesClientpublic static void setUpBeforeClass()
throws java.lang.Exception
java.lang.Exceptionpublic void setUp()
setUp in class TestReplicationStateBasicpublic void tearDown()
throws KeeperException,
java.io.IOException
KeeperExceptionjava.io.IOExceptionpublic static void tearDownAfterClass()
throws java.lang.Exception
java.lang.Exceptionpublic void testIsPeerPath_PathToParentOfPeerNode()
public void testIsPeerPath_PathToChildOfPeerNode()
public void testIsPeerPath_ActualPeerPath()