org.apache.hadoop.hbase.ipc

Class AbstractTestIPC

java.lang.Object

org.apache.hadoop.hbase.ipc.AbstractTestIPC

Direct Known Subclasses:

TestAsyncIPC, TestIPC

public abstract class AbstractTestIPC
extends Object

Some basic ipc tests.

Constructor Summary

Constructors

Constructor and Description
AbstractTestIPC()

Method Summary

Modifier and Type	Method and Description
protected abstract AbstractRpcClient	createRpcClient(Configuration conf)
protected abstract AbstractRpcClient	createRpcClientNoCodec(Configuration conf)
protected abstract AbstractRpcClient	createRpcClientRTEDuringConnectionSetup(Configuration conf)
void	testCompressCellBlock() It is hard to verify the compression is actually happening under the wraps.
void	testNoCodec() Ensure we do not HAVE TO HAVE a codec.
void	testRpcScheduler() Tests that the rpc scheduler is called when requests arrive.
void	testRTEDuringConnectionSetup()

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractTestIPC

public AbstractTestIPC()

Method Detail

createRpcClientNoCodec

protected abstract AbstractRpcClient createRpcClientNoCodec(Configuration conf)

testNoCodec

public void testNoCodec()
                 throws InterruptedException,
                        IOException

Ensure we do not HAVE TO HAVE a codec.

Throws:

InterruptedException

IOException

createRpcClient

protected abstract AbstractRpcClient createRpcClient(Configuration conf)

testCompressCellBlock

public void testCompressCellBlock()
                           throws IOException,
                                  InterruptedException,
                                  SecurityException,
                                  NoSuchMethodException,
                                  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

InterruptedException

SecurityException

NoSuchMethodException

ServiceException

createRpcClientRTEDuringConnectionSetup

protected abstract AbstractRpcClient createRpcClientRTEDuringConnectionSetup(Configuration conf)
                                                                      throws IOException

Throws:

IOException

testRTEDuringConnectionSetup

public void testRTEDuringConnectionSetup()
                                  throws Exception

Throws:

Exception

testRpcScheduler

public void testRpcScheduler()
                      throws IOException,
                             InterruptedException

Tests that the rpc scheduler is called when requests arrive.

Throws:

IOException

InterruptedException