Package org.apache.hadoop.hbase.ipc

Class Call

java.lang.Object
org.apache.hadoop.hbase.ipc.Call
@Private class Call extends Object
A call waiting for a value.

  • Field Details

    • id

      final int id

    • param

      final org.apache.hbase.thirdparty.com.google.protobuf.Message param

    • cells

      ExtendedCellScanner cells
      Optionally has cells when making call. Optionally has cells set on response. Used passing cells to the rpc and receiving the response.

    • response

      org.apache.hbase.thirdparty.com.google.protobuf.Message response

    • responseDefaultType

      org.apache.hbase.thirdparty.com.google.protobuf.Message responseDefaultType

    • error

      IOException error

    • done

      private boolean done

    • md

      final org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md

    • timeout

      final int timeout

    • priority

      final int priority

    • attributes

      final Map<String,byte[]> attributes

    • callStats

      final MetricsConnection.CallStats callStats

    • callback

      private final org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<Call> callback

    • span

      final io.opentelemetry.api.trace.Span span

    • timeoutTask

      org.apache.hbase.thirdparty.io.netty.util.Timeout timeoutTask

  • Constructor Details

    • Call

      Call(int id, org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, org.apache.hbase.thirdparty.com.google.protobuf.Message param, ExtendedCellScanner cells, org.apache.hbase.thirdparty.com.google.protobuf.Message responseDefaultType, int timeout, int priority, Map<String,byte[]> attributes, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<Call> callback, MetricsConnection.CallStats callStats)

  • Method Details

    • toShortString

      public String toShortString()
      Builds a simplified toString() that includes just the id and method name.

    • toString

      public String toString()
      Overrides:
      toString in class Object

    • setTimeout

      public void setTimeout(IOException error)
      called from timeoutTask, prevent self cancel

    • callComplete

      private void callComplete()

    • setException

      public void setException(IOException error)
      Set the exception when there is an error. Notify the caller the call is done.
      Parameters:
      error - exception thrown by the call; either local or remote

    • setResponse

      public void setResponse(org.apache.hbase.thirdparty.com.google.protobuf.Message response, ExtendedCellScanner cells)
      Set the return value when there is no error. Notify the caller the call is done.
      Parameters:
      response - return value of the call.
      cells - Can be null

    • isDone

      public boolean isDone()

    • getStartTime

      public long getStartTime()

    • isConnectionRegistryCall

      public boolean isConnectionRegistryCall()