Method extract_data

cpp/src/arrow/c/bridge.cc:2795–2809

  }

  static int extract_data(struct ArrowAsyncTask* task, struct ArrowDeviceArray* out) {
    std::unique_ptr<PrivateTaskData> private_data{
        reinterpret_cast<PrivateTaskData*>(task->private_data)};
    int ret = 0;
    if (out != nullptr) {
      auto status = ExportDeviceRecordBatch(*private_data->record_,
                                            private_data->record_->GetSyncEvent(), out);
      if (!status.ok()) {
        std::lock_guard<std::mutex> lock(private_data->producer_->mutex_);
        private_data->producer_->error_ = status;
      }
    }

    return ret;
  }

  struct ArrowAsyncDeviceStreamHandler* handler_;
  std::shared_ptr<State> state_;