AsyncCall (Apache HBase 1.2.12 API)

java.lang.Object
- io.netty.util.concurrent.AbstractFuture<V>
- - io.netty.util.concurrent.DefaultPromise<com.google.protobuf.Message>
  - - org.apache.hadoop.hbase.ipc.AsyncCall

All Implemented Interfaces:

io.netty.util.concurrent.Promise<com.google.protobuf.Message>, Future<com.google.protobuf.Message>
```
@InterfaceAudience.Private
public class AsyncCall
extends io.netty.util.concurrent.DefaultPromise<com.google.protobuf.Message>
```
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
`(package private) MetricsConnection.CallStats`	`callStats`
`(package private) PayloadCarryingRpcController`	`controller`
`(package private) int`	`id`
`private static org.apache.commons.logging.Log`	`LOG`
`(package private) com.google.protobuf.Descriptors.MethodDescriptor`	`method`
`(package private) com.google.protobuf.Message`	`param`
`(package private) com.google.protobuf.Message`	`responseDefaultType`
`(package private) long`	`rpcTimeout`
`(package private) long`	`startTime`

Constructor Summary

Constructors
Constructor and Description
`AsyncCall(io.netty.channel.EventLoop eventLoop, int connectId, com.google.protobuf.Descriptors.MethodDescriptor md, com.google.protobuf.Message param, PayloadCarryingRpcController controller, com.google.protobuf.Message responseDefaultType, MetricsConnection.CallStats callStats)` Constructor

Method Summary

Methods
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(com.google.protobuf.Message value, CellScanner cellBlockScanner)` Set success with a cellBlockScanner
`String`	`toString()`

Methods inherited from class io.netty.util.concurrent.DefaultPromise
addListener, addListeners, await, await, await, awaitUninterruptibly, awaitUninterruptibly, awaitUninterruptibly, cancel, cause, checkDeadLock, executor, getNow, isCancellable, isCancelled, isDone, isSuccess, notifyListener, removeListener, removeListeners, setFailure, setSuccess, setUncancellable, sync, syncUninterruptibly, toStringBuilder, tryFailure, trySuccess

Methods inherited from class io.netty.util.concurrent.AbstractFuture
get, get

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.Future
get, get

Field Detail

LOG

private static final org.apache.commons.logging.Log LOG

id
```
final int id
```

method

final com.google.protobuf.Descriptors.MethodDescriptor method

param

final com.google.protobuf.Message param

controller

final PayloadCarryingRpcController controller

responseDefaultType

final com.google.protobuf.Message responseDefaultType

startTime
```
final long startTime
```

rpcTimeout
```
final long rpcTimeout
```

callStats

final MetricsConnection.CallStats callStats

Constructor Detail

AsyncCall

public AsyncCall(io.netty.channel.EventLoop eventLoop,
         int connectId,
         com.google.protobuf.Descriptors.MethodDescriptor md,
         com.google.protobuf.Message param,
         PayloadCarryingRpcController controller,
         com.google.protobuf.Message responseDefaultType,
         MetricsConnection.CallStats callStats)

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()
```
  Overrides:
  
  toString in class io.netty.util.concurrent.DefaultPromise<com.google.protobuf.Message>
- setSuccess
```
public void setSuccess(com.google.protobuf.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

Class AsyncCall

Field Summary

Constructor Summary

Method Summary

Methods inherited from class io.netty.util.concurrent.DefaultPromise

Methods inherited from class io.netty.util.concurrent.AbstractFuture

Methods inherited from class java.lang.Object

Methods inherited from interface java.util.concurrent.Future

Field Detail

LOG

id

method

param

controller

responseDefaultType

startTime

rpcTimeout

callStats

Constructor Detail

AsyncCall

Method Detail

getStartTime

toString

setSuccess

setFailed

getRpcTimeout