coll_bufsize 530 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c int coll_bufsize; coll_bufsize 542 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c coll_bufsize = fd->hints->cb_buffer_size; coll_bufsize 572 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ntimes = (int) ((end_loc - st_loc + coll_bufsize)/coll_bufsize); coll_bufsize 663 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c size = ADIOI_MIN((unsigned)coll_bufsize, end_loc-st_loc+1-done); coll_bufsize 781 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c ADIOI_Assert((for_next_iter+coll_bufsize) == (size_t)(for_next_iter+coll_bufsize)); coll_bufsize 784 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c fd->io_buf = (char *) ADIOI_Malloc(for_next_iter+coll_bufsize); coll_bufsize 641 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c int info_flag, coll_bufsize; coll_bufsize 658 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c coll_bufsize = atoi(value); coll_bufsize 664 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c coll_bufsize = coll_bufsize/2; coll_bufsize 684 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c ntimes = (int) ((end_loc - st_loc + coll_bufsize)/coll_bufsize); coll_bufsize 716 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c write_buf2 = fd->io_buf + coll_bufsize; coll_bufsize 802 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c size = ADIOI_MIN((unsigned)coll_bufsize, end_loc-st_loc+1-done); coll_bufsize 113 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int coll_bufsize; coll_bufsize 595 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c int coll_bufsize; coll_bufsize 605 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c coll_bufsize = fd->hints->cb_buffer_size; coll_bufsize 606 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->coll_bufsize = coll_bufsize; coll_bufsize 639 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->ntimes = (int)((end_loc - st_loc + coll_bufsize) / coll_bufsize); coll_bufsize 760 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c size = ADIOI_MIN((unsigned)vars->coll_bufsize, coll_bufsize 892 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c ADIOI_Assert((for_next_iter+vars->coll_bufsize) == (size_t)(for_next_iter+vars->coll_bufsize)); coll_bufsize 895 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c fd->io_buf = (char *)ADIOI_Malloc(for_next_iter+vars->coll_bufsize); coll_bufsize 115 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int coll_bufsize; coll_bufsize 642 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c int info_flag, coll_bufsize; coll_bufsize 655 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c coll_bufsize = atoi(value); coll_bufsize 656 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->coll_bufsize = coll_bufsize; coll_bufsize 679 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->ntimes = (int)((end_loc - st_loc + coll_bufsize) / coll_bufsize); coll_bufsize 800 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c size = ADIOI_MIN((unsigned)vars->coll_bufsize, coll_bufsize 527 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c int coll_bufsize; coll_bufsize 537 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c coll_bufsize = fd->hints->cb_buffer_size; coll_bufsize 567 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ntimes = (int) ((end_loc - st_loc + coll_bufsize)/coll_bufsize); coll_bufsize 651 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c size = ADIOI_MIN((unsigned)coll_bufsize, end_loc-st_loc+1-done); coll_bufsize 738 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c ADIOI_Assert((ADIO_Size) (for_next_iter+coll_bufsize) == (size_t)(for_next_iter+coll_bufsize)); coll_bufsize 741 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c fd->io_buf = (char *) ADIOI_Malloc(for_next_iter+coll_bufsize); coll_bufsize 325 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c int info_flag, coll_bufsize; coll_bufsize 339 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c coll_bufsize = atoi(value); coll_bufsize 360 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c ntimes = (int) ((end_loc - st_loc + coll_bufsize)/coll_bufsize); coll_bufsize 444 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c size = ADIOI_MIN((unsigned)coll_bufsize, end_loc-st_loc+1-done); coll_bufsize 324 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset coll_bufsize = (ADIO_Offset)(fd->hints->cb_buffer_size); coll_bufsize 328 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c coll_bufsize = (ADIO_Offset)(fd->hints->cb_buffer_size/2); coll_bufsize 367 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int currentNumberOfRounds = (int)(((fd_end[j] - fd_start[j])+(ADIO_Offset)1)/coll_bufsize); coll_bufsize 368 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (((ADIO_Offset)currentNumberOfRounds*coll_bufsize) < ((fd_end[j] - fd_start[j])+(ADIO_Offset)1)) coll_bufsize 528 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((blockStart - fd_start[currentAggRankListIndex]) >= coll_bufsize) { coll_bufsize 531 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c while (blockStart > (currentRoundBlockStart + coll_bufsize - (ADIO_Offset)1)) { coll_bufsize 532 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundBlockStart+=coll_bufsize; coll_bufsize 581 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c intraRoundCollBufsizeOffset = fd_start[currentAggRankListIndex] + ((ADIO_Offset)(targetAggsForMyDataCurrentRoundIter[numTargetAggs]+1) * coll_bufsize); coll_bufsize 606 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c intraRoundCollBufsizeOffset += coll_bufsize; coll_bufsize 717 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c intraRoundCollBufsizeOffset = fd_start[currentAggRankListIndex] + coll_bufsize; coll_bufsize 731 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c intraRoundCollBufsizeOffset += coll_bufsize; coll_bufsize 771 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c char *write_buf1 = fd->io_buf + coll_bufsize; coll_bufsize 805 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { coll_bufsize 816 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c tmpCurrentRoundFDEnd = currentRoundFDStart + coll_bufsize - (ADIO_Offset)1; coll_bufsize 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)); coll_bufsize 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); coll_bufsize 955 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c targetDisplacementToUseThisRound += (MPI_Aint) coll_bufsize; coll_bufsize 1065 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { coll_bufsize 1076 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = currentRoundFDStart + coll_bufsize - (ADIO_Offset)1; coll_bufsize 1150 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDStart += coll_bufsize; coll_bufsize 1154 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { coll_bufsize 1165 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c tmpCurrentRoundFDEnd = currentRoundFDStart + coll_bufsize - (ADIO_Offset)1; coll_bufsize 1360 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int coll_bufsize = fd->hints->cb_buffer_size; coll_bufsize 1364 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c coll_bufsize = fd->hints->cb_buffer_size/2; coll_bufsize 1402 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int currentNumberOfRounds = (int)(((fd_end[j] - fd_start[j])+(ADIO_Offset)1)/coll_bufsize); coll_bufsize 1403 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if (((ADIO_Offset)currentNumberOfRounds*coll_bufsize) < ((fd_end[j] - fd_start[j])+(ADIO_Offset)1)) coll_bufsize 1553 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((blockStart - fd_start[currentAggRankListIndex]) >= coll_bufsize) { coll_bufsize 1556 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c while (blockStart > (currentRoundBlockStart + coll_bufsize - (ADIO_Offset)1)) { coll_bufsize 1557 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundBlockStart+=coll_bufsize; coll_bufsize 1605 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c intraRoundCollBufsizeOffset = fd_start[currentAggRankListIndex] + ((ADIO_Offset)(sourceAggsForMyDataCurrentRoundIter[numSourceAggs]+1) * coll_bufsize); coll_bufsize 1629 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c intraRoundCollBufsizeOffset += coll_bufsize; coll_bufsize 1730 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c intraRoundCollBufsizeOffset = fd_start[currentAggRankListIndex] + coll_bufsize; coll_bufsize 1743 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c intraRoundCollBufsizeOffset += coll_bufsize; coll_bufsize 1775 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c char *read_buf1 = fd->io_buf + coll_bufsize; coll_bufsize 1843 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { coll_bufsize 1848 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentRoundFDEnd = currentRoundFDStart + coll_bufsize - (ADIO_Offset)1; coll_bufsize 1849 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c amountDataToReadThisRound = coll_bufsize; coll_bufsize 1866 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nextRoundFDStart += coll_bufsize; coll_bufsize 1868 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c if ((fd_end[myAggRank] - nextRoundFDStart) < coll_bufsize) { coll_bufsize 1873 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nextRoundFDEnd = nextRoundFDStart + coll_bufsize - (ADIO_Offset)1; coll_bufsize 1874 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c amountDataToReadNextRound = coll_bufsize; coll_bufsize 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)); coll_bufsize 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); coll_bufsize 2041 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceDisplacementToUseThisRound += (MPI_Aint)coll_bufsize; coll_bufsize 2140 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c nextRoundFDStart = currentRoundFDStart + coll_bufsize; coll_bufsize 49 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int coll_bufsize = fd->hints->cb_buffer_size; coll_bufsize 53 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c coll_bufsize = fd->hints->cb_buffer_size/2; coll_bufsize 146 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c char *write_buf1 = fd->io_buf + coll_bufsize; coll_bufsize 153 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset numberOfRounds = (ADIO_Offset)((((ADIO_Offset)(end_offsets[nprocs-1]-st_offsets[0]))/((ADIO_Offset)((ADIO_Offset)coll_bufsize*(ADIO_Offset)naggs)))) + 1; coll_bufsize 196 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset currentRoundFDStartForMyTargetAgg = (ADIO_Offset)((ADIO_Offset)targetAggsForMyDataFDStart[i] + (ADIO_Offset)((ADIO_Offset)roundIter*(ADIO_Offset)coll_bufsize)); coll_bufsize 197 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset currentRoundFDEndForMyTargetAgg = (ADIO_Offset)((ADIO_Offset)targetAggsForMyDataFDStart[i] + (ADIO_Offset)((ADIO_Offset)(roundIter+1)*(ADIO_Offset)coll_bufsize) - (ADIO_Offset)1); coll_bufsize 255 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { coll_bufsize 259 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDEnd = currentRoundFDStart + coll_bufsize - 1; coll_bufsize 437 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDStart += coll_bufsize; coll_bufsize 520 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int coll_bufsize = fd->hints->cb_buffer_size; coll_bufsize 524 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c coll_bufsize = coll_bufsize/2; coll_bufsize 615 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c char *read_buf1 = fd->io_buf + coll_bufsize; coll_bufsize 620 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset numberOfRounds = (ADIO_Offset)((((ADIO_Offset)(end_offsets[nprocs-1]-st_offsets[0]))/((ADIO_Offset)((ADIO_Offset)coll_bufsize*(ADIO_Offset)naggs)))) + 1; coll_bufsize 663 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((fd_end[myAggRank] - currentRoundFDStart) < coll_bufsize) { coll_bufsize 668 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c currentRoundFDEnd = currentRoundFDStart + coll_bufsize - 1; coll_bufsize 669 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c amountDataToReadThisRound = coll_bufsize; coll_bufsize 690 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c nextRoundFDStart += coll_bufsize; coll_bufsize 692 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c if ((fd_end[myAggRank] - nextRoundFDStart) < coll_bufsize) { coll_bufsize 697 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c nextRoundFDEnd = nextRoundFDStart + coll_bufsize - 1; coll_bufsize 698 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c amountDataToReadNextRound = coll_bufsize; coll_bufsize 765 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c (ADIO_Offset)((ADIO_Offset)roundIter*(ADIO_Offset)coll_bufsize)); coll_bufsize 768 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c (ADIO_Offset)((ADIO_Offset)(roundIter+1)*(ADIO_Offset)coll_bufsize) - (ADIO_Offset)1); coll_bufsize 874 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c nextRoundFDStart = currentRoundFDStart + coll_bufsize;