Uses of Class
org.apache.hadoop.hbase.ipc.SimpleServerRpcConnection
-
Uses of SimpleServerRpcConnection in org.apache.hadoop.hbase.ipc
Modifier and TypeFieldDescriptionprivate final Set<SimpleServerRpcConnection>
SimpleRpcServer.ConnectionManager.connections
private final LinkedBlockingQueue<SimpleServerRpcConnection>
SimpleRpcServer.Listener.Reader.pendingConnections
private final Set<SimpleServerRpcConnection>
SimpleRpcServerResponder.writingCons
Deprecated.Modifier and TypeMethodDescriptionprotected SimpleServerRpcConnection
SimpleRpcServer.getConnection
(SocketChannel channel, long time) Deprecated.Subclasses of HBaseServer can override this to provide their own Connection implementations.(package private) SimpleServerRpcConnection
SimpleServerCall.getConnection()
Deprecated.(package private) SimpleServerRpcConnection
SimpleRpcServer.ConnectionManager.register
(SocketChannel channel) (package private) SimpleServerRpcConnection[]
SimpleRpcServer.ConnectionManager.toArray()
Modifier and TypeMethodDescriptionprivate boolean
SimpleRpcServer.ConnectionManager.add
(SimpleServerRpcConnection connection) void
SimpleRpcServer.Listener.Reader.addConnection
(SimpleServerRpcConnection conn) Updating the readSelector while it's being used is not thread-safe, so the connection must be queued.(package private) boolean
SimpleRpcServer.ConnectionManager.close
(SimpleServerRpcConnection connection) protected void
SimpleRpcServer.closeConnection
(SimpleServerRpcConnection connection) Deprecated.(package private) void
SimpleRpcServerResponder.doRespond
(SimpleServerRpcConnection conn, RpcResponse resp) Deprecated.private boolean
SimpleRpcServerResponder.processAllResponses
(SimpleServerRpcConnection connection) Deprecated.Process all the responses for this connectionprivate boolean
SimpleRpcServerResponder.processResponse
(SimpleServerRpcConnection conn, RpcResponse resp) Deprecated.Process the response for this call.void
SimpleRpcServerResponder.registerForWrite
(SimpleServerRpcConnection c) Deprecated.Add a connection to the list that want to write,private boolean
SimpleRpcServer.ConnectionManager.remove
(SimpleServerRpcConnection connection) ModifierConstructorDescription(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) Deprecated.