Package org.apache.hadoop.hbase.ipc

Class TestRpcClientLeaks.MyRpcClientImpl

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.ipc.TestRpcClientLeaks.MyRpcClientImpl

All Implemented Interfaces:

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

Enclosing class:

TestRpcClientLeaks

public static class TestRpcClientLeaks.MyRpcClientImpl
extends org.apache.hadoop.hbase.ipc.BlockingRpcClient

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

Modifier and Type	Field	Description
private static boolean	throwException

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, connectionAttributes, 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, REGISTRY_PREAMBLE_HEADER, SECURITY_PREAMBLE_HEADER, SOCKET_TIMEOUT_CONNECT, SOCKET_TIMEOUT_READ, SOCKET_TIMEOUT_WRITE, SPECIFIC_WRITE_THREAD

Constructor Summary

Constructors

Constructor	Description
MyRpcClientImpl(org.apache.hadoop.conf.Configuration conf)
MyRpcClientImpl(org.apache.hadoop.conf.Configuration conf, String clusterId, SocketAddress address, org.apache.hadoop.hbase.client.MetricsConnection metrics, Map<String,byte[]> connectionAttributes)

Method Summary

Modifier and Type	Method	Description
protected org.apache.hadoop.hbase.ipc.BlockingRpcConnection	createConnection(org.apache.hadoop.hbase.ipc.ConnectionId remoteId)
static void	enableThrowExceptions()

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

closeInternal

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

cancelConnections, close, configureHBaseRpcController, createAddr, createBlockingRpcChannel, createRpcChannel, getCodec, getConnections, getDefaultCodec, hasCellBlockSupport, isTcpNoDelay

Methods inherited from class java.lang.Object

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

Field Details

throwException

private static boolean throwException

Constructor Details

MyRpcClientImpl

public MyRpcClientImpl(org.apache.hadoop.conf.Configuration conf)

MyRpcClientImpl

public MyRpcClientImpl(org.apache.hadoop.conf.Configuration conf,
 String clusterId,
 SocketAddress address,
 org.apache.hadoop.hbase.client.MetricsConnection metrics,
 Map<String,byte[]> connectionAttributes)

Method Details

createConnection

protected org.apache.hadoop.hbase.ipc.BlockingRpcConnection createConnection(org.apache.hadoop.hbase.ipc.ConnectionId remoteId)
                                                                      throws IOException

Overrides:

createConnection in class org.apache.hadoop.hbase.ipc.BlockingRpcClient

Throws:

IOException

enableThrowExceptions

public static void enableThrowExceptions()