dataSizeGottenThisRoundPerProc 171 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int *dataSizeGottenThisRoundPerProc = (int *)ADIOI_Malloc(numSourceProcs * sizeof(int)); dataSizeGottenThisRoundPerProc 272 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c dataSizeGottenThisRoundPerProc[i] = remainingDataAmountToGetPerProc[i]; dataSizeGottenThisRoundPerProc 274 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c dataSizeGottenThisRoundPerProc[i] = (currentRoundFDEnd - remainingDataOffsetToGetPerProc[i]) +1; dataSizeGottenThisRoundPerProc 278 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c dataSizeGottenThisRoundPerProc[i] = remainingDataAmountToGetPerProc[i]; dataSizeGottenThisRoundPerProc 280 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c dataSizeGottenThisRoundPerProc[i] = (remainingDataOffsetToGetPerProc[i]-currentRoundFDStart) +1; dataSizeGottenThisRoundPerProc 283 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c dataSizeGottenThisRoundPerProc[i] = 0; dataSizeGottenThisRoundPerProc 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); dataSizeGottenThisRoundPerProc 288 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (dataSizeGottenThisRoundPerProc[i] > 0) { dataSizeGottenThisRoundPerProc 290 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c MPI_Isend(&dataSizeGottenThisRoundPerProc[i],1,MPI_INT, dataSizeGottenThisRoundPerProc 339 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentWBOffset += dataSizeGottenThisRoundPerProc[j]; dataSizeGottenThisRoundPerProc 342 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (dataSizeGottenThisRoundPerProc[i] > 0) { dataSizeGottenThisRoundPerProc 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); dataSizeGottenThisRoundPerProc 346 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c MPI_Irecv(&((char*)write_buf)[currentWBOffset],dataSizeGottenThisRoundPerProc[i], dataSizeGottenThisRoundPerProc 363 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c dataSizeGottenThisRoundPerProc[mpiRequestMapPerProc[irecv]]; dataSizeGottenThisRoundPerProc 365 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c dataSizeGottenThisRoundPerProc[mpiRequestMapPerProc[irecv]]; dataSizeGottenThisRoundPerProc 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); dataSizeGottenThisRoundPerProc 371 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c dataSizeGottenThisRoundPerProc[mpiRequestMapPerProc[irecv]]; dataSizeGottenThisRoundPerProc 373 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c dataSizeGottenThisRoundPerProc[mpiRequestMapPerProc[irecv]]; dataSizeGottenThisRoundPerProc 478 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIOI_Free(dataSizeGottenThisRoundPerProc);