Package org.apache.hadoop.hbase.ipc

Class RpcConnection

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcConnection

Direct Known Subclasses:

BlockingRpcConnection, NettyRpcConnection

@Private
abstract class RpcConnection
extends Object

Base class for ipc connection.

Field Summary

Fields

Modifier and Type	Field	Description
protected final CellBlockBuilder	cellBlockBuilder
protected final Codec	codec
protected final org.apache.hadoop.io.compress.CompressionCodec	compressor
protected final org.apache.hadoop.conf.Configuration	conf
private final Map<String,byte[]>	connectionAttributes
protected static boolean	CRYPTO_AES_ENABLED_DEFAULT
protected static String	CRYPTO_AES_ENABLED_KEY
private String	lastSucceededServerPrincipal
protected long	lastTouched
private static final org.slf4j.Logger	LOG
protected final MetricsConnection	metrics
protected SaslClientAuthenticationProvider	provider
protected final int	reloginMaxBackoff
protected final ConnectionId	remoteId
protected final SecurityInfo	securityInfo
protected final org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer	timeoutTimer
protected final org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier>	token
protected final boolean	useSasl

Constructor Summary

Constructors

Modifier	Constructor	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, CellBlockBuilder cellBlockBuilder, MetricsConnection metrics, Map<String,byte[]> connectionAttributes)

Method Summary

Modifier and Type	Method	Description
protected abstract void	callTimeout(Call call)
protected final String	chooseServerPrincipal(Set<String> candidates, Call securityPreambleCall)
abstract void	cleanupConnection()	Does the clean up work after the connection is removed from the connection pool
protected final Call	createSecurityPreambleCall(org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<Call> callback)
private <T extends InputStream & DataInput> void	finishCall(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ResponseHeader responseHeader, T in, Call call)
protected final org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader	getConnectionHeader()
protected byte[]	getConnectionHeaderPreamble()
private static String	getHostnameForServerPrincipal(org.apache.hadoop.conf.Configuration conf, InetAddress addr)
long	getLastTouched()
protected final InetSocketAddress	getRemoteInetAddress(MetricsConnection metrics)
private static String	getServerPrincipal(org.apache.hadoop.conf.Configuration conf, String serverKey, InetAddress server)
protected final Set<String>	getServerPrincipals()
abstract boolean	isActive()	Tell the idle connection sweeper whether we could be swept.
protected final boolean	isKerberosAuth()
protected final <T> T	randomSelect(Collection<T> c)
(package private) <T extends InputStream & DataInput> void	readResponse(T in, Map<Integer,Call> id2Call, Call preambleCall, Consumer<org.apache.hadoop.ipc.RemoteException> fatalConnectionErrorConsumer)
ConnectionId	remoteId()
protected final void	saslNegotiationDone(String serverPrincipal, boolean succeed)
protected final void	scheduleTimeoutTask(Call call)
abstract void	sendRequest(Call call, HBaseRpcController hrc)
void	setLastTouched(long lastTouched)
abstract void	shutdown()	Just close connection.
private static boolean	useCanonicalHostname(org.apache.hadoop.conf.Configuration conf)

Methods inherited from class java.lang.Object

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

Field Details

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

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

cellBlockBuilder

protected final CellBlockBuilder cellBlockBuilder

metrics

protected final MetricsConnection metrics

connectionAttributes

private final Map<String,byte[]> connectionAttributes

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

lastSucceededServerPrincipal

private String lastSucceededServerPrincipal

Constructor Details

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,
 CellBlockBuilder cellBlockBuilder,
 MetricsConnection metrics,
 Map<String,byte[]> connectionAttributes)
                 throws IOException

Throws:

IOException

Method Details

scheduleTimeoutTask

protected final void scheduleTimeoutTask(Call call)

getConnectionHeaderPreamble

protected byte[] getConnectionHeaderPreamble()

getConnectionHeader

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

getRemoteInetAddress

protected final InetSocketAddress getRemoteInetAddress(MetricsConnection metrics)
                                                throws UnknownHostException

Throws:

UnknownHostException

useCanonicalHostname

private static boolean useCanonicalHostname(org.apache.hadoop.conf.Configuration conf)

getHostnameForServerPrincipal

private static String getHostnameForServerPrincipal(org.apache.hadoop.conf.Configuration conf,
 InetAddress addr)

getServerPrincipal

private static String getServerPrincipal(org.apache.hadoop.conf.Configuration conf,
 String serverKey,
 InetAddress server)
                                  throws IOException

Throws:

IOException

isKerberosAuth

protected final boolean isKerberosAuth()

getServerPrincipals

protected final Set<String> getServerPrincipals()
                                         throws IOException

Throws:

IOException

randomSelect

protected final <T> T randomSelect(Collection<T> c)

chooseServerPrincipal

protected final String chooseServerPrincipal(Set<String> candidates,
 Call securityPreambleCall)
                                      throws SaslException

Throws:

SaslException

saslNegotiationDone

protected final void saslNegotiationDone(String serverPrincipal,
 boolean succeed)

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

createSecurityPreambleCall

protected final Call createSecurityPreambleCall(org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<Call> callback)

finishCall

private <T extends InputStream & DataInput> void finishCall(org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ResponseHeader responseHeader,
 T in,
 Call call)
                                                     throws IOException

Throws:

IOException

readResponse

<T extends InputStream & DataInput> void readResponse(T in,
 Map<Integer,Call> id2Call,
 Call preambleCall,
 Consumer<org.apache.hadoop.ipc.RemoteException> fatalConnectionErrorConsumer)
                                               throws IOException

Throws:

IOException