Changeset 1661 for XIOS/dev/dev_trunk_omp/src/node/domain.cpp
- Timestamp:
- 05/15/19 17:19:08 (5 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/dev/dev_trunk_omp/src/node/domain.cpp
r1646 r1661 116 116 \return the number of indexes written by each server 117 117 */ 118 int CDomain::getNumberWrittenIndexes( ep_lib::MPI_Comm writtenCom)118 int CDomain::getNumberWrittenIndexes(MPI_Comm writtenCom) 119 119 TRY 120 120 { 121 121 int writtenSize; 122 ep_lib::MPI_Comm_size(writtenCom, &writtenSize);122 MPI_Comm_size(writtenCom, &writtenSize); 123 123 return numberWrittenIndexes_[writtenSize]; 124 124 } … … 129 129 \return the total number of indexes written by the servers 130 130 */ 131 int CDomain::getTotalNumberWrittenIndexes( ep_lib::MPI_Comm writtenCom)131 int CDomain::getTotalNumberWrittenIndexes(MPI_Comm writtenCom) 132 132 TRY 133 133 { 134 134 int writtenSize; 135 ep_lib::MPI_Comm_size(writtenCom, &writtenSize);135 MPI_Comm_size(writtenCom, &writtenSize); 136 136 return totalNumberWrittenIndexes_[writtenSize]; 137 137 } … … 142 142 \return the offset of indexes written by each server 143 143 */ 144 int CDomain::getOffsetWrittenIndexes( ep_lib::MPI_Comm writtenCom)144 int CDomain::getOffsetWrittenIndexes(MPI_Comm writtenCom) 145 145 TRY 146 146 { 147 147 int writtenSize; 148 ep_lib::MPI_Comm_size(writtenCom, &writtenSize);148 MPI_Comm_size(writtenCom, &writtenSize); 149 149 return offsetWrittenIndexes_[writtenSize]; 150 150 } 151 151 CATCH_DUMP_ATTR 152 152 153 CArray<int, 1>& CDomain::getCompressedIndexToWriteOnServer( ep_lib::MPI_Comm writtenCom)153 CArray<int, 1>& CDomain::getCompressedIndexToWriteOnServer(MPI_Comm writtenCom) 154 154 TRY 155 155 { 156 156 int writtenSize; 157 ep_lib::MPI_Comm_size(writtenCom, &writtenSize);157 MPI_Comm_size(writtenCom, &writtenSize); 158 158 return compressedIndexToWriteOnServer[writtenSize]; 159 159 } … … 707 707 int v ; 708 708 v=ibegin ; 709 ep_lib::MPI_Allgather(&v,1,MPI_INT,ibegin_g,1,MPI_INT,client->intraComm) ;709 MPI_Allgather(&v,1,MPI_INT,ibegin_g,1,MPI_INT,client->intraComm) ; 710 710 v=jbegin ; 711 ep_lib::MPI_Allgather(&v,1,MPI_INT,jbegin_g,1,MPI_INT,client->intraComm) ;711 MPI_Allgather(&v,1,MPI_INT,jbegin_g,1,MPI_INT,client->intraComm) ; 712 712 v=ni ; 713 ep_lib::MPI_Allgather(&v,1,MPI_INT,ni_g,1,MPI_INT,client->intraComm) ;713 MPI_Allgather(&v,1,MPI_INT,ni_g,1,MPI_INT,client->intraComm) ; 714 714 v=nj ; 715 ep_lib::MPI_Allgather(&v,1,MPI_INT,nj_g,1,MPI_INT,client->intraComm) ;716 717 ep_lib::MPI_Allgatherv(lon.dataFirst(),ni,MPI_DOUBLE,lon_g.dataFirst(),ni_g, ibegin_g,MPI_DOUBLE,client->intraComm) ;718 ep_lib::MPI_Allgatherv(lat.dataFirst(),nj,MPI_DOUBLE,lat_g.dataFirst(),nj_g, jbegin_g,MPI_DOUBLE,client->intraComm) ;715 MPI_Allgather(&v,1,MPI_INT,nj_g,1,MPI_INT,client->intraComm) ; 716 717 MPI_Allgatherv(lon.dataFirst(),ni,MPI_DOUBLE,lon_g.dataFirst(),ni_g, ibegin_g,MPI_DOUBLE,client->intraComm) ; 718 MPI_Allgatherv(lat.dataFirst(),nj,MPI_DOUBLE,lat_g.dataFirst(),nj_g, jbegin_g,MPI_DOUBLE,client->intraComm) ; 719 719 720 720 delete[] ibegin_g ; … … 1949 1949 displs[0] = 0; 1950 1950 int localCount = connectedServerRank_[nbServer].size() ; 1951 ep_lib::MPI_Gather(&localCount, 1, MPI_INT, &counts[0], 1, MPI_INT, 0, client->intraComm) ;1951 MPI_Gather(&localCount, 1, MPI_INT, &counts[0], 1, MPI_INT, 0, client->intraComm) ; 1952 1952 for (int i = 0; i < clientSize-1; ++i) 1953 1953 { … … 1955 1955 } 1956 1956 std::vector<int> allConnectedServers(displs[clientSize-1]+counts[clientSize-1]); 1957 1958 ep_lib::MPI_Gatherv(&(connectedServerRank_[nbServer])[0], localCount, MPI_INT, &allConnectedServers[0], &counts[0], &displs[0], MPI_INT, 0, client->intraComm); 1959 1957 MPI_Gatherv(&(connectedServerRank_[nbServer])[0], localCount, MPI_INT, &allConnectedServers[0], &counts[0], &displs[0], MPI_INT, 0, client->intraComm); 1960 1958 1961 1959 if ((allConnectedServers.size() != nbServer) && (rank == 0)) … … 2022 2020 CATCH_DUMP_ATTR 2023 2021 2024 void CDomain::computeWrittenCompressedIndex( ep_lib::MPI_Comm writtenComm)2022 void CDomain::computeWrittenCompressedIndex(MPI_Comm writtenComm) 2025 2023 TRY 2026 2024 { 2027 2025 int writtenCommSize; 2028 ep_lib::MPI_Comm_size(writtenComm, &writtenCommSize);2026 MPI_Comm_size(writtenComm, &writtenCommSize); 2029 2027 if (compressedIndexToWriteOnServer.find(writtenCommSize) != compressedIndexToWriteOnServer.end()) 2030 2028 return; … … 2083 2081 { 2084 2082 2085 ep_lib::MPI_Allreduce(&numberWrittenIndexes_[writtenCommSize], &totalNumberWrittenIndexes_[writtenCommSize], 1, MPI_INT, MPI_SUM, writtenComm);2086 ep_lib::MPI_Scan(&numberWrittenIndexes_[writtenCommSize], &offsetWrittenIndexes_[writtenCommSize], 1, MPI_INT, MPI_SUM, writtenComm);2083 MPI_Allreduce(&numberWrittenIndexes_[writtenCommSize], &totalNumberWrittenIndexes_[writtenCommSize], 1, MPI_INT, MPI_SUM, writtenComm); 2084 MPI_Scan(&numberWrittenIndexes_[writtenCommSize], &offsetWrittenIndexes_[writtenCommSize], 1, MPI_INT, MPI_SUM, writtenComm); 2087 2085 offsetWrittenIndexes_[writtenCommSize] -= numberWrittenIndexes_[writtenCommSize]; 2088 2086 }
Note: See TracChangeset
for help on using the changeset viewer.