Package org.apache.hadoop.hbase.client

Class TestClientScannerTimeouts.RSRpcServicesWithScanTimeout

java.lang.Object
org.apache.hadoop.hbase.HBaseRpcServicesBase<org.apache.hadoop.hbase.regionserver.HRegionServer>
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.BootstrapNodeProtos.BootstrapNodeService.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
    Description
    private static boolean
    closed
     
    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

    REGION_SERVER_RPC_SCHEDULER_FACTORY_CLASS, REGIONSERVER_ADMIN_SERVICE_CONFIG, REGIONSERVER_BOOTSTRAP_NODES_SERVICE_CONFIG, REGIONSERVER_CLIENT_META_SERVICE_CONFIG, REGIONSERVER_CLIENT_SERVICE_CONFIG

    Fields inherited from class org.apache.hadoop.hbase.HBaseRpcServicesBase

    CLIENT_BOOTSTRAP_NODE_LIMIT, DEFAULT_CLIENT_BOOTSTRAP_NODE_LIMIT, priority, rpcServer, server

  • Constructor Summary

    Constructors
    Constructor
    Description
    RSRpcServicesWithScanTimeout(org.apache.hadoop.hbase.regionserver.HRegionServer rs)
     

  • Method Summary

    Modifier and Type
    Method
    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, checkOpen, cleanupBulkLoad, clearCompactionQueues, clearManagedKeyDataCache, clearRegionBlockCache, closeRegion, compactionSwitch, compactRegion, createPriority, createRpcServer, defaultReservoirEnabled, ejectManagedKeyDataCacheEntry, execRegionServerService, execService, executeProcedures, flushRegion, get, getAllBootstrapNodes, getCachedFilesList, getDefaultPort, getDNSServerType, getHostname, getOnlineRegion, getPortConfigName, getRegion, getRegionInfo, getRegionLoad, getRpcSchedulerFactoryClass, getRpcSchedulerFactoryClass, getScanDetailsWithId, getScanDetailsWithRequest, getScannersCount, getServerInfo, getServices, getSpaceQuotaSnapshots, getStoreFile, multi, mutate, onConfigurationChange, openRegion, prepareBulkLoad, refreshSystemKeyCache, replay, replicateToReplica, replicateWALEntry, rollWALWriter, stopServer, updateFavoredNodes, warmupRegion

    Methods inherited from class org.apache.hadoop.hbase.HBaseRpcServicesBase

    checkOOME, clearSlowLogsResponses, getAccessChecker, getActiveMaster, getBootstrapNodes, getClientMetaCoprocessorHost, getClusterId, getConfiguration, getDeadline, getLogEntries, getMasters, getMetaRegionLocations, getPriority, getRpcScheduler, getRpcServer, getServer, getSocketAddress, getZkPermissionWatcher, internalStart, internalStop, requirePermission, updateConfiguration

    Methods inherited from class java.lang.Object

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

  • Field Details

    • tableScannerId

      private long tableScannerId

    • seqNoToThrowOn

      private static volatile long seqNoToThrowOn

    • throwAlways

      private static volatile boolean throwAlways

    • threw

      private static volatile boolean threw

    • seqNoToSleepOn

      private static volatile long seqNoToSleepOn

    • sleepOnOpen

      private static volatile boolean sleepOnOpen

    • slept

      private static volatile boolean slept

    • tryNumber

      private static volatile int tryNumber

    • closed

      private static volatile boolean closed

    • sleepTime

      private static volatile int sleepTime

  • Constructor Details

  • Method Details

    • 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