group 90 ompi/communicator/comm.c static int ompi_comm_idup_internal (ompi_communicator_t *comm, ompi_group_t *group, ompi_group_t *remote_group, group 154 ompi/communicator/comm.c if ( (NULL != remote_group) && (&ompi_mpi_group_null.group != remote_group) ) { group 189 ompi/communicator/comm.c if (&ompi_mpi_group_null.group == remote_group) { group 259 ompi/communicator/comm.c int ompi_comm_group ( ompi_communicator_t* comm, ompi_group_t **group ) group 264 ompi/communicator/comm.c *group = comm->c_local_group; group 274 ompi/communicator/comm.c int ompi_comm_create ( ompi_communicator_t *comm, ompi_group_t *group, group 292 ompi/communicator/comm.c remote_group = &ompi_mpi_group_null.group; group 301 ompi/communicator/comm.c rc = comm->c_coll->coll_allgather ( &(group->grp_my_rank), group 318 ompi/communicator/comm.c if ( 0 == rsize || 0 == group->grp_proc_count ) { group 354 ompi/communicator/comm.c group, /* local group */ group 498 ompi/communicator/comm.c remote_group = &ompi_mpi_group_null.group; group 648 ompi/communicator/comm.c static int ompi_comm_split_type_get_part (ompi_group_t *group, const int split_type, int **ranks_out, int *rank_size) { group 649 ompi/communicator/comm.c int size = ompi_group_size (group); group 660 ompi/communicator/comm.c ompi_proc_t *proc = ompi_group_get_proc_ptr_raw (group, i); group 1059 ompi/communicator/comm.c static int ompi_comm_idup_internal (ompi_communicator_t *comm, ompi_group_t *group, ompi_group_t *remote_group, group 1097 ompi/communicator/comm.c group, /* local group */ group 1191 ompi/communicator/comm.c int ompi_comm_create_group (ompi_communicator_t *comm, ompi_group_t *group, int tag, ompi_communicator_t **newcomm) group 1200 ompi/communicator/comm.c group->grp_proc_count, /* local_size */ group 1207 ompi/communicator/comm.c group, /* local group */ group 1104 ompi/communicator/comm_cid.c ompi_group_t *group = cid_context->newcomm->c_local_group; group 1105 ompi/communicator/comm_cid.c const int group_size = ompi_group_size (group); group 1106 ompi/communicator/comm_cid.c const int group_rank = ompi_group_rank (group); group 1138 ompi/communicator/comm_cid.c ompi_group_translate_ranks (group, 3, peers_group, comm->c_local_group, context->peers_comm); group 88 ompi/communicator/comm_init.c ompi_group_t *group; group 108 ompi/communicator/comm_init.c group = OBJ_NEW(ompi_group_t); group 111 ompi/communicator/comm_init.c group->grp_proc_pointers = (ompi_proc_t **) calloc (size, sizeof (ompi_proc_t *)); group 112 ompi/communicator/comm_init.c group->grp_proc_count = size; group 117 ompi/communicator/comm_init.c group->grp_proc_pointers[i] = (ompi_proc_t *) ompi_proc_lookup (name); group 118 ompi/communicator/comm_init.c if (NULL == group->grp_proc_pointers[i]) { group 120 ompi/communicator/comm_init.c group->grp_proc_pointers[i] = (ompi_proc_t *) ompi_proc_name_to_sentinel (name); group 122 ompi/communicator/comm_init.c OBJ_RETAIN (group->grp_proc_pointers[i]); group 126 ompi/communicator/comm_init.c OMPI_GROUP_SET_INTRINSIC (group); group 127 ompi/communicator/comm_init.c OMPI_GROUP_SET_DENSE (group); group 128 ompi/communicator/comm_init.c ompi_set_group_rank(group, ompi_proc_local()); group 133 ompi/communicator/comm_init.c ompi_mpi_comm_world.comm.c_my_rank = group->grp_my_rank; group 134 ompi/communicator/comm_init.c ompi_mpi_comm_world.comm.c_local_group = group; group 135 ompi/communicator/comm_init.c ompi_mpi_comm_world.comm.c_remote_group = group; group 177 ompi/communicator/comm_init.c group = OBJ_NEW(ompi_group_t); group 178 ompi/communicator/comm_init.c group->grp_proc_pointers = ompi_proc_self(&size); group 179 ompi/communicator/comm_init.c group->grp_my_rank = 0; group 180 ompi/communicator/comm_init.c group->grp_proc_count = (int)size; group 181 ompi/communicator/comm_init.c OMPI_GROUP_SET_INTRINSIC (group); group 182 ompi/communicator/comm_init.c OMPI_GROUP_SET_DENSE (group); group 187 ompi/communicator/comm_init.c ompi_mpi_comm_self.comm.c_my_rank = group->grp_my_rank; group 188 ompi/communicator/comm_init.c ompi_mpi_comm_self.comm.c_local_group = group; group 189 ompi/communicator/comm_init.c ompi_mpi_comm_self.comm.c_remote_group = group; group 209 ompi/communicator/comm_init.c ompi_mpi_comm_null.comm.c_local_group = &ompi_mpi_group_null.group; group 210 ompi/communicator/comm_init.c ompi_mpi_comm_null.comm.c_remote_group = &ompi_mpi_group_null.group; group 211 ompi/communicator/comm_init.c OBJ_RETAIN(&ompi_mpi_group_null.group); group 212 ompi/communicator/comm_init.c OBJ_RETAIN(&ompi_mpi_group_null.group); group 229 ompi/communicator/comm_init.c OBJ_RETAIN(&ompi_mpi_group_null.group); group 411 ompi/communicator/communicator.h OMPI_DECLSPEC int ompi_comm_group (ompi_communicator_t *comm, ompi_group_t **group); group 416 ompi/communicator/communicator.h int ompi_comm_create (ompi_communicator_t* comm, ompi_group_t *group, group 423 ompi/communicator/communicator.h int ompi_comm_create_group (ompi_communicator_t *comm, ompi_group_t *group, int tag, group 447 ompi/debuggers/ompi_mpihandles_dll.c mqs_taddr_t group, topo, keyhash; group 500 ompi/debuggers/ompi_mpihandles_dll.c group = ompi_fetch_pointer(process, group 504 ompi/debuggers/ompi_mpihandles_dll.c group + i_info->ompi_group_t.offset.grp_my_rank, group 507 ompi/debuggers/ompi_mpihandles_dll.c group + i_info->ompi_group_t.offset.grp_proc_count, group 520 ompi/debuggers/ompi_mpihandles_dll.c group = ompi_fetch_pointer(process, group 524 ompi/debuggers/ompi_mpihandles_dll.c group + i_info->ompi_group_t.offset.grp_proc_count, group 238 ompi/debuggers/ompi_msgq_dll.c group_t *group; group 257 ompi/debuggers/ompi_msgq_dll.c group = comm->group; group 258 ompi/debuggers/ompi_msgq_dll.c if( group && (group->group_base == group_base) ) { group 259 ompi/debuggers/ompi_msgq_dll.c group->ref_count++; /* Someone else is interested */ group 261 ompi/debuggers/ompi_msgq_dll.c (void*)group, group->ref_count) ); group 262 ompi/debuggers/ompi_msgq_dll.c return group; group 267 ompi/debuggers/ompi_msgq_dll.c group = (group_t *)mqs_malloc (sizeof (group_t)); group 270 ompi/debuggers/ompi_msgq_dll.c group->local_to_global = tr; group 271 ompi/debuggers/ompi_msgq_dll.c group->group_base = group_base; group 273 ompi/debuggers/ompi_msgq_dll.c (void*)group, np) ); group 283 ompi/debuggers/ompi_msgq_dll.c (void*)group)); group 284 ompi/debuggers/ompi_msgq_dll.c mqs_free (group); group 306 ompi/debuggers/ompi_msgq_dll.c group->local_to_global[i] = is_dense ? i : -1; group 319 ompi/debuggers/ompi_msgq_dll.c group->local_to_global[i] = j; group 324 ompi/debuggers/ompi_msgq_dll.c group->local_to_global[i] = -1; group 331 ompi/debuggers/ompi_msgq_dll.c group->entries = np; group 332 ompi/debuggers/ompi_msgq_dll.c group->ref_count = 1; group 333 ompi/debuggers/ompi_msgq_dll.c return group; group 337 ompi/debuggers/ompi_msgq_dll.c static void group_decref (group_t * group) group 339 ompi/debuggers/ompi_msgq_dll.c DEBUG(VERBOSE_GROUP, ("Decrement reference count for group %p to %d\n", (void*)group, group 340 ompi/debuggers/ompi_msgq_dll.c (group->ref_count - 1))); group 341 ompi/debuggers/ompi_msgq_dll.c if (--(group->ref_count) == 0) { group 342 ompi/debuggers/ompi_msgq_dll.c mqs_free (group->local_to_global); group 343 ompi/debuggers/ompi_msgq_dll.c DEBUG(VERBOSE_GROUP, ("Destroy group %p\n", (void*)group)); group 344 ompi/debuggers/ompi_msgq_dll.c mqs_free (group); group 673 ompi/debuggers/ompi_msgq_dll.c old->group = NULL; group 681 ompi/debuggers/ompi_msgq_dll.c old->group = find_or_create_group( proc, group_base ); group 686 ompi/debuggers/ompi_msgq_dll.c if( NULL != old->group ) { group 687 ompi/debuggers/ompi_msgq_dll.c old->comm_info.size = old->group->entries; group 693 ompi/debuggers/ompi_msgq_dll.c (void*)old->group)); group 713 ompi/debuggers/ompi_msgq_dll.c (void*)comm->group)); group 714 ompi/debuggers/ompi_msgq_dll.c group_decref (comm->group); /* Group is no longer referenced from here */ group 804 ompi/debuggers/ompi_msgq_dll.c if (comm && comm->group) { group 805 ompi/debuggers/ompi_msgq_dll.c group_t * g = comm->group; group 1139 ompi/debuggers/ompi_msgq_dll.c res->desired_global_rank = translate( extra->current_communicator->group, group 1211 ompi/debuggers/ompi_msgq_dll.c res->actual_global_rank = translate( extra->current_communicator->group, group 1235 ompi/debuggers/ompi_msgq_dll.c res->actual_global_rank = translate( extra->current_communicator->group, group 1312 ompi/debuggers/ompi_msgq_dll.c if( NULL != comm->group ) group 1313 ompi/debuggers/ompi_msgq_dll.c group_decref (comm->group); /* Group is no longer referenced from here */ group 67 ompi/debuggers/ompi_msgq_dll_defs.h group_t * group; /* Translations */ group 63 ompi/debuggers/predefined_pad_test.c PAD_CHECK(group); group 109 ompi/dpm/dpm.c ompi_group_t *group=comm->c_local_group; group 162 ompi/dpm/dpm.c if (OMPI_GROUP_IS_DENSE(group)) { group 163 ompi/dpm/dpm.c proc_list = group->grp_proc_pointers; group 166 ompi/dpm/dpm.c proc_list = (ompi_proc_t**)calloc(group->grp_proc_count, group 168 ompi/dpm/dpm.c for (i=0 ; i<group->grp_proc_count ; i++) { group 169 ompi/dpm/dpm.c if (NULL == (proc_list[i] = ompi_group_peer_lookup(group,i))) { group 462 ompi/dpm/dpm.c group->grp_proc_count, /* local_size */ group 469 ompi/dpm/dpm.c group, /* local group */ group 520 ompi/dpm/dpm.c static int construct_peers(ompi_group_t *group, opal_list_t *peers) group 527 ompi/dpm/dpm.c for (i=0; i < group->grp_proc_count; i++) { group 528 ompi/dpm/dpm.c if (OMPI_GROUP_IS_DENSE(group)) { group 529 ompi/dpm/dpm.c proct = group->grp_proc_pointers[i]; group 531 ompi/dpm/dpm.c proct = ompi_group_peer_lookup(group, i); group 566 ompi/dpm/dpm.c ompi_group_t *group; group 578 ompi/dpm/dpm.c group = comm->c_local_group; group 579 ompi/dpm/dpm.c if (OMPI_SUCCESS != (ret = construct_peers(group, &coll))) { group 585 ompi/dpm/dpm.c group = comm->c_remote_group; group 586 ompi/dpm/dpm.c if (OMPI_SUCCESS != (ret = construct_peers(group, &coll))) { group 1205 ompi/dpm/dpm.c static bool ompi_dpm_group_is_dyn (ompi_group_t *group, ompi_jobid_t thisjobid) group 1207 ompi/dpm/dpm.c int size = group ? ompi_group_size (group) : 0; group 1210 ompi/dpm/dpm.c opal_process_name_t name = ompi_group_get_proc_name (group, i); group 35 ompi/group/group.c int ompi_group_free ( ompi_group_t **group ) group 39 ompi/group/group.c l_group = (ompi_group_t *) *group; group 42 ompi/group/group.c *group = MPI_GROUP_NULL; group 128 ompi/group/group.c int ompi_group_dump (ompi_group_t* group) group 134 ompi/group/group.c printf("Group Proc Count: %d\n",group->grp_proc_count); group 135 ompi/group/group.c printf("Group My Rank: %d\n",group->grp_my_rank); group 136 ompi/group/group.c if (OMPI_GROUP_IS_SPORADIC(group)) { group 137 ompi/group/group.c ompi_group_translate_ranks( group,1,&group->grp_my_rank, group 138 ompi/group/group.c group->grp_parent_group_ptr, group 142 ompi/group/group.c group->sparse_data.grp_sporadic.grp_sporadic_list_len); group 144 ompi/group/group.c for(i=0 ; i<group->sparse_data.grp_sporadic.grp_sporadic_list_len ; i++) { group 146 ompi/group/group.c group->sparse_data.grp_sporadic.grp_sporadic_list[i].rank_first, group 147 ompi/group/group.c group->sparse_data.grp_sporadic.grp_sporadic_list[i].length); group 150 ompi/group/group.c else if (OMPI_GROUP_IS_STRIDED(group)) { group 151 ompi/group/group.c ompi_group_translate_ranks( group,1,&group->grp_my_rank, group 152 ompi/group/group.c group->grp_parent_group_ptr, group 155 ompi/group/group.c printf("The Offset is: %d\n",group->sparse_data.grp_strided.grp_strided_offset); group 156 ompi/group/group.c printf("The Stride is: %d\n",group->sparse_data.grp_strided.grp_strided_stride); group 158 ompi/group/group.c group->sparse_data.grp_strided.grp_strided_last_element); group 160 ompi/group/group.c else if (OMPI_GROUP_IS_BITMAP(group)) { group 161 ompi/group/group.c ompi_group_translate_ranks( group,1,&group->grp_my_rank, group 162 ompi/group/group.c group->grp_parent_group_ptr, group 166 ompi/group/group.c group->sparse_data.grp_bitmap.grp_bitmap_array_len); group 167 ompi/group/group.c for (i=0 ; i<group->sparse_data.grp_bitmap.grp_bitmap_array_len ; i++) { group 168 ompi/group/group.c printf("%d\t",group->sparse_data.grp_bitmap.grp_bitmap_array[i]); group 190 ompi/group/group.c int ompi_group_incl(ompi_group_t* group, int n, const int *ranks, ompi_group_t **new_group) group 202 ompi/group/group.c len[3] = ompi_group_calc_bmap ( n , group->grp_proc_count ,ranks ); group 212 ompi/group/group.c result = ompi_group_incl_plist(group, n, ranks, new_group); group 215 ompi/group/group.c result = ompi_group_incl_strided(group, n, ranks, new_group); group 218 ompi/group/group.c result = ompi_group_incl_spor(group, n, ranks, new_group); group 221 ompi/group/group.c result = ompi_group_incl_bmap(group, n, ranks, new_group); group 228 ompi/group/group.c int ompi_group_excl(ompi_group_t* group, int n, const int *ranks, ompi_group_t **new_group) group 235 ompi/group/group.c if (0 < (group->grp_proc_count - n)) { group 236 ompi/group/group.c ranks_included = (int *)malloc( (group->grp_proc_count-n)*(sizeof(int))); group 238 ompi/group/group.c for (i=0 ; i<group->grp_proc_count ; i++) { group 251 ompi/group/group.c result = ompi_group_incl(group, k, ranks_included, new_group); group 260 ompi/group/group.c int ompi_group_range_incl(ompi_group_t* group, int n_triplets, int ranges[][3], group 337 ompi/group/group.c result = ompi_group_incl(group, k, ranks_included, new_group); group 345 ompi/group/group.c int ompi_group_range_excl(ompi_group_t* group, int n_triplets, int ranges[][3], group 418 ompi/group/group.c if (0 != (group->grp_proc_count - count)) { group 419 ompi/group/group.c ranks_included = (int *)malloc( (group->grp_proc_count - count)*(sizeof(int))); group 421 ompi/group/group.c for (j=0 ; j<group->grp_proc_count ; j++) { group 434 ompi/group/group.c result = ompi_group_incl(group, k, ranks_included, new_group); group 559 ompi/group/group.c bool ompi_group_have_remote_peers (ompi_group_t *group) group 561 ompi/group/group.c for (int i = 0 ; i < group->grp_proc_count ; ++i) { group 564 ompi/group/group.c proc = ompi_group_peer_lookup (group, i); group 566 ompi/group/group.c proc = ompi_group_get_proc_ptr_raw (group, i); group 113 ompi/group/group.h struct ompi_group_t group; group 169 ompi/group/group.h OMPI_DECLSPEC void ompi_group_increment_proc_count(ompi_group_t *group); group 177 ompi/group/group.h OMPI_DECLSPEC void ompi_group_decrement_proc_count(ompi_group_t *group); group 203 ompi/group/group.h static inline int ompi_group_size(ompi_group_t *group) group 205 ompi/group/group.h return group->grp_proc_count; group 216 ompi/group/group.h static inline int ompi_group_rank(ompi_group_t *group) group 218 ompi/group/group.h return group->grp_my_rank; group 233 ompi/group/group.h void ompi_set_group_rank(ompi_group_t *group, struct ompi_proc_t *proc_pointer); group 253 ompi/group/group.h int ompi_group_free (ompi_group_t **group); group 287 ompi/group/group.h int ompi_group_incl(ompi_group_t* group, int n, const int *ranks, group 289 ompi/group/group.h int ompi_group_excl(ompi_group_t* group, int n, const int *ranks, group 291 ompi/group/group.h int ompi_group_range_incl(ompi_group_t* group, int n_triplets, group 293 ompi/group/group.h int ompi_group_range_excl(ompi_group_t* group, int n_triplets, group 306 ompi/group/group.h int ompi_group_incl_plist(ompi_group_t* group, int n, const int *ranks, group 308 ompi/group/group.h int ompi_group_incl_spor(ompi_group_t* group, int n, const int *ranks, group 310 ompi/group/group.h int ompi_group_incl_strided(ompi_group_t* group, int n, const int *ranks, group 312 ompi/group/group.h int ompi_group_incl_bmap(ompi_group_t* group, int n, const int *ranks, group 337 ompi/group/group.h static inline struct ompi_proc_t *ompi_group_dense_lookup (ompi_group_t *group, const int peer_id, const bool allocate) group 342 ompi/group/group.h if (peer_id >= group->grp_proc_count) { group 348 ompi/group/group.h proc = group->grp_proc_pointers[peer_id]; group 359 ompi/group/group.h if (opal_atomic_compare_exchange_strong_ptr ((opal_atomic_intptr_t *)(group->grp_proc_pointers + peer_id), group 374 ompi/group/group.h static inline ompi_proc_t *ompi_group_get_proc_ptr (ompi_group_t *group, int rank, const bool allocate) group 378 ompi/group/group.h if (OMPI_GROUP_IS_DENSE(group)) { group 379 ompi/group/group.h return ompi_group_dense_lookup (group, rank, allocate); group 382 ompi/group/group.h ompi_group_translate_ranks (group, 1, &ranks1, group->grp_parent_group_ptr, &rank); group 383 ompi/group/group.h group = group->grp_parent_group_ptr; group 386 ompi/group/group.h return ompi_group_dense_lookup (group, rank, allocate); group 397 ompi/group/group.h ompi_proc_t *ompi_group_get_proc_ptr_raw (ompi_group_t *group, int rank); group 399 ompi/group/group.h static inline opal_process_name_t ompi_group_get_proc_name (ompi_group_t *group, int rank) group 401 ompi/group/group.h ompi_proc_t *proc = ompi_group_get_proc_ptr_raw (group, rank); group 413 ompi/group/group.h static inline struct ompi_proc_t* ompi_group_peer_lookup(ompi_group_t *group, int peer_id) group 415 ompi/group/group.h return ompi_group_get_proc_ptr (group, peer_id, true); group 418 ompi/group/group.h static inline struct ompi_proc_t *ompi_group_peer_lookup_existing (ompi_group_t *group, int peer_id) group 420 ompi/group/group.h return ompi_group_get_proc_ptr (group, peer_id, false); group 423 ompi/group/group.h bool ompi_group_have_remote_peers (ompi_group_t *group); group 428 ompi/group/group.h int ompi_group_dump (ompi_group_t* group); group 147 ompi/group/group_bitmap.c int ompi_group_incl_bmap(ompi_group_t* group, int n, const int *ranks, group 154 ompi/group/group_bitmap.c group_pointer = (ompi_group_t *)group; group 162 ompi/group/group_bitmap.c new_group_pointer = ompi_group_allocate_bmap(group->grp_proc_count, n); group 220 ompi/group/group_init.c void ompi_group_increment_proc_count(ompi_group_t *group) group 223 ompi/group/group_init.c for (int proc = 0 ; proc < group->grp_proc_count ; ++proc) { group 224 ompi/group/group_init.c proc_pointer = ompi_group_peer_lookup_existing (group, proc); group 235 ompi/group/group_init.c void ompi_group_decrement_proc_count(ompi_group_t *group) group 238 ompi/group/group_init.c for (int proc = 0 ; proc < group->grp_proc_count ; ++proc) { group 239 ompi/group/group_init.c proc_pointer = ompi_group_peer_lookup_existing (group, proc); group 271 ompi/group/group_init.c static void ompi_group_destruct(ompi_group_t *group) group 279 ompi/group/group_init.c if (OMPI_GROUP_IS_DENSE(group)) group 282 ompi/group/group_init.c ompi_group_decrement_proc_count (group); group 285 ompi/group/group_init.c if (NULL != group->grp_proc_pointers) { group 286 ompi/group/group_init.c free(group->grp_proc_pointers); group 289 ompi/group/group_init.c if (OMPI_GROUP_IS_SPORADIC(group)) { group 290 ompi/group/group_init.c if (NULL != group->sparse_data.grp_sporadic.grp_sporadic_list) { group 291 ompi/group/group_init.c free(group->sparse_data.grp_sporadic.grp_sporadic_list); group 295 ompi/group/group_init.c if (OMPI_GROUP_IS_BITMAP(group)) { group 296 ompi/group/group_init.c if (NULL != group->sparse_data.grp_bitmap.grp_bitmap_array) { group 297 ompi/group/group_init.c free(group->sparse_data.grp_bitmap.grp_bitmap_array); group 301 ompi/group/group_init.c if (NULL != group->grp_parent_group_ptr){ group 302 ompi/group/group_init.c OBJ_RELEASE(group->grp_parent_group_ptr); group 308 ompi/group/group_init.c group->grp_f_to_c_index)) { group 310 ompi/group/group_init.c group->grp_f_to_c_index, NULL); group 329 ompi/group/group_init.c ompi_mpi_group_null.group.grp_proc_count = 0; group 330 ompi/group/group_init.c ompi_mpi_group_null.group.grp_my_rank = MPI_PROC_NULL; group 331 ompi/group/group_init.c ompi_mpi_group_null.group.grp_proc_pointers = NULL; group 332 ompi/group/group_init.c ompi_mpi_group_null.group.grp_flags |= OMPI_GROUP_DENSE; group 333 ompi/group/group_init.c ompi_mpi_group_null.group.grp_flags |= OMPI_GROUP_INTRINSIC; group 337 ompi/group/group_init.c ompi_mpi_group_empty.group.grp_proc_count = 0; group 338 ompi/group/group_init.c ompi_mpi_group_empty.group.grp_my_rank = MPI_UNDEFINED; group 339 ompi/group/group_init.c ompi_mpi_group_empty.group.grp_proc_pointers = NULL; group 340 ompi/group/group_init.c ompi_mpi_group_empty.group.grp_flags |= OMPI_GROUP_DENSE; group 341 ompi/group/group_init.c ompi_mpi_group_empty.group.grp_flags |= OMPI_GROUP_INTRINSIC; group 352 ompi/group/group_init.c ompi_mpi_group_null.group.grp_flags = 0; group 355 ompi/group/group_init.c ompi_mpi_group_null.group.grp_flags = 0; group 64 ompi/group/group_plist.c static struct ompi_proc_t *ompi_group_dense_lookup_raw (ompi_group_t *group, const int peer_id) group 66 ompi/group/group_plist.c if (OPAL_UNLIKELY(ompi_proc_is_sentinel (group->grp_proc_pointers[peer_id]))) { group 68 ompi/group/group_plist.c (ompi_proc_t *) ompi_proc_lookup (ompi_proc_sentinel_to_name ((uintptr_t) group->grp_proc_pointers[peer_id])); group 71 ompi/group/group_plist.c group->grp_proc_pointers[peer_id] = proc; group 73 ompi/group/group_plist.c OBJ_RETAIN(group->grp_proc_pointers[peer_id]); group 77 ompi/group/group_plist.c return group->grp_proc_pointers[peer_id]; group 80 ompi/group/group_plist.c ompi_proc_t *ompi_group_get_proc_ptr_raw (ompi_group_t *group, int rank) group 84 ompi/group/group_plist.c if (OMPI_GROUP_IS_DENSE(group)) { group 85 ompi/group/group_plist.c return ompi_group_dense_lookup_raw (group, rank); group 88 ompi/group/group_plist.c ompi_group_translate_ranks (group, 1, &ranks1, group->grp_parent_group_ptr, &rank); group 89 ompi/group/group_plist.c group = group->grp_parent_group_ptr; group 92 ompi/group/group_plist.c return ompi_group_dense_lookup_raw (group, rank); group 100 ompi/group/group_plist.c int ompi_group_incl_plist(ompi_group_t* group, int n, const int *ranks, group 107 ompi/group/group_plist.c group_pointer = (ompi_group_t *)group; group 30 ompi/group/group_set_rank.c void ompi_set_group_rank(ompi_group_t *group, struct ompi_proc_t *proc_pointer) group 38 ompi/group/group_set_rank.c group->grp_my_rank = MPI_UNDEFINED; group 41 ompi/group/group_set_rank.c for (proc = 0; proc < group->grp_proc_count; proc++) { group 44 ompi/group/group_set_rank.c if (ompi_group_peer_lookup_existing (group, proc) == proc_pointer) { group 45 ompi/group/group_set_rank.c group->grp_my_rank = proc; group 117 ompi/group/group_sporadic.c int ompi_group_incl_spor(ompi_group_t* group, int n, const int *ranks, group 124 ompi/group/group_sporadic.c group_pointer = (ompi_group_t *)group; group 104 ompi/group/group_strided.c int ompi_group_incl_strided(ompi_group_t* group, int n, const int *ranks, group 111 ompi/group/group_strided.c group_pointer = (ompi_group_t *)group; group 87 ompi/mca/coll/hcoll/coll_hcoll_rte.c static int group_size ( rte_grp_handle_t group ); group 89 ompi/mca/coll/hcoll/coll_hcoll_rte.c static int ec_on_local_node (rte_ec_handle_t ec, rte_grp_handle_t group); group 101 ompi/mca/coll/hcoll/coll_hcoll_rte.c static int group_id(rte_grp_handle_t group); group 319 ompi/mca/coll/hcoll/coll_hcoll_rte.c static int ec_on_local_node (rte_ec_handle_t ec, rte_grp_handle_t group){ group 334 ompi/mca/coll/hcoll/coll_hcoll_rte.c static int group_id(rte_grp_handle_t group){ group 335 ompi/mca/coll/hcoll/coll_hcoll_rte.c return ((ompi_communicator_t *)group)->c_contextid; group 70 ompi/mca/common/monitoring/common_monitoring.h static inline int mca_common_monitoring_get_world_rank(int dest, ompi_group_t *group, group 76 ompi/mca/common/monitoring/common_monitoring.h ompi_proc_t *proc = ompi_group_get_proc_ptr(group, dest, true); group 208 ompi/mca/fs/pvfs2/fs_pvfs2_file_open.c attribs.group = getegid(); group 93 ompi/mca/io/romio321/romio/adio/ad_pvfs2/ad_pvfs2_common.c attribs->group = getegid(); group 94 ompi/mca/io/romio321/romio/mpi-io/fortran/get_groupf.c void mpi_file_get_group_(MPI_Fint *fh, MPI_Fint *group, MPI_Fint *ierr ); group 96 ompi/mca/io/romio321/romio/mpi-io/fortran/get_groupf.c void mpi_file_get_group_(MPI_Fint *fh, MPI_Fint *group, MPI_Fint *ierr ) group 103 ompi/mca/io/romio321/romio/mpi-io/fortran/get_groupf.c *group = MPI_Group_c2f(group_c); group 107 ompi/mca/io/romio321/romio/mpi-io/fortran/get_groupf.c FORTRAN_API void FORT_CALL mpi_file_get_group_(MPI_Fint *fh,MPI_Group *group, MPI_Fint *ierr ); group 109 ompi/mca/io/romio321/romio/mpi-io/fortran/get_groupf.c FORTRAN_API void FORT_CALL mpi_file_get_group_(MPI_Fint *fh,MPI_Group *group, MPI_Fint *ierr ) group 114 ompi/mca/io/romio321/romio/mpi-io/fortran/get_groupf.c *ierr = MPI_File_get_group(fh_c, group); group 20 ompi/mca/io/romio321/romio/mpi-io/get_group.c int MPI_File_get_group(MPI_File fh, MPI_Group *group) __attribute__((weak,alias("PMPI_File_get_group"))); group 40 ompi/mca/io/romio321/romio/mpi-io/get_group.c int MPI_File_get_group(MPI_File fh, MPI_Group *group) group 59 ompi/mca/io/romio321/romio/mpi-io/get_group.c error_code = MPI_Comm_group(adio_fh->comm, group); group 348 ompi/mca/mtl/portals4/mtl_portals4.c ompi_mtl_portals4_get_proc_group(struct ompi_group_t *group, int rank) group 352 ompi/mca/mtl/portals4/mtl_portals4.c ompi_proc_t *proc = ompi_group_peer_lookup (group, rank); group 234 ompi/mca/mtl/portals4/mtl_portals4.h ompi_mtl_portals4_get_proc_group(struct ompi_group_t *group, int rank); group 237 ompi/mca/mtl/portals4/mtl_portals4.h ompi_mtl_portals4_get_peer_group(struct ompi_group_t *group, int rank) group 239 ompi/mca/mtl/portals4/mtl_portals4.h return *((ptl_process_t*)(ompi_mtl_portals4_get_proc_group(group, rank)->proc_endpoints[OMPI_PROC_ENDPOINT_TAG_PORTALS4])); group 18 ompi/mca/osc/monitoring/osc_monitoring_active_target.h static int ompi_osc_monitoring_## template ##_post (ompi_group_t *group, int assert, ompi_win_t *win) \ group 20 ompi/mca/osc/monitoring/osc_monitoring_active_target.h return OMPI_OSC_MONITORING_MODULE_VARIABLE(template).osc_post(group, assert, win); \ group 23 ompi/mca/osc/monitoring/osc_monitoring_active_target.h static int ompi_osc_monitoring_## template ##_start (ompi_group_t *group, int assert, ompi_win_t *win) \ group 25 ompi/mca/osc/monitoring/osc_monitoring_active_target.h return OMPI_OSC_MONITORING_MODULE_VARIABLE(template).osc_start(group, assert, win); \ group 315 ompi/mca/osc/osc.h typedef int (*ompi_osc_base_module_start_fn_t)(struct ompi_group_t *group, group 323 ompi/mca/osc/osc.h typedef int (*ompi_osc_base_module_post_fn_t)(struct ompi_group_t *group, group 247 ompi/mca/osc/portals4/osc_portals4.h int ompi_osc_portals4_start(struct ompi_group_t *group, group 253 ompi/mca/osc/portals4/osc_portals4.h int ompi_osc_portals4_post(struct ompi_group_t *group, group 308 ompi/mca/osc/portals4/osc_portals4.h ompi_osc_portals4_get_peer_group(struct ompi_group_t *group, int rank) group 310 ompi/mca/osc/portals4/osc_portals4.h return ompi_mtl_portals4_get_peer_group(group, rank); group 44 ompi/mca/osc/portals4/osc_portals4_active_target.c ompi_osc_portals4_start(struct ompi_group_t *group, group 59 ompi/mca/osc/portals4/osc_portals4_active_target.c OBJ_RETAIN(group); group 60 ompi/mca/osc/portals4/osc_portals4_active_target.c module->start_group = group; group 117 ompi/mca/osc/portals4/osc_portals4_active_target.c ompi_osc_portals4_post(struct ompi_group_t *group, group 126 ompi/mca/osc/portals4/osc_portals4_active_target.c OBJ_RETAIN(group); group 127 ompi/mca/osc/portals4/osc_portals4_active_target.c module->post_group = group; group 434 ompi/mca/osc/pt2pt/osc_pt2pt.h int ompi_osc_pt2pt_start(struct ompi_group_t *group, group 439 ompi/mca/osc/pt2pt/osc_pt2pt.h int ompi_osc_pt2pt_post(struct ompi_group_t *group, group 210 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c int ompi_osc_pt2pt_start (ompi_group_t *group, int assert, ompi_win_t *win) group 224 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c sync->num_peers = ompi_group_size (group); group 225 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c sync->sync.pscw.group = group; group 247 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c OBJ_RETAIN(group); group 249 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c if (0 == ompi_group_size (group)) { group 259 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c sync->peer_list.peers = ompi_osc_pt2pt_get_peers (module, group); group 308 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c ompi_group_t *group; group 324 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c group = sync->sync.pscw.group; group 414 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c OBJ_RELEASE(group); group 423 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c int ompi_osc_pt2pt_post (ompi_group_t *group, int assert, ompi_win_t *win) group 437 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c ompi_group_size (group))); group 448 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c OBJ_RETAIN(group); group 450 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c module->pw_group = group; group 459 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c if ((assert & MPI_MODE_NOCHECK) || 0 == ompi_group_size (group)) { group 509 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c ompi_group_t *group; group 526 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c group = module->pw_group; group 530 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c OBJ_RELEASE(group); group 542 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c ompi_group_t *group; group 560 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c group = module->pw_group; group 563 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c OBJ_RELEASE(group); group 61 ompi/mca/osc/pt2pt/osc_pt2pt_sync.h ompi_group_t *group; group 186 ompi/mca/osc/pt2pt/osc_pt2pt_sync.h sync->sync.pscw.group = NULL; group 300 ompi/mca/osc/rdma/osc_rdma_active_target.c int ompi_osc_rdma_post_atomic (ompi_group_t *group, int assert, ompi_win_t *win) group 307 ompi/mca/osc/rdma/osc_rdma_active_target.c OSC_RDMA_VERBOSE(MCA_BASE_VERBOSE_TRACE, "post: %p, %d, %s", (void*) group, assert, win->w_name); group 315 ompi/mca/osc/rdma/osc_rdma_active_target.c OBJ_RETAIN(group); group 324 ompi/mca/osc/rdma/osc_rdma_active_target.c module->pw_group = group; group 332 ompi/mca/osc/rdma/osc_rdma_active_target.c if ((assert & MPI_MODE_NOCHECK) || 0 == ompi_group_size (group)) { group 359 ompi/mca/osc/rdma/osc_rdma_active_target.c int ompi_osc_rdma_start_atomic (ompi_group_t *group, int assert, ompi_win_t *win) group 365 ompi/mca/osc/rdma/osc_rdma_active_target.c int group_size = ompi_group_size (group); group 367 ompi/mca/osc/rdma/osc_rdma_active_target.c OSC_RDMA_VERBOSE(MCA_BASE_VERBOSE_TRACE, "start: %p, %d, %s", (void*) group, assert, group 379 ompi/mca/osc/rdma/osc_rdma_active_target.c sync->num_peers = ompi_group_size (group); group 380 ompi/mca/osc/rdma/osc_rdma_active_target.c sync->sync.pscw.group = group; group 387 ompi/mca/osc/rdma/osc_rdma_active_target.c if (0 == ompi_group_size (group)) { group 402 ompi/mca/osc/rdma/osc_rdma_active_target.c sync->peer_list.peers = ompi_osc_rdma_get_peers (module, group); group 409 ompi/mca/osc/rdma/osc_rdma_active_target.c OBJ_RETAIN(group); group 450 ompi/mca/osc/rdma/osc_rdma_active_target.c ompi_group_t *group; group 463 ompi/mca/osc/rdma/osc_rdma_active_target.c group = sync->sync.pscw.group; group 469 ompi/mca/osc/rdma/osc_rdma_active_target.c OBJ_RELEASE(group); group 475 ompi/mca/osc/rdma/osc_rdma_active_target.c OBJ_RELEASE(group); group 510 ompi/mca/osc/rdma/osc_rdma_active_target.c ompi_group_t *group; group 534 ompi/mca/osc/rdma/osc_rdma_active_target.c group = module->pw_group; group 538 ompi/mca/osc/rdma/osc_rdma_active_target.c OBJ_RELEASE(group); group 550 ompi/mca/osc/rdma/osc_rdma_active_target.c ompi_group_t *group; group 578 ompi/mca/osc/rdma/osc_rdma_active_target.c group = module->pw_group; group 582 ompi/mca/osc/rdma/osc_rdma_active_target.c OBJ_RELEASE(group); group 31 ompi/mca/osc/rdma/osc_rdma_active_target.h int ompi_osc_rdma_start_atomic (struct ompi_group_t *group, group 35 ompi/mca/osc/rdma/osc_rdma_active_target.h int ompi_osc_rdma_post_atomic (struct ompi_group_t *group, group 76 ompi/mca/osc/rdma/osc_rdma_sync.h ompi_group_t *group; group 220 ompi/mca/osc/sm/osc_sm.h int ompi_osc_sm_start(struct ompi_group_t *group, group 226 ompi/mca/osc/sm/osc_sm.h int ompi_osc_sm_post(struct ompi_group_t *group, group 63 ompi/mca/osc/sm/osc_sm_active_target.c static int *ompi_osc_sm_group_ranks (ompi_group_t *group, ompi_group_t *sub_group) group 81 ompi/mca/osc/sm/osc_sm_active_target.c ret = ompi_group_translate_ranks (sub_group, size, ranks1, group, ranks2); group 126 ompi/mca/osc/sm/osc_sm_active_target.c ompi_osc_sm_start(struct ompi_group_t *group, group 135 ompi/mca/osc/sm/osc_sm_active_target.c OBJ_RETAIN(group); group 137 ompi/mca/osc/sm/osc_sm_active_target.c if (!OPAL_ATOMIC_COMPARE_EXCHANGE_STRONG_PTR(&module->start_group, (void *) &_tmp_ptr, group)) { group 138 ompi/mca/osc/sm/osc_sm_active_target.c OBJ_RELEASE(group); group 145 ompi/mca/osc/sm/osc_sm_active_target.c int *ranks = ompi_osc_sm_group_ranks (module->comm->c_local_group, group); group 184 ompi/mca/osc/sm/osc_sm_active_target.c ompi_group_t *group; group 190 ompi/mca/osc/sm/osc_sm_active_target.c group = module->start_group; group 191 ompi/mca/osc/sm/osc_sm_active_target.c if (NULL == group || !OPAL_ATOMIC_COMPARE_EXCHANGE_STRONG_PTR((opal_atomic_intptr_t *) &module->start_group, (opal_atomic_intptr_t *) &group, 0)) { group 197 ompi/mca/osc/sm/osc_sm_active_target.c int *ranks = ompi_osc_sm_group_ranks (module->comm->c_local_group, group); group 202 ompi/mca/osc/sm/osc_sm_active_target.c gsize = ompi_group_size(group); group 209 ompi/mca/osc/sm/osc_sm_active_target.c OBJ_RELEASE(group); group 217 ompi/mca/osc/sm/osc_sm_active_target.c ompi_osc_sm_post(struct ompi_group_t *group, group 235 ompi/mca/osc/sm/osc_sm_active_target.c module->post_group = group; group 237 ompi/mca/osc/sm/osc_sm_active_target.c OBJ_RETAIN(group); group 240 ompi/mca/osc/sm/osc_sm_active_target.c int *ranks = ompi_osc_sm_group_ranks (module->comm->c_local_group, group); group 275 ompi/mca/osc/sm/osc_sm_active_target.c ompi_group_t *group; group 284 ompi/mca/osc/sm/osc_sm_active_target.c group = module->post_group; group 286 ompi/mca/osc/sm/osc_sm_active_target.c int size = ompi_group_size (group); group 293 ompi/mca/osc/sm/osc_sm_active_target.c OBJ_RELEASE(group); group 193 ompi/mca/osc/ucx/osc_ucx.h int ompi_osc_ucx_start(struct ompi_group_t *group, int assert, struct ompi_win_t *win); group 195 ompi/mca/osc/ucx/osc_ucx.h int ompi_osc_ucx_post(struct ompi_group_t *group, int assert, struct ompi_win_t *win); group 87 ompi/mca/osc/ucx/osc_ucx_active_target.c int ompi_osc_ucx_start(struct ompi_group_t *group, int assert, struct ompi_win_t *win) { group 100 ompi/mca/osc/ucx/osc_ucx_active_target.c OBJ_RETAIN(group); group 101 ompi/mca/osc/ucx/osc_ucx_active_target.c module->start_group = group; group 201 ompi/mca/osc/ucx/osc_ucx_active_target.c int ompi_osc_ucx_post(struct ompi_group_t *group, int assert, struct ompi_win_t *win) { group 209 ompi/mca/osc/ucx/osc_ucx_active_target.c OBJ_RETAIN(group); group 210 ompi/mca/osc/ucx/osc_ucx_active_target.c module->post_group = group; group 85 ompi/mca/sharedfp/sm/sharedfp_sm.c ompi_group_t *group = comm->c_local_group; group 88 ompi/mca/sharedfp/sm/sharedfp_sm.c proc = ompi_group_peer_lookup(group,i); group 64 ompi/mca/topo/treematch/treematch/tm_tree.c void group(tm_affinity_mat_t *, tm_tree_t *, tm_tree_t *, int, int, int, double *, tm_tree_t **); group 866 ompi/mca/topo/treematch/treematch/tm_tree.c static group_list_t * group_dup(group_list_t *group, int nb_groups){ group 870 ompi/mca/topo/treematch/treematch/tm_tree.c size_t bound_size = nb_groups-group->id+2; group 876 ompi/mca/topo/treematch/treematch/tm_tree.c memcpy(bound, group->bound, bound_size*sizeof(double)); group 880 ompi/mca/topo/treematch/treematch/tm_tree.c elem-> tab = group->tab; group 881 ompi/mca/topo/treematch/treematch/tm_tree.c elem-> val = group->val; group 882 ompi/mca/topo/treematch/treematch/tm_tree.c elem-> sum_neighbour = group->sum_neighbour; group 883 ompi/mca/topo/treematch/treematch/tm_tree.c elem-> wg = group ->wg; group 884 ompi/mca/topo/treematch/treematch/tm_tree.c elem-> id = group->id; group 40 ompi/mpi/c/comm_create.c int MPI_Comm_create(MPI_Comm comm, MPI_Group group, MPI_Comm *newcomm) { group 55 ompi/mpi/c/comm_create.c if ( MPI_GROUP_NULL == group || NULL == group ) group 66 ompi/mpi/c/comm_create.c rc = ompi_comm_create ( (ompi_communicator_t*)comm, (ompi_group_t*)group, group 44 ompi/mpi/c/comm_create_group.c int MPI_Comm_create_group (MPI_Comm comm, MPI_Group group, int tag, MPI_Comm *newcomm) { group 62 ompi/mpi/c/comm_create_group.c if ( NULL == group ) group 71 ompi/mpi/c/comm_create_group.c if (MPI_GROUP_NULL == group || MPI_UNDEFINED == ompi_group_rank (group)) { group 78 ompi/mpi/c/comm_create_group.c rc = ompi_comm_create_group ((ompi_communicator_t *) comm, (ompi_group_t *) group, group 40 ompi/mpi/c/comm_group.c int MPI_Comm_group(MPI_Comm comm, MPI_Group *group) { group 56 ompi/mpi/c/comm_group.c if ( NULL == group ) group 63 ompi/mpi/c/comm_group.c rc = ompi_comm_group ( (ompi_communicator_t*)comm, (ompi_group_t**)group ); group 42 ompi/mpi/c/comm_remote_group.c int MPI_Comm_remote_group(MPI_Comm comm, MPI_Group *group) group 57 ompi/mpi/c/comm_remote_group.c if ( NULL == group ) { group 71 ompi/mpi/c/comm_remote_group.c *group = (MPI_Group) comm->c_remote_group; group 39 ompi/mpi/c/file_get_group.c int MPI_File_get_group(MPI_File fh, MPI_Group *group) group 49 ompi/mpi/c/file_get_group.c } else if (NULL == group) { group 59 ompi/mpi/c/file_get_group.c rc = ompi_comm_group (fh->f_comm, group); group 40 ompi/mpi/c/group_c2f.c MPI_Fint MPI_Group_c2f(MPI_Group group) group 47 ompi/mpi/c/group_c2f.c if( (NULL == group) ) { group 52 ompi/mpi/c/group_c2f.c return OMPI_INT_2_FINT(group->grp_f_to_c_index) ; group 43 ompi/mpi/c/group_excl.c int MPI_Group_excl(MPI_Group group, int n, const int ranks[], group 46 ompi/mpi/c/group_excl.c ompi_group_t *group_pointer = (ompi_group_t *)group; group 54 ompi/mpi/c/group_excl.c if ( (MPI_GROUP_NULL == group) || (NULL == group) || group 87 ompi/mpi/c/group_excl.c err = ompi_group_excl ( group, n, ranks, new_group ); group 40 ompi/mpi/c/group_free.c int MPI_Group_free(MPI_Group *group) group 61 ompi/mpi/c/group_free.c if ((NULL == group) || group 62 ompi/mpi/c/group_free.c (MPI_GROUP_NULL == *group) || (NULL == *group) ) { group 71 ompi/mpi/c/group_free.c ret = ompi_group_free ( group); group 44 ompi/mpi/c/group_incl.c int MPI_Group_incl(MPI_Group group, int n, const int ranks[], MPI_Group *new_group) group 49 ompi/mpi/c/group_incl.c group_pointer = (ompi_group_t *)group; group 56 ompi/mpi/c/group_incl.c if ( (MPI_GROUP_NULL == group) || ( NULL == group) || group 87 ompi/mpi/c/group_incl.c err = ompi_group_incl(group,n,ranks,new_group); group 41 ompi/mpi/c/group_range_excl.c int MPI_Group_range_excl(MPI_Group group, int n_triplets, int ranges[][3], group 50 ompi/mpi/c/group_range_excl.c if ( (MPI_GROUP_NULL == group) || (NULL == group) || group 56 ompi/mpi/c/group_range_excl.c group_size = ompi_group_size ( group ); group 116 ompi/mpi/c/group_range_excl.c err = ompi_group_range_excl(group,n_triplets,ranges,new_group); group 41 ompi/mpi/c/group_range_incl.c int MPI_Group_range_incl(MPI_Group group, int n_triplets, int ranges[][3], group 52 ompi/mpi/c/group_range_incl.c if ( (MPI_GROUP_NULL == group) || (NULL == group) || group 58 ompi/mpi/c/group_range_incl.c group_size = ompi_group_size ( group); group 117 ompi/mpi/c/group_range_incl.c err = ompi_group_range_incl ( group, n_triplets, ranges, new_group ); group 40 ompi/mpi/c/group_rank.c int MPI_Group_rank(MPI_Group group, int *rank) group 48 ompi/mpi/c/group_rank.c if( (MPI_GROUP_NULL == group) || ( NULL == group) ){ group 57 ompi/mpi/c/group_rank.c *rank=ompi_group_rank((ompi_group_t *)group); group 40 ompi/mpi/c/group_size.c int MPI_Group_size(MPI_Group group, int *size) group 49 ompi/mpi/c/group_size.c if( (MPI_GROUP_NULL == group) || (NULL == group) ) { group 58 ompi/mpi/c/group_size.c *size=ompi_group_size((ompi_group_t *)group); group 39 ompi/mpi/c/win_get_group.c int MPI_Win_get_group(MPI_Win win, MPI_Group *group) group 48 ompi/mpi/c/win_get_group.c } else if (NULL == group) { group 55 ompi/mpi/c/win_get_group.c ret = ompi_win_group(win, (ompi_group_t**) group); group 40 ompi/mpi/c/win_post.c int MPI_Win_post(MPI_Group group, int assert, MPI_Win win) group 57 ompi/mpi/c/win_post.c rc = win->w_osc_module->osc_post(group, assert, win); group 40 ompi/mpi/c/win_start.c int MPI_Win_start(MPI_Group group, int assert, MPI_Win win) group 56 ompi/mpi/c/win_start.c rc = win->w_osc_module->osc_start(group, assert, win); group 258 ompi/mpi/cxx/comm_inln.h MPI_Group group; group 259 ompi/mpi/cxx/comm_inln.h (void)MPI_Comm_group(mpi_comm, &group); group 260 ompi/mpi/cxx/comm_inln.h return group; group 58 ompi/mpi/cxx/file_inln.h MPI_Group group; group 59 ompi/mpi/cxx/file_inln.h (void) MPI_File_get_group(mpi_file, &group); group 60 ompi/mpi/cxx/file_inln.h return group; group 83 ompi/mpi/cxx/intercomm.h virtual Intercomm Create(const Group& group) const; group 49 ompi/mpi/cxx/intercomm_inln.h MPI_Group group; group 50 ompi/mpi/cxx/intercomm_inln.h (void)MPI_Comm_remote_group(mpi_comm, &group); group 51 ompi/mpi/cxx/intercomm_inln.h return group; group 68 ompi/mpi/cxx/intercomm_inln.h MPI::Intercomm::Create(const Group& group) const group 71 ompi/mpi/cxx/intercomm_inln.h (void) MPI_Comm_create(mpi_comm, (MPI_Group) group, &newcomm); group 104 ompi/mpi/cxx/intracomm.h Create(const Group& group) const; group 71 ompi/mpi/cxx/intracomm_inln.h MPI::Intracomm::Create(const MPI::Group& group) const group 74 ompi/mpi/cxx/intracomm_inln.h (void)MPI_Comm_create(mpi_comm, group, &newcomm); group 129 ompi/mpi/cxx/win.h virtual void Post(const MPI::Group& group, int assert) const; group 136 ompi/mpi/cxx/win.h virtual void Start(const MPI::Group& group, int assert) const; group 120 ompi/mpi/cxx/win_inln.h MPI::Win::Post(const MPI::Group& group, int assert) const group 122 ompi/mpi/cxx/win_inln.h (void) MPI_Win_post(group, assert, mpi_win); group 141 ompi/mpi/cxx/win_inln.h MPI::Win::Start(const MPI::Group& group, int assert) const group 143 ompi/mpi/cxx/win_inln.h (void) MPI_Win_start(group, assert, mpi_win); group 41 ompi/mpi/fortran/mpif-h/comm_create_f.c (MPI_Fint *comm, MPI_Fint *group, MPI_Fint *newcomm, MPI_Fint *ierr), group 42 ompi/mpi/fortran/mpif-h/comm_create_f.c (comm, group, newcomm, ierr) ) group 61 ompi/mpi/fortran/mpif-h/comm_create_f.c (MPI_Fint *comm, MPI_Fint *group, MPI_Fint *newcomm, MPI_Fint *ierr), group 62 ompi/mpi/fortran/mpif-h/comm_create_f.c (comm, group, newcomm, ierr) ) group 68 ompi/mpi/fortran/mpif-h/comm_create_f.c void ompi_comm_create_f(MPI_Fint *comm, MPI_Fint *group, MPI_Fint *newcomm, MPI_Fint *ierr) group 73 ompi/mpi/fortran/mpif-h/comm_create_f.c MPI_Group c_group = PMPI_Group_f2c(*group); group 44 ompi/mpi/fortran/mpif-h/comm_create_group_f.c (MPI_Fint *comm, MPI_Fint *group, MPI_Fint *tag, MPI_Fint *newcomm, MPI_Fint *ierr), group 45 ompi/mpi/fortran/mpif-h/comm_create_group_f.c (comm, group, tag, newcomm, ierr) ) group 64 ompi/mpi/fortran/mpif-h/comm_create_group_f.c (MPI_Fint *comm, MPI_Fint *group, MPI_Fint *tag, MPI_Fint *newcomm, MPI_Fint *ierr), group 65 ompi/mpi/fortran/mpif-h/comm_create_group_f.c (comm, group, tag, newcomm, ierr) ) group 71 ompi/mpi/fortran/mpif-h/comm_create_group_f.c void ompi_comm_create_group_f(MPI_Fint *comm, MPI_Fint *group, MPI_Fint *tag, MPI_Fint *newcomm, MPI_Fint *ierr) group 76 ompi/mpi/fortran/mpif-h/comm_create_group_f.c MPI_Group c_group = PMPI_Group_f2c(*group); group 41 ompi/mpi/fortran/mpif-h/comm_group_f.c (MPI_Fint *comm, MPI_Fint *group, MPI_Fint *ierr), group 42 ompi/mpi/fortran/mpif-h/comm_group_f.c (comm, group, ierr) ) group 61 ompi/mpi/fortran/mpif-h/comm_group_f.c (MPI_Fint *comm, MPI_Fint *group, MPI_Fint *ierr), group 62 ompi/mpi/fortran/mpif-h/comm_group_f.c (comm, group, ierr) ) group 69 ompi/mpi/fortran/mpif-h/comm_group_f.c void ompi_comm_group_f(MPI_Fint *comm, MPI_Fint *group, MPI_Fint *ierr) group 79 ompi/mpi/fortran/mpif-h/comm_group_f.c *group = PMPI_Group_c2f (c_group); group 41 ompi/mpi/fortran/mpif-h/comm_remote_group_f.c (MPI_Fint *comm, MPI_Fint *group, MPI_Fint *ierr), group 42 ompi/mpi/fortran/mpif-h/comm_remote_group_f.c (comm, group, ierr) ) group 61 ompi/mpi/fortran/mpif-h/comm_remote_group_f.c (MPI_Fint *comm, MPI_Fint *group, MPI_Fint *ierr), group 62 ompi/mpi/fortran/mpif-h/comm_remote_group_f.c (comm, group, ierr) ) group 68 ompi/mpi/fortran/mpif-h/comm_remote_group_f.c void ompi_comm_remote_group_f(MPI_Fint *comm, MPI_Fint *group, MPI_Fint *ierr) group 78 ompi/mpi/fortran/mpif-h/comm_remote_group_f.c *group = PMPI_Group_c2f (c_group); group 41 ompi/mpi/fortran/mpif-h/file_get_group_f.c (MPI_Fint *fh, MPI_Fint *group, MPI_Fint *ierr), group 42 ompi/mpi/fortran/mpif-h/file_get_group_f.c (fh, group, ierr) ) group 61 ompi/mpi/fortran/mpif-h/file_get_group_f.c (MPI_Fint *fh, MPI_Fint *group, MPI_Fint *ierr), group 62 ompi/mpi/fortran/mpif-h/file_get_group_f.c (fh, group, ierr) ) group 69 ompi/mpi/fortran/mpif-h/file_get_group_f.c void ompi_file_get_group_f(MPI_Fint *fh, MPI_Fint *group, MPI_Fint *ierr) group 79 ompi/mpi/fortran/mpif-h/file_get_group_f.c *group = PMPI_Group_c2f(c_grp); group 42 ompi/mpi/fortran/mpif-h/group_excl_f.c (MPI_Fint *group, MPI_Fint *n, MPI_Fint *ranks, MPI_Fint *newgroup, MPI_Fint *ierr), group 43 ompi/mpi/fortran/mpif-h/group_excl_f.c (group, n, ranks, newgroup, ierr) ) group 62 ompi/mpi/fortran/mpif-h/group_excl_f.c (MPI_Fint *group, MPI_Fint *n, MPI_Fint *ranks, MPI_Fint *newgroup, MPI_Fint *ierr), group 63 ompi/mpi/fortran/mpif-h/group_excl_f.c (group, n, ranks, newgroup, ierr) ) group 70 ompi/mpi/fortran/mpif-h/group_excl_f.c void ompi_group_excl_f(MPI_Fint *group, MPI_Fint *n, group 79 ompi/mpi/fortran/mpif-h/group_excl_f.c c_group = PMPI_Group_f2c(*group); group 42 ompi/mpi/fortran/mpif-h/group_free_f.c (MPI_Fint *group, MPI_Fint *ierr), group 43 ompi/mpi/fortran/mpif-h/group_free_f.c (group, ierr) ) group 62 ompi/mpi/fortran/mpif-h/group_free_f.c (MPI_Fint *group, MPI_Fint *ierr), group 63 ompi/mpi/fortran/mpif-h/group_free_f.c (group, ierr) ) group 70 ompi/mpi/fortran/mpif-h/group_free_f.c void ompi_group_free_f(MPI_Fint *group, MPI_Fint *ierr) group 77 ompi/mpi/fortran/mpif-h/group_free_f.c c_group = PMPI_Group_f2c(*group); group 85 ompi/mpi/fortran/mpif-h/group_free_f.c *group = 0; group 42 ompi/mpi/fortran/mpif-h/group_incl_f.c (MPI_Fint *group, MPI_Fint *n, MPI_Fint *ranks, MPI_Fint *newgroup, MPI_Fint *ierr), group 43 ompi/mpi/fortran/mpif-h/group_incl_f.c (group, n, ranks, newgroup, ierr) ) group 62 ompi/mpi/fortran/mpif-h/group_incl_f.c (MPI_Fint *group, MPI_Fint *n, MPI_Fint *ranks, MPI_Fint *newgroup, MPI_Fint *ierr), group 63 ompi/mpi/fortran/mpif-h/group_incl_f.c (group, n, ranks, newgroup, ierr) ) group 70 ompi/mpi/fortran/mpif-h/group_incl_f.c void ompi_group_incl_f(MPI_Fint *group, MPI_Fint *n, MPI_Fint *ranks, MPI_Fint *newgroup, MPI_Fint *ierr) group 78 ompi/mpi/fortran/mpif-h/group_incl_f.c c_group = PMPI_Group_f2c(*group); group 42 ompi/mpi/fortran/mpif-h/group_range_excl_f.c (MPI_Fint *group, MPI_Fint *n, MPI_Fint ranges[][3], MPI_Fint *newgroup, MPI_Fint *ierr), group 43 ompi/mpi/fortran/mpif-h/group_range_excl_f.c (group, n, ranges, newgroup, ierr) ) group 62 ompi/mpi/fortran/mpif-h/group_range_excl_f.c (MPI_Fint *group, MPI_Fint *n, MPI_Fint ranges[][3], MPI_Fint *newgroup, MPI_Fint *ierr), group 63 ompi/mpi/fortran/mpif-h/group_range_excl_f.c (group, n, ranges, newgroup, ierr) ) group 70 ompi/mpi/fortran/mpif-h/group_range_excl_f.c void ompi_group_range_excl_f(MPI_Fint *group, MPI_Fint *n, MPI_Fint ranges[][3], MPI_Fint *newgroup, MPI_Fint *ierr) group 77 ompi/mpi/fortran/mpif-h/group_range_excl_f.c c_group = PMPI_Group_f2c(*group); group 42 ompi/mpi/fortran/mpif-h/group_range_incl_f.c (MPI_Fint *group, MPI_Fint *n, MPI_Fint ranges[][3], MPI_Fint *newgroup, MPI_Fint *ierr), group 43 ompi/mpi/fortran/mpif-h/group_range_incl_f.c (group, n, ranges, newgroup, ierr) ) group 62 ompi/mpi/fortran/mpif-h/group_range_incl_f.c (MPI_Fint *group, MPI_Fint *n, MPI_Fint ranges[][3], MPI_Fint *newgroup, MPI_Fint *ierr), group 63 ompi/mpi/fortran/mpif-h/group_range_incl_f.c (group, n, ranges, newgroup, ierr) ) group 70 ompi/mpi/fortran/mpif-h/group_range_incl_f.c void ompi_group_range_incl_f(MPI_Fint *group, MPI_Fint *n, MPI_Fint ranges[][3], MPI_Fint *newgroup, MPI_Fint *ierr) group 77 ompi/mpi/fortran/mpif-h/group_range_incl_f.c c_group = PMPI_Group_f2c(*group); group 42 ompi/mpi/fortran/mpif-h/group_rank_f.c (MPI_Fint *group, MPI_Fint *rank, MPI_Fint *ierr), group 43 ompi/mpi/fortran/mpif-h/group_rank_f.c (group, rank, ierr) ) group 62 ompi/mpi/fortran/mpif-h/group_rank_f.c (MPI_Fint *group, MPI_Fint *rank, MPI_Fint *ierr), group 63 ompi/mpi/fortran/mpif-h/group_rank_f.c (group, rank, ierr) ) group 70 ompi/mpi/fortran/mpif-h/group_rank_f.c void ompi_group_rank_f(MPI_Fint *group, MPI_Fint *rank, MPI_Fint *ierr) group 77 ompi/mpi/fortran/mpif-h/group_rank_f.c c_group = PMPI_Group_f2c(*group); group 42 ompi/mpi/fortran/mpif-h/group_size_f.c (MPI_Fint *group, MPI_Fint *size, MPI_Fint *ierr), group 43 ompi/mpi/fortran/mpif-h/group_size_f.c (group, size, ierr) ) group 62 ompi/mpi/fortran/mpif-h/group_size_f.c (MPI_Fint *group, MPI_Fint *size, MPI_Fint *ierr), group 63 ompi/mpi/fortran/mpif-h/group_size_f.c (group, size, ierr) ) group 70 ompi/mpi/fortran/mpif-h/group_size_f.c void ompi_group_size_f(MPI_Fint *group, MPI_Fint *size, MPI_Fint *ierr) group 77 ompi/mpi/fortran/mpif-h/group_size_f.c c_group = PMPI_Group_f2c(*group); group 126 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Comm_create, mpi_comm_create, MPI_COMM_CREATE, (MPI_Fint *comm, MPI_Fint *group, MPI_Fint *newcomm, MPI_Fint *ierr)); group 127 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Comm_create_group, mpi_comm_create_group, MPI_COMM_CREATE_GROUP, (MPI_Fint *comm, MPI_Fint *group, MPI_Fint *tag, MPI_Fint *newcomm, MPI_Fint *ierr)); group 140 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Comm_group, mpi_comm_group, MPI_COMM_GROUP, (MPI_Fint *comm, MPI_Fint *group, MPI_Fint *ierr)); group 143 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Comm_remote_group, mpi_comm_remote_group, MPI_COMM_REMOTE_GROUP, (MPI_Fint *comm, MPI_Fint *group, MPI_Fint *ierr)); group 180 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_File_get_group, mpi_file_get_group, MPI_FILE_GET_GROUP, (MPI_Fint *fh, MPI_Fint *group, MPI_Fint *ierr)); group 253 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Group_excl, mpi_group_excl, MPI_GROUP_EXCL, (MPI_Fint *group, MPI_Fint *n, MPI_Fint *ranks, MPI_Fint *newgroup, MPI_Fint *ierr)); group 254 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Group_free, mpi_group_free, MPI_GROUP_FREE, (MPI_Fint *group, MPI_Fint *ierr)); group 255 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Group_incl, mpi_group_incl, MPI_GROUP_INCL, (MPI_Fint *group, MPI_Fint *n, MPI_Fint *ranks, MPI_Fint *newgroup, MPI_Fint *ierr)); group 257 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Group_range_excl, mpi_group_range_excl, MPI_GROUP_RANGE_EXCL, (MPI_Fint *group, MPI_Fint *n, MPI_Fint ranges[][3], MPI_Fint *newgroup, MPI_Fint *ierr)); group 258 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Group_range_incl, mpi_group_range_incl, MPI_GROUP_RANGE_INCL, (MPI_Fint *group, MPI_Fint *n, MPI_Fint ranges[][3], MPI_Fint *newgroup, MPI_Fint *ierr)); group 259 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Group_rank, mpi_group_rank, MPI_GROUP_RANK, (MPI_Fint *group, MPI_Fint *rank, MPI_Fint *ierr)); group 260 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Group_size, mpi_group_size, MPI_GROUP_SIZE, (MPI_Fint *group, MPI_Fint *size, MPI_Fint *ierr)); group 434 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Win_get_group, mpi_win_get_group, MPI_WIN_GET_GROUP, (MPI_Fint *win, MPI_Fint *group, MPI_Fint *ierr)); group 439 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Win_post, mpi_win_post, MPI_WIN_POST, (MPI_Fint *group, MPI_Fint *assert, MPI_Fint *win, MPI_Fint *ierr)); group 446 ompi/mpi/fortran/mpif-h/prototypes_mpi.h PN2(void, MPI_Win_start, mpi_win_start, MPI_WIN_START, (MPI_Fint *group, MPI_Fint *assert, MPI_Fint *win, MPI_Fint *ierr)); group 41 ompi/mpi/fortran/mpif-h/win_get_group_f.c (MPI_Fint *win, MPI_Fint *group, MPI_Fint *ierr), group 42 ompi/mpi/fortran/mpif-h/win_get_group_f.c (win, group, ierr) ) group 61 ompi/mpi/fortran/mpif-h/win_get_group_f.c (MPI_Fint *win, MPI_Fint *group, MPI_Fint *ierr), group 62 ompi/mpi/fortran/mpif-h/win_get_group_f.c (win, group, ierr) ) group 69 ompi/mpi/fortran/mpif-h/win_get_group_f.c void ompi_win_get_group_f(MPI_Fint *win, MPI_Fint *group, MPI_Fint *ierr) group 79 ompi/mpi/fortran/mpif-h/win_get_group_f.c *group = PMPI_Group_c2f(c_grp); group 41 ompi/mpi/fortran/mpif-h/win_post_f.c (MPI_Fint *group, MPI_Fint *assert, MPI_Fint *win, MPI_Fint *ierr), group 42 ompi/mpi/fortran/mpif-h/win_post_f.c (group, assert, win, ierr) ) group 61 ompi/mpi/fortran/mpif-h/win_post_f.c (MPI_Fint *group, MPI_Fint *assert, MPI_Fint *win, MPI_Fint *ierr), group 62 ompi/mpi/fortran/mpif-h/win_post_f.c (group, assert, win, ierr) ) group 69 ompi/mpi/fortran/mpif-h/win_post_f.c void ompi_win_post_f(MPI_Fint *group, MPI_Fint *assert, group 74 ompi/mpi/fortran/mpif-h/win_post_f.c MPI_Group c_grp = PMPI_Group_f2c(*group); group 41 ompi/mpi/fortran/mpif-h/win_start_f.c (MPI_Fint *group, MPI_Fint *assert, MPI_Fint *win, MPI_Fint *ierr), group 42 ompi/mpi/fortran/mpif-h/win_start_f.c (group, assert, win, ierr) ) group 61 ompi/mpi/fortran/mpif-h/win_start_f.c (MPI_Fint *group, MPI_Fint *assert, MPI_Fint *win, MPI_Fint *ierr), group 62 ompi/mpi/fortran/mpif-h/win_start_f.c (group, assert, win, ierr) ) group 69 ompi/mpi/fortran/mpif-h/win_start_f.c void ompi_win_start_f(MPI_Fint *group, MPI_Fint *assert, group 73 ompi/mpi/fortran/mpif-h/win_start_f.c MPI_Group c_grp = PMPI_Group_f2c(*group); group 1267 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_comm_create_f(comm,group,newcomm,ierror) & group 1271 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(IN) :: group group 1276 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_comm_create_group_f(comm, group, tag, newcomm, ierror) & group 1280 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h integer, intent(in) :: group group 1357 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_comm_group_f(comm,group,ierror) & group 1361 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(OUT) :: group group 1382 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_comm_remote_group_f(comm,group,ierror) & group 1386 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(OUT) :: group group 1461 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_group_excl_f(group,n,ranks,newgroup,ierror) & group 1464 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(IN) :: group group 1471 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_group_free_f(group,ierror) & group 1474 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(INOUT) :: group group 1478 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_group_incl_f(group,n,ranks,newgroup,ierror) & group 1483 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(IN) :: group group 1497 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_group_range_excl_f(group,n,ranges,newgroup,ierror) & group 1500 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(IN) :: group group 1507 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_group_range_incl_f(group,n,ranges,newgroup,ierror) & group 1510 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(IN) :: group group 1517 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_group_rank_f(group,rank,ierror) & group 1520 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(IN) :: group group 1525 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_group_size_f(group,size,ierror) & group 1528 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(IN) :: group group 2503 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_win_get_group_f(win,group,ierror) & group 2507 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(OUT) :: group group 2535 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_win_post_f(group,assert,win,ierror) & group 2538 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(IN) :: group group 2564 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_win_start_f(group,assert,win,ierror) & group 2567 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(IN) :: group group 2693 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h subroutine ompi_file_get_group_f(fh,group,ierror) & group 2697 ompi/mpi/fortran/use-mpi-f08/bindings/mpi-f-interfaces-bind.h INTEGER, INTENT(OUT) :: group group 114 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-file-interfaces.h subroutine MPI_File_get_group(fh, group, ierror) group 116 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-file-interfaces.h integer, intent(out) :: group group 271 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Comm_create(comm, group, newcomm, ierror) group 273 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(in) :: group group 283 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Comm_create_group(comm, group, tag, newcomm, ierror) group 285 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(in) :: group group 436 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Comm_group(comm, group, ierror) group 438 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(out) :: group group 458 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Comm_remote_group(comm, group, ierror) group 460 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(out) :: group group 820 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Group_excl(group, n, ranks, newgroup, ierror) group 821 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(in) :: group group 833 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Group_free(group, ierror) group 834 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(inout) :: group group 843 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Group_incl(group, n, ranks, newgroup, ierror) group 844 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(in) :: group group 868 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Group_range_excl(group, n, ranges, newgroup, ierror) group 869 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(in) :: group group 881 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Group_range_incl(group, n, ranges, newgroup, ierror) group 882 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(in) :: group group 894 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Group_rank(group, rank, ierror) group 895 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(in) :: group group 905 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Group_size(group, size, ierror) group 906 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(in) :: group group 1986 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Win_get_group(win, group, ierror) group 1988 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(out) :: group group 2022 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Win_post(group, assert, win, ierror) group 2023 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(in) :: group group 2069 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h subroutine MPI_Win_start(group, assert, win, ierror) group 2070 ompi/mpi/fortran/use-mpi-tkr/mpi-f90-interfaces.h integer, intent(in) :: group group 114 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-file-interfaces.h subroutine PMPI_File_get_group(fh, group, ierror) group 116 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-file-interfaces.h integer, intent(out) :: group group 271 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Comm_create(comm, group, newcomm, ierror) group 273 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(in) :: group group 283 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Comm_create_group(comm, group, tag, newcomm, ierror) group 285 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(in) :: group group 436 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Comm_group(comm, group, ierror) group 438 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(out) :: group group 458 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Comm_remote_group(comm, group, ierror) group 460 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(out) :: group group 820 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Group_excl(group, n, ranks, newgroup, ierror) group 821 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(in) :: group group 833 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Group_free(group, ierror) group 834 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(inout) :: group group 843 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Group_incl(group, n, ranks, newgroup, ierror) group 844 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(in) :: group group 868 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Group_range_excl(group, n, ranges, newgroup, ierror) group 869 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(in) :: group group 881 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Group_range_incl(group, n, ranges, newgroup, ierror) group 882 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(in) :: group group 894 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Group_rank(group, rank, ierror) group 895 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(in) :: group group 905 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Group_size(group, size, ierror) group 906 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(in) :: group group 1988 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Win_get_group(win, group, ierror) group 1990 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(out) :: group group 2024 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Win_post(group, assert, win, ierror) group 2025 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(in) :: group group 2071 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h subroutine PMPI_Win_start(group, assert, win, ierror) group 2072 ompi/mpi/fortran/use-mpi-tkr/pmpi-f90-interfaces.h integer, intent(in) :: group group 293 ompi/mpi/java/c/mpi_Comm.c MPI_Group group; group 294 ompi/mpi/java/c/mpi_Comm.c int rc = MPI_Comm_group((MPI_Comm)comm, &group); group 296 ompi/mpi/java/c/mpi_Comm.c return (jlong)group; group 93 ompi/mpi/java/c/mpi_File.c MPI_Group group; group 94 ompi/mpi/java/c/mpi_File.c int rc = MPI_File_get_group((MPI_File)fh, &group); group 96 ompi/mpi/java/c/mpi_File.c return (jlong)group; group 72 ompi/mpi/java/c/mpi_Group.c JNIEnv *env, jobject jthis, jlong group) group 75 ompi/mpi/java/c/mpi_Group.c rc = MPI_Group_size((MPI_Group)group, &size); group 81 ompi/mpi/java/c/mpi_Group.c JNIEnv *env, jobject jthis, jlong group) group 84 ompi/mpi/java/c/mpi_Group.c rc = MPI_Group_rank((MPI_Group)group, &rank); group 92 ompi/mpi/java/c/mpi_Group.c MPI_Group group = (MPI_Group)handle; group 93 ompi/mpi/java/c/mpi_Group.c int rc = MPI_Group_free(&group); group 95 ompi/mpi/java/c/mpi_Group.c return (jlong)group; group 160 ompi/mpi/java/c/mpi_Group.c JNIEnv *env, jobject jthis, jlong group, jintArray ranks) group 168 ompi/mpi/java/c/mpi_Group.c int rc = MPI_Group_incl((MPI_Group)group, n, cRanks, &newGroup); group 176 ompi/mpi/java/c/mpi_Group.c JNIEnv *env, jobject jthis, jlong group, jintArray ranks) group 184 ompi/mpi/java/c/mpi_Group.c int rc = MPI_Group_excl((MPI_Group)group, n, cRanks, &newGroup); group 192 ompi/mpi/java/c/mpi_Group.c JNIEnv *env, jobject jthis, jlong group, jobjectArray ranges) group 210 ompi/mpi/java/c/mpi_Group.c int rc = MPI_Group_range_incl((MPI_Group)group, n, cRanges, &newGroup); group 217 ompi/mpi/java/c/mpi_Group.c JNIEnv *env, jobject jthis, jlong group, jobjectArray ranges) group 235 ompi/mpi/java/c/mpi_Group.c int rc = MPI_Group_range_excl((MPI_Group)group, n, cRanges, &newGroup); group 84 ompi/mpi/java/c/mpi_Intercomm.c MPI_Group group; group 88 ompi/mpi/java/c/mpi_Intercomm.c &group); group 91 ompi/mpi/java/c/mpi_Intercomm.c return (jlong)group; group 81 ompi/mpi/java/c/mpi_Intracomm.c JNIEnv *env, jobject jthis, jlong comm, jlong group) group 84 ompi/mpi/java/c/mpi_Intracomm.c int rc = MPI_Comm_create((MPI_Comm)comm, (MPI_Group)group, &newcomm); group 90 ompi/mpi/java/c/mpi_Intracomm.c JNIEnv *env, jobject jthis, jlong comm, jlong group, int tag) group 93 ompi/mpi/java/c/mpi_Intracomm.c int rc = MPI_Comm_create_group((MPI_Comm)comm, (MPI_Group)group, tag, &newcomm); group 112 ompi/mpi/java/c/mpi_Win.c MPI_Group group; group 113 ompi/mpi/java/c/mpi_Win.c int rc = MPI_Win_get_group((MPI_Win)win, &group); group 115 ompi/mpi/java/c/mpi_Win.c return (jlong)group; group 170 ompi/mpi/java/c/mpi_Win.c JNIEnv *env, jobject jthis, jlong win, jlong group, jint assertion) group 172 ompi/mpi/java/c/mpi_Win.c int rc = MPI_Win_start((MPI_Group)group, assertion, (MPI_Win)win); group 184 ompi/mpi/java/c/mpi_Win.c JNIEnv *env, jobject jthis, jlong win, jlong group, jint assertion) group 186 ompi/mpi/java/c/mpi_Win.c int rc = MPI_Win_post((MPI_Group)group, assertion, (MPI_Win)win); group 83 ompi/mpi/java/java/Group.java private native int getSize(long group) throws MPIException; group 98 ompi/mpi/java/java/Group.java private native int getRank(long group) throws MPIException; group 109 ompi/mpi/java/java/Group.java private native long free(long group); group 219 ompi/mpi/java/java/Group.java private native long incl(long group, int[] ranks); group 234 ompi/mpi/java/java/Group.java private native long excl(long group, int[] ranks); group 254 ompi/mpi/java/java/Group.java private native long rangeIncl(long group, int[][] ranges); group 272 ompi/mpi/java/java/Group.java private native long rangeExcl(long group, int[][] ranges); group 183 ompi/mpi/java/java/Intracomm.java public final Intracomm create(Group group) throws MPIException group 186 ompi/mpi/java/java/Intracomm.java return new Intracomm(create(handle, group.handle)); group 189 ompi/mpi/java/java/Intracomm.java private native long create(long comm, long group); group 199 ompi/mpi/java/java/Intracomm.java public final Intracomm createGroup(Group group, int tag) throws MPIException group 202 ompi/mpi/java/java/Intracomm.java return new Intracomm(createGroup(handle, group.handle, tag)); group 205 ompi/mpi/java/java/Intracomm.java private native long createGroup(long comm, long group, int tag); group 327 ompi/mpi/java/java/Win.java public void start(Group group, int assertion) throws MPIException group 330 ompi/mpi/java/java/Win.java start(handle, group.handle, assertion); group 333 ompi/mpi/java/java/Win.java private native void start(long win, long group, int assertion) group 354 ompi/mpi/java/java/Win.java public void post(Group group, int assertion) throws MPIException group 357 ompi/mpi/java/java/Win.java post(handle, group.handle, assertion); group 360 ompi/mpi/java/java/Win.java private native void post(long win, long group, int assertion) group 27 ompi/mpi/tool/category_get_categories.c const mca_base_var_group_t *group; group 39 ompi/mpi/tool/category_get_categories.c rc = mca_base_var_group_get (cat_index, &group); group 45 ompi/mpi/tool/category_get_categories.c size = opal_value_array_get_size((opal_value_array_t *) &group->group_subgroups); group 46 ompi/mpi/tool/category_get_categories.c subgroups = OPAL_VALUE_ARRAY_GET_BASE(&group->group_subgroups, int); group 27 ompi/mpi/tool/category_get_cvars.c const mca_base_var_group_t *group; group 39 ompi/mpi/tool/category_get_cvars.c rc = mca_base_var_group_get (cat_index, &group); group 45 ompi/mpi/tool/category_get_cvars.c size = opal_value_array_get_size((opal_value_array_t *) &group->group_vars); group 46 ompi/mpi/tool/category_get_cvars.c vars = OPAL_VALUE_ARRAY_GET_BASE(&group->group_vars, int); group 29 ompi/mpi/tool/category_get_info.c const mca_base_var_group_t *group; group 39 ompi/mpi/tool/category_get_info.c rc = mca_base_var_group_get (cat_index, &group); group 46 ompi/mpi/tool/category_get_info.c *num_pvars = opal_value_array_get_size ((opal_value_array_t *) &group->group_pvars); group 50 ompi/mpi/tool/category_get_info.c *num_cvars = opal_value_array_get_size ((opal_value_array_t *) &group->group_vars); group 54 ompi/mpi/tool/category_get_info.c *num_categories = opal_value_array_get_size ((opal_value_array_t *) &group->group_subgroups); group 57 ompi/mpi/tool/category_get_info.c mpit_copy_string (name, name_len, group->group_full_name); group 58 ompi/mpi/tool/category_get_info.c mpit_copy_string (desc, desc_len, group->group_description); group 27 ompi/mpi/tool/category_get_pvars.c const mca_base_var_group_t *group; group 39 ompi/mpi/tool/category_get_pvars.c rc = mca_base_var_group_get (cat_index, &group); group 45 ompi/mpi/tool/category_get_pvars.c size = opal_value_array_get_size((opal_value_array_t *) &group->group_pvars); group 46 ompi/mpi/tool/category_get_pvars.c vars = OPAL_VALUE_ARRAY_GET_BASE(&group->group_pvars, int); group 94 ompi/win/win.c ompi_mpi_win_null.win.w_group = &ompi_mpi_group_null.group; group 146 ompi/win/win.c ompi_group_t *group; group 179 ompi/win/win.c group = comm->c_local_group; group 180 ompi/win/win.c OBJ_RETAIN(group); group 181 ompi/win/win.c win->w_group = group; group 407 ompi/win/win.c ompi_win_group(ompi_win_t *win, ompi_group_t **group) { group 409 ompi/win/win.c *group = win->w_group; group 150 ompi/win/win.h OMPI_DECLSPEC int ompi_win_group(ompi_win_t *win, ompi_group_t **group); group 817 opal/mca/base/mca_base_pvar.c mca_base_var_group_t *group; group 828 opal/mca/base/mca_base_pvar.c ret = mca_base_var_group_get_internal (pvar->group_index, &group, true); group 833 opal/mca/base/mca_base_pvar.c framework = group->group_framework; group 834 opal/mca/base/mca_base_pvar.c component = group->group_component ? group->group_component : "base"; group 1283 opal/mca/base/mca_base_var.c mca_base_var_group_t *group; group 1462 opal/mca/base/mca_base_var.c ret = mca_base_var_group_get_internal (var->mbv_group_index, &group, true); group 1468 opal/mca/base/mca_base_var.c if (!group->group_isvalid) { group 1469 opal/mca/base/mca_base_var.c group->group_isvalid = true; group 1473 opal/mca/base/mca_base_var.c if (0 != compare_strings(framework_name, group->group_framework) || group 1474 opal/mca/base/mca_base_var.c 0 != compare_strings(component_name, group->group_component) || group 1479 opal/mca/base/mca_base_var.c group->group_framework, group->group_component, group 2084 opal/mca/base/mca_base_var.c mca_base_var_group_t *group; group 2091 opal/mca/base/mca_base_var.c ret = mca_base_var_group_get_internal(var->mbv_group_index, &group, false); group 2107 opal/mca/base/mca_base_var.c framework = group->group_framework; group 2108 opal/mca/base/mca_base_var.c component = group->group_component ? group->group_component : "base"; group 54 opal/mca/base/mca_base_var_group.c static void mca_base_var_group_constructor (mca_base_var_group_t *group); group 55 opal/mca/base/mca_base_var_group.c static void mca_base_var_group_destructor (mca_base_var_group_t *group); group 108 opal/mca/base/mca_base_var_group.c int mca_base_var_group_get_internal (const int group_index, mca_base_var_group_t **group, bool invalidok) group 114 opal/mca/base/mca_base_var_group.c *group = (mca_base_var_group_t *) opal_pointer_array_get_item (&mca_base_var_groups, group 116 opal/mca/base/mca_base_var_group.c if (NULL == *group || (!invalidok && !(*group)->group_isvalid)) { group 117 opal/mca/base/mca_base_var_group.c *group = NULL; group 126 opal/mca/base/mca_base_var_group.c mca_base_var_group_t *group; group 136 opal/mca/base/mca_base_var_group.c rc = mca_base_var_group_get_internal ((int)(uintptr_t) tmp, &group, invalidok); group 141 opal/mca/base/mca_base_var_group.c if (invalidok || group->group_isvalid) { group 166 opal/mca/base/mca_base_var_group.c mca_base_var_group_t *group; group 168 opal/mca/base/mca_base_var_group.c int rc = mca_base_var_group_get_internal (i, &group, invalidok); group 173 opal/mca/base/mca_base_var_group.c if (compare_strings (project_name, group->group_project) && group 174 opal/mca/base/mca_base_var_group.c compare_strings (framework_name, group->group_framework) && group 175 opal/mca/base/mca_base_var_group.c compare_strings (component_name, group->group_component)) { group 214 opal/mca/base/mca_base_var_group.c mca_base_var_group_t *group; group 231 opal/mca/base/mca_base_var_group.c ret = mca_base_var_group_get_internal (group_id, &group, true); group 234 opal/mca/base/mca_base_var_group.c assert (NULL != group); group 237 opal/mca/base/mca_base_var_group.c group->group_isvalid = true; group 244 opal/mca/base/mca_base_var_group.c group = OBJ_NEW(mca_base_var_group_t); group 246 opal/mca/base/mca_base_var_group.c group->group_isvalid = true; group 249 opal/mca/base/mca_base_var_group.c group->group_project = strdup (project_name); group 250 opal/mca/base/mca_base_var_group.c if (NULL == group->group_project) { group 251 opal/mca/base/mca_base_var_group.c OBJ_RELEASE(group); group 256 opal/mca/base/mca_base_var_group.c group->group_framework = strdup (framework_name); group 257 opal/mca/base/mca_base_var_group.c if (NULL == group->group_framework) { group 258 opal/mca/base/mca_base_var_group.c OBJ_RELEASE(group); group 263 opal/mca/base/mca_base_var_group.c group->group_component = strdup (component_name); group 264 opal/mca/base/mca_base_var_group.c if (NULL == group->group_component) { group 265 opal/mca/base/mca_base_var_group.c OBJ_RELEASE(group); group 270 opal/mca/base/mca_base_var_group.c group->group_description = strdup (description); group 271 opal/mca/base/mca_base_var_group.c if (NULL == group->group_description) { group 272 opal/mca/base/mca_base_var_group.c OBJ_RELEASE(group); group 287 opal/mca/base/mca_base_var_group.c &group->group_full_name); group 289 opal/mca/base/mca_base_var_group.c OBJ_RELEASE(group); group 293 opal/mca/base/mca_base_var_group.c group_id = opal_pointer_array_add (&mca_base_var_groups, group); group 295 opal/mca/base/mca_base_var_group.c OBJ_RELEASE(group); group 299 opal/mca/base/mca_base_var_group.c opal_hash_table_set_value_ptr (&mca_base_var_group_index_hash, group->group_full_name, group 300 opal/mca/base/mca_base_var_group.c strlen (group->group_full_name), (void *)(uintptr_t) group_id); group 331 opal/mca/base/mca_base_var_group.c mca_base_var_group_t *group; group 336 opal/mca/base/mca_base_var_group.c ret = mca_base_var_group_get_internal (group_index, &group, false); group 341 opal/mca/base/mca_base_var_group.c group->group_isvalid = false; group 344 opal/mca/base/mca_base_var_group.c size = opal_value_array_get_size(&group->group_vars); group 345 opal/mca/base/mca_base_var_group.c params = OPAL_VALUE_ARRAY_GET_BASE(&group->group_vars, int); group 359 opal/mca/base/mca_base_var_group.c size = opal_value_array_get_size(&group->group_pvars); group 360 opal/mca/base/mca_base_var_group.c params = OPAL_VALUE_ARRAY_GET_BASE(&group->group_pvars, int); group 373 opal/mca/base/mca_base_var_group.c size = opal_value_array_get_size(&group->group_enums); group 374 opal/mca/base/mca_base_var_group.c enums = OPAL_VALUE_ARRAY_GET_BASE(&group->group_enums, opal_object_t *); group 379 opal/mca/base/mca_base_var_group.c size = opal_value_array_get_size(&group->group_subgroups); group 380 opal/mca/base/mca_base_var_group.c subgroups = OPAL_VALUE_ARRAY_GET_BASE(&group->group_subgroups, int); group 406 opal/mca/base/mca_base_var_group.c mca_base_var_group_t *group; group 410 opal/mca/base/mca_base_var_group.c ret = mca_base_var_group_get_internal (group_index, &group, false); group 415 opal/mca/base/mca_base_var_group.c size = opal_value_array_get_size(&group->group_vars); group 416 opal/mca/base/mca_base_var_group.c params = OPAL_VALUE_ARRAY_GET_BASE(&group->group_vars, int); group 424 opal/mca/base/mca_base_var_group.c (ret = opal_value_array_append_item (&group->group_vars, ¶m_index))) { group 431 opal/mca/base/mca_base_var_group.c return (int) opal_value_array_get_size (&group->group_vars) - 1; group 436 opal/mca/base/mca_base_var_group.c mca_base_var_group_t *group; group 440 opal/mca/base/mca_base_var_group.c ret = mca_base_var_group_get_internal (group_index, &group, false); group 445 opal/mca/base/mca_base_var_group.c size = opal_value_array_get_size(&group->group_pvars); group 446 opal/mca/base/mca_base_var_group.c params = OPAL_VALUE_ARRAY_GET_BASE(&group->group_pvars, int); group 454 opal/mca/base/mca_base_var_group.c (ret = opal_value_array_append_item (&group->group_pvars, ¶m_index))) { group 461 opal/mca/base/mca_base_var_group.c return (int) opal_value_array_get_size (&group->group_pvars) - 1; group 466 opal/mca/base/mca_base_var_group.c mca_base_var_group_t *group; group 470 opal/mca/base/mca_base_var_group.c ret = mca_base_var_group_get_internal (group_index, &group, false); group 475 opal/mca/base/mca_base_var_group.c size = opal_value_array_get_size(&group->group_enums); group 476 opal/mca/base/mca_base_var_group.c params = OPAL_VALUE_ARRAY_GET_BASE(&group->group_enums, void *); group 484 opal/mca/base/mca_base_var_group.c (ret = opal_value_array_append_item (&group->group_enums, storage))) { group 489 opal/mca/base/mca_base_var_group.c return (int) opal_value_array_get_size (&group->group_enums) - 1; group 492 opal/mca/base/mca_base_var_group.c int mca_base_var_group_get (const int group_index, const mca_base_var_group_t **group) group 494 opal/mca/base/mca_base_var_group.c return mca_base_var_group_get_internal (group_index, (mca_base_var_group_t **) group, false); group 499 opal/mca/base/mca_base_var_group.c mca_base_var_group_t *group; group 503 opal/mca/base/mca_base_var_group.c ret = mca_base_var_group_get_internal (group_index, &group, false); group 509 opal/mca/base/mca_base_var_group.c size = opal_value_array_get_size(&group->group_vars); group 510 opal/mca/base/mca_base_var_group.c vars = OPAL_VALUE_ARRAY_GET_BASE(&group->group_vars, int); group 522 opal/mca/base/mca_base_var_group.c static void mca_base_var_group_constructor (mca_base_var_group_t *group) group 524 opal/mca/base/mca_base_var_group.c memset ((char *) group + sizeof (group->super), 0, sizeof (*group) - sizeof (group->super)); group 526 opal/mca/base/mca_base_var_group.c OBJ_CONSTRUCT(&group->group_subgroups, opal_value_array_t); group 527 opal/mca/base/mca_base_var_group.c opal_value_array_init (&group->group_subgroups, sizeof (int)); group 529 opal/mca/base/mca_base_var_group.c OBJ_CONSTRUCT(&group->group_vars, opal_value_array_t); group 530 opal/mca/base/mca_base_var_group.c opal_value_array_init (&group->group_vars, sizeof (int)); group 532 opal/mca/base/mca_base_var_group.c OBJ_CONSTRUCT(&group->group_pvars, opal_value_array_t); group 533 opal/mca/base/mca_base_var_group.c opal_value_array_init (&group->group_pvars, sizeof (int)); group 535 opal/mca/base/mca_base_var_group.c OBJ_CONSTRUCT(&group->group_enums, opal_value_array_t); group 536 opal/mca/base/mca_base_var_group.c opal_value_array_init (&group->group_enums, sizeof(void *)); group 539 opal/mca/base/mca_base_var_group.c static void mca_base_var_group_destructor (mca_base_var_group_t *group) group 541 opal/mca/base/mca_base_var_group.c free (group->group_full_name); group 542 opal/mca/base/mca_base_var_group.c group->group_full_name = NULL; group 544 opal/mca/base/mca_base_var_group.c free (group->group_description); group 545 opal/mca/base/mca_base_var_group.c group->group_description = NULL; group 547 opal/mca/base/mca_base_var_group.c free (group->group_project); group 548 opal/mca/base/mca_base_var_group.c group->group_project = NULL; group 550 opal/mca/base/mca_base_var_group.c free (group->group_framework); group 551 opal/mca/base/mca_base_var_group.c group->group_framework = NULL; group 553 opal/mca/base/mca_base_var_group.c free (group->group_component); group 554 opal/mca/base/mca_base_var_group.c group->group_component = NULL; group 556 opal/mca/base/mca_base_var_group.c OBJ_DESTRUCT(&group->group_subgroups); group 557 opal/mca/base/mca_base_var_group.c OBJ_DESTRUCT(&group->group_vars); group 558 opal/mca/base/mca_base_var_group.c OBJ_DESTRUCT(&group->group_pvars); group 559 opal/mca/base/mca_base_var_group.c OBJ_DESTRUCT(&group->group_enums); group 149 opal/mca/base/mca_base_var_group.h const mca_base_var_group_t **group); group 119 opal/mca/base/mca_base_vari.h OPAL_DECLSPEC int mca_base_var_group_get_internal (const int group_index, mca_base_var_group_t **group, bool invalidok); group 122 opal/mca/event/libevent2022/libevent/bufferevent-internal.h struct bufferevent_rate_limit_group *group; group 632 opal/mca/event/libevent2022/libevent/bufferevent.c if (bufev_private->rate_limiting->group) group 230 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->group) { group 232 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->group; group 297 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->group) { group 298 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c LOCK_GROUP(bev->rate_limiting->group); group 299 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->group->rate_limit.read_limit -= bytes; group 300 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->group->total_read += bytes; group 301 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->group->rate_limit.read_limit <= 0) { group 302 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bev_group_suspend_reading(bev->rate_limiting->group); group 303 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c } else if (bev->rate_limiting->group->read_suspended) { group 304 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bev_group_unsuspend_reading(bev->rate_limiting->group); group 306 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c UNLOCK_GROUP(bev->rate_limiting->group); group 335 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->group) { group 336 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c LOCK_GROUP(bev->rate_limiting->group); group 337 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->group->rate_limit.write_limit -= bytes; group 338 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev->rate_limiting->group->total_written += bytes; group 339 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bev->rate_limiting->group->rate_limit.write_limit <= 0) { group 340 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bev_group_suspend_writing(bev->rate_limiting->group); group 341 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c } else if (bev->rate_limiting->group->write_suspended) { group 342 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bev_group_unsuspend_writing(bev->rate_limiting->group); group 344 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c UNLOCK_GROUP(bev->rate_limiting->group); group 445 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c _bev_group_random_element(struct bufferevent_rate_limit_group *group) group 452 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (!group->n_members) group 455 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c EVUTIL_ASSERT(! TAILQ_EMPTY(&group->members)); group 457 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c which = _evutil_weakrand() % group->n_members; group 459 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bev = TAILQ_FIRST(&group->members); group 752 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bevp->rate_limiting->group == g) { group 756 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bevp->rate_limiting->group) group 760 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bevp->rate_limiting->group = g; group 791 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c if (bevp->rate_limiting && bevp->rate_limiting->group) { group 793 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bevp->rate_limiting->group; group 795 opal/mca/event/libevent2022/libevent/bufferevent_ratelim.c bevp->rate_limiting->group = NULL; group 182 opal/mca/event/libevent2022/libevent/test/test-ratelim.c struct bufferevent_rate_limit_group *group = NULL; group 239 opal/mca/event/libevent2022/libevent/test/test-ratelim.c group = ratelim_group = bufferevent_rate_limit_group_new( group 298 opal/mca/event/libevent2022/libevent/test/test-ratelim.c if (group) group 299 opal/mca/event/libevent2022/libevent/test/test-ratelim.c bufferevent_rate_limit_group_free(group); group 113 opal/mca/event/libevent2022/libevent/test/tinytest.c _testcase_run_forked(const struct testgroup_t *group, group 140 opal/mca/event/libevent2022/libevent/test/tinytest.c commandname, verbosity_flag, group->prefix, testcase->name); group 165 opal/mca/event/libevent2022/libevent/test/tinytest.c (void)group; group 213 opal/mca/event/libevent2022/libevent/test/tinytest.c testcase_run_one(const struct testgroup_t *group, group 221 opal/mca/event/libevent2022/libevent/test/tinytest.c group->prefix, testcase->name); group 227 opal/mca/event/libevent2022/libevent/test/tinytest.c printf("%s%s: ", group->prefix, testcase->name); group 230 opal/mca/event/libevent2022/libevent/test/tinytest.c cur_test_prefix = group->prefix; group 235 opal/mca/event/libevent2022/libevent/test/tinytest.c outcome = _testcase_run_forked(group, testcase); group 197 opal/mca/hwloc/hwloc201/hwloc/hwloc/diff.c if (memcmp(obj1->attr, obj2->attr, sizeof(obj1->attr->group))) group 863 opal/mca/hwloc/hwloc201/hwloc/hwloc/distances.c group_obj->attr->group.kind = HWLOC_GROUP_KIND_DISTANCE; group 864 opal/mca/hwloc/hwloc201/hwloc/hwloc/distances.c group_obj->attr->group.subkind = topology->grouping_next_subkind; group 683 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-aix.c obj->attr->group.kind = HWLOC_GROUP_KIND_AIX_SDL_UNKNOWN; group 684 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-aix.c obj->attr->group.subkind = level; group 3360 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c cluster->attr->group.kind = HWLOC_GROUP_KIND_INTEL_KNL_SUBNUMA_CLUSTER; group 3638 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-linux.c book->attr->group.kind = HWLOC_GROUP_KIND_S390_BOOK; group 842 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-solaris.c hwloc_obj_t group = hwloc_alloc_setup_object(topology, HWLOC_OBJ_GROUP, HWLOC_UNKNOWN_INDEX); group 843 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-solaris.c group->cpuset = cpuset; group 844 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-solaris.c group->attr->group.kind = HWLOC_GROUP_KIND_SOLARIS_PG_HW_PERF; group 845 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-solaris.c group->attr->group.subkind = hwloc_bitmap_weight(cpuset); group 847 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-solaris.c hwloc_obj_add_info(group, "SolarisProcessorGroup", ksp->ks_name); group 848 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-solaris.c hwloc_insert_object_by_cpuset(topology, group); group 210 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-synthetic.c && attrs.group.depth != (unsigned) -1 group 211 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-synthetic.c && attrs.group.depth != data->level[i].attr.depth) group 562 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-synthetic.c data->level[count].attr.depth = attrs.group.depth; group 814 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-synthetic.c obj->attr->group.kind = HWLOC_GROUP_KIND_SYNTHETIC; group 815 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-synthetic.c obj->attr->group.subkind = sattr->depth-1; group 400 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-windows.c unsigned group; group 407 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-windows.c if (hwloc_bitmap_to_single_ULONG_PTR(hwloc_set, &group, &mask) < 0) { group 417 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-windows.c aff.Group = group; group 869 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-windows.c obj->attr->group.kind = procInfo[i].Relationship == RelationGroup ? HWLOC_GROUP_KIND_WINDOWS_PROCESSOR_GROUP : HWLOC_GROUP_KIND_WINDOWS_RELATIONSHIP_UNKNOWN; group 967 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-windows.c obj->attr->group.kind = HWLOC_GROUP_KIND_WINDOWS_PROCESSOR_GROUP; group 849 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-x86.c unit->attr->group.kind = HWLOC_GROUP_KIND_AMD_COMPUTE_UNIT; group 876 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-x86.c unknown_obj->attr->group.kind = HWLOC_GROUP_KIND_INTEL_X2APIC_UNKNOWN; group 877 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-x86.c unknown_obj->attr->group.subkind = level; group 226 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c obj->attr->group.kind = lvalue; group 235 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c obj->attr->group.subkind = lvalue; group 966 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c hwloc_obj_t group = hwloc_alloc_setup_object(topology, HWLOC_OBJ_GROUP, HWLOC_UNKNOWN_INDEX); group 967 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c group->gp_index = 0; /* will be initialized at the end of the discovery once we know the max */ group 968 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c group->cpuset = hwloc_bitmap_dup(obj->cpuset); group 969 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c group->complete_cpuset = hwloc_bitmap_dup(obj->cpuset); group 970 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c group->nodeset = hwloc_bitmap_dup(obj->nodeset); group 971 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c group->complete_nodeset = hwloc_bitmap_dup(obj->complete_nodeset); group 972 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c group->attr->group.kind = HWLOC_GROUP_KIND_MEMORY; group 973 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c hwloc_insert_object_by_parent(topology, parent, group); group 974 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c parent = group; group 2041 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c sprintf(tmp, "%u", obj->attr->group.depth); group 2044 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c sprintf(tmp, "%u", obj->attr->group.kind); group 2046 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c sprintf(tmp, "%u", obj->attr->group.subkind); group 2218 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c hwloc_obj_t group = parentstate->global->v1_memory_group; group 2220 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c group->cpuset = obj->cpuset; group 2221 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c group->complete_cpuset = obj->complete_cpuset; group 2222 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c group->nodeset = obj->nodeset; group 2223 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c group->complete_nodeset = obj->complete_nodeset; group 2224 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c hwloc__xml_export_object_contents (&gstate, topology, group, flags); group 2225 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c group->cpuset = NULL; group 2226 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c group->complete_cpuset = NULL; group 2227 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c group->nodeset = NULL; group 2228 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology-xml.c group->complete_nodeset = NULL; group 1109 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c && (obj1->attr->group.kind != obj2->attr->group.kind group 1110 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c || obj1->attr->group.subkind != obj2->attr->group.subkind)) group 1293 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c if (old->type == HWLOC_OBJ_PU && new->attr->group.kind == HWLOC_GROUP_KIND_MEMORY) group 1306 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c && (new->attr->group.kind < old->attr->group.kind)) group 1313 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c if (new->type == HWLOC_OBJ_PU && old->attr->group.kind == HWLOC_GROUP_KIND_MEMORY) group 1467 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c hwloc_obj_t parent, group, result; group 1498 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c group = hwloc_alloc_setup_object(topology, HWLOC_OBJ_GROUP, HWLOC_UNKNOWN_INDEX); group 1499 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c if (!group) group 1503 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c group->attr->group.kind = HWLOC_GROUP_KIND_MEMORY; group 1504 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c group->cpuset = hwloc_bitmap_dup(obj->cpuset); group 1505 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c group->complete_cpuset = hwloc_bitmap_dup(obj->complete_cpuset); group 1510 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c if (!group->cpuset != !obj->cpuset group 1511 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c || !group->complete_cpuset != !obj->complete_cpuset) { group 1513 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c hwloc_free_unlinked_object(group); group 1517 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c result = hwloc__insert_object_by_cpuset(topology, parent, group, report_error); group 1523 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c assert(result == group); group 1524 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c return group; group 1859 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c group_obj->attr->group.kind = HWLOC_GROUP_KIND_IO; group 2453 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c topology->levels[i][j]->attr->group.depth = groupdepth; group 4115 opal/mca/hwloc/hwloc201/hwloc/hwloc/topology.c assert(obj->attr->group.depth != (unsigned) -1); group 360 opal/mca/hwloc/hwloc201/hwloc/hwloc/traversal.c } else if (type == HWLOC_OBJ_GROUP && attrsize >= sizeof(attrp->group)) { group 361 opal/mca/hwloc/hwloc201/hwloc/hwloc/traversal.c attrp->group.depth = depthattr; group 388 opal/mca/hwloc/hwloc201/hwloc/hwloc/traversal.c && attr.group.depth != (unsigned)-1) { group 393 opal/mca/hwloc/hwloc201/hwloc/hwloc/traversal.c && topology->levels[l][0]->attr->group.depth == attr.group.depth) { group 440 opal/mca/hwloc/hwloc201/hwloc/hwloc/traversal.c if (obj->attr->group.depth != (unsigned) -1) group 441 opal/mca/hwloc/hwloc201/hwloc/hwloc/traversal.c return hwloc_snprintf(string, size, "%s%u", hwloc_obj_type_string(type), obj->attr->group.depth); group 579 opal/mca/hwloc/hwloc201/hwloc/include/hwloc.h } group; group 2219 opal/mca/hwloc/hwloc201/hwloc/include/hwloc.h HWLOC_DECLSPEC hwloc_obj_t hwloc_topology_insert_group_object(hwloc_topology_t topology, hwloc_obj_t group); group 89 opal/mca/hwloc/hwloc201/hwloc/include/hwloc/deprecated.h *depthattrp = (int) attr.group.depth; group 551 opal/mca/pmix/pmix4x/pmix/include/pmix_server.h pmix_server_grp_fn_t group; group 1304 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var.c pmix_mca_base_var_group_t *group; group 1465 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var.c ret = pmix_mca_base_var_group_get_internal (var->mbv_group_index, &group, true); group 1471 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var.c if (!group->group_isvalid) { group 1472 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var.c group->group_isvalid = true; group 1476 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var.c if (0 != compare_strings(framework_name, group->group_framework) || group 1477 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var.c 0 != compare_strings(component_name, group->group_component) || group 1482 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var.c group->group_framework, group->group_component, group 2072 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var.c pmix_mca_base_var_group_t *group; group 2079 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var.c ret = pmix_mca_base_var_group_get_internal(var->mbv_group_index, &group, false); group 2095 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var.c framework = group->group_framework; group 2096 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var.c component = group->group_component ? group->group_component : "base"; group 51 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c static void pmix_mca_base_var_group_constructor (pmix_mca_base_var_group_t *group); group 52 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c static void pmix_mca_base_var_group_destructor (pmix_mca_base_var_group_t *group); group 105 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c int pmix_mca_base_var_group_get_internal (const int group_index, pmix_mca_base_var_group_t **group, bool invalidok) group 111 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c *group = (pmix_mca_base_var_group_t *) pmix_pointer_array_get_item (&pmix_mca_base_var_groups, group 113 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c if (NULL == *group || (!invalidok && !(*group)->group_isvalid)) { group 114 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c *group = NULL; group 123 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c pmix_mca_base_var_group_t *group; group 133 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c rc = pmix_mca_base_var_group_get_internal ((int)(uintptr_t) tmp, &group, invalidok); group 138 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c if (invalidok || group->group_isvalid) { group 163 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c pmix_mca_base_var_group_t *group; group 165 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c int rc = pmix_mca_base_var_group_get_internal (i, &group, invalidok); group 170 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c if (compare_strings (project_name, group->group_project) && group 171 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c compare_strings (framework_name, group->group_framework) && group 172 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c compare_strings (component_name, group->group_component)) { group 211 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c pmix_mca_base_var_group_t *group; group 228 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c ret = pmix_mca_base_var_group_get_internal (group_id, &group, true); group 231 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c assert (NULL != group); group 234 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c group->group_isvalid = true; group 241 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c group = PMIX_NEW(pmix_mca_base_var_group_t); group 243 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c group->group_isvalid = true; group 246 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c group->group_project = strdup (project_name); group 247 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c if (NULL == group->group_project) { group 248 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c PMIX_RELEASE(group); group 253 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c group->group_framework = strdup (framework_name); group 254 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c if (NULL == group->group_framework) { group 255 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c PMIX_RELEASE(group); group 260 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c group->group_component = strdup (component_name); group 261 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c if (NULL == group->group_component) { group 262 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c PMIX_RELEASE(group); group 267 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c group->group_description = strdup (description); group 268 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c if (NULL == group->group_description) { group 269 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c PMIX_RELEASE(group); group 280 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c &group->group_full_name); group 282 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c PMIX_RELEASE(group); group 286 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c group_id = pmix_pointer_array_add (&pmix_mca_base_var_groups, group); group 288 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c PMIX_RELEASE(group); group 292 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c pmix_hash_table_set_value_ptr (&pmix_mca_base_var_group_index_hash, group->group_full_name, group 293 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c strlen (group->group_full_name), (void *)(uintptr_t) group_id); group 325 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c pmix_mca_base_var_group_t *group; group 329 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c ret = pmix_mca_base_var_group_get_internal (group_index, &group, false); group 334 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c group->group_isvalid = false; group 337 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c size = pmix_value_array_get_size(&group->group_vars); group 338 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c params = PMIX_VALUE_ARRAY_GET_BASE(&group->group_vars, int); group 351 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c size = pmix_value_array_get_size(&group->group_subgroups); group 352 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c subgroups = PMIX_VALUE_ARRAY_GET_BASE(&group->group_subgroups, int); group 378 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c pmix_mca_base_var_group_t *group; group 382 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c ret = pmix_mca_base_var_group_get_internal (group_index, &group, false); group 387 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c size = pmix_value_array_get_size(&group->group_vars); group 388 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c params = PMIX_VALUE_ARRAY_GET_BASE(&group->group_vars, int); group 396 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c (ret = pmix_value_array_append_item (&group->group_vars, ¶m_index))) { group 403 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c return (int) pmix_value_array_get_size (&group->group_vars) - 1; group 406 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c int pmix_mca_base_var_group_get (const int group_index, const pmix_mca_base_var_group_t **group) group 408 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c return pmix_mca_base_var_group_get_internal (group_index, (pmix_mca_base_var_group_t **) group, false); group 413 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c pmix_mca_base_var_group_t *group; group 417 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c ret = pmix_mca_base_var_group_get_internal (group_index, &group, false); group 423 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c size = pmix_value_array_get_size(&group->group_vars); group 424 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c vars = PMIX_VALUE_ARRAY_GET_BASE(&group->group_vars, int); group 436 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c static void pmix_mca_base_var_group_constructor (pmix_mca_base_var_group_t *group) group 438 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c memset ((char *) group + sizeof (group->super), 0, sizeof (*group) - sizeof (group->super)); group 440 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c PMIX_CONSTRUCT(&group->group_subgroups, pmix_value_array_t); group 441 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c pmix_value_array_init (&group->group_subgroups, sizeof (int)); group 443 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c PMIX_CONSTRUCT(&group->group_vars, pmix_value_array_t); group 444 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c pmix_value_array_init (&group->group_vars, sizeof (int)); group 448 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c static void pmix_mca_base_var_group_destructor (pmix_mca_base_var_group_t *group) group 450 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c free (group->group_full_name); group 451 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c group->group_full_name = NULL; group 453 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c free (group->group_description); group 454 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c group->group_description = NULL; group 456 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c free (group->group_project); group 457 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c group->group_project = NULL; group 459 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c free (group->group_framework); group 460 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c group->group_framework = NULL; group 462 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c free (group->group_component); group 463 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c group->group_component = NULL; group 465 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c PMIX_DESTRUCT(&group->group_subgroups); group 466 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.c PMIX_DESTRUCT(&group->group_vars); group 143 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_var_group.h const pmix_mca_base_var_group_t **group); group 116 opal/mca/pmix/pmix4x/pmix/src/mca/base/pmix_mca_base_vari.h int pmix_mca_base_var_group_get_internal (const int group_index, pmix_mca_base_var_group_t **group, bool invalidok); group 231 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h uint32_t group; group 272 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c if (0 != chown(address->sun_path, -1, lt->group)) { group 4137 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == pmix_host_server.group) { group 4177 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rc = pmix_host_server.group(PMIX_GROUP_CONSTRUCT, grp->grpid, group 4224 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == pmix_host_server.group) { group 4328 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c rc = pmix_host_server.group(PMIX_GROUP_DESTRUCT, grp->grpid, group 557 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c const pmix_mca_base_var_group_t *group; group 588 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c (void) pmix_mca_base_var_group_get(var->mbv_group_index, &group); group 591 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c if (0 > asprintf (&message, "MCA %s", group->group_framework)) { group 607 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c static void pmix_info_show_mca_group_params(const pmix_mca_base_var_group_t *group, pmix_mca_base_var_info_lvl_t max_level, bool want_internal) group 616 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c variables = PMIX_VALUE_ARRAY_GET_BASE(&group->group_vars, const int); group 617 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c count = pmix_value_array_get_size((pmix_value_array_t *)&group->group_vars); group 621 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c group_component = group->group_component ? group->group_component : "base"; group 628 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c var_id = pmix_mca_base_var_find (group->group_project, group->group_framework, NULL, NULL); group 664 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c if (pmix_info_pretty && curr_group != group) { group 666 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c group->group_framework, group 672 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c curr_group = group; group 683 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c group->group_framework, group 697 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c if (0 > asprintf (&message, "mca:%s:%s:param:%s:disabled:%s", group->group_framework, group 707 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c groups = PMIX_VALUE_ARRAY_GET_BASE(&group->group_subgroups, const int); group 708 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c count = pmix_value_array_get_size((pmix_value_array_t *)&group->group_subgroups); group 711 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c ret = pmix_mca_base_var_group_get(groups[i], &group); group 715 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c pmix_info_show_mca_group_params(group, max_level, want_internal); group 723 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c const pmix_mca_base_var_group_t *group; group 732 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c (void) pmix_mca_base_var_group_get(ret, &group); group 734 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c pmix_info_show_mca_group_params(group, max_level, want_internal); group 741 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c (void) pmix_mca_base_var_group_get(ret, &group); group 742 opal/mca/pmix/pmix4x/pmix/src/tools/pmix_info/support.c pmix_info_show_mca_group_params(group, max_level, want_internal); group 572 opal/runtime/opal_info_support.c const mca_base_var_group_t *group; group 603 opal/runtime/opal_info_support.c (void) mca_base_var_group_get(var->mbv_group_index, &group); group 606 opal/runtime/opal_info_support.c opal_asprintf (&message, "MCA %s", group->group_framework); group 620 opal/runtime/opal_info_support.c static void opal_info_show_mca_group_params(const mca_base_var_group_t *group, mca_base_var_info_lvl_t max_level, bool want_internal) group 630 opal/runtime/opal_info_support.c variables = OPAL_VALUE_ARRAY_GET_BASE(&group->group_vars, const int); group 631 opal/runtime/opal_info_support.c count = opal_value_array_get_size((opal_value_array_t *)&group->group_vars); group 635 opal/runtime/opal_info_support.c group_component = group->group_component ? group->group_component : "base"; group 642 opal/runtime/opal_info_support.c var_id = mca_base_var_find (group->group_project, group->group_framework, NULL, NULL); group 676 opal/runtime/opal_info_support.c if (opal_info_pretty && curr_group != group) { group 678 opal/runtime/opal_info_support.c group->group_framework, group 682 opal/runtime/opal_info_support.c curr_group = group; group 693 opal/runtime/opal_info_support.c group->group_framework, group 705 opal/runtime/opal_info_support.c opal_asprintf (&message, "mca:%s:%s:param:%s:disabled:%s", group->group_framework, group 713 opal/runtime/opal_info_support.c variables = OPAL_VALUE_ARRAY_GET_BASE(&group->group_pvars, const int); group 714 opal/runtime/opal_info_support.c count = opal_value_array_get_size((opal_value_array_t *)&group->group_pvars); group 722 opal/runtime/opal_info_support.c if (opal_info_pretty && curr_group != group) { group 724 opal/runtime/opal_info_support.c group->group_framework, group 728 opal/runtime/opal_info_support.c curr_group = group; group 739 opal/runtime/opal_info_support.c group->group_framework, group 751 opal/runtime/opal_info_support.c opal_asprintf (&message, "mca:%s:%s:pvar:%s:disabled:%s", group->group_framework, group 759 opal/runtime/opal_info_support.c groups = OPAL_VALUE_ARRAY_GET_BASE(&group->group_subgroups, const int); group 760 opal/runtime/opal_info_support.c count = opal_value_array_get_size((opal_value_array_t *)&group->group_subgroups); group 763 opal/runtime/opal_info_support.c ret = mca_base_var_group_get(groups[i], &group); group 767 opal/runtime/opal_info_support.c opal_info_show_mca_group_params(group, max_level, want_internal); group 775 opal/runtime/opal_info_support.c const mca_base_var_group_t *group; group 784 opal/runtime/opal_info_support.c (void) mca_base_var_group_get(ret, &group); group 786 opal/runtime/opal_info_support.c opal_info_show_mca_group_params(group, max_level, want_internal); group 793 opal/runtime/opal_info_support.c (void) mca_base_var_group_get(ret, &group); group 794 opal/runtime/opal_info_support.c opal_info_show_mca_group_params(group, max_level, want_internal); group 241 opal/util/opal_pty.c struct group *grptr; group 142 orte/tools/orte-info/param.c static void orte_info_show_mca_group_params(const mca_base_var_group_t *group, bool want_internal) group 150 orte/tools/orte-info/param.c variables = OPAL_VALUE_ARRAY_GET_BASE(&group->group_vars, const int); group 151 orte/tools/orte-info/param.c count = opal_value_array_get_size((opal_value_array_t *)&group->group_vars); group 169 orte/tools/orte-info/param.c opal_asprintf (&message, "MCA %s", group->group_framework); group 180 orte/tools/orte-info/param.c groups = OPAL_VALUE_ARRAY_GET_BASE(&group->group_subgroups, const int); group 181 orte/tools/orte-info/param.c count = opal_value_array_get_size((opal_value_array_t *)&group->group_subgroups); group 184 orte/tools/orte-info/param.c ret = mca_base_var_group_get(groups[i], &group); group 188 orte/tools/orte-info/param.c orte_info_show_mca_group_params(group, want_internal); group 195 orte/tools/orte-info/param.c const mca_base_var_group_t *group; group 204 orte/tools/orte-info/param.c (void) mca_base_var_group_get(ret, &group); group 206 orte/tools/orte-info/param.c orte_info_show_mca_group_params(group, want_internal); group 213 orte/tools/orte-info/param.c (void) mca_base_var_group_get(ret, &group); group 214 orte/tools/orte-info/param.c orte_info_show_mca_group_params(group, want_internal); group 37 oshmem/mca/scoll/base/base.h OSHMEM_DECLSPEC int mca_scoll_base_select(struct oshmem_group_t *group); group 39 oshmem/mca/scoll/base/base.h int mca_scoll_base_group_unselect(struct oshmem_group_t *group); group 47 oshmem/mca/scoll/base/scoll_base_select.c oshmem_group_t * group); group 48 oshmem/mca/scoll/base/scoll_base_select.c static int check_one_component(oshmem_group_t * group, group 53 oshmem/mca/scoll/base/scoll_base_select.c oshmem_group_t * group, group 58 oshmem/mca/scoll/base/scoll_base_select.c oshmem_group_t * group, group 62 oshmem/mca/scoll/base/scoll_base_select.c static int scoll_null_barrier(struct oshmem_group_t *group, group 66 oshmem/mca/scoll/base/scoll_base_select.c if (oshmem_proc_group_is_member(group)) { group 74 oshmem/mca/scoll/base/scoll_base_select.c static int scoll_null_broadcast(struct oshmem_group_t *group, group 83 oshmem/mca/scoll/base/scoll_base_select.c if (oshmem_proc_group_is_member(group)) { group 91 oshmem/mca/scoll/base/scoll_base_select.c static int scoll_null_collect(struct oshmem_group_t *group, group 99 oshmem/mca/scoll/base/scoll_base_select.c if (oshmem_proc_group_is_member(group)) { group 107 oshmem/mca/scoll/base/scoll_base_select.c static int scoll_null_reduce(struct oshmem_group_t *group, group 116 oshmem/mca/scoll/base/scoll_base_select.c if (oshmem_proc_group_is_member(group)) { group 124 oshmem/mca/scoll/base/scoll_base_select.c static int scoll_null_alltoall(struct oshmem_group_t *group, group 133 oshmem/mca/scoll/base/scoll_base_select.c if (oshmem_proc_group_is_member(group)) { group 146 oshmem/mca/scoll/base/scoll_base_select.c #define COPY(module, group, func) \ group 149 oshmem/mca/scoll/base/scoll_base_select.c if (NULL != group->g_scoll.scoll_ ## func ## _module) { \ group 150 oshmem/mca/scoll/base/scoll_base_select.c OBJ_RELEASE(group->g_scoll.scoll_ ## func ## _module); \ group 152 oshmem/mca/scoll/base/scoll_base_select.c group->g_scoll.scoll_ ## func = module->scoll_ ## func; \ group 153 oshmem/mca/scoll/base/scoll_base_select.c group->g_scoll.scoll_ ## func ## _module = module; \ group 158 oshmem/mca/scoll/base/scoll_base_select.c #define CLOSE(group, func) \ group 160 oshmem/mca/scoll/base/scoll_base_select.c if (NULL != group->g_scoll.scoll_ ## func ## _module) { \ group 161 oshmem/mca/scoll/base/scoll_base_select.c OBJ_RELEASE(group->g_scoll.scoll_ ## func ## _module); \ group 162 oshmem/mca/scoll/base/scoll_base_select.c group->g_scoll.scoll_## func = NULL; \ group 163 oshmem/mca/scoll/base/scoll_base_select.c group->g_scoll.scoll_## func ## _module = NULL; \ group 167 oshmem/mca/scoll/base/scoll_base_select.c int mca_scoll_base_group_unselect(struct oshmem_group_t * group) group 177 oshmem/mca/scoll/base/scoll_base_select.c SCOLL_VERBOSE(10, "scoll:base:group_unselect: group: %d", group->id); group 179 oshmem/mca/scoll/base/scoll_base_select.c CLOSE(group, barrier); group 180 oshmem/mca/scoll/base/scoll_base_select.c CLOSE(group, broadcast); group 181 oshmem/mca/scoll/base/scoll_base_select.c CLOSE(group, collect); group 182 oshmem/mca/scoll/base/scoll_base_select.c CLOSE(group, reduce); group 183 oshmem/mca/scoll/base/scoll_base_select.c CLOSE(group, alltoall); group 193 oshmem/mca/scoll/base/scoll_base_select.c int mca_scoll_base_select(struct oshmem_group_t *group) group 202 oshmem/mca/scoll/base/scoll_base_select.c SCOLL_VERBOSE(10, "scoll:base:group_select: new group: %d", group->id); group 203 oshmem/mca/scoll/base/scoll_base_select.c mca_scoll_base_group_unselect(group); group 204 oshmem/mca/scoll/base/scoll_base_select.c memset(&group->g_scoll, 0, sizeof(mca_scoll_base_group_scoll_t)); group 205 oshmem/mca/scoll/base/scoll_base_select.c if (!oshmem_proc_group_is_member(group)) { group 206 oshmem/mca/scoll/base/scoll_base_select.c group->g_scoll.scoll_barrier = scoll_null_barrier; group 207 oshmem/mca/scoll/base/scoll_base_select.c group->g_scoll.scoll_broadcast = scoll_null_broadcast; group 208 oshmem/mca/scoll/base/scoll_base_select.c group->g_scoll.scoll_collect = scoll_null_collect; group 209 oshmem/mca/scoll/base/scoll_base_select.c group->g_scoll.scoll_reduce = scoll_null_reduce; group 210 oshmem/mca/scoll/base/scoll_base_select.c group->g_scoll.scoll_alltoall = scoll_null_alltoall; group 218 oshmem/mca/scoll/base/scoll_base_select.c selectable = check_components(&oshmem_scoll_base_framework.framework_components, group); group 234 oshmem/mca/scoll/base/scoll_base_select.c ret = avail->ac_module->scoll_module_enable(avail->ac_module, group); group 236 oshmem/mca/scoll/base/scoll_base_select.c mca_scoll_base_group_unselect(group); group 238 oshmem/mca/scoll/base/scoll_base_select.c COPY(avail->ac_module, group, barrier); group 239 oshmem/mca/scoll/base/scoll_base_select.c COPY(avail->ac_module, group, broadcast); group 240 oshmem/mca/scoll/base/scoll_base_select.c COPY(avail->ac_module, group, collect); group 241 oshmem/mca/scoll/base/scoll_base_select.c COPY(avail->ac_module, group, reduce); group 242 oshmem/mca/scoll/base/scoll_base_select.c COPY(avail->ac_module, group, alltoall); group 252 oshmem/mca/scoll/base/scoll_base_select.c if ((NULL == group->g_scoll.scoll_barrier) group 253 oshmem/mca/scoll/base/scoll_base_select.c || (NULL == group->g_scoll.scoll_broadcast) group 254 oshmem/mca/scoll/base/scoll_base_select.c || (NULL == group->g_scoll.scoll_collect) group 255 oshmem/mca/scoll/base/scoll_base_select.c || (NULL == group->g_scoll.scoll_reduce) group 256 oshmem/mca/scoll/base/scoll_base_select.c || (NULL == group->g_scoll.scoll_alltoall)) { group 257 oshmem/mca/scoll/base/scoll_base_select.c mca_scoll_base_group_unselect(group); group 288 oshmem/mca/scoll/base/scoll_base_select.c oshmem_group_t *group) group 304 oshmem/mca/scoll/base/scoll_base_select.c priority = check_one_component(group, component, &module); group 332 oshmem/mca/scoll/base/scoll_base_select.c static int check_one_component(oshmem_group_t *group, group 339 oshmem/mca/scoll/base/scoll_base_select.c err = query(component, group, &priority, module); group 366 oshmem/mca/scoll/base/scoll_base_select.c oshmem_group_t *group, group 377 oshmem/mca/scoll/base/scoll_base_select.c return query_1_0_0(coll100, group, priority, module); group 386 oshmem/mca/scoll/base/scoll_base_select.c oshmem_group_t *group, group 394 oshmem/mca/scoll/base/scoll_base_select.c ret = component->scoll_query(group, priority); group 48 oshmem/mca/scoll/basic/scoll_basic.h mca_scoll_basic_query(struct oshmem_group_t *group, int *priority); group 57 oshmem/mca/scoll/basic/scoll_basic.h int mca_scoll_basic_barrier(struct oshmem_group_t *group, long *pSync, int alg); group 58 oshmem/mca/scoll/basic/scoll_basic.h int mca_scoll_basic_broadcast(struct oshmem_group_t *group, group 66 oshmem/mca/scoll/basic/scoll_basic.h int mca_scoll_basic_collect(struct oshmem_group_t *group, group 73 oshmem/mca/scoll/basic/scoll_basic.h int mca_scoll_basic_reduce(struct oshmem_group_t *group, group 81 oshmem/mca/scoll/basic/scoll_basic.h int mca_scoll_basic_alltoall(struct oshmem_group_t *group, group 22 oshmem/mca/scoll/basic/scoll_basic_alltoall.c static int a2a_alg_simple(struct oshmem_group_t *group, group 28 oshmem/mca/scoll/basic/scoll_basic_alltoall.c static int a2as_alg_simple(struct oshmem_group_t *group, group 36 oshmem/mca/scoll/basic/scoll_basic_alltoall.c int mca_scoll_basic_alltoall(struct oshmem_group_t *group, group 49 oshmem/mca/scoll/basic/scoll_basic_alltoall.c if (!group) { group 55 oshmem/mca/scoll/basic/scoll_basic_alltoall.c if (!oshmem_proc_group_is_member(group)) { group 70 oshmem/mca/scoll/basic/scoll_basic_alltoall.c rc = a2a_alg_simple(group, target, source, nelems, element_size); group 72 oshmem/mca/scoll/basic/scoll_basic_alltoall.c rc = a2as_alg_simple(group, target, source, dst, sst, nelems, group 86 oshmem/mca/scoll/basic/scoll_basic_alltoall.c SCOLL_VERBOSE(14, "[#%d] Wait for operation completion", group->my_pe); group 87 oshmem/mca/scoll/basic/scoll_basic_alltoall.c rc = BARRIER_FUNC(group, pSync, SCOLL_DEFAULT_ALG); group 91 oshmem/mca/scoll/basic/scoll_basic_alltoall.c group->my_pe); group 113 oshmem/mca/scoll/basic/scoll_basic_alltoall.c get_dst_pe(struct oshmem_group_t *group, int src_blk_idx, int dst_blk_idx, int *dst_pe_idx) group 116 oshmem/mca/scoll/basic/scoll_basic_alltoall.c (*dst_pe_idx) = (dst_blk_idx + src_blk_idx) % group->proc_count; group 119 oshmem/mca/scoll/basic/scoll_basic_alltoall.c return oshmem_proc_pe(group->proc_array[*dst_pe_idx]); group 122 oshmem/mca/scoll/basic/scoll_basic_alltoall.c static int a2as_alg_simple(struct oshmem_group_t *group, group 138 oshmem/mca/scoll/basic/scoll_basic_alltoall.c group->my_pe); group 140 oshmem/mca/scoll/basic/scoll_basic_alltoall.c dst_blk_idx = oshmem_proc_group_find_id(group, group->my_pe); group 142 oshmem/mca/scoll/basic/scoll_basic_alltoall.c for (src_blk_idx = 0; src_blk_idx < group->proc_count; src_blk_idx++) { group 144 oshmem/mca/scoll/basic/scoll_basic_alltoall.c dst_pe = get_dst_pe(group, src_blk_idx, dst_blk_idx, &dst_pe_idx); group 161 oshmem/mca/scoll/basic/scoll_basic_alltoall.c static int a2a_alg_simple(struct oshmem_group_t *group, group 176 oshmem/mca/scoll/basic/scoll_basic_alltoall.c group->my_pe); group 178 oshmem/mca/scoll/basic/scoll_basic_alltoall.c dst_blk_idx = oshmem_proc_group_find_id(group, group->my_pe); group 183 oshmem/mca/scoll/basic/scoll_basic_alltoall.c for (src_blk_idx = 0; src_blk_idx < group->proc_count; src_blk_idx++) { group 185 oshmem/mca/scoll/basic/scoll_basic_alltoall.c dst_pe = get_dst_pe(group, src_blk_idx, dst_blk_idx, &dst_pe_idx); group 24 oshmem/mca/scoll/basic/scoll_basic_barrier.c static int _algorithm_central_counter(struct oshmem_group_t *group, group 26 oshmem/mca/scoll/basic/scoll_basic_barrier.c static int _algorithm_tournament(struct oshmem_group_t *group, long *pSync); group 27 oshmem/mca/scoll/basic/scoll_basic_barrier.c static int _algorithm_recursive_doubling(struct oshmem_group_t *group, group 29 oshmem/mca/scoll/basic/scoll_basic_barrier.c static int _algorithm_dissemination(struct oshmem_group_t *group, long *pSync); group 30 oshmem/mca/scoll/basic/scoll_basic_barrier.c static int _algorithm_basic(struct oshmem_group_t *group, long *pSync); group 31 oshmem/mca/scoll/basic/scoll_basic_barrier.c static int _algorithm_adaptive(struct oshmem_group_t *group, long *pSync); group 33 oshmem/mca/scoll/basic/scoll_basic_barrier.c int mca_scoll_basic_barrier(struct oshmem_group_t *group, long *pSync, int alg) group 38 oshmem/mca/scoll/basic/scoll_basic_barrier.c if (!group || !pSync) { group 43 oshmem/mca/scoll/basic/scoll_basic_barrier.c if ((rc == OSHMEM_SUCCESS) && oshmem_proc_group_is_member(group)) { group 50 oshmem/mca/scoll/basic/scoll_basic_barrier.c rc = _algorithm_central_counter(group, pSync); group 55 oshmem/mca/scoll/basic/scoll_basic_barrier.c rc = _algorithm_tournament(group, pSync); group 60 oshmem/mca/scoll/basic/scoll_basic_barrier.c rc = _algorithm_recursive_doubling(group, pSync); group 65 oshmem/mca/scoll/basic/scoll_basic_barrier.c rc = _algorithm_dissemination(group, pSync); group 70 oshmem/mca/scoll/basic/scoll_basic_barrier.c rc = _algorithm_basic(group, pSync); group 75 oshmem/mca/scoll/basic/scoll_basic_barrier.c rc = _algorithm_adaptive(group, pSync); group 80 oshmem/mca/scoll/basic/scoll_basic_barrier.c rc = _algorithm_recursive_doubling(group, pSync); group 100 oshmem/mca/scoll/basic/scoll_basic_barrier.c static int _algorithm_central_counter(struct oshmem_group_t *group, group 106 oshmem/mca/scoll/basic/scoll_basic_barrier.c int PE_root = oshmem_proc_pe(group->proc_array[root_id]); group 109 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(12, "[#%d] Barrier algorithm: Central Counter", group->my_pe); group 110 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 116 oshmem/mca/scoll/basic/scoll_basic_barrier.c if (PE_root == group->my_pe) { group 121 oshmem/mca/scoll/basic/scoll_basic_barrier.c wait_pe_array = malloc(sizeof(*wait_pe_array) * group->proc_count); group 123 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(14, "[#%d] PE is the root", group->my_pe); group 125 oshmem/mca/scoll/basic/scoll_basic_barrier.c wait_pe_count = group->proc_count; group 126 oshmem/mca/scoll/basic/scoll_basic_barrier.c for (i = 0; i < group->proc_count; i++) { group 127 oshmem/mca/scoll/basic/scoll_basic_barrier.c wait_pe_array[i] = oshmem_proc_pe(group->proc_array[i]); group 133 oshmem/mca/scoll/basic/scoll_basic_barrier.c for (i = 0; (i < group->proc_count) && (rc == OSHMEM_SUCCESS); group 144 oshmem/mca/scoll/basic/scoll_basic_barrier.c group->my_pe, pe_cur, (int)wait_pe_count); group 150 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(14, "[#%d] PE signals to all", group->my_pe); group 152 oshmem/mca/scoll/basic/scoll_basic_barrier.c for (i = 0; (i < group->proc_count) && (rc == OSHMEM_SUCCESS); group 154 oshmem/mca/scoll/basic/scoll_basic_barrier.c pe_cur = oshmem_proc_pe(group->proc_array[i]); group 176 oshmem/mca/scoll/basic/scoll_basic_barrier.c group->my_pe); group 185 oshmem/mca/scoll/basic/scoll_basic_barrier.c group->my_pe); group 190 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 205 oshmem/mca/scoll/basic/scoll_basic_barrier.c static int _algorithm_tournament(struct oshmem_group_t *group, long *pSync) group 209 oshmem/mca/scoll/basic/scoll_basic_barrier.c int exit_flag = group->proc_count - 1; group 211 oshmem/mca/scoll/basic/scoll_basic_barrier.c int my_id = oshmem_proc_group_find_id(group, group->my_pe); group 216 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(12, "[#%d] Barrier algorithm: Tournament", group->my_pe); group 217 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 231 oshmem/mca/scoll/basic/scoll_basic_barrier.c if (peer_id >= group->proc_count) group 238 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(14, "[#%d] round = %d wait", group->my_pe, round); group 241 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 253 oshmem/mca/scoll/basic/scoll_basic_barrier.c group->my_pe, round, peer_pe); group 257 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(14, "[#%d] round = %d signals to #%d", group->my_pe, round, peer_pe); group 263 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(14, "[#%d] round = %d wait", group->my_pe, round); group 274 oshmem/mca/scoll/basic/scoll_basic_barrier.c group->my_pe); group 281 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(14, "[#%d] signals to all", group->my_pe); group 285 oshmem/mca/scoll/basic/scoll_basic_barrier.c (peer_id < group->proc_count) && (rc == OSHMEM_SUCCESS); group 287 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 292 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 305 oshmem/mca/scoll/basic/scoll_basic_barrier.c static int _algorithm_recursive_doubling(struct oshmem_group_t *group, group 313 oshmem/mca/scoll/basic/scoll_basic_barrier.c int my_id = oshmem_proc_group_find_id(group, group->my_pe); group 319 oshmem/mca/scoll/basic/scoll_basic_barrier.c i = group->proc_count; group 328 oshmem/mca/scoll/basic/scoll_basic_barrier.c group->my_pe); group 331 oshmem/mca/scoll/basic/scoll_basic_barrier.c group->my_pe, pSync[0], floor2_proc); group 336 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 340 oshmem/mca/scoll/basic/scoll_basic_barrier.c group->my_pe, peer_pe); group 344 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(14, "[#%d] wait", group->my_pe); group 351 oshmem/mca/scoll/basic/scoll_basic_barrier.c group->my_pe); group 357 oshmem/mca/scoll/basic/scoll_basic_barrier.c if ((group->proc_count - floor2_proc) > my_id) { group 360 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 364 oshmem/mca/scoll/basic/scoll_basic_barrier.c group->my_pe, peer_pe); group 380 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 392 oshmem/mca/scoll/basic/scoll_basic_barrier.c group->my_pe, round, peer_pe); group 396 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(14, "[#%d] round = %d signals to #%d", group->my_pe, round, peer_pe); group 406 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(14, "[#%d] round = %d wait", group->my_pe, round); group 414 oshmem/mca/scoll/basic/scoll_basic_barrier.c group->my_pe); group 420 oshmem/mca/scoll/basic/scoll_basic_barrier.c if ((group->proc_count - floor2_proc) > my_id) { group 423 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 425 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(14, "[#%d] signals to #%d", group->my_pe, peer_pe); group 431 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 443 oshmem/mca/scoll/basic/scoll_basic_barrier.c static int _algorithm_dissemination(struct oshmem_group_t *group, long *pSync) group 449 oshmem/mca/scoll/basic/scoll_basic_barrier.c int my_id = oshmem_proc_group_find_id(group, group->my_pe); group 454 oshmem/mca/scoll/basic/scoll_basic_barrier.c log2_proc = scoll_log2((unsigned long) group->proc_count); group 456 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(12, "[#%d] Barrier algorithm: Dissemination", group->my_pe); group 459 oshmem/mca/scoll/basic/scoll_basic_barrier.c group->my_pe, pSync[0], log2_proc); group 464 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_id = (my_id + (1 << round)) % group->proc_count; group 466 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 478 oshmem/mca/scoll/basic/scoll_basic_barrier.c group->my_pe, round, peer_pe); group 483 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(14, "[#%d] round = %d wait", group->my_pe, round); group 491 oshmem/mca/scoll/basic/scoll_basic_barrier.c group->my_pe); group 496 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 501 oshmem/mca/scoll/basic/scoll_basic_barrier.c static int _algorithm_basic(struct oshmem_group_t *group, long *pSync) group 505 oshmem/mca/scoll/basic/scoll_basic_barrier.c int PE_root = oshmem_proc_pe(group->proc_array[root_id]); group 508 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(12, "[#%d] Barrier algorithm: Basic", group->my_pe); group 510 oshmem/mca/scoll/basic/scoll_basic_barrier.c if (PE_root != group->my_pe) { group 527 oshmem/mca/scoll/basic/scoll_basic_barrier.c for (i = 0; (i < group->proc_count) && (rc == OSHMEM_SUCCESS); i++) { group 528 oshmem/mca/scoll/basic/scoll_basic_barrier.c pe_cur = oshmem_proc_pe(group->proc_array[i]); group 537 oshmem/mca/scoll/basic/scoll_basic_barrier.c for (i = 0; (i < group->proc_count) && (rc == OSHMEM_SUCCESS); i++) { group 538 oshmem/mca/scoll/basic/scoll_basic_barrier.c pe_cur = oshmem_proc_pe(group->proc_array[i]); group 551 oshmem/mca/scoll/basic/scoll_basic_barrier.c static int _algorithm_adaptive(struct oshmem_group_t *group, long *pSync) group 556 oshmem/mca/scoll/basic/scoll_basic_barrier.c SCOLL_VERBOSE(12, "[#%d] Barrier algorithm: Adaptive", group->my_pe); group 561 oshmem/mca/scoll/basic/scoll_basic_barrier.c int my_id = oshmem_proc_group_find_id(group, group->my_pe); group 563 oshmem/mca/scoll/basic/scoll_basic_barrier.c for (i = 0; i < group->proc_count; i++) { group 567 oshmem/mca/scoll/basic/scoll_basic_barrier.c if (!OPAL_PROC_ON_LOCAL_NODE(group->proc_array[i]->super.proc_flags)) { group 578 oshmem/mca/scoll/basic/scoll_basic_barrier.c if (local_peers_only || (group->proc_count < 32)) { group 579 oshmem/mca/scoll/basic/scoll_basic_barrier.c rc = _algorithm_basic(group, pSync); group 581 oshmem/mca/scoll/basic/scoll_basic_barrier.c rc = _algorithm_recursive_doubling(group, pSync); group 25 oshmem/mca/scoll/basic/scoll_basic_broadcast.c static int _algorithm_central_counter(struct oshmem_group_t *group, group 31 oshmem/mca/scoll/basic/scoll_basic_broadcast.c static int _algorithm_binomial_tree(struct oshmem_group_t *group, group 38 oshmem/mca/scoll/basic/scoll_basic_broadcast.c int mca_scoll_basic_broadcast(struct oshmem_group_t *group, group 50 oshmem/mca/scoll/basic/scoll_basic_broadcast.c if (!group) { group 56 oshmem/mca/scoll/basic/scoll_basic_broadcast.c if ((rc == OSHMEM_SUCCESS) && oshmem_proc_group_is_member(group)) { group 70 oshmem/mca/scoll/basic/scoll_basic_broadcast.c rc = _algorithm_central_counter(group, group 80 oshmem/mca/scoll/basic/scoll_basic_broadcast.c rc = _algorithm_binomial_tree(group, group 90 oshmem/mca/scoll/basic/scoll_basic_broadcast.c rc = _algorithm_binomial_tree(group, group 106 oshmem/mca/scoll/basic/scoll_basic_broadcast.c group->my_pe); group 122 oshmem/mca/scoll/basic/scoll_basic_broadcast.c static int _algorithm_central_counter(struct oshmem_group_t *group, group 134 oshmem/mca/scoll/basic/scoll_basic_broadcast.c group->my_pe); group 137 oshmem/mca/scoll/basic/scoll_basic_broadcast.c group->my_pe, pSync[0], PE_root); group 140 oshmem/mca/scoll/basic/scoll_basic_broadcast.c if (PE_root == group->my_pe) { group 145 oshmem/mca/scoll/basic/scoll_basic_broadcast.c group->my_pe); group 146 oshmem/mca/scoll/basic/scoll_basic_broadcast.c for (i = 0; (i < group->proc_count) && (rc == OSHMEM_SUCCESS); i++) { group 147 oshmem/mca/scoll/basic/scoll_basic_broadcast.c pe_cur = oshmem_proc_pe(group->proc_array[i]); group 151 oshmem/mca/scoll/basic/scoll_basic_broadcast.c group->my_pe, pe_cur); group 162 oshmem/mca/scoll/basic/scoll_basic_broadcast.c SCOLL_VERBOSE(14, "[#%d] Wait for operation completion", group->my_pe); group 164 oshmem/mca/scoll/basic/scoll_basic_broadcast.c rc = BARRIER_FUNC(group, group 177 oshmem/mca/scoll/basic/scoll_basic_broadcast.c static int _algorithm_binomial_tree(struct oshmem_group_t *group, group 186 oshmem/mca/scoll/basic/scoll_basic_broadcast.c int root_id = oshmem_proc_group_find_id(group, PE_root); group 187 oshmem/mca/scoll/basic/scoll_basic_broadcast.c int my_id = oshmem_proc_group_find_id(group, group->my_pe); group 191 oshmem/mca/scoll/basic/scoll_basic_broadcast.c int dim = opal_cube_dim(group->proc_count); group 196 oshmem/mca/scoll/basic/scoll_basic_broadcast.c SCOLL_VERBOSE(12, "[#%d] Broadcast algorithm: Tree", group->my_pe); group 199 oshmem/mca/scoll/basic/scoll_basic_broadcast.c group->my_pe, pSync[0], PE_root); group 201 oshmem/mca/scoll/basic/scoll_basic_broadcast.c vrank = (my_id + group->proc_count - root_id) % group->proc_count; group 206 oshmem/mca/scoll/basic/scoll_basic_broadcast.c group->my_pe, dim, vrank, hibit); group 215 oshmem/mca/scoll/basic/scoll_basic_broadcast.c SCOLL_VERBOSE(14, "[#%d] wait", group->my_pe); group 220 oshmem/mca/scoll/basic/scoll_basic_broadcast.c group->my_pe, pSync[0]); group 233 oshmem/mca/scoll/basic/scoll_basic_broadcast.c if (peer_id < group->proc_count) { group 235 oshmem/mca/scoll/basic/scoll_basic_broadcast.c peer_id = (peer_id + root_id) % group->proc_count; group 236 oshmem/mca/scoll/basic/scoll_basic_broadcast.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 240 oshmem/mca/scoll/basic/scoll_basic_broadcast.c group->my_pe, peer_pe); group 245 oshmem/mca/scoll/basic/scoll_basic_broadcast.c SCOLL_VERBOSE(14, "[#%d] send data to #%d", group->my_pe, peer_pe); group 250 oshmem/mca/scoll/basic/scoll_basic_broadcast.c SCOLL_VERBOSE(14, "[#%d] signals to #%d", group->my_pe, peer_pe); group 23 oshmem/mca/scoll/basic/scoll_basic_collect.c static int _algorithm_central_collector(struct oshmem_group_t *group, group 28 oshmem/mca/scoll/basic/scoll_basic_collect.c static int _algorithm_f_central_counter(struct oshmem_group_t *group, group 33 oshmem/mca/scoll/basic/scoll_basic_collect.c static int _algorithm_f_tournament(struct oshmem_group_t *group, group 38 oshmem/mca/scoll/basic/scoll_basic_collect.c static int _algorithm_f_recursive_doubling(struct oshmem_group_t *group, group 43 oshmem/mca/scoll/basic/scoll_basic_collect.c static int _algorithm_f_ring(struct oshmem_group_t *group, group 49 oshmem/mca/scoll/basic/scoll_basic_collect.c int mca_scoll_basic_collect(struct oshmem_group_t *group, group 60 oshmem/mca/scoll/basic/scoll_basic_collect.c if (!group || !pSync) { group 66 oshmem/mca/scoll/basic/scoll_basic_collect.c if ((rc == OSHMEM_SUCCESS) && oshmem_proc_group_is_member(group)) { group 81 oshmem/mca/scoll/basic/scoll_basic_collect.c rc = _algorithm_f_central_counter(group, group 90 oshmem/mca/scoll/basic/scoll_basic_collect.c rc = _algorithm_f_tournament(group, group 99 oshmem/mca/scoll/basic/scoll_basic_collect.c rc = _algorithm_f_recursive_doubling(group, group 108 oshmem/mca/scoll/basic/scoll_basic_collect.c rc = _algorithm_f_ring(group, group 117 oshmem/mca/scoll/basic/scoll_basic_collect.c rc = _algorithm_f_central_counter(group, group 125 oshmem/mca/scoll/basic/scoll_basic_collect.c rc = _algorithm_central_collector(group, group 135 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe); group 150 oshmem/mca/scoll/basic/scoll_basic_collect.c static int _algorithm_f_central_counter(struct oshmem_group_t *group, group 158 oshmem/mca/scoll/basic/scoll_basic_collect.c int PE_root = oshmem_proc_pe(group->proc_array[0]); group 162 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe); group 163 oshmem/mca/scoll/basic/scoll_basic_collect.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 165 oshmem/mca/scoll/basic/scoll_basic_collect.c if (PE_root == group->my_pe) { group 174 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe); group 175 oshmem/mca/scoll/basic/scoll_basic_collect.c for (i = 0; (i < group->proc_count) && (rc == OSHMEM_SUCCESS); i++) { group 177 oshmem/mca/scoll/basic/scoll_basic_collect.c pe_cur = oshmem_proc_pe(group->proc_array[i]); group 179 oshmem/mca/scoll/basic/scoll_basic_collect.c if (pe_cur == group->my_pe) group 184 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, (int)nlong, pe_cur); group 195 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, PE_root); group 196 oshmem/mca/scoll/basic/scoll_basic_collect.c rc = BCAST_FUNC(group, group 200 oshmem/mca/scoll/basic/scoll_basic_collect.c group->proc_count * nlong, group 206 oshmem/mca/scoll/basic/scoll_basic_collect.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 211 oshmem/mca/scoll/basic/scoll_basic_collect.c static int _algorithm_f_tournament(struct oshmem_group_t *group, group 219 oshmem/mca/scoll/basic/scoll_basic_collect.c int exit_flag = group->proc_count - 1; group 221 oshmem/mca/scoll/basic/scoll_basic_collect.c int my_id = oshmem_proc_group_find_id(group, group->my_pe); group 224 oshmem/mca/scoll/basic/scoll_basic_collect.c int PE_root = oshmem_proc_pe(group->proc_array[0]); group 228 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe); group 229 oshmem/mca/scoll/basic/scoll_basic_collect.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 248 oshmem/mca/scoll/basic/scoll_basic_collect.c if (peer_id >= group->proc_count) group 255 oshmem/mca/scoll/basic/scoll_basic_collect.c SCOLL_VERBOSE(14, "[#%d] round = %d wait", group->my_pe, round); group 258 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 270 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, round, peer_pe); group 277 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, round, peer_pe); group 281 oshmem/mca/scoll/basic/scoll_basic_collect.c SCOLL_VERBOSE(14, "[#%d] round = %d wait", group->my_pe, round); group 291 oshmem/mca/scoll/basic/scoll_basic_collect.c SCOLL_VERBOSE(14, "[#%d] signals to all", group->my_pe); group 295 oshmem/mca/scoll/basic/scoll_basic_collect.c (peer_id < group->proc_count) && (rc == OSHMEM_SUCCESS); group 297 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 306 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, PE_root); group 307 oshmem/mca/scoll/basic/scoll_basic_collect.c rc = BCAST_FUNC(group, group 311 oshmem/mca/scoll/basic/scoll_basic_collect.c group->proc_count * nlong, group 317 oshmem/mca/scoll/basic/scoll_basic_collect.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 322 oshmem/mca/scoll/basic/scoll_basic_collect.c static int _algorithm_f_ring(struct oshmem_group_t *group, group 331 oshmem/mca/scoll/basic/scoll_basic_collect.c int my_id = oshmem_proc_group_find_id(group, group->my_pe); group 338 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe); group 339 oshmem/mca/scoll/basic/scoll_basic_collect.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 341 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_id = (my_id + 1) % group->proc_count; group 342 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 348 oshmem/mca/scoll/basic/scoll_basic_collect.c for (i = 0; (i < (group->proc_count - 1)) && (rc == OSHMEM_SUCCESS); i++) { group 351 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, i, peer_pe, data_index); group 358 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, i, peer_pe); group 362 oshmem/mca/scoll/basic/scoll_basic_collect.c data_index = (data_index ? (data_index - 1) : (group->proc_count - 1)); group 366 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, i, data_index); group 376 oshmem/mca/scoll/basic/scoll_basic_collect.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 381 oshmem/mca/scoll/basic/scoll_basic_collect.c static int _algorithm_f_recursive_doubling(struct oshmem_group_t *group, group 392 oshmem/mca/scoll/basic/scoll_basic_collect.c int my_id = oshmem_proc_group_find_id(group, group->my_pe); group 399 oshmem/mca/scoll/basic/scoll_basic_collect.c i = group->proc_count; group 408 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe); group 411 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, pSync[0], floor2_proc); group 423 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 425 oshmem/mca/scoll/basic/scoll_basic_collect.c for (i = 0; (i < group->proc_count) && (rc == OSHMEM_SUCCESS); i++) { group 429 oshmem/mca/scoll/basic/scoll_basic_collect.c pe_cur = oshmem_proc_pe(group->proc_array[i]); group 433 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, pe_cur); group 441 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, peer_pe); group 445 oshmem/mca/scoll/basic/scoll_basic_collect.c SCOLL_VERBOSE(14, "[#%d] wait", group->my_pe); group 450 oshmem/mca/scoll/basic/scoll_basic_collect.c if ((group->proc_count - floor2_proc) > my_id) { group 453 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 457 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, peer_pe); group 473 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 485 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, round, peer_pe, data_index); group 494 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, round, peer_pe); group 499 oshmem/mca/scoll/basic/scoll_basic_collect.c SCOLL_VERBOSE(14, "[#%d] round = %d wait", group->my_pe, round); group 507 oshmem/mca/scoll/basic/scoll_basic_collect.c if ((group->proc_count - floor2_proc) > my_id) { group 510 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 514 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, peer_pe); group 515 oshmem/mca/scoll/basic/scoll_basic_collect.c rc = MCA_SPML_CALL(put(oshmem_ctx_default, target, group->proc_count * nlong, target, peer_pe)); group 519 oshmem/mca/scoll/basic/scoll_basic_collect.c SCOLL_VERBOSE(14, "[#%d] signals to #%d", group->my_pe, peer_pe); group 525 oshmem/mca/scoll/basic/scoll_basic_collect.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 536 oshmem/mca/scoll/basic/scoll_basic_collect.c static int _algorithm_central_collector(struct oshmem_group_t *group, group 545 oshmem/mca/scoll/basic/scoll_basic_collect.c int PE_root = oshmem_proc_pe(group->proc_array[0]); group 549 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe); group 554 oshmem/mca/scoll/basic/scoll_basic_collect.c if (PE_root == group->my_pe) { group 560 oshmem/mca/scoll/basic/scoll_basic_collect.c wait_pe_count = group->proc_count; group 572 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe); group 573 oshmem/mca/scoll/basic/scoll_basic_collect.c for (i = 1; (i < group->proc_count) && (rc == OSHMEM_SUCCESS); group 576 oshmem/mca/scoll/basic/scoll_basic_collect.c pe_cur = oshmem_proc_pe(group->proc_array[i]); group 596 oshmem/mca/scoll/basic/scoll_basic_collect.c for (i = 1; (i < group->proc_count) && (rc == OSHMEM_SUCCESS); group 605 oshmem/mca/scoll/basic/scoll_basic_collect.c pe_cur = oshmem_proc_pe(group->proc_array[i]); group 627 oshmem/mca/scoll/basic/scoll_basic_collect.c group->my_pe, PE_root); group 629 oshmem/mca/scoll/basic/scoll_basic_collect.c rc = BCAST_FUNC(group, group 43 oshmem/mca/scoll/basic/scoll_basic_module.c mca_scoll_basic_query(struct oshmem_group_t *group, int *priority) group 24 oshmem/mca/scoll/basic/scoll_basic_reduce.c static int _algorithm_central_counter(struct oshmem_group_t *group, group 31 oshmem/mca/scoll/basic/scoll_basic_reduce.c static int _algorithm_tournament(struct oshmem_group_t *group, group 38 oshmem/mca/scoll/basic/scoll_basic_reduce.c static int _algorithm_recursive_doubling(struct oshmem_group_t *group, group 45 oshmem/mca/scoll/basic/scoll_basic_reduce.c static int _algorithm_linear(struct oshmem_group_t *group, group 52 oshmem/mca/scoll/basic/scoll_basic_reduce.c static int _algorithm_log(struct oshmem_group_t *group, group 60 oshmem/mca/scoll/basic/scoll_basic_reduce.c int mca_scoll_basic_reduce(struct oshmem_group_t *group, group 72 oshmem/mca/scoll/basic/scoll_basic_reduce.c if (!group) { group 78 oshmem/mca/scoll/basic/scoll_basic_reduce.c if ((rc == OSHMEM_SUCCESS) && oshmem_proc_group_is_member(group)) { group 92 oshmem/mca/scoll/basic/scoll_basic_reduce.c rc = _algorithm_central_counter(group, group 103 oshmem/mca/scoll/basic/scoll_basic_reduce.c rc = _algorithm_tournament(group, group 114 oshmem/mca/scoll/basic/scoll_basic_reduce.c rc = _algorithm_recursive_doubling(group, group 125 oshmem/mca/scoll/basic/scoll_basic_reduce.c rc = _algorithm_linear(group, group 136 oshmem/mca/scoll/basic/scoll_basic_reduce.c rc = _algorithm_log(group, group 147 oshmem/mca/scoll/basic/scoll_basic_reduce.c rc = _algorithm_central_counter(group, group 164 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe); group 179 oshmem/mca/scoll/basic/scoll_basic_reduce.c static int _algorithm_central_counter(struct oshmem_group_t *group, group 189 oshmem/mca/scoll/basic/scoll_basic_reduce.c int PE_root = oshmem_proc_pe(group->proc_array[0]); group 191 oshmem/mca/scoll/basic/scoll_basic_reduce.c SCOLL_VERBOSE(12, "[#%d] Reduce algorithm: Central Counter", group->my_pe); group 193 oshmem/mca/scoll/basic/scoll_basic_reduce.c if (PE_root == group->my_pe) { group 203 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe); group 204 oshmem/mca/scoll/basic/scoll_basic_reduce.c for (i = 0; (i < group->proc_count) && (rc == OSHMEM_SUCCESS); group 207 oshmem/mca/scoll/basic/scoll_basic_reduce.c pe_cur = oshmem_proc_pe(group->proc_array[i]); group 209 oshmem/mca/scoll/basic/scoll_basic_reduce.c if (pe_cur == group->my_pe) group 214 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe, (int)nlong, pe_cur); group 238 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe, PE_root); group 239 oshmem/mca/scoll/basic/scoll_basic_reduce.c rc = BCAST_FUNC(group, group 252 oshmem/mca/scoll/basic/scoll_basic_reduce.c static int _algorithm_tournament(struct oshmem_group_t *group, group 262 oshmem/mca/scoll/basic/scoll_basic_reduce.c int exit_flag = group->proc_count - 1; group 264 oshmem/mca/scoll/basic/scoll_basic_reduce.c int my_id = oshmem_proc_group_find_id(group, group->my_pe); group 268 oshmem/mca/scoll/basic/scoll_basic_reduce.c int PE_root = oshmem_proc_pe(group->proc_array[0]); group 270 oshmem/mca/scoll/basic/scoll_basic_reduce.c SCOLL_VERBOSE(12, "[#%d] Reduce algorithm: Tournament", group->my_pe); group 271 oshmem/mca/scoll/basic/scoll_basic_reduce.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 292 oshmem/mca/scoll/basic/scoll_basic_reduce.c if (peer_id >= group->proc_count) group 299 oshmem/mca/scoll/basic/scoll_basic_reduce.c SCOLL_VERBOSE(14, "[#%d] round = %d wait", group->my_pe, round); group 307 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 319 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe, round, peer_pe); group 326 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe, round, peer_pe); group 330 oshmem/mca/scoll/basic/scoll_basic_reduce.c SCOLL_VERBOSE(14, "[#%d] round = %d wait", group->my_pe, round); group 340 oshmem/mca/scoll/basic/scoll_basic_reduce.c SCOLL_VERBOSE(14, "[#%d] signals to all", group->my_pe); group 346 oshmem/mca/scoll/basic/scoll_basic_reduce.c (peer_id < group->proc_count) && (rc == OSHMEM_SUCCESS); group 348 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 357 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe, PE_root); group 358 oshmem/mca/scoll/basic/scoll_basic_reduce.c rc = BCAST_FUNC(group, group 370 oshmem/mca/scoll/basic/scoll_basic_reduce.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 375 oshmem/mca/scoll/basic/scoll_basic_reduce.c static int _algorithm_recursive_doubling(struct oshmem_group_t *group, group 389 oshmem/mca/scoll/basic/scoll_basic_reduce.c int my_id = oshmem_proc_group_find_id(group, group->my_pe); group 395 oshmem/mca/scoll/basic/scoll_basic_reduce.c i = group->proc_count; group 411 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe); group 414 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe, pSync[0], floor2_proc); group 419 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 425 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe, peer_pe); group 432 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe, peer_pe); group 439 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe, peer_pe); group 443 oshmem/mca/scoll/basic/scoll_basic_reduce.c SCOLL_VERBOSE(14, "[#%d] wait", group->my_pe); group 448 oshmem/mca/scoll/basic/scoll_basic_reduce.c if ((group->proc_count - floor2_proc) > my_id) { group 451 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 457 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe, peer_pe); group 464 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe, peer_pe); group 485 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 497 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe, round, peer_pe); group 504 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe, round, peer_pe); group 509 oshmem/mca/scoll/basic/scoll_basic_reduce.c SCOLL_VERBOSE(14, "[#%d] round = %d wait", group->my_pe, round); group 524 oshmem/mca/scoll/basic/scoll_basic_reduce.c if ((group->proc_count - floor2_proc) > my_id) { group 527 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 531 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe, peer_pe); group 536 oshmem/mca/scoll/basic/scoll_basic_reduce.c SCOLL_VERBOSE(14, "[#%d] signals to #%d", group->my_pe, peer_pe); group 544 oshmem/mca/scoll/basic/scoll_basic_reduce.c SCOLL_VERBOSE(15, "[#%d] pSync[0] = %ld", group->my_pe, pSync[0]); group 549 oshmem/mca/scoll/basic/scoll_basic_reduce.c static int _algorithm_linear(struct oshmem_group_t *group, group 566 oshmem/mca/scoll/basic/scoll_basic_reduce.c rank = group->my_pe; group 567 oshmem/mca/scoll/basic/scoll_basic_reduce.c size = group->proc_count; group 569 oshmem/mca/scoll/basic/scoll_basic_reduce.c int root_pe = oshmem_proc_pe(group->proc_array[root_id]); group 571 oshmem/mca/scoll/basic/scoll_basic_reduce.c SCOLL_VERBOSE(12, "[#%d] Reduce algorithm: Basic", group->my_pe); group 595 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 612 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 637 oshmem/mca/scoll/basic/scoll_basic_reduce.c group->my_pe, root_pe); group 638 oshmem/mca/scoll/basic/scoll_basic_reduce.c rc = BCAST_FUNC(group, group 652 oshmem/mca/scoll/basic/scoll_basic_reduce.c static int _algorithm_log(struct oshmem_group_t *group, group 670 oshmem/mca/scoll/basic/scoll_basic_reduce.c int my_id = oshmem_proc_group_find_id(group, group->my_pe); group 674 oshmem/mca/scoll/basic/scoll_basic_reduce.c int root_pe = oshmem_proc_pe(group->proc_array[root_id]); group 678 oshmem/mca/scoll/basic/scoll_basic_reduce.c rank = group->my_pe; group 679 oshmem/mca/scoll/basic/scoll_basic_reduce.c size = group->proc_count; group 680 oshmem/mca/scoll/basic/scoll_basic_reduce.c dim = opal_cube_dim(group->proc_count); group 722 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 741 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); group 807 oshmem/mca/scoll/basic/scoll_basic_reduce.c rc = BCAST_FUNC(group, group 85 oshmem/mca/scoll/mpi/scoll_mpi.h int mca_scoll_mpi_barrier(struct oshmem_group_t *group, long *pSync, int alg); group 87 oshmem/mca/scoll/mpi/scoll_mpi.h int mca_scoll_mpi_broadcast(struct oshmem_group_t *group, group 96 oshmem/mca/scoll/mpi/scoll_mpi.h int mca_scoll_mpi_collect(struct oshmem_group_t *group, group 104 oshmem/mca/scoll/mpi/scoll_mpi.h int mca_scoll_mpi_reduce(struct oshmem_group_t *group, group 18 oshmem/mca/scoll/mpi/scoll_mpi_ops.c int mca_scoll_mpi_barrier(struct oshmem_group_t *group, long *pSync, int alg) group 23 oshmem/mca/scoll/mpi/scoll_mpi_ops.c mpi_module = (mca_scoll_mpi_module_t *) group->g_scoll.scoll_barrier_module; group 28 oshmem/mca/scoll/mpi/scoll_mpi_ops.c PREVIOUS_SCOLL_FN(mpi_module, barrier, group, group 35 oshmem/mca/scoll/mpi/scoll_mpi_ops.c int mca_scoll_mpi_broadcast(struct oshmem_group_t *group, group 50 oshmem/mca/scoll/mpi/scoll_mpi_ops.c mpi_module = (mca_scoll_mpi_module_t *) group->g_scoll.scoll_broadcast_module; group 51 oshmem/mca/scoll/mpi/scoll_mpi_ops.c if (group->my_pe == PE_root) { group 57 oshmem/mca/scoll/mpi/scoll_mpi_ops.c root = oshmem_proc_group_find_id(group, PE_root); group 67 oshmem/mca/scoll/mpi/scoll_mpi_ops.c PREVIOUS_SCOLL_FN(mpi_module, broadcast, group, group 90 oshmem/mca/scoll/mpi/scoll_mpi_ops.c PREVIOUS_SCOLL_FN(mpi_module, broadcast, group, group 102 oshmem/mca/scoll/mpi/scoll_mpi_ops.c int mca_scoll_mpi_collect(struct oshmem_group_t *group, group 119 oshmem/mca/scoll/mpi/scoll_mpi_ops.c mpi_module = (mca_scoll_mpi_module_t *) group->g_scoll.scoll_collect_module; group 138 oshmem/mca/scoll/mpi/scoll_mpi_ops.c PREVIOUS_SCOLL_FN(mpi_module, collect, group, group 153 oshmem/mca/scoll/mpi/scoll_mpi_ops.c PREVIOUS_SCOLL_FN(mpi_module, collect, group, group 164 oshmem/mca/scoll/mpi/scoll_mpi_ops.c PREVIOUS_SCOLL_FN(mpi_module, collect, group, group 175 oshmem/mca/scoll/mpi/scoll_mpi_ops.c disps = malloc(group->proc_count * sizeof(*disps)); group 181 oshmem/mca/scoll/mpi/scoll_mpi_ops.c recvcounts = malloc(group->proc_count * sizeof(*recvcounts)); group 195 oshmem/mca/scoll/mpi/scoll_mpi_ops.c for (i = 1; i < group->proc_count; i++) { group 212 oshmem/mca/scoll/mpi/scoll_mpi_ops.c int mca_scoll_mpi_reduce(struct oshmem_group_t *group, group 228 oshmem/mca/scoll/mpi/scoll_mpi_ops.c mpi_module = (mca_scoll_mpi_module_t *) group->g_scoll.scoll_reduce_module; group 249 oshmem/mca/scoll/mpi/scoll_mpi_ops.c PREVIOUS_SCOLL_FN(mpi_module, reduce, group, group 265 oshmem/mca/scoll/mpi/scoll_mpi_ops.c PREVIOUS_SCOLL_FN(mpi_module, reduce, group, group 116 oshmem/mca/scoll/scoll.h typedef int (*mca_scoll_base_module_barrier_fn_t)(struct oshmem_group_t *group, group 119 oshmem/mca/scoll/scoll.h typedef int (*mca_scoll_base_module_broadcast_fn_t)(struct oshmem_group_t *group, group 127 oshmem/mca/scoll/scoll.h typedef int (*mca_scoll_base_module_collect_fn_t)(struct oshmem_group_t *group, group 134 oshmem/mca/scoll/scoll.h typedef int (*mca_scoll_base_module_reduce_fn_t)(struct oshmem_group_t *group, group 142 oshmem/mca/scoll/scoll.h typedef int (*mca_scoll_base_module_alltoall_fn_t)(struct oshmem_group_t *group, group 200 oshmem/mca/scoll/scoll.h #define PREVIOUS_SCOLL_FN(module, __api, group, ...) do { \ group 201 oshmem/mca/scoll/scoll.h group->g_scoll.scoll_ ## __api ## _module = (mca_scoll_base_module_1_0_0_t*) module->previous_ ## __api ## _module; \ group 202 oshmem/mca/scoll/scoll.h rc = module->previous_ ## __api (group, __VA_ARGS__); \ group 203 oshmem/mca/scoll/scoll.h group->g_scoll.scoll_ ## __api ## _module = (mca_scoll_base_module_1_0_0_t*) module; \ group 62 oshmem/proc/proc.c static void oshmem_proc_group_destroy_internal(oshmem_group_t* group, group 112 oshmem/proc/proc.c oshmem_group_t *group; group 117 oshmem/proc/proc.c group = (oshmem_group_t *) opal_pointer_array_get_item(&oshmem_group_array, group 119 oshmem/proc/proc.c if (NULL != group) { group 120 oshmem/proc/proc.c mca_scoll_base_group_unselect(group); group 128 oshmem/proc/proc.c oshmem_group_t *group; group 133 oshmem/proc/proc.c group = group 136 oshmem/proc/proc.c if (NULL != group) { group 138 oshmem/proc/proc.c oshmem_proc_group_destroy_internal(group, 0); group 152 oshmem/proc/proc.c oshmem_group_t* group = NULL; group 158 oshmem/proc/proc.c group = oshmem_group_cache_find(pe_start, pe_stride, pe_size); group 159 oshmem/proc/proc.c if (NULL != group) { group 160 oshmem/proc/proc.c return group; group 163 oshmem/proc/proc.c group = OBJ_NEW(oshmem_group_t); group 164 oshmem/proc/proc.c if (NULL == group) { group 176 oshmem/proc/proc.c OBJ_RELEASE(group); group 181 oshmem/proc/proc.c group->my_pe = oshmem_proc_pe(oshmem_proc_local()); group 182 oshmem/proc/proc.c group->is_member = 0; group 189 oshmem/proc/proc.c OBJ_RELEASE(group); group 199 oshmem/proc/proc.c if (oshmem_proc_pe(proc) == group->my_pe) group 200 oshmem/proc/proc.c group->is_member = 1; group 204 oshmem/proc/proc.c group->proc_array = proc_array; group 205 oshmem/proc/proc.c group->proc_count = (int) count_pe; group 206 oshmem/proc/proc.c group->ompi_comm = NULL; group 209 oshmem/proc/proc.c OBJ_CONSTRUCT(&(group->peer_list), opal_list_t); group 213 oshmem/proc/proc.c for (i = 0; i < group->proc_count; i++) { group 215 oshmem/proc/proc.c peer->name.jobid = OSHMEM_PROC_JOBID(group->proc_array[i]); group 216 oshmem/proc/proc.c peer->name.vpid = OSHMEM_PROC_VPID(group->proc_array[i]); group 217 oshmem/proc/proc.c opal_list_append(&(group->peer_list), &peer->super); group 220 oshmem/proc/proc.c group->id = opal_pointer_array_add(&oshmem_group_array, group); group 222 oshmem/proc/proc.c memset(&group->g_scoll, 0, sizeof(mca_scoll_base_group_scoll_t)); group 224 oshmem/proc/proc.c if (OSHMEM_SUCCESS != mca_scoll_base_select(group)) { group 227 oshmem/proc/proc.c oshmem_proc_group_destroy_internal(group, 0); group 232 oshmem/proc/proc.c if (OSHMEM_SUCCESS != oshmem_group_cache_insert(group, pe_start, group 234 oshmem/proc/proc.c oshmem_proc_group_destroy_internal(group, 1); group 240 oshmem/proc/proc.c return group; group 244 oshmem/proc/proc.c oshmem_proc_group_destroy_internal(oshmem_group_t* group, int scoll_unselect) group 246 oshmem/proc/proc.c if (NULL == group) { group 251 oshmem/proc/proc.c mca_scoll_base_group_unselect(group); group 255 oshmem/proc/proc.c if (group->proc_array) { group 256 oshmem/proc/proc.c free(group->proc_array); group 263 oshmem/proc/proc.c while (NULL != (item = opal_list_remove_first(&(group->peer_list)))) { group 267 oshmem/proc/proc.c OBJ_DESTRUCT(&(group->peer_list)); group 274 oshmem/proc/proc.c group->id)) { group 275 oshmem/proc/proc.c opal_pointer_array_set_item(&oshmem_group_array, group->id, NULL ); group 278 oshmem/proc/proc.c OBJ_RELEASE(group); group 281 oshmem/proc/proc.c void oshmem_proc_group_destroy(oshmem_group_t* group) group 286 oshmem/proc/proc.c oshmem_proc_group_destroy_internal(group, 1); group 213 oshmem/proc/proc.h oshmem_group_t *group; group 215 oshmem/proc/proc.h group = oshmem_proc_group_create(pe_start, pe_stride, pe_size); group 216 oshmem/proc/proc.h if (NULL == group) { group 219 oshmem/proc/proc.h return group; group 233 oshmem/proc/proc.h OSHMEM_DECLSPEC void oshmem_proc_group_destroy(oshmem_group_t* group); group 240 oshmem/proc/proc.h static inline ompi_proc_t *oshmem_proc_group_find(oshmem_group_t* group, group 246 oshmem/proc/proc.h if (OPAL_LIKELY(group)) { group 247 oshmem/proc/proc.h if (OPAL_LIKELY(group == oshmem_group_all)) { group 249 oshmem/proc/proc.h proc = group->proc_array[pe]; group 251 oshmem/proc/proc.h for (i = 0; i < group->proc_count; i++) { group 252 oshmem/proc/proc.h if (pe == oshmem_proc_pe(group->proc_array[i])) { group 253 oshmem/proc/proc.h proc = group->proc_array[i]; group 269 oshmem/proc/proc.h static inline int oshmem_proc_group_find_id(oshmem_group_t* group, int pe) group 274 oshmem/proc/proc.h if (group) { group 275 oshmem/proc/proc.h for (i = 0; i < group->proc_count; i++) { group 276 oshmem/proc/proc.h if (pe == oshmem_proc_pe(group->proc_array[i])) { group 286 oshmem/proc/proc.h static inline int oshmem_proc_group_is_member(oshmem_group_t *group) group 288 oshmem/proc/proc.h return group->is_member; group 46 oshmem/proc/proc_group_cache.c oshmem_group_t *group; group 59 oshmem/proc/proc_group_cache.c sizeof(key), (void **)&group)) { group 64 oshmem/proc/proc_group_cache.c return group; group 67 oshmem/proc/proc_group_cache.c int oshmem_group_cache_insert(oshmem_group_t *group, int pe_start, group 81 oshmem/proc/proc_group_cache.c sizeof(key), group)) { group 35 oshmem/proc/proc_group_cache.h int oshmem_group_cache_insert(oshmem_group_t *group, int pe_start, group 81 oshmem/shmem/c/shmem_alltoall.c oshmem_group_t* group; group 84 oshmem/shmem/c/shmem_alltoall.c group = oshmem_proc_group_create_nofail(PE_start, 1<<logPE_stride, PE_size); group 86 oshmem/shmem/c/shmem_alltoall.c rc = group->g_scoll.scoll_alltoall(group, group 95 oshmem/shmem/c/shmem_alltoall.c oshmem_proc_group_destroy(group); group 33 oshmem/shmem/c/shmem_barrier.c oshmem_group_t* group; group 43 oshmem/shmem/c/shmem_barrier.c group = oshmem_proc_group_create_nofail(PE_start, 1<<logPE_stride, PE_size); group 45 oshmem/shmem/c/shmem_barrier.c rc = group->g_scoll.scoll_barrier(group, pSync, SCOLL_DEFAULT_ALG); group 47 oshmem/shmem/c/shmem_barrier.c oshmem_proc_group_destroy(group); group 61 oshmem/shmem/c/shmem_broadcast.c oshmem_group_t *group; group 65 oshmem/shmem/c/shmem_broadcast.c group = oshmem_proc_group_create_nofail(PE_start, 1 << logPE_stride, PE_size); group 66 oshmem/shmem/c/shmem_broadcast.c if (PE_root >= group->proc_count) { group 72 oshmem/shmem/c/shmem_broadcast.c PE_root = oshmem_proc_pe(group->proc_array[PE_root]); group 75 oshmem/shmem/c/shmem_broadcast.c rc = group->g_scoll.scoll_broadcast(group, group 84 oshmem/shmem/c/shmem_broadcast.c oshmem_proc_group_destroy(group); group 61 oshmem/shmem/c/shmem_collect.c oshmem_group_t *group; group 64 oshmem/shmem/c/shmem_collect.c group = oshmem_proc_group_create_nofail(PE_start, 1<<logPE_stride, PE_size); group 66 oshmem/shmem/c/shmem_collect.c rc = group->g_scoll.scoll_collect(group, group 73 oshmem/shmem/c/shmem_collect.c oshmem_proc_group_destroy(group); group 40 oshmem/shmem/c/shmem_reduce.c oshmem_group_t* group = NULL; \ group 47 oshmem/shmem/c/shmem_reduce.c group = oshmem_proc_group_create_nofail(PE_start, 1<<logPE_stride, PE_size); \ group 52 oshmem/shmem/c/shmem_reduce.c rc = group->g_scoll.scoll_reduce( \ group 53 oshmem/shmem/c/shmem_reduce.c group, \ group 62 oshmem/shmem/c/shmem_reduce.c oshmem_proc_group_destroy(group); \ group 33 oshmem/shmem/c/shmem_sync.c oshmem_group_t* group; group 43 oshmem/shmem/c/shmem_sync.c group = oshmem_proc_group_create_nofail(PE_start, 1<<logPE_stride, PE_size); group 45 oshmem/shmem/c/shmem_sync.c rc = group->g_scoll.scoll_barrier(group, pSync, SCOLL_DEFAULT_ALG); group 47 oshmem/shmem/c/shmem_sync.c oshmem_proc_group_destroy(group); group 70 oshmem/shmem/fortran/shmem_alltoall_f.c oshmem_group_t *group;\ group 72 oshmem/shmem/fortran/shmem_alltoall_f.c group = oshmem_proc_group_create_nofail(OMPI_FINT_2_INT(*PE_start), \ group 78 oshmem/shmem/fortran/shmem_alltoall_f.c rc = group->g_scoll.scoll_alltoall( group, \ group 86 oshmem/shmem/fortran/shmem_alltoall_f.c oshmem_proc_group_destroy(group);\ group 101 oshmem/shmem/fortran/shmem_alltoall_f.c oshmem_group_t *group;\ group 103 oshmem/shmem/fortran/shmem_alltoall_f.c group = oshmem_proc_group_create_nofail(OMPI_FINT_2_INT(*PE_start), \ group 109 oshmem/shmem/fortran/shmem_alltoall_f.c rc = group->g_scoll.scoll_alltoall( group, \ group 117 oshmem/shmem/fortran/shmem_alltoall_f.c oshmem_proc_group_destroy(group);\ group 62 oshmem/shmem/fortran/shmem_and_to_all_f.c oshmem_group_t *group;\ group 64 oshmem/shmem/fortran/shmem_and_to_all_f.c group = oshmem_proc_group_create_nofail(OMPI_FINT_2_INT(*PE_start), \ group 71 oshmem/shmem/fortran/shmem_and_to_all_f.c rc = group->g_scoll.scoll_reduce(group, \ group 78 oshmem/shmem/fortran/shmem_and_to_all_f.c oshmem_proc_group_destroy(group);\ group 71 oshmem/shmem/fortran/shmem_broadcast_f.c oshmem_group_t *group;\ group 78 oshmem/shmem/fortran/shmem_broadcast_f.c group = oshmem_proc_group_create_nofail(OMPI_FINT_2_INT(*PE_start), \ group 81 oshmem/shmem/fortran/shmem_broadcast_f.c if (OMPI_FINT_2_INT(*PE_root) >= group->proc_count)\ group 88 oshmem/shmem/fortran/shmem_broadcast_f.c rel_PE_root = oshmem_proc_pe(group->proc_array[OMPI_FINT_2_INT(*PE_root)]);\ group 91 oshmem/shmem/fortran/shmem_broadcast_f.c rc = group->g_scoll.scoll_broadcast( group, \ group 100 oshmem/shmem/fortran/shmem_broadcast_f.c oshmem_proc_group_destroy(group);\ group 106 oshmem/shmem/fortran/shmem_collect_f.c oshmem_group_t *group;\ group 108 oshmem/shmem/fortran/shmem_collect_f.c group = oshmem_proc_group_create_nofail(OMPI_FINT_2_INT(*PE_start), \ group 113 oshmem/shmem/fortran/shmem_collect_f.c rc = group->g_scoll.scoll_collect( group, \ group 119 oshmem/shmem/fortran/shmem_collect_f.c oshmem_proc_group_destroy(group);\ group 89 oshmem/shmem/fortran/shmem_max_to_all_f.c oshmem_group_t *group;\ group 91 oshmem/shmem/fortran/shmem_max_to_all_f.c group = oshmem_proc_group_create_nofail(OMPI_FINT_2_INT(*PE_start),\ group 97 oshmem/shmem/fortran/shmem_max_to_all_f.c rc = group->g_scoll.scoll_reduce( group,\ group 104 oshmem/shmem/fortran/shmem_max_to_all_f.c oshmem_proc_group_destroy(group);\ group 90 oshmem/shmem/fortran/shmem_min_to_all_f.c oshmem_group_t *group;\ group 92 oshmem/shmem/fortran/shmem_min_to_all_f.c group = oshmem_proc_group_create_nofail(OMPI_FINT_2_INT(*PE_start),\ group 99 oshmem/shmem/fortran/shmem_min_to_all_f.c rc = group->g_scoll.scoll_reduce( group,\ group 106 oshmem/shmem/fortran/shmem_min_to_all_f.c oshmem_proc_group_destroy(group);\ group 62 oshmem/shmem/fortran/shmem_or_to_all_f.c oshmem_group_t *group;\ group 64 oshmem/shmem/fortran/shmem_or_to_all_f.c group = oshmem_proc_group_create_nofail(OMPI_FINT_2_INT(*PE_start),\ group 70 oshmem/shmem/fortran/shmem_or_to_all_f.c rc = group->g_scoll.scoll_reduce( group,\ group 77 oshmem/shmem/fortran/shmem_or_to_all_f.c oshmem_proc_group_destroy(group);\ group 108 oshmem/shmem/fortran/shmem_prod_to_all_f.c oshmem_group_t *group;\ group 110 oshmem/shmem/fortran/shmem_prod_to_all_f.c group = oshmem_proc_group_create_nofail(OMPI_FINT_2_INT(*PE_start),\ group 116 oshmem/shmem/fortran/shmem_prod_to_all_f.c rc = group->g_scoll.scoll_reduce( group,\ group 123 oshmem/shmem/fortran/shmem_prod_to_all_f.c oshmem_proc_group_destroy(group);\ group 107 oshmem/shmem/fortran/shmem_sum_to_all_f.c oshmem_group_t *group;\ group 109 oshmem/shmem/fortran/shmem_sum_to_all_f.c group = oshmem_proc_group_create_nofail(OMPI_FINT_2_INT(*PE_start),\ group 115 oshmem/shmem/fortran/shmem_sum_to_all_f.c rc = group->g_scoll.scoll_reduce( group,\ group 122 oshmem/shmem/fortran/shmem_sum_to_all_f.c oshmem_proc_group_destroy(group);\ group 80 oshmem/shmem/fortran/shmem_xor_to_all_f.c oshmem_group_t *group;\ group 82 oshmem/shmem/fortran/shmem_xor_to_all_f.c group = oshmem_proc_group_create_nofail(OMPI_FINT_2_INT(*PE_start), \ group 89 oshmem/shmem/fortran/shmem_xor_to_all_f.c rc = group->g_scoll.scoll_reduce( group,\ group 96 oshmem/shmem/fortran/shmem_xor_to_all_f.c oshmem_proc_group_destroy(group);\