import org.apache.hadoop.cli.util.CLITestData; //导入依赖的package包/类
@Override
public void startElement(String uri, 
		String localName, 
		String qName, 
		Attributes attributes) throws SAXException {
  if (qName.equals("test")) {
    td = new CLITestData();
  } else if (qName.equals("test-commands")) {
    testCommands = new ArrayList<TestCmd>();
  } else if (qName.equals("cleanup-commands")) {
    cleanupCommands = new ArrayList<TestCmd>();
  } else if (qName.equals("comparators")) {
    testComparators = new ArrayList<ComparatorData>();
  } else if (qName.equals("comparator")) {
    comparatorData = new ComparatorData();
  }
  charString = "";
}
 

import org.apache.hadoop.cli.util.CLITestData; //导入依赖的package包/类
public static CommandExecutor getCommandExecutor(CLITestData.TestCmd cmd,
                                          String tag)
  throws IllegalArgumentException {
  CommandExecutor executor;
  switch (cmd.getType()) {
    case DFSADMIN:
      executor = new CLICommands.FSCmdExecutor(tag, new DFSAdmin());
      break;
    default:
      executor = CmdFactory.getCommandExecutor(cmd, tag);
  }
  return executor;
}
 

import org.apache.hadoop.cli.util.CLITestData; //导入依赖的package包/类
@Override
public void startDocument() throws SAXException {
  testsFromConfigFile = new ArrayList<CLITestData>();
}
 

import org.apache.hadoop.cli.util.CLITestData; //导入依赖的package包/类
/**
 * Test dfsadmin -restoreFailedStorage command
 * @throws Exception
 */
public void testDfsAdminCmd() throws Exception {
  cluster = new MiniDFSCluster.Builder(config).
                               numDataNodes(2).
                               manageNameDfsDirs(false).build();
  cluster.waitActive();
  try {

    FSImage fsi = cluster.getNameNode().getFSImage();

    // it is started with dfs.name.dir.restore set to true (in SetUp())
    boolean restore = fsi.getRestoreFailedStorage();
    LOG.info("Restore is " + restore);
    assertEquals(restore, true);

    // now run DFSAdmnin command

    String cmd = "-fs NAMENODE -restoreFailedStorage false";
    String namenode = config.get(DFSConfigKeys.FS_DEFAULT_NAME_KEY, "file:///");
    CommandExecutor executor = 
      CmdFactoryDFS.getCommandExecutor(
        new CLITestData.TestCmd(cmd, CLITestData.TestCmd.CommandType.DFSADMIN),
        namenode);
    executor.executeCommand(cmd);
    restore = fsi.getRestoreFailedStorage();
    assertFalse("After set true call restore is " + restore, restore);

    // run one more time - to set it to true again
    cmd = "-fs NAMENODE -restoreFailedStorage true";
    executor.executeCommand(cmd);
    restore = fsi.getRestoreFailedStorage();
    assertTrue("After set false call restore is " + restore, restore);
    
 // run one more time - no change in value
    cmd = "-fs NAMENODE -restoreFailedStorage check";
    CommandExecutor.Result cmdResult = executor.executeCommand(cmd);
    restore = fsi.getRestoreFailedStorage();
    assertTrue("After check call restore is " + restore, restore);
    String commandOutput = cmdResult.getCommandOutput();
    commandOutput.trim();
    assertTrue(commandOutput.contains("restoreFailedStorage is set to true"));
    

  } finally {
    cluster.shutdown();
  }
}