public class TestNettyChannelWritability extends Object
Modifier and Type | Field and Description |
---|---|
private static org.apache.hadoop.hbase.KeyValue |
CELL |
private static byte[] |
CELL_BYTES |
static HBaseClassTestRule |
CLASS_RULE |
private static MetricsAssertHelper |
METRICS_ASSERT |
Constructor and Description |
---|
TestNettyChannelWritability() |
Modifier and Type | Method and 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.Cell> 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.
|
public static final HBaseClassTestRule CLASS_RULE
private static final MetricsAssertHelper METRICS_ASSERT
private static final byte[] CELL_BYTES
private static final org.apache.hadoop.hbase.KeyValue CELL
public TestNettyChannelWritability()
public void testNettyWritableWatermarks() throws Exception
Exception
public void testNettyWritableFatalThreshold() throws Exception
Exception
private void sendAndReceive(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.ipc.NettyRpcServer rpcServer, int requestCount) throws Exception
Exception
private void sendMessage(List<org.apache.hadoop.hbase.Cell> cells, org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface stub) throws Exception
Exception
private org.apache.hadoop.hbase.ipc.NettyRpcServer createRpcServer(org.apache.hadoop.conf.Configuration conf, int flushAfter) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.