org.apache.hadoop.hbase.ipc

Class AsyncCall

java.lang.Object

<any>

org.apache.hadoop.hbase.ipc.AsyncCall

@InterfaceAudience.Private
public class AsyncCall
extends <any>

Represents an Async Hbase call and its response. Responses are passed on to its given doneHandler and failures to the rpcController

Field Summary

Fields

Modifier and Type	Field and Description
static Log	LOG

Constructor Summary

Constructors

Constructor and Description
AsyncCall(EventLoop eventLoop, int connectId, Descriptors.MethodDescriptor md, Message param, PayloadCarryingRpcController controller, Message responseDefaultType) Constructor

Method Summary

Modifier and Type	Method and Description
long	getRpcTimeout() Get the rpc timeout
long	getStartTime() Get the start time
void	setFailed(IOException exception) Set failed
void	setSuccess(Message value, CellScanner cellBlockScanner) Set success with a cellBlockScanner
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final Log LOG

Constructor Detail

AsyncCall

public AsyncCall(EventLoop eventLoop,
                 int connectId,
                 Descriptors.MethodDescriptor md,
                 Message param,
                 PayloadCarryingRpcController controller,
                 Message responseDefaultType)

Constructor

Parameters:

eventLoop - for call

connectId - connection id

md - the method descriptor

param - parameters to send to Server

controller - controller for response

responseDefaultType - the default response type

Method Detail

getStartTime

public long getStartTime()

Get the start time

Returns:

start time for the call

toString

public String toString()

setSuccess

public void setSuccess(Message value,
                       CellScanner cellBlockScanner)

Set success with a cellBlockScanner

Parameters:

value - to set

cellBlockScanner - to set

setFailed

public void setFailed(IOException exception)

Set failed

Parameters:

exception - to set

getRpcTimeout

public long getRpcTimeout()

Get the rpc timeout

Returns:

current timeout for this call