org.apache.hadoop.hbase.ipc

Class NettyRpcConnection

java.lang.Object

org.apache.hadoop.hbase.ipc.RpcConnection

org.apache.hadoop.hbase.ipc.NettyRpcConnection

@InterfaceAudience.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 and 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 org.apache.hbase.thirdparty.io.netty.channel.EventLoop	eventLoop
private static org.slf4j.Logger	LOG
private static ScheduledExecutorService	RELOGIN_EXECUTOR
private boolean	reloginInProgress
private NettyRpcClient	rpcClient

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

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

Constructor Summary

Constructors

Constructor and Description
NettyRpcConnection(NettyRpcClient rpcClient, ConnectionId remoteId)

Method Summary

Modifier and Type	Method and 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()
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)
boolean	isActive() Tell the idle connection sweeper whether we could be swept.
private void	saslNegotiate(org.apache.hbase.thirdparty.io.netty.channel.Channel ch)
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

getConnectionHeader, getConnectionHeaderPreamble, getLastTouched, remoteId, scheduleTimeoutTask, setLastTouched

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

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 Detail

NettyRpcConnection

NettyRpcConnection(NettyRpcClient rpcClient,
                   ConnectionId remoteId)
            throws IOException

Throws:

IOException

Method Detail

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)
                  throws IOException

Throws:

IOException

scheduleRelogin

private void scheduleRelogin(Throwable error)

failInit

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

saslNegotiate

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

connect

private void connect()

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