pr 199 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c static void wait_cbfunc(struct pmix_peer_t *pr, pr 211 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c static void job_data(struct pmix_peer_t *pr, pr 376 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c static void client_iof_handler(struct pmix_peer_t *pr, pr 380 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_peer_t *peer = (pmix_peer_t*)pr; pr 735 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c static void finwait_cbfunc(struct pmix_peer_t *pr, pr 61 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c static void wait_cbfunc(struct pmix_peer_t *pr, pr 341 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c static void wait_cbfunc(struct pmix_peer_t *pr, pr 62 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c static void wait_cbfunc(struct pmix_peer_t *pr, pr 251 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c static void wait_cbfunc(struct pmix_peer_t *pr, pmix_ptl_hdr_t *hdr, pr 68 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c static void _getnb_cbfunc(struct pmix_peer_t *pr, pr 284 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c static void _getnb_cbfunc(struct pmix_peer_t *pr, pr 109 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c static void grp_cbfunc(struct pmix_peer_t *pr, pr 939 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c static void grp_cbfunc(struct pmix_peer_t *pr, pr 58 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c static void wait_cbfunc(struct pmix_peer_t *pr, pr 62 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c static void wait_lookup_cbfunc(struct pmix_peer_t *pr, pr 509 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c static void wait_cbfunc(struct pmix_peer_t *pr, pr 559 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c static void wait_lookup_cbfunc(struct pmix_peer_t *pr, pr 60 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c static void wait_cbfunc(struct pmix_peer_t *pr, pr 275 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c static void wait_cbfunc(struct pmix_peer_t *pr, pr 93 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c static void notify_event_cbfunc(struct pmix_peer_t *pr, pmix_ptl_hdr_t *hdr, pr 101 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_BFROPS_UNPACK(rc, pr, buf, &ret, &cnt, PMIX_STATUS); pr 811 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pmix_peer_events_info_t *pr; pr 986 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_LIST_FOREACH(pr, ®infoptr->peers, pmix_peer_events_info_t) { pr 990 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (PMIX_CHECK_PROCID(&cd->source, &pr->peer->info->pname)) { pr 996 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c if (nm->pname == &pr->peer->info->pname) { pr 1007 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pr->affected, pr->naffected)) { pr 1019 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_LOAD_PROCID(&proc, pr->peer->info->pname.nspace, pr->peer->info->pname.rank); pr 1025 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c pr->peer->info->pname.nspace, pr->peer->info->pname.rank, pr 1030 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c nm->pname = &pr->peer->info->pname; pr 1038 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_BFROPS_PACK(rc, pr->peer, bfr, &cmd, 1, PMIX_COMMAND); pr 1046 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_BFROPS_PACK(rc, pr->peer, bfr, &cd->status, 1, PMIX_STATUS); pr 1054 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_BFROPS_PACK(rc, pr->peer, bfr, &cd->source, 1, PMIX_PROC); pr 1061 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_BFROPS_PACK(rc, pr->peer, bfr, &cd->ninfo, 1, PMIX_SIZE); pr 1069 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_BFROPS_PACK(rc, pr->peer, bfr, cd->info, cd->ninfo, PMIX_INFO); pr 1076 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_notification.c PMIX_SERVER_QUEUE_REPLY(rc, pr->peer, 0, bfr); pr 277 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h #define PMIX_REGISTER_TYPE(n, t, p, u, c, pr, arr) \ pr 286 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h _info->odti_print_fn = (pmix_bfrop_print_fn_t)(pr) ; \ pr 294 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h PMIX_EXPORT pmix_buffer_t* pmix_bfrops_stub_create_buffer(struct pmix_peer_t *pr); pr 295 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h PMIX_EXPORT void pmix_bfrops_construct_buffer(struct pmix_peer_t *pr, pr 390 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_copy.c pmix_regattr_t *pr, *sr; pr 818 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_copy.c pr = (pmix_regattr_t*)p->array; pr 822 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_copy.c pr[n].name = strdup(sr[n].name); pr 824 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_copy.c PMIX_LOAD_KEY(pr[n].string, sr[n].string); pr 825 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_copy.c pr[n].type = sr[n].type; pr 827 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_copy.c PMIX_INFO_XFER(pr[n].info, sr[n].info); pr 829 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_copy.c pr[n].ninfo = sr[n].ninfo; pr 830 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/bfrop_base_copy.c pr[n].description = pmix_argv_copy(sr[n].description); pr 430 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h #define PMIX_BFROPS_PRINT(r, p, o, pr, s, t) \ pr 431 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = (p)->nptr->compat.bfrops->print(o, pr, s, t) pr 457 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h #define PMIX_BFROPS_REGISTER(r, p, n, t, pk, u, c, pr) \ pr 458 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/bfrops.h (r) = (p)->nptr->compat.bfrops->register_type(n, t, pk, u, c, pr) pr 2741 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c struct pmix_peer_t *pr, pr 2744 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_peer_t *peer = (pmix_peer_t*)pr; pr 61 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_common.h struct pmix_peer_t *pr, pr 94 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_base.c static pmix_status_t ds12_register_job_info(struct pmix_peer_t *pr, pr 97 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_base.c if (PMIX_PROC_IS_V1(pr)) { pr 102 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds12/gds_ds12_base.c return pmix_common_dstor_register_job_info(ds12_ctx, pr, reply); pr 87 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_base.c static pmix_status_t ds21_register_job_info(struct pmix_peer_t *pr, pr 90 opal/mca/pmix/pmix4x/pmix/src/mca/gds/ds21/gds_ds21_base.c return pmix_common_dstor_register_job_info(ds21_ctx, pr, reply); pr 161 opal/mca/pmix/pmix4x/pmix/src/mca/gds/gds.h typedef pmix_status_t (*pmix_gds_base_module_register_job_info_fn_t)(struct pmix_peer_t *pr, pr 59 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c static pmix_status_t hash_register_job_info(struct pmix_peer_t *pr, pr 686 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c static pmix_status_t hash_register_job_info(struct pmix_peer_t *pr, pr 689 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_peer_t *peer = (pmix_peer_t*)pr; pr 181 opal/mca/pmix/pmix4x/pmix/src/mca/psec/munge/psec_munge.c pmix_peer_t *pr = (pmix_peer_t*)peer; pr 226 opal/mca/pmix/pmix4x/pmix/src/mca/psec/munge/psec_munge.c if (euid != pr->info->uid) { pr 231 opal/mca/pmix/pmix4x/pmix/src/mca/psec/munge/psec_munge.c if (egid != pr->info->gid) { pr 68 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c pmix_peer_t *pr = (pmix_peer_t*)peer; pr 108 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c if (PMIX_PROTOCOL_V1 == pr->protocol) { pr 111 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c } else if (PMIX_PROTOCOL_V2 == pr->protocol) { pr 150 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c pmix_peer_t *pr = (pmix_peer_t*)peer; pr 174 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c if (PMIX_PROTOCOL_V1 == pr->protocol) { pr 179 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c "psec:native checking getsockopt on socket %d for peer credentials", pr->sd); pr 180 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c if (getsockopt(pr->sd, SOL_SOCKET, SO_PEERCRED, &ucred, &crlen) < 0) { pr 196 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c "psec:native checking getpeereid on socket %d for peer credentials", pr->sd); pr 197 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c if (0 != getpeereid(pr->sd, &euid, &egid)) { pr 206 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c } else if (PMIX_PROTOCOL_V2 == pr->protocol) { pr 228 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c } else if (PMIX_PROTOCOL_UNDEF != pr->protocol) { pr 257 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c if (euid != pr->info->uid) { pr 264 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c if (egid != pr->info->gid) { pr 109 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pmix_peer_t *pr = (pmix_peer_t*)peer; pr 115 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pr->nptr->compat.ptl = active->module; pr 688 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c pmix_peer_t *pr = (pmix_peer_t*)peer; pr 695 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c PMIX_RETAIN(pr); pr 696 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c ms->peer = pr; pr 709 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c pmix_peer_t *pr = (pmix_peer_t*)peer; pr 715 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c PMIX_RETAIN(pr); pr 716 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c q->peer = pr; pr 240 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_peer_t *pr = (pmix_peer_t*)peer; pr 247 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c PMIX_RETAIN(pr); pr 248 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c ms->peer = pr; pr 261 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_peer_t *pr = (pmix_peer_t*)peer; pr 267 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c PMIX_RETAIN(pr); pr 3548 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c void pmix_server_message_handler(struct pmix_peer_t *pr, pr 3552 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_peer_t *peer = (pmix_peer_t*)pr; pr 3572 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c PMIX_BFROPS_PACK(rc, pr, reply, &ret, 1, PMIX_STATUS); pr 2862 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_peer_t *pr; pr 2936 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (pr = (pmix_peer_t*)pmix_pointer_array_get_item(&pmix_server_globals.clients, m))) { pr 2939 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (0 != strncmp(pr->info->pname.nspace, cd->targets[n].nspace, PMIX_MAX_NSLEN)) { pr 2942 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (pr->info->pname.rank == cd->targets[n].rank) { pr 2944 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c epicd->epi = &pr->epilog; pr 3882 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_peer_t *pr; pr 3966 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (pr = (pmix_peer_t*)pmix_pointer_array_get_item(&pmix_server_globals.clients, m))) { pr 3969 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (PMIX_CHECK_NSPACE(procs[n].nspace, pr->info->pname.nspace)) { pr 3971 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c nm->pname = &pr->info->pname; pr 3979 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (pr = (pmix_peer_t*)pmix_pointer_array_get_item(&pmix_server_globals.clients, m))) { pr 3983 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c nm->pname = &pr->info->pname; pr 4086 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (NULL == (pr = (pmix_peer_t*)pmix_pointer_array_get_item(&pmix_server_globals.clients, m))) { pr 4089 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c if (PMIX_CHECK_PROCID(&grp->members[n], &pr->info->pname)) { pr 357 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h void pmix_server_message_handler(struct pmix_peer_t *pr, pr 184 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c static void tool_iof_handler(struct pmix_peer_t *pr, pr 188 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_peer_t *peer = (pmix_peer_t*)pr; pr 228 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c static void job_data(struct pmix_peer_t *pr, pr 1106 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c static void finwait_cbfunc(struct pmix_peer_t *pr, pr 38 orte/mca/oob/base/oob_base_stubs.c orte_oob_base_peer_t *pr; pr 69 orte/mca/oob/base/oob_base_stubs.c ui64, (void**)&pr) || pr 70 orte/mca/oob/base/oob_base_stubs.c NULL == pr) { pr 86 orte/mca/oob/base/oob_base_stubs.c ui64, (void**)&pr) || pr 87 orte/mca/oob/base/oob_base_stubs.c NULL == pr) { pr 106 orte/mca/oob/base/oob_base_stubs.c pr = NULL; pr 114 orte/mca/oob/base/oob_base_stubs.c if (NULL == pr) { pr 115 orte/mca/oob/base/oob_base_stubs.c pr = OBJ_NEW(orte_oob_base_peer_t); pr 116 orte/mca/oob/base/oob_base_stubs.c if (OPAL_SUCCESS != (rc = opal_hash_table_set_value_uint64(&orte_oob_base.peers, ui64, (void*)pr))) { pr 124 orte/mca/oob/base/oob_base_stubs.c opal_bitmap_set_bit(&pr->addressable, component->idx); pr 151 orte/mca/oob/base/oob_base_stubs.c if (NULL != pr->component) { pr 159 orte/mca/oob/base/oob_base_stubs.c if (ORTE_SUCCESS == (rc = pr->component->send_nb(msg))) { pr 181 orte/mca/oob/base/oob_base_stubs.c pr->component = component; pr 308 orte/mca/oob/base/oob_base_stubs.c orte_oob_base_peer_t *pr; pr 344 orte/mca/oob/base/oob_base_stubs.c ui64, (void**)&pr) || pr 345 orte/mca/oob/base/oob_base_stubs.c NULL == pr) { pr 346 orte/mca/oob/base/oob_base_stubs.c pr = OBJ_NEW(orte_oob_base_peer_t); pr 347 orte/mca/oob/base/oob_base_stubs.c if (OPAL_SUCCESS != (rc = opal_hash_table_set_value_uint64(&orte_oob_base.peers, ui64, (void*)pr))) { pr 375 orte/mca/oob/base/oob_base_stubs.c opal_bitmap_set_bit(&pr->addressable, component->idx); pr 831 orte/mca/oob/tcp/oob_tcp_component.c mca_oob_tcp_peer_t *pr; pr 929 orte/mca/oob/tcp/oob_tcp_component.c if (NULL == (pr = mca_oob_tcp_peer_lookup(peer))) { pr 930 orte/mca/oob/tcp/oob_tcp_component.c pr = OBJ_NEW(mca_oob_tcp_peer_t); pr 931 orte/mca/oob/tcp/oob_tcp_component.c pr->name.jobid = peer->jobid; pr 932 orte/mca/oob/tcp/oob_tcp_component.c pr->name.vpid = peer->vpid; pr 937 orte/mca/oob/tcp/oob_tcp_component.c if (OPAL_SUCCESS != opal_hash_table_set_value_uint64(&mca_oob_tcp_component.peers, ui64, pr)) { pr 938 orte/mca/oob/tcp/oob_tcp_component.c OBJ_RELEASE(pr); pr 952 orte/mca/oob/tcp/oob_tcp_component.c OBJ_RELEASE(pr); pr 962 orte/mca/oob/tcp/oob_tcp_component.c opal_list_append(&pr->addrs, &maddr->super); pr 720 orte/mca/oob/tcp/oob_tcp_connection.c int mca_oob_tcp_peer_recv_connect_ack(mca_oob_tcp_peer_t* pr, pr 730 orte/mca/oob/tcp/oob_tcp_connection.c bool is_new = (NULL == pr); pr 735 orte/mca/oob/tcp/oob_tcp_connection.c (NULL == pr) ? "UNKNOWN" : ORTE_NAME_PRINT(&pr->name), sd); pr 737 orte/mca/oob/tcp/oob_tcp_connection.c peer = pr;