roundIter 843 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int roundIter; roundIter 845 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (roundIter=0;roundIter<numberOfRounds;roundIter++) { roundIter 855 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (targetAggsForMyDataFirstOffLenIndex[roundIter][aggIter] != -1) { roundIter 856 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset currentRoundFDStartForMyTargetAgg = (ADIO_Offset)((ADIO_Offset)targetAggsForMyDataFDStart[aggIter] + (ADIO_Offset)((ADIO_Offset)roundIter*coll_bufsize)); roundIter 857 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset currentRoundFDEndForMyTargetAgg = (ADIO_Offset)((ADIO_Offset)targetAggsForMyDataFDStart[aggIter] + (ADIO_Offset)((ADIO_Offset)(roundIter+1)*coll_bufsize) - (ADIO_Offset)1); roundIter 874 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("roundIter %d processing targetAggsForMyData %d \n",roundIter,targetAggsForMyData[aggIter]); roundIter 880 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int startingOffLenIndex = targetAggsForMyDataFirstOffLenIndex[roundIter][aggIter], endingOffLenIndex = targetAggsForMyDataLastOffLenIndex[roundIter][aggIter]; roundIter 889 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c roundIter,aggIter,targetAggsForMyData[aggIter],offsetIter,offset_list[offsetIter],offsetIter,len_list[offsetIter], roundIter 891 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDStartForMyTargetAgg,currentRoundFDEndForMyTargetAgg, targetAggsForMyDataFirstOffLenIndex[roundIter][aggIter]); roundIter 933 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (k=targetAggsForMyDataFirstOffLenIndex[roundIter][aggIter];k<=targetAggsForMyDataLastOffLenIndex[roundIter][aggIter];k++) roundIter 1002 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("roundIter %d bufferAmountToSend is %d offsetStart is %ld currentRoundFDStartForMyTargetAgg is %ld targetDisplacementToUseThisRound is %ld targetAggsForMyDataFDStart[aggIter] is %ld\n",roundIter, bufferAmountToSend, offsetStart,currentRoundFDStartForMyTargetAgg,targetDisplacementToUseThisRound,targetAggsForMyDataFDStart[aggIter]); roundIter 1058 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("first barrier roundIter %d\n",roundIter); roundIter 1152 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (gpfsmpio_onesided_always_rmw && (roundIter<(numberOfRounds-1))) { // read in the buffer for the next round unless this is the last round roundIter 1167 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("gpfsmpio_onesided_always_rmw - round %d buffer pre-read for file offsets %ld to %ld total is %d\n",roundIter, currentRoundFDStart,tmpCurrentRoundFDEnd,(int)(tmpCurrentRoundFDEnd - currentRoundFDStart)+1); roundIter 1175 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (roundIter<(numberOfRounds-1)) { roundIter 1177 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("second barrier roundIter %d\n",roundIter); roundIter 1831 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int roundIter; roundIter 1832 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (roundIter=0;roundIter<numberOfRounds;roundIter++) { roundIter 1841 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (!useIOBuffer || (roundIter == 0)) { roundIter 1862 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (roundIter > 0) roundIter 1865 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (roundIter < (numberOfRounds-1)) { roundIter 1928 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (roundIter < (numberOfRounds-1)) { roundIter 1956 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (sourceAggsForMyDataFirstOffLenIndex[roundIter][aggIter] != -1) { roundIter 1958 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset currentRoundFDStartForMySourceAgg = (ADIO_Offset)((ADIO_Offset)sourceAggsForMyDataFDStart[aggIter] + (ADIO_Offset)((ADIO_Offset)roundIter*coll_bufsize)); roundIter 1959 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset currentRoundFDEndForMySourceAgg = (ADIO_Offset)((ADIO_Offset)sourceAggsForMyDataFDStart[aggIter] + (ADIO_Offset)((ADIO_Offset)(roundIter+1)*coll_bufsize) - (ADIO_Offset)1); roundIter 1977 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int startingOffLenIndex = sourceAggsForMyDataFirstOffLenIndex[roundIter][aggIter], endingOffLenIndex = sourceAggsForMyDataLastOffLenIndex[roundIter][aggIter]; roundIter 2019 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (k=sourceAggsForMyDataFirstOffLenIndex[roundIter][aggIter];k<=sourceAggsForMyDataLastOffLenIndex[roundIter][aggIter];k++) roundIter 185 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int roundIter; roundIter 186 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c for (roundIter=0;roundIter<numberOfRounds;roundIter++) { roundIter 196 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset currentRoundFDStartForMyTargetAgg = (ADIO_Offset)((ADIO_Offset)targetAggsForMyDataFDStart[i] + (ADIO_Offset)((ADIO_Offset)roundIter*(ADIO_Offset)coll_bufsize)); roundIter 197 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset currentRoundFDEndForMyTargetAgg = (ADIO_Offset)((ADIO_Offset)targetAggsForMyDataFDStart[i] + (ADIO_Offset)((ADIO_Offset)(roundIter+1)*(ADIO_Offset)coll_bufsize) - (ADIO_Offset)1); roundIter 203 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c roundIter,i,targetAggsForMyData[i],myOffsetStart,myOffsetEnd, roundIter 243 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (roundIter > 0) roundIter 289 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (roundIter > 0) { roundIter 303 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (roundIter > 0) { roundIter 652 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int roundIter; roundIter 653 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c for (roundIter=0;roundIter<numberOfRounds;roundIter++) { roundIter 661 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (!useIOBuffer || (roundIter == 0)) { roundIter 686 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (roundIter > 0) roundIter 689 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (roundIter < (numberOfRounds-1)) { roundIter 765 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c (ADIO_Offset)((ADIO_Offset)roundIter*(ADIO_Offset)coll_bufsize)); roundIter 768 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c (ADIO_Offset)((ADIO_Offset)(roundIter+1)*(ADIO_Offset)coll_bufsize) - (ADIO_Offset)1); roundIter 773 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c printf("roundIter %d source iter %d sourceAggsForMyData is %d myOffsetStart is %ld myOffsetEnd is %ld sourceAggsForMyDataFDStart is %ld sourceAggsForMyDataFDEnd is %ld currentRoundFDStartForMySourceAgg is %ld currentRoundFDEndForMySourceAgg is %ld\n",roundIter,i,sourceAggsForMyData[i],myOffsetStart,myOffsetEnd,sourceAggsForMyDataFDStart[i],sourceAggsForMyDataFDEnd[i],currentRoundFDStartForMySourceAgg,currentRoundFDEndForMySourceAgg);