import org.apache.hadoop.ha.BadFencingConfigurationException; //导入依赖的package包/类
public JobTrackerHAServiceTarget(Configuration conf, String jtId) {
  this.logicalName = HAUtil.getLogicalName(conf);
  this.jtId = jtId;

  // Make a copy of the conf, and override configs based on the
  // target node -- not the node we happen to be running on.
  JobConf targetConf = new JobConf(conf);
  HAUtil.setGenericConf(targetConf, logicalName, jtId, HAUtil.JOB_TRACKER_SPECIFIC_KEYS);
  
  this.addr = HAUtil.getJtHaRpcAddress(targetConf, jtId);

  this.autoFailoverEnabled = targetConf.getBoolean(
      HAUtil.MR_HA_AUTO_FAILOVER_ENABLED_KEY,
      HAUtil.MR_HA_AUTO_FAILOVER_ENABLED_DEFAULT);
  if (autoFailoverEnabled) {
    int port = MRZKFailoverController.getZkfcPort(targetConf);
    if (port != 0) {
      setZkfcPort(port);
    }
  }
  try {
    fencer = NodeFencer.create(targetConf, HAUtil.MR_HA_FENCING_METHODS_KEY);
  } catch (BadFencingConfigurationException e) {
    this.fenceConfigError = e;
  }
}
 

import org.apache.hadoop.ha.BadFencingConfigurationException; //导入依赖的package包/类
public Args(String arg) 
    throws BadFencingConfigurationException {
  user = System.getProperty("user.name");
  sshPort = DEFAULT_SSH_PORT;

  // Parse optional user and ssh port
  if (arg != null && !arg.isEmpty()) {
    Matcher m = USER_PORT_RE.matcher(arg);
    if (!m.matches()) {
      throw new BadFencingConfigurationException(
          "Unable to parse user and SSH port: "+ arg);
    }
    if (m.group(1) != null) {
      user = m.group(1);
    }
    if (m.group(2) != null) {
      sshPort = parseConfiggedPort(m.group(2));
    }
  }
}
 

import org.apache.hadoop.ha.BadFencingConfigurationException; //导入依赖的package包/类
@Override
public void checkFencingConfigured() throws BadFencingConfigurationException {
  if (fenceConfigError != null) {
    throw fenceConfigError;
  }
  if (fencer == null) {
    throw new BadFencingConfigurationException(
        "No fencer configured for " + this);
  }
}
 

import org.apache.hadoop.ha.BadFencingConfigurationException; //导入依赖的package包/类
/**
 * Verify that the argument, if given, in the conf is parseable.
 */
@Override
public void checkArgs(String argStr) throws BadFencingConfigurationException {
  if (argStr != null) {
    new Args(argStr);
  }
}
 

import org.apache.hadoop.ha.BadFencingConfigurationException; //导入依赖的package包/类
private Integer parseConfiggedPort(String portStr)
    throws BadFencingConfigurationException {
  try {
    return Integer.valueOf(portStr);
  } catch (NumberFormatException nfe) {
    throw new BadFencingConfigurationException(
        "Port number '" + portStr + "' invalid");
  }
}
 

import org.apache.hadoop.ha.BadFencingConfigurationException; //导入依赖的package包/类
@Override
public void checkFencingConfigured() throws BadFencingConfigurationException {
  throw new BadFencingConfigurationException("Fencer not configured");
}