currentRoundFDEndForMySourceAgg 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); currentRoundFDEndForMySourceAgg 1979 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentRoundFDEndForMySourceAgg > sourceAggsForMyDataFDEnd[aggIter]) currentRoundFDEndForMySourceAgg 1980 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEndForMySourceAgg = sourceAggsForMyDataFDEnd[aggIter]; currentRoundFDEndForMySourceAgg 1988 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((offsetStart >= currentRoundFDStartForMySourceAgg) && (offsetStart <= currentRoundFDEndForMySourceAgg)) { currentRoundFDEndForMySourceAgg 1989 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (offsetEnd > currentRoundFDEndForMySourceAgg) currentRoundFDEndForMySourceAgg 1990 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToRecv = (currentRoundFDEndForMySourceAgg - offsetStart) +1; currentRoundFDEndForMySourceAgg 1994 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c else if ((offsetEnd >= currentRoundFDStartForMySourceAgg) && (offsetEnd <= currentRoundFDEndForMySourceAgg)) { currentRoundFDEndForMySourceAgg 1995 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (offsetEnd > currentRoundFDEndForMySourceAgg) currentRoundFDEndForMySourceAgg 1996 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToRecv = (currentRoundFDEndForMySourceAgg - currentRoundFDStartForMySourceAgg) +1; currentRoundFDEndForMySourceAgg 2003 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c else if ((offsetStart <= currentRoundFDStartForMySourceAgg) && (offsetEnd >= currentRoundFDEndForMySourceAgg)) { currentRoundFDEndForMySourceAgg 2004 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToRecv = (currentRoundFDEndForMySourceAgg - currentRoundFDStartForMySourceAgg) +1; currentRoundFDEndForMySourceAgg 766 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset currentRoundFDEndForMySourceAgg = currentRoundFDEndForMySourceAgg 769 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (currentRoundFDEndForMySourceAgg > sourceAggsForMyDataFDEnd[i]) currentRoundFDEndForMySourceAgg 770 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDEndForMySourceAgg = sourceAggsForMyDataFDEnd[i]; currentRoundFDEndForMySourceAgg 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); currentRoundFDEndForMySourceAgg 781 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((myOffsetStart >= currentRoundFDStartForMySourceAgg) && (myOffsetStart <= currentRoundFDEndForMySourceAgg)) { currentRoundFDEndForMySourceAgg 782 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (myOffsetEnd > currentRoundFDEndForMySourceAgg) currentRoundFDEndForMySourceAgg 783 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToGet = (currentRoundFDEndForMySourceAgg - myOffsetStart) +1; currentRoundFDEndForMySourceAgg 787 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((myOffsetEnd >= currentRoundFDStartForMySourceAgg) && (myOffsetEnd <= currentRoundFDEndForMySourceAgg)) { currentRoundFDEndForMySourceAgg 789 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (myOffsetEnd > currentRoundFDEndForMySourceAgg) currentRoundFDEndForMySourceAgg 790 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToGet = (currentRoundFDEndForMySourceAgg - currentRoundFDStartForMySourceAgg) +1; currentRoundFDEndForMySourceAgg 794 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((myOffsetStart <= currentRoundFDStartForMySourceAgg) && (myOffsetEnd >= currentRoundFDEndForMySourceAgg)) { currentRoundFDEndForMySourceAgg 796 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToGet = (currentRoundFDEndForMySourceAgg - currentRoundFDStartForMySourceAgg) +1;