sourceAggsForMyDataCurrentRoundIter 1455 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int *sourceAggsForMyDataCurrentRoundIter = (int *)ADIOI_Malloc(naggs * sizeof(int)); sourceAggsForMyDataCurrentRoundIter 1457 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataCurrentRoundIter[i] = 0; sourceAggsForMyDataCurrentRoundIter 1560 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataCurrentRoundIter[numSourceAggs] = startingRound; sourceAggsForMyDataCurrentRoundIter 1565 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (sourceAggsForMyDataFirstOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] == -1) { sourceAggsForMyDataCurrentRoundIter 1581 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataFirstOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter; sourceAggsForMyDataCurrentRoundIter 1605 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c intraRoundCollBufsizeOffset = fd_start[currentAggRankListIndex] + ((ADIO_Offset)(sourceAggsForMyDataCurrentRoundIter[numSourceAggs]+1) * coll_bufsize); sourceAggsForMyDataCurrentRoundIter 1614 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataLastOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter; sourceAggsForMyDataCurrentRoundIter 1628 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataCurrentRoundIter[numSourceAggs]++; sourceAggsForMyDataCurrentRoundIter 1630 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataFirstOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter; sourceAggsForMyDataCurrentRoundIter 1631 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataLastOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter; sourceAggsForMyDataCurrentRoundIter 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); sourceAggsForMyDataCurrentRoundIter 1668 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataFirstOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter; sourceAggsForMyDataCurrentRoundIter 1731 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataLastOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter; sourceAggsForMyDataCurrentRoundIter 1742 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataCurrentRoundIter[numSourceAggs]++; sourceAggsForMyDataCurrentRoundIter 1744 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataFirstOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter; sourceAggsForMyDataCurrentRoundIter 1745 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataLastOffLenIndex[sourceAggsForMyDataCurrentRoundIter[numSourceAggs]][numSourceAggs] = blockIter; sourceAggsForMyDataCurrentRoundIter 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]); sourceAggsForMyDataCurrentRoundIter 1762 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (j=0;j<=sourceAggsForMyDataCurrentRoundIter[i];j++) sourceAggsForMyDataCurrentRoundIter 1770 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIOI_Free(sourceAggsForMyDataCurrentRoundIter);