Package org.apache.hadoop.hbase.regionserver.regionreplication

Class TestRegionReplicationSinkCallbackAndFlushConcurrently

java.lang.Object

org.apache.hadoop.hbase.regionserver.regionreplication.TestRegionReplicationSinkCallbackAndFlushConcurrently

@Tag("org.apache.hadoop.hbase.testclassification.RegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.LargeTests")
public class TestRegionReplicationSinkCallbackAndFlushConcurrently
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TestRegionReplicationSinkCallbackAndFlushConcurrently.ErrorReplayRSRpcServices
static final class	TestRegionReplicationSinkCallbackAndFlushConcurrently.HRegionForTest
static final class	TestRegionReplicationSinkCallbackAndFlushConcurrently.RSForTest

Field Summary

Fields

Modifier and Type	Field	Description
private static final byte[]	FAMILY
private static final HBaseTestingUtil	HTU
private static final int	NB_SERVERS
private static final byte[]	QUAL
private static boolean	startTest
private static org.apache.hadoop.hbase.TableName	tableName

Constructor Summary

Constructors

Constructor	Description
TestRegionReplicationSinkCallbackAndFlushConcurrently()

Method Summary

Modifier and Type	Method	Description
private TestRegionReplicationSinkCallbackAndFlushConcurrently.HRegionForTest[]	createTable()
static void	setUp()
private org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationSink	setUpSpiedRegionReplicationSink(org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationSink regionReplicationSink, TestRegionReplicationSinkCallbackAndFlushConcurrently.HRegionForTest primaryRegion, AtomicBoolean completedRef)
static void	tearDown()
void	test()	This test is for HBASE-26768,test the case that we have already clear the RegionReplicationSink.failedReplicas due to a flush all edit,which may in flusher thread,and then in the callback of replay, which may in Netty nioEventLoop,we add a replica to the RegionReplicationSink.failedReplicas because of a failure of replicating.

Methods inherited from class java.lang.Object

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

Field Details

FAMILY

private static final byte[] FAMILY

QUAL

private static final byte[] QUAL

HTU

private static final HBaseTestingUtil HTU

NB_SERVERS

private static final int NB_SERVERS

See Also:

• Constant Field Values

tableName

private static org.apache.hadoop.hbase.TableName tableName

startTest

private static volatile boolean startTest

Constructor Details

TestRegionReplicationSinkCallbackAndFlushConcurrently

public TestRegionReplicationSinkCallbackAndFlushConcurrently()

Method Details

setUp

@BeforeAll
public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

@AfterAll
public static void tearDown()
                     throws Exception

Throws:

Exception

test

@Test
public void test()
          throws Exception

This test is for HBASE-26768,test the case that we have already clear the RegionReplicationSink.failedReplicas due to a flush all edit,which may in flusher thread,and then in the callback of replay, which may in Netty nioEventLoop,we add a replica to the RegionReplicationSink.failedReplicas because of a failure of replicating.

Throws:

Exception

setUpSpiedRegionReplicationSink

private org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationSink setUpSpiedRegionReplicationSink(org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationSink regionReplicationSink,
 TestRegionReplicationSinkCallbackAndFlushConcurrently.HRegionForTest primaryRegion,
 AtomicBoolean completedRef)

createTable

private TestRegionReplicationSinkCallbackAndFlushConcurrently.HRegionForTest[] createTable()
                                                                                    throws Exception

Throws:

Exception