currentRoundFDEndForMyTargetAgg 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); currentRoundFDEndForMyTargetAgg 882 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentRoundFDEndForMyTargetAgg > targetAggsForMyDataFDEnd[aggIter]) currentRoundFDEndForMyTargetAgg 883 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEndForMyTargetAgg = targetAggsForMyDataFDEnd[aggIter]; currentRoundFDEndForMyTargetAgg 891 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDStartForMyTargetAgg,currentRoundFDEndForMyTargetAgg, targetAggsForMyDataFirstOffLenIndex[roundIter][aggIter]); currentRoundFDEndForMyTargetAgg 898 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((offsetStart >= currentRoundFDStartForMyTargetAgg) && (offsetStart <= currentRoundFDEndForMyTargetAgg)) { currentRoundFDEndForMyTargetAgg 899 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (offsetEnd > currentRoundFDEndForMyTargetAgg) currentRoundFDEndForMyTargetAgg 900 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - offsetStart) +1; currentRoundFDEndForMyTargetAgg 904 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c else if ((offsetEnd >= currentRoundFDStartForMyTargetAgg) && (offsetEnd <= currentRoundFDEndForMyTargetAgg)) { currentRoundFDEndForMyTargetAgg 905 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (offsetEnd > currentRoundFDEndForMyTargetAgg) currentRoundFDEndForMyTargetAgg 906 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - currentRoundFDStartForMyTargetAgg) +1; currentRoundFDEndForMyTargetAgg 913 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c else if ((offsetStart <= currentRoundFDStartForMyTargetAgg) && (offsetEnd >= currentRoundFDEndForMyTargetAgg)) { currentRoundFDEndForMyTargetAgg 914 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - currentRoundFDStartForMyTargetAgg) +1; currentRoundFDEndForMyTargetAgg 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); currentRoundFDEndForMyTargetAgg 198 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (currentRoundFDEndForMyTargetAgg > targetAggsForMyDataFDEnd[i]) currentRoundFDEndForMyTargetAgg 199 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDEndForMyTargetAgg = targetAggsForMyDataFDEnd[i]; currentRoundFDEndForMyTargetAgg 205 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDStartForMyTargetAgg,currentRoundFDEndForMyTargetAgg); currentRoundFDEndForMyTargetAgg 216 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((myOffsetStart >= currentRoundFDStartForMyTargetAgg) && (myOffsetStart <= currentRoundFDEndForMyTargetAgg)) { currentRoundFDEndForMyTargetAgg 217 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (myOffsetEnd > currentRoundFDEndForMyTargetAgg) currentRoundFDEndForMyTargetAgg 218 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - myOffsetStart) +1; currentRoundFDEndForMyTargetAgg 222 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((myOffsetEnd >= currentRoundFDStartForMyTargetAgg) && (myOffsetEnd <= currentRoundFDEndForMyTargetAgg)) { currentRoundFDEndForMyTargetAgg 224 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (myOffsetEnd > currentRoundFDEndForMyTargetAgg) currentRoundFDEndForMyTargetAgg 225 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - currentRoundFDStartForMyTargetAgg) +1; currentRoundFDEndForMyTargetAgg 229 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((myOffsetStart <= currentRoundFDStartForMyTargetAgg) && (myOffsetEnd >= currentRoundFDEndForMyTargetAgg)) { currentRoundFDEndForMyTargetAgg 231 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - currentRoundFDStartForMyTargetAgg) +1;