Field Detail

• id

  final int id

• param

  final 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

  com.google.protobuf.Message response

• responseDefaultType

  com.google.protobuf.Message responseDefaultType

• error

  IOException error

• done

  volatile boolean done

• md

  final com.google.protobuf.Descriptors.MethodDescriptor md

• timeout

  final int timeout

• callStats

  final MetricsConnection.CallStats callStats

Constructor Detail

• Call

  protected Call(int id,
      com.google.protobuf.Descriptors.MethodDescriptor md,
      com.google.protobuf.Message param,
      CellScanner cells,
      com.google.protobuf.Message responseDefaultType,
      int timeout,
      MetricsConnection.CallStats callStats)

Method Detail

• checkAndSetTimeout

  public boolean checkAndSetTimeout()

  Check if the call did timeout. Set an exception (includes a notify) if it's the case.

  Returns:

  true if the call is on timeout, false otherwise.

• remainingTime

  public int remainingTime()

• toString

  public String toString()

  Overrides:

  toString in class Object

• callComplete

  protected void callComplete()

  Indicate when the call is complete and the value or error are available. Notifies by default.

• 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(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

• getStartTime

  public long getStartTime()