Package org.apache.hadoop.hbase.ipc

Class FailingNettyRpcServer.FailingConnection

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

  • Field Details

    • channel

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

    • rpcServer

      protected final org.apache.hadoop.hbase.ipc.RpcServer rpcServer

    • connectionHeaderRead

      protected boolean connectionHeaderRead

    • callCleanup

      protected org.apache.hadoop.hbase.ipc.RpcServer.CallCleanup callCleanup

    • hostAddress

      protected String hostAddress

    • remotePort

      protected int remotePort

    • addr

      protected InetAddress addr

    • connectionHeader

      protected org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader connectionHeader

    • connectionAttributes

      protected Map<String,byte[]> connectionAttributes

    • codec

      protected org.apache.hadoop.hbase.codec.Codec codec

    • compressionCodec

      protected org.apache.hadoop.io.compress.CompressionCodec compressionCodec

    • service

      protected org.apache.hbase.thirdparty.com.google.protobuf.BlockingService service

    • provider

      protected org.apache.hadoop.hbase.security.provider.SaslServerAuthenticationProvider provider

    • skipInitialSaslHandshake

      protected boolean skipInitialSaslHandshake

    • useSasl

      protected boolean useSasl

    • saslServer

      protected org.apache.hadoop.hbase.security.HBaseSaslRpcServer saslServer

    • authenticatedWithFallback

      protected boolean authenticatedWithFallback

    • retryImmediatelySupported

      protected boolean retryImmediatelySupported

    • user

      protected org.apache.hadoop.hbase.security.User user

    • ugi

      protected org.apache.hadoop.security.UserGroupInformation ugi

    • saslProviders

      protected org.apache.hadoop.hbase.security.provider.SaslServerAuthenticationProviders saslProviders

    • clientCertificateChain

      protected X509Certificate[] clientCertificateChain

  • Constructor Details

  • Method Details

    • processRequest

      public void processRequest(org.apache.hadoop.hbase.nio.ByteBuff buf) throws IOException, InterruptedException
      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()

    • 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.CellScanner arg5, long arg6, InetAddress arg7, int arg8, org.apache.hadoop.hbase.ipc.RpcServer.CallCleanup arg9)

    • doRespond

      protected void doRespond(org.apache.hadoop.hbase.ipc.RpcResponse arg0)

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • getHostAddress

      public String getHostAddress()

    • getHostInetAddress

      public InetAddress getHostInetAddress()

    • getRemotePort

      public int getRemotePort()

    • getVersionInfo

      public org.apache.hadoop.hbase.shaded.protobuf.generated.HBaseProtos.VersionInfo getVersionInfo()

    • disposeSasl

      protected final void disposeSasl()

    • doRawSaslReply

      protected final void doRawSaslReply(org.apache.hadoop.hbase.security.SaslStatus arg0, org.apache.hadoop.io.Writable arg1, String arg2, String arg3) throws IOException
      Throws:
      IOException

    • getOrCreateSaslServer

      org.apache.hadoop.hbase.security.HBaseSaslRpcServer getOrCreateSaslServer() throws IOException
      Throws:
      IOException

    • finishSaslNegotiation

      void finishSaslNegotiation() throws IOException
      Throws:
      IOException

    • processOneRpc

      public void processOneRpc(org.apache.hadoop.hbase.nio.ByteBuff arg0) throws IOException, InterruptedException
      Throws:
      IOException
      InterruptedException

    • getErrorResponse

      protected final org.apache.hadoop.hbase.ipc.RpcResponse getErrorResponse(String arg0, Exception arg1) throws IOException
      Throws:
      IOException

    • callCleanupIfNeeded

      protected final void callCleanupIfNeeded()

    • processPreamble

      protected final org.apache.hadoop.hbase.ipc.ServerRpcConnection.PreambleResponse processPreamble(ByteBuffer arg0) throws IOException
      Throws:
      IOException

    • isSimpleAuthentication

      boolean isSimpleAuthentication()