Changeset 1638 for XIOS/trunk/src/dht_auto_indexing.cpp
- Timestamp:
- 01/22/19 16:15:03 (5 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/trunk/src/dht_auto_indexing.cpp
r1158 r1638 22 22 23 23 CDHTAutoIndexing::CDHTAutoIndexing(const CArray<size_t,1>& hashValue, 24 const MPI_Comm& clientIntraComm)24 const ep_lib::MPI_Comm& clientIntraComm) 25 25 : CClientClientDHTTemplate<size_t>(clientIntraComm) 26 26 { … … 28 28 nbIndexOnProc_ = hashValue.size(); 29 29 size_t nbIndexAccum; 30 MPI_Scan(&nbIndexOnProc_, &nbIndexAccum, 1, MPI_UNSIGNED_LONG, MPI_SUM, clientIntraComm);30 ep_lib::MPI_Scan(&nbIndexOnProc_, &nbIndexAccum, 1, EP_UNSIGNED_LONG, EP_SUM, clientIntraComm); 31 31 32 32 // Broadcasting the total number of indexes 33 33 int rank, size; 34 MPI_Comm_rank(clientIntraComm, &rank);35 MPI_Comm_size(clientIntraComm, &size);34 ep_lib::MPI_Comm_rank(clientIntraComm, &rank); 35 ep_lib::MPI_Comm_size(clientIntraComm, &size); 36 36 if (rank == (size-1)) nbIndexesGlobal_ = nbIndexAccum; 37 MPI_Bcast(&nbIndexesGlobal_, 1, MPI_UNSIGNED_LONG, size-1, clientIntraComm);37 ep_lib::MPI_Bcast(&nbIndexesGlobal_, 1, EP_UNSIGNED_LONG, size-1, clientIntraComm); 38 38 39 39 CArray<size_t,1>::const_iterator itbIdx = hashValue.begin(), itIdx, … … 58 58 */ 59 59 CDHTAutoIndexing::CDHTAutoIndexing(Index2VectorInfoTypeMap& hashInitMap, 60 const MPI_Comm& clientIntraComm)60 const ep_lib::MPI_Comm& clientIntraComm) 61 61 : CClientClientDHTTemplate<size_t>(clientIntraComm) 62 62 { … … 64 64 nbIndexOnProc_ = hashInitMap.size(); 65 65 size_t nbIndexAccum; 66 MPI_Scan(&nbIndexOnProc_, &nbIndexAccum, 1, MPI_UNSIGNED_LONG, MPI_SUM, clientIntraComm);66 ep_lib::MPI_Scan(&nbIndexOnProc_, &nbIndexAccum, 1, EP_UNSIGNED_LONG, EP_SUM, clientIntraComm); 67 67 68 68 int rank, size; 69 MPI_Comm_rank(clientIntraComm, &rank);70 MPI_Comm_size(clientIntraComm, &size);69 ep_lib::MPI_Comm_rank(clientIntraComm, &rank); 70 ep_lib::MPI_Comm_size(clientIntraComm, &size); 71 71 if (rank == (size-1)) nbIndexesGlobal_ = nbIndexAccum; 72 MPI_Bcast(&nbIndexesGlobal_, 1, MPI_UNSIGNED_LONG, size-1, clientIntraComm);72 ep_lib::MPI_Bcast(&nbIndexesGlobal_, 1, EP_UNSIGNED_LONG, size-1, clientIntraComm); 73 73 74 74 Index2VectorInfoTypeMap::iterator itbIdx = hashInitMap.begin(), itIdx,
Note: See TracChangeset
for help on using the changeset viewer.