bufferAmountToRecv 1986 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int bufferAmountToRecv = 0; bufferAmountToRecv 1990 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToRecv = (currentRoundFDEndForMySourceAgg - offsetStart) +1; bufferAmountToRecv 1992 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToRecv = (offsetEnd - offsetStart) +1; bufferAmountToRecv 1996 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToRecv = (currentRoundFDEndForMySourceAgg - currentRoundFDStartForMySourceAgg) +1; bufferAmountToRecv 1998 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToRecv = (offsetEnd - currentRoundFDStartForMySourceAgg) +1; bufferAmountToRecv 2004 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToRecv = (currentRoundFDEndForMySourceAgg - currentRoundFDStartForMySourceAgg) +1; bufferAmountToRecv 2008 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (bufferAmountToRecv > 0) { /* we have data to recv this round */ bufferAmountToRecv 2052 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Get(((char*)buf) + currentFDSourceBufferState[aggIter].sourceBufferOffset,bufferAmountToRecv, MPI_BYTE,sourceAggsForMyData[aggIter],sourceDisplacementToUseThisRound, bufferAmountToRecv,MPI_BYTE,read_buf_window); bufferAmountToRecv 2053 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[aggIter].sourceBufferOffset += (ADIO_Offset)bufferAmountToRecv; bufferAmountToRecv 2057 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c getSourceData = (char *) ADIOI_Malloc(bufferAmountToRecv*sizeof(char)); bufferAmountToRecv 2058 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Get(getSourceData,bufferAmountToRecv, MPI_BYTE,sourceAggsForMyData[aggIter],sourceDisplacementToUseThisRound, bufferAmountToRecv,MPI_BYTE,read_buf_window); bufferAmountToRecv 2063 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, bufferAmountToRecv, 0, ¤tFDSourceBufferState[aggIter], getSourceData); bufferAmountToRecv 2074 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggBlockLengths[sourceAggContigAccessCount]= bufferAmountToRecv; bufferAmountToRecv 2078 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[aggIter].sourceBufferOffset += (ADIO_Offset)bufferAmountToRecv; bufferAmountToRecv 2082 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggBlockLengths[sourceAggContigAccessCount]= bufferAmountToRecv; bufferAmountToRecv 2086 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c derivedTypePackedSourceBufferOffset += (ADIO_Offset)bufferAmountToRecv;