Package org.apache.hadoop.hbase.ipc

Class TestNettyChannelWritability

java.lang.Object

org.apache.hadoop.hbase.ipc.TestNettyChannelWritability

public class TestNettyChannelWritability
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.apache.hadoop.hbase.KeyValue	CELL
private static final byte[]	CELL_BYTES
static final HBaseClassTestRule	CLASS_RULE
private static final MetricsAssertHelper	METRICS_ASSERT

Constructor Summary

Constructors

Constructor	Description
TestNettyChannelWritability()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.ipc.NettyRpcServer	createRpcServer(org.apache.hadoop.conf.Configuration conf, int flushAfter)
private void	sendAndReceive(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.ipc.NettyRpcServer rpcServer, int requestCount)
private void	sendMessage(List<org.apache.hadoop.hbase.ExtendedCell> cells, org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface stub)
void	testNettyWritableFatalThreshold()	Test that our fatal watermark is honored, which requires artificially causing some queueing so that pendingOutboundBytes increases.
void	testNettyWritableWatermarks()	Test that we properly send configured watermarks to netty, and trigger setWritable when necessary.

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

METRICS_ASSERT

private static final MetricsAssertHelper METRICS_ASSERT

CELL_BYTES

private static final byte[] CELL_BYTES

CELL

private static final org.apache.hadoop.hbase.KeyValue CELL

Constructor Details

TestNettyChannelWritability

public TestNettyChannelWritability()

Method Details

testNettyWritableWatermarks

public void testNettyWritableWatermarks()
                                 throws Exception

Test that we properly send configured watermarks to netty, and trigger setWritable when necessary.

Throws:

Exception

testNettyWritableFatalThreshold

public void testNettyWritableFatalThreshold()
                                     throws Exception

Test that our fatal watermark is honored, which requires artificially causing some queueing so that pendingOutboundBytes increases.

Throws:

Exception

sendAndReceive

private void sendAndReceive(org.apache.hadoop.conf.Configuration conf,
 org.apache.hadoop.hbase.ipc.NettyRpcServer rpcServer,
 int requestCount)
                     throws Exception

Throws:

Exception

sendMessage

private void sendMessage(List<org.apache.hadoop.hbase.ExtendedCell> cells,
 org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface stub)
                  throws Exception

Throws:

Exception

createRpcServer

private org.apache.hadoop.hbase.ipc.NettyRpcServer createRpcServer(org.apache.hadoop.conf.Configuration conf,
 int flushAfter)
                                                            throws IOException

Throws:

IOException