currentRoundFDEnd 788 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset currentRoundFDEnd = 0; currentRoundFDEnd 797 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentRoundFDEnd > lastFileOffset) currentRoundFDEnd 798 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = lastFileOffset; currentRoundFDEnd 801 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("iAmUsedAgg - currentRoundFDStart initialized to %ld currentRoundFDEnd to %ld\n",currentRoundFDStart,currentRoundFDEnd); currentRoundFDEnd 1068 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = lastFileOffset; currentRoundFDEnd 1070 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = fd_end[myAggRank]; currentRoundFDEnd 1073 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = fd_end[myAggRank]; currentRoundFDEnd 1076 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = currentRoundFDStart + coll_bufsize - (ADIO_Offset)1; currentRoundFDEnd 1079 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("used agg about to writecontig - currentRoundFDStart is %ld currentRoundFDEnd is %ld within file domeain %ld to %ld\n",currentRoundFDStart,currentRoundFDEnd,fd_start[myAggRank],fd_end[myAggRank]); currentRoundFDEnd 1089 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (numBytesPutIntoBuf != ((int)(currentRoundFDEnd - currentRoundFDStart)+1)) { currentRoundFDEnd 1097 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_WriteContig(fd, write_buf, (int)(currentRoundFDEnd - currentRoundFDStart)+1, currentRoundFDEnd 1125 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c io_thread_args.size = (currentRoundFDEnd-currentRoundFDStart) + 1; currentRoundFDEnd 1791 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset currentRoundFDEnd = 0, nextRoundFDEnd = 0; currentRoundFDEnd 1803 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentRoundFDEnd > lastFileOffset) currentRoundFDEnd 1804 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = lastFileOffset; currentRoundFDEnd 1811 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDStart,currentRoundFDEnd); currentRoundFDEnd 1844 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = fd_end[myAggRank]; currentRoundFDEnd 1845 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c amountDataToReadThisRound = ((currentRoundFDEnd-currentRoundFDStart)+1); currentRoundFDEnd 1848 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = currentRoundFDStart + coll_bufsize - (ADIO_Offset)1; currentRoundFDEnd 1863 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = nextRoundFDEnd; currentRoundFDEnd 165 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset currentRoundFDEnd = 0; currentRoundFDEnd 256 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDEnd = fd_end[myAggRank]; currentRoundFDEnd 259 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDEnd = currentRoundFDStart + coll_bufsize - 1; currentRoundFDEnd 261 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c printf("currentRoundFDStart is %ld currentRoundFDEnd is %ld within file domeain %ld to %ld\n",currentRoundFDStart,currentRoundFDEnd,fd_start[myAggRank],fd_end[myAggRank]); currentRoundFDEnd 270 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((remainingDataOffsetToGetPerProc[i] >= currentRoundFDStart) && (remainingDataOffsetToGetPerProc[i] <= currentRoundFDEnd)) { currentRoundFDEnd 271 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((remainingDataOffsetToGetPerProc[i] + remainingDataAmountToGetPerProc[i]) <= currentRoundFDEnd) currentRoundFDEnd 274 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c dataSizeGottenThisRoundPerProc[i] = (currentRoundFDEnd - remainingDataOffsetToGetPerProc[i]) +1; currentRoundFDEnd 276 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if (((remainingDataOffsetToGetPerProc[i]+remainingDataAmountToGetPerProc[i]) >= currentRoundFDStart) && ((remainingDataOffsetToGetPerProc[i]+remainingDataAmountToGetPerProc[i]) <= currentRoundFDEnd)) { currentRoundFDEnd 286 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c printf("dataSizeGottenThisRoundPerProc[%d] set to %d - remainingDataOffsetToGetPerProc is %d remainingDataAmountToGetPerProc is %d currentRoundFDStart is %d currentRoundFDEnd is %d\n",i,dataSizeGottenThisRoundPerProc[i],remainingDataOffsetToGetPerProc[i],remainingDataAmountToGetPerProc[i],currentRoundFDStart,currentRoundFDEnd); currentRoundFDEnd 623 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset currentRoundFDEnd = 0, nextRoundFDEnd = 0; currentRoundFDEnd 664 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDEnd = fd_end[myAggRank]; currentRoundFDEnd 665 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c amountDataToReadThisRound = ((currentRoundFDEnd-currentRoundFDStart)+1); currentRoundFDEnd 668 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDEnd = currentRoundFDStart + coll_bufsize - 1; currentRoundFDEnd 687 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDEnd = nextRoundFDEnd; currentRoundFDEnd 816 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c (remainingDataOffsetToSendPerProc[i] <= currentRoundFDEnd)) { currentRoundFDEnd 818 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataAmountToSendPerProc[i]) <= currentRoundFDEnd) currentRoundFDEnd 822 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c (currentRoundFDEnd - remainingDataOffsetToSendPerProc[i]) +1; currentRoundFDEnd 828 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataAmountToSendPerProc[i]) <= currentRoundFDEnd)) {