org.apache.hadoop.hbase.ipc

Class Call

java.lang.Object

org.apache.hadoop.hbase.ipc.Call

@InterfaceAudience.Private
class Call
extends Object

A call waiting for a value.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<Call>	callback
(package private) MetricsConnection.CallStats	callStats
(package private) CellScanner	cells Optionally has cells when making call.
private boolean	done
(package private) IOException	error
(package private) int	id
(package private) org.apache.hbase.thirdparty.com.google.protobuf.Descriptors.MethodDescriptor	md
(package private) org.apache.hbase.thirdparty.com.google.protobuf.Message	param
(package private) 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) org.apache.htrace.core.Span	span
(package private) int	timeout
(package private) org.apache.hbase.thirdparty.io.netty.util.Timeout	timeoutTask

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	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, org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<Call> callback, MetricsConnection.CallStats callStats)

Method Summary

Modifier and Type	Method and Description
private void	callComplete()
long	getStartTime()
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	toString()

Methods inherited from class java.lang.Object

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

Field Detail

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

callStats

final MetricsConnection.CallStats callStats

callback

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

span

final org.apache.htrace.core.Span span

timeoutTask

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

Constructor Detail

Call

protected 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,
               org.apache.hbase.thirdparty.com.google.protobuf.RpcCallback<Call> callback,
               MetricsConnection.CallStats callStats)

Method Detail

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