numSourceAggs    1414 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c     int numSourceAggs = 0;
numSourceAggs    1548 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           numSourceAggs++;
numSourceAggs    1560 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         sourceAggsForMyDataCurrentRoundIter[numSourceAggs] = startingRound;
numSourceAggs    1565 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c       if (sourceAggsForMyDataFirstOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] == -1) {
numSourceAggs    1566 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         sourceAggsForMyData[numSourceAggs] = fd->hints->ranklist[currentAggRankListIndex];
numSourceAggs    1567 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         sourceAggsForMyDataFDStart[numSourceAggs] = fd_start[currentAggRankListIndex];
numSourceAggs    1571 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           if (sourceAggsForMyDataFDStart[numSourceAggs] < firstFileOffset)
numSourceAggs    1572 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             sourceAggsForMyDataFDStart[numSourceAggs] = firstFileOffset;
numSourceAggs    1574 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         sourceAggsForMyDataFDEnd[numSourceAggs] = fd_end[currentAggRankListIndex];
numSourceAggs    1578 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           if (sourceAggsForMyDataFDEnd[numSourceAggs] > lastFileOffset)
numSourceAggs    1579 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             sourceAggsForMyDataFDEnd[numSourceAggs] = lastFileOffset;
numSourceAggs    1581 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         sourceAggsForMyDataFirstOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter;
numSourceAggs    1586 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           if (currentFDSourceBufferState[numSourceAggs].sourceBufferOffset == -1) {
numSourceAggs    1588 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             currentFDSourceBufferState[numSourceAggs].sourceBufferOffset = currentRecvBufferOffset;
numSourceAggs    1595 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           if (currentFDSourceBufferState[numSourceAggs].indiceOffset == -1) {
numSourceAggs    1596 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             currentFDSourceBufferState[numSourceAggs].indiceOffset = currentIndiceOffset;
numSourceAggs    1597 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             currentFDSourceBufferState[numSourceAggs].bufTypeExtent = bufTypeExtent;
numSourceAggs    1598 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             currentFDSourceBufferState[numSourceAggs].dataTypeExtent = currentDataTypeExtent;
numSourceAggs    1599 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             currentFDSourceBufferState[numSourceAggs].flatBufIndice = currentFlatBufIndice;
numSourceAggs    1601 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             printf("For agg %d dataTypeExtent initialized to %d flatBufIndice to %d indiceOffset to %ld\n",numSourceAggs,currentDataTypeExtent,currentFlatBufIndice,currentIndiceOffset);
numSourceAggs    1605 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         intraRoundCollBufsizeOffset = fd_start[currentAggRankListIndex] + ((ADIO_Offset)(sourceAggsForMyDataCurrentRoundIter[numSourceAggs]+1) * coll_bufsize);
numSourceAggs    1607 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         printf("init settings numSourceAggs %d offset_list[%d] with value %ld past fd border %ld with len %ld currentRecvBufferOffset set to %ld intraRoundCollBufsizeOffset set to %ld\n",numSourceAggs,blockIter,offset_list[blockIter],fd_start[currentAggRankListIndex],len_list[blockIter],currentRecvBufferOffset,intraRoundCollBufsizeOffset);
numSourceAggs    1614 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c       sourceAggsForMyDataLastOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter;
numSourceAggs    1628 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               sourceAggsForMyDataCurrentRoundIter[numSourceAggs]++;
numSourceAggs    1630 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               sourceAggsForMyDataFirstOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter;
numSourceAggs    1631 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               sourceAggsForMyDataLastOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter;
numSourceAggs    1633 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               printf("sourceAggsForMyDataCurrentRoundI%d] is now %d intraRoundCollBufsizeOffset is now %ld\n",numSourceAggs,sourceAggsForMyDataCurrentRoundIter[numSourceAggs],intraRoundCollBufsizeOffset);
numSourceAggs    1652 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             numSourceAggs++;
numSourceAggs    1653 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             sourceAggsForMyData[numSourceAggs] = fd->hints->ranklist[currentAggRankListIndex];
numSourceAggs    1654 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             sourceAggsForMyDataFDStart[numSourceAggs] = fd_start[currentAggRankListIndex];
numSourceAggs    1658 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               if (sourceAggsForMyDataFDStart[numSourceAggs] < firstFileOffset)
numSourceAggs    1659 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 sourceAggsForMyDataFDStart[numSourceAggs] = firstFileOffset;
numSourceAggs    1661 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             sourceAggsForMyDataFDEnd[numSourceAggs] = fd_end[currentAggRankListIndex];
numSourceAggs    1665 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               if (sourceAggsForMyDataFDEnd[numSourceAggs] > lastFileOffset)
numSourceAggs    1666 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 sourceAggsForMyDataFDEnd[numSourceAggs] = lastFileOffset;
numSourceAggs    1668 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             sourceAggsForMyDataFirstOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter;
numSourceAggs    1682 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               ADIOI_Assert(numSourceAggs > 0);
numSourceAggs    1683 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               if (currentFDSourceBufferState[numSourceAggs].sourceBufferOffset == -1) {
numSourceAggs    1685 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                   currentFDSourceBufferState[numSourceAggs].sourceBufferOffset = currentRecvBufferOffset+amountToAdvanceSBOffsetForFD;
numSourceAggs    1688 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                   currentFDSourceBufferState[numSourceAggs].sourceBufferOffset = currentFDSourceBufferState[numSourceAggs-1].sourceBufferOffset+amountToAdvanceSBOffsetForFD;
numSourceAggs    1692 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             printf("Crossed into new FD - for agg %d sourceBufferOffset initialized to %ld amountToAdvanceSBOffsetForFD is %ld\n",numSourceAggs,currentFDSourceBufferState[numSourceAggs].sourceBufferOffset,amountToAdvanceSBOffsetForFD);
numSourceAggs    1696 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             else if (currentFDSourceBufferState[numSourceAggs].indiceOffset == -1) {
numSourceAggs    1698 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               ADIOI_Assert(numSourceAggs > 0);
numSourceAggs    1705 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numSourceAggs].indiceOffset = currentIndiceOffset;
numSourceAggs    1706 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numSourceAggs].bufTypeExtent = bufTypeExtent;
numSourceAggs    1707 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numSourceAggs].dataTypeExtent = currentDataTypeExtent;
numSourceAggs    1708 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numSourceAggs].flatBufIndice = currentFlatBufIndice;
numSourceAggs    1713 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numSourceAggs].indiceOffset = currentFDSourceBufferState[numSourceAggs-1].indiceOffset;
numSourceAggs    1714 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numSourceAggs].bufTypeExtent = currentFDSourceBufferState[numSourceAggs-1].bufTypeExtent;
numSourceAggs    1715 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numSourceAggs].dataTypeExtent = currentFDSourceBufferState[numSourceAggs-1].dataTypeExtent;
numSourceAggs    1716 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numSourceAggs].flatBufIndice = currentFDSourceBufferState[numSourceAggs-1].flatBufIndice;
numSourceAggs    1718 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               nonContigSourceDataBufferAdvance(((char*)buf), flatBuf, (int)amountToAdvanceSBOffsetForFD, 0, &currentFDSourceBufferState[numSourceAggs], NULL);
numSourceAggs    1720 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               printf("Crossed into new FD - for agg %d dataTypeExtent initialized to %d flatBufIndice to %d indiceOffset to %ld amountToAdvanceSBOffsetForFD is %d\n",numSourceAggs,currentFDSourceBufferState[numSourceAggs].dataTypeExtent,currentFDSourceBufferState[numSourceAggs].flatBufIndice,currentFDSourceBufferState[numSourceAggs].indiceOffset,amountToAdvanceSBOffsetForFD);
numSourceAggs    1728 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             printf("block extended beyond fd init settings numSourceAggs %d offset_list[%d] with value %ld past fd border %ld with len %ld\n",numSourceAggs,i,offset_list[blockIter],fd_start[currentAggRankListIndex],len_list[blockIter]);
numSourceAggs    1731 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             sourceAggsForMyDataLastOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter;
numSourceAggs    1742 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           sourceAggsForMyDataCurrentRoundIter[numSourceAggs]++;
numSourceAggs    1744 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           sourceAggsForMyDataFirstOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter;
numSourceAggs    1745 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           sourceAggsForMyDataLastOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter;
numSourceAggs    1747 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           printf("block less than fd currentBlockEnd is now %ld intraRoundCollBufsizeOffset is now %ld sourceAggsForMyDataCurrentRoundIter[%d] is now %d\n",currentBlockEnd, intraRoundCollBufsizeOffset, numSourceAggs,sourceAggsForMyDataCurrentRoundIter[numSourceAggs]);
numSourceAggs    1756 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         numSourceAggs++;
numSourceAggs    1760 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c     printf("numSourceAggs is %d\n",numSourceAggs);
numSourceAggs    1761 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c     for (i=0;i<numSourceAggs;i++) {
numSourceAggs    1952 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c     for (aggIter=0;aggIter<numSourceAggs;aggIter++) {
numSourceAggs     543 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c     int numSourceAggs = 0;
numSourceAggs     548 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 	    sourceAggsForMyData[numSourceAggs] = fd->hints->ranklist[i];
numSourceAggs     549 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 	    sourceAggsForMyDataFDStart[numSourceAggs] = fd_start[i];
numSourceAggs     550 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 	    sourceAggsForMyDataFDEnd[numSourceAggs] = fd_end[i];
numSourceAggs     551 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 	    numSourceAggs++;
numSourceAggs     608 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c     MPI_Request *mpiRecvDataFromSourceAggsRequest = (MPI_Request *) ADIOI_Malloc(numSourceAggs * sizeof(MPI_Request));
numSourceAggs     631 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c     int *sourceAggIndexesForMyDataThisRound = (int *)ADIOI_Malloc(numSourceAggs * sizeof(int));
numSourceAggs     632 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c     int *recvBufferOffsetsThisRound = (int *)ADIOI_Malloc(numSourceAggs * sizeof(int));
numSourceAggs     633 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c     int *bufferAmountsToGetThisRound = (int *)ADIOI_Malloc(numSourceAggs * sizeof(int));
numSourceAggs     755 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 	for (i=0;i<numSourceAggs;i++) {