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 AuthMethod	authMethod
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 int	reloginMaxBackoff
protected ConnectionId	remoteId
protected String	serverPrincipal
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()
protected org.apache.hadoop.security.UserGroupInformation	getUGI()
private org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.UserInformation	getUserInfo(org.apache.hadoop.security.UserGroupInformation ugi)
abstract boolean	isActive() Tell the idle connection sweeper whether we could be swept.
protected void	relogin()
ConnectionId	remoteId()
protected void	scheduleTimeoutTask(Call call)
abstract void	sendRequest(Call call, HBaseRpcController hrc)
void	setLastTouched(long lastTouched)
protected boolean	shouldAuthenticateOverKrb()
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

authMethod

protected final AuthMethod authMethod

useSasl

protected final boolean useSasl

token

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

serverPrincipal

protected final String serverPrincipal

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

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

getUserInfo

private org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.UserInformation getUserInfo(org.apache.hadoop.security.UserGroupInformation ugi)

getUGI

protected org.apache.hadoop.security.UserGroupInformation getUGI()

shouldAuthenticateOverKrb

protected boolean shouldAuthenticateOverKrb()
                                     throws IOException

Throws:

IOException

relogin

protected void relogin()
                throws IOException

Throws:

IOException

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