Method on_error

cpp/src/arrow/c/bridge.cc:2674–2699

  }

  static void on_error(ArrowAsyncDeviceStreamHandler* self, int code, const char* message,
                       const char* metadata) {
    auto* private_data = reinterpret_cast<PrivateData*>(self->private_data);
    std::string message_str, metadata_str;
    if (message != nullptr) {
      message_str = message;
    }
    if (metadata != nullptr) {
      metadata_str = metadata;
    }

    Status error = Status::FromDetailAndArgs(
        StatusCode::UnknownError,
        std::make_shared<AsyncErrorDetail>(code, message_str, std::move(metadata_str)),
        std::move(message_str));

    if (!private_data->fut_iterator_.is_finished()) {
      private_data->fut_iterator_.MarkFinished(error);
      return;
    }

    std::unique_lock<std::mutex> lock(private_data->state_->mutex_);
    private_data->state_->error_ = std::move(error);
    lock.unlock();
    private_data->state_->cv_.notify_one();
  }

  static void release(ArrowAsyncDeviceStreamHandler* self) {
    delete reinterpret_cast<PrivateData*>(self->private_data);