peer_id 382 ompi/communicator/communicator.h static inline struct ompi_proc_t* ompi_comm_peer_lookup(ompi_communicator_t* comm, int peer_id) peer_id 385 ompi/communicator/communicator.h if(peer_id >= comm->c_remote_group->grp_proc_count) { peer_id 386 ompi/communicator/communicator.h opal_output(0, "ompi_comm_peer_lookup: invalid peer index (%d)", peer_id); peer_id 391 ompi/communicator/communicator.h return ompi_group_peer_lookup(comm->c_remote_group,peer_id); peer_id 394 ompi/communicator/communicator.h static inline bool ompi_comm_peer_invalid(ompi_communicator_t* comm, int peer_id) peer_id 396 ompi/communicator/communicator.h if(peer_id < 0 || peer_id >= comm->c_remote_group->grp_proc_count) { peer_id 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) peer_id 342 ompi/group/group.h if (peer_id >= group->grp_proc_count) { peer_id 343 ompi/group/group.h opal_output(0, "ompi_group_dense_lookup: invalid peer index (%d)", peer_id); peer_id 348 ompi/group/group.h proc = group->grp_proc_pointers[peer_id]; peer_id 359 ompi/group/group.h if (opal_atomic_compare_exchange_strong_ptr ((opal_atomic_intptr_t *)(group->grp_proc_pointers + peer_id), peer_id 413 ompi/group/group.h static inline struct ompi_proc_t* ompi_group_peer_lookup(ompi_group_t *group, int peer_id) peer_id 415 ompi/group/group.h return ompi_group_get_proc_ptr (group, peer_id, true); peer_id 418 ompi/group/group.h static inline struct ompi_proc_t *ompi_group_peer_lookup_existing (ompi_group_t *group, int peer_id) peer_id 420 ompi/group/group.h return ompi_group_get_proc_ptr (group, peer_id, false); peer_id 64 ompi/group/group_plist.c static struct ompi_proc_t *ompi_group_dense_lookup_raw (ompi_group_t *group, const int peer_id) peer_id 66 ompi/group/group_plist.c if (OPAL_UNLIKELY(ompi_proc_is_sentinel (group->grp_proc_pointers[peer_id]))) { peer_id 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])); peer_id 71 ompi/group/group_plist.c group->grp_proc_pointers[peer_id] = proc; peer_id 73 ompi/group/group_plist.c OBJ_RETAIN(group->grp_proc_pointers[peer_id]); peer_id 77 ompi/group/group_plist.c return group->grp_proc_pointers[peer_id]; peer_id 312 ompi/mca/osc/rdma/osc_rdma.h static inline ompi_osc_rdma_peer_t *ompi_osc_module_get_peer (ompi_osc_rdma_module_t *module, int peer_id) peer_id 316 ompi/mca/osc/rdma/osc_rdma.h (void) opal_hash_table_get_value_uint32 (&module->peer_hash, peer_id, (void **) &peer); peer_id 320 ompi/mca/osc/rdma/osc_rdma.h return module->peer_array[peer_id]; peer_id 329 ompi/mca/osc/rdma/osc_rdma.h static inline ompi_osc_rdma_peer_t *ompi_osc_rdma_module_peer (ompi_osc_rdma_module_t *module, int peer_id) peer_id 333 ompi/mca/osc/rdma/osc_rdma.h peer = ompi_osc_module_get_peer (module, peer_id); peer_id 338 ompi/mca/osc/rdma/osc_rdma.h return ompi_osc_rdma_peer_lookup (module, peer_id); peer_id 36 ompi/mca/osc/rdma/osc_rdma_peer.c struct mca_btl_base_endpoint_t *ompi_osc_rdma_peer_btl_endpoint (struct ompi_osc_rdma_module_t *module, int peer_id) peer_id 38 ompi/mca/osc/rdma/osc_rdma_peer.c ompi_proc_t *proc = ompi_comm_peer_lookup (module->comm, peer_id); peer_id 57 ompi/mca/osc/rdma/osc_rdma_peer.c int ompi_osc_rdma_new_peer (struct ompi_osc_rdma_module_t *module, int peer_id, ompi_osc_rdma_peer_t **peer_out) { peer_id 63 ompi/mca/osc/rdma/osc_rdma_peer.c endpoint = ompi_osc_rdma_peer_btl_endpoint (module, peer_id); peer_id 65 ompi/mca/osc/rdma/osc_rdma_peer.c peer_id == ompi_comm_rank (module->comm)))) { peer_id 79 ompi/mca/osc/rdma/osc_rdma_peer.c peer->rank = peer_id; peer_id 242 ompi/mca/osc/rdma/osc_rdma_peer.c static struct ompi_osc_rdma_peer_t *ompi_osc_rdma_peer_lookup_internal (struct ompi_osc_rdma_module_t *module, int peer_id) peer_id 247 ompi/mca/osc/rdma/osc_rdma_peer.c OSC_RDMA_VERBOSE(MCA_BASE_VERBOSE_DEBUG, "looking up peer data for rank %d", peer_id); peer_id 249 ompi/mca/osc/rdma/osc_rdma_peer.c peer = ompi_osc_module_get_peer (module, peer_id); peer_id 254 ompi/mca/osc/rdma/osc_rdma_peer.c ret = ompi_osc_rdma_new_peer (module, peer_id, &peer); peer_id 278 ompi/mca/osc/rdma/osc_rdma_peer.c struct ompi_osc_rdma_peer_t *ompi_osc_rdma_peer_lookup (struct ompi_osc_rdma_module_t *module, int peer_id) peer_id 283 ompi/mca/osc/rdma/osc_rdma_peer.c peer = ompi_osc_rdma_peer_lookup_internal (module, peer_id); peer_id 151 ompi/mca/osc/rdma/osc_rdma_peer.h int ompi_osc_rdma_new_peer (struct ompi_osc_rdma_module_t *module, int peer_id, ompi_osc_rdma_peer_t **peer_out); peer_id 162 ompi/mca/osc/rdma/osc_rdma_peer.h struct ompi_osc_rdma_peer_t *ompi_osc_rdma_peer_lookup (struct ompi_osc_rdma_module_t *module, int peer_id); peer_id 173 ompi/mca/osc/rdma/osc_rdma_peer.h struct mca_btl_base_endpoint_t *ompi_osc_rdma_peer_btl_endpoint (struct ompi_osc_rdma_module_t *module, int peer_id); peer_id 212 oshmem/mca/scoll/basic/scoll_basic_barrier.c int peer_id = 0; peer_id 224 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_id = my_id ^ (1 << round); peer_id 231 oshmem/mca/scoll/basic/scoll_basic_barrier.c if (peer_id >= group->proc_count) peer_id 234 oshmem/mca/scoll/basic/scoll_basic_barrier.c if (my_id < peer_id) { peer_id 235 oshmem/mca/scoll/basic/scoll_basic_barrier.c pSync[0] = peer_id; peer_id 241 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 254 oshmem/mca/scoll/basic/scoll_basic_barrier.c value = peer_id; peer_id 260 oshmem/mca/scoll/basic/scoll_basic_barrier.c rc = MCA_ATOMIC_CALL(cswap((void*)pSync, (void*)&value, (const void*)&my_id, (const void*)&peer_id, sizeof(value), peer_pe)); peer_id 284 oshmem/mca/scoll/basic/scoll_basic_barrier.c for (peer_id = 1; peer_id 285 oshmem/mca/scoll/basic/scoll_basic_barrier.c (peer_id < group->proc_count) && (rc == OSHMEM_SUCCESS); peer_id 286 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_id++) { peer_id 287 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 314 oshmem/mca/scoll/basic/scoll_basic_barrier.c int peer_id = 0; peer_id 335 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_id = my_id - floor2_proc; peer_id 336 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 359 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_id = my_id + floor2_proc; peer_id 360 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 374 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_id = my_id ^ (1 << round); peer_id 380 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 422 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_id = my_id + floor2_proc; peer_id 423 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 450 oshmem/mca/scoll/basic/scoll_basic_barrier.c int peer_id = 0; peer_id 464 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_id = (my_id + (1 << round)) % group->proc_count; peer_id 466 oshmem/mca/scoll/basic/scoll_basic_barrier.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 188 oshmem/mca/scoll/basic/scoll_basic_broadcast.c int peer_id = 0; peer_id 231 oshmem/mca/scoll/basic/scoll_basic_broadcast.c peer_id = vrank | mask; peer_id 233 oshmem/mca/scoll/basic/scoll_basic_broadcast.c if (peer_id < group->proc_count) { peer_id 235 oshmem/mca/scoll/basic/scoll_basic_broadcast.c peer_id = (peer_id + root_id) % group->proc_count; peer_id 236 oshmem/mca/scoll/basic/scoll_basic_broadcast.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 222 oshmem/mca/scoll/basic/scoll_basic_collect.c int peer_id = 0; peer_id 241 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_id = my_id ^ (1 << round); peer_id 248 oshmem/mca/scoll/basic/scoll_basic_collect.c if (peer_id >= group->proc_count) peer_id 251 oshmem/mca/scoll/basic/scoll_basic_collect.c if (my_id < peer_id) { peer_id 252 oshmem/mca/scoll/basic/scoll_basic_collect.c pSync[0] = peer_id; peer_id 258 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 278 oshmem/mca/scoll/basic/scoll_basic_collect.c value = peer_id; peer_id 294 oshmem/mca/scoll/basic/scoll_basic_collect.c for (peer_id = 1; peer_id 295 oshmem/mca/scoll/basic/scoll_basic_collect.c (peer_id < group->proc_count) && (rc == OSHMEM_SUCCESS); peer_id 296 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_id++) { peer_id 297 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 333 oshmem/mca/scoll/basic/scoll_basic_collect.c int peer_id = 0; peer_id 341 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_id = (my_id + 1) % group->proc_count; peer_id 342 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 394 oshmem/mca/scoll/basic/scoll_basic_collect.c int peer_id = 0; peer_id 422 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_id = my_id - floor2_proc; peer_id 423 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 452 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_id = my_id + floor2_proc; peer_id 453 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 467 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_id = my_id ^ (1 << round); peer_id 473 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 509 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_id = my_id + floor2_proc; peer_id 510 oshmem/mca/scoll/basic/scoll_basic_collect.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 265 oshmem/mca/scoll/basic/scoll_basic_reduce.c int peer_id = 0; peer_id 285 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_id = my_id ^ (1 << round); peer_id 292 oshmem/mca/scoll/basic/scoll_basic_reduce.c if (peer_id >= group->proc_count) peer_id 295 oshmem/mca/scoll/basic/scoll_basic_reduce.c if (my_id < peer_id) { peer_id 296 oshmem/mca/scoll/basic/scoll_basic_reduce.c pSync[0] = peer_id; peer_id 307 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 327 oshmem/mca/scoll/basic/scoll_basic_reduce.c value = peer_id; peer_id 345 oshmem/mca/scoll/basic/scoll_basic_reduce.c for (peer_id = 1; peer_id 346 oshmem/mca/scoll/basic/scoll_basic_reduce.c (peer_id < group->proc_count) && (rc == OSHMEM_SUCCESS); peer_id 347 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_id++) { peer_id 348 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 390 oshmem/mca/scoll/basic/scoll_basic_reduce.c int peer_id = 0; peer_id 418 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_id = my_id - floor2_proc; peer_id 419 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 450 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_id = my_id + floor2_proc; peer_id 451 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 479 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_id = my_id ^ (1 << round); peer_id 485 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 526 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_id = my_id + floor2_proc; peer_id 527 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 562 oshmem/mca/scoll/basic/scoll_basic_reduce.c int peer_id = 0; peer_id 594 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_id = size - 1; peer_id 595 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 611 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_id = i; peer_id 612 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 671 oshmem/mca/scoll/basic/scoll_basic_reduce.c int peer_id = 0; peer_id 720 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_id = vrank & ~mask; peer_id 721 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_id = (peer_id + root_id) % size; peer_id 722 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]); peer_id 736 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_id = vrank | mask; peer_id 737 oshmem/mca/scoll/basic/scoll_basic_reduce.c if (peer_id >= size) { peer_id 740 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_id = (peer_id + root_id) % size; peer_id 741 oshmem/mca/scoll/basic/scoll_basic_reduce.c peer_pe = oshmem_proc_pe(group->proc_array[peer_id]);