org.apache.hadoop.hbase.ipc

Class TestNettyIPC.TestFailingRpcServer

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcServer

org.apache.hadoop.hbase.ipc.NettyRpcServer

org.apache.hadoop.hbase.ipc.TestNettyIPC.TestFailingRpcServer

All Implemented Interfaces:

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

Enclosing class:

TestNettyIPC

private static class TestNettyIPC.TestFailingRpcServer
extends org.apache.hadoop.hbase.ipc.NettyRpcServer

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	TestNettyIPC.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.NettyRpcServer

HBASE_NETTY_EVENTLOOP_RPCSERVER_THREADCOUNT_KEY, LOG

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

allowFallbackToSimpleAuth, AUDITLOG, AUTH_FAILED_FOR, AUTH_SUCCESSFUL_FOR, authManager, authTokenSecretMgr, bbAllocator, 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, MAX_REQUEST_SIZE, maxQueueSizeInBytes, maxRequestSize, metrics, MIN_CLIENT_REQUEST_TIMEOUT, minClientRequestTimeout, MONITORED_RPC, NIO_BUFFER_LIMIT, REQUEST_TOO_BIG_EXCEPTION, 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.NettyRpcServerPreambleHandler	createNettyRpcServerPreambleHandler()

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

call, call, 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, getStatus, initReconfigurable, isInRpcCallContext, isStarted, logResponse, 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 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

createNettyRpcServerPreambleHandler

protected org.apache.hadoop.hbase.ipc.NettyRpcServerPreambleHandler createNettyRpcServerPreambleHandler()

Overrides:

createNettyRpcServerPreambleHandler in class org.apache.hadoop.hbase.ipc.NettyRpcServer