Method RequestData

IO/CatalystConduit/vtkConduitSource.cxx:246–302

----------------------------------------------------------------------------

//----------------------------------------------------------------------------
int vtkConduitSource::RequestData(
  vtkInformation*, vtkInformationVector**, vtkInformationVector* outputVector)
{
  auto& internals = (*this->Internals);
  vtkDataObject* real_output = vtkDataObject::GetData(outputVector, 0);

  bool dataGenerated = false;
  if (this->UseAMRMeshProtocol)
  {
    dataGenerated = this->GenerateAMR(real_output);
  }
  else if (this->UseMultiMeshProtocol)
  {
    dataGenerated = this->GeneratePartitionedDataSetCollection(real_output);
  }
  else
  {
    dataGenerated = this->GeneratePartitionedDataSet(real_output);
  }

  // Check wether all ranks successfully generated the data. If at least one rank failed, we need to
  // return 0 on every nodes to prevent code hanging in the pipeline.
  vtkMultiProcessController* controller = vtkMultiProcessController::GetGlobalController();
  std::vector<int> allDataGenerationResults(controller->GetNumberOfProcesses());
  int dataGenerationLocalResult = dataGenerated;
  controller->AllGather(&dataGenerationLocalResult, allDataGenerationResults.data(), 1);

  for (size_t nodeIdx = 0; nodeIdx < allDataGenerationResults.size(); nodeIdx++)
  {
    if (!allDataGenerationResults[nodeIdx])
    {
      vtkLogF(ERROR, "Data generation failure on process %lu", nodeIdx);
      return 0;
    }
  }

  if (this->OutputMultiBlock)
  {
    vtkNew<vtkConvertToMultiBlockDataSet> converter;
    converter->SetInputData(real_output);
    converter->Update();
    real_output->ShallowCopy(converter->GetOutput());
  }

  if (internals.GlobalFieldsNodeValid)
  {
    vtkConduitToDataObject::AddFieldData(
      real_output, internals.GlobalFieldsNode, /*isAMReX=*/false);
  }

  if (internals.Node.has_path("state/fields"))
  {
    vtkConduitToDataObject::AddFieldData(real_output, internals.Node["state/fields"]);
  }

  return 1;
}