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 Summary

    Fields
    Modifier and Type
    Field
    Description
    (package private) final Map<String,byte[]>
    attributes
     
    private final org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<Call>
    callback
     
    (package private) final MetricsConnection.CallStats
    callStats
     
    (package private) CellScanner
    cells
    Optionally has cells when making call.
    private boolean
    done
     
    (package private) IOException
    error
     
    (package private) final int
    id
     
    (package private) final org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor
    md
     
    (package private) final org.apache.hbase.thirdparty.com.google.protobuf.Message
    param
     
    (package private) final int
    priority
     
    (package private) org.apache.hbase.thirdparty.com.google.protobuf.Message
    response
     
    (package private) org.apache.hbase.thirdparty.com.google.protobuf.Message
    responseDefaultType
     
    (package private) final io.opentelemetry.api.trace.Span
    span
     
    (package private) final int
    timeout
     
    (package private) org.apache.hbase.thirdparty.io.netty.util.Timeout
    timeoutTask
     

  • Constructor Summary

    Constructors
    Constructor
    Description
    Call(int id, org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor md, org.apache.hbase.thirdparty.com.google.protobuf.Message param, CellScanner 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 Summary

    Modifier and Type
    Method
    Description
    private void
    callComplete()
     
    long
    getStartTime()
     
    boolean
    isConnectionRegistryCall()
     
    boolean
    isDone()
     
    void
    setException(IOException error)
    Set the exception when there is an error.
    void
    setResponse(org.apache.hbase.thirdparty.com.google.protobuf.Message response, CellScanner cells)
    Set the return value when there is no error.
    void
    setTimeout(IOException error)
    called from timeoutTask, prevent self cancel
    String
    toShortString()
    Builds a simplified toString() that includes just the id and method name.
    String
    toString()
     

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

  • Field Details

    • id

      final int id

    • param

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

    • cells

      CellScanner 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, CellScanner 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, CellScanner 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()