Method Exchange

Filters/ParallelMPI/vtkStructuredImplicitConnectivity.cxx:778–821

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

//------------------------------------------------------------------------------
void CommunicationManager::Exchange(vtkMPIController* comm)
{
  std::map<int, unsigned char*>::iterator it;

  // STEP 0: exchange & allocate buffer sizes
  this->AllocateRcvBuffers(comm);

  // STEP 1: Allocate vector to store request objects for non-blocking comm.
  int rqstIdx = 0;
  this->Requests.resize(this->NumMsgs());

  // STEP 2: Post Rcvs
  for (it = this->Rcv.begin(); it != this->Rcv.end(); ++it)
  {
    int fromRank = it->first;
    unsigned char* buffer = it->second;
    assert("pre: rcv buffer size not found!" &&
      this->RcvByteSize.find(fromRank) != this->RcvByteSize.end());
    int bytesize = this->RcvByteSize[fromRank];

    comm->NoBlockReceive(buffer, bytesize, fromRank, 0, this->Requests[rqstIdx]);
    ++rqstIdx;
  }

  // STEP 3: Post Sends
  for (it = this->Send.begin(); it != this->Send.end(); ++it)
  {
    int toRank = it->first;
    unsigned char* buffer = it->second;
    assert("pre: rcv buffer size not found!" &&
      this->SendByteSize.find(toRank) != this->SendByteSize.end());
    int bytesize = this->SendByteSize[toRank];

    comm->NoBlockSend(buffer, bytesize, toRank, 0, this->Requests[rqstIdx]);
    ++rqstIdx;
  }

  // STEP 4: WaitAll
  if (!this->Requests.empty())
  {
    comm->WaitAll(this->NumMsgs(), this->Requests.data());
  }
  this->Requests.clear();
}

VTK_ABI_NAMESPACE_END
} // END namespace detail