cb_nodes 109 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c ADIOI_Assert ( (off <= fd_end[fd->hints->cb_nodes-1] && off >= min_off && fd_start[0] >= min_off ) ); cb_nodes 112 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c int ub = fd->hints->cb_nodes; cb_nodes 129 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c rank_index = fd->hints->cb_nodes / 2; cb_nodes 144 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c if (rank_index >= fd->hints->cb_nodes || rank_index < 0) { cb_nodes 146 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_aggrs.c rank_index,fd->hints->cb_nodes,fd_size,off); cb_nodes 113 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_hints.c fd->hints->cb_nodes = -1; cb_nodes 234 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_hints.c fd->hints->cb_nodes = intval; cb_nodes 242 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_hints.c ADIOI_BG_gen_agg_ranklist(fd, fd->hints->cb_nodes); cb_nodes 144 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_rdcoll.c nprocs_for_coll = fd->hints->cb_nodes; cb_nodes 151 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c nprocs_for_coll = fd->hints->cb_nodes; cb_nodes 594 ompi/mca/io/romio321/romio/adio/ad_gpfs/ad_gpfs_wrcoll.c for (i=0; i<fd->hints->cb_nodes; i++ ){ cb_nodes 124 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c ADIOI_Malloc(fd->hints->cb_nodes*sizeof(int)); cb_nodes 129 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c MPI_Bcast(fd->hints->fs_hints.bg.bridgelist, fd->hints->cb_nodes, MPI_INT, 0, cb_nodes 134 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c ADIOI_Malloc(fd->hints->cb_nodes*sizeof(int)); cb_nodes 139 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c MPI_Bcast(fd->hints->fs_hints.bg.bridgelistnum, fd->hints->cb_nodes, cb_nodes 651 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c fd->hints->cb_nodes = naggs; cb_nodes 674 ompi/mca/io/romio321/romio/adio/ad_gpfs/bg/ad_bg_aggrs.c fd->hints->cb_nodes = naggs; cb_nodes 272 ompi/mca/io/romio321/romio/adio/ad_gpfs/pe/ad_pe_aggrs.c fd->hints->cb_nodes = numAggs; cb_nodes 26 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_aggregate.c int avail_cb_nodes, divisor, nprocs_for_coll = fd->hints->cb_nodes; cb_nodes 115 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_aggregate.c if (rank_index >= fd->hints->cb_nodes) cb_nodes 220 ompi/mca/io/romio321/romio/adio/ad_lustre/ad_lustre_wrcoll.c if (fd->hints->cb_nodes == 1) cb_nodes 101 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c if (rank_index >= fd->hints->cb_nodes || rank_index < 0) { cb_nodes 103 ompi/mca/io/romio321/romio/adio/common/ad_aggregate.c rank_index,fd->hints->cb_nodes,fd_size,off); cb_nodes 53 ompi/mca/io/romio321/romio/adio/common/ad_aggregate_new.c nprocs_for_coll = fd->hints->cb_nodes; cb_nodes 263 ompi/mca/io/romio321/romio/adio/common/ad_aggregate_new.c int i, cb_nodes, *ranklist; cb_nodes 264 ompi/mca/io/romio321/romio/adio/common/ad_aggregate_new.c cb_nodes = fd->hints->cb_nodes; cb_nodes 267 ompi/mca/io/romio321/romio/adio/common/ad_aggregate_new.c for (i=0; i<cb_nodes; i++) { cb_nodes 86 ompi/mca/io/romio321/romio/adio/common/ad_close.c for (i=0; i<fd->hints->cb_nodes; i++) { cb_nodes 571 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c rw_type == ADIOI_WRITE && fd->hints->cb_nodes > 1) cb_nodes 925 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c if (i != fd->hints->cb_nodes - 1) cb_nodes 986 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c assert(tmp_agg_fr_idx < fd->hints->cb_nodes); cb_nodes 1177 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c if (tmp_agg_idx != fd->hints->cb_nodes - 1) cb_nodes 1261 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c if (agg_idx < 0 || agg_idx >= fd->hints->cb_nodes) cb_nodes 1800 ompi/mca/io/romio321/romio/adio/common/ad_coll_build_req_new.c if (agg_idx < 0 || agg_idx >= fd->hints->cb_nodes) cb_nodes 181 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c send_count_arr = ADIOI_Calloc(fd->hints->cb_nodes, cb_nodes 195 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c send_req_arr = ADIOI_Calloc (fd->hints->cb_nodes, sizeof(MPI_Request)); cb_nodes 196 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c for (i=0; i < fd->hints->cb_nodes; i++) { cb_nodes 222 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c for (i = 0; i < fd->hints->cb_nodes; i++) cb_nodes 301 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c MPI_Waitall(fd->hints->cb_nodes, send_req_arr, statuses); cb_nodes 321 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c for (i = 0; i < fd->hints->cb_nodes; i++) cb_nodes 338 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c for (i=0; i < fd->hints->cb_nodes; i++) cb_nodes 419 ompi/mca/io/romio321/romio/adio/common/ad_coll_exch_new.c for (i = 0; i < fd->hints->cb_nodes; i++) { cb_nodes 77 ompi/mca/io/romio321/romio/adio/common/ad_hints.c fd->hints->cb_nodes = nprocs; cb_nodes 213 ompi/mca/io/romio321/romio/adio/common/ad_hints.c &(fd->hints->cb_nodes), myname, error_code); cb_nodes 214 ompi/mca/io/romio321/romio/adio/common/ad_hints.c if ((fd->hints->cb_nodes <= 0) || (fd->hints->cb_nodes > nprocs)) { cb_nodes 220 ompi/mca/io/romio321/romio/adio/common/ad_hints.c fd->hints->cb_nodes = nprocs; cb_nodes 115 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c nprocs_for_coll = fd->hints->cb_nodes; cb_nodes 257 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i = 0; i < fd->hints->cb_nodes; i++) cb_nodes 259 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c agg_rank = fd->hints->ranklist[(i+myrank)%fd->hints->cb_nodes]; cb_nodes 264 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c fd, agg_rank, (i+myrank)%fd->hints->cb_nodes, cb_nodes 319 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c ADIOI_Calloc (fd->hints->cb_nodes, sizeof(MPI_Request)); cb_nodes 321 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i = 0; i < fd->hints->cb_nodes; i++) cb_nodes 324 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c agg_rank = fd->hints->ranklist[(i+myrank)%fd->hints->cb_nodes]; cb_nodes 327 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c (i+myrank)%fd->hints->cb_nodes, cb_nodes 591 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i = 0; i < fd->hints->cb_nodes; i++) cb_nodes 593 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c agg_rank = fd->hints->ranklist[(i+myrank)%fd->hints->cb_nodes]; cb_nodes 598 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c fd, agg_rank, (i+myrank)%fd->hints->cb_nodes, cb_nodes 638 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=0; i<fd->hints->cb_nodes; i++) { cb_nodes 1021 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c recv_requests = ADIOI_Malloc (fd->hints->cb_nodes * sizeof(MPI_Request)); cb_nodes 1023 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i = 0; i < fd->hints->cb_nodes; i++) cb_nodes 1049 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c for (i=0; i < fd->hints->cb_nodes; i++) { cb_nodes 1050 ompi/mca/io/romio321/romio/adio/common/ad_io_coll.c MPI_Waitany (fd->hints->cb_nodes, recv_requests, &recv_idx, &status); cb_nodes 260 ompi/mca/io/romio321/romio/adio/common/ad_iread_coll.c vars->nprocs_for_coll = fd->hints->cb_nodes; cb_nodes 285 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c vars->nprocs_for_coll = fd->hints->cb_nodes; cb_nodes 535 ompi/mca/io/romio321/romio/adio/common/ad_iwrite_coll.c if (fd->hints->cb_nodes == 1) { cb_nodes 246 ompi/mca/io/romio321/romio/adio/common/ad_open.c for (i=0; i< fd->hints->cb_nodes; i++ ) { cb_nodes 309 ompi/mca/io/romio321/romio/adio/common/ad_open.c fd->hints->cb_nodes); cb_nodes 317 ompi/mca/io/romio321/romio/adio/common/ad_open.c fd->hints->cb_nodes = rank_ct; cb_nodes 326 ompi/mca/io/romio321/romio/adio/common/ad_open.c if (fd->hints->cb_nodes <= 0) { cb_nodes 98 ompi/mca/io/romio321/romio/adio/common/ad_read_coll.c nprocs_for_coll = fd->hints->cb_nodes; cb_nodes 97 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c nprocs_for_coll = fd->hints->cb_nodes; cb_nodes 232 ompi/mca/io/romio321/romio/adio/common/ad_write_coll.c if (fd->hints->cb_nodes == 1) cb_nodes 43 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c static int get_max_procs(int cb_nodes); cb_nodes 74 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c MPI_Bcast(&(fd->hints->cb_nodes), 1, MPI_INT, 0, fd->comm); cb_nodes 75 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c if (fd->hints->cb_nodes > 0) { cb_nodes 78 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c fd->hints->ranklist = ADIOI_Malloc(fd->hints->cb_nodes*sizeof(int)); cb_nodes 89 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c MPI_Bcast(fd->hints->ranklist, fd->hints->cb_nodes, MPI_INT, 0, cb_nodes 95 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c ADIOI_Snprintf(value, MPI_MAX_INFO_VAL+1, "%d", fd->hints->cb_nodes); cb_nodes 102 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c for (i=0; i< fd->hints->cb_nodes; i++) { cb_nodes 277 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c int cb_nodes) cb_nodes 304 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c if (cb_nodes > nr_procnames) cb_nodes = nr_procnames; cb_nodes 323 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c for (cur_rank = 0; cur_rank < cb_nodes; cur_rank++) { cb_nodes 330 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c return cb_nodes; cb_nodes 333 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c while (cur_rank < cb_nodes) { cb_nodes 365 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c max_procs = get_max_procs(cb_nodes); cb_nodes 378 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c nr_procnames, ranklist, cb_nodes, &cur_rank); cb_nodes 668 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c static int get_max_procs(int cb_nodes) cb_nodes 682 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c if (token == AGG_WILDCARD) max_procs = cb_nodes; cb_nodes 268 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int naggs = fd->hints->cb_nodes; cb_nodes 1303 ompi/mca/io/romio321/romio/adio/common/onesided_aggregation.c int naggs = fd->hints->cb_nodes; cb_nodes 48 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int naggs = fd->hints->cb_nodes; cb_nodes 519 ompi/mca/io/romio321/romio/adio/common/p2p_aggregation.c int naggs = fd->hints->cb_nodes; cb_nodes 26 ompi/mca/io/romio321/romio/adio/include/adio_cb_config_list.h int ranklist[], int cb_nodes); cb_nodes 37 ompi/mca/io/romio321/romio/adio/include/adioi.h int cb_nodes; cb_nodes 51 ompi/mca/io/romio321/romio/test-internal/file_realms_test.c fd->hints->cb_nodes = nprocs_for_coll;