org.apache.hadoop.hbase.client

Class TestClientTimeouts.RandomTimeoutRpcClient

java.lang.Object

org.apache.hadoop.hbase.ipc.AbstractRpcClient

org.apache.hadoop.hbase.ipc.RpcClientImpl

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

All Implemented Interfaces:

Closeable, AutoCloseable, RpcClient

Enclosing class:

TestClientTimeouts

public static class TestClientTimeouts.RandomTimeoutRpcClient
extends RpcClientImpl

Rpc Channel implementation with RandomTimeoutBlockingRpcChannel

Nested Class Summary

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

RpcClientImpl.Connection

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

AbstractRpcClient.BlockingRpcChannelImplementation

Field Summary

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

callIdCnt, connections, failedServers, running, socketFactory, tokenHandlers

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
RandomTimeoutRpcClient(Configuration conf, String clusterId, SocketAddress localAddr)

Method Summary

Modifier and Type	Method and Description
BlockingRpcChannel	createBlockingRpcChannel(ServerName sn, User ticket, int rpcTimeout) Creates a "channel" that can be used by a blocking protobuf service.

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

call, cancelConnections, close, createConnection, getConnection, wrapException

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

getDefaultCodec, getPoolSize, getPoolType

Methods inherited from class java.lang.Object

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

Constructor Detail

RandomTimeoutRpcClient

public RandomTimeoutRpcClient(Configuration conf,
                              String clusterId,
                              SocketAddress localAddr)

Method Detail

createBlockingRpcChannel

public BlockingRpcChannel createBlockingRpcChannel(ServerName sn,
                                                   User ticket,
                                                   int rpcTimeout)

Description copied from interface: RpcClient

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

Specified by:

createBlockingRpcChannel in interface RpcClient

Overrides:

createBlockingRpcChannel in class AbstractRpcClient

Parameters:

sn - server name describing location of server

ticket - which is to use the connection

rpcTimeout - default rpc operation timeout

Returns:

A blocking rpc channel that goes via this rpc client instance.