aggIter           849 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c     int aggIter;
aggIter           850 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c     for (aggIter=0;aggIter<numTargetAggs;aggIter++) {
aggIter           855 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c     if (targetAggsForMyDataFirstOffLenIndex[roundIter][aggIter] != -1) {
aggIter           856 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c       ADIO_Offset currentRoundFDStartForMyTargetAgg = (ADIO_Offset)((ADIO_Offset)targetAggsForMyDataFDStart[aggIter] + (ADIO_Offset)((ADIO_Offset)roundIter*coll_bufsize));
aggIter           857 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c       ADIO_Offset currentRoundFDEndForMyTargetAgg = (ADIO_Offset)((ADIO_Offset)targetAggsForMyDataFDStart[aggIter] + (ADIO_Offset)((ADIO_Offset)(roundIter+1)*coll_bufsize) - (ADIO_Offset)1);
aggIter           874 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c       printf("roundIter %d processing targetAggsForMyData %d \n",roundIter,targetAggsForMyData[aggIter]);
aggIter           880 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c       int startingOffLenIndex = targetAggsForMyDataFirstOffLenIndex[roundIter][aggIter], endingOffLenIndex = targetAggsForMyDataLastOffLenIndex[roundIter][aggIter];
aggIter           882 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         if (currentRoundFDEndForMyTargetAgg > targetAggsForMyDataFDEnd[aggIter])
aggIter           883 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             currentRoundFDEndForMyTargetAgg = targetAggsForMyDataFDEnd[aggIter];
aggIter           889 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             roundIter,aggIter,targetAggsForMyData[aggIter],offsetIter,offset_list[offsetIter],offsetIter,len_list[offsetIter],
aggIter           890 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             targetAggsForMyDataFDStart[aggIter],targetAggsForMyDataFDEnd[aggIter],
aggIter           891 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             currentRoundFDStartForMyTargetAgg,currentRoundFDEndForMyTargetAgg, targetAggsForMyDataFirstOffLenIndex[roundIter][aggIter]);
aggIter           933 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 for (k=targetAggsForMyDataFirstOffLenIndex[roundIter][aggIter];k<=targetAggsForMyDataLastOffLenIndex[roundIter][aggIter];k++)
aggIter           963 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             MPI_Win_lock(MPI_LOCK_SHARED, targetAggsForMyData[aggIter], 0, write_buf_window);
aggIter           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);
aggIter           966 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               currentFDSourceBufferState[aggIter].sourceBufferOffset += (ADIO_Offset)bufferAmountToSend;
aggIter           970 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, bufferAmountToSend, 1, &currentFDSourceBufferState[aggIter], putSourceData);
aggIter           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);
aggIter           974 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             MPI_Win_unlock(targetAggsForMyData[aggIter], write_buf_window);
aggIter           987 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               sourceBufferDisplacements[targetAggContigAccessCount] = (MPI_Aint)currentFDSourceBufferState[aggIter].sourceBufferOffset;
aggIter           988 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               currentFDSourceBufferState[aggIter].sourceBufferOffset += (ADIO_Offset)bufferAmountToSend;
aggIter           992 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, bufferAmountToSend, 1, &currentFDSourceBufferState[aggIter], &derivedTypePackedSourceBuffer[derivedTypePackedSourceBufferOffset]);
aggIter          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]);
aggIter          1019 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         printf("mpi_put of derived type to agg %d targetAggContigAccessCount is %d\n",targetAggsForMyData[aggIter],targetAggContigAccessCount);
aggIter          1022 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         MPI_Win_lock(MPI_LOCK_SHARED, targetAggsForMyData[aggIter], 0, write_buf_window);
aggIter          1024 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           MPI_Put(((char*)buf),1, sourceBufferDerivedDataType,targetAggsForMyData[aggIter],0, 1,targetBufferDerivedDataType,write_buf_window);
aggIter          1027 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           MPI_Put(derivedTypePackedSourceBuffer,1, sourceBufferDerivedDataType,targetAggsForMyData[aggIter],0, 1,targetBufferDerivedDataType,write_buf_window);
aggIter          1031 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         MPI_Win_unlock(targetAggsForMyData[aggIter], write_buf_window);
aggIter          1049 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         MPI_Win_lock(MPI_LOCK_SHARED, targetAggsForMyData[aggIter], 0, fd->io_buf_put_amounts_window);
aggIter          1050 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         MPI_Put(&numBytesPutThisAggRound,1, MPI_INT,targetAggsForMyData[aggIter],myrank, 1,MPI_INT,fd->io_buf_put_amounts_window);
aggIter          1051 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         MPI_Win_unlock(targetAggsForMyData[aggIter], fd->io_buf_put_amounts_window);
aggIter          1951 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c     int aggIter;
aggIter          1952 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c     for (aggIter=0;aggIter<numSourceAggs;aggIter++) {
aggIter          1956 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c     if (sourceAggsForMyDataFirstOffLenIndex[roundIter][aggIter] != -1)  {
aggIter          1958 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c       ADIO_Offset currentRoundFDStartForMySourceAgg = (ADIO_Offset)((ADIO_Offset)sourceAggsForMyDataFDStart[aggIter] + (ADIO_Offset)((ADIO_Offset)roundIter*coll_bufsize));
aggIter          1959 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c       ADIO_Offset currentRoundFDEndForMySourceAgg = (ADIO_Offset)((ADIO_Offset)sourceAggsForMyDataFDStart[aggIter] + (ADIO_Offset)((ADIO_Offset)(roundIter+1)*coll_bufsize) - (ADIO_Offset)1);
aggIter          1977 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c       int startingOffLenIndex = sourceAggsForMyDataFirstOffLenIndex[roundIter][aggIter], endingOffLenIndex = sourceAggsForMyDataLastOffLenIndex[roundIter][aggIter];
aggIter          1979 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         if (currentRoundFDEndForMySourceAgg > sourceAggsForMyDataFDEnd[aggIter])
aggIter          1980 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             currentRoundFDEndForMySourceAgg = sourceAggsForMyDataFDEnd[aggIter];
aggIter          2019 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 for (k=sourceAggsForMyDataFirstOffLenIndex[roundIter][aggIter];k<=sourceAggsForMyDataLastOffLenIndex[roundIter][aggIter];k++)
aggIter          2049 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             MPI_Win_lock(MPI_LOCK_SHARED, sourceAggsForMyData[aggIter], 0, read_buf_window);
aggIter          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);
aggIter          2053 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               currentFDSourceBufferState[aggIter].sourceBufferOffset += (ADIO_Offset)bufferAmountToRecv;
aggIter          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);
aggIter          2061 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             MPI_Win_unlock(sourceAggsForMyData[aggIter], read_buf_window);
aggIter          2063 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, bufferAmountToRecv, 0, &currentFDSourceBufferState[aggIter], getSourceData);
aggIter          2077 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               recvBufferDisplacements[sourceAggContigAccessCount] = (MPI_Aint)currentFDSourceBufferState[aggIter].sourceBufferOffset;
aggIter          2078 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               currentFDSourceBufferState[aggIter].sourceBufferOffset += (ADIO_Offset)bufferAmountToRecv;
aggIter          2105 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         MPI_Win_lock(MPI_LOCK_SHARED, sourceAggsForMyData[aggIter], 0, read_buf_window);
aggIter          2107 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           MPI_Get(((char*)buf),1, recvBufferDerivedDataType,sourceAggsForMyData[aggIter],0, 1,sourceBufferDerivedDataType,read_buf_window);
aggIter          2110 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           MPI_Get(derivedTypePackedSourceBuffer,1, recvBufferDerivedDataType,sourceAggsForMyData[aggIter],0, 1,sourceBufferDerivedDataType,read_buf_window);
aggIter          2113 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         MPI_Win_unlock(sourceAggsForMyData[aggIter], read_buf_window);
aggIter          2115 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, derivedTypePackedSourceBufferOffset, 0, &currentFDSourceBufferState[aggIter], derivedTypePackedSourceBuffer);