Uses of Class
org.apache.hadoop.hbase.ipc.SimpleServerRpcConnection
Packages that use SimpleServerRpcConnection
-
Uses of SimpleServerRpcConnection in org.apache.hadoop.hbase.ipc
Fields in org.apache.hadoop.hbase.ipc with type parameters of type SimpleServerRpcConnectionModifier and TypeFieldDescriptionprivate final Set<SimpleServerRpcConnection>SimpleRpcServer.ConnectionManager.connectionsprivate final LinkedBlockingQueue<SimpleServerRpcConnection>SimpleRpcServer.Listener.Reader.pendingConnectionsprivate final Set<SimpleServerRpcConnection>SimpleRpcServerResponder.writingConsDeprecated.Methods in org.apache.hadoop.hbase.ipc that return SimpleServerRpcConnectionModifier and TypeMethodDescriptionprotected SimpleServerRpcConnectionSimpleRpcServer.getConnection(SocketChannel channel, long time) Deprecated.Subclasses of HBaseServer can override this to provide their own Connection implementations.(package private) SimpleServerRpcConnectionSimpleServerCall.getConnection()Deprecated.(package private) SimpleServerRpcConnectionSimpleRpcServer.ConnectionManager.register(SocketChannel channel) (package private) SimpleServerRpcConnection[]SimpleRpcServer.ConnectionManager.toArray()Methods in org.apache.hadoop.hbase.ipc with parameters of type SimpleServerRpcConnectionModifier and TypeMethodDescriptionprivate booleanSimpleRpcServer.ConnectionManager.add(SimpleServerRpcConnection connection) voidSimpleRpcServer.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) booleanSimpleRpcServer.ConnectionManager.close(SimpleServerRpcConnection connection) protected voidSimpleRpcServer.closeConnection(SimpleServerRpcConnection connection) Deprecated.(package private) voidSimpleRpcServerResponder.doRespond(SimpleServerRpcConnection conn, RpcResponse resp) Deprecated.private booleanSimpleRpcServerResponder.processAllResponses(SimpleServerRpcConnection connection) Deprecated.Process all the responses for this connectionprivate booleanSimpleRpcServerResponder.processResponse(SimpleServerRpcConnection conn, RpcResponse resp) Deprecated.Process the response for this call.voidSimpleRpcServerResponder.registerForWrite(SimpleServerRpcConnection c) Deprecated.Add a connection to the list that want to write,private booleanSimpleRpcServer.ConnectionManager.remove(SimpleServerRpcConnection connection) Constructors in org.apache.hadoop.hbase.ipc with parameters of type SimpleServerRpcConnectionModifierConstructorDescription(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, CellScanner cellScanner, SimpleServerRpcConnection connection, long size, InetAddress remoteAddress, long receiveTime, int timeout, ByteBuffAllocator bbAllocator, CellBlockBuilder cellBlockBuilder, RpcServer.CallCleanup reqCleanup, SimpleRpcServerResponder responder) Deprecated.