public class DelayPacketsCommandAction extends TCCommandAction
Action.ActionContext
Modifier and Type | Field and Description |
---|---|
private long |
delay |
private long |
duration |
private static org.slf4j.Logger |
LOG |
ADD, DELETE, network
clusterManager, timeout
cluster, context, initialServers, initialStatus, KILL_DATANODE_TIMEOUT_DEFAULT, KILL_DATANODE_TIMEOUT_KEY, KILL_MASTER_TIMEOUT_DEFAULT, KILL_MASTER_TIMEOUT_KEY, KILL_NAMENODE_TIMEOUT_DEFAULT, KILL_NAMENODE_TIMEOUT_KEY, KILL_RS_TIMEOUT_DEFAULT, KILL_RS_TIMEOUT_KEY, KILL_ZK_NODE_TIMEOUT_DEFAULT, KILL_ZK_NODE_TIMEOUT_KEY, killDataNodeTimeout, killMasterTimeout, killNameNodeTimeout, killRsTimeout, killZkNodeTimeout, monkeyProps, skipMetaRS, START_DATANODE_TIMEOUT_DEFAULT, START_DATANODE_TIMEOUT_KEY, START_MASTER_TIMEOUT_DEFAULT, START_MASTER_TIMEOUT_KEY, START_NAMENODE_TIMEOUT_DEFAULT, START_NAMENODE_TIMEOUT_KEY, START_RS_TIMEOUT_DEFAULT, START_RS_TIMEOUT_KEY, START_ZK_NODE_TIMEOUT_DEFAULT, START_ZK_NODE_TIMEOUT_KEY, startDataNodeTimeout, startMasterTimeout, startNameNodeTimeout, startRsTimeout, startZkNodeTimeout
Constructor and Description |
---|
DelayPacketsCommandAction(long delay,
long duration,
long timeout,
String network)
Adds latency to communication on a random region server
|
Modifier and Type | Method and Description |
---|---|
private String |
getCommand(String operation) |
protected org.slf4j.Logger |
getLogger()
Retrieve the instance's
Logger , for use throughout the class hierarchy. |
protected void |
localPerform() |
init, perform
forceBalancer, getConf, getCurrentServers, killDataNode, killMaster, killNameNode, killRs, killZKNode, modifyAllTableColumns, modifyAllTableColumns, resumeRs, setBalancer, startDataNode, startMaster, startNameNode, startRs, startZKNode, stopRs, suspendRs, unbalanceRegions
private static final org.slf4j.Logger LOG
private final long delay
private final long duration
public DelayPacketsCommandAction(long delay, long duration, long timeout, String network)
delay
- the latency wil be delay +/-50% in millisecondsduration
- the time this issue persists in millisecondstimeout
- the timeout for executing required commands on the region server in millisecondsnetwork
- network interface the regionserver uses for communicationprotected org.slf4j.Logger getLogger()
Action
Logger
, for use throughout the class hierarchy.protected void localPerform() throws IOException
localPerform
in class SudoCommandAction
IOException
private String getCommand(String operation)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.