currentRoundFDStartForMyTargetAgg 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)); currentRoundFDStartForMyTargetAgg 891 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDStartForMyTargetAgg,currentRoundFDEndForMyTargetAgg, targetAggsForMyDataFirstOffLenIndex[roundIter][aggIter]); currentRoundFDStartForMyTargetAgg 898 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((offsetStart >= currentRoundFDStartForMyTargetAgg) && (offsetStart <= currentRoundFDEndForMyTargetAgg)) { currentRoundFDStartForMyTargetAgg 904 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c else if ((offsetEnd >= currentRoundFDStartForMyTargetAgg) && (offsetEnd <= currentRoundFDEndForMyTargetAgg)) { currentRoundFDStartForMyTargetAgg 906 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - currentRoundFDStartForMyTargetAgg) +1; currentRoundFDStartForMyTargetAgg 908 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToSend = (offsetEnd - currentRoundFDStartForMyTargetAgg) +1; currentRoundFDStartForMyTargetAgg 909 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (offsetStart < currentRoundFDStartForMyTargetAgg) { currentRoundFDStartForMyTargetAgg 910 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c offsetStart = currentRoundFDStartForMyTargetAgg; currentRoundFDStartForMyTargetAgg 913 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c else if ((offsetStart <= currentRoundFDStartForMyTargetAgg) && (offsetEnd >= currentRoundFDEndForMyTargetAgg)) { currentRoundFDStartForMyTargetAgg 914 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - currentRoundFDStartForMyTargetAgg) +1; currentRoundFDStartForMyTargetAgg 915 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c offsetStart = currentRoundFDStartForMyTargetAgg; currentRoundFDStartForMyTargetAgg 950 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Aint targetDisplacementToUseThisRound = (MPI_Aint) (offsetStart - currentRoundFDStartForMyTargetAgg); currentRoundFDStartForMyTargetAgg 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]); currentRoundFDStartForMyTargetAgg 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)); currentRoundFDStartForMyTargetAgg 205 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDStartForMyTargetAgg,currentRoundFDEndForMyTargetAgg); currentRoundFDStartForMyTargetAgg 216 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((myOffsetStart >= currentRoundFDStartForMyTargetAgg) && (myOffsetStart <= currentRoundFDEndForMyTargetAgg)) { currentRoundFDStartForMyTargetAgg 222 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((myOffsetEnd >= currentRoundFDStartForMyTargetAgg) && (myOffsetEnd <= currentRoundFDEndForMyTargetAgg)) { currentRoundFDStartForMyTargetAgg 223 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c sendBufferOffset = (int) (currentRoundFDStartForMyTargetAgg - myOffsetStart); currentRoundFDStartForMyTargetAgg 225 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - currentRoundFDStartForMyTargetAgg) +1; currentRoundFDStartForMyTargetAgg 227 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToSend = (myOffsetEnd - currentRoundFDStartForMyTargetAgg) +1; currentRoundFDStartForMyTargetAgg 229 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((myOffsetStart <= currentRoundFDStartForMyTargetAgg) && (myOffsetEnd >= currentRoundFDEndForMyTargetAgg)) { currentRoundFDStartForMyTargetAgg 230 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c sendBufferOffset = (int) (currentRoundFDStartForMyTargetAgg - myOffsetStart); currentRoundFDStartForMyTargetAgg 231 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - currentRoundFDStartForMyTargetAgg) +1;