org.apache.hadoop.hbase.ipc

Class RpcConnection

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcConnection

Direct Known Subclasses:

BlockingRpcConnection, NettyRpcConnection

@InterfaceAudience.Private
abstract class RpcConnection
extends Object

Base class for ipc connection.

Field Summary

Fields

Modifier and Type	Field and Description
protected Codec	codec
protected org.apache.hadoop.io.compress.CompressionCodec	compressor
protected org.apache.hadoop.conf.Configuration	conf
protected static boolean	CRYPTO_AES_ENABLED_DEFAULT
protected static String	CRYPTO_AES_ENABLED_KEY
protected long	lastTouched
private static org.slf4j.Logger	LOG
protected SaslClientAuthenticationProvider	provider
protected int	reloginMaxBackoff
protected ConnectionId	remoteId
protected SecurityInfo	securityInfo
protected InetAddress	serverAddress
protected org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer	timeoutTimer
protected org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier>	token
protected boolean	useSasl

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	RpcConnection(org.apache.hadoop.conf.Configuration conf, org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer timeoutTimer, ConnectionId remoteId, String clusterId, boolean isSecurityEnabled, Codec codec, org.apache.hadoop.io.compress.CompressionCodec compressor)

Method Summary

Modifier and Type	Method and Description
protected abstract void	callTimeout(Call call)
abstract void	cleanupConnection() Does the clean up work after the connection is removed from the connection pool
protected org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader	getConnectionHeader()
protected byte[]	getConnectionHeaderPreamble()
long	getLastTouched()
abstract boolean	isActive() Tell the idle connection sweeper whether we could be swept.
ConnectionId	remoteId()
protected void	scheduleTimeoutTask(Call call)
abstract void	sendRequest(Call call, HBaseRpcController hrc)
void	setLastTouched(long lastTouched)
abstract void	shutdown() Just close connection.

Methods inherited from class java.lang.Object

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

Field Detail

LOG

private static final org.slf4j.Logger LOG

remoteId

protected final ConnectionId remoteId

useSasl

protected final boolean useSasl

token

protected final org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> token

serverAddress

protected final InetAddress serverAddress

securityInfo

protected final SecurityInfo securityInfo

reloginMaxBackoff

protected final int reloginMaxBackoff

codec

protected final Codec codec

compressor

protected final org.apache.hadoop.io.compress.CompressionCodec compressor

timeoutTimer

protected final org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer timeoutTimer

conf

protected final org.apache.hadoop.conf.Configuration conf

CRYPTO_AES_ENABLED_KEY

protected static String CRYPTO_AES_ENABLED_KEY

CRYPTO_AES_ENABLED_DEFAULT

protected static boolean CRYPTO_AES_ENABLED_DEFAULT

lastTouched

protected long lastTouched

provider

protected SaslClientAuthenticationProvider provider

Constructor Detail

RpcConnection

protected RpcConnection(org.apache.hadoop.conf.Configuration conf,
                        org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer timeoutTimer,
                        ConnectionId remoteId,
                        String clusterId,
                        boolean isSecurityEnabled,
                        Codec codec,
                        org.apache.hadoop.io.compress.CompressionCodec compressor)
                 throws IOException

Throws:

IOException

Method Detail

scheduleTimeoutTask

protected void scheduleTimeoutTask(Call call)

getConnectionHeaderPreamble

protected byte[] getConnectionHeaderPreamble()

getConnectionHeader

protected org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader getConnectionHeader()

callTimeout

protected abstract void callTimeout(Call call)

remoteId

public ConnectionId remoteId()

getLastTouched

public long getLastTouched()

setLastTouched

public void setLastTouched(long lastTouched)

isActive

public abstract boolean isActive()

Tell the idle connection sweeper whether we could be swept.

shutdown

public abstract void shutdown()

Just close connection. Do not need to remove from connection pool.

sendRequest

public abstract void sendRequest(Call call,
                                 HBaseRpcController hrc)
                          throws IOException

Throws:

IOException

cleanupConnection

public abstract void cleanupConnection()

Does the clean up work after the connection is removed from the connection pool