org.apache.hadoop.hbase.ipc

Class TestBlockingIPC.TestFailingRpcServer

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcServer

org.apache.hadoop.hbase.ipc.SimpleRpcServer

org.apache.hadoop.hbase.ipc.TestBlockingIPC.TestFailingRpcServer

All Implemented Interfaces:

org.apache.hadoop.hbase.conf.ConfigurationObserver, org.apache.hadoop.hbase.ipc.RpcServerInterface

Enclosing class:

TestBlockingIPC

private static class TestBlockingIPC.TestFailingRpcServer
extends org.apache.hadoop.hbase.ipc.SimpleRpcServer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) class	TestBlockingIPC.TestFailingRpcServer.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, 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, isSecurityEnabled, KEY_WORD_TRUNCATED, LOG, MAPPER, MAX_REQUEST_SIZE, maxQueueSizeInBytes, maxRequestSize, metrics, MIN_CLIENT_REQUEST_TIMEOUT, minClientRequestTimeout, minSizeForReservoirUse, MONITORED_RPC, NIO_BUFFER_LIMIT, REQUEST_TOO_BIG_EXCEPTION, reservoir, running, saslProps, scheduler, secretManager, server, services, started, tcpKeepAlive, tcpNoDelay, TRACE_LOG_MAX_LENGTH, userProvider, WARN_RESPONSE_SIZE, WARN_RESPONSE_TIME, warnResponseSize, warnResponseTime

Constructor Summary

Constructors

Constructor and Description
TestFailingRpcServer(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 and 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, allocateByteBuffToReadInto, authorize, call, channelRead, createSecretManager, getConf, getCurrentCall, getErrorHandler, getMetrics, getMinSizeForReservoirUse, getRemoteAddress, getRemoteIp, getRequestUser, getRequestUserName, getScheduler, getSecretManager, getService, getServiceAndInterface, getServiceInterface, getStatus, initReconfigurable, isInRpcCallContext, isStarted, logResponse, onConfigurationChange, refreshAuthManager, setErrorHandler, setRsRpcServices, setSecretManager, truncateTraceLog

Methods inherited from class java.lang.Object

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

Constructor Detail

TestFailingRpcServer

TestFailingRpcServer(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)
              throws IOException

Throws:

IOException

Method Detail

getConnection

protected org.apache.hadoop.hbase.ipc.SimpleServerRpcConnection getConnection(SocketChannel channel,
                                                                              long time)

Overrides:

getConnection in class org.apache.hadoop.hbase.ipc.SimpleRpcServer