Method PartitionController

Parallel/Core/vtkMultiProcessController.cxx:277–328

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

//------------------------------------------------------------------------------
vtkMultiProcessController* vtkMultiProcessController::PartitionController(
  int localColor, int localKey)
{
  vtkMultiProcessController* subController = nullptr;

  int numProc = this->GetNumberOfProcesses();

  std::vector<int> allColors(numProc);
  this->AllGather(&localColor, allColors.data(), 1);

  std::vector<int> allKeys(numProc);
  this->AllGather(&localKey, allKeys.data(), 1);

  std::vector<bool> inPartition;
  inPartition.assign(numProc, false);

  for (int i = 0; i < numProc; i++)
  {
    if (inPartition[i])
      continue;
    int targetColor = allColors[i];
    std::list<int> partitionIds; // Make sorted list, then put in group.
    for (int j = i; j < numProc; j++)
    {
      if (allColors[j] != targetColor)
        continue;
      inPartition[j] = true;
      std::list<int>::iterator iter = partitionIds.begin();
      while ((iter != partitionIds.end()) && (allKeys[*iter] <= allKeys[j]))
      {
        ++iter;
      }
      partitionIds.insert(iter, j);
    }
    // Copy list into process group.
    vtkNew<vtkProcessGroup> group;
    group->Initialize(this);
    group->RemoveAllProcessIds();
    for (std::list<int>::iterator iter = partitionIds.begin(); iter != partitionIds.end(); ++iter)
    {
      group->AddProcessId(*iter);
    }
    // Use group to create controller.
    vtkMultiProcessController* sc = this->CreateSubController(group);
    if (sc)
    {
      subController = sc;
    }
  }

  return subController;
}

//------------------------------------------------------------------------------
unsigned long vtkMultiProcessController::AddRMICallback(