Package org.apache.hadoop.hbase.ipc
Interface RpcServerInterface
- All Known Implementing Classes:
NettyRpcServer
,RpcServer
,SimpleRpcServer
-
Method Summary
Modifier and TypeMethodDescriptionvoid
addCallSize
(long diff) Add/subtract from the current size of all outstanding calls.Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,
ExtendedCellScanner> call
(RpcCall call, MonitoredRPCHandler status) Allocator to allocate/free the ByteBuffers, those ByteBuffers can be on-heap or off-heap.Returns the metrics instance for reporting RPC call statisticsboolean
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
setNamedQueueRecorder
(NamedQueueRecorder namedQueueRecorder) Set Online SlowLog Providervoid
setRsRpcServices
(RSRpcServices rsRpcServices) void
setSocketSendBufSize
(int size) void
start()
void
stop()
-
Method Details
-
start
void start() -
isStarted
boolean isStarted() -
stop
void stop() -
join
- Throws:
InterruptedException
-
setSocketSendBufSize
-
getListenerAddress
-
call
Pair<org.apache.hbase.thirdparty.com.google.protobuf.Message,ExtendedCellScanner> call(RpcCall call, MonitoredRPCHandler status) throws IOException - Throws:
IOException
-
setErrorHandler
-
getErrorHandler
-
getMetrics
Returns the metrics instance for reporting RPC call statistics -
addCallSize
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. -
getScheduler
-
getByteBuffAllocator
Allocator to allocate/free the ByteBuffers, those ByteBuffers can be on-heap or off-heap.- Returns:
- byte buffer allocator
-
setRsRpcServices
-
setNamedQueueRecorder
Set Online SlowLog Provider- Parameters:
namedQueueRecorder
- instance ofNamedQueueRecorder
-