Method SetUp

cpp/src/arrow/io/hdfs_test.cc:84–122

Set up shared state between unit tests

  // Set up shared state between unit tests
  void SetUp() {
    internal::LibHdfsShim* driver_shim;

    client_ = nullptr;
    scratch_dir_ =
        (std::filesystem::temp_directory_path() / "arrow-hdfs/scratch-").string();
    int random_size = 4;
    scratch_dir_.resize(scratch_dir_.size() + random_size, '%');
    random_alnum(
        random_size, 0,
        reinterpret_cast<uint8_t*>(&scratch_dir_[scratch_dir_.size() - random_size]));

    loaded_driver_ = false;

    Status msg = ConnectLibHdfs(&driver_shim);
    if (!msg.ok()) {
      if (std::getenv("ARROW_HDFS_TEST_LIBHDFS_REQUIRE")) {
        FAIL() << "Loading libhdfs failed: " << msg.ToString();
      } else {
        std::cout << "Loading libhdfs failed, skipping tests gracefully: "
                  << msg.ToString() << std::endl;
      }
      return;
    }

    loaded_driver_ = true;

    const char* host = std::getenv("ARROW_HDFS_TEST_HOST");
    const char* port = std::getenv("ARROW_HDFS_TEST_PORT");
    const char* user = std::getenv("ARROW_HDFS_TEST_USER");

    ASSERT_TRUE(user != nullptr) << "Set ARROW_HDFS_TEST_USER";

    conf_.host = host == nullptr ? "localhost" : host;
    conf_.user = user;
    conf_.port = port == nullptr ? 20500 : atoi(port);

    ASSERT_OK(HadoopFileSystem::Connect(&conf_, &client_));
  }

  void TearDown() {
    if (client_) {