currentAggRankListIndex 407 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int currentAggRankListIndex = 0; currentAggRankListIndex 508 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (!((blockStart >= fd_start[currentAggRankListIndex]) && (blockStart <= fd_end[currentAggRankListIndex]))) { currentAggRankListIndex 509 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c while (!((blockStart >= fd_start[currentAggRankListIndex]) && (blockStart <= fd_end[currentAggRankListIndex]))) currentAggRankListIndex 510 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentAggRankListIndex++; currentAggRankListIndex 514 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("currentAggRankListIndex is %d blockStart %ld blockEnd %ld fd_start[currentAggRankListIndex] %ld fd_end[currentAggRankListIndex] %ld\n",currentAggRankListIndex,blockStart,blockEnd,fd_start[currentAggRankListIndex],fd_end[currentAggRankListIndex]); currentAggRankListIndex 520 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((offset_list[blockIter-1]+len_list[blockIter-1]-(ADIO_Offset)1) < fd_start[currentAggRankListIndex]) { currentAggRankListIndex 528 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((blockStart - fd_start[currentAggRankListIndex]) >= coll_bufsize) { currentAggRankListIndex 529 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset currentRoundBlockStart = fd_start[currentAggRankListIndex]; currentAggRankListIndex 541 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c targetAggsForMyData[numTargetAggs] = fd->hints->ranklist[currentAggRankListIndex]; currentAggRankListIndex 542 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c targetAggsForMyDataFDStart[numTargetAggs] = fd_start[currentAggRankListIndex]; currentAggRankListIndex 545 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentAggRankListIndex == smallestFileDomainAggRank) { currentAggRankListIndex 549 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c targetAggsForMyDataFDEnd[numTargetAggs] = fd_end[currentAggRankListIndex]; currentAggRankListIndex 552 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentAggRankListIndex == greatestFileDomainAggRank) { currentAggRankListIndex 565 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("For agg %d sourceBufferOffset initialized to %ld\n",currentAggRankListIndex,currentSourceBufferOffset); currentAggRankListIndex 581 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c intraRoundCollBufsizeOffset = fd_start[currentAggRankListIndex] + ((ADIO_Offset)(targetAggsForMyDataCurrentRoundIter[numTargetAggs]+1) * coll_bufsize); currentAggRankListIndex 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); currentAggRankListIndex 594 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (blockEnd > fd_end[currentAggRankListIndex]) { currentAggRankListIndex 596 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("block extends past current fd, blockEnd %ld >= fd_end[currentAggRankListIndex] %ld total block size is %ld blockStart was %ld\n",blockEnd,fd_end[currentAggRankListIndex], len_list[blockIter],blockStart); currentAggRankListIndex 601 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c while (blockEnd >= fd_end[currentAggRankListIndex]) { currentAggRankListIndex 602 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset thisAggBlockEnd = fd_end[currentAggRankListIndex]; currentAggRankListIndex 615 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int prevAggRankListIndex = currentAggRankListIndex; currentAggRankListIndex 616 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentAggRankListIndex++; currentAggRankListIndex 620 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (fd_start[currentAggRankListIndex] > fd_end[currentAggRankListIndex]) { currentAggRankListIndex 621 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c while (fd_start[currentAggRankListIndex] > fd_end[currentAggRankListIndex]) currentAggRankListIndex 622 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentAggRankListIndex++; currentAggRankListIndex 628 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (blockEnd >= fd_start[currentAggRankListIndex]) { currentAggRankListIndex 630 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c targetAggsForMyData[numTargetAggs] = fd->hints->ranklist[currentAggRankListIndex]; currentAggRankListIndex 631 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c targetAggsForMyDataFDStart[numTargetAggs] = fd_start[currentAggRankListIndex]; currentAggRankListIndex 634 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentAggRankListIndex == smallestFileDomainAggRank) { currentAggRankListIndex 638 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c targetAggsForMyDataFDEnd[numTargetAggs] = fd_end[currentAggRankListIndex]; currentAggRankListIndex 641 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentAggRankListIndex == greatestFileDomainAggRank) { currentAggRankListIndex 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]); currentAggRankListIndex 717 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c intraRoundCollBufsizeOffset = fd_start[currentAggRankListIndex] + coll_bufsize; currentAggRankListIndex 1441 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int currentAggRankListIndex = 0; currentAggRankListIndex 1539 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (!((blockStart >= fd_start[currentAggRankListIndex]) && (blockStart <= fd_end[currentAggRankListIndex]))) { currentAggRankListIndex 1540 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c while (!((blockStart >= fd_start[currentAggRankListIndex]) && (blockStart <= fd_end[currentAggRankListIndex]))) currentAggRankListIndex 1541 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentAggRankListIndex++; currentAggRankListIndex 1547 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((offset_list[blockIter-1]+len_list[blockIter-1]-(ADIO_Offset)1) < fd_start[currentAggRankListIndex]) currentAggRankListIndex 1553 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((blockStart - fd_start[currentAggRankListIndex]) >= coll_bufsize) { currentAggRankListIndex 1554 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset currentRoundBlockStart = fd_start[currentAggRankListIndex]; currentAggRankListIndex 1566 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyData[numSourceAggs] = fd->hints->ranklist[currentAggRankListIndex]; currentAggRankListIndex 1567 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataFDStart[numSourceAggs] = fd_start[currentAggRankListIndex]; currentAggRankListIndex 1570 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentAggRankListIndex == smallestFileDomainAggRank) { currentAggRankListIndex 1574 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataFDEnd[numSourceAggs] = fd_end[currentAggRankListIndex]; currentAggRankListIndex 1577 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentAggRankListIndex == greatestFileDomainAggRank) { currentAggRankListIndex 1590 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("For agg %d sourceBufferOffset initialized to %ld\n",currentAggRankListIndex,currentRecvBufferOffset); currentAggRankListIndex 1605 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c intraRoundCollBufsizeOffset = fd_start[currentAggRankListIndex] + ((ADIO_Offset)(sourceAggsForMyDataCurrentRoundIter[numSourceAggs]+1) * coll_bufsize); currentAggRankListIndex 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); currentAggRankListIndex 1618 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (blockEnd > fd_end[currentAggRankListIndex]) { currentAggRankListIndex 1620 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c printf("block extends past current fd, blockEnd %ld >= fd_end[currentAggRankListIndex] %ld total block size is %ld blockStart was %ld\n",blockEnd,fd_end[currentAggRankListIndex], len_list[blockIter],blockStart); currentAggRankListIndex 1624 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c while (blockEnd >= fd_end[currentAggRankListIndex]) { currentAggRankListIndex 1625 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset thisAggBlockEnd = fd_end[currentAggRankListIndex]; currentAggRankListIndex 1638 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int prevAggRankListIndex = currentAggRankListIndex; currentAggRankListIndex 1639 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentAggRankListIndex++; currentAggRankListIndex 1643 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (fd_start[currentAggRankListIndex] > fd_end[currentAggRankListIndex]) { currentAggRankListIndex 1644 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c while (fd_start[currentAggRankListIndex] > fd_end[currentAggRankListIndex]) currentAggRankListIndex 1645 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentAggRankListIndex++; currentAggRankListIndex 1651 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (blockEnd >= fd_start[currentAggRankListIndex]) { currentAggRankListIndex 1653 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyData[numSourceAggs] = fd->hints->ranklist[currentAggRankListIndex]; currentAggRankListIndex 1654 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataFDStart[numSourceAggs] = fd_start[currentAggRankListIndex]; currentAggRankListIndex 1657 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentAggRankListIndex == smallestFileDomainAggRank) { currentAggRankListIndex 1661 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataFDEnd[numSourceAggs] = fd_end[currentAggRankListIndex]; currentAggRankListIndex 1664 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (currentAggRankListIndex == greatestFileDomainAggRank) { currentAggRankListIndex 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]); currentAggRankListIndex 1730 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c intraRoundCollBufsizeOffset = fd_start[currentAggRankListIndex] + coll_bufsize;