Package org.apache.hadoop.hbase.ipc

Class TestServerCall

java.lang.Object

org.apache.hadoop.hbase.ipc.TestServerCall

@Tag("org.apache.hadoop.hbase.testclassification.RPCTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestServerCall
extends Object

Test for ServerCall IOException handling in setResponse method.

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.conf.Configuration	conf
private org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader	header
private InetAddress	lbAddr
private static final org.slf4j.Logger	LOG
private org.apache.hadoop.hbase.io.ByteBuffAllocator	mockAllocator
private org.apache.hadoop.hbase.ipc.CellBlockBuilder	mockCellBlockBuilder
private org.apache.hadoop.hbase.ipc.NettyServerRpcConnection	mockConnection
private org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor	mockMethodDescriptor
private org.apache.hbase.thirdparty.com.google.protobuf.Message	mockParam
private org.apache.hbase.thirdparty.com.google.protobuf.BlockingService	mockService

Constructor Summary

Constructors

Constructor	Description
TestServerCall()

Method Summary

Modifier and Type	Method	Description
void	setUp()
void	testSetResponseNormalFlow()	Test normal response creation to ensure our changes don't break the normal flow.
void	testSetResponseWithDoubleIOException()	Test the case where both normal response creation and error response creation fail with IOException.
void	testSetResponseWithIOException()	Test that when IOException occurs during response creation in setResponse, an error response is created and sent to the client instead of leaving the response as null.

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

conf

private org.apache.hadoop.conf.Configuration conf

mockConnection

private org.apache.hadoop.hbase.ipc.NettyServerRpcConnection mockConnection

header

private org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header

mockParam

private org.apache.hbase.thirdparty.com.google.protobuf.Message mockParam

mockAllocator

private org.apache.hadoop.hbase.io.ByteBuffAllocator mockAllocator

mockCellBlockBuilder

private org.apache.hadoop.hbase.ipc.CellBlockBuilder mockCellBlockBuilder

lbAddr

private InetAddress lbAddr

mockService

private org.apache.hbase.thirdparty.com.google.protobuf.BlockingService mockService

mockMethodDescriptor

private org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor mockMethodDescriptor

Constructor Details

TestServerCall

public TestServerCall()

Method Details

setUp

@BeforeEach
public void setUp()
           throws Exception

Throws:

Exception

testSetResponseWithIOException

@Test
public void testSetResponseWithIOException()
                                    throws Exception

Test that when IOException occurs during response creation in setResponse, an error response is created and sent to the client instead of leaving the response as null.

Throws:

Exception

testSetResponseWithDoubleIOException

@Test
public void testSetResponseWithDoubleIOException()
                                          throws Exception

Test the case where both normal response creation and error response creation fail with IOException.

Throws:

Exception

testSetResponseNormalFlow

@Test
public void testSetResponseNormalFlow()
                               throws Exception

Test normal response creation to ensure our changes don't break the normal flow.

Throws:

Exception