@InterfaceAudience.Private public class TimeLimitedRpcController extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected java.lang.Integer |
callTimeout
The time, in ms before the call should expire.
|
protected java.util.concurrent.atomic.AtomicReference<<any>> |
cancellationCb |
protected boolean |
cancelled |
protected java.util.concurrent.atomic.AtomicReference<<any>> |
failureCb |
Constructor and Description |
---|
TimeLimitedRpcController() |
Modifier and Type | Method and Description |
---|---|
java.lang.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(java.io.IOException e)
Set failed with an exception to pass on.
|
void |
setFailed(java.lang.String reason) |
void |
startCancel() |
protected volatile java.lang.Integer callTimeout
protected volatile boolean cancelled
protected final java.util.concurrent.atomic.AtomicReference<<any>> cancellationCb
protected final java.util.concurrent.atomic.AtomicReference<<any>> failureCb
public int getCallTimeout()
public void setCallTimeout(int callTimeout)
public boolean hasCallTimeout()
public java.lang.String errorText()
public boolean failed()
public boolean isCanceled()
public void notifyOnCancel(<any> cancellationCb)
public void notifyOnFail(<any> failureCb)
failureCb
- the callback to call on errorpublic void reset()
public void setFailed(java.lang.String reason)
public void setFailed(java.io.IOException e)
e
- exception to set withpublic void startCancel()