remainingDataAmountToGetPerProc   86 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c     int *remainingDataAmountToGetPerProc=NULL;
remainingDataAmountToGetPerProc  100 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 	remainingDataAmountToGetPerProc = (int *)ADIOI_Malloc(numSourceProcs * sizeof(int));
remainingDataAmountToGetPerProc  111 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 		    remainingDataAmountToGetPerProc[numSourceProcs] = (end_offsets[i] - st_offsets[i])+1;
remainingDataAmountToGetPerProc  115 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 		    remainingDataAmountToGetPerProc[numSourceProcs] = (fd_end[myAggRank] - st_offsets[i]) +1;
remainingDataAmountToGetPerProc  119 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 		    remainingDataAmountToGetPerProc[numSourceProcs] = (end_offsets[i] - fd_start[myAggRank]) +1;
remainingDataAmountToGetPerProc  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]);
remainingDataAmountToGetPerProc  271 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 		if ((remainingDataOffsetToGetPerProc[i] + remainingDataAmountToGetPerProc[i]) <= currentRoundFDEnd)
remainingDataAmountToGetPerProc  272 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 		    dataSizeGottenThisRoundPerProc[i] = remainingDataAmountToGetPerProc[i];
remainingDataAmountToGetPerProc  276 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 	    else if (((remainingDataOffsetToGetPerProc[i]+remainingDataAmountToGetPerProc[i]) >= currentRoundFDStart) && ((remainingDataOffsetToGetPerProc[i]+remainingDataAmountToGetPerProc[i]) <= currentRoundFDEnd)) {
remainingDataAmountToGetPerProc  278 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 		    dataSizeGottenThisRoundPerProc[i] = remainingDataAmountToGetPerProc[i];
remainingDataAmountToGetPerProc  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);
remainingDataAmountToGetPerProc  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);
remainingDataAmountToGetPerProc  370 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 	    remainingDataAmountToGetPerProc[mpiRequestMapPerProc[irecv]] -=
remainingDataAmountToGetPerProc  463 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 	ADIOI_Free(remainingDataAmountToGetPerProc);