Changeset 1642 for XIOS/dev/branch_openmp/src/dht_auto_indexing.cpp
- Timestamp:
- 01/23/19 10:31:44 (5 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/dev/branch_openmp/src/dht_auto_indexing.cpp
r1328 r1642 8 8 */ 9 9 #include "dht_auto_indexing.hpp" 10 using namespace ep_lib;11 10 12 11 namespace xios … … 23 22 24 23 CDHTAutoIndexing::CDHTAutoIndexing(const CArray<size_t,1>& hashValue, 25 const MPI_Comm& clientIntraComm)24 const ep_lib::MPI_Comm& clientIntraComm) 26 25 : CClientClientDHTTemplate<size_t>(clientIntraComm) 27 26 { … … 29 28 nbIndexOnProc_ = hashValue.size(); 30 29 size_t nbIndexAccum; 31 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); 32 31 33 32 // Broadcasting the total number of indexes 34 33 int rank, size; 35 MPI_Comm_rank(clientIntraComm, &rank);36 MPI_Comm_size(clientIntraComm, &size);34 ep_lib::MPI_Comm_rank(clientIntraComm, &rank); 35 ep_lib::MPI_Comm_size(clientIntraComm, &size); 37 36 if (rank == (size-1)) nbIndexesGlobal_ = nbIndexAccum; 38 MPI_Bcast(&nbIndexesGlobal_, 1, MPI_UNSIGNED_LONG, size-1, clientIntraComm);37 ep_lib::MPI_Bcast(&nbIndexesGlobal_, 1, EP_UNSIGNED_LONG, size-1, clientIntraComm); 39 38 40 39 CArray<size_t,1>::const_iterator itbIdx = hashValue.begin(), itIdx, … … 59 58 */ 60 59 CDHTAutoIndexing::CDHTAutoIndexing(Index2VectorInfoTypeMap& hashInitMap, 61 const MPI_Comm& clientIntraComm)60 const ep_lib::MPI_Comm& clientIntraComm) 62 61 : CClientClientDHTTemplate<size_t>(clientIntraComm) 63 62 { … … 65 64 nbIndexOnProc_ = hashInitMap.size(); 66 65 size_t nbIndexAccum; 67 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); 68 67 69 68 int rank, size; 70 MPI_Comm_rank(clientIntraComm, &rank);71 MPI_Comm_size(clientIntraComm, &size);69 ep_lib::MPI_Comm_rank(clientIntraComm, &rank); 70 ep_lib::MPI_Comm_size(clientIntraComm, &size); 72 71 if (rank == (size-1)) nbIndexesGlobal_ = nbIndexAccum; 73 MPI_Bcast(&nbIndexesGlobal_, 1, MPI_UNSIGNED_LONG, size-1, clientIntraComm);72 ep_lib::MPI_Bcast(&nbIndexesGlobal_, 1, EP_UNSIGNED_LONG, size-1, clientIntraComm); 74 73 75 74 Index2VectorInfoTypeMap::iterator itbIdx = hashInitMap.begin(), itIdx,
Note: See TracChangeset
for help on using the changeset viewer.