Package org.apache.hadoop.hbase.regionserver

Class TestReplicateToReplica

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestReplicateToReplica

@Tag("org.apache.hadoop.hbase.testclassification.RegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
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
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
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(org.junit.jupiter.api.TestInfo testInfo)
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

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

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

@BeforeAll
public static void setUpBeforeClass()

tearDownAfterClass

@AfterAll
public static void tearDownAfterClass()

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)
           throws IOException

Throws:

IOException

tearDown

@AfterEach
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

@Test
public void testNormalReplicate()
                         throws IOException

Throws:

IOException

testNormalFlush

@Test
public void testNormalFlush()
                     throws IOException

Throws:

IOException

testErrorBeforeFlushStart

@Test
public void testErrorBeforeFlushStart()
                               throws IOException

Throws:

IOException

testErrorAfterFlushStartBeforeFlushCommit

@Test
public void testErrorAfterFlushStartBeforeFlushCommit()
                                               throws IOException

Throws:

IOException

testCatchUpWithCannotFlush

@Test
public void testCatchUpWithCannotFlush()
                                throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

testCatchUpWithReopen

@Test
public void testCatchUpWithReopen()
                           throws IOException

Throws:

IOException