org.apache.hadoop.hbase

Class ShellExecEndpointCoprocessor

java.lang.Object

org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService

org.apache.hadoop.hbase.ShellExecEndpointCoprocessor

All Implemented Interfaces:

com.google.protobuf.Service, org.apache.hadoop.hbase.Coprocessor, org.apache.hadoop.hbase.coprocessor.MasterCoprocessor, org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessor

@InterfaceAudience.Private
public class ShellExecEndpointCoprocessor
extends org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService
implements org.apache.hadoop.hbase.coprocessor.MasterCoprocessor, org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessor

Receives shell commands from the client and executes them blindly. Intended only for use by ChaosMonkey via CoprocClusterManager

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService

org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService.BlockingInterface, org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService.Interface, org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService.Stub

Nested classes/interfaces inherited from interface org.apache.hadoop.hbase.Coprocessor

org.apache.hadoop.hbase.Coprocessor.State

Field Summary

Fields

Modifier and Type	Field and Description
static String	BACKGROUND_DELAY_MS_KEY
private ExecutorService	backgroundExecutor
private org.apache.hadoop.conf.Configuration	conf
static long	DEFAULT_BACKGROUND_DELAY_MS
private static org.slf4j.Logger	LOG

Fields inherited from interface org.apache.hadoop.hbase.Coprocessor

PRIORITY_HIGHEST, PRIORITY_LOWEST, PRIORITY_SYSTEM, PRIORITY_USER, VERSION

Constructor Summary

Constructors

Constructor and Description
ShellExecEndpointCoprocessor()

Method Summary

Modifier and Type	Method and Description
private void	doExec(org.apache.hadoop.util.Shell.ShellCommandExecutor shell, org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse.Builder builder) Execute shell and collect results into builder as side-effects.
Iterable<com.google.protobuf.Service>	getServices()
private void	runBackgroundTask(org.apache.hadoop.util.Shell.ShellCommandExecutor shell, com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse> done)
private void	runForegroundTask(org.apache.hadoop.util.Shell.ShellCommandExecutor shell, com.google.protobuf.RpcController controller, com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse> done)
void	shellExec(com.google.protobuf.RpcController controller, org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecRequest request, com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse> done)
void	start(org.apache.hadoop.hbase.CoprocessorEnvironment env)

Methods inherited from class org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService

callMethod, getDescriptor, getDescriptorForType, getRequestPrototype, getResponsePrototype, newBlockingStub, newReflectiveBlockingService, newReflectiveService, newStub

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.MasterCoprocessor

getMasterObserver

Methods inherited from interface org.apache.hadoop.hbase.coprocessor.RegionServerCoprocessor

getRegionServerObserver

Methods inherited from interface org.apache.hadoop.hbase.Coprocessor

stop

Field Detail

LOG

private static final org.slf4j.Logger LOG

BACKGROUND_DELAY_MS_KEY

public static final String BACKGROUND_DELAY_MS_KEY

See Also:

Constant Field Values

DEFAULT_BACKGROUND_DELAY_MS

public static final long DEFAULT_BACKGROUND_DELAY_MS

See Also:

Constant Field Values

backgroundExecutor

private final ExecutorService backgroundExecutor

conf

private org.apache.hadoop.conf.Configuration conf

Constructor Detail

ShellExecEndpointCoprocessor

public ShellExecEndpointCoprocessor()

Method Detail

getServices

public Iterable<com.google.protobuf.Service> getServices()

Specified by:

getServices in interface org.apache.hadoop.hbase.Coprocessor

start

public void start(org.apache.hadoop.hbase.CoprocessorEnvironment env)

Specified by:

start in interface org.apache.hadoop.hbase.Coprocessor

shellExec

public void shellExec(com.google.protobuf.RpcController controller,
                      org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecRequest request,
                      com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse> done)

Specified by:

shellExec in class org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecService

runForegroundTask

private void runForegroundTask(org.apache.hadoop.util.Shell.ShellCommandExecutor shell,
                               com.google.protobuf.RpcController controller,
                               com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse> done)

runBackgroundTask

private void runBackgroundTask(org.apache.hadoop.util.Shell.ShellCommandExecutor shell,
                               com.google.protobuf.RpcCallback<org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse> done)

doExec

private void doExec(org.apache.hadoop.util.Shell.ShellCommandExecutor shell,
                    org.apache.hadoop.hbase.coprocessor.protobuf.generated.ShellExecEndpoint.ShellExecResponse.Builder builder)
             throws IOException

Execute shell and collect results into builder as side-effects.

Throws:

IOException