remainingDataOffsetToGetPerProc 87 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset *remainingDataOffsetToGetPerProc=NULL; remainingDataOffsetToGetPerProc 101 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataOffsetToGetPerProc = (ADIO_Offset *)ADIOI_Malloc(numSourceProcs * sizeof(ADIO_Offset)); remainingDataOffsetToGetPerProc 112 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataOffsetToGetPerProc[numSourceProcs] = st_offsets[i]; remainingDataOffsetToGetPerProc 116 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataOffsetToGetPerProc[numSourceProcs] = st_offsets[i]; remainingDataOffsetToGetPerProc 120 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataOffsetToGetPerProc[numSourceProcs] = fd_start[myAggRank]; remainingDataOffsetToGetPerProc 270 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((remainingDataOffsetToGetPerProc[i] >= currentRoundFDStart) && (remainingDataOffsetToGetPerProc[i] <= currentRoundFDEnd)) { remainingDataOffsetToGetPerProc 271 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((remainingDataOffsetToGetPerProc[i] + remainingDataAmountToGetPerProc[i]) <= currentRoundFDEnd) remainingDataOffsetToGetPerProc 274 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c dataSizeGottenThisRoundPerProc[i] = (currentRoundFDEnd - remainingDataOffsetToGetPerProc[i]) +1; remainingDataOffsetToGetPerProc 276 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c else if (((remainingDataOffsetToGetPerProc[i]+remainingDataAmountToGetPerProc[i]) >= currentRoundFDStart) && ((remainingDataOffsetToGetPerProc[i]+remainingDataAmountToGetPerProc[i]) <= currentRoundFDEnd)) { remainingDataOffsetToGetPerProc 277 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((remainingDataOffsetToGetPerProc[i]) >= currentRoundFDStart) remainingDataOffsetToGetPerProc 280 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c dataSizeGottenThisRoundPerProc[i] = (remainingDataOffsetToGetPerProc[i]-currentRoundFDStart) +1; remainingDataOffsetToGetPerProc 286 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c printf("dataSizeGottenThisRoundPerProc[%d] set to %d - remainingDataOffsetToGetPerProc is %d remainingDataAmountToGetPerProc is %d currentRoundFDStart is %d currentRoundFDEnd is %d\n",i,dataSizeGottenThisRoundPerProc[i],remainingDataOffsetToGetPerProc[i],remainingDataAmountToGetPerProc[i],currentRoundFDStart,currentRoundFDEnd); remainingDataOffsetToGetPerProc 372 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataOffsetToGetPerProc[mpiRequestMapPerProc[irecv]] += remainingDataOffsetToGetPerProc 464 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIOI_Free(remainingDataOffsetToGetPerProc);