Package org.apache.hadoop.hbase.replication

Class SyncReplicationTestBase

java.lang.Object

org.apache.hadoop.hbase.replication.SyncReplicationTestBase

Direct Known Subclasses:

SyncReplicationActiveTestBase, SyncReplicationStandbyTestBase, TestDrainReplicationQueuesForStandBy, TestRegisterPeerWorkerWhenRestarting, TestSerialSyncReplication, TestSyncReplicationMoreLogsInLocalCopyToRemote, TestSyncReplicationMoreLogsInLocalGiveUpSplitting, TestSyncReplicationNewRSJoinBetweenRefreshes, TestSyncReplicationRemoveRemoteWAL, TestSyncReplicationShipperQuit, TestSyncReplicationStandbyKillMaster, TestSyncReplicationStandbyKillRS, TestTransitPeerSyncReplicationStateProcedureRetry

public class SyncReplicationTestBase
extends Object

Base class for testing sync replication.

Field Summary

Fields

Modifier and Type	Field	Description
protected static byte[]	CF
protected static byte[]	CQ
protected static String	PEER_ID
protected static org.apache.hadoop.fs.Path	REMOTE_WAL_DIR1
protected static org.apache.hadoop.fs.Path	REMOTE_WAL_DIR2
protected static org.apache.hadoop.hbase.TableName	TABLE_NAME
protected static final HBaseTestingUtil	UTIL1
protected static final HBaseTestingUtil	UTIL2
protected static final HBaseZKTestingUtil	ZK_UTIL

Constructor Summary

Constructors

Constructor	Description
SyncReplicationTestBase()

Method Summary

Modifier and Type	Method	Description
private void	assertRejection(Throwable error)
protected final org.apache.hadoop.fs.Path	getRemoteWALDir(org.apache.hadoop.fs.Path remoteWALDir, String peerId)
protected final org.apache.hadoop.fs.Path	getRemoteWALDir(org.apache.hadoop.hbase.master.MasterFileSystem mfs, String peerId)
protected final org.apache.hadoop.fs.Path	getReplayRemoteWALs(org.apache.hadoop.fs.Path remoteWALDir, String peerId)
protected static void	initTestingUtility(HBaseTestingUtil util, String zkParent)
static void	setUp()
private static void	shutdown(HBaseTestingUtil util)
static void	tearDown()
protected final void	verify(HBaseTestingUtil util, int start, int end)
protected final void	verifyNotReplicatedThroughRegion(HBaseTestingUtil util, int start, int end)
protected final void	verifyRemovedPeer(String peerId, org.apache.hadoop.fs.Path remoteWALDir, HBaseTestingUtil utility)
protected final void	verifyReplicationRequestRejection(HBaseTestingUtil utility, boolean expectedRejection)
protected final void	verifyThroughRegion(HBaseTestingUtil util, int start, int end)
protected final void	waitUntilDeleted(HBaseTestingUtil util, org.apache.hadoop.fs.Path remoteWAL)
protected final void	waitUntilReplicationDone(HBaseTestingUtil util, int end)
protected final void	write(HBaseTestingUtil util, int start, int end)
protected final void	writeAndVerifyReplication(HBaseTestingUtil util1, HBaseTestingUtil util2, int start, int end)

Methods inherited from class java.lang.Object

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

Field Details

ZK_UTIL

protected static final HBaseZKTestingUtil ZK_UTIL

UTIL1

protected static final HBaseTestingUtil UTIL1

UTIL2

protected static final HBaseTestingUtil UTIL2

TABLE_NAME

protected static org.apache.hadoop.hbase.TableName TABLE_NAME

CF

protected static byte[] CF

CQ

protected static byte[] CQ

PEER_ID

protected static String PEER_ID

REMOTE_WAL_DIR1

protected static org.apache.hadoop.fs.Path REMOTE_WAL_DIR1

REMOTE_WAL_DIR2

protected static org.apache.hadoop.fs.Path REMOTE_WAL_DIR2

Constructor Details

SyncReplicationTestBase

public SyncReplicationTestBase()

Method Details

initTestingUtility

protected static void initTestingUtility(HBaseTestingUtil util,
 String zkParent)

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

shutdown

private static void shutdown(HBaseTestingUtil util)
                      throws Exception

Throws:

Exception

tearDown

public static void tearDown()
                     throws Exception

Throws:

Exception

write

protected final void write(HBaseTestingUtil util,
 int start,
 int end)
                    throws IOException

Throws:

IOException

verify

protected final void verify(HBaseTestingUtil util,
 int start,
 int end)
                     throws IOException

Throws:

IOException

verifyThroughRegion

protected final void verifyThroughRegion(HBaseTestingUtil util,
 int start,
 int end)
                                  throws IOException

Throws:

IOException

verifyNotReplicatedThroughRegion

protected final void verifyNotReplicatedThroughRegion(HBaseTestingUtil util,
 int start,
 int end)
                                               throws IOException

Throws:

IOException

waitUntilReplicationDone

protected final void waitUntilReplicationDone(HBaseTestingUtil util,
 int end)
                                       throws Exception

Throws:

Exception

writeAndVerifyReplication

protected final void writeAndVerifyReplication(HBaseTestingUtil util1,
 HBaseTestingUtil util2,
 int start,
 int end)
                                        throws Exception

Throws:

Exception

getRemoteWALDir

protected final org.apache.hadoop.fs.Path getRemoteWALDir(org.apache.hadoop.hbase.master.MasterFileSystem mfs,
 String peerId)

getRemoteWALDir

protected final org.apache.hadoop.fs.Path getRemoteWALDir(org.apache.hadoop.fs.Path remoteWALDir,
 String peerId)

getReplayRemoteWALs

protected final org.apache.hadoop.fs.Path getReplayRemoteWALs(org.apache.hadoop.fs.Path remoteWALDir,
 String peerId)

verifyRemovedPeer

protected final void verifyRemovedPeer(String peerId,
 org.apache.hadoop.fs.Path remoteWALDir,
 HBaseTestingUtil utility)
                                throws Exception

Throws:

Exception

assertRejection

private void assertRejection(Throwable error)

verifyReplicationRequestRejection

protected final void verifyReplicationRequestRejection(HBaseTestingUtil utility,
 boolean expectedRejection)
                                                throws Exception

Throws:

Exception

waitUntilDeleted

protected final void waitUntilDeleted(HBaseTestingUtil util,
 org.apache.hadoop.fs.Path remoteWAL)
                               throws Exception

Throws:

Exception