org.apache.hadoop.hbase

Class TestClientOperationTimeout.DelayedRSRpcServices

java.lang.Object

org.apache.hadoop.hbase.regionserver.RSRpcServices

org.apache.hadoop.hbase.TestClientOperationTimeout.DelayedRSRpcServices

All Implemented Interfaces:

org.apache.hadoop.hbase.conf.ConfigurationObserver, org.apache.hadoop.hbase.ipc.HBaseRPCErrorHandler, org.apache.hadoop.hbase.ipc.PriorityFunction, org.apache.hadoop.hbase.shaded.protobuf.generated.AdminProtos.AdminService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface, org.apache.hadoop.hbase.shaded.protobuf.generated.RegistryProtos.ClientMetaService.BlockingInterface

Enclosing class:

TestClientOperationTimeout

public static class TestClientOperationTimeout.DelayedRSRpcServices
extends org.apache.hadoop.hbase.regionserver.RSRpcServices

This RSRpcServices class injects delay for Rpc calls and after executes super methods.

Field Summary

Fields inherited from class org.apache.hadoop.hbase.regionserver.RSRpcServices

CLIENT_BOOTSTRAP_NODE_LIMIT, DEFAULT_CLIENT_BOOTSTRAP_NODE_LIMIT, LOG, MASTER_RPC_SCHEDULER_FACTORY_CLASS, REGION_SERVER_RPC_SCHEDULER_FACTORY_CLASS, regionServer, REGIONSERVER_ADMIN_SERVICE_CONFIG, REGIONSERVER_CLIENT_META_SERVICE_CONFIG, REGIONSERVER_CLIENT_SERVICE_CONFIG

Constructor Summary

Constructors

Constructor and Description
DelayedRSRpcServices(org.apache.hadoop.hbase.regionserver.HRegionServer rs)

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.GetResponse	get(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.GetRequest request)
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiResponse	multi(org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequest request)
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse	mutate(org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcc, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateRequest request)
org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse	scan(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request)

Methods inherited from class org.apache.hadoop.hbase.regionserver.RSRpcServices

bulkLoadHFile, checkOOME, checkOpen, cleanupBulkLoad, clearCompactionQueues, clearRegionBlockCache, clearSlowLogsResponses, closeRegion, compactionSwitch, compactRegion, createPriority, createRpcServer, execRegionServerService, execService, executeProcedures, exitIfOOME, flushRegion, getAccessChecker, getActiveMaster, getBootstrapNodes, getClusterId, getConfiguration, getDeadline, getLargeLogResponses, getLogEntries, getMasters, getMetaRegionLocations, getOnlineRegion, getPriority, getPriority, getRegion, getRegionInfo, getRegionLoad, getRpcScheduler, getRpcSchedulerFactoryClass, getScanDetailsWithId, getScanDetailsWithRequest, getScannersCount, getServerInfo, getServices, getSlowLogResponses, getSocketAddress, getSpaceQuotaSnapshots, getStoreFile, getZkPermissionWatcher, onConfigurationChange, openRegion, prepareBulkLoad, replay, replicateWALEntry, requirePermission, rollWALWriter, stopServer, updateConfiguration, updateFavoredNodes, warmupRegion

Methods inherited from class java.lang.Object

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

Constructor Detail

DelayedRSRpcServices

DelayedRSRpcServices(org.apache.hadoop.hbase.regionserver.HRegionServer rs)
              throws IOException

Throws:

IOException

Method Detail

get

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.GetResponse get(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                      org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.GetRequest request)
                                                                               throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

get in interface org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface

Overrides:

get in class org.apache.hadoop.hbase.regionserver.RSRpcServices

Throws:

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

mutate

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateResponse mutate(org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcc,
                                                                                            org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MutateRequest request)
                                                                                     throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

mutate in interface org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface

Overrides:

mutate in class org.apache.hadoop.hbase.regionserver.RSRpcServices

Throws:

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

scan

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanResponse scan(org.apache.hbase.thirdparty.com.google.protobuf.RpcController controller,
                                                                                        org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ScanRequest request)
                                                                                 throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

scan in interface org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface

Overrides:

scan in class org.apache.hadoop.hbase.regionserver.RSRpcServices

Throws:

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

multi

public org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiResponse multi(org.apache.hbase.thirdparty.com.google.protobuf.RpcController rpcc,
                                                                                          org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.MultiRequest request)
                                                                                   throws org.apache.hbase.thirdparty.com.google.protobuf.ServiceException

Specified by:

multi in interface org.apache.hadoop.hbase.shaded.protobuf.generated.ClientProtos.ClientService.BlockingInterface

Overrides:

multi in class org.apache.hadoop.hbase.regionserver.RSRpcServices

Throws:

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