Tools to help define network clients and servers.
-
(package private)
NettyServerCall(int id,
org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
ExtendedCellScanner cellScanner,
NettyServerRpcConnection connection,
long size,
InetAddress remoteAddress,
long receiveTime,
int timeout,
ByteBuffAllocator bbAllocator,
CellBlockBuilder cellBlockBuilder,
RpcServer.CallCleanup reqCleanup)
protected
RpcConnection(org.apache.hadoop.conf.Configuration conf,
org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer timeoutTimer,
ConnectionId remoteId,
String clusterId,
boolean isSecurityEnabled,
Codec codec,
org.apache.hadoop.io.compress.CompressionCodec compressor,
CellBlockBuilder cellBlockBuilder,
MetricsConnection metrics,
Map<String,byte[]> connectionAttributes)
(package private)
ServerCall(int id,
org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
ExtendedCellScanner cellScanner,
T connection,
long size,
InetAddress remoteAddress,
long receiveTime,
int timeout,
ByteBuffAllocator byteBuffAllocator,
CellBlockBuilder cellBlockBuilder,
RpcServer.CallCleanup reqCleanup)
(package private)
SimpleServerCall(int id,
org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header,
org.apache.hbase.thirdparty.com.google.protobuf.Message param,
ExtendedCellScanner cellScanner,
SimpleServerRpcConnection connection,
long size,
InetAddress remoteAddress,
long receiveTime,
int timeout,
ByteBuffAllocator bbAllocator,
CellBlockBuilder cellBlockBuilder,
RpcServer.CallCleanup reqCleanup,
SimpleRpcServerResponder responder)