Package org.apache.hadoop.hbase.ipc

Class TestNettyChannelWritability

java.lang.Object

org.apache.hadoop.hbase.ipc.TestNettyChannelWritability

@Tag("org.apache.hadoop.hbase.testclassification.RPCTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
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
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

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

@Test
public void testNettyWritableWatermarks()
                                 throws Exception

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

Throws:

Exception

testNettyWritableFatalThreshold

@Test
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