Package org.apache.hadoop.hbase.ipc

Class TestRpcConnectionHeader.MyRpcConnection

java.lang.Object
org.apache.hadoop.hbase.ipc.TestRpcConnectionHeader.MyRpcConnection
Enclosing class:
TestRpcConnectionHeader
private class TestRpcConnectionHeader.MyRpcConnection extends Object

  • Field Details

    • remoteId

      protected final org.apache.hadoop.hbase.ipc.ConnectionId remoteId

    • useSasl

      protected final boolean useSasl

    • token

      protected final org.apache.hadoop.security.token.Token<? extends org.apache.hadoop.security.token.TokenIdentifier> token

    • securityInfo

      protected final org.apache.hadoop.hbase.security.SecurityInfo securityInfo

    • reloginMaxBackoff

      protected final int reloginMaxBackoff

    • codec

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

    • compressor

      protected final org.apache.hadoop.io.compress.CompressionCodec compressor

    • cellBlockBuilder

      protected final org.apache.hadoop.hbase.ipc.CellBlockBuilder cellBlockBuilder

    • metrics

      protected final org.apache.hadoop.hbase.client.MetricsConnection metrics

    • timeoutTimer

      protected final org.apache.hbase.thirdparty.io.netty.util.HashedWheelTimer timeoutTimer

    • conf

      protected final org.apache.hadoop.conf.Configuration conf

    • CRYPTO_AES_ENABLED_KEY

      protected static String CRYPTO_AES_ENABLED_KEY

    • CRYPTO_AES_ENABLED_DEFAULT

      protected static boolean CRYPTO_AES_ENABLED_DEFAULT

    • lastTouched

      protected long lastTouched

    • provider

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

  • Constructor Details

  • Method Details

    • callTimeout

      protected void callTimeout(org.apache.hadoop.hbase.ipc.Call call)

    • isActive

      public boolean isActive()

    • shutdown

      public void shutdown()

    • sendRequest

      public void sendRequest(org.apache.hadoop.hbase.ipc.Call call, org.apache.hadoop.hbase.ipc.HBaseRpcController hrc) throws IOException
      Throws:
      IOException

    • cleanupConnection

      public void cleanupConnection()

    • scheduleTimeoutTask

      protected final void scheduleTimeoutTask(org.apache.hadoop.hbase.ipc.Call arg0)

    • getConnectionHeaderPreamble

      protected byte[] getConnectionHeaderPreamble()

    • getConnectionHeader

      protected final org.apache.hadoop.hbase.shaded.protobuf.generated.RPCProtos.ConnectionHeader getConnectionHeader()

    • getRemoteInetAddress

      protected final InetSocketAddress getRemoteInetAddress(org.apache.hadoop.hbase.client.MetricsConnection arg0) throws UnknownHostException
      Throws:
      UnknownHostException

    • isKerberosAuth

      protected final boolean isKerberosAuth()

    • getServerPrincipals

      protected final Set<String> getServerPrincipals() throws IOException
      Throws:
      IOException

    • randomSelect

      protected final <T extends Object> T randomSelect(Collection<T> arg0)

    • chooseServerPrincipal

      protected final String chooseServerPrincipal(Set<String> arg0, org.apache.hadoop.hbase.ipc.Call arg1) throws SaslException
      Throws:
      SaslException

    • saslNegotiationDone

      protected final void saslNegotiationDone(String arg0, boolean arg1)

    • remoteId

      public org.apache.hadoop.hbase.ipc.ConnectionId remoteId()

    • getLastTouched

      public long getLastTouched()

    • setLastTouched

      public void setLastTouched(long arg0)

    • createSecurityPreambleCall

      protected final org.apache.hadoop.hbase.ipc.Call createSecurityPreambleCall(org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.ipc.Call> arg0)

    • readResponse

      <T extends InputStream & DataInput> void readResponse(T arg0, Map<Integer,org.apache.hadoop.hbase.ipc.Call> arg1, org.apache.hadoop.hbase.ipc.Call arg2, Consumer<org.apache.hadoop.ipc.RemoteException> arg3) throws IOException
      Throws:
      IOException