Package org.apache.hadoop.hbase.ipc

Class AbstractTestIPC

java.lang.Object

org.apache.hadoop.hbase.ipc.AbstractTestIPC

Direct Known Subclasses:

TestBlockingIPC, TestNettyIPC, TestNettyTlsIPC

public abstract class AbstractTestIPC
extends Object

Some basic ipc tests.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	AbstractTestIPC.FailingSimpleRpcServer

Field Summary

Fields

Modifier and Type	Field	Description
private static final org.apache.hadoop.hbase.KeyValue	CELL
private static final byte[]	CELL_BYTES
protected static final org.apache.hadoop.conf.Configuration	CONF
private static final org.slf4j.Logger	LOG
Class<? extends org.apache.hadoop.hbase.ipc.RpcServer>	rpcServerImpl
io.opentelemetry.sdk.testing.junit4.OpenTelemetryRule	traceRule

Constructor Summary

Constructors

Constructor	Description
AbstractTestIPC()

Method Summary

Modifier and Type	Method	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<?>	createBadAuthRpcClient(org.apache.hadoop.conf.Configuration conf)
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)
private org.apache.hadoop.hbase.ipc.RpcServer	createRpcServer(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 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 org.apache.hadoop.hbase.ipc.RpcServer	createTestFailingRpcServer(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)
private IOException	doBadPreableHeaderCall(org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface stub)
void	setUpBeforeTest()
void	testAsyncEcho()
void	testAsyncRemoteError()
void	testAsyncTimeout()
void	testBadPreambleHeader()
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	testGetConnectionRegistry()	Testcase for getting connection registry information through connection preamble header, see HBASE-25051 for more details.
void	testGetConnectionRegistryError()	Test server does not support getting connection registry information through connection preamble header, i.e, a new client connecting to an old server.
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 Details

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

rpcServerImpl

public Class<? extends org.apache.hadoop.hbase.ipc.RpcServer> rpcServerImpl

Constructor Details

AbstractTestIPC

public AbstractTestIPC()

Method Details

createRpcServer

protected 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

createRpcServer

private org.apache.hadoop.hbase.ipc.RpcServer createRpcServer(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)

setUpBeforeTest

public void setUpBeforeTest()

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 org.apache.hadoop.hbase.ipc.RpcServer createTestFailingRpcServer(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

createBadAuthRpcClient

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

doBadPreableHeaderCall

private IOException doBadPreableHeaderCall(org.apache.hadoop.hbase.shaded.ipc.protobuf.generated.TestRpcServiceProtos.TestProtobufRpcProto.BlockingInterface stub)

testBadPreambleHeader

public void testBadPreambleHeader()
                           throws Exception

Throws:

Exception

testGetConnectionRegistry

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

Testcase for getting connection registry information through connection preamble header, see HBASE-25051 for more details.

Throws:

IOException

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

testGetConnectionRegistryError

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

Test server does not support getting connection registry information through connection preamble header, i.e, a new client connecting to an old server. We simulate this by using a Server without implementing the ConnectionRegistryEndpoint interface.

Throws:

IOException

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