Package org.apache.hadoop.hbase.ipc

Class SimpleRpcServer

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcServer

org.apache.hadoop.hbase.ipc.SimpleRpcServer

All Implemented Interfaces:

ConfigurationObserver, RpcServerInterface

@Deprecated
@LimitedPrivate("Configuration")
public class SimpleRpcServer
extends RpcServer

Deprecated.

The RPC server with native java NIO implementation deriving from Hadoop to host protobuf described Services. It's the original one before HBASE-17262, and the default RPC server for now. An RpcServer instance has a Listener that hosts the socket. Listener has fixed number of Readers in an ExecutorPool, 10 by default. The Listener does an accept and then round robin a Reader is chosen to do the read. The reader is registered on Selector. Read does total read off the channel and the parse from which it makes a Call. The call is wrapped in a CallRunner and passed to the scheduler to be run. Reader goes back to see if more to be done and loops till done.

Scheduler can be variously implemented but default simple scheduler has handlers to which it has given the queues into which calls (i.e. CallRunner instances) are inserted. Handlers run taking from the queue. They run the CallRunner#run method on each item gotten from queue and keep taking while the server is up. CallRunner#run executes the call. When done, asks the included Call to put itself on new queue for Responder to pull from and return result to client.

See Also:

• BlockingRpcClient

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private class	SimpleRpcServer.ConnectionManager	Deprecated.
private class	SimpleRpcServer.Listener	Deprecated. Listens on the socket.

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.ipc.RpcServer

RpcServer.BlockingServiceAndInterface, RpcServer.CallCleanup

Field Summary

Fields

Modifier and Type	Field	Description
protected InetSocketAddress	address	Deprecated.
private SimpleRpcServer.ConnectionManager	connectionManager	Deprecated.
private SimpleRpcServer.Listener	listener	Deprecated.
protected int	port	Deprecated.
protected final long	purgeTimeout	Deprecated.
private int	readThreads	Deprecated.
protected SimpleRpcServerResponder	responder	Deprecated.
protected int	socketSendBufferSize	Deprecated.

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

allowFallbackToSimpleAuth, AUDITLOG, AUTH_FAILED_FOR, AUTH_SUCCESSFUL_FOR, authManager, authTokenSecretMgr, bbAllocator, 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, GSON, isSecurityEnabled, KEY_WORD_TRUNCATED, LOG, MAX_REQUEST_SIZE, maxQueueSizeInBytes, maxRequestSize, metrics, MIN_CLIENT_REQUEST_TIMEOUT, minClientRequestTimeout, MONITORED_RPC, NIO_BUFFER_LIMIT, running, saslProps, scheduler, secretManager, server, serverPrincipal, 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	Description
SimpleRpcServer(Server server, String name, List<RpcServer.BlockingServiceAndInterface> services, InetSocketAddress bindAddress, org.apache.hadoop.conf.Configuration conf, RpcScheduler scheduler, boolean reservoirEnabled)	Deprecated. Constructs a server listening on the named port and address.

Method Summary

Modifier and Type	Method	Description
static void	bind(ServerSocket socket, InetSocketAddress address, int backlog)	Deprecated. A convenience method to bind to a given address and report better exceptions if the address is not a valid host.
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner>	call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service, org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, org.apache.hbase.thirdparty.com.google.protobuf.Message param, CellScanner cellScanner, long receiveTime, MonitoredRPCHandler status)	Deprecated.
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner>	call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service, org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, org.apache.hbase.thirdparty.com.google.protobuf.Message param, CellScanner cellScanner, long receiveTime, MonitoredRPCHandler status, long startTime, int timeout)	Deprecated.
protected long	channelWrite(GatheringByteChannel channel, BufferChain bufferChain)	Deprecated.
protected void	closeConnection(SimpleServerRpcConnection connection)	Deprecated.
protected SimpleServerRpcConnection	getConnection(SocketChannel channel, long time)	Deprecated. Subclasses of HBaseServer can override this to provide their own Connection implementations.
InetSocketAddress	getListenerAddress()	Deprecated. Return the socket (ip+port) on which the RPC server is listening to.
int	getNumOpenConnections()	Deprecated. The number of open RPC conections
void	join()	Deprecated. Wait for the server to be stopped.
void	setSocketSendBufSize(int size)	Deprecated. Sets the socket buffer size used for responding to RPCs.
void	start()	Deprecated. Starts the service.
void	stop()	Deprecated. Stops the service.

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

Field Details

port

protected int port

Deprecated.

address

protected InetSocketAddress address

Deprecated.

readThreads

private int readThreads

Deprecated.

socketSendBufferSize

protected int socketSendBufferSize

Deprecated.

purgeTimeout

protected final long purgeTimeout

Deprecated.

connectionManager

private SimpleRpcServer.ConnectionManager connectionManager

Deprecated.

listener

private SimpleRpcServer.Listener listener

Deprecated.

responder

protected SimpleRpcServerResponder responder

Deprecated.

Constructor Details

SimpleRpcServer

public SimpleRpcServer(Server server,
 String name,
 List<RpcServer.BlockingServiceAndInterface> services,
 InetSocketAddress bindAddress,
 org.apache.hadoop.conf.Configuration conf,
 RpcScheduler scheduler,
 boolean reservoirEnabled)
                throws IOException

Deprecated.

Constructs a server listening on the named port and address.

Parameters:

server - hosting instance of Server. We will do authentications if an instance else pass null for no authentication check.

name - Used keying this rpc servers' metrics and for naming the Listener thread.

services - A list of services.

bindAddress - Where to listen

reservoirEnabled - Enable ByteBufferPool or not.

Throws:

IOException

Method Details

getConnection

protected SimpleServerRpcConnection getConnection(SocketChannel channel,
 long time)

Deprecated.

Subclasses of HBaseServer can override this to provide their own Connection implementations.

closeConnection

protected void closeConnection(SimpleServerRpcConnection connection)

Deprecated.

setSocketSendBufSize

public void setSocketSendBufSize(int size)

Deprecated.

Sets the socket buffer size used for responding to RPCs.

Parameters:

size - send size

start

public void start()

Deprecated.

Starts the service. Must be called before any calls will be handled.

stop

public void stop()

Deprecated.

Stops the service. No new calls will be handled after this is called.

join

public void join()
          throws InterruptedException

Deprecated.

Wait for the server to be stopped. Does not wait for all subthreads to finish.

Throws:

InterruptedException

See Also:

• stop()

getListenerAddress

public InetSocketAddress getListenerAddress()

Deprecated.

Return the socket (ip+port) on which the RPC server is listening to. May return null if the listener channel is closed.

Returns:

the socket (ip+port) on which the RPC server is listening to, or null if this information cannot be determined

call

public Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
 org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
 org.apache.hbase.thirdparty.com.google.protobuf.Message param,
 CellScanner cellScanner,
 long receiveTime,
 MonitoredRPCHandler status)
                                                                               throws IOException

Deprecated.

Throws:

IOException

call

public Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> call(org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
 org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
 org.apache.hbase.thirdparty.com.google.protobuf.Message param,
 CellScanner cellScanner,
 long receiveTime,
 MonitoredRPCHandler status,
 long startTime,
 int timeout)
                                                                               throws IOException

Deprecated.

Throws:

IOException

channelWrite

protected long channelWrite(GatheringByteChannel channel,
 BufferChain bufferChain)
                     throws IOException

Deprecated.

Throws:

IOException

bind

public static void bind(ServerSocket socket,
 InetSocketAddress address,
 int backlog)
                 throws IOException

Deprecated.

A convenience method to bind to a given address and report better exceptions if the address is not a valid host.

Parameters:

socket - the socket to bind

address - the address to bind to

backlog - the number of connections allowed in the queue

Throws:

BindException - if the address can't be bound

UnknownHostException - if the address isn't a valid host name

IOException - other random errors from bind

getNumOpenConnections

public int getNumOpenConnections()

Deprecated.

The number of open RPC conections

Specified by:

getNumOpenConnections in class RpcServer

Returns:

the number of open rpc connections