Package org.apache.hadoop.hbase.ipc

Class AbstractTestIPC.FailingSimpleRpcServer

java.lang.Object
org.apache.hadoop.hbase.ipc.RpcServer
org.apache.hadoop.hbase.ipc.SimpleRpcServer
org.apache.hadoop.hbase.ipc.AbstractTestIPC.FailingSimpleRpcServer
All Implemented Interfaces:
org.apache.hadoop.hbase.conf.ConfigurationObserver, org.apache.hadoop.hbase.ipc.RpcServerInterface
Enclosing class:
AbstractTestIPC
private static class AbstractTestIPC.FailingSimpleRpcServer extends org.apache.hadoop.hbase.ipc.SimpleRpcServer

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    (package private) final class 
    AbstractTestIPC.FailingSimpleRpcServer.FailingConnection
     

    Nested classes/interfaces inherited from class org.apache.hadoop.hbase.ipc.RpcServer

    org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface, org.apache.hadoop.hbase.ipc.RpcServer.CallCleanup

  • Field Summary

    Fields inherited from class org.apache.hadoop.hbase.ipc.SimpleRpcServer

    address, port, purgeTimeout, responder, socketSendBufferSize

    Fields inherited from class org.apache.hadoop.hbase.ipc.RpcServer

    allowFallbackToSimpleAuth, AUDITLOG, AUTH_FAILED_FOR, AUTH_SUCCESSFUL_FOR, authManager, authTokenSecretMgr, bbAllocator, bindAddress, CALL_QUEUE_TOO_BIG_EXCEPTION, callQueueSizeInBytes, cellBlockBuilder, conf, CurCall, CURRENT_VERSION, DEFAULT_MAX_CALLQUEUE_LENGTH_PER_HANDLER, DEFAULT_MAX_CALLQUEUE_SIZE, DEFAULT_MAX_REQUEST_SIZE, DEFAULT_MIN_CLIENT_REQUEST_TIMEOUT, DEFAULT_TRACE_LOG_MAX_LENGTH, DEFAULT_WARN_RESPONSE_SIZE, DEFAULT_WARN_RESPONSE_TIME, errorHandler, FALLBACK_TO_INSECURE_CLIENT_AUTH, GSON, isSecurityEnabled, KEY_WORD_TRUNCATED, LOG, MAX_REQUEST_SIZE, maxQueueSizeInBytes, maxRequestSize, metrics, MIN_CLIENT_REQUEST_TIMEOUT, minClientRequestTimeout, MONITORED_RPC, NIO_BUFFER_LIMIT, running, saslProps, scheduler, secretManager, server, serverPrincipal, services, started, tcpKeepAlive, tcpNoDelay, TRACE_LOG_MAX_LENGTH, userProvider, WARN_RESPONSE_SIZE, WARN_RESPONSE_TIME, WARN_SCAN_RESPONSE_SIZE, WARN_SCAN_RESPONSE_TIME, warnResponseSize, warnResponseTime, warnScanResponseSize, warnScanResponseTime

  • Constructor Summary

    Constructors
    Constructor
    Description
    FailingSimpleRpcServer(org.apache.hadoop.hbase.Server server, String name, List<org.apache.hadoop.hbase.ipc.RpcServer.BlockingServiceAndInterface> services, InetSocketAddress bindAddress, org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.hbase.ipc.RpcScheduler scheduler)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected org.apache.hadoop.hbase.ipc.SimpleServerRpcConnection
    getConnection(SocketChannel channel, long time)
     

    Methods inherited from class org.apache.hadoop.hbase.ipc.SimpleRpcServer

    bind, call, call, channelWrite, closeConnection, getListenerAddress, getNumOpenConnections, join, setSocketSendBufSize, start, stop

    Methods inherited from class org.apache.hadoop.hbase.ipc.RpcServer

    addCallSize, authorize, call, channelRead, createSecretManager, getByteBuffAllocator, getConf, getCurrentCall, getErrorHandler, getMetrics, getRemoteAddress, getRemoteIp, getRequestUser, getRequestUserName, getScheduler, getSecretManager, getService, getServiceAndInterface, getServiceInterface, getServices, getStatus, initReconfigurable, isInRpcCallContext, isStarted, logResponse, needAuthorization, onConfigurationChange, refreshAuthManager, setCurrentCall, setErrorHandler, setNamedQueueRecorder, setRsRpcServices, setSecretManager, truncateTraceLog, unsetCurrentCall

    Methods inherited from class java.lang.Object

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

  • Constructor Details

  • Method Details

    • getConnection

      protected org.apache.hadoop.hbase.ipc.SimpleServerRpcConnection getConnection(SocketChannel channel, long time)
      Overrides:
      getConnection in class org.apache.hadoop.hbase.ipc.SimpleRpcServer