Function InitDfsClient

src/admincli.cc:1182–1210

}

int InitDfsClient() {
  if (g_dfs != NULL) {
    return 0;
  }
  if (FLAGS_tera_leveldb_env_dfs_type == "nfs") {
    if (access(FLAGS_tera_leveldb_env_nfs_conf_path.c_str(), R_OK) == 0) {
      LOG(INFO) << "init nfs system: use configure file" << FLAGS_tera_leveldb_env_nfs_conf_path;
      leveldb::Nfs::Init(FLAGS_tera_leveldb_env_nfs_mountpoint,
                         FLAGS_tera_leveldb_env_nfs_conf_path);
      g_dfs = leveldb::Nfs::GetInstance();
    } else {
      LOG(ERROR) << "init nfs system: no configure file found";
      return -1;
    }
  } else if (FLAGS_tera_leveldb_env_dfs_type == "hdfs2") {
    LOG(INFO) << "init hdfs2 file system";
    g_dfs = new leveldb::Hdfs2(FLAGS_tera_leveldb_env_hdfs2_nameservice_list);
  } else if (FLAGS_tera_leveldb_env_dfs_type == "hdfs") {
    g_dfs = new leveldb::Hdfs();
  } else {
    LOG(INFO) << "init dfs system: " << FLAGS_tera_dfs_so_path << "(" << FLAGS_tera_dfs_conf << ")";
    g_dfs = leveldb::Dfs::NewDfs(FLAGS_tera_dfs_so_path, FLAGS_tera_dfs_conf);
  }

  if (g_dfs == NULL) {
    return -1;
  }
  return 0;
}

CliStatus AllDiff(const std::string& prefix_path) {
  int ret = DfsListDir(prefix_path, &g_tables);