naggs 242 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c int naggs = nprocs_for_coll; naggs 287 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c ADIO_Offset nb_cn_small = n_gpfs_blk/naggs; naggs 288 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c ADIO_Offset naggs_large = n_gpfs_blk - naggs * (n_gpfs_blk/naggs); naggs 289 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c ADIO_Offset naggs_small = naggs - naggs_large; naggs 299 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c for (i=0; i<naggs; i++) naggs 369 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c for (i=0; i<naggs; i++) { naggs 382 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c for (i=0; i<naggs; i++) { naggs 389 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c for (i=0; i<naggs; i++) { naggs 426 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c fd_size[naggs-1] -= gpfs_ub_rdoff; naggs 430 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c for (aggr=0; aggr<naggs; aggr++) { naggs 430 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c int naggs; naggs 443 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c naggs= naggs 456 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c naggs ); naggs 463 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c for(i=0;i<naggs;i++) naggs 474 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c for (i=0; i<naggs; i++) { naggs 485 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c int *interleavedbridgeranklist = (int *) ADIOI_Malloc (naggs * sizeof(int)); // resorted agg rank list naggs 487 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c int *bridgelist = (int *) ADIOI_Malloc (naggs * sizeof(int)); naggs 491 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c int *bridgelistnum = (int *) ADIOI_Malloc (naggs * sizeof(int)); naggs 493 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c int *ionlist = (int *) ADIOI_Malloc (naggs * sizeof(int)); naggs 497 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c for (i=0;i<naggs;i++) naggs 502 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c int *summarybridgeminionaggrank = (int *) ADIOI_Malloc (naggs * sizeof(int)); naggs 503 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c for (i=0;i<naggs;i++) naggs 509 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c for (i=0;i<naggs;i++) { naggs 601 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c int *thisBridgeAggList = (int *) ADIOI_Malloc (naggs * sizeof(int)); naggs 605 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c for (k=0;k<naggs;k++) { naggs 634 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c for (i=0;i<naggs;i++) { naggs 651 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c fd->hints->cb_nodes = naggs; naggs 653 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c fd->hints->ranklist = (int *) ADIOI_Malloc (naggs * sizeof(int)); naggs 654 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c memcpy( fd->hints->ranklist, interleavedbridgeranklist, naggs*sizeof(int) ); naggs 656 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c fd->hints->fs_hints.bg.bridgelist = (int *) ADIOI_Malloc (naggs * sizeof(int)); naggs 657 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c memcpy( fd->hints->fs_hints.bg.bridgelist, bridgelist, naggs*sizeof(int) ); naggs 659 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c fd->hints->fs_hints.bg.bridgelistnum = (int *) ADIOI_Malloc (naggs * sizeof(int)); naggs 660 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c memcpy( fd->hints->fs_hints.bg.bridgelistnum, bridgelistnum, naggs*sizeof(int) ); naggs 674 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c fd->hints->cb_nodes = naggs; naggs 675 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c fd->hints->ranklist = (int *) ADIOI_Malloc (naggs * sizeof(int)); naggs 676 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c memcpy( fd->hints->ranklist, tmp_ranklist, naggs*sizeof(int) ); naggs 268 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int naggs = fd->hints->cb_nodes; naggs 283 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState = (FDSourceBufferState *) ADIOI_Malloc(naggs * sizeof(FDSourceBufferState)); naggs 284 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (i=0;i<naggs;i++) { naggs 338 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (j=0;j<naggs;j++) { naggs 366 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (j=0;j<naggs;j++) { naggs 377 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int *targetAggsForMyData = (int *)ADIOI_Malloc(naggs * sizeof(int)); naggs 378 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset *targetAggsForMyDataFDStart = (ADIO_Offset *)ADIOI_Malloc(naggs * sizeof(ADIO_Offset)); naggs 379 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset *targetAggsForMyDataFDEnd = (ADIO_Offset *)ADIOI_Malloc(naggs * sizeof(ADIO_Offset)); naggs 387 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c targetAggsForMyDataFirstOffLenIndex[i] = (int *)ADIOI_Malloc(naggs * sizeof(int)); naggs 388 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (j=0;j<naggs;j++) naggs 397 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c targetAggsForMyDataLastOffLenIndex[i] = (int *)ADIOI_Malloc(naggs * sizeof(int)); naggs 401 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (i=0;i<naggs;i++) naggs 421 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int *targetAggsForMyDataCurrentRoundIter = (int *)ADIOI_Malloc(naggs * sizeof(int)); naggs 422 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (i=0;i<naggs;i++) naggs 1303 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int naggs = fd->hints->cb_nodes; naggs 1319 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c currentFDSourceBufferState = (FDSourceBufferState *) ADIOI_Malloc(naggs * sizeof(FDSourceBufferState)); naggs 1320 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (i=0;i<naggs;i++) { naggs 1374 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (j=0;j<naggs;j++) { naggs 1401 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (j=0;j<naggs;j++) { naggs 1411 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c */ int *sourceAggsForMyData = (int *)ADIOI_Malloc(naggs * sizeof(int)); naggs 1412 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset *sourceAggsForMyDataFDStart = (ADIO_Offset *)ADIOI_Malloc(naggs * sizeof(ADIO_Offset)); naggs 1413 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c ADIO_Offset *sourceAggsForMyDataFDEnd = (ADIO_Offset *)ADIOI_Malloc(naggs * sizeof(ADIO_Offset)); naggs 1421 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataFirstOffLenIndex[i] = (int *)ADIOI_Malloc(naggs * sizeof(int)); naggs 1422 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (j=0;j<naggs;j++) naggs 1431 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c sourceAggsForMyDataLastOffLenIndex[i] = (int *)ADIOI_Malloc(naggs * sizeof(int)); naggs 1435 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (i=0;i<naggs;i++) naggs 1455 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int *sourceAggsForMyDataCurrentRoundIter = (int *)ADIOI_Malloc(naggs * sizeof(int)); naggs 1456 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c for (i=0;i<naggs;i++) naggs 48 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int naggs = fd->hints->cb_nodes; naggs 58 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c for (j=0;j<naggs;j++) { naggs 70 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int *targetAggsForMyData = (int *)ADIOI_Malloc(naggs * sizeof(int)); naggs 71 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset *targetAggsForMyDataFDStart = (ADIO_Offset *)ADIOI_Malloc(naggs * sizeof(ADIO_Offset)); naggs 72 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset *targetAggsForMyDataFDEnd = (ADIO_Offset *)ADIOI_Malloc(naggs * sizeof(ADIO_Offset)); naggs 75 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c for (i=0;i<naggs;i++) { naggs 130 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int *amountOfDataReqestedByTargetAgg = (int *)ADIOI_Malloc(naggs * sizeof(int)); naggs 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; naggs 519 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int naggs = fd->hints->cb_nodes; naggs 528 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c for (j=0;j<naggs;j++) { naggs 540 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int *sourceAggsForMyData = (int *)ADIOI_Malloc(naggs * sizeof(int)); naggs 541 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset *sourceAggsForMyDataFDStart = (ADIO_Offset *)ADIOI_Malloc(naggs * sizeof(ADIO_Offset)); naggs 542 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c ADIO_Offset *sourceAggsForMyDataFDEnd = (ADIO_Offset *)ADIOI_Malloc(naggs * sizeof(ADIO_Offset)); naggs 545 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c for (i=0;i<naggs;i++) { naggs 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;