Field Detail

• LOG

  private static final org.apache.commons.logging.Log LOG

• callIdCnt

  protected final AtomicInteger callIdCnt

• connections

  protected final PoolMap<ConnectionId,RpcClientImpl.Connection> connections

• running

  protected final AtomicBoolean running

• failedServers

  protected final FailedServers failedServers

• socketFactory

  protected final SocketFactory socketFactory

• tokenHandlers

  protected static final Map<org.apache.hadoop.hbase.protobuf.generated.AuthenticationProtos.TokenIdentifier.Kind,org.apache.hadoop.security.token.TokenSelector<? extends org.apache.hadoop.security.token.TokenIdentifier>> tokenHandlers

Constructor Detail

• RpcClientImpl

  RpcClientImpl(org.apache.hadoop.conf.Configuration conf,
               String clusterId,
               SocketFactory factory)

  Used in test only. Construct an IPC cluster client whose values are of the Message class.

  Parameters:

  conf - configuration

  clusterId - the cluster id

  factory - socket factory

• RpcClientImpl

  RpcClientImpl(org.apache.hadoop.conf.Configuration conf,
               String clusterId,
               SocketFactory factory,
               SocketAddress localAddr,
               MetricsConnection metrics)

  Construct an IPC cluster client whose values are of the Message class.

  Parameters:

  conf - configuration

  clusterId - the cluster id

  factory - socket factory

  localAddr - client socket bind address

  metrics - the connection metrics

• RpcClientImpl

  RpcClientImpl(org.apache.hadoop.conf.Configuration conf,
               String clusterId)

  Used in test only. Construct an IPC client for the cluster clusterId with the default SocketFactory

• RpcClientImpl

  public RpcClientImpl(org.apache.hadoop.conf.Configuration conf,
               String clusterId,
               SocketAddress localAddr,
               MetricsConnection metrics)

  Construct an IPC client for the cluster clusterId with the default SocketFactory This method is called with reflection by the RpcClientFactory to create an instance

  Parameters:

  conf - configuration

  clusterId - the cluster id

  localAddr - client socket bind address.

  metrics - the connection metrics

Method Detail

• createConnection

  protected RpcClientImpl.Connection createConnection(ConnectionId remoteId,
                                          Codec codec,
                                          org.apache.hadoop.io.compress.CompressionCodec compressor)
                                               throws IOException

  Creates a connection. Can be overridden by a subclass for testing.

  Parameters:

  remoteId - - the ConnectionId to use for the connection creation.

  Throws:

  IOException

• close

  public void close()

  Stop all threads related to this client. No further calls may be made using this client.

• 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,
                                                   MetricsConnection.CallStats callStats)
                                                        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

  IOException

• 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. their next retries should be faster and with a safe exception.

  Parameters:

  sn - server location to cancel connections of

• getConnection

  protected RpcClientImpl.Connection getConnection(User ticket,
                                       Call call,
                                       InetSocketAddress addr)
                                            throws IOException

  Get a connection from the pool, or create a new one and add it to the pool. Connections to a given host/port are reused.

  Throws:

  IOException