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 java.lang.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 java.lang.InterruptedException,
                        java.io.IOException

Ensure we do not HAVE TO HAVE a codec.

Throws:

java.lang.InterruptedException

java.io.IOException

createRpcClient

protected abstract AbstractRpcClient createRpcClient(Configuration conf)

testCompressCellBlock

public void testCompressCellBlock()
                           throws java.io.IOException,
                                  java.lang.InterruptedException,
                                  java.lang.SecurityException,
                                  java.lang.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:

java.io.IOException

java.lang.InterruptedException

java.lang.SecurityException

java.lang.NoSuchMethodException

ServiceException

createRpcClientRTEDuringConnectionSetup

protected abstract AbstractRpcClient createRpcClientRTEDuringConnectionSetup(Configuration conf)
                                                                      throws java.io.IOException

Throws:

java.io.IOException

testRTEDuringConnectionSetup

public void testRTEDuringConnectionSetup()
                                  throws java.lang.Exception

Throws:

java.lang.Exception

testRpcScheduler

public void testRpcScheduler()
                      throws java.io.IOException,
                             java.lang.InterruptedException

Tests that the rpc scheduler is called when requests arrive.

Throws:

java.io.IOException

java.lang.InterruptedException