Method GcsTestbench

cpp/src/arrow/filesystem/gcsfs_test.cc:68–114

class GcsTestbench : public ::testing::Environment {
 public:
  GcsTestbench() {
    port_ = std::to_string(GetListenPort());
    auto error = std::string("Could not start GCS emulator 'storage-testbench'");
    auto server_process = std::make_unique<util::Process>();
    auto status = server_process->SetExecutable("storage-testbench");
    if (!status.ok()) {
      error += ": " + status.ToString();
      error_ = std::move(error);
      return;
    }

    server_process->SetArgs({"--port", port_});
    server_process->IgnoreStderr();
    status = server_process->Execute();
    if (!status.ok()) {
      error += ": " + status.ToString();
      error_ = std::move(error);
      return;
    }

    auto testbench_is_running = [&server_process, this]() {
      auto ready_timeout = std::chrono::seconds(10);
      std::chrono::time_point<std::chrono::steady_clock> end =
          std::chrono::steady_clock::now() + ready_timeout;
      while (server_process->IsRunning() && std::chrono::steady_clock::now() < end) {
        auto client = gcs::Client(
            google::cloud::Options{}
                .set<gcs::RestEndpointOption>("http://127.0.0.1:" + port_)
                .set<gc::UnifiedCredentialsOption>(gc::MakeInsecureCredentials())
                .set<gcs::RetryPolicyOption>(
                    gcs::LimitedTimeRetryPolicy(ready_timeout).clone()));
        auto metadata = client.GetBucketMetadata("nonexistent");
        if (metadata.status().code() == google::cloud::StatusCode::kNotFound) {
          return true;
        }
      }
      return false;
    };

    if (!testbench_is_running()) {
      error += " (failed to listen)";
      error_ = std::move(error);
      return;
    }

    server_process_ = std::move(server_process);
  }

  bool running() { return server_process_ && server_process_->IsRunning(); }