@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"}) @InterfaceStability.Evolving public class CallRunner extends Object
RpcScheduler
. Call run()
to actually execute the contained
RpcServer.CallModifier and Type | Field and Description |
---|---|
private RpcServer.Call |
call |
private static org.apache.commons.logging.Log |
LOG |
private RpcServerInterface |
rpcServer |
private MonitoredRPCHandler |
status |
private boolean |
sucessful |
Constructor and Description |
---|
CallRunner(RpcServerInterface rpcServer,
RpcServer.Call call)
On construction, adds the size of this call to the running count of outstanding call sizes.
|
Modifier and Type | Method and Description |
---|---|
private void |
cleanup()
Cleanup after ourselves...
|
RpcServer.Call |
getCall() |
void |
run() |
void |
setStatus(MonitoredRPCHandler status) |
private static final org.apache.commons.logging.Log LOG
private RpcServer.Call call
private RpcServerInterface rpcServer
private MonitoredRPCHandler status
private volatile boolean sucessful
CallRunner(RpcServerInterface rpcServer, RpcServer.Call call)
public RpcServer.Call getCall()
public void setStatus(MonitoredRPCHandler status)
private void cleanup()
public void run()
Copyright © 2007–2019 The Apache Software Foundation. All rights reserved.