org.apache.hadoop.hbase.ipc

Class AbstractTestIPC

java.lang.Object

org.apache.hadoop.hbase.ipc.AbstractTestIPC

Direct Known Subclasses:

TestBlockingIPC, TestNettyIPC

public abstract class AbstractTestIPC
extends Object

Some basic ipc tests.

Field Summary

Fields

Modifier and Type	Field and Description
private static org.apache.hadoop.hbase.KeyValue	CELL
private static byte[]	CELL_BYTES
protected static org.apache.hadoop.conf.Configuration	CONF
private static org.slf4j.Logger	LOG
io.opentelemetry.sdk.testing.junit4.OpenTelemetryRule	traceRule

Constructor Summary

Constructors

Constructor and Description
AbstractTestIPC()

Method Summary

Modifier and Type	Method and Description
private void	assertRemoteSpan()
private static org.hamcrest.Matcher<io.opentelemetry.sdk.trace.data.SpanData>	buildIpcClientSpanAttributesMatcher(String packageAndService, String methodName, InetSocketAddress isa)
private static org.hamcrest.Matcher<io.opentelemetry.sdk.trace.data.SpanData>	buildIpcClientSpanMatcher(String packageAndService, String methodName)
private static org.hamcrest.Matcher<io.opentelemetry.sdk.trace.data.SpanData>	buildIpcServerSpanAttributesMatcher(String packageAndService, String methodName)
private static org.hamcrest.Matcher<io.opentelemetry.sdk.trace.data.SpanData>	buildIpcServerSpanMatcher(String packageAndService, String methodName)
private static String	buildIpcSpanName(String packageAndService, String methodName)
protected abstract org.apache.hadoop.hbase.ipc.AbstractRpcClient<?>	createRpcClient(org.apache.hadoop.conf.Configuration conf)
protected abstract org.apache.hadoop.hbase.ipc.AbstractRpcClient<?>	createRpcClientNoCodec(org.apache.hadoop.conf.Configuration conf)
protected abstract org.apache.hadoop.hbase.ipc.AbstractRpcClient<?>	createRpcClientRTEDuringConnectionSetup(org.apache.hadoop.conf.Configuration conf)
protected abstract org.apache.hadoop.hbase.ipc.RpcServer	createRpcServer(org.apache.hadoop.hbase.Server server, String name, List<org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface> services, InetSocketAddress bindAddress, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.ipc.RpcScheduler scheduler)
protected abstract org.apache.hadoop.hbase.ipc.RpcServer	createTestFailingRpcServer(org.apache.hadoop.hbase.Server server, String name, List<org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface> services, InetSocketAddress bindAddress, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.ipc.RpcScheduler scheduler)
void	testAsyncEcho()
void	testAsyncRemoteError()
void	testAsyncTimeout()
void	testCompressCellBlock() It is hard to verify the compression is actually happening under the wraps.
void	testConnectionCloseWithOutstandingRPCs() Tests that the connection closing is handled by the client with outstanding RPC calls
void	testNoCodec() Ensure we do not HAVE TO HAVE a codec.
void	testRemoteError()
void	testRpcMaxRequestSize() Tests that the rpc scheduler is called when requests arrive.
void	testRpcScheduler() Tests that the rpc scheduler is called when requests arrive.
void	testRpcServerForNotNullRemoteAddressInCallObject() Tests that the RpcServer creates & dispatches CallRunner object to scheduler with non-null remoteAddress set to its Call Object
void	testRTEDuringConnectionSetup()
void	testTimeout()
void	testTracingErrorIpc()
void	testTracingSuccessIpc()
private io.opentelemetry.sdk.trace.data.SpanData	waitSpan(org.hamcrest.Matcher<io.opentelemetry.sdk.trace.data.SpanData> matcher)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

CELL_BYTES

private static final byte[] CELL_BYTES

CELL

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

CONF

protected static final org.apache.hadoop.conf.Configuration CONF

traceRule

public io.opentelemetry.sdk.testing.junit4.OpenTelemetryRule traceRule

Constructor Detail

AbstractTestIPC

public AbstractTestIPC()

Method Detail

createRpcServer

protected abstract org.apache.hadoop.hbase.ipc.RpcServer createRpcServer(org.apache.hadoop.hbase.Server server,
                                                                         String name,
                                                                         List<org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface> services,
                                                                         InetSocketAddress bindAddress,
                                                                         org.apache.hadoop.conf.Configuration conf,
                                                                         org.apache.hadoop.hbase.ipc.RpcScheduler scheduler)
                                                                  throws IOException

Throws:

IOException

createRpcClientNoCodec

protected abstract org.apache.hadoop.hbase.ipc.AbstractRpcClient<?> createRpcClientNoCodec(org.apache.hadoop.conf.Configuration conf)

testNoCodec

public void testNoCodec()
                 throws IOException,
                        org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Ensure we do not HAVE TO HAVE a codec.

Throws:

IOException

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

createRpcClient

protected abstract org.apache.hadoop.hbase.ipc.AbstractRpcClient<?> createRpcClient(org.apache.hadoop.conf.Configuration conf)

testCompressCellBlock

public void testCompressCellBlock()
                           throws IOException,
                                  org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

It is hard to verify the compression is actually happening under the wraps. Hope that if unsupported, we'll get an exception out of some time (meantime, have to trace it manually to confirm that compression is happening down in the client and server).

Throws:

IOException

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

createRpcClientRTEDuringConnectionSetup

protected abstract org.apache.hadoop.hbase.ipc.AbstractRpcClient<?> createRpcClientRTEDuringConnectionSetup(org.apache.hadoop.conf.Configuration conf)
                                                                                                     throws IOException

Throws:

IOException

testRTEDuringConnectionSetup

public void testRTEDuringConnectionSetup()
                                  throws Exception

Throws:

Exception

testRpcScheduler

public void testRpcScheduler()
                      throws IOException,
                             org.apache.hbase.thirdparty.com.google.protobuf.ServiceException,
                             InterruptedException

Tests that the rpc scheduler is called when requests arrive.

Throws:

IOException

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

InterruptedException

testRpcMaxRequestSize

public void testRpcMaxRequestSize()
                           throws IOException,
                                  org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Tests that the rpc scheduler is called when requests arrive.

Throws:

IOException

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

testRpcServerForNotNullRemoteAddressInCallObject

public void testRpcServerForNotNullRemoteAddressInCallObject()
                                                      throws IOException,
                                                             org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Tests that the RpcServer creates & dispatches CallRunner object to scheduler with non-null remoteAddress set to its Call Object

Throws:

IOException

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

testRemoteError

public void testRemoteError()
                     throws IOException,
                            org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Throws:

IOException

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

testTimeout

public void testTimeout()
                 throws IOException

Throws:

IOException

createTestFailingRpcServer

protected abstract org.apache.hadoop.hbase.ipc.RpcServer createTestFailingRpcServer(org.apache.hadoop.hbase.Server server,
                                                                                    String name,
                                                                                    List<org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface> services,
                                                                                    InetSocketAddress bindAddress,
                                                                                    org.apache.hadoop.conf.Configuration conf,
                                                                                    org.apache.hadoop.hbase.ipc.RpcScheduler scheduler)
                                                                             throws IOException

Throws:

IOException

testConnectionCloseWithOutstandingRPCs

public void testConnectionCloseWithOutstandingRPCs()
                                            throws InterruptedException,
                                                   IOException

Tests that the connection closing is handled by the client with outstanding RPC calls

Throws:

InterruptedException

IOException

testAsyncEcho

public void testAsyncEcho()
                   throws IOException

Throws:

IOException

testAsyncRemoteError

public void testAsyncRemoteError()
                          throws IOException

Throws:

IOException

testAsyncTimeout

public void testAsyncTimeout()
                      throws IOException

Throws:

IOException

waitSpan

private io.opentelemetry.sdk.trace.data.SpanData waitSpan(org.hamcrest.Matcher<io.opentelemetry.sdk.trace.data.SpanData> matcher)

buildIpcSpanName

private static String buildIpcSpanName(String packageAndService,
                                       String methodName)

buildIpcClientSpanMatcher

private static org.hamcrest.Matcher<io.opentelemetry.sdk.trace.data.SpanData> buildIpcClientSpanMatcher(String packageAndService,
                                                                                                        String methodName)

buildIpcServerSpanMatcher

private static org.hamcrest.Matcher<io.opentelemetry.sdk.trace.data.SpanData> buildIpcServerSpanMatcher(String packageAndService,
                                                                                                        String methodName)

buildIpcClientSpanAttributesMatcher

private static org.hamcrest.Matcher<io.opentelemetry.sdk.trace.data.SpanData> buildIpcClientSpanAttributesMatcher(String packageAndService,
                                                                                                                  String methodName,
                                                                                                                  InetSocketAddress isa)

buildIpcServerSpanAttributesMatcher

private static org.hamcrest.Matcher<io.opentelemetry.sdk.trace.data.SpanData> buildIpcServerSpanAttributesMatcher(String packageAndService,
                                                                                                                  String methodName)

assertRemoteSpan

private void assertRemoteSpan()

testTracingSuccessIpc

public void testTracingSuccessIpc()
                           throws IOException,
                                  org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Throws:

IOException

org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

testTracingErrorIpc

public void testTracingErrorIpc()
                         throws IOException

Throws:

IOException