org.apache.hadoop.hbase.ipc

Class FailingNettyRpcServer

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcServer

org.apache.hadoop.hbase.ipc.NettyRpcServer

org.apache.hadoop.hbase.ipc.FailingNettyRpcServer

All Implemented Interfaces:

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

public class FailingNettyRpcServer
extends org.apache.hadoop.hbase.ipc.NettyRpcServer

Nested Class Summary

Nested Classes

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

allChannels, CHANNEL_WRITABLE_FATAL_WATERMARK_KEY, CHANNEL_WRITABLE_HIGH_WATERMARK_KEY, CHANNEL_WRITABLE_LOW_WATERMARK_KEY, HBASE_NETTY_ALLOCATOR_KEY, HEAP_ALLOCATOR_TYPE, LOG, POOLED_ALLOCATOR_TYPE, UNPOOLED_ALLOCATOR_TYPE

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, running, saslProps, scheduler, secretManager, server, 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 and Description
FailingNettyRpcServer(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.NettyServerRpcConnection	createNettyServerRpcConnection(org.apache.hbase.thirdparty.io.netty.channel.Channel channel)

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

getListenerAddress, getNumOpenConnections, getSslContext, getTotalAndMaxNettyOutboundBytes, getWriteBufferFatalThreshold, isWritabilityBackpressureEnabled, join, onConfigurationChange, setSocketSendBufSize, start, stop

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

addCallSize, authorize, call, channelRead, createSecretManager, getByteBuffAllocator, getConf, getCurrentCall, getCurrentServerCallWithCellScanner, getErrorHandler, getMetrics, getRemoteAddress, getRemoteIp, getRequestUser, getRequestUserName, getScheduler, getSecretManager, getService, getServiceAndInterface, getServiceInterface, getStatus, initReconfigurable, isInRpcCallContext, isStarted, logResponse, needAuthorization, 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

FailingNettyRpcServer

public FailingNettyRpcServer(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

createNettyServerRpcConnection

protected org.apache.hadoop.hbase.ipc.NettyServerRpcConnection createNettyServerRpcConnection(org.apache.hbase.thirdparty.io.netty.channel.Channel channel)

Overrides:

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