Changeset 1661 for XIOS/dev/dev_trunk_omp/src/node/axis.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/axis.cpp
r1646 r1661 149 149 \return the number of indexes written by each server 150 150 */ 151 int CAxis::getNumberWrittenIndexes( ep_lib::MPI_Comm writtenCom)151 int CAxis::getNumberWrittenIndexes(MPI_Comm writtenCom) 152 152 TRY 153 153 { 154 154 int writtenSize; 155 ep_lib::MPI_Comm_size(writtenCom, &writtenSize);155 MPI_Comm_size(writtenCom, &writtenSize); 156 156 return numberWrittenIndexes_[writtenSize]; 157 157 } … … 162 162 \return the total number of indexes written by the servers 163 163 */ 164 int CAxis::getTotalNumberWrittenIndexes( ep_lib::MPI_Comm writtenCom)164 int CAxis::getTotalNumberWrittenIndexes(MPI_Comm writtenCom) 165 165 TRY 166 166 { 167 167 int writtenSize; 168 ep_lib::MPI_Comm_size(writtenCom, &writtenSize);168 MPI_Comm_size(writtenCom, &writtenSize); 169 169 return totalNumberWrittenIndexes_[writtenSize]; 170 170 } … … 175 175 \return the offset of indexes written by each server 176 176 */ 177 int CAxis::getOffsetWrittenIndexes( ep_lib::MPI_Comm writtenCom)177 int CAxis::getOffsetWrittenIndexes(MPI_Comm writtenCom) 178 178 TRY 179 179 { 180 180 int writtenSize; 181 ep_lib::MPI_Comm_size(writtenCom, &writtenSize);181 MPI_Comm_size(writtenCom, &writtenSize); 182 182 return offsetWrittenIndexes_[writtenSize]; 183 183 } 184 184 CATCH_DUMP_ATTR 185 185 186 CArray<int, 1>& CAxis::getCompressedIndexToWriteOnServer( ep_lib::MPI_Comm writtenCom)186 CArray<int, 1>& CAxis::getCompressedIndexToWriteOnServer(MPI_Comm writtenCom) 187 187 TRY 188 188 { 189 189 int writtenSize; 190 ep_lib::MPI_Comm_size(writtenCom, &writtenSize);190 MPI_Comm_size(writtenCom, &writtenSize); 191 191 return compressedIndexToWriteOnServer[writtenSize]; 192 192 } … … 787 787 CATCH_DUMP_ATTR 788 788 789 void CAxis::computeWrittenCompressedIndex( ep_lib::MPI_Comm writtenComm)789 void CAxis::computeWrittenCompressedIndex(MPI_Comm writtenComm) 790 790 TRY 791 791 { 792 792 int writtenCommSize; 793 ep_lib::MPI_Comm_size(writtenComm, &writtenCommSize);793 MPI_Comm_size(writtenComm, &writtenCommSize); 794 794 if (compressedIndexToWriteOnServer.find(writtenCommSize) != compressedIndexToWriteOnServer.end()) 795 795 return; … … 869 869 { 870 870 871 ep_lib::MPI_Allreduce(&numberWrittenIndexes_[writtenCommSize], &totalNumberWrittenIndexes_[writtenCommSize], 1, MPI_INT, MPI_SUM, writtenComm);872 ep_lib::MPI_Scan(&numberWrittenIndexes_[writtenCommSize], &offsetWrittenIndexes_[writtenCommSize], 1, MPI_INT, MPI_SUM, writtenComm);871 MPI_Allreduce(&numberWrittenIndexes_[writtenCommSize], &totalNumberWrittenIndexes_[writtenCommSize], 1, MPI_INT, MPI_SUM, writtenComm); 872 MPI_Scan(&numberWrittenIndexes_[writtenCommSize], &offsetWrittenIndexes_[writtenCommSize], 1, MPI_INT, MPI_SUM, writtenComm); 873 873 offsetWrittenIndexes_[writtenCommSize] -= numberWrittenIndexes_[writtenCommSize]; 874 874 }
Note: See TracChangeset
for help on using the changeset viewer.