Method ProcessRequest

Common/ExecutionModel/vtkReaderAlgorithm.cxx:24–125

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

//------------------------------------------------------------------------------
vtkTypeBool vtkReaderAlgorithm::ProcessRequest(
  vtkInformation* request, vtkInformationVector** vtkNotUsed(inInfo), vtkInformationVector* outInfo)
{
  using vtkSDDP = vtkStreamingDemandDrivenPipeline;
  vtkInformation* reqs = outInfo->GetInformationObject(0);
  const int hasTime = reqs->Has(vtkSDDP::UPDATE_TIME_STEP());
  const double* steps = reqs->Get(vtkStreamingDemandDrivenPipeline::TIME_STEPS());
  int timeIndex = 0;
  if (hasTime && steps)
  {
    double requestedTimeStep = reqs->Get(vtkStreamingDemandDrivenPipeline::UPDATE_TIME_STEP());

    int length = reqs->Length(vtkStreamingDemandDrivenPipeline::TIME_STEPS());

    // find the first time value larger than requested time value
    // this logic could be improved
    int cnt = 0;
    while (cnt < length - 1 && steps[cnt] < requestedTimeStep)
    {
      cnt++;
    }
    timeIndex = cnt;
  }

  int result = 1;
  if (request->Has(vtkSDDP::REQUEST_DATA_OBJECT()))
  {
    vtkDataObject* currentOutput = vtkDataObject::GetData(outInfo);
    vtkDataObject* output = this->CreateOutput(currentOutput);
    if (output)
    {
      result = 1;
      if (output != currentOutput)
      {
        outInfo->GetInformationObject(0)->Set(vtkDataObject::DATA_OBJECT(), output);
        output->Delete();
      }
    }
  }
  else if (request->Has(vtkSDDP::REQUEST_INFORMATION()))
  {
    try
    {
      result = this->ReadMetaData(outInfo->GetInformationObject(0));
    }
    catch (const std::exception&)
    {
      result = 0;
    }
  }
  else if (request->Has(vtkSDDP::REQUEST_TIME_DEPENDENT_INFORMATION()))
  {
    try
    {
      result = this->ReadTimeDependentMetaData(timeIndex, outInfo->GetInformationObject(0));
    }
    catch (const std::exception&)
    {