Package org.apache.hadoop.hbase.regionserver

Class TestReplicateToReplica

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestReplicateToReplica

public class TestReplicateToReplica
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TestReplicateToReplica.HRegionForTest

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.hbase.client.AsyncClusterConnection	conn
private static org.apache.hadoop.hbase.executor.ExecutorService	EXEC
private static byte[]	FAMILY
private org.apache.hadoop.hbase.regionserver.FlushRequester	flushRequester
private org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationBufferManager	manager
final TableNameTestRule	name
private org.apache.hadoop.hbase.regionserver.HRegion	primary
private static byte[]	QUAL
private boolean	queueReqAndResps
private Queue<org.apache.hadoop.hbase.util.Pair<List<org.apache.hadoop.hbase.wal.WAL.Entry>,CompletableFuture<Void>>>	reqAndResps
private org.apache.hadoop.hbase.regionserver.RegionServerServices	rss
private org.apache.hadoop.hbase.regionserver.HRegion	secondary
private org.apache.hadoop.hbase.TableName	tableName
private org.apache.hadoop.hbase.client.TableDescriptor	td
private org.apache.hadoop.fs.Path	testDir
private static List<org.apache.hadoop.hbase.client.Put>	TO_ADD_AFTER_PREPARE_FLUSH
private static final HBaseTestingUtil	UTIL
private org.apache.hadoop.hbase.wal.WALFactory	walFactory

Constructor Summary

Constructors

Constructor	Description
TestReplicateToReplica()

Method Summary

Modifier and Type	Method	Description
private void	failAll()
private void	failOne()
private org.apache.hadoop.hbase.regionserver.HRegion.FlushResult	flushPrimary()
private void	replicate(org.apache.hadoop.hbase.util.Pair<List<org.apache.hadoop.hbase.wal.WAL.Entry>,CompletableFuture<Void>> pair)
private void	replicateAll()
private void	replicateOne()
void	setUp()
static void	setUpBeforeClass()
void	tearDown()
static void	tearDownAfterClass()
void	testCatchUpWithCannotFlush()
void	testCatchUpWithReopen()
void	testErrorAfterFlushStartBeforeFlushCommit()
void	testErrorBeforeFlushStart()
void	testNormalFlush()
void	testNormalReplicate()

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

UTIL

private static final HBaseTestingUtil UTIL

FAMILY

private static byte[] FAMILY

QUAL

private static byte[] QUAL

EXEC

private static org.apache.hadoop.hbase.executor.ExecutorService EXEC

name

public final TableNameTestRule name

tableName

private org.apache.hadoop.hbase.TableName tableName

testDir

private org.apache.hadoop.fs.Path testDir

td

private org.apache.hadoop.hbase.client.TableDescriptor td

rss

private org.apache.hadoop.hbase.regionserver.RegionServerServices rss

conn

private org.apache.hadoop.hbase.client.AsyncClusterConnection conn

manager

private org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationBufferManager manager

flushRequester

private org.apache.hadoop.hbase.regionserver.FlushRequester flushRequester

primary

private org.apache.hadoop.hbase.regionserver.HRegion primary

secondary

private org.apache.hadoop.hbase.regionserver.HRegion secondary

walFactory

private org.apache.hadoop.hbase.wal.WALFactory walFactory

queueReqAndResps

private boolean queueReqAndResps

reqAndResps

private Queue<org.apache.hadoop.hbase.util.Pair<List<org.apache.hadoop.hbase.wal.WAL.Entry>,CompletableFuture<Void>>> reqAndResps

TO_ADD_AFTER_PREPARE_FLUSH

private static List<org.apache.hadoop.hbase.client.Put> TO_ADD_AFTER_PREPARE_FLUSH

Constructor Details

TestReplicateToReplica

public TestReplicateToReplica()

Method Details

setUpBeforeClass

public static void setUpBeforeClass()

tearDownAfterClass

public static void tearDownAfterClass()

setUp

public void setUp()
           throws IOException

Throws:

IOException

tearDown

public void tearDown()
              throws IOException

Throws:

IOException

flushPrimary

private org.apache.hadoop.hbase.regionserver.HRegion.FlushResult flushPrimary()
                                                                       throws IOException

Throws:

IOException

replicate

private void replicate(org.apache.hadoop.hbase.util.Pair<List<org.apache.hadoop.hbase.wal.WAL.Entry>,CompletableFuture<Void>> pair)
                throws IOException

Throws:

IOException

replicateOne

private void replicateOne()
                   throws IOException

Throws:

IOException

replicateAll

private void replicateAll()
                   throws IOException

Throws:

IOException

failOne

private void failOne()

failAll

private void failAll()

testNormalReplicate

public void testNormalReplicate()
                         throws IOException

Throws:

IOException

testNormalFlush

public void testNormalFlush()
                     throws IOException

Throws:

IOException

testErrorBeforeFlushStart

public void testErrorBeforeFlushStart()
                               throws IOException

Throws:

IOException

testErrorAfterFlushStartBeforeFlushCommit

public void testErrorAfterFlushStartBeforeFlushCommit()
                                               throws IOException

Throws:

IOException

testCatchUpWithCannotFlush

public void testCatchUpWithCannotFlush()
                                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testCatchUpWithReopen

public void testCatchUpWithReopen()
                           throws IOException

Throws:

IOException