currentRoundFDStartForMySourceAgg 1958 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset currentRoundFDStartForMySourceAgg = (ADIO_Offset)((ADIO_Offset)sourceAggsForMyDataFDStart[aggIter] + (ADIO_Offset)((ADIO_Offset)roundIter*coll_bufsize)); currentRoundFDStartForMySourceAgg 1988 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((offsetStart >= currentRoundFDStartForMySourceAgg) && (offsetStart <= currentRoundFDEndForMySourceAgg)) { currentRoundFDStartForMySourceAgg 1994 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c else if ((offsetEnd >= currentRoundFDStartForMySourceAgg) && (offsetEnd <= currentRoundFDEndForMySourceAgg)) { currentRoundFDStartForMySourceAgg 1996 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToRecv = (currentRoundFDEndForMySourceAgg - currentRoundFDStartForMySourceAgg) +1; currentRoundFDStartForMySourceAgg 1998 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToRecv = (offsetEnd - currentRoundFDStartForMySourceAgg) +1; currentRoundFDStartForMySourceAgg 1999 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (offsetStart < currentRoundFDStartForMySourceAgg) { currentRoundFDStartForMySourceAgg 2000 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c offsetStart = currentRoundFDStartForMySourceAgg; currentRoundFDStartForMySourceAgg 2003 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c else if ((offsetStart <= currentRoundFDStartForMySourceAgg) && (offsetEnd >= currentRoundFDEndForMySourceAgg)) { currentRoundFDStartForMySourceAgg 2004 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToRecv = (currentRoundFDEndForMySourceAgg - currentRoundFDStartForMySourceAgg) +1; currentRoundFDStartForMySourceAgg 2005 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c offsetStart = currentRoundFDStartForMySourceAgg; currentRoundFDStartForMySourceAgg 2036 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Aint sourceDisplacementToUseThisRound = (MPI_Aint) (offsetStart - currentRoundFDStartForMySourceAgg); currentRoundFDStartForMySourceAgg 763 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset currentRoundFDStartForMySourceAgg = currentRoundFDStartForMySourceAgg 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); currentRoundFDStartForMySourceAgg 781 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((myOffsetStart >= currentRoundFDStartForMySourceAgg) && (myOffsetStart <= currentRoundFDEndForMySourceAgg)) { currentRoundFDStartForMySourceAgg 787 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((myOffsetEnd >= currentRoundFDStartForMySourceAgg) && (myOffsetEnd <= currentRoundFDEndForMySourceAgg)) { currentRoundFDStartForMySourceAgg 788 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c recvBufferOffset = (int) (currentRoundFDStartForMySourceAgg - myOffsetStart); currentRoundFDStartForMySourceAgg 790 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToGet = (currentRoundFDEndForMySourceAgg - currentRoundFDStartForMySourceAgg) +1; currentRoundFDStartForMySourceAgg 792 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToGet = (myOffsetEnd - currentRoundFDStartForMySourceAgg) +1; currentRoundFDStartForMySourceAgg 794 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((myOffsetStart <= currentRoundFDStartForMySourceAgg) && (myOffsetEnd >= currentRoundFDEndForMySourceAgg)) { currentRoundFDStartForMySourceAgg 795 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c recvBufferOffset = (int) (currentRoundFDStartForMySourceAgg - myOffsetStart); currentRoundFDStartForMySourceAgg 796 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToGet = (currentRoundFDEndForMySourceAgg - currentRoundFDStartForMySourceAgg) +1;