myOffsetStart 39 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset myOffsetStart = st_offsets[myrank], myOffsetEnd = end_offsets[myrank]; myOffsetStart 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]))) { myOffsetStart 191 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ( ((myOffsetStart >= targetAggsForMyDataFDStart[i]) && (myOffsetStart <= targetAggsForMyDataFDEnd[i])) || myOffsetStart 203 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c roundIter,i,targetAggsForMyData[i],myOffsetStart,myOffsetEnd, myOffsetStart 216 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((myOffsetStart >= currentRoundFDStartForMyTargetAgg) && (myOffsetStart <= currentRoundFDEndForMyTargetAgg)) { myOffsetStart 218 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - myOffsetStart) +1; myOffsetStart 220 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToSend = (myOffsetEnd - myOffsetStart) +1; myOffsetStart 223 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c sendBufferOffset = (int) (currentRoundFDStartForMyTargetAgg - myOffsetStart); myOffsetStart 229 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((myOffsetStart <= currentRoundFDStartForMyTargetAgg) && (myOffsetEnd >= currentRoundFDEndForMyTargetAgg)) { myOffsetStart 230 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c sendBufferOffset = (int) (currentRoundFDStartForMyTargetAgg - myOffsetStart); myOffsetStart 514 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset myOffsetStart = st_offsets[myrank], myOffsetEnd = end_offsets[myrank]; myOffsetStart 546 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ( ((myOffsetStart >= fd_start[i]) && (myOffsetStart <= fd_end[i])) || myOffsetStart 756 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ( ((myOffsetStart >= sourceAggsForMyDataFDStart[i]) && (myOffsetStart <= sourceAggsForMyDataFDEnd[i])) myOffsetStart 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); myOffsetStart 781 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((myOffsetStart >= currentRoundFDStartForMySourceAgg) && (myOffsetStart <= currentRoundFDEndForMySourceAgg)) { myOffsetStart 783 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToGet = (currentRoundFDEndForMySourceAgg - myOffsetStart) +1; myOffsetStart 785 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToGet = (myOffsetEnd - myOffsetStart) +1; myOffsetStart 788 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c recvBufferOffset = (int) (currentRoundFDStartForMySourceAgg - myOffsetStart); myOffsetStart 794 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if ((myOffsetStart <= currentRoundFDStartForMySourceAgg) && (myOffsetEnd >= currentRoundFDEndForMySourceAgg)) { myOffsetStart 795 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c recvBufferOffset = (int) (currentRoundFDStartForMySourceAgg - myOffsetStart);