numSourceProcs 89 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int numSourceProcs = 0; numSourceProcs 97 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c numSourceProcs++; numSourceProcs 99 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c sourceProcsForMyData = (int *)ADIOI_Malloc(numSourceProcs * sizeof(int)); numSourceProcs 100 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataAmountToGetPerProc = (int *)ADIOI_Malloc(numSourceProcs * sizeof(int)); numSourceProcs 101 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataOffsetToGetPerProc = (ADIO_Offset *)ADIOI_Malloc(numSourceProcs * sizeof(ADIO_Offset)); numSourceProcs 106 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c numSourceProcs = 0; numSourceProcs 109 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c sourceProcsForMyData[numSourceProcs] = i; numSourceProcs 111 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataAmountToGetPerProc[numSourceProcs] = (end_offsets[i] - st_offsets[i])+1; numSourceProcs 112 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataOffsetToGetPerProc[numSourceProcs] = st_offsets[i]; numSourceProcs 115 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataAmountToGetPerProc[numSourceProcs] = (fd_end[myAggRank] - st_offsets[i]) +1; numSourceProcs 116 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataOffsetToGetPerProc[numSourceProcs] = st_offsets[i]; numSourceProcs 119 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataAmountToGetPerProc[numSourceProcs] = (end_offsets[i] - fd_start[myAggRank]) +1; numSourceProcs 120 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c remainingDataOffsetToGetPerProc[numSourceProcs] = fd_start[myAggRank]; numSourceProcs 123 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c printf("getting %ld bytes from source proc %d in fd rank %d with borders %ld to %ld\n",remainingDataAmountToGetPerProc[numSourceProcs],i,fd->hints->ranklist[myAggRank],fd_start[myAggRank],fd_end[myAggRank]); numSourceProcs 125 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c numSourceProcs++; numSourceProcs 137 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c MPI_Request *mpiRecvDataRequest = (MPI_Request *) ADIOI_Malloc(numSourceProcs * sizeof(MPI_Request)); numSourceProcs 138 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c MPI_Request *mpiSendDataSizeRequest = (MPI_Request *) ADIOI_Malloc(numSourceProcs * sizeof(MPI_Request)); numSourceProcs 171 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int *dataSizeGottenThisRoundPerProc = (int *)ADIOI_Malloc(numSourceProcs * sizeof(int)); numSourceProcs 172 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int *mpiRequestMapPerProc = (int *)ADIOI_Malloc(numSourceProcs * sizeof(int)); numSourceProcs 269 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c for (i=0;i<numSourceProcs;i++) { numSourceProcs 335 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c for (i=0;i<numSourceProcs;i++) {