Package org.apache.hadoop.hbase.io.hfile

Class TestHFileBlockHeaderCorruption

java.lang.Object

org.apache.hadoop.hbase.io.hfile.TestHFileBlockHeaderCorruption

@Tag("org.apache.hadoop.hbase.testclassification.IOTests") @Tag("org.apache.hadoop.hbase.testclassification.SmallTests")
public class TestHFileBlockHeaderCorruption
extends Object

This test provides coverage for HFileHeader block fields that are read and interpreted before HBase checksum validation can be applied. As of now, this is just onDiskSizeWithoutHeader.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestHFileBlockHeaderCorruption.Corrupter	Enables writing and rewriting portions of the file backing an HFileBlock.
static class	TestHFileBlockHeaderCorruption.CountingConsumer	Reads blocks off of an TestHFileBlockHeaderCorruption.HFileBlockChannelPositionIterator, counting them as it does.
static class	TestHFileBlockHeaderCorruption.HFileBlockChannelPosition	Data class to enabled messing with the bytes behind an HFileBlock.
static class	TestHFileBlockHeaderCorruption.HFileBlockChannelPositionIterator	A simplified wrapper over an HFileBlock.BlockIterator that looks a lot like an Iterator.
private static final class	TestHFileBlockHeaderCorruption.IsThrowableMatching	A Matcher implementation that can make basic assertions over a provided Throwable.

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.hbase.io.hfile.HFileContext	hfileCtx
private static org.apache.hadoop.hbase.fs.HFileSystem	HFS
private static final org.slf4j.Logger	LOG
private org.apache.hadoop.fs.Path	path
private static final HBaseTestingUtil	UTIL

Constructor Summary

Constructors

Constructor	Description
TestHFileBlockHeaderCorruption()

Method Summary

Modifier and Type	Method	Description
private static void	logHeader(TestHFileBlockHeaderCorruption.HFileBlockChannelPosition hbcp)
private static void	logHeader(org.apache.hadoop.hbase.nio.ByteBuff buf)
void	setUp(org.junit.jupiter.api.TestInfo testInfo)
static void	setUpBeforeAll()
void	testChecksumTypeCorruptionFirstBlock()
void	testChecksumTypeCorruptionSecondBlock()
void	testOnDiskSizeWithoutHeaderCorruptionFirstBlock()
void	testOnDiskSizeWithoutHeaderCorruptionSecondBlock()
void	testValidChecksumTypeReadBlock(byte checksumTypeCode, TestHFileBlockHeaderCorruption.Corrupter c, TestHFileBlockHeaderCorruption.HFileBlockChannelPosition testBlock)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

UTIL

private static final HBaseTestingUtil UTIL

HFS

private static org.apache.hadoop.hbase.fs.HFileSystem HFS

hfileCtx

private org.apache.hadoop.hbase.io.hfile.HFileContext hfileCtx

path

private org.apache.hadoop.fs.Path path

Constructor Details

TestHFileBlockHeaderCorruption

public TestHFileBlockHeaderCorruption()

Method Details

setUpBeforeAll

@BeforeAll
public static void setUpBeforeAll()
                           throws IOException

Throws:

IOException

setUp

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

Throws:

IOException

testChecksumTypeCorruptionFirstBlock

@Test
public void testChecksumTypeCorruptionFirstBlock()
                                          throws Exception

Throws:

Exception

testChecksumTypeCorruptionSecondBlock

@Test
public void testChecksumTypeCorruptionSecondBlock()
                                           throws Exception

Throws:

Exception

testValidChecksumTypeReadBlock

public void testValidChecksumTypeReadBlock(byte checksumTypeCode,
 TestHFileBlockHeaderCorruption.Corrupter c,
 TestHFileBlockHeaderCorruption.HFileBlockChannelPosition testBlock)
                                    throws IOException

Throws:

IOException

testOnDiskSizeWithoutHeaderCorruptionFirstBlock

@Test
public void testOnDiskSizeWithoutHeaderCorruptionFirstBlock()
                                                     throws Exception

Throws:

Exception

testOnDiskSizeWithoutHeaderCorruptionSecondBlock

@Test
public void testOnDiskSizeWithoutHeaderCorruptionSecondBlock()
                                                      throws Exception

Throws:

Exception

logHeader

private static void logHeader(TestHFileBlockHeaderCorruption.HFileBlockChannelPosition hbcp)
                       throws IOException

Throws:

IOException

logHeader

private static void logHeader(org.apache.hadoop.hbase.nio.ByteBuff buf)