Package org.apache.hadoop.hbase.ipc

Class NettyRpcConnection

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcConnection

org.apache.hadoop.hbase.ipc.NettyRpcConnection

@Private
class NettyRpcConnection
extends RpcConnection

RPC connection implementation based on netty.

Most operations are executed in handlers. Netty handler is always executed in the same thread(EventLoop) so no lock is needed.

Implementation assumptions: All the private methods should be called in the eventLoop thread, otherwise there will be races.

Since:

2.0.0

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hbase.thirdparty.io.netty.channel.Channel	channel
private org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf	connectionHeaderPreamble
private org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf	connectionHeaderWithLength
private final org.apache.hbase.thirdparty.io.netty.channel.EventLoop	eventLoop
private static final org.slf4j.Logger	LOG
private static final ScheduledExecutorService	RELOGIN_EXECUTOR
private boolean	reloginInProgress
private final NettyRpcClient	rpcClient

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

cellBlockBuilder, codec, compressor, conf, CRYPTO_AES_ENABLED_DEFAULT, CRYPTO_AES_ENABLED_KEY, lastTouched, metrics, provider, reloginMaxBackoff, remoteId, securityInfo, timeoutTimer, token, useSasl

Constructor Summary

Constructors

Constructor	Description
NettyRpcConnection(NettyRpcClient rpcClient, ConnectionId remoteId)

Method Summary

Modifier and Type	Method	Description
protected void	callTimeout(Call call)
void	cleanupConnection()	Does the clean up work after the connection is removed from the connection pool
private void	connect(Call connectionRegistryCall)
private void	established(org.apache.hbase.thirdparty.io.netty.channel.Channel ch)
private void	failInit(org.apache.hbase.thirdparty.io.netty.channel.Channel ch, IOException e)
private void	getConnectionRegistry(org.apache.hbase.thirdparty.io.netty.channel.Channel ch, Call connectionRegistryCall)
boolean	isActive()	Tell the idle connection sweeper whether we could be swept.
private void	onSecurityPreambleError(org.apache.hbase.thirdparty.io.netty.channel.Channel ch, Set<String> serverPrincipals, IOException error)
private void	onSecurityPreambleFinish(org.apache.hbase.thirdparty.io.netty.channel.Channel ch, Set<String> serverPrincipals, Call securityPreambleCall)
private void	saslEstablished(org.apache.hbase.thirdparty.io.netty.channel.Channel ch, String serverPrincipal)
private void	saslFailInit(org.apache.hbase.thirdparty.io.netty.channel.Channel ch, String serverPrincipal, IOException error)
private void	saslNegotiate(org.apache.hbase.thirdparty.io.netty.channel.Channel ch)
private void	saslNegotiate(org.apache.hbase.thirdparty.io.netty.channel.Channel ch, String serverPrincipal)
private void	scheduleRelogin(Throwable error)
void	sendRequest(Call call, HBaseRpcController hrc)
private void	sendRequest0(Call call, HBaseRpcController hrc)
void	shutdown()	Just close connection.
private void	shutdown0()

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

chooseServerPrincipal, createSecurityPreambleCall, getConnectionHeader, getConnectionHeaderPreamble, getLastTouched, getRemoteInetAddress, getServerPrincipals, isKerberosAuth, randomSelect, readResponse, remoteId, saslNegotiationDone, scheduleTimeoutTask, setLastTouched

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

RELOGIN_EXECUTOR

private static final ScheduledExecutorService RELOGIN_EXECUTOR

rpcClient

private final NettyRpcClient rpcClient

eventLoop

private final org.apache.hbase.thirdparty.io.netty.channel.EventLoop eventLoop

connectionHeaderPreamble

private org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf connectionHeaderPreamble

connectionHeaderWithLength

private org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf connectionHeaderWithLength

channel

private volatile org.apache.hbase.thirdparty.io.netty.channel.Channel channel

reloginInProgress

private boolean reloginInProgress

Constructor Details

NettyRpcConnection

NettyRpcConnection(NettyRpcClient rpcClient,
 ConnectionId remoteId)
            throws IOException

Throws:

IOException

Method Details

callTimeout

protected void callTimeout(Call call)

Specified by:

callTimeout in class RpcConnection

isActive

public boolean isActive()

Description copied from class: RpcConnection

Tell the idle connection sweeper whether we could be swept.

Specified by:

isActive in class RpcConnection

shutdown0

private void shutdown0()

shutdown

public void shutdown()

Description copied from class: RpcConnection

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

Specified by:

shutdown in class RpcConnection

cleanupConnection

public void cleanupConnection()

Description copied from class: RpcConnection

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

Specified by:

cleanupConnection in class RpcConnection

established

private void established(org.apache.hbase.thirdparty.io.netty.channel.Channel ch)

saslEstablished

private void saslEstablished(org.apache.hbase.thirdparty.io.netty.channel.Channel ch,
 String serverPrincipal)

scheduleRelogin

private void scheduleRelogin(Throwable error)

failInit

private void failInit(org.apache.hbase.thirdparty.io.netty.channel.Channel ch,
 IOException e)

saslFailInit

private void saslFailInit(org.apache.hbase.thirdparty.io.netty.channel.Channel ch,
 String serverPrincipal,
 IOException error)

saslNegotiate

private void saslNegotiate(org.apache.hbase.thirdparty.io.netty.channel.Channel ch,
 String serverPrincipal)

getConnectionRegistry

private void getConnectionRegistry(org.apache.hbase.thirdparty.io.netty.channel.Channel ch,
 Call connectionRegistryCall)

onSecurityPreambleError

private void onSecurityPreambleError(org.apache.hbase.thirdparty.io.netty.channel.Channel ch,
 Set<String> serverPrincipals,
 IOException error)

onSecurityPreambleFinish

private void onSecurityPreambleFinish(org.apache.hbase.thirdparty.io.netty.channel.Channel ch,
 Set<String> serverPrincipals,
 Call securityPreambleCall)

saslNegotiate

private void saslNegotiate(org.apache.hbase.thirdparty.io.netty.channel.Channel ch)
                    throws IOException

Throws:

IOException

connect

private void connect(Call connectionRegistryCall)
              throws UnknownHostException

Throws:

UnknownHostException

sendRequest0

private void sendRequest0(Call call,
 HBaseRpcController hrc)
                   throws IOException

Throws:

IOException

sendRequest

public void sendRequest(Call call,
 HBaseRpcController hrc)

Specified by:

sendRequest in class RpcConnection