bufferAmountToSend 896 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int bufferAmountToSend = 0; bufferAmountToSend 900 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - offsetStart) +1; bufferAmountToSend 902 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToSend = (offsetEnd - offsetStart) +1; bufferAmountToSend 906 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - currentRoundFDStartForMyTargetAgg) +1; bufferAmountToSend 908 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToSend = (offsetEnd - currentRoundFDStartForMyTargetAgg) +1; bufferAmountToSend 914 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - currentRoundFDStartForMyTargetAgg) +1; bufferAmountToSend 918 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c numBytesPutThisAggRound += bufferAmountToSend; bufferAmountToSend 920 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("bufferAmountToSend is %d\n",bufferAmountToSend); bufferAmountToSend 922 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (bufferAmountToSend > 0) { /* we have data to send this round */ bufferAmountToSend 965 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Put(((char*)buf) + currentFDSourceBufferState[aggIter].sourceBufferOffset,bufferAmountToSend, MPI_BYTE,targetAggsForMyData[aggIter],targetDisplacementToUseThisRound, bufferAmountToSend,MPI_BYTE,write_buf_window); bufferAmountToSend 966 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[aggIter].sourceBufferOffset += (ADIO_Offset)bufferAmountToSend; bufferAmountToSend 969 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c char *putSourceData = (char *) ADIOI_Malloc(bufferAmountToSend*sizeof(char)); bufferAmountToSend 970 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, bufferAmountToSend, 1, ¤tFDSourceBufferState[aggIter], putSourceData); bufferAmountToSend 971 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c MPI_Put(putSourceData,bufferAmountToSend, MPI_BYTE,targetAggsForMyData[aggIter],targetDisplacementToUseThisRound, bufferAmountToSend,MPI_BYTE,write_buf_window); bufferAmountToSend 984 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c targetAggBlockLengths[targetAggContigAccessCount]= bufferAmountToSend; bufferAmountToSend 988 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState[aggIter].sourceBufferOffset += (ADIO_Offset)bufferAmountToSend; bufferAmountToSend 992 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, bufferAmountToSend, 1, ¤tFDSourceBufferState[aggIter], &derivedTypePackedSourceBuffer[derivedTypePackedSourceBufferOffset]); bufferAmountToSend 993 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c targetAggBlockLengths[targetAggContigAccessCount]= bufferAmountToSend; bufferAmountToSend 998 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c derivedTypePackedSourceBufferOffset += (ADIO_Offset)bufferAmountToSend; bufferAmountToSend 1002 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("roundIter %d bufferAmountToSend is %d offsetStart is %ld currentRoundFDStartForMyTargetAgg is %ld targetDisplacementToUseThisRound is %ld targetAggsForMyDataFDStart[aggIter] is %ld\n",roundIter, bufferAmountToSend, offsetStart,currentRoundFDStartForMyTargetAgg,targetDisplacementToUseThisRound,targetAggsForMyDataFDStart[aggIter]); bufferAmountToSend 214 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int bufferAmountToSend = 0; bufferAmountToSend 218 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - myOffsetStart) +1; bufferAmountToSend 220 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToSend = (myOffsetEnd - myOffsetStart) +1; bufferAmountToSend 225 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - currentRoundFDStartForMyTargetAgg) +1; bufferAmountToSend 227 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToSend = (myOffsetEnd - currentRoundFDStartForMyTargetAgg) +1; bufferAmountToSend 231 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountToSend = (currentRoundFDEndForMyTargetAgg - currentRoundFDStartForMyTargetAgg) +1; bufferAmountToSend 234 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if (bufferAmountToSend > 0) { /* we have data to send this round */ bufferAmountToSend 237 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c bufferAmountsToSendThisRound[numTargetAggsThisRound] = bufferAmountToSend; bufferAmountToSend 239 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c printf("bufferAmountToSend is %d sendBufferOffset is %d\n",bufferAmountToSend,sendBufferOffset);