myOffsetEnd 39 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset myOffsetStart = st_offsets[myrank], myOffsetEnd = end_offsets[myrank]; myOffsetEnd 76 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ( ((myOffsetStart >= fd_start[i]) && (myOffsetStart <= fd_end[i])) || ((myOffsetEnd >= fd_start[i]) && (myOffsetEnd <= fd_end[i]))) { myOffsetEnd 192 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ((myOffsetEnd >= targetAggsForMyDataFDStart[i]) && (myOffsetEnd <= targetAggsForMyDataFDEnd[i]))) { myOffsetEnd 203 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c roundIter,i,targetAggsForMyData[i],myOffsetStart,myOffsetEnd, myOffsetEnd 217 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (myOffsetEnd > currentRoundFDEndForMyTargetAgg) myOffsetEnd 220 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToSend = (myOffsetEnd - myOffsetStart) +1; myOffsetEnd 222 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((myOffsetEnd >= currentRoundFDStartForMyTargetAgg) && (myOffsetEnd <= currentRoundFDEndForMyTargetAgg)) { myOffsetEnd 224 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (myOffsetEnd > currentRoundFDEndForMyTargetAgg) myOffsetEnd 227 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToSend = (myOffsetEnd - currentRoundFDStartForMyTargetAgg) +1; myOffsetEnd 229 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((myOffsetStart <= currentRoundFDStartForMyTargetAgg) && (myOffsetEnd >= currentRoundFDEndForMyTargetAgg)) { myOffsetEnd 514 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset myOffsetStart = st_offsets[myrank], myOffsetEnd = end_offsets[myrank]; myOffsetEnd 547 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ((myOffsetEnd >= fd_start[i]) && (myOffsetEnd <= fd_end[i]))) { myOffsetEnd 757 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c || ((myOffsetEnd >= sourceAggsForMyDataFDStart[i]) && (myOffsetEnd <= sourceAggsForMyDataFDEnd[i])) ) { myOffsetEnd 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); myOffsetEnd 782 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (myOffsetEnd > currentRoundFDEndForMySourceAgg) myOffsetEnd 785 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToGet = (myOffsetEnd - myOffsetStart) +1; myOffsetEnd 787 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((myOffsetEnd >= currentRoundFDStartForMySourceAgg) && (myOffsetEnd <= currentRoundFDEndForMySourceAgg)) { myOffsetEnd 789 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (myOffsetEnd > currentRoundFDEndForMySourceAgg) myOffsetEnd 792 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToGet = (myOffsetEnd - currentRoundFDStartForMySourceAgg) +1; myOffsetEnd 794 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((myOffsetStart <= currentRoundFDStartForMySourceAgg) && (myOffsetEnd >= currentRoundFDEndForMySourceAgg)) {