targetAggsForMyData 377 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int *targetAggsForMyData = (int *)ADIOI_Malloc(naggs * sizeof(int)); targetAggsForMyData 541 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c targetAggsForMyData[numTargetAggs] = fd->hints->ranklist[currentAggRankListIndex]; targetAggsForMyData 630 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c targetAggsForMyData[numTargetAggs] = fd->hints->ranklist[currentAggRankListIndex]; targetAggsForMyData 751 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("targetAggsForMyData[%d] is %d targetAggsForMyDataFDStart[%d] is %ld targetAggsForMyDataFDEnd is %ld targetAggsForMyDataFirstOffLenIndex is %d with value %ld targetAggsForMyDataLastOffLenIndex is %d with value %ld\n",i,targetAggsForMyData[i],i,targetAggsForMyDataFDStart[i],targetAggsForMyDataFDEnd[i],targetAggsForMyDataFirstOffLenIndex[j][i],offset_list[targetAggsForMyDataFirstOffLenIndex[j][i]],targetAggsForMyDataLastOffLenIndex[j][i],offset_list[targetAggsForMyDataLastOffLenIndex[j][i]]); targetAggsForMyData 874 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("roundIter %d processing targetAggsForMyData %d \n",roundIter,targetAggsForMyData[aggIter]); targetAggsForMyData 889 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c roundIter,aggIter,targetAggsForMyData[aggIter],offsetIter,offset_list[offsetIter],offsetIter,len_list[offsetIter], targetAggsForMyData 963 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Win_lock(MPI_LOCK_SHARED, targetAggsForMyData[aggIter], 0, write_buf_window); targetAggsForMyData 965 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Put(((char*)buf) + currentFDSourceBufferState[aggIter].sourceBufferOffset,bufferAmountToSend, MPI_BYTE,targetAggsForMyData[aggIter],targetDisplacementToUseThisRound, bufferAmountToSend,MPI_BYTE,write_buf_window); targetAggsForMyData 971 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Put(putSourceData,bufferAmountToSend, MPI_BYTE,targetAggsForMyData[aggIter],targetDisplacementToUseThisRound, bufferAmountToSend,MPI_BYTE,write_buf_window); targetAggsForMyData 974 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Win_unlock(targetAggsForMyData[aggIter], write_buf_window); targetAggsForMyData 1019 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("mpi_put of derived type to agg %d targetAggContigAccessCount is %d\n",targetAggsForMyData[aggIter],targetAggContigAccessCount); targetAggsForMyData 1022 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Win_lock(MPI_LOCK_SHARED, targetAggsForMyData[aggIter], 0, write_buf_window); targetAggsForMyData 1024 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Put(((char*)buf),1, sourceBufferDerivedDataType,targetAggsForMyData[aggIter],0, 1,targetBufferDerivedDataType,write_buf_window); targetAggsForMyData 1027 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Put(derivedTypePackedSourceBuffer,1, sourceBufferDerivedDataType,targetAggsForMyData[aggIter],0, 1,targetBufferDerivedDataType,write_buf_window); targetAggsForMyData 1031 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Win_unlock(targetAggsForMyData[aggIter], write_buf_window); targetAggsForMyData 1049 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Win_lock(MPI_LOCK_SHARED, targetAggsForMyData[aggIter], 0, fd->io_buf_put_amounts_window); targetAggsForMyData 1050 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Put(&numBytesPutThisAggRound,1, MPI_INT,targetAggsForMyData[aggIter],myrank, 1,MPI_INT,fd->io_buf_put_amounts_window); targetAggsForMyData 1051 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Win_unlock(targetAggsForMyData[aggIter], fd->io_buf_put_amounts_window); targetAggsForMyData 1202 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIOI_Free(targetAggsForMyData); targetAggsForMyData 70 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int *targetAggsForMyData = (int *)ADIOI_Malloc(naggs * sizeof(int)); targetAggsForMyData 77 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c targetAggsForMyData[numTargetAggs] = fd->hints->ranklist[i]; targetAggsForMyData 203 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c roundIter,i,targetAggsForMyData[i],myOffsetStart,myOffsetEnd, targetAggsForMyData 245 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c MPI_INT,targetAggsForMyData[i],0, targetAggsForMyData 309 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c printf("irecv is %d amountOfDataReqestedByTargetAgg is %d bufferAmountsToSendThisRound is %d sendBufferOffsetsThisRound is %d targetAggsForMyData is %d\n",irecv,amountOfDataReqestedByTargetAgg[irecv], bufferAmountsToSendThisRound[irecv], sendBufferOffsetsThisRound[irecv],targetAggsForMyData[targetAggIndexesForMyDataThisRound[irecv]]); targetAggsForMyData 314 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c targetAggsForMyData[targetAggIndexesForMyDataThisRound[irecv]], targetAggsForMyData 320 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c printf("i is %d bufferAmountsToSendThisRound is %d sendBufferOffsetsThisRound is %d targetAggsForMyData is %d\n",i, bufferAmountsToSendThisRound[i], sendBufferOffsetsThisRound[i],targetAggsForMyData[targetAggIndexesForMyDataThisRound[i]]); targetAggsForMyData 323 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c targetAggsForMyData[targetAggIndexesForMyDataThisRound[i]],0,fd->comm,&mpiSendDataToTargetAggRequest[i]); targetAggsForMyData 354 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c printf("MPI_Irecv from rank %d\n",targetAggsForMyData[i]); targetAggsForMyData 467 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIOI_Free(targetAggsForMyData);