Package org.apache.hadoop.hbase.io.asyncfs

Class TestLeaseRenewal

java.lang.Object

org.apache.hadoop.hbase.io.asyncfs.AsyncFSTestBase

org.apache.hadoop.hbase.io.asyncfs.TestLeaseRenewal

@Tag("org.apache.hadoop.hbase.testclassification.MiscTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestLeaseRenewal
extends AsyncFSTestBase

Make sure lease renewal works. Since it is in a background thread, normal read/write test can not verify it.

See HBASE-28955 for more details.

Field Summary

Fields

Modifier and Type	Field	Description
private static Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel>	CHANNEL_CLASS
private static org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup	EVENT_LOOP_GROUP
private static org.apache.hadoop.hdfs.DistributedFileSystem	FS
private static org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor	MONITOR

Fields inherited from class org.apache.hadoop.hbase.io.asyncfs.AsyncFSTestBase

CLUSTER, CLUSTER_TEST_DIR, UTIL

Constructor Summary

Constructors

Constructor	Description
TestLeaseRenewal()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.io.asyncfs.FanOutOneBlockAsyncDFSOutput	create(String file)
private Optional<Method>	getUniqKeyMethod()
static void	setUp()
static void	tearDown()
void	testEnsureMethodsCalledWhenAborting()
void	testEnsureMethodsCalledWhenClosing()
void	testEnsureMethodsCalledWhenLeaseRenewal()
void	testLeaseRenew()
private void	verifyGetUniqKey(org.apache.hadoop.hdfs.DummyDFSOutputStream dummy)

Methods inherited from class org.apache.hadoop.hbase.io.asyncfs.AsyncFSTestBase

setupClusterTestDir, shutdownMiniDFSCluster, startMiniDFSCluster

Methods inherited from class java.lang.Object

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

Field Details

FS

private static org.apache.hadoop.hdfs.DistributedFileSystem FS

EVENT_LOOP_GROUP

private static org.apache.hbase.thirdparty.io.netty.channel.EventLoopGroup EVENT_LOOP_GROUP

CHANNEL_CLASS

private static Class<? extends org.apache.hbase.thirdparty.io.netty.channel.Channel> CHANNEL_CLASS

MONITOR

private static org.apache.hadoop.hbase.io.asyncfs.monitor.StreamSlowMonitor MONITOR

Constructor Details

TestLeaseRenewal

public TestLeaseRenewal()

Method Details

setUp

@BeforeAll
public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

@AfterAll
public static void tearDown()
                     throws Exception

Throws:

Exception

create

private org.apache.hadoop.hbase.io.asyncfs.FanOutOneBlockAsyncDFSOutput create(String file)
                                                                        throws IllegalArgumentException,
IOException

Throws:

IllegalArgumentException

IOException

testLeaseRenew

@Test
public void testLeaseRenew()
                    throws IOException

Throws:

IOException

getUniqKeyMethod

private Optional<Method> getUniqKeyMethod()

testEnsureMethodsCalledWhenLeaseRenewal

@Test
public void testEnsureMethodsCalledWhenLeaseRenewal()
                                             throws Exception

Throws:

Exception

verifyGetUniqKey

private void verifyGetUniqKey(org.apache.hadoop.hdfs.DummyDFSOutputStream dummy)
                       throws Exception

Throws:

Exception

testEnsureMethodsCalledWhenClosing

@Test
public void testEnsureMethodsCalledWhenClosing()
                                        throws Exception

Throws:

Exception

testEnsureMethodsCalledWhenAborting

@Test
public void testEnsureMethodsCalledWhenAborting()
                                         throws Exception

Throws:

Exception