sourceAggsForMyData 1411 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c */ int *sourceAggsForMyData = (int *)ADIOI_Malloc(naggs * sizeof(int)); sourceAggsForMyData 1566 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyData[numSourceAggs] = fd->hints->ranklist[currentAggRankListIndex]; sourceAggsForMyData 1653 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyData[numSourceAggs] = fd->hints->ranklist[currentAggRankListIndex]; sourceAggsForMyData 1763 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("sourceAggsForMyData[%d] is %d sourceAggsForMyDataFDStart[%d] is %ld sourceAggsForMyDataFDEnd is %ld sourceAggsForMyDataFirstOffLenIndex is %d with value %ld sourceAggsForMyDataLastOffLenIndex is %d with value %ld\n",i,sourceAggsForMyData[i],i,sourceAggsForMyDataFDStart[i],sourceAggsForMyDataFDEnd[i],sourceAggsForMyDataFirstOffLenIndex[j][i],offset_list[sourceAggsForMyDataFirstOffLenIndex[j][i]],sourceAggsForMyDataLastOffLenIndex[j][i],offset_list[sourceAggsForMyDataLastOffLenIndex[j][i]]); sourceAggsForMyData 2049 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Win_lock(MPI_LOCK_SHARED, sourceAggsForMyData[aggIter], 0, read_buf_window); sourceAggsForMyData 2052 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Get(((char*)buf) + currentFDSourceBufferState[aggIter].sourceBufferOffset,bufferAmountToRecv, MPI_BYTE,sourceAggsForMyData[aggIter],sourceDisplacementToUseThisRound, bufferAmountToRecv,MPI_BYTE,read_buf_window); sourceAggsForMyData 2058 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Get(getSourceData,bufferAmountToRecv, MPI_BYTE,sourceAggsForMyData[aggIter],sourceDisplacementToUseThisRound, bufferAmountToRecv,MPI_BYTE,read_buf_window); sourceAggsForMyData 2061 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Win_unlock(sourceAggsForMyData[aggIter], read_buf_window); sourceAggsForMyData 2105 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Win_lock(MPI_LOCK_SHARED, sourceAggsForMyData[aggIter], 0, read_buf_window); sourceAggsForMyData 2107 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Get(((char*)buf),1, recvBufferDerivedDataType,sourceAggsForMyData[aggIter],0, 1,sourceBufferDerivedDataType,read_buf_window); sourceAggsForMyData 2110 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Get(derivedTypePackedSourceBuffer,1, recvBufferDerivedDataType,sourceAggsForMyData[aggIter],0, 1,sourceBufferDerivedDataType,read_buf_window); sourceAggsForMyData 2113 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Win_unlock(sourceAggsForMyData[aggIter], read_buf_window); sourceAggsForMyData 2158 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIOI_Free(sourceAggsForMyData); sourceAggsForMyData 540 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int *sourceAggsForMyData = (int *)ADIOI_Malloc(naggs * sizeof(int)); sourceAggsForMyData 548 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c sourceAggsForMyData[numSourceAggs] = fd->hints->ranklist[i]; sourceAggsForMyData 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); sourceAggsForMyData 844 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c sourceAggsForMyData[sourceAggIndexesForMyDataThisRound[i]],0,fd->comm, sourceAggsForMyData 900 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIOI_Free(sourceAggsForMyData);