@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"}) @InterfaceStability.Evolving public class CallRunner extends java.lang.Object
RpcScheduler
. Call run()
to actually execute the contained
RpcServer.CallModifier and Type | Method and Description |
---|---|
void |
drop()
When we want to drop this call because of server is overloaded.
|
RpcServer.Call |
getCall() |
void |
run() |
void |
setStatus(MonitoredRPCHandler status) |
public RpcServer.Call getCall()
public void setStatus(MonitoredRPCHandler status)
public void run()
public void drop()