my_rank 67 ompi/communicator/comm.c int my_rank, my_rank 1938 ompi/communicator/comm.c int my_rank, my_rank 1963 ompi/communicator/comm.c comm->c_local_group->grp_my_rank = my_rank; my_rank 1964 ompi/communicator/comm.c comm->c_my_rank = my_rank; my_rank 1966 ompi/communicator/comm.c if( MPI_UNDEFINED != my_rank ) { my_rank 88 ompi/mca/coll/hcoll/coll_hcoll_rte.c static int my_rank (rte_grp_handle_t grp_h); my_rank 129 ompi/mca/coll/hcoll/coll_hcoll_rte.c hcoll_rte_functions.rte_my_rank_fn = my_rank; my_rank 301 ompi/mca/coll/hcoll/coll_hcoll_rte.c int my_rank = ompi_comm_rank(comm); my_rank 302 ompi/mca/coll/hcoll/coll_hcoll_rte.c ompi_proc_t *my_proc = ompi_comm_peer_lookup(comm,my_rank); my_rank 304 ompi/mca/coll/hcoll/coll_hcoll_rte.c ec_handle->rank = my_rank; my_rank 26 ompi/mca/coll/monitoring/coll_monitoring_allgather.c const int my_rank = ompi_comm_rank(comm); my_rank 32 ompi/mca/coll/monitoring/coll_monitoring_allgather.c if( i == my_rank ) continue; /* No communication for self */ my_rank 55 ompi/mca/coll/monitoring/coll_monitoring_allgather.c const int my_rank = ompi_comm_rank(comm); my_rank 61 ompi/mca/coll/monitoring/coll_monitoring_allgather.c if( my_rank == i ) continue; /* No communication for self */ my_rank 26 ompi/mca/coll/monitoring/coll_monitoring_allgatherv.c const int my_rank = ompi_comm_rank(comm); my_rank 32 ompi/mca/coll/monitoring/coll_monitoring_allgatherv.c if( my_rank == i ) continue; /* No communication for self */ my_rank 55 ompi/mca/coll/monitoring/coll_monitoring_allgatherv.c const int my_rank = ompi_comm_rank(comm); my_rank 61 ompi/mca/coll/monitoring/coll_monitoring_allgatherv.c if( my_rank == i ) continue; /* No communication for self */ my_rank 26 ompi/mca/coll/monitoring/coll_monitoring_allreduce.c const int my_rank = ompi_comm_rank(comm); my_rank 32 ompi/mca/coll/monitoring/coll_monitoring_allreduce.c if( my_rank == i ) continue; /* No communication for self */ my_rank 54 ompi/mca/coll/monitoring/coll_monitoring_allreduce.c const int my_rank = ompi_comm_rank(comm); my_rank 60 ompi/mca/coll/monitoring/coll_monitoring_allreduce.c if( my_rank == i ) continue; /* No communication for self */ my_rank 24 ompi/mca/coll/monitoring/coll_monitoring_alltoall.c const int my_rank = ompi_comm_rank(comm); my_rank 30 ompi/mca/coll/monitoring/coll_monitoring_alltoall.c if( my_rank == i ) continue; /* No communication for self */ my_rank 53 ompi/mca/coll/monitoring/coll_monitoring_alltoall.c const int my_rank = ompi_comm_rank(comm); my_rank 59 ompi/mca/coll/monitoring/coll_monitoring_alltoall.c if( my_rank == i ) continue; /* No communication for self */ my_rank 26 ompi/mca/coll/monitoring/coll_monitoring_alltoallv.c const int my_rank = ompi_comm_rank(comm); my_rank 30 ompi/mca/coll/monitoring/coll_monitoring_alltoallv.c if( my_rank == i ) continue; /* No communication for self */ my_rank 58 ompi/mca/coll/monitoring/coll_monitoring_alltoallv.c const int my_rank = ompi_comm_rank(comm); my_rank 62 ompi/mca/coll/monitoring/coll_monitoring_alltoallv.c if( my_rank == i ) continue; /* No communication for self */ my_rank 28 ompi/mca/coll/monitoring/coll_monitoring_alltoallw.c const int my_rank = ompi_comm_rank(comm); my_rank 31 ompi/mca/coll/monitoring/coll_monitoring_alltoallw.c if( my_rank == i ) continue; /* No communication for self */ my_rank 60 ompi/mca/coll/monitoring/coll_monitoring_alltoallw.c const int my_rank = ompi_comm_rank(comm); my_rank 63 ompi/mca/coll/monitoring/coll_monitoring_alltoallw.c if( my_rank == i ) continue; /* No communication for self */ my_rank 21 ompi/mca/coll/monitoring/coll_monitoring_barrier.c const int my_rank = ompi_comm_rank(comm); my_rank 23 ompi/mca/coll/monitoring/coll_monitoring_barrier.c if( my_rank == i ) continue; /* No communication for self */ my_rank 43 ompi/mca/coll/monitoring/coll_monitoring_barrier.c const int my_rank = ompi_comm_rank(comm); my_rank 45 ompi/mca/coll/monitoring/coll_monitoring_barrier.c if( my_rank == i ) continue; /* No communication for self */ my_rank 26 ompi/mca/coll/monitoring/coll_monitoring_exscan.c const int my_rank = ompi_comm_rank(comm); my_rank 30 ompi/mca/coll/monitoring/coll_monitoring_exscan.c mca_common_monitoring_coll_a2a(data_size * (comm_size - my_rank), monitoring_module->data); my_rank 31 ompi/mca/coll/monitoring/coll_monitoring_exscan.c for( i = my_rank + 1; i < comm_size; ++i ) { my_rank 53 ompi/mca/coll/monitoring/coll_monitoring_exscan.c const int my_rank = ompi_comm_rank(comm); my_rank 57 ompi/mca/coll/monitoring/coll_monitoring_exscan.c mca_common_monitoring_coll_a2a(data_size * (comm_size - my_rank), monitoring_module->data); my_rank 58 ompi/mca/coll/monitoring/coll_monitoring_exscan.c for( i = my_rank + 1; i < comm_size; ++i ) { my_rank 27 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter.c const int my_rank = ompi_comm_rank(comm); my_rank 31 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter.c if( my_rank == i ) continue; /* No communication for self */ my_rank 57 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter.c const int my_rank = ompi_comm_rank(comm); my_rank 61 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter.c if( my_rank == i ) continue; /* No communication for self */ my_rank 27 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c const int my_rank = ompi_comm_rank(comm); my_rank 32 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c if( my_rank == i ) continue; /* No communication for self */ my_rank 56 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c const int my_rank = ompi_comm_rank(comm); my_rank 61 ompi/mca/coll/monitoring/coll_monitoring_reduce_scatter_block.c if( my_rank == i ) continue; /* No communication for self */ my_rank 26 ompi/mca/coll/monitoring/coll_monitoring_scan.c const int my_rank = ompi_comm_rank(comm); my_rank 30 ompi/mca/coll/monitoring/coll_monitoring_scan.c mca_common_monitoring_coll_a2a(data_size * (comm_size - my_rank), monitoring_module->data); my_rank 31 ompi/mca/coll/monitoring/coll_monitoring_scan.c for( i = my_rank + 1; i < comm_size; ++i ) { my_rank 53 ompi/mca/coll/monitoring/coll_monitoring_scan.c const int my_rank = ompi_comm_rank(comm); my_rank 57 ompi/mca/coll/monitoring/coll_monitoring_scan.c mca_common_monitoring_coll_a2a(data_size * (comm_size - my_rank), monitoring_module->data); my_rank 58 ompi/mca/coll/monitoring/coll_monitoring_scan.c for( i = my_rank + 1; i < comm_size; ++i ) { my_rank 25 ompi/mca/coll/monitoring/coll_monitoring_scatter.c const int my_rank = ompi_comm_rank(comm); my_rank 26 ompi/mca/coll/monitoring/coll_monitoring_scatter.c if( root == my_rank ) { my_rank 33 ompi/mca/coll/monitoring/coll_monitoring_scatter.c if( my_rank == i ) continue; /* No communication for self */ my_rank 58 ompi/mca/coll/monitoring/coll_monitoring_scatter.c const int my_rank = ompi_comm_rank(comm); my_rank 59 ompi/mca/coll/monitoring/coll_monitoring_scatter.c if( root == my_rank ) { my_rank 66 ompi/mca/coll/monitoring/coll_monitoring_scatter.c if( my_rank == i ) continue; /* No communication for self */ my_rank 23 ompi/mca/coll/monitoring/coll_monitoring_scatterv.c const int my_rank = ompi_comm_rank(comm); my_rank 24 ompi/mca/coll/monitoring/coll_monitoring_scatterv.c if( root == my_rank ) { my_rank 53 ompi/mca/coll/monitoring/coll_monitoring_scatterv.c const int my_rank = ompi_comm_rank(comm); my_rank 54 ompi/mca/coll/monitoring/coll_monitoring_scatterv.c if( root == my_rank ) { my_rank 184 ompi/mca/coll/portals4/coll_portals4_gather.c int vrank = VRANK(request->u.gather.my_rank, request->u.gather.root_rank, request->u.gather.size); my_rank 188 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_comm_peer_lookup(comm, request->u.gather.my_rank), my_rank 269 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); my_rank 285 ompi/mca/coll/portals4/coll_portals4_gather.c int8_t i_am_root = (request->u.gather.my_rank == request->u.gather.root_rank); my_rank 289 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_comm_peer_lookup(comm, request->u.gather.my_rank), my_rank 311 ompi/mca/coll/portals4/coll_portals4_gather.c uint64_t gather_buf_offset = (ptrdiff_t)request->u.gather.my_rank * request->u.gather.packed_size; my_rank 318 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, request->u.gather.my_rank, my_rank 336 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, request->u.gather.my_rank, my_rank 346 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); my_rank 399 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); my_rank 450 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); my_rank 476 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); my_rank 502 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); my_rank 534 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_binomial_top enter rank %d", request->u.gather.my_rank)); my_rank 545 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.my_rank = ompi_comm_rank(comm); my_rank 550 ompi/mca/coll/portals4/coll_portals4_gather.c if ((root == request->u.gather.my_rank) && (sbuf == MPI_IN_PLACE)) { my_rank 576 ompi/mca/coll/portals4/coll_portals4_gather.c if ((root == request->u.gather.my_rank) && (sbuf == MPI_IN_PLACE)) { my_rank 577 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_offset = request->u.gather.pack_src_extent * request->u.gather.pack_src_count * request->u.gather.my_rank; my_rank 594 ompi/mca/coll/portals4/coll_portals4_gather.c vrank = VRANK(request->u.gather.my_rank, request->u.gather.root_rank, request->u.gather.size); my_rank 718 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_coll_portals4_get_peer(comm, request->u.gather.my_rank), my_rank 788 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_binomial_top exit rank %d", request->u.gather.my_rank)); my_rank 800 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); my_rank 829 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_linear_top enter rank %d", request->u.gather.my_rank)); my_rank 840 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.my_rank = ompi_comm_rank(comm); my_rank 845 ompi/mca/coll/portals4/coll_portals4_gather.c if ((root == request->u.gather.my_rank) && (sbuf == MPI_IN_PLACE)) { my_rank 871 ompi/mca/coll/portals4/coll_portals4_gather.c if ((root == request->u.gather.my_rank) && (sbuf == MPI_IN_PLACE)) { my_rank 872 ompi/mca/coll/portals4/coll_portals4_gather.c request->u.gather.pack_src_offset = request->u.gather.pack_src_extent * request->u.gather.pack_src_count * request->u.gather.my_rank; my_rank 877 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, request->u.gather.my_rank, my_rank 884 ompi/mca/coll/portals4/coll_portals4_gather.c i_am_root = (request->u.gather.my_rank == request->u.gather.root_rank); my_rank 902 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, request->u.gather.my_rank, number_of_fragment); my_rank 932 ompi/mca/coll/portals4/coll_portals4_gather.c ptl_size_t remote_offset=request->u.gather.my_rank * request->u.gather.packed_size; my_rank 938 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, request->u.gather.my_rank, my_rank 939 ompi/mca/coll/portals4/coll_portals4_gather.c remote_offset, request->u.gather.my_rank, request->u.gather.packed_size); my_rank 952 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, request->u.gather.my_rank, my_rank 1006 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_coll_portals4_get_peer(comm, request->u.gather.my_rank), my_rank 1076 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_linear_top exit rank %d", request->u.gather.my_rank)); my_rank 1086 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); my_rank 1099 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_binomial_bottom enter rank %d", request->u.gather.my_rank)); my_rank 1107 ompi/mca/coll/portals4/coll_portals4_gather.c if (request->u.gather.my_rank == request->u.gather.root_rank) { my_rank 1113 ompi/mca/coll/portals4/coll_portals4_gather.c uint64_t offset = request->u.gather.unpack_dst_extent * request->u.gather.unpack_dst_count * ((request->u.gather.my_rank + i) % request->u.gather.size); my_rank 1117 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, request->u.gather.my_rank, my_rank 1122 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_comm_peer_lookup(comm, request->u.gather.my_rank), my_rank 1142 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_binomial_bottom exit rank %d", request->u.gather.my_rank)); my_rank 1154 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); my_rank 1167 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_linear_bottom enter rank %d", request->u.gather.my_rank)); my_rank 1175 ompi/mca/coll/portals4/coll_portals4_gather.c if (request->u.gather.my_rank == request->u.gather.root_rank) { my_rank 1183 ompi/mca/coll/portals4/coll_portals4_gather.c ompi_comm_peer_lookup(comm, request->u.gather.my_rank), my_rank 1203 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra_linear_bottom exit rank %d", request->u.gather.my_rank)); my_rank 1215 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); my_rank 1279 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:gather_intra exit rank %d", request->u.gather.my_rank)); my_rank 1286 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); my_rank 1342 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:igather_intra exit rank %d", request->u.gather.my_rank)); my_rank 1349 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); my_rank 1361 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:igather_intra_fini enter rank %d", request->u.gather.my_rank)); my_rank 1375 ompi/mca/coll/portals4/coll_portals4_gather.c "coll:portals4:igather_intra_fini exit rank %d", request->u.gather.my_rank)); my_rank 1382 ompi/mca/coll/portals4/coll_portals4_gather.c __FILE__, __LINE__, line, ret, request->u.gather.my_rank); my_rank 104 ompi/mca/coll/portals4/coll_portals4_request.h int my_rank; my_rank 143 ompi/mca/coll/portals4/coll_portals4_request.h int my_rank; my_rank 38 ompi/mca/coll/portals4/coll_portals4_scatter.c int8_t i_am_root = (request->u.scatter.my_rank == request->u.scatter.root_rank); my_rank 42 ompi/mca/coll/portals4/coll_portals4_scatter.c ompi_comm_peer_lookup(comm, request->u.scatter.my_rank), my_rank 75 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, request->u.scatter.my_rank, my_rank 80 ompi/mca/coll/portals4/coll_portals4_scatter.c ompi_comm_peer_lookup(comm, request->u.scatter.my_rank), my_rank 93 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, request->u.scatter.my_rank, my_rank 106 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, request->u.scatter.my_rank, my_rank 116 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, line, ret, request->u.scatter.my_rank); my_rank 131 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:setup_scatter_handles enter rank %d", request->u.scatter.my_rank)); my_rank 141 ompi/mca/coll/portals4/coll_portals4_scatter.c request->u.scatter.my_rank, request->u.scatter.scatter_match_bits)); my_rank 170 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:setup_scatter_handles exit rank %d", request->u.scatter.my_rank)); my_rank 177 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, line, ret, request->u.scatter.my_rank); my_rank 192 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:setup_sync_handles enter rank %d", request->u.scatter.my_rank)); my_rank 202 ompi/mca/coll/portals4/coll_portals4_scatter.c request->u.scatter.my_rank, request->u.scatter.sync_match_bits)); my_rank 231 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:setup_sync_handles exit rank %d", request->u.scatter.my_rank)); my_rank 238 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, line, ret, request->u.scatter.my_rank); my_rank 249 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:cleanup_scatter_handles enter rank %d", request->u.scatter.my_rank)); my_rank 263 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:cleanup_scatter_handles exit rank %d", request->u.scatter.my_rank)); my_rank 270 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, line, ret, request->u.scatter.my_rank); my_rank 282 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:cleanup_sync_handles enter rank %d", request->u.scatter.my_rank)); my_rank 296 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:cleanup_sync_handles exit rank %d", request->u.scatter.my_rank)); my_rank 303 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, line, ptl_ret, ret, request->u.scatter.my_rank); my_rank 335 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:scatter_intra_linear_top enter rank %d", request->u.scatter.my_rank)); my_rank 346 ompi/mca/coll/portals4/coll_portals4_scatter.c request->u.scatter.my_rank = ompi_comm_rank(comm); my_rank 362 ompi/mca/coll/portals4/coll_portals4_scatter.c if ((root == request->u.scatter.my_rank) && (rbuf == MPI_IN_PLACE)) { my_rank 381 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, request->u.scatter.my_rank, my_rank 388 ompi/mca/coll/portals4/coll_portals4_scatter.c i_am_root = (request->u.scatter.my_rank == request->u.scatter.root_rank); my_rank 406 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, request->u.scatter.my_rank, number_of_fragment); my_rank 439 ompi/mca/coll/portals4/coll_portals4_scatter.c if (i == request->u.scatter.my_rank) { my_rank 449 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, request->u.scatter.my_rank, my_rank 460 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, request->u.scatter.my_rank, my_rank 526 ompi/mca/coll/portals4/coll_portals4_scatter.c ompi_coll_portals4_get_peer(comm, request->u.scatter.my_rank), my_rank 569 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:scatter_intra_linear_top exit rank %d", request->u.scatter.my_rank)); my_rank 579 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, line, ret, request->u.scatter.my_rank); my_rank 591 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:scatter_intra_linear_bottom enter rank %d", request->u.scatter.my_rank)); my_rank 606 ompi/mca/coll/portals4/coll_portals4_scatter.c ompi_comm_peer_lookup(comm, request->u.scatter.my_rank), my_rank 611 ompi/mca/coll/portals4/coll_portals4_scatter.c if (request->u.scatter.my_rank == request->u.scatter.root_rank) { my_rank 613 ompi/mca/coll/portals4/coll_portals4_scatter.c uint64_t offset = request->u.scatter.pack_src_extent * request->u.scatter.pack_src_count * request->u.scatter.my_rank; my_rank 631 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:scatter_intra_linear_bottom exit rank %d", request->u.scatter.my_rank)); my_rank 643 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, line, ret, request->u.scatter.my_rank); my_rank 694 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:scatter_intra exit rank %d", request->u.scatter.my_rank)); my_rank 701 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, line, ret, request->u.scatter.my_rank); my_rank 747 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:iscatter_intra exit rank %d", request->u.scatter.my_rank)); my_rank 754 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, line, ret, request->u.scatter.my_rank); my_rank 766 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:iscatter_intra_fini enter rank %d", request->u.scatter.my_rank)); my_rank 775 ompi/mca/coll/portals4/coll_portals4_scatter.c "coll:portals4:iscatter_intra_fini exit rank %d", request->u.scatter.my_rank)); my_rank 782 ompi/mca/coll/portals4/coll_portals4_scatter.c __FILE__, __LINE__, line, ret, request->u.scatter.my_rank); my_rank 696 ompi/mca/common/monitoring/common_monitoring.c static void mca_common_monitoring_output( FILE *pf, int my_rank, int nbprocs ) my_rank 703 ompi/mca/common/monitoring/common_monitoring.c my_rank, i, pml_data[i], pml_count[i]); my_rank 715 ompi/mca/common/monitoring/common_monitoring.c my_rank, i, filtered_pml_data[i], filtered_pml_count[i], my_rank 737 ompi/mca/common/monitoring/common_monitoring.c my_rank, i, osc_data_s[i], osc_count_s[i]); my_rank 741 ompi/mca/common/monitoring/common_monitoring.c my_rank, i, osc_data_r[i], osc_count_r[i]); my_rank 750 ompi/mca/common/monitoring/common_monitoring.c my_rank, i, coll_data[i], coll_count[i]); my_rank 67 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c int my_rank; my_rank 76 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c MPI_Comm_rank(fd->comm, &my_rank); my_rank 77 ompi/mca/io/romio321/romio/adio/common/cb_config_list.c if (my_rank != 0) { my_rank 27 ompi/mca/mtl/portals4/mtl_portals4_flowctl.h int my_rank; my_rank 444 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->my_rank, my_rank 452 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->my_rank, my_rank 518 ompi/mca/mtl/portals4/mtl_portals4_send.c pending->my_rank = comm->c_my_rank; my_rank 305 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c int my_rank = ompi_comm_rank (module->comm); my_rank 347 ompi/mca/osc/pt2pt/osc_pt2pt_active_target.c if (my_rank == rank) { my_rank 60 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c const int my_rank = ompi_comm_rank (module->comm); my_rank 61 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c ompi_osc_pt2pt_peer_t *peer = ompi_osc_pt2pt_peer_lookup (module, my_rank); my_rank 69 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c acquired = ompi_osc_pt2pt_lock_try_acquire (module, my_rank, lock_type, (uint64_t) (uintptr_t) lock); my_rank 72 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c queue_lock (module, my_rank, lock_type, (uint64_t) (uintptr_t) lock); my_rank 90 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c const int my_rank = ompi_comm_rank (module->comm); my_rank 91 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c ompi_osc_pt2pt_peer_t *peer = ompi_osc_pt2pt_peer_lookup (module, my_rank); my_rank 249 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c int my_rank = ompi_comm_rank (module->comm); my_rank 257 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c if (my_rank != target && target != -1) { my_rank 375 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c int my_rank = ompi_comm_rank (module->comm); my_rank 403 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c if (my_rank != target) { my_rank 409 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c if (my_rank == i || !ompi_osc_pt2pt_peer_locked (peer)) { my_rank 500 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c int my_rank = ompi_comm_rank (module->comm); my_rank 509 ompi/mca/osc/pt2pt/osc_pt2pt_passive_target.c if (i == my_rank) { my_rank 247 ompi/mca/osc/rdma/osc_rdma_active_target.c int my_rank = ompi_comm_rank (module->comm); my_rank 250 ompi/mca/osc/rdma/osc_rdma_active_target.c if (peer->rank == my_rank) { my_rank 251 ompi/mca/osc/rdma/osc_rdma_active_target.c ompi_osc_rdma_handle_post (module, my_rank, NULL, 0); my_rank 277 ompi/mca/osc/rdma/osc_rdma_active_target.c ret = ompi_osc_rdma_lock_btl_cswap (module, peer, target, 0, 1 + (int64_t) my_rank, &result); my_rank 283 ompi/mca/osc/rdma/osc_rdma_active_target.c 1 + (osc_rdma_counter_t) my_rank); my_rank 420 ompi/mca/osc/rdma/osc_rdma_component.c int ret, my_rank; my_rank 424 ompi/mca/osc/rdma/osc_rdma_component.c my_rank = ompi_comm_rank (module->comm); my_rank 474 ompi/mca/osc/rdma/osc_rdma_component.c ret = ompi_osc_rdma_new_peer (module, my_rank, &my_peer); my_rank 496 ompi/mca/osc/rdma/osc_rdma_component.c my_peer->state_endpoint = ompi_osc_rdma_peer_btl_endpoint (module, my_rank); my_rank 533 ompi/mca/osc/rdma/osc_rdma_component.c int my_rank = ompi_comm_rank (module->comm); my_rank 568 ompi/mca/osc/rdma/osc_rdma_component.c temp[local_rank].rank = my_rank; my_rank 711 ompi/mca/osc/rdma/osc_rdma_component.c if (my_rank == peer_rank) { my_rank 726 ompi/mca/osc/rdma/osc_rdma_component.c if (module->use_cpu_atomics && peer_rank == my_rank) { my_rank 742 ompi/mca/osc/rdma/osc_rdma_component.c if (module->use_cpu_atomics && (MPI_WIN_FLAVOR_ALLOCATE == module->flavor || peer_rank == my_rank)) { my_rank 936 ompi/mca/osc/rdma/osc_rdma_component.c int my_rank = ompi_comm_rank (module->comm); my_rank 948 ompi/mca/osc/rdma/osc_rdma_component.c temp[my_rank].node_id = module->node_id; my_rank 949 ompi/mca/osc/rdma/osc_rdma_component.c temp[my_rank].rank = ompi_comm_rank (module->shared_comm); my_rank 964 ompi/mca/osc/rdma/osc_rdma_component.c my_data->len = (osc_rdma_size_t) my_rank; my_rank 92 ompi/mca/osc/rdma/osc_rdma_dynamic.c const int my_rank = ompi_comm_rank (module->comm); my_rank 93 ompi/mca/osc/rdma/osc_rdma_dynamic.c ompi_osc_rdma_peer_t *my_peer = ompi_osc_rdma_module_peer (module, my_rank); my_rank 212 ompi/mca/osc/rdma/osc_rdma_dynamic.c const int my_rank = ompi_comm_rank (module->comm); my_rank 213 ompi/mca/osc/rdma/osc_rdma_dynamic.c ompi_osc_rdma_peer_dynamic_t *my_peer = (ompi_osc_rdma_peer_dynamic_t *) ompi_osc_rdma_module_peer (module, my_rank); my_rank 132 ompi/mca/osc/sm/osc_sm_active_target.c int my_rank = ompi_comm_rank (module->comm); my_rank 157 ompi/mca/osc/sm/osc_sm_active_target.c while (!(module->posts[my_rank][rank_byte] & rank_bit)) { my_rank 165 ompi/mca/osc/sm/osc_sm_active_target.c (void) opal_atomic_fetch_xor_64 ((opal_atomic_int64_t *) module->posts[my_rank] + rank_byte, rank_bit); my_rank 167 ompi/mca/osc/sm/osc_sm_active_target.c (void) opal_atomic_fetch_xor_32 ((opal_atomic_int32_t *) module->posts[my_rank] + rank_byte, rank_bit); my_rank 223 ompi/mca/osc/sm/osc_sm_active_target.c int my_rank = ompi_comm_rank (module->comm); my_rank 224 ompi/mca/osc/sm/osc_sm_active_target.c int my_byte = my_rank >> 6; my_rank 225 ompi/mca/osc/sm/osc_sm_active_target.c uint64_t my_bit = ((uint64_t) 1) << (my_rank & 0x3f); my_rank 32 ompi/mpiext/cr/c/checkpoint.c int my_rank; my_rank 46 ompi/mpiext/cr/c/checkpoint.c MPI_Comm_rank(comm, &my_rank); my_rank 47 ompi/mpiext/cr/c/checkpoint.c if( 0 == my_rank ) { my_rank 31 ompi/mpiext/cr/c/migrate.c int my_rank, my_size, i; my_rank 50 ompi/mpiext/cr/c/migrate.c MPI_Comm_rank(comm, &my_rank); my_rank 52 ompi/mpiext/cr/c/migrate.c if( 0 == my_rank ) { my_rank 68 ompi/mpiext/cr/c/migrate.c if( 0 == my_rank ) { my_rank 30 ompi/mpiext/cr/c/quiesce_checkpoint.c int my_rank; my_rank 44 ompi/mpiext/cr/c/quiesce_checkpoint.c MPI_Comm_rank(comm, &my_rank); my_rank 45 ompi/mpiext/cr/c/quiesce_checkpoint.c if( 0 == my_rank ) { my_rank 30 ompi/mpiext/cr/c/quiesce_end.c int my_rank; my_rank 44 ompi/mpiext/cr/c/quiesce_end.c MPI_Comm_rank(comm, &my_rank); my_rank 45 ompi/mpiext/cr/c/quiesce_end.c if( 0 == my_rank ) { my_rank 34 ompi/mpiext/cr/c/quiesce_start.c int my_rank; my_rank 48 ompi/mpiext/cr/c/quiesce_start.c MPI_Comm_rank(comm, &my_rank); my_rank 49 ompi/mpiext/cr/c/quiesce_start.c if( 0 == my_rank ) { my_rank 88 ompi/patterns/net/allreduce.c int my_rank,count_processed,count_this_stripe; my_rank 133 ompi/patterns/net/allreduce.c my_rank=0; my_rank 141 ompi/patterns/net/allreduce.c my_rank++; my_rank 156 ompi/patterns/net/allreduce.c ret=ompi_netpatterns_setup_recursive_doubling_tree_node(n_peers,my_rank,&my_exchange_node); my_rank 78 ompi/patterns/net/netpatterns.h int my_rank; my_rank 100 ompi/patterns/net/netpatterns.h int my_rank; my_rank 128 ompi/patterns/net/netpatterns.h OMPI_DECLSPEC int ompi_netpatterns_setup_narray_tree(int tree_order, int my_rank, int num_nodes, my_rank 131 ompi/patterns/net/netpatterns.h OMPI_DECLSPEC int ompi_netpatterns_setup_narray_knomial_tree( int tree_order, int my_rank, int num_nodes, my_rank 149 ompi/patterns/net/netpatterns_knomial_tree.h int my_rank, int src_rank, my_rank 158 ompi/patterns/net/netpatterns_knomial_tree.h distance = src_rank - my_rank; my_rank 181 ompi/patterns/net/netpatterns_knomial_tree.h int my_rank, int root, int radix, int size, my_rank 188 ompi/patterns/net/netpatterns_knomial_tree.h while((0 == (root - my_rank) % level) my_rank 196 ompi/patterns/net/netpatterns_knomial_tree.h return my_rank - (my_rank % level - root % level); my_rank 240 ompi/patterns/net/netpatterns_knomial_tree.h #define MCA_COMMON_NETPATTERNS_GET_NEXT_KNOMIAL_PEER(my_rank, radix, step_info, peer) \ my_rank 242 ompi/patterns/net/netpatterns_knomial_tree.h int rank_radix_base = my_rank/step_info.k_level; \ my_rank 254 ompi/patterns/net/netpatterns_knomial_tree.h step_info.k_tmp_peer = my_rank; \ my_rank 75 ompi/patterns/net/netpatterns_multinomial_tree.c tree_nodes[node_index].my_rank=node_index; my_rank 36 ompi/patterns/net/netpatterns_nary_tree.c int ompi_netpatterns_setup_narray_tree(int tree_order, int my_rank, int num_nodes, my_rank 50 ompi/patterns/net/netpatterns_nary_tree.c my_node->my_rank=my_rank; my_rank 63 ompi/patterns/net/netpatterns_nary_tree.c result=my_rank; my_rank 74 ompi/patterns/net/netpatterns_nary_tree.c if( 0 == my_rank ) { my_rank 88 ompi/patterns/net/netpatterns_nary_tree.c my_rank_in_my_level=my_rank-cum_cnt; my_rank 170 ompi/patterns/net/netpatterns_nary_tree.c if (0 != my_node->my_rank) { my_rank 176 ompi/patterns/net/netpatterns_nary_tree.c int tree_order, int my_rank, int num_nodes, my_rank 191 ompi/patterns/net/netpatterns_nary_tree.c my_node->my_rank=my_rank; my_rank 204 ompi/patterns/net/netpatterns_nary_tree.c result=my_rank; my_rank 215 ompi/patterns/net/netpatterns_nary_tree.c if( 0 == my_rank ) { my_rank 232 ompi/patterns/net/netpatterns_nary_tree.c my_rank-cum_cnt; my_rank 191 opal/mca/common/ucx/common_ucx.c size_t my_rank, size_t max_disconnect, ucp_worker_h worker) { my_rank 211 opal/mca/common/ucx/common_ucx.c n = (i + my_rank) % count; my_rank 242 opal/mca/common/ucx/common_ucx.c size_t my_rank, size_t max_disconnect, ucp_worker_h worker) my_rank 244 opal/mca/common/ucx/common_ucx.c opal_common_ucx_del_procs_nofence(procs, count, my_rank, max_disconnect, worker); my_rank 113 opal/mca/common/ucx/common_ucx.h size_t my_rank, size_t max_disconnect, ucp_worker_h worker); my_rank 115 opal/mca/common/ucx/common_ucx.h size_t my_rank, size_t max_disconnect, ucp_worker_h worker); my_rank 133 opal/mca/pmix/cray/pmix_cray_pmap_parser.c int *pmix_cray_parse_pmap(char *pmap, int my_rank, my_rank 143 opal/mca/pmix/cray/pmix_cray_pmap_parser.c *node = find_my_node(p, my_rank); my_rank 16 opal/mca/pmix/cray/pmix_cray_pmap_parser.h int *pmix_cray_parse_pmap(char *pmap, int my_rank, my_rank 16 opal/mca/pmix/pmix4x/pmix/contrib/perf_tools/pmi2.c static int my_rank, my_node; my_rank 37 opal/mca/pmix/pmix4x/pmix/contrib/perf_tools/pmi2.c my_rank = *rank; my_rank 69 opal/mca/pmix/pmix4x/pmix/contrib/perf_tools/pmi2.c *local_ranks = mca_common_pmi2_parse_pmap(pmapping, my_rank, &my_node, local_cnt); my_rank 134 opal/mca/pmix/pmix4x/pmix/contrib/perf_tools/pmi2_pmap_parser.c int *mca_common_pmi2_parse_pmap(char *pmap, int my_rank, my_rank 144 opal/mca/pmix/pmix4x/pmix/contrib/perf_tools/pmi2_pmap_parser.c *node = find_my_node(p, my_rank); my_rank 22 opal/mca/pmix/pmix4x/pmix/contrib/perf_tools/pmi2_pmap_parser.h int *mca_common_pmi2_parse_pmap(char *pmap, int my_rank, my_rank 36 opal/mca/pmix/pmix4x/pmix/test/test_cd.c int test_connect_disconnect(char *my_nspace, int my_rank) my_rank 47 opal/mca/pmix/pmix4x/pmix/test/test_cd.c TEST_ERROR(("%s:%d: Connect blocking test failed.", my_nspace, my_rank)); my_rank 50 opal/mca/pmix/pmix4x/pmix/test/test_cd.c TEST_VERBOSE(("%s:%d: Connect blocking test succeded", my_nspace, my_rank)); my_rank 54 opal/mca/pmix/pmix4x/pmix/test/test_cd.c TEST_ERROR(("%s:%d: Disconnect blocking test failed.", my_nspace, my_rank)); my_rank 57 opal/mca/pmix/pmix4x/pmix/test/test_cd.c TEST_VERBOSE(("%s:%d: Disconnect blocking test succeded.", my_nspace, my_rank)); my_rank 66 opal/mca/pmix/pmix4x/pmix/test/test_cd.c TEST_ERROR(("%s:%d: Connect non-blocking test failed.", my_nspace, my_rank)); my_rank 69 opal/mca/pmix/pmix4x/pmix/test/test_cd.c TEST_VERBOSE(("%s:%d: Connect non-blocking test succeded.", my_nspace, my_rank)); my_rank 78 opal/mca/pmix/pmix4x/pmix/test/test_cd.c TEST_ERROR(("%s:%d: Disconnect non-blocking test failed.", my_nspace, my_rank)); my_rank 81 opal/mca/pmix/pmix4x/pmix/test/test_cd.c TEST_VERBOSE(("%s:%d: Disconnect non-blocking test succeded.", my_nspace, my_rank)); my_rank 16 opal/mca/pmix/pmix4x/pmix/test/test_cd.h int test_connect_disconnect(char *my_nspace, int my_rank); my_rank 245 opal/mca/pmix/pmix4x/pmix/test/test_common.h TEST_VERBOSE(("%s:%d put key %s", my_nspace, my_rank, key)); \ my_rank 247 opal/mca/pmix/pmix4x/pmix/test/test_common.h TEST_ERROR(("%s:%d: PMIx_Put key %s failed: %d", my_nspace, my_rank, key, rc)); \ my_rank 262 opal/mca/pmix/pmix4x/pmix/test/test_common.h TEST_VERBOSE(("%s:%d want to get from %s:%d key %s", my_nspace, my_rank, ns, r, key)); \ my_rank 266 opal/mca/pmix/pmix4x/pmix/test/test_common.h TEST_ERROR(("%s:%d: PMIx_Get failed: %d from %s:%d, key %s", my_nspace, my_rank, rc, ns, r, key)); \ my_rank 276 opal/mca/pmix/pmix4x/pmix/test/test_common.h TEST_VERBOSE(("%s:%d: PMIx_Get_nb failed: %d from %s:%d, key=%s", my_nspace, my_rank, rc, ns, r, key)); \ my_rank 294 opal/mca/pmix/pmix4x/pmix/test/test_common.h my_nspace, my_rank, rc, my_nspace, r)); \ my_rank 298 opal/mca/pmix/pmix4x/pmix/test/test_common.h TEST_VERBOSE(("%s:%d: PMIx_Get returned NULL value", my_nspace, my_rank)); \ my_rank 304 opal/mca/pmix/pmix4x/pmix/test/test_common.h my_nspace, my_rank, ns, r, key, PMIX_VAL_TYPE_ ## dtype, val->type)); \ my_rank 309 opal/mca/pmix/pmix4x/pmix/test/test_common.h TEST_VERBOSE(("%s:%d: GET OF %s from %s:%d SUCCEEDED", my_nspace, my_rank, key, ns, r)); \ my_rank 345 opal/mca/pmix/pmix4x/pmix/test/test_common.h my_nspace, my_rank)); \ my_rank 65 opal/mca/pmix/pmix4x/pmix/test/test_error.c int test_error(char *my_nspace, int my_rank, test_params params) my_rank 86 opal/mca/pmix/pmix4x/pmix/test/test_error.c source.rank = my_rank; my_rank 16 opal/mca/pmix/pmix4x/pmix/test/test_error.h int test_error(char *my_nspace, int my_rank, test_params params); my_rank 27 opal/mca/pmix/pmix4x/pmix/test/test_fence.c static void add_noise(char *noise_param, char *my_nspace, pmix_rank_t my_rank) my_rank 36 opal/mca/pmix/pmix4x/pmix/test/test_fence.c (my_rank == p->proc.rank || PMIX_RANK_WILDCARD == p->proc.rank)) { my_rank 43 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_VERBOSE(("I'm %s:%d sleeping\n", my_nspace, my_rank)); my_rank 56 opal/mca/pmix/pmix4x/pmix/test/test_fence.c int test_fence(test_params params, char *my_nspace, pmix_rank_t my_rank) my_rank 70 opal/mca/pmix/pmix4x/pmix/test/test_fence.c add_noise(params.noise, my_nspace, my_rank); my_rank 87 opal/mca/pmix/pmix4x/pmix/test/test_fence.c (my_rank == p->proc.rank || PMIX_RANK_WILDCARD == p->proc.rank)) { my_rank 101 opal/mca/pmix/pmix4x/pmix/test/test_fence.c (void)snprintf(sval, 500, "%d:%s:%d", fence_num, my_nspace, my_rank); my_rank 104 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Put failed: %d", my_nspace, my_rank, rc)); my_rank 109 opal/mca/pmix/pmix4x/pmix/test/test_fence.c PUT(int, fence_num+my_rank, PMIX_GLOBAL, fence_num, put_ind++, params.use_same_keys); my_rank 111 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Put failed: %d", my_nspace, my_rank, rc)); my_rank 118 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Put failed: %d", my_nspace, my_rank, rc)); my_rank 125 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Put failed: %d", my_nspace, my_rank, rc)); my_rank 132 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Put failed: %d", my_nspace, my_rank, rc)); my_rank 139 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Commit failed: %d", my_nspace, my_rank, rc)); my_rank 157 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Fence failed: %d", my_nspace, my_rank, rc)); my_rank 170 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: Can't parse --ns-dist value in order to get ranks for namespace %s", my_nspace, my_rank, p->proc.nspace)); my_rank 192 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Get failed (%d) from %s:%d", my_nspace, my_rank, rc, p->proc.nspace, p->proc.rank)); my_rank 199 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Get failed (%d) from %s:%d", my_nspace, my_rank, rc, p->proc.nspace, p->proc.rank)); my_rank 206 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Get failed (%d) from %s:%d", my_nspace, my_rank, rc, p->proc.nspace, p->proc.rank)); my_rank 213 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Get failed (%d) from %s:%d", my_nspace, my_rank, rc, p->proc.nspace, p->proc.rank)); my_rank 220 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Get failed (%d) from %s:%d", my_nspace, my_rank, rc, p->proc.nspace, p->proc.rank)); my_rank 238 opal/mca/pmix/pmix4x/pmix/test/test_fence.c static int get_local_peers(char *my_nspace, int my_rank, pmix_rank_t **_peers, pmix_rank_t *count) my_rank 251 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Get local peer # failed: %d", my_nspace, my_rank, rc)); my_rank 255 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Get local peer # returned NULL value", my_nspace, my_rank)); my_rank 262 opal/mca/pmix/pmix4x/pmix/test/test_fence.c my_nspace, my_rank, PMIX_UINT32, val->type)); my_rank 270 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Get local peers failed: %d", my_nspace, my_rank, rc)); my_rank 275 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Get local peers returned NULL value", my_nspace, my_rank)); my_rank 283 opal/mca/pmix/pmix4x/pmix/test/test_fence.c my_nspace, my_rank, PMIX_UINT32, val->type)); my_rank 294 opal/mca/pmix/pmix4x/pmix/test/test_fence.c my_nspace, my_rank, npeers, *count, val->data.string)); my_rank 303 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: Bad peer ranks string", my_nspace, my_rank)); my_rank 313 opal/mca/pmix/pmix4x/pmix/test/test_fence.c my_nspace, my_rank, npeers, *count, val->data.string)); my_rank 321 opal/mca/pmix/pmix4x/pmix/test/test_fence.c int test_job_fence(test_params params, char *my_nspace, pmix_rank_t my_rank) my_rank 332 opal/mca/pmix/pmix4x/pmix/test/test_fence.c proc.rank = my_rank; my_rank 337 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Put failed: %d", my_nspace, my_rank, rc)); my_rank 341 opal/mca/pmix/pmix4x/pmix/test/test_fence.c (void)snprintf(sval, 50, "%s:%d", my_nspace, my_rank); my_rank 344 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Put failed: %d", my_nspace, my_rank, rc)); my_rank 350 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Put failed: %d", my_nspace, my_rank, rc)); my_rank 357 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Commit failed: %d", my_nspace, my_rank, rc)); my_rank 364 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Fence failed: %d", my_nspace, my_rank, rc)); my_rank 368 opal/mca/pmix/pmix4x/pmix/test/test_fence.c if (PMIX_SUCCESS != (rc = get_local_peers(my_nspace, my_rank, &peers, &npeers))) { my_rank 387 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Get failed: %s", my_nspace, my_rank, PMIx_Error_string(rc))); my_rank 393 opal/mca/pmix/pmix4x/pmix/test/test_fence.c if (PMIX_SUCCESS == rc && (i+params.base_rank) != my_rank ) { my_rank 394 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Get of remote key on local proc", my_nspace, my_rank)); my_rank 399 opal/mca/pmix/pmix4x/pmix/test/test_fence.c if (PMIX_SUCCESS == rc && (i+params.base_rank) != my_rank) { my_rank 400 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Get of local key on the remote proc", my_nspace, my_rank)); my_rank 407 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Get failed (%d)", my_nspace, my_rank, rc)); my_rank 414 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d: PMIx_Get failed (%d)", my_nspace, my_rank, rc)); my_rank 423 opal/mca/pmix/pmix4x/pmix/test/test_fence.c my_nspace, my_rank)); my_rank 428 opal/mca/pmix/pmix4x/pmix/test/test_fence.c my_nspace, my_rank, PMIx_Error_string(rc))); my_rank 432 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_ERROR(("%s:%d [ERROR]: PMIx_Get did not return NULL value", my_nspace, my_rank)); my_rank 435 opal/mca/pmix/pmix4x/pmix/test/test_fence.c TEST_VERBOSE(("%s:%d: rank %d is OK", my_nspace, my_rank, i+params.base_rank)); my_rank 19 opal/mca/pmix/pmix4x/pmix/test/test_fence.h int test_fence(test_params params, char *my_nspace, pmix_rank_t my_rank); my_rank 20 opal/mca/pmix/pmix4x/pmix/test/test_fence.h int test_job_fence(test_params params, char *my_nspace, pmix_rank_t my_rank); my_rank 31 opal/mca/pmix/pmix4x/pmix/test/test_internal.c int test_internal(char *my_nspace, pmix_rank_t my_rank, test_params params) { my_rank 41 opal/mca/pmix/pmix4x/pmix/test/test_internal.c proc.rank = my_rank; my_rank 45 opal/mca/pmix/pmix4x/pmix/test/test_internal.c sprintf(sval, "test_internal:%s:%d:%d", my_nspace, my_rank, idx); my_rank 51 opal/mca/pmix/pmix4x/pmix/test/test_internal.c TEST_ERROR(("%s:%d: PMIx_Store_internal failed: %d", my_nspace, my_rank, rc)); my_rank 59 opal/mca/pmix/pmix4x/pmix/test/test_internal.c TEST_ERROR(("%s:%d: PMIx_Commit failed: %d", my_nspace, my_rank, rc)); my_rank 67 opal/mca/pmix/pmix4x/pmix/test/test_internal.c TEST_ERROR(("%s:%d: PMIx_Fence failed: %d", my_nspace, my_rank, rc)); my_rank 74 opal/mca/pmix/pmix4x/pmix/test/test_internal.c sprintf(sval, "test_internal:%s:%d:%d", my_nspace, my_rank, idx); my_rank 76 opal/mca/pmix/pmix4x/pmix/test/test_internal.c GET(string, sval, my_nspace, my_rank, 0, idx, 1, 1, 0); my_rank 78 opal/mca/pmix/pmix4x/pmix/test/test_internal.c TEST_ERROR(("%s:%d: PMIx_Get of remote key on local proc", my_nspace, my_rank)); my_rank 17 opal/mca/pmix/pmix4x/pmix/test/test_internal.h int test_internal(char *my_nspace, pmix_rank_t my_rank, test_params params); my_rank 52 opal/mca/pmix/pmix4x/pmix/test/test_publish.c static int test_publish(char *my_nspace, int my_rank, int blocking) my_rank 59 opal/mca/pmix/pmix4x/pmix/test/test_publish.c (void)snprintf(info.key, PMIX_MAX_KEYLEN, "%s:%d", my_nspace, my_rank); my_rank 60 opal/mca/pmix/pmix4x/pmix/test/test_publish.c (void)snprintf(data, 512, "data from proc %s:%d", my_nspace, my_rank); my_rank 76 opal/mca/pmix/pmix4x/pmix/test/test_publish.c static int test_lookup(char *my_nspace, int my_rank, int blocking) my_rank 84 opal/mca/pmix/pmix4x/pmix/test/test_publish.c (void)snprintf(pdata.key, PMIX_MAX_KEYLEN, "%s:%d", my_nspace, my_rank); my_rank 85 opal/mca/pmix/pmix4x/pmix/test/test_publish.c (void)snprintf(data, 512, "data from proc %s:%d", my_nspace, my_rank); my_rank 94 opal/mca/pmix/pmix4x/pmix/test/test_publish.c (void)snprintf(keys[0], PMIX_MAX_KEYLEN, "%s:%d", my_nspace, my_rank); my_rank 125 opal/mca/pmix/pmix4x/pmix/test/test_publish.c static int test_unpublish(char *my_nspace, int my_rank, int blocking) my_rank 131 opal/mca/pmix/pmix4x/pmix/test/test_publish.c (void)snprintf(keys[0], PMIX_MAX_KEYLEN, "%s:%d", my_nspace, my_rank); my_rank 147 opal/mca/pmix/pmix4x/pmix/test/test_publish.c static int test_publish_lookup_common(char *my_nspace, int my_rank, int blocking) my_rank 150 opal/mca/pmix/pmix4x/pmix/test/test_publish.c rc = test_publish(my_nspace, my_rank, blocking); my_rank 152 opal/mca/pmix/pmix4x/pmix/test/test_publish.c TEST_ERROR(("%s:%d: %s failed.", my_nspace, my_rank, blocking ? "PMIX_Publish" : "PMIX_Publish_nb")); my_rank 155 opal/mca/pmix/pmix4x/pmix/test/test_publish.c TEST_VERBOSE(("%s:%d: %s succeeded.", my_nspace, my_rank, blocking ? "PMIX_Publish" : "PMIX_Publish_nb")); my_rank 157 opal/mca/pmix/pmix4x/pmix/test/test_publish.c rc = test_lookup(my_nspace, my_rank, blocking); my_rank 159 opal/mca/pmix/pmix4x/pmix/test/test_publish.c TEST_ERROR(("%s:%d: %s failed.", my_nspace, my_rank, blocking ? "PMIX_Lookup" : "PMIX_Lookup_nb")); my_rank 162 opal/mca/pmix/pmix4x/pmix/test/test_publish.c TEST_VERBOSE(("%s:%d: %s succeeded.\n", my_nspace, my_rank, blocking ? "PMIX_Lookup" : "PMIX_Lookup_nb")); my_rank 164 opal/mca/pmix/pmix4x/pmix/test/test_publish.c rc = test_unpublish(my_nspace, my_rank, blocking); my_rank 166 opal/mca/pmix/pmix4x/pmix/test/test_publish.c TEST_ERROR(("%s:%d: %s failed.", my_nspace, my_rank, blocking ? "PMIX_Unpublish" : "PMIX_Unpublish_nb")); my_rank 169 opal/mca/pmix/pmix4x/pmix/test/test_publish.c TEST_VERBOSE(("%s:%d: %s succeeded.", my_nspace, my_rank, blocking ? "PMIX_Unpublish" : "PMIX_Unpublish_nb")); my_rank 171 opal/mca/pmix/pmix4x/pmix/test/test_publish.c rc = test_lookup(my_nspace, my_rank, blocking); my_rank 173 opal/mca/pmix/pmix4x/pmix/test/test_publish.c TEST_ERROR(("%s:%d: %s function returned %d instead of PMIX_ERR_NOT_FOUND.", my_nspace, my_rank, blocking ? "PMIX_Lookup" : "PMIX_Lookup_nb", rc)); my_rank 179 opal/mca/pmix/pmix4x/pmix/test/test_publish.c int test_publish_lookup(char *my_nspace, int my_rank) my_rank 183 opal/mca/pmix/pmix4x/pmix/test/test_publish.c rc = test_publish_lookup_common(my_nspace, my_rank, 1); my_rank 185 opal/mca/pmix/pmix4x/pmix/test/test_publish.c TEST_ERROR(("%s:%d: Publish/Lookup blocking test failed.", my_nspace, my_rank)); my_rank 189 opal/mca/pmix/pmix4x/pmix/test/test_publish.c rc = test_publish_lookup_common(my_nspace, my_rank, 0); my_rank 191 opal/mca/pmix/pmix4x/pmix/test/test_publish.c TEST_ERROR(("%s:%d: Publish/Lookup non-blocking test failed.", my_nspace, my_rank)); my_rank 18 opal/mca/pmix/pmix4x/pmix/test/test_publish.h int test_publish_lookup(char *my_nspace, int my_rank); my_rank 40 opal/mca/pmix/pmix4x/pmix/test/test_replace.c int test_replace(char *my_nspace, pmix_rank_t my_rank, test_params params) { my_rank 53 opal/mca/pmix/pmix4x/pmix/test/test_replace.c sprintf(sval, "test_replace:%s:%d:%d", my_nspace, my_rank, key_idx); my_rank 57 opal/mca/pmix/pmix4x/pmix/test/test_replace.c TEST_ERROR(("%s:%d: PMIx_Put failed: %d", my_nspace, my_rank, rc)); my_rank 69 opal/mca/pmix/pmix4x/pmix/test/test_replace.c TEST_ERROR(("%s:%d: PMIx_Commit failed: %d", my_nspace, my_rank, rc)); my_rank 77 opal/mca/pmix/pmix4x/pmix/test/test_replace.c TEST_ERROR(("%s:%d: PMIx_Fence failed: %d", my_nspace, my_rank, rc)); my_rank 85 opal/mca/pmix/pmix4x/pmix/test/test_replace.c sprintf(sval, "test_replace:%s:%d:%d: replaced key", my_nspace, my_rank, item->key_idx); my_rank 89 opal/mca/pmix/pmix4x/pmix/test/test_replace.c TEST_ERROR(("%s:%d: PMIx_Put failed: %d", my_nspace, my_rank, rc)); my_rank 99 opal/mca/pmix/pmix4x/pmix/test/test_replace.c TEST_ERROR(("%s:%d: PMIx_Commit failed: %d", my_nspace, my_rank, rc)); my_rank 107 opal/mca/pmix/pmix4x/pmix/test/test_replace.c TEST_ERROR(("%s:%d: PMIx_Fence failed: %d", my_nspace, my_rank, rc)); my_rank 117 opal/mca/pmix/pmix4x/pmix/test/test_replace.c sprintf(sval, "test_replace:%s:%d:%d: replaced key", my_nspace, my_rank, key_idx); my_rank 119 opal/mca/pmix/pmix4x/pmix/test/test_replace.c sprintf(sval, "test_replace:%s:%d:%d", my_nspace, my_rank, key_idx); my_rank 123 opal/mca/pmix/pmix4x/pmix/test/test_replace.c GET(string, sval, my_nspace, my_rank, 0, key_idx, 1, 1, 0); my_rank 125 opal/mca/pmix/pmix4x/pmix/test/test_replace.c TEST_ERROR(("%s:%d: PMIx_Get of remote key on local proc", my_nspace, my_rank)); my_rank 17 opal/mca/pmix/pmix4x/pmix/test/test_replace.h int test_replace(char *my_nspace, pmix_rank_t my_rank, test_params params); my_rank 18 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c static int resolve_nspace(char *nspace, test_params params, char *my_nspace, int my_rank) my_rank 26 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c TEST_ERROR(("%s:%d: Resolve peers test failed: rc = %d", my_nspace, my_rank, rc)); my_rank 30 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c TEST_ERROR(("%s:%d: Resolve peers didn't find any process from ns %s at this node\n", my_nspace, my_rank,my_nspace)); my_rank 35 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c TEST_ERROR(("%s:%d: get_all_ranks_from_namespace function failed", my_nspace, my_rank)); my_rank 40 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c TEST_ERROR(("%s:%d: Resolve peers returned incorect result: returned %lu processes, expected %lu", my_nspace, my_rank, nprocs, nranks)); my_rank 48 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c my_nspace, my_rank, procs[i].nspace, procs[i].rank, ranks[i].rank)); my_rank 58 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c int test_resolve_peers(char *my_nspace, int my_rank, test_params params) my_rank 66 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c rc = resolve_nspace(my_nspace, params, my_nspace, my_rank); my_rank 68 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c TEST_VERBOSE(("%s:%d: Resolve peers succeeded for the own namespace\n", my_nspace, my_rank)); my_rank 70 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c TEST_ERROR(("%s:%d: Resolve peers failed for the own namespace\n", my_nspace, my_rank)); my_rank 77 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c TEST_ERROR(("%s:%d: get_total_ns_number function failed", my_nspace, my_rank)); my_rank 103 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c TEST_VERBOSE(("%s:%d: Connect to %s succeeded.", my_nspace, my_rank, nspace)); my_rank 105 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c TEST_ERROR(("%s:%d: Connect to %s failed.", my_nspace, my_rank, nspace)); my_rank 110 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c rc = resolve_nspace(nspace, params, my_nspace, my_rank); my_rank 112 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c TEST_VERBOSE(("%s:%d: Resolve peers succeeded for ns %s\n", my_nspace, my_rank, nspace)); my_rank 121 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c TEST_VERBOSE(("%s:%d: Disconnect from %s succeeded %s.", my_nspace, my_rank, nspace)); my_rank 123 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c TEST_ERROR(("%s:%d: Disconnect from %s failed %s.", my_nspace, my_rank, nspace)); my_rank 128 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.c TEST_VERBOSE(("%s:%d: Resolve peers test succeeded.", my_nspace, my_rank)); my_rank 18 opal/mca/pmix/pmix4x/pmix/test/test_resolve_peers.h int test_resolve_peers(char *my_nspace, int my_rank, test_params params); my_rank 30 opal/mca/pmix/pmix4x/pmix/test/test_spawn.c static int test_spawn_common(char *my_nspace, int my_rank, int blocking) my_rank 63 opal/mca/pmix/pmix4x/pmix/test/test_spawn.c int test_spawn(char *my_nspace, int my_rank) my_rank 66 opal/mca/pmix/pmix4x/pmix/test/test_spawn.c rc = test_spawn_common(my_nspace, my_rank, 1); my_rank 68 opal/mca/pmix/pmix4x/pmix/test/test_spawn.c TEST_ERROR(("%s:%d: Spawn blocking test failed.", my_nspace, my_rank)); my_rank 71 opal/mca/pmix/pmix4x/pmix/test/test_spawn.c TEST_VERBOSE(("%s:%d: Spawn blocking test succeded.", my_nspace, my_rank)); my_rank 72 opal/mca/pmix/pmix4x/pmix/test/test_spawn.c rc = test_spawn_common(my_nspace, my_rank, 0); my_rank 74 opal/mca/pmix/pmix4x/pmix/test/test_spawn.c TEST_ERROR(("%s:%d: Spawn non-blocking test failed.", my_nspace, my_rank)); my_rank 77 opal/mca/pmix/pmix4x/pmix/test/test_spawn.c TEST_VERBOSE(("%s:%d: Spawn non-blocking test succeded.", my_nspace, my_rank)); my_rank 18 opal/mca/pmix/pmix4x/pmix/test/test_spawn.h int test_spawn(char *my_nspace, int my_rank); my_rank 131 opal/mca/pmix/s2/pmi2_pmap_parser.c int *mca_common_pmi2_parse_pmap(char *pmap, int my_rank, my_rank 141 opal/mca/pmix/s2/pmi2_pmap_parser.c *node = find_my_node(p, my_rank); my_rank 16 opal/mca/pmix/s2/pmi2_pmap_parser.h int *mca_common_pmi2_parse_pmap(char *pmap, int my_rank, my_rank 81 orte/mca/grpcomm/grpcomm.h unsigned long my_rank; my_rank 37 orte/test/mpi/pmix.c static int my_rank; my_rank 53 orte/test/mpi/pmix.c fprintf(stderr, "%d: received notification status %d\n", my_rank, status); my_rank 73 orte/test/mpi/pmix.c MPI_Comm_rank(MPI_COMM_WORLD, &my_rank); my_rank 82 orte/test/mpi/pmix.c int data = my_rank; my_rank 87 orte/test/mpi/pmix.c DO_FINALIZE(rc, 1, "[%d] OPAL_MODEX_SEND_STRING failed.\n", my_rank); my_rank 102 orte/test/mpi/pmix.c DO_FINALIZE(rc, 1, "[%d] OPAL_MODEX_RECV_VALUE failed from rank %d.\n", my_rank, i); my_rank 111 orte/test/mpi/pmix.c fprintf(stderr, "[%d] Test passed.\n", my_rank); my_rank 112 orte/test/mpi/pmix.c fprintf(stderr, "[%d] \"MODEX_SEND\" %f\n", my_rank, t1-t0); my_rank 113 orte/test/mpi/pmix.c fprintf(stderr, "[%d] \"FENCE\" %f\n", my_rank, t3-t2); my_rank 114 orte/test/mpi/pmix.c fprintf(stderr, "[%d] \"MODEX_RECV\" %f\n", my_rank, t5-t4); my_rank 115 orte/test/mpi/pmix.c fprintf(stderr, "[%d] \"BARRIER\" %f\n", my_rank, t6-t5); my_rank 116 orte/test/mpi/pmix.c fprintf(stderr, "[%d] \"TOTAL\" %f\n", my_rank, t6-t0); my_rank 118 orte/test/mpi/pmix.c fprintf(stderr, "[%d] Pid %d waiting for notification\n", my_rank, (int)getpid()); my_rank 289 oshmem/mca/spml/ikrit/spml_ikrit.c int my_rank = oshmem_my_proc_id(); my_rank 301 oshmem/mca/spml/ikrit/spml_ikrit.c i = (my_rank + n) % nprocs; my_rank 324 oshmem/mca/spml/ikrit/spml_ikrit.c int my_rank = oshmem_my_proc_id(); my_rank 379 oshmem/mca/spml/ikrit/spml_ikrit.c i = (my_rank + n) % nprocs; my_rank 410 oshmem/mca/spml/ikrit/spml_ikrit.c proc_self = oshmem_proc_group_find(oshmem_group_all, my_rank); my_rank 447 oshmem/mca/spml/ikrit/spml_ikrit.c int my_rank = oshmem_my_proc_id(); my_rank 505 oshmem/mca/spml/ikrit/spml_ikrit.c my_rank, i, addr, (unsigned long long)size, my_rank 508 oshmem/mca/spml/ikrit/spml_ikrit.c mca_spml_ikrit_cache_mkeys(&mkeys[i], memheap_find_segnum(addr), my_rank, i); my_rank 203 oshmem/mca/spml/ucx/spml_ucx.c int my_rank = oshmem_my_proc_id(); my_rank 206 oshmem/mca/spml/ucx/spml_ucx.c printf("me=%d dest_pe=%d addr=%p len=%d\n", my_rank, pe, addr, len); my_rank 220 oshmem/mca/spml/ucx/spml_ucx.c int my_rank = oshmem_my_proc_id(); my_rank 239 oshmem/mca/spml/ucx/spml_ucx.c dump_address(my_rank, (char *)wk_local_addr, wk_addr_len); my_rank 254 oshmem/mca/spml/ucx/spml_ucx.c i = (my_rank + n) % nprocs;