Method AllReduceUniqueList

Parallel/Core/vtkSubGroup.cxx:399–454

#endif

int vtkSubGroup::AllReduceUniqueList(int* list, int len, int** newList)
{
  int transferLen, myListLen, lastListLen, nextListLen;

  int* myList = nullptr;
  myListLen = vtkSubGroup::MakeSortedUnique(list, len, &myList);

  if (this->nmembers == 1)
  {
    *newList = myList;
    return myListLen;
  }

  int* lastList = myList;
  lastListLen = myListLen;

  for (int i = 0; i < this->nFrom; i++)
  {
    this->comm->Receive(&transferLen, 1, this->members[this->fanInFrom[i]], this->tag);

    int* buf = new int[transferLen];

    this->comm->Receive(buf, transferLen, this->members[this->fanInFrom[i]], this->tag + 1);

    int* nextList = nullptr;
    nextListLen =
      vtkSubGroup::MergeSortedUnique(lastList, lastListLen, buf, transferLen, &nextList);

    delete[] buf;
    delete[] lastList;

    lastList = nextList;
    lastListLen = nextListLen;
  }

  if (this->nTo > 0)
  {
    this->comm->Send(&lastListLen, 1, this->members[this->fanInTo], this->tag);

    this->comm->Send(lastList, lastListLen, this->members[this->fanInTo], this->tag + 1);
  }

  this->Broadcast(&lastListLen, 1, 0);

  if (this->myLocalRank > 0)
  {
    delete[] lastList;
    lastList = new int[lastListLen];
  }

  this->Broadcast(lastList, lastListLen, 0);

  *newList = lastList;

  return lastListLen;
}
int vtkSubGroup::MergeSortedUnique(int* list1, int len1, int* list2, int len2, int** newList)
{