org.apache.hadoop.hbase.client

Class TestClientTimeouts.RandomTimeoutBlockingRpcChannel

java.lang.Object

org.apache.hadoop.hbase.ipc.AbstractRpcClient.BlockingRpcChannelImplementation

org.apache.hadoop.hbase.client.TestClientTimeouts.RandomTimeoutBlockingRpcChannel

All Implemented Interfaces:

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

Enclosing class:

TestClientTimeouts

static class TestClientTimeouts.RandomTimeoutBlockingRpcChannel
extends org.apache.hadoop.hbase.ipc.AbstractRpcClient.BlockingRpcChannelImplementation

Blocking rpc channel that goes via hbase rpc.

Field Summary

Fields

Modifier and Type	Field and Description
static double	CHANCE_OF_TIMEOUT
private static AtomicInteger	invokations
private static Random	RANDOM

Constructor Summary

Constructors

Constructor and Description
RandomTimeoutBlockingRpcChannel(org.apache.hadoop.hbase.ipc.BlockingRpcClient rpcClient, org.apache.hadoop.hbase.ServerName sn, org.apache.hadoop.hbase.security.User ticket, int rpcTimeout)

Method Summary

Modifier and Type	Method and Description
org.apache.hbase.thirdparty.com.google.protobuf.Message	callBlockingMethod(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hbase.thirdparty.com.google.protobuf.Message param, org.apache.hbase.thirdparty.com.google.protobuf.Message returnType)

Methods inherited from class java.lang.Object

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

Field Detail

RANDOM

private static final Random RANDOM

CHANCE_OF_TIMEOUT

public static final double CHANCE_OF_TIMEOUT

See Also:

Constant Field Values

invokations

private static AtomicInteger invokations

Constructor Detail

RandomTimeoutBlockingRpcChannel

RandomTimeoutBlockingRpcChannel(org.apache.hadoop.hbase.ipc.BlockingRpcClient rpcClient,
                                org.apache.hadoop.hbase.ServerName sn,
                                org.apache.hadoop.hbase.security.User ticket,
                                int rpcTimeout)

Method Detail

callBlockingMethod

public org.apache.hbase.thirdparty.com.google.protobuf.Message callBlockingMethod(org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
                                                                                  org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                  org.apache.hbase.thirdparty.com.google.protobuf.Message param,
                                                                                  org.apache.hbase.thirdparty.com.google.protobuf.Message returnType)
                                                                           throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

callBlockingMethod in interface org.apache.hbase.thirdparty.com.google.protobuf.BlockingRpcChannel

Overrides:

callBlockingMethod in class org.apache.hadoop.hbase.ipc.AbstractRpcClient.BlockingRpcChannelImplementation

Throws:

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