numTargetAggs     380 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c     int numTargetAggs = 0;
numTargetAggs     521 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           numTargetAggs++;
numTargetAggs     535 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         targetAggsForMyDataCurrentRoundIter[numTargetAggs] = startingRound;
numTargetAggs     540 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c       if (targetAggsForMyDataFirstOffLenIndex[targetAggsForMyDataCurrentRoundIter[numTargetAggs]][numTargetAggs] == -1) {
numTargetAggs     541 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         targetAggsForMyData[numTargetAggs] = fd->hints->ranklist[currentAggRankListIndex];
numTargetAggs     542 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         targetAggsForMyDataFDStart[numTargetAggs] = fd_start[currentAggRankListIndex];
numTargetAggs     546 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           if (targetAggsForMyDataFDStart[numTargetAggs] < firstFileOffset)
numTargetAggs     547 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             targetAggsForMyDataFDStart[numTargetAggs] = firstFileOffset;
numTargetAggs     549 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         targetAggsForMyDataFDEnd[numTargetAggs] = fd_end[currentAggRankListIndex];
numTargetAggs     553 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           if (targetAggsForMyDataFDEnd[numTargetAggs] > lastFileOffset)
numTargetAggs     554 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             targetAggsForMyDataFDEnd[numTargetAggs] = lastFileOffset;
numTargetAggs     556 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         targetAggsForMyDataFirstOffLenIndex[targetAggsForMyDataCurrentRoundIter[numTargetAggs]][numTargetAggs] = blockIter;
numTargetAggs     561 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           if (currentFDSourceBufferState[numTargetAggs].sourceBufferOffset == -1) {
numTargetAggs     563 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             currentFDSourceBufferState[numTargetAggs].sourceBufferOffset = currentSourceBufferOffset;
numTargetAggs     570 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           if (currentFDSourceBufferState[numTargetAggs].indiceOffset == -1) {
numTargetAggs     571 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             currentFDSourceBufferState[numTargetAggs].indiceOffset = currentIndiceOffset;
numTargetAggs     572 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             currentFDSourceBufferState[numTargetAggs].bufTypeExtent = bufTypeExtent;
numTargetAggs     573 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             currentFDSourceBufferState[numTargetAggs].dataTypeExtent = currentDataTypeExtent;
numTargetAggs     574 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             currentFDSourceBufferState[numTargetAggs].flatBufIndice = currentFlatBufIndice;
numTargetAggs     576 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",numTargetAggs,currentDataTypeExtent,currentFlatBufIndice,currentIndiceOffset);
numTargetAggs     581 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         intraRoundCollBufsizeOffset = fd_start[currentAggRankListIndex] + ((ADIO_Offset)(targetAggsForMyDataCurrentRoundIter[numTargetAggs]+1) * coll_bufsize);
numTargetAggs     584 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         printf("Initial settings numTargetAggs %d offset_list[%d] with value %ld past fd border %ld with len %ld currentSourceBufferOffset set to %ld intraRoundCollBufsizeOffset set to %ld\n",numTargetAggs,blockIter,offset_list[blockIter],fd_start[currentAggRankListIndex],len_list[blockIter],currentSourceBufferOffset,intraRoundCollBufsizeOffset);
numTargetAggs     590 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c       targetAggsForMyDataLastOffLenIndex[targetAggsForMyDataCurrentRoundIter[numTargetAggs]][numTargetAggs] = blockIter;
numTargetAggs     605 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               targetAggsForMyDataCurrentRoundIter[numTargetAggs]++;
numTargetAggs     607 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               targetAggsForMyDataFirstOffLenIndex[targetAggsForMyDataCurrentRoundIter[numTargetAggs]][numTargetAggs] = blockIter;
numTargetAggs     608 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               targetAggsForMyDataLastOffLenIndex[targetAggsForMyDataCurrentRoundIter[numTargetAggs]][numTargetAggs] = blockIter;
numTargetAggs     610 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               printf("targetAggsForMyDataCurrentRoundI%d] is now %d intraRoundCollBufsizeOffset is now %ld\n",numTargetAggs,targetAggsForMyDataCurrentRoundIter[numTargetAggs],intraRoundCollBufsizeOffset);
numTargetAggs     629 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             numTargetAggs++;
numTargetAggs     630 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             targetAggsForMyData[numTargetAggs] = fd->hints->ranklist[currentAggRankListIndex];
numTargetAggs     631 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             targetAggsForMyDataFDStart[numTargetAggs] = fd_start[currentAggRankListIndex];
numTargetAggs     635 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               if (targetAggsForMyDataFDStart[numTargetAggs] < firstFileOffset)
numTargetAggs     636 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 targetAggsForMyDataFDStart[numTargetAggs] = firstFileOffset;
numTargetAggs     638 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             targetAggsForMyDataFDEnd[numTargetAggs] = fd_end[currentAggRankListIndex];
numTargetAggs     642 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               if (targetAggsForMyDataFDEnd[numTargetAggs] > lastFileOffset)
numTargetAggs     643 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 targetAggsForMyDataFDEnd[numTargetAggs] = lastFileOffset;
numTargetAggs     645 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             targetAggsForMyDataFirstOffLenIndex[targetAggsForMyDataCurrentRoundIter[numTargetAggs]][numTargetAggs] = blockIter;
numTargetAggs     660 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               ADIOI_Assert(numTargetAggs > 0);
numTargetAggs     661 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               if (currentFDSourceBufferState[numTargetAggs].sourceBufferOffset == -1) {
numTargetAggs     663 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                   currentFDSourceBufferState[numTargetAggs].sourceBufferOffset =
numTargetAggs     667 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                   currentFDSourceBufferState[numTargetAggs].sourceBufferOffset =
numTargetAggs     668 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c 		      currentFDSourceBufferState[numTargetAggs-1].sourceBufferOffset+amountToAdvanceSBOffsetForFD;
numTargetAggs     672 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",numTargetAggs,currentFDSourceBufferState[numTargetAggs].sourceBufferOffset,amountToAdvanceSBOffsetForFD);
numTargetAggs     676 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             else if (currentFDSourceBufferState[numTargetAggs].indiceOffset == -1) {
numTargetAggs     678 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c               ADIOI_Assert(numTargetAggs > 0);
numTargetAggs     686 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numTargetAggs].indiceOffset =
numTargetAggs     688 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numTargetAggs].bufTypeExtent = bufTypeExtent;
numTargetAggs     689 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numTargetAggs].dataTypeExtent =
numTargetAggs     691 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numTargetAggs].flatBufIndice =
numTargetAggs     696 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numTargetAggs].indiceOffset =
numTargetAggs     697 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c 		    currentFDSourceBufferState[numTargetAggs-1].indiceOffset;
numTargetAggs     698 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numTargetAggs].bufTypeExtent =
numTargetAggs     699 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c 		    currentFDSourceBufferState[numTargetAggs-1].bufTypeExtent;
numTargetAggs     700 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numTargetAggs].dataTypeExtent =
numTargetAggs     701 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c 		    currentFDSourceBufferState[numTargetAggs-1].dataTypeExtent;
numTargetAggs     702 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c                 currentFDSourceBufferState[numTargetAggs].flatBufIndice =
numTargetAggs     703 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c 		    currentFDSourceBufferState[numTargetAggs-1].flatBufIndice;
numTargetAggs     707 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c 		      &currentFDSourceBufferState[numTargetAggs], NULL);
numTargetAggs     709 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",numTargetAggs,currentFDSourceBufferState[numTargetAggs].dataTypeExtent,currentFDSourceBufferState[numTargetAggs].flatBufIndice,currentFDSourceBufferState[numTargetAggs].indiceOffset,amountToAdvanceSBOffsetForFD);
numTargetAggs     715 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             printf("block extended beyond fd init settings numTargetAggs %d offset_list[%d] with value %ld past fd border %ld with len %ld\n",numTargetAggs,i,offset_list[blockIter],fd_start[currentAggRankListIndex],len_list[blockIter]);
numTargetAggs     718 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c             targetAggsForMyDataLastOffLenIndex[targetAggsForMyDataCurrentRoundIter[numTargetAggs]][numTargetAggs] = blockIter;
numTargetAggs     730 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           targetAggsForMyDataCurrentRoundIter[numTargetAggs]++;
numTargetAggs     732 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           targetAggsForMyDataFirstOffLenIndex[targetAggsForMyDataCurrentRoundIter[numTargetAggs]][numTargetAggs] = blockIter;
numTargetAggs     733 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c           targetAggsForMyDataLastOffLenIndex[targetAggsForMyDataCurrentRoundIter[numTargetAggs]][numTargetAggs] = blockIter;
numTargetAggs     735 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         printf("smaller than fd currentBlockEnd is now %ld intraRoundCollBufsizeOffset is now %ld targetAggsForMyDataCurrentRoundIter[%d] is now %d\n",currentBlockEnd, intraRoundCollBufsizeOffset, numTargetAggs,targetAggsForMyDataCurrentRoundIter[numTargetAggs]);
numTargetAggs     744 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c         numTargetAggs++;
numTargetAggs     748 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c     printf("numTargetAggs is %d\n",numTargetAggs);
numTargetAggs     749 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c     for (i=0;i<numTargetAggs;i++) {
numTargetAggs     850 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c     for (aggIter=0;aggIter<numTargetAggs;aggIter++) {
numTargetAggs      73 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c     int numTargetAggs = 0;
numTargetAggs      77 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 	    targetAggsForMyData[numTargetAggs] = fd->hints->ranklist[i];
numTargetAggs      78 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 	    targetAggsForMyDataFDStart[numTargetAggs] = fd_start[i];
numTargetAggs      79 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 	    targetAggsForMyDataFDEnd[numTargetAggs] = fd_end[i];
numTargetAggs      80 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 	    numTargetAggs++;
numTargetAggs     131 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c     for (i=0;i<numTargetAggs;i++) {
numTargetAggs     136 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c     MPI_Request *mpiSizeToSendRequest = (MPI_Request *) ADIOI_Malloc(numTargetAggs * sizeof(MPI_Request));
numTargetAggs     140 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c     MPI_Request *mpiSendDataToTargetAggRequest = (MPI_Request *) ADIOI_Malloc(numTargetAggs * sizeof(MPI_Request));
numTargetAggs     173 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c     int *targetAggIndexesForMyDataThisRound = (int *)ADIOI_Malloc(numTargetAggs * sizeof(int));
numTargetAggs     174 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c     int *sendBufferOffsetsThisRound = (int *)ADIOI_Malloc(numTargetAggs * sizeof(int));
numTargetAggs     175 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c     int *bufferAmountsToSendThisRound = (int *)ADIOI_Malloc(numTargetAggs * sizeof(int));
numTargetAggs     190 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c 	for (i=0;i<numTargetAggs;i++) {