numDataRecvToWaitFor 334 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int numDataRecvToWaitFor = 0; numDataRecvToWaitFor 348 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c fd->comm,&mpiRecvDataRequest[numDataRecvToWaitFor]); numDataRecvToWaitFor 349 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c mpiRequestMapPerProc[numDataRecvToWaitFor] = i; numDataRecvToWaitFor 350 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c numDataRecvToWaitFor++; numDataRecvToWaitFor 359 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c for (i = 0; i < numDataRecvToWaitFor; i++) { numDataRecvToWaitFor 360 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c MPI_Waitany(numDataRecvToWaitFor,mpiRecvDataRequest, numDataRecvToWaitFor 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); numDataRecvToWaitFor 390 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (numDataRecvToWaitFor > 0) {