org.apache.hadoop.hbase.ipc

Class Call

java.lang.Object

org.apache.hadoop.hbase.ipc.Call

@InterfaceAudience.Private
public class Call
extends Object

A call waiting for a value.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	Call(int id, com.google.protobuf.Descriptors.MethodDescriptor md, com.google.protobuf.Message param, CellScanner cells, com.google.protobuf.Message responseDefaultType, int timeout)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	callComplete() Indicate when the call is complete and the value or error are available.
boolean	checkAndSetTimeout() Check if the call did timeout.
long	getStartTime()
int	remainingTime()
void	setException(IOException error) Set the exception when there is an error.
void	setResponse(com.google.protobuf.Message response, CellScanner cells) Set the return value when there is no error.
String	toString()

Methods inherited from class java.lang.Object

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

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)

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