currentRoundFDStart 787 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset currentRoundFDStart = 0; currentRoundFDStart 791 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDStart = fd_start[myAggRank]; currentRoundFDStart 793 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentRoundFDStart < firstFileOffset) currentRoundFDStart 794 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDStart = firstFileOffset; currentRoundFDStart 801 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("iAmUsedAgg - currentRoundFDStart initialized to %ld currentRoundFDEnd to %ld\n",currentRoundFDStart,currentRoundFDEnd); currentRoundFDStart 805 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { currentRoundFDStart 816 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c tmpCurrentRoundFDEnd = currentRoundFDStart + coll_bufsize - (ADIO_Offset)1; currentRoundFDStart 818 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("gpfsmpio_onesided_always_rmw - first buffer pre-read for file offsets %ld to %ld total is %d\n",currentRoundFDStart,tmpCurrentRoundFDEnd,(int)(tmpCurrentRoundFDEnd - currentRoundFDStart)+1); currentRoundFDStart 820 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_ReadContig(fd, write_buf, (int)(tmpCurrentRoundFDEnd - currentRoundFDStart)+1, currentRoundFDStart 821 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_BYTE, ADIO_EXPLICIT_OFFSET,currentRoundFDStart, &status, error_code); currentRoundFDStart 1065 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { currentRoundFDStart 1076 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = currentRoundFDStart + coll_bufsize - (ADIO_Offset)1; currentRoundFDStart 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]); currentRoundFDStart 1089 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (numBytesPutIntoBuf != ((int)(currentRoundFDEnd - currentRoundFDStart)+1)) { currentRoundFDStart 1097 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_WriteContig(fd, write_buf, (int)(currentRoundFDEnd - currentRoundFDStart)+1, currentRoundFDStart 1098 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_BYTE, ADIO_EXPLICIT_OFFSET,currentRoundFDStart, &status, error_code); currentRoundFDStart 1125 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c io_thread_args.size = (currentRoundFDEnd-currentRoundFDStart) + 1; currentRoundFDStart 1126 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c io_thread_args.offset = currentRoundFDStart; currentRoundFDStart 1150 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDStart += coll_bufsize; currentRoundFDStart 1154 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { currentRoundFDStart 1165 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c tmpCurrentRoundFDEnd = currentRoundFDStart + coll_bufsize - (ADIO_Offset)1; currentRoundFDStart 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); currentRoundFDStart 1169 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_ReadContig(fd, write_buf, (int)(tmpCurrentRoundFDEnd - currentRoundFDStart)+1, currentRoundFDStart 1170 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_BYTE, ADIO_EXPLICIT_OFFSET,currentRoundFDStart, &status, error_code); currentRoundFDStart 1790 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset currentRoundFDStart = 0, nextRoundFDStart = 0; currentRoundFDStart 1794 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDStart = fd_start[myAggRank]; currentRoundFDStart 1797 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentRoundFDStart < firstFileOffset) currentRoundFDStart 1798 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDStart = firstFileOffset; currentRoundFDStart 1811 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDStart,currentRoundFDEnd); currentRoundFDStart 1839 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDStart = nextRoundFDStart; currentRoundFDStart 1843 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { currentRoundFDStart 1845 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c amountDataToReadThisRound = ((currentRoundFDEnd-currentRoundFDStart)+1); currentRoundFDStart 1848 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = currentRoundFDStart + coll_bufsize - (ADIO_Offset)1; currentRoundFDStart 1854 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_BYTE, ADIO_EXPLICIT_OFFSET, currentRoundFDStart, currentRoundFDStart 2140 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nextRoundFDStart = currentRoundFDStart + coll_bufsize; currentRoundFDStart 164 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset currentRoundFDStart = 0; currentRoundFDStart 168 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDStart = fd_start[myAggRank]; currentRoundFDStart 255 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { currentRoundFDStart 259 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDEnd = currentRoundFDStart + coll_bufsize - 1; currentRoundFDStart 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]); currentRoundFDStart 270 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((remainingDataOffsetToGetPerProc[i] >= currentRoundFDStart) && (remainingDataOffsetToGetPerProc[i] <= currentRoundFDEnd)) { currentRoundFDStart 276 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if (((remainingDataOffsetToGetPerProc[i]+remainingDataAmountToGetPerProc[i]) >= currentRoundFDStart) && ((remainingDataOffsetToGetPerProc[i]+remainingDataAmountToGetPerProc[i]) <= currentRoundFDEnd)) { currentRoundFDStart 277 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((remainingDataOffsetToGetPerProc[i]) >= currentRoundFDStart) currentRoundFDStart 280 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c dataSizeGottenThisRoundPerProc[i] = (remainingDataOffsetToGetPerProc[i]-currentRoundFDStart) +1; currentRoundFDStart 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); currentRoundFDStart 399 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDStart, &status, error_code); currentRoundFDStart 425 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c io_thread_args.offset = currentRoundFDStart; currentRoundFDStart 437 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDStart += coll_bufsize; currentRoundFDStart 622 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset currentRoundFDStart = 0, nextRoundFDStart = 0; currentRoundFDStart 626 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDStart = fd_start[myAggRank]; currentRoundFDStart 659 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDStart = nextRoundFDStart; currentRoundFDStart 663 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { currentRoundFDStart 665 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c amountDataToReadThisRound = ((currentRoundFDEnd-currentRoundFDStart)+1); currentRoundFDStart 668 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDEnd = currentRoundFDStart + coll_bufsize - 1; currentRoundFDStart 674 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c MPI_BYTE, ADIO_EXPLICIT_OFFSET, currentRoundFDStart, currentRoundFDStart 815 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((remainingDataOffsetToSendPerProc[i] >= currentRoundFDStart) && currentRoundFDStart 826 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDStart) && currentRoundFDStart 829 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((remainingDataOffsetToSendPerProc[i]) >= currentRoundFDStart) currentRoundFDStart 833 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c (remainingDataOffsetToSendPerProc[i]-currentRoundFDStart) +1; currentRoundFDStart 874 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c nextRoundFDStart = currentRoundFDStart + coll_bufsize;