org.apache.hadoop.hbase.client

Class TestClientTimeouts.RandomTimeoutRpcClient

java.lang.Object

org.apache.hadoop.hbase.ipc.AbstractRpcClient<org.apache.hadoop.hbase.ipc.BlockingRpcConnection>

org.apache.hadoop.hbase.ipc.BlockingRpcClient

org.apache.hadoop.hbase.client.TestClientTimeouts.RandomTimeoutRpcClient

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.hbase.ipc.RpcClient

Enclosing class:

TestClientTimeouts

public static class TestClientTimeouts.RandomTimeoutRpcClient
extends org.apache.hadoop.hbase.ipc.BlockingRpcClient

Rpc Channel implementation with RandomTimeoutBlockingRpcChannel

Nested Class Summary

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

org.apache.hadoop.hbase.ipc.AbstractRpcClient.BlockingRpcChannelImplementation, org.apache.hadoop.hbase.ipc.AbstractRpcClient.RpcChannelImplementation

Field Summary

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

socketFactory

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

cellBlockBuilder, clusterId, codec, compressor, conf, connectTO, failedServers, failureSleep, fallbackAllowed, localAddr, LOG, maxRetries, metrics, minIdleTimeBeforeClose, readTO, tcpKeepAlive, tcpNoDelay, userProvider, WHEEL_TIMER, 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
RandomTimeoutRpcClient(org.apache.hadoop.conf.Configuration conf, String clusterId, SocketAddress localAddr, org.apache.hadoop.hbase.client.MetricsConnection metrics)

Method Summary

Modifier and Type	Method and Description
org.apache.hbase.thirdparty.com.google.protobuf.BlockingRpcChannel	createBlockingRpcChannel(org.apache.hadoop.hbase.ServerName sn, org.apache.hadoop.hbase.security.User ticket, int rpcTimeout)
org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel	createRpcChannel(org.apache.hadoop.hbase.ServerName sn, org.apache.hadoop.hbase.security.User ticket, int rpcTimeout)

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

closeInternal, createConnection

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

cancelConnections, close, getDefaultCodec, hasCellBlockSupport

Methods inherited from class java.lang.Object

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

Constructor Detail

RandomTimeoutRpcClient

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

Method Detail

createBlockingRpcChannel

public org.apache.hbase.thirdparty.com.google.protobuf.BlockingRpcChannel createBlockingRpcChannel(org.apache.hadoop.hbase.ServerName sn,
                                                                                                   org.apache.hadoop.hbase.security.User ticket,
                                                                                                   int rpcTimeout)

Specified by:

createBlockingRpcChannel in interface org.apache.hadoop.hbase.ipc.RpcClient

Overrides:

createBlockingRpcChannel in class org.apache.hadoop.hbase.ipc.AbstractRpcClient<org.apache.hadoop.hbase.ipc.BlockingRpcConnection>

createRpcChannel

public org.apache.hbase.thirdparty.com.google.protobuf.RpcChannel createRpcChannel(org.apache.hadoop.hbase.ServerName sn,
                                                                                   org.apache.hadoop.hbase.security.User ticket,
                                                                                   int rpcTimeout)

Specified by:

createRpcChannel in interface org.apache.hadoop.hbase.ipc.RpcClient

Overrides:

createRpcChannel in class org.apache.hadoop.hbase.ipc.AbstractRpcClient<org.apache.hadoop.hbase.ipc.BlockingRpcConnection>