org.apache.hadoop.hbase.client

Class TestClientScannerTimeouts.RSRpcServicesWithScanTimeout

java.lang.Object

org.apache.hadoop.hbase.regionserver.RSRpcServices

org.apache.hadoop.hbase.client.TestClientScannerTimeouts.RSRpcServicesWithScanTimeout

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:

TestClientScannerTimeouts

private static class TestClientScannerTimeouts.RSRpcServicesWithScanTimeout
extends org.apache.hadoop.hbase.regionserver.RSRpcServices

Field Summary

Fields

Modifier and Type	Field and Description
private static long	seqNoToSleepOn
private static long	seqNoToThrowOn
private static boolean	sleepOnOpen
private static int	sleepTime
private static boolean	slept
private long	tableScannerId
private static boolean	threw
private static boolean	throwAlways
private static int	tryNumber

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
RSRpcServicesWithScanTimeout(org.apache.hadoop.hbase.regionserver.HRegionServer rs)

Method Summary

Modifier and Type	Method and Description
static void	reset()
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)
static void	setSleepForTimeout(int timeout)

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, get, 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, multi, mutate, 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

Field Detail

tableScannerId

private long tableScannerId

seqNoToThrowOn

private static long seqNoToThrowOn

throwAlways

private static boolean throwAlways

threw

private static boolean threw

seqNoToSleepOn

private static long seqNoToSleepOn

sleepOnOpen

private static boolean sleepOnOpen

slept

private static volatile boolean slept

tryNumber

private static int tryNumber

sleepTime

private static int sleepTime

Constructor Detail

RSRpcServicesWithScanTimeout

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

Throws:

IOException

Method Detail

setSleepForTimeout

public static void setSleepForTimeout(int timeout)

reset

public static void reset()

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