private static class TestNettyIPC.TestFailingRpcServer extends org.apache.hadoop.hbase.ipc.NettyRpcServer
Modifier and Type | Class and Description |
---|---|
(package private) static class |
TestNettyIPC.TestFailingRpcServer.FailingConnection |
allowFallbackToSimpleAuth, AUDITLOG, AUTH_FAILED_FOR, AUTH_SUCCESSFUL_FOR, authManager, authTokenSecretMgr, 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, 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 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) |
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.hbase.ipc.NettyRpcServerPreambleHandler |
createNettyRpcServerPreambleHandler() |
call, call, getListenerAddress, getNumOpenConnections, join, setSocketSendBufSize, start, stop
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
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
IOException
protected org.apache.hadoop.hbase.ipc.NettyRpcServerPreambleHandler createNettyRpcServerPreambleHandler()
createNettyRpcServerPreambleHandler
in class org.apache.hadoop.hbase.ipc.NettyRpcServer
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.