org.apache.hadoop.hbase.ipc

Class AsyncRpcClient

java.lang.Object

org.apache.hadoop.hbase.ipc.AbstractRpcClient

org.apache.hadoop.hbase.ipc.AsyncRpcClient

All Implemented Interfaces:

Closeable, AutoCloseable, RpcClient

@InterfaceAudience.LimitedPrivate(value="Configuration")
public class AsyncRpcClient
extends AbstractRpcClient

Netty client for the requests and responses

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AsyncRpcClient.RpcChannelImplementation Blocking rpc channel that goes via hbase rpc.

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.ipc.AbstractRpcClient

AbstractRpcClient.BlockingRpcChannelImplementation

Field Summary

Fields

Modifier and Type	Field and Description
protected AtomicInteger	callIdCnt
static String	CLIENT_MAX_THREADS
static String	USE_GLOBAL_EVENT_LOOP_GROUP
static String	USE_NATIVE_TRANSPORT

Fields inherited from class org.apache.hadoop.hbase.ipc.AbstractRpcClient

clusterId, codec, compressor, conf, connectTO, failureSleep, fallbackAllowed, ipcUtil, localAddr, LOG, maxRetries, minIdleTimeBeforeClose, readTO, tcpKeepAlive, tcpNoDelay, userProvider, writeTO

Fields inherited from interface org.apache.hadoop.hbase.ipc.RpcClient

DEFAULT_CODEC_CLASS, DEFAULT_SOCKET_TIMEOUT_CONNECT, DEFAULT_SOCKET_TIMEOUT_READ, DEFAULT_SOCKET_TIMEOUT_WRITE, FAILED_SERVER_EXPIRY_DEFAULT, FAILED_SERVER_EXPIRY_KEY, IDLE_TIME, IPC_CLIENT_FALLBACK_TO_SIMPLE_AUTH_ALLOWED_DEFAULT, IPC_CLIENT_FALLBACK_TO_SIMPLE_AUTH_ALLOWED_KEY, PING_CALL_ID, SOCKET_TIMEOUT_CONNECT, SOCKET_TIMEOUT_READ, SOCKET_TIMEOUT_WRITE, SPECIFIC_WRITE_THREAD

Constructor Summary

Constructors

Constructor and Description
AsyncRpcClient(org.apache.hadoop.conf.Configuration configuration, String clusterId, SocketAddress localAddress) Constructor

Method Summary

Methods

Modifier and Type	Method and Description
ByteBuffer	buildCellBlock(CellScanner cells) Build cell block
protected Pair<com.google.protobuf.Message,CellScanner>	call(PayloadCarryingRpcController pcrc, com.google.protobuf.Descriptors.MethodDescriptor md, com.google.protobuf.Message param, com.google.protobuf.Message returnType, User ticket, InetSocketAddress addr) Make a call, passing param, to the IPC server running at address which is servicing the protocol protocol, with the ticket credentials, returning the value.
void	cancelConnections(ServerName sn) Interrupt the connections to the given ip:port server.
void	close() Close netty
CellScanner	createCellScanner(byte[] cellBlock) Create a cell scanner
com.google.protobuf.RpcChannel	createRpcChannel(ServerName sn, User user, int rpcTimeout) Creates a "channel" that can be used by a protobuf service.
void	removeConnection(AsyncRpcChannel connection) Remove connection from pool

Methods inherited from class org.apache.hadoop.hbase.ipc.AbstractRpcClient

createBlockingRpcChannel, getDefaultCodec, getPoolSize, getPoolType, hasCellBlockSupport, wrapException

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

CLIENT_MAX_THREADS

public static final String CLIENT_MAX_THREADS

See Also:

Constant Field Values

USE_NATIVE_TRANSPORT

public static final String USE_NATIVE_TRANSPORT

See Also:

Constant Field Values

USE_GLOBAL_EVENT_LOOP_GROUP

public static final String USE_GLOBAL_EVENT_LOOP_GROUP

See Also:

Constant Field Values

callIdCnt

protected final AtomicInteger callIdCnt

Constructor Detail

AsyncRpcClient

public AsyncRpcClient(org.apache.hadoop.conf.Configuration configuration,
              String clusterId,
              SocketAddress localAddress)

Constructor

Parameters:

configuration - to HBase

clusterId - for the cluster

localAddress - local address to connect to

Method Detail

call

protected Pair<com.google.protobuf.Message,CellScanner> call(PayloadCarryingRpcController pcrc,
                                                 com.google.protobuf.Descriptors.MethodDescriptor md,
                                                 com.google.protobuf.Message param,
                                                 com.google.protobuf.Message returnType,
                                                 User ticket,
                                                 InetSocketAddress addr)
                                                      throws IOException,
                                                             InterruptedException

Make a call, passing param, to the IPC server running at address which is servicing the protocol protocol, with the ticket credentials, returning the value. Throws exceptions if there are network problems or if the remote code threw an exception.

Specified by:

call in class AbstractRpcClient

Parameters:

ticket - Be careful which ticket you pass. A new user will mean a new Connection. UserProvider.getCurrent() makes a new instance of User each time so will be a new Connection each time.

Returns:

A pair with the Message response and the Cell data (if any).

Throws:

InterruptedException - if call is interrupted

IOException - if a connection failure is encountered

close

public void close()

Close netty

createCellScanner

public CellScanner createCellScanner(byte[] cellBlock)
                              throws IOException

Create a cell scanner

Parameters:

cellBlock - to create scanner for

Returns:

CellScanner

Throws:

IOException - on error on creation cell scanner

buildCellBlock

public ByteBuffer buildCellBlock(CellScanner cells)
                          throws IOException

Build cell block

Parameters:

cells - to create block with

Returns:

ByteBuffer with cells

Throws:

IOException - if block creation fails

cancelConnections

public void cancelConnections(ServerName sn)

Interrupt the connections to the given ip:port server. This should be called if the server is known as actually dead. This will not prevent current operation to be retried, and, depending on their own behavior, they may retry on the same server. This can be a feature, for example at startup. In any case, they're likely to get connection refused (if the process died) or no route to host: i.e. there next retries should be faster and with a safe exception.

Parameters:

sn - server to cancel connections for

removeConnection

public void removeConnection(AsyncRpcChannel connection)

Remove connection from pool

createRpcChannel

public com.google.protobuf.RpcChannel createRpcChannel(ServerName sn,
                                              User user,
                                              int rpcTimeout)

Creates a "channel" that can be used by a protobuf service. Useful setting up protobuf stubs.

Parameters:

sn - server name describing location of server

user - which is to use the connection

rpcTimeout - default rpc operation timeout

Returns:

A rpc channel that goes via this rpc client instance.

Throws:

IOException - when channel could not be created