org.apache.hadoop.hbase.ipc

Interface RpcServerInterface

All Known Implementing Classes:

NettyRpcServer, RpcServer, SimpleRpcServer

@InterfaceAudience.Private
public interface RpcServerInterface

Method Summary

Modifier and Type	Method and Description
void	addCallSize(long diff) Add/subtract from the current size of all outstanding calls.
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. As of release 1.3, this will be removed in HBase 3.0
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. As of release 2.0, this will be removed in HBase 3.0
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner>	call(RpcCall call, MonitoredRPCHandler status)
ByteBuffAllocator	getByteBuffAllocator() Allocator to allocate/free the ByteBuffers, those ByteBuffers can be on-heap or off-heap.
HBaseRPCErrorHandler	getErrorHandler()
InetSocketAddress	getListenerAddress()
MetricsHBaseServer	getMetrics() Returns the metrics instance for reporting RPC call statistics
RpcScheduler	getScheduler()
SlowLogRecorder	getSlowLogRecorder()
boolean	isStarted()
void	join()
void	refreshAuthManager(org.apache.hadoop.conf.Configuration conf, org.apache.hadoop.security.authorize.PolicyProvider pp) Refresh authentication manager policy.
void	setErrorHandler(HBaseRPCErrorHandler handler)
void	setRsRpcServices(RSRpcServices rsRpcServices)
void	setSlowLogRecorder(SlowLogRecorder slowLogRecorder) Set Online SlowLog Provider
void	setSocketSendBufSize(int size)
void	start()
void	stop()

Method Detail

start

void start()

isStarted

boolean isStarted()

stop

void stop()

join

void join()
   throws InterruptedException

Throws:

InterruptedException

setSocketSendBufSize

void setSocketSendBufSize(int size)

getListenerAddress

InetSocketAddress getListenerAddress()

call

@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)
                                                                                    throws IOException

Deprecated. As of release 1.3, this will be removed in HBase 3.0

Throws:

IOException

call

@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)
                                                                                    throws IOException

Deprecated. As of release 2.0, this will be removed in HBase 3.0

Throws:

IOException

call

Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,CellScanner> call(RpcCall call,
                                                                               MonitoredRPCHandler status)
                                                                        throws IOException

Throws:

IOException

setErrorHandler

void setErrorHandler(HBaseRPCErrorHandler handler)

getErrorHandler

HBaseRPCErrorHandler getErrorHandler()

getMetrics

MetricsHBaseServer getMetrics()

Returns the metrics instance for reporting RPC call statistics

addCallSize

void addCallSize(long diff)

Add/subtract from the current size of all outstanding calls. Called on setup of a call to add call total size and then again at end of a call to remove the call size.

Parameters:

diff - Change (plus or minus)

refreshAuthManager

void refreshAuthManager(org.apache.hadoop.conf.Configuration conf,
                        org.apache.hadoop.security.authorize.PolicyProvider pp)

Refresh authentication manager policy.

Parameters:

pp -

getScheduler

RpcScheduler getScheduler()

getByteBuffAllocator

ByteBuffAllocator getByteBuffAllocator()

Allocator to allocate/free the ByteBuffers, those ByteBuffers can be on-heap or off-heap.

Returns:

byte buffer allocator

setRsRpcServices

void setRsRpcServices(RSRpcServices rsRpcServices)

setSlowLogRecorder

void setSlowLogRecorder(SlowLogRecorder slowLogRecorder)

Set Online SlowLog Provider

Parameters:

slowLogRecorder - instance of SlowLogRecorder

getSlowLogRecorder

SlowLogRecorder getSlowLogRecorder()

Returns:

Retrieve instance of SlowLogRecorder maintained by RpcServer