Package org.apache.hadoop.hbase.ipc

Class NettyServerRpcConnection

java.lang.Object

org.apache.hadoop.hbase.ipc.ServerRpcConnection

org.apache.hadoop.hbase.ipc.NettyServerRpcConnection

All Implemented Interfaces:

Closeable, AutoCloseable

@Private
class NettyServerRpcConnection
extends ServerRpcConnection

RpcConnection implementation for netty rpc server.

Since:

2.0.0

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.ipc.ServerRpcConnection

ServerRpcConnection.PreambleResponse

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final org.apache.hbase.thirdparty.io.netty.channel.Channel	channel

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

addr, authenticatedWithFallback, callCleanup, clientCertificateChain, codec, compressionCodec, connectionAttributes, connectionHeader, connectionHeaderRead, hostAddress, provider, remotePort, retryImmediatelySupported, rpcServer, saslProviders, saslServer, service, skipInitialSaslHandshake, ugi, user, useSasl

Constructor Summary

Constructors

Constructor	Description
NettyServerRpcConnection(NettyRpcServer rpcServer, org.apache.hbase.thirdparty.io.netty.channel.Channel channel)

Method Summary

Modifier and Type	Method	Description
void	close()
NettyServerCall	createCall(int id, org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service, org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header, org.apache.hbase.thirdparty.com.google.protobuf.Message param, ExtendedCellScanner cellScanner, long size, InetAddress remoteAddress, int timeout, RpcServer.CallCleanup reqCleanup)
protected void	doRespond(RpcResponse resp)
boolean	isConnectionOpen()
(package private) void	process(org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf buf)
(package private) void	setupHandler()

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

callCleanupIfNeeded, disposeSasl, doRawSaslReply, finishSaslNegotiation, getErrorResponse, getHostAddress, getHostInetAddress, getOrCreateSaslServer, getRemotePort, getVersionInfo, isSimpleAuthentication, processOneRpc, processPreamble, processRequest, toString

Methods inherited from class java.lang.Object

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

Field Details

channel

final org.apache.hbase.thirdparty.io.netty.channel.Channel channel

Constructor Details

NettyServerRpcConnection

NettyServerRpcConnection(NettyRpcServer rpcServer,
 org.apache.hbase.thirdparty.io.netty.channel.Channel channel)

Method Details

setupHandler

void setupHandler()

process

void process(org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf buf)
      throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

close

public void close()

isConnectionOpen

public boolean isConnectionOpen()

Specified by:

isConnectionOpen in class ServerRpcConnection

createCall

public NettyServerCall createCall(int id,
 org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service,
 org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md,
 org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader header,
 org.apache.hbase.thirdparty.com.google.protobuf.Message param,
 ExtendedCellScanner cellScanner,
 long size,
 InetAddress remoteAddress,
 int timeout,
 RpcServer.CallCleanup reqCleanup)

Specified by:

createCall in class ServerRpcConnection

doRespond

protected void doRespond(RpcResponse resp)

Specified by:

doRespond in class ServerRpcConnection