sourceProcsForMyData 85 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int *sourceProcsForMyData=NULL; sourceProcsForMyData 99 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c sourceProcsForMyData = (int *)ADIOI_Malloc(numSourceProcs * sizeof(int)); sourceProcsForMyData 109 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c sourceProcsForMyData[numSourceProcs] = i; sourceProcsForMyData 291 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c sourceProcsForMyData[i],0,fd->comm, sourceProcsForMyData 344 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c printf("receiving data from rank %d dataSizeGottenThisRoundPerProc is %d currentWBOffset is %d\n",sourceProcsForMyData[i],dataSizeGottenThisRoundPerProc[i],currentWBOffset); sourceProcsForMyData 347 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c MPI_BYTE,sourceProcsForMyData[i],0, sourceProcsForMyData 368 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c printf("numDataRecvToWaitFor is %d was sent %d bytes data for %d remaining bytes from rank %d irecv index %d\n",numDataRecvToWaitFor,dataSizeGottenThisRoundPerProc[mpiRequestMapPerProc[irecv]],remainingDataAmountToGetPerProc[mpiRequestMapPerProc[irecv]],sourceProcsForMyData[mpiRequestMapPerProc[irecv]],irecv); sourceProcsForMyData 462 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIOI_Free(sourceProcsForMyData);