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

@InterfaceAudience.Private
class NettyServerRpcConnection
extends ServerRpcConnection

RpcConnection implementation for netty rpc server.

Since:

2.0.0

Field Summary

Fields

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

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

addr, authenticatedWithFallback, callCleanup, codec, compressionCodec, connectionHeader, connectionHeaderRead, cryptoAES, hostAddress, provider, remotePort, retryImmediatelySupported, rpcServer, saslContextEstablished, saslProviders, saslServer, service, skipInitialSaslHandshake, ugi, useCryptoAesWrap, user, useSasl, useWrap

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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, CellScanner 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	process(ByteBuff buf)
(package private) void	process(ByteBuffer buf)

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

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

Methods inherited from class java.lang.Object

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

Field Detail

channel

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

Constructor Detail

NettyServerRpcConnection

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

Method Detail

process

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

Throws:

IOException

InterruptedException

process

void process(ByteBuffer buf)
      throws IOException,
             InterruptedException

Throws:

IOException

InterruptedException

process

void process(ByteBuff 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,
                                  CellScanner 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