Package org.apache.hadoop.hbase.ipc

Class FailingNettyRpcServer.FailingConnection

java.lang.Object
org.apache.hadoop.hbase.ipc.ServerRpcConnection
org.apache.hadoop.hbase.ipc.FailingNettyRpcServer.FailingConnection
All Implemented Interfaces:
Closeable, AutoCloseable
Enclosing class:
FailingNettyRpcServer
static final class FailingNettyRpcServer.FailingConnection extends org.apache.hadoop.hbase.ipc.ServerRpcConnection

  • Nested Class Summary

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

    org.apache.hadoop.hbase.ipc.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, saslServer, service, skipInitialSaslHandshake, ugi, user, useSasl

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
    private
    FailingConnection(FailingNettyRpcServer rpcServer, org.apache.hbase.thirdparty.io.netty.channel.Channel channel)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    org.apache.hadoop.hbase.ipc.NettyServerCall
    createCall(int arg0, org.apache.hbase.thirdparty.com.google.protobuf.BlockingService arg1, org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor arg2, org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader arg3, org.apache.hbase.thirdparty.com.google.protobuf.Message arg4, org.apache.hadoop.hbase.ExtendedCellScanner arg5, long arg6, InetAddress arg7, int arg8, org.apache.hadoop.hbase.ipc.RpcServer.CallCleanup arg9)
     
    protected void
    doRespond(org.apache.hadoop.hbase.ipc.RpcResponse arg0)
     
    boolean
    isConnectionOpen()
     
    (package private) void
    process(org.apache.hbase.thirdparty.io.netty.buffer.ByteBuf arg0)
     
    void
    processRequest(org.apache.hadoop.hbase.nio.ByteBuff buf)
     
    (package private) void
    setupHandler()
     

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

    callCleanupIfNeeded, disposeSasl, doRawSaslReply, finishSaslNegotiation, getConnectionHeader, getErrorResponse, getHostAddress, getHostInetAddress, getOrCreateSaslServer, getRemotePort, getVersionInfo, isSimpleAuthentication, processOneRpc, processPreamble, 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

  • Method Details

    • processRequest

      public void processRequest(org.apache.hadoop.hbase.nio.ByteBuff buf) throws IOException, InterruptedException
      Overrides:
      processRequest in class org.apache.hadoop.hbase.ipc.ServerRpcConnection
      Throws:
      IOException
      InterruptedException

    • setupHandler

      void setupHandler()

    • process

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

    • close

      public void close()

    • isConnectionOpen

      public boolean isConnectionOpen()
      Specified by:
      isConnectionOpen in class org.apache.hadoop.hbase.ipc.ServerRpcConnection

    • createCall

      public org.apache.hadoop.hbase.ipc.NettyServerCall createCall(int arg0, org.apache.hbase.thirdparty.com.google.protobuf.BlockingService arg1, org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor arg2, org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.RequestHeader arg3, org.apache.hbase.thirdparty.com.google.protobuf.Message arg4, org.apache.hadoop.hbase.ExtendedCellScanner arg5, long arg6, InetAddress arg7, int arg8, org.apache.hadoop.hbase.ipc.RpcServer.CallCleanup arg9)
      Specified by:
      createCall in class org.apache.hadoop.hbase.ipc.ServerRpcConnection

    • doRespond

      protected void doRespond(org.apache.hadoop.hbase.ipc.RpcResponse arg0)
      Specified by:
      doRespond in class org.apache.hadoop.hbase.ipc.ServerRpcConnection