public abstract class AbstractTestIPC
extends java.lang.Object
Constructor and Description |
---|
AbstractTestIPC() |
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() |
protected abstract AbstractRpcClient createRpcClientNoCodec(Configuration conf)
public void testNoCodec() throws java.lang.InterruptedException, java.io.IOException
java.lang.InterruptedException
java.io.IOException
protected abstract AbstractRpcClient createRpcClient(Configuration conf)
public void testCompressCellBlock() throws java.io.IOException, java.lang.InterruptedException, java.lang.SecurityException, java.lang.NoSuchMethodException, ServiceException
java.io.IOException
java.lang.InterruptedException
java.lang.SecurityException
java.lang.NoSuchMethodException
ServiceException
protected abstract AbstractRpcClient createRpcClientRTEDuringConnectionSetup(Configuration conf) throws java.io.IOException
java.io.IOException
public void testRTEDuringConnectionSetup() throws java.lang.Exception
java.lang.Exception
public void testRpcScheduler() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException