Function TestProcess

Parallel/MPI/Testing/Cxx/TestProcess.cxx:79–133

}

int TestProcess(int argc, char* argv[])
{
  // This is here to avoid false leak messages from vtkDebugLeaks when
  // using mpich. It appears that the root process which spawns all the
  // main processes waits in MPI_Init() and calls exit() when
  // the others are done, causing apparent memory leaks for any objects
  // created before MPI_Init().
  MPI_Init(&argc, &argv);

  // Note that this will create a vtkMPIController if MPI
  // is configured, vtkThreadedController otherwise.
  vtkMPIController* c = vtkMPIController::New();
  c->Initialize(&argc, &argv, 1);

  int retVal = 1;

  vtkMultiProcessController::SetGlobalController(c);

  int numProcs = c->GetNumberOfProcesses();
  int me = c->GetLocalProcessId();

  if (numProcs != 2)
  {
    if (me == 0)
    {
      std::cout << "DistributedData test requires 2 processes" << std::endl;
    }
    c->Delete();
    return retVal;
  }

  if (!c->IsA("vtkMPIController"))
  {
    if (me == 0)
    {
      std::cout << "TestProcess test requires MPI" << std::endl;
    }
    c->Delete();
    return retVal;
  }

  MyProcess* p = MyProcess::New();
  p->SetArgs(argc, argv);

  c->SetSingleProcessObject(p);
  c->SingleMethodExecute();

  retVal = p->GetReturnValue();

  p->Delete();
  c->Finalize();
  c->Delete();

  return retVal;
}