org.apache.hadoop.hbase.ipc

Class CallRunner

java.lang.Object

org.apache.hadoop.hbase.ipc.CallRunner

@InterfaceAudience.LimitedPrivate(value={"Coprocesssor","Phoenix"})
 @InterfaceStability.Evolving
public class CallRunner
extends Object

The request processing logic, which is usually executed in thread pools provided by an RpcScheduler. Call run() to actually execute the contained RpcServer.Call

Field Summary

Fields

Modifier and Type	Field and Description
private RpcCall	call
private static CallDroppedException	CALL_DROPPED_EXCEPTION
private RpcServerInterface	rpcServer
private io.opentelemetry.api.trace.Span	span
private MonitoredRPCHandler	status
private boolean	successful

Constructor Summary

Constructors

Constructor and Description
CallRunner(RpcServerInterface rpcServer, RpcCall call) On construction, adds the size of this call to the running count of outstanding call sizes.

Method Summary

Modifier and Type	Method and Description
private void	cleanup() Cleanup after ourselves...
void	drop() When we want to drop this call because of server is overloaded.
RpcCall	getRpcCall()
void	run()
void	setStatus(MonitoredRPCHandler status)

Methods inherited from class java.lang.Object

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

Field Detail

CALL_DROPPED_EXCEPTION

private static final CallDroppedException CALL_DROPPED_EXCEPTION

call

private RpcCall call

rpcServer

private RpcServerInterface rpcServer

status

private MonitoredRPCHandler status

span

private final io.opentelemetry.api.trace.Span span

successful

private volatile boolean successful

Constructor Detail

CallRunner

CallRunner(RpcServerInterface rpcServer,
           RpcCall call)

On construction, adds the size of this call to the running count of outstanding call sizes. Presumption is that we are put on a queue while we wait on an executor to run us. During this time we occupy heap.

Method Detail

getRpcCall

public RpcCall getRpcCall()

setStatus

public void setStatus(MonitoredRPCHandler status)

cleanup

private void cleanup()

Cleanup after ourselves... let go of references.

run

public void run()

drop

public void drop()

When we want to drop this call because of server is overloaded.