org.apache.hadoop.hbase.util

Class TestByteBufferUtils

java.lang.Object

org.apache.hadoop.hbase.util.TestByteBufferUtils

public class TestByteBufferUtils
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private byte[]	array
static HBaseClassTestRule	CLASS_RULE
private static int	MAX_VLONG_LENGTH
private static Collection<Long>	testNumbers
private static String	UNSAFE_AVAIL_NAME
private static String	UNSAFE_UNALIGNED_NAME

Constructor Summary

Constructors

Constructor and Description
TestByteBufferUtils(boolean useUnsafeIfPossible)

Method Summary

Modifier and Type	Method and Description
private static void	addNumber(Set<Long> a, long l)
static void	afterClass()
(package private) static void	detectAvailabilityOfUnsafe()
(package private) static void	disableUnsafe()
private static void	fillArray(byte[] bb, byte b)
private static void	fillBB(ByteBuffer bb, byte b)
static Collection<Object[]>	parameters()
private static void	setUnsafe(String fieldName, boolean value)
void	setUp() Create an array with sample data.
void	testArePartEqual() Test if we are comparing equal bytes.
void	testCompareTo()
void	testCompressedInt() Test 7-bit encoding of integers.
private void	testCompressedInt(int value)
void	testConsistencyWithHadoopVLong()
void	testCopyFromArrayToBuffer()
void	testCopyFromBuffer() Test copying from buffer.
void	testCopyFromBufferToArray()
void	testCopyFromSrcToDestWithThreads()
private void	testCopyFromSrcToDestWithThreads(Object input, Object output, List<Integer> lengthes, List<Integer> offsets)
void	testCopyFromStream() Test copying data from stream.
void	testCopyToStreamWithOffset() Test copying to stream from buffer with offset.
void	testEquals()
void	testIntFitsIn() Test how much bytes we need to store integer.
void	testLongFitsIn() Test how much bytes we need to store long.
void	testMoveBufferToStream() Test copying to stream from buffer.
void	testPutInt() Test serializing int to bytes
private void	testPutInt(int value)
void	testReadWriteVLong()
void	testRelativeCopyFromBuffertoBuffer()
void	testToBytes()
void	testToPrimitiveTypes()

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

UNSAFE_AVAIL_NAME

private static final String UNSAFE_AVAIL_NAME

See Also:

Constant Field Values

UNSAFE_UNALIGNED_NAME

private static final String UNSAFE_UNALIGNED_NAME

See Also:

Constant Field Values

array

private byte[] array

MAX_VLONG_LENGTH

private static final int MAX_VLONG_LENGTH

See Also:

Constant Field Values

testNumbers

private static final Collection<Long> testNumbers

Constructor Detail

TestByteBufferUtils

public TestByteBufferUtils(boolean useUnsafeIfPossible)
                    throws Exception

Throws:

Exception

Method Detail

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

parameters

public static Collection<Object[]> parameters()

setUnsafe

private static void setUnsafe(String fieldName,
                              boolean value)
                       throws Exception

Throws:

Exception

disableUnsafe

static void disableUnsafe()
                   throws Exception

Throws:

Exception

detectAvailabilityOfUnsafe

static void detectAvailabilityOfUnsafe()
                                throws Exception

Throws:

Exception

setUp

public void setUp()

Create an array with sample data.

addNumber

private static void addNumber(Set<Long> a,
                              long l)

testReadWriteVLong

public void testReadWriteVLong()

testConsistencyWithHadoopVLong

public void testConsistencyWithHadoopVLong()
                                    throws IOException

Throws:

IOException

testMoveBufferToStream

public void testMoveBufferToStream()

Test copying to stream from buffer.

testCopyToStreamWithOffset

public void testCopyToStreamWithOffset()
                                throws IOException

Test copying to stream from buffer with offset.

Throws:

IOException - On test failure.

testCopyFromStream

public void testCopyFromStream()
                        throws IOException

Test copying data from stream.

Throws:

IOException - On test failure.

testCopyFromBuffer

public void testCopyFromBuffer()

Test copying from buffer.

testCompressedInt

public void testCompressedInt()
                       throws IOException

Test 7-bit encoding of integers.

Throws:

IOException - On test failure.

testIntFitsIn

public void testIntFitsIn()

Test how much bytes we need to store integer.

testLongFitsIn

public void testLongFitsIn()

Test how much bytes we need to store long.

testArePartEqual

public void testArePartEqual()

Test if we are comparing equal bytes.

testPutInt

public void testPutInt()

Test serializing int to bytes

testCompressedInt

private void testCompressedInt(int value)
                        throws IOException

Throws:

IOException

testPutInt

private void testPutInt(int value)

testToBytes

public void testToBytes()

testToPrimitiveTypes

public void testToPrimitiveTypes()

testCopyFromArrayToBuffer

public void testCopyFromArrayToBuffer()

testCopyFromSrcToDestWithThreads

private void testCopyFromSrcToDestWithThreads(Object input,
                                              Object output,
                                              List<Integer> lengthes,
                                              List<Integer> offsets)
                                       throws InterruptedException

Throws:

InterruptedException

testCopyFromSrcToDestWithThreads

public void testCopyFromSrcToDestWithThreads()
                                      throws InterruptedException

Throws:

InterruptedException

testCopyFromBufferToArray

public void testCopyFromBufferToArray()

testRelativeCopyFromBuffertoBuffer

public void testRelativeCopyFromBuffertoBuffer()

testCompareTo

public void testCompareTo()

testEquals

public void testEquals()

fillBB

private static void fillBB(ByteBuffer bb,
                           byte b)

fillArray

private static void fillArray(byte[] bb,
                              byte b)