Function AllDiff

src/admincli.cc:1212–1253

}

CliStatus AllDiff(const std::string& prefix_path) {
  int ret = DfsListDir(prefix_path, &g_tables);
  if (0 != ret) {
    LOG(ERROR) << "all check fail, get table path fail";
    return CliStatus::kError;
  }

  if (g_tables.size() > 0) {
    // scan tablet meta and compare, thread pool parallel
    g_thread_count = g_tables.size();
    const std::string gc_table("#trackable_gc_trash");
    const std::string trash_table("#trash");
    const std::string meta_table("meta");
    const std::string stat_table("stat_table");

    ThreadPool thread_pool(g_tables.size());
    for (size_t i = 0; i < g_tables.size(); ++i) {
      LOG(INFO) << "table is:(" << g_tables[i] << ")";
      if (g_tables[i] == gc_table || g_tables[i] == trash_table || g_tables[i] == meta_table ||
          g_tables[i] == stat_table) {
        g_thread_count--;
        continue;
      }
      ThreadPool::Task task = std::bind(&ScanAndDiff, g_tables[i], prefix_path);
      thread_pool.AddTask(task);
    }

    while (g_thread_count > 0) {
      LOG(INFO) << get_time_str(time(NULL)) << " " << g_thread_count << "scan and diff ......";
      sleep(5);
    }
    thread_pool.Stop(true);
  }

  if (g_diff_count == 0) {
    std::cout << "tables no diff" << std::endl;
  } else {
    std::cout << "table diff num:" << g_diff_count << ", check the details in ./meta.diff"
              << std::endl;
  }
  return CliStatus::kOk;
}

CliStatus TableDiff(const std::string& prefix_path, const std::string& table_name) {
  int ret = ScanAndDiff(table_name, prefix_path);