org.apache.hadoop.hbase.ipc

Class TimeLimitedRpcController

java.lang.Object

org.apache.hadoop.hbase.ipc.TimeLimitedRpcController

Direct Known Subclasses:

PayloadCarryingRpcController

@InterfaceAudience.Private
public class TimeLimitedRpcController
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected Integer	callTimeout The time, in ms before the call should expire.
protected AtomicReference<<any>>	cancellationCb
protected boolean	cancelled
protected AtomicReference<<any>>	failureCb

Constructor Summary

Constructors

Constructor and Description
TimeLimitedRpcController()

Method Summary

Modifier and Type	Method and Description
String	errorText()
boolean	failed() For use in async rpc clients
int	getCallTimeout()
boolean	hasCallTimeout()
boolean	isCanceled()
void	notifyOnCancel(<any> cancellationCb)
void	notifyOnFail(<any> failureCb) Notify a callback on error.
void	reset()
void	setCallTimeout(int callTimeout)
void	setFailed(IOException e) Set failed with an exception to pass on.
void	setFailed(String reason)
void	startCancel()

Methods inherited from class java.lang.Object

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

Field Detail

callTimeout

protected volatile Integer callTimeout

The time, in ms before the call should expire.

cancelled

protected volatile boolean cancelled

cancellationCb

protected final AtomicReference<<any>> cancellationCb

failureCb

protected final AtomicReference<<any>> failureCb

Constructor Detail

TimeLimitedRpcController

public TimeLimitedRpcController()

Method Detail

getCallTimeout

public int getCallTimeout()

setCallTimeout

public void setCallTimeout(int callTimeout)

hasCallTimeout

public boolean hasCallTimeout()

errorText

public String errorText()

failed

public boolean failed()

For use in async rpc clients

Returns:

true if failed

isCanceled

public boolean isCanceled()

notifyOnCancel

public void notifyOnCancel(<any> cancellationCb)

notifyOnFail

public void notifyOnFail(<any> failureCb)

Notify a callback on error. For use in async rpc clients

Parameters:

failureCb - the callback to call on error

reset

public void reset()

setFailed

public void setFailed(String reason)

setFailed

public void setFailed(IOException e)

Set failed with an exception to pass on. For use in async rpc clients

Parameters:

e - exception to set with

startCancel

public void startCancel()