Package org.apache.hadoop.hbase.ipc

Class AbstractTestIPC.FailingSimpleRpcServer.FailingConnection

java.lang.Object
org.apache.hadoop.hbase.ipc.ServerRpcConnection
org.apache.hadoop.hbase.ipc.AbstractTestIPC.FailingSimpleRpcServer.FailingConnection
All Implemented Interfaces:
Closeable, AutoCloseable
Enclosing class:
AbstractTestIPC.FailingSimpleRpcServer
final class AbstractTestIPC.FailingSimpleRpcServer.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 SocketChannel
    channel
    Deprecated.
     
    (package private) long
    lastSentTime
    Deprecated.
     
    (package private) final org.apache.hadoop.hbase.ipc.SimpleRpcServerResponder
    responder
    Deprecated.
     
    (package private) final ConcurrentLinkedDeque<org.apache.hadoop.hbase.ipc.RpcResponse>
    responseQueue
    Deprecated.
     
    (package private) final Lock
    responseWriteLock
    Deprecated.
     
    (package private) boolean
    useWrap
    Deprecated.
     

    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(AbstractTestIPC.FailingSimpleRpcServer rpcServer, SocketChannel channel, long lastContact)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected int
    channelDataRead(ReadableByteChannel arg0, org.apache.hadoop.hbase.nio.ByteBuff arg1)
    Deprecated.
     
    void
    close()
    Deprecated.
     
    org.apache.hadoop.hbase.ipc.SimpleServerCall
    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)
    Deprecated.
     
    protected void
    decRpcCount()
    Deprecated.
     
    protected void
    doRespond(org.apache.hadoop.hbase.ipc.RpcResponse arg0)
    Deprecated.
     
    long
    getLastContact()
    Deprecated.
     
    protected void
    incRpcCount()
    Deprecated.
     
    boolean
    isConnectionOpen()
    Deprecated.
     
    (package private) boolean
    isIdle()
    Deprecated.
     
    void
    processRequest(org.apache.hadoop.hbase.nio.ByteBuff buf)
     
    int
    readAndProcess()
    Deprecated.
     
    void
    setLastContact(long arg0)
    Deprecated.
     

    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 SocketChannel channel
      Deprecated.

    • responder

      final org.apache.hadoop.hbase.ipc.SimpleRpcServerResponder responder
      Deprecated.

    • useWrap

      boolean useWrap
      Deprecated.

    • responseQueue

      final ConcurrentLinkedDeque<org.apache.hadoop.hbase.ipc.RpcResponse> responseQueue
      Deprecated.

    • responseWriteLock

      final Lock responseWriteLock
      Deprecated.

    • lastSentTime

      long lastSentTime
      Deprecated.

  • 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

    • setLastContact

      public void setLastContact(long arg0)
      Deprecated.

    • getLastContact

      public long getLastContact()
      Deprecated.

    • isIdle

      boolean isIdle()
      Deprecated.

    • decRpcCount

      protected void decRpcCount()
      Deprecated.

    • incRpcCount

      protected void incRpcCount()
      Deprecated.

    • readAndProcess

      public int readAndProcess() throws IOException, InterruptedException
      Deprecated.
      Throws:
      IOException
      InterruptedException

    • channelDataRead

      protected int channelDataRead(ReadableByteChannel arg0, org.apache.hadoop.hbase.nio.ByteBuff arg1) throws IOException
      Deprecated.
      Throws:
      IOException

    • close

      public void close()
      Deprecated.

    • isConnectionOpen

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

    • createCall

      public org.apache.hadoop.hbase.ipc.SimpleServerCall 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)
      Deprecated.
      Specified by:
      createCall in class org.apache.hadoop.hbase.ipc.ServerRpcConnection

    • doRespond

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