public class NettyRpcServer extends RpcServer
RpcServer.BlockingServiceAndInterface, RpcServer.CallCleanup
Modifier and Type | Field and Description |
---|---|
static Logger |
LOG |
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_WARN_RESPONSE_SIZE, DEFAULT_WARN_RESPONSE_TIME, errorHandler, FALLBACK_TO_INSECURE_CLIENT_AUTH, isSecurityEnabled, MAPPER, MAX_REQUEST_SIZE, maxQueueSizeInBytes, maxRequestSize, metrics, MIN_CLIENT_REQUEST_TIMEOUT, minClientRequestTimeout, minSizeForReservoirUse, MONITORED_RPC, NIO_BUFFER_LIMIT, REQUEST_TOO_BIG_EXCEPTION, reservoir, saslProps, scheduler, secretManager, server, services, tcpKeepAlive, tcpNoDelay, userProvider, WARN_RESPONSE_SIZE, WARN_RESPONSE_TIME, warnResponseSize, warnResponseTime
Constructor and Description |
---|
NettyRpcServer(Server server,
java.lang.String name,
java.util.List<RpcServer.BlockingServiceAndInterface> services,
java.net.InetSocketAddress bindAddress,
Configuration conf,
RpcScheduler scheduler,
boolean reservoirEnabled) |
Modifier and Type | Method and Description |
---|---|
<any> |
call(BlockingService service,
MethodDescriptor md,
Message param,
CellScanner cellScanner,
long receiveTime,
MonitoredRPCHandler status) |
<any> |
call(BlockingService service,
MethodDescriptor md,
Message param,
CellScanner cellScanner,
long receiveTime,
MonitoredRPCHandler status,
long startTime,
int timeout) |
protected org.apache.hadoop.hbase.ipc.NettyRpcServerPreambleHandler |
createNettyRpcServerPreambleHandler() |
java.net.InetSocketAddress |
getListenerAddress() |
int |
getNumOpenConnections()
The number of open RPC conections
|
void |
join() |
void |
setSocketSendBufSize(int size) |
void |
start() |
void |
stop() |
addCallSize, authorize, call, channelRead, createSecretManager, getCurrentCall, getErrorHandler, getMetrics, getRemoteAddress, getRemoteIp, getRequestUser, getRequestUserName, getScheduler, getSecretManager, getService, getServiceAndInterface, getServiceInterface, getStatus, initReconfigurable, isInRpcCallContext, isStarted, onConfigurationChange, refreshAuthManager, setErrorHandler, setRsRpcServices, setSecretManager
public NettyRpcServer(Server server, java.lang.String name, java.util.List<RpcServer.BlockingServiceAndInterface> services, java.net.InetSocketAddress bindAddress, Configuration conf, RpcScheduler scheduler, boolean reservoirEnabled) throws java.io.IOException
java.io.IOException
protected org.apache.hadoop.hbase.ipc.NettyRpcServerPreambleHandler createNettyRpcServerPreambleHandler()
public void start()
public void stop()
public void join() throws java.lang.InterruptedException
java.lang.InterruptedException
public java.net.InetSocketAddress getListenerAddress()
public void setSocketSendBufSize(int size)
public int getNumOpenConnections()
RpcServer
getNumOpenConnections
in class RpcServer
public <any> call(BlockingService service, MethodDescriptor md, Message param, CellScanner cellScanner, long receiveTime, MonitoredRPCHandler status) throws java.io.IOException
java.io.IOException
public <any> call(BlockingService service, MethodDescriptor md, Message param, CellScanner cellScanner, long receiveTime, MonitoredRPCHandler status, long startTime, int timeout) throws java.io.IOException
java.io.IOException