pmix_peer_t 86 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c static void pmix_client_notify_recv(struct pmix_peer_t *peer, pmix_peer_t 199 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c static void wait_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 211 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c static void job_data(struct pmix_peer_t *pr, pmix_peer_t 376 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c static void client_iof_handler(struct pmix_peer_t *pr, pmix_peer_t 380 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_peer_t *peer = (pmix_peer_t*)pr; pmix_peer_t 487 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_client_globals.myserver = PMIX_NEW(pmix_peer_t); pmix_peer_t 620 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c rc = pmix_ptl_base_connect_to_peer((struct pmix_peer_t*)pmix_client_globals.myserver, info, ninfo); pmix_peer_t 735 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c static void finwait_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 758 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c pmix_peer_t *peer; pmix_peer_t 849 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client.c if (NULL != (peer = (pmix_peer_t*)pmix_pointer_array_get_item(&pmix_client_globals.peers, i))) { pmix_peer_t 61 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c static void wait_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 341 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_connect.c static void wait_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 62 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_fence.c static void wait_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 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, pmix_peer_t 68 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c static void _getnb_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 284 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_get.c static void _getnb_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 109 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c static void grp_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 939 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_group.c static void grp_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 25 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_ops.h pmix_peer_t *myserver; // messaging support to/from my server pmix_peer_t 58 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c static void wait_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 62 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c static void wait_lookup_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 509 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c static void wait_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 559 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_pub.c static void wait_lookup_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 60 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c static void wait_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 275 opal/mca/pmix/pmix4x/pmix/src/client/pmix_client_spawn.c static void wait_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 709 opal/mca/pmix/pmix4x/pmix/src/common/pmix_attributes.c static void query_cbfunc(struct pmix_peer_t *peer, pmix_peer_t 49 opal/mca/pmix/pmix4x/pmix/src/common/pmix_control.c static void query_cbfunc(struct pmix_peer_t *peer, pmix_peer_t 71 opal/mca/pmix/pmix4x/pmix/src/common/pmix_data.c static pmix_peer_t* find_peer(const pmix_proc_t *proc) pmix_peer_t 74 opal/mca/pmix/pmix4x/pmix/src/common/pmix_data.c pmix_peer_t *peer; pmix_peer_t 91 opal/mca/pmix/pmix4x/pmix/src/common/pmix_data.c if (NULL != (peer = (pmix_peer_t*)pmix_pointer_array_get_item(&pmix_server_globals.clients, i))) { pmix_peer_t 108 opal/mca/pmix/pmix4x/pmix/src/common/pmix_data.c peer = PMIX_NEW(pmix_peer_t); pmix_peer_t 149 opal/mca/pmix/pmix4x/pmix/src/common/pmix_data.c peer = PMIX_NEW(pmix_peer_t); pmix_peer_t 180 opal/mca/pmix/pmix4x/pmix/src/common/pmix_data.c pmix_peer_t *peer; pmix_peer_t 211 opal/mca/pmix/pmix4x/pmix/src/common/pmix_data.c pmix_peer_t *peer; pmix_peer_t 45 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c static void msgcbfunc(struct pmix_peer_t *peer, pmix_peer_t 202 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c static void stdincbfunc(struct pmix_peer_t *peer, pmix_peer_t 811 opal/mca/pmix/pmix4x/pmix/src/common/pmix_iof.c static void iof_stdin_cbfunc(struct pmix_peer_t *peer, pmix_peer_t 44 opal/mca/pmix/pmix4x/pmix/src/common/pmix_log.c static void log_cbfunc(struct pmix_peer_t *peer, pmix_peer_t 50 opal/mca/pmix/pmix4x/pmix/src/common/pmix_query.c static void query_cbfunc(struct pmix_peer_t *peer, pmix_peer_t 37 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c static void getcbfunc(struct pmix_peer_t *peer, pmix_peer_t 233 opal/mca/pmix/pmix4x/pmix/src/common/pmix_security.c static void valid_cbfunc(struct pmix_peer_t *peer, pmix_peer_t 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, pmix_peer_t 83 opal/mca/pmix/pmix4x/pmix/src/event/pmix_event_registration.c static void regevents_cbfunc(struct pmix_peer_t *peer, pmix_ptl_hdr_t *hdr, pmix_peer_t 173 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c static void pcon(pmix_peer_t *p) pmix_peer_t 194 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c static void pdes(pmix_peer_t *p) pmix_peer_t 227 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.c PMIX_EXPORT PMIX_CLASS_INSTANCE(pmix_peer_t, pmix_peer_t 260 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h PMIX_CLASS_DECLARATION(pmix_peer_t); pmix_peer_t 266 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_peer_t *peer; pmix_peer_t 338 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_peer_t *peer; pmix_peer_t 472 opal/mca/pmix/pmix4x/pmix/src/include/pmix_globals.h pmix_peer_t *mypeer; // my own peer object pmix_peer_t 292 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h PMIX_EXPORT pmix_status_t pmix_bfrops_stub_assign_module(struct pmix_peer_t *peer, pmix_peer_t 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); pmix_peer_t 295 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h PMIX_EXPORT void pmix_bfrops_construct_buffer(struct pmix_peer_t *pr, pmix_peer_t 297 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h PMIX_EXPORT pmix_status_t pmix_bfrops_stub_pack(struct pmix_peer_t *peer, pmix_peer_t 302 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h PMIX_EXPORT pmix_status_t pmix_bfrops_stub_unpack(struct pmix_peer_t *peer, pmix_peer_t 306 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h PMIX_EXPORT pmix_status_t pmix_bfrops_stub_copy(struct pmix_peer_t *peer, pmix_peer_t 309 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h PMIX_EXPORT pmix_status_t pmix_bfrops_stub_print(struct pmix_peer_t *peer, pmix_peer_t 312 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h PMIX_EXPORT pmix_status_t pmix_bfrops_stub_copy_payload(struct pmix_peer_t *peer, pmix_peer_t 315 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h PMIX_EXPORT pmix_status_t pmix_bfrops_stub_value_xfer(struct pmix_peer_t *peer, pmix_peer_t 318 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h PMIX_EXPORT void pmix_bfrops_stub_value_load(struct pmix_peer_t *peer, pmix_peer_t 321 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h PMIX_EXPORT pmix_status_t pmix_bfrops_stub_value_unload(struct pmix_peer_t *peer, pmix_peer_t 324 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h PMIX_EXPORT pmix_value_cmp_t pmix_bfrops_stub_value_cmp(struct pmix_peer_t *peer, pmix_peer_t 326 opal/mca/pmix/pmix4x/pmix/src/mca/bfrops/base/base.h PMIX_EXPORT pmix_status_t pmix_bfrops_stub_register_type(struct pmix_peer_t *peer, pmix_peer_t 105 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline void _client_compat_save(pmix_common_dstore_ctx_t *ds_ctx, pmix_peer_t *peer); pmix_peer_t 106 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline pmix_peer_t * _client_peer(pmix_common_dstore_ctx_t *ds_ctx); pmix_peer_t 2503 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_peer_t *peer; pmix_peer_t 2508 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c if (NULL != (peer = (pmix_peer_t *)pmix_pointer_array_get_item(&pmix_server_globals.clients, i))) { pmix_peer_t 2741 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c struct pmix_peer_t *pr, pmix_peer_t 2744 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c pmix_peer_t *peer = (pmix_peer_t*)pr; pmix_peer_t 2827 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static void _client_compat_save(pmix_common_dstore_ctx_t *ds_ctx, pmix_peer_t *peer) pmix_peer_t 2832 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c ds_ctx->clients_peer = PMIX_NEW(pmix_peer_t); pmix_peer_t 2840 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.c static inline pmix_peer_t * _client_peer(pmix_common_dstore_ctx_t *ds_ctx) pmix_peer_t 65 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_base.h pmix_peer_t *clients_peer; pmix_peer_t 61 opal/mca/pmix/pmix4x/pmix/src/mca/common/dstore/dstore_common.h struct pmix_peer_t *pr, pmix_peer_t 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, pmix_peer_t 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, pmix_peer_t 47 opal/mca/pmix/pmix4x/pmix/src/mca/gds/gds.h struct pmix_peer_t; pmix_peer_t 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, pmix_peer_t 172 opal/mca/pmix/pmix4x/pmix/src/mca/gds/gds.h (s) = _g->register_job_info((struct pmix_peer_t*)(p), b); \ pmix_peer_t 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, pmix_peer_t 591 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c static pmix_status_t register_info(pmix_peer_t *peer, pmix_peer_t 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, pmix_peer_t 689 opal/mca/pmix/pmix4x/pmix/src/mca/gds/hash/gds_hash.c pmix_peer_t *peer = (pmix_peer_t*)pr; pmix_peer_t 34 opal/mca/pmix/pmix4x/pmix/src/mca/psec/munge/psec_munge.c static pmix_status_t create_cred(struct pmix_peer_t *peer, pmix_peer_t 38 opal/mca/pmix/pmix4x/pmix/src/mca/psec/munge/psec_munge.c static pmix_status_t validate_cred(struct pmix_peer_t *peer, pmix_peer_t 98 opal/mca/pmix/pmix4x/pmix/src/mca/psec/munge/psec_munge.c static pmix_status_t create_cred(struct pmix_peer_t *peer, pmix_peer_t 176 opal/mca/pmix/pmix4x/pmix/src/mca/psec/munge/psec_munge.c static pmix_status_t validate_cred(struct pmix_peer_t *peer, pmix_peer_t 181 opal/mca/pmix/pmix4x/pmix/src/mca/psec/munge/psec_munge.c pmix_peer_t *pr = (pmix_peer_t*)peer; pmix_peer_t 33 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c static pmix_status_t create_cred(struct pmix_peer_t *peer, pmix_peer_t 37 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c static pmix_status_t validate_cred(struct pmix_peer_t *peer, pmix_peer_t 63 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c static pmix_status_t create_cred(struct pmix_peer_t *peer, pmix_peer_t 68 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c pmix_peer_t *pr = (pmix_peer_t*)peer; pmix_peer_t 145 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c static pmix_status_t validate_cred(struct pmix_peer_t *peer, pmix_peer_t 150 opal/mca/pmix/pmix4x/pmix/src/mca/psec/native/psec_native.c pmix_peer_t *pr = (pmix_peer_t*)peer; pmix_peer_t 34 opal/mca/pmix/pmix4x/pmix/src/mca/psec/none/psec_none.c static pmix_status_t create_cred(struct pmix_peer_t *peer, pmix_peer_t 38 opal/mca/pmix/pmix4x/pmix/src/mca/psec/none/psec_none.c static pmix_status_t validate_cred(struct pmix_peer_t *peer, pmix_peer_t 64 opal/mca/pmix/pmix4x/pmix/src/mca/psec/none/psec_none.c static pmix_status_t create_cred(struct pmix_peer_t *peer, pmix_peer_t 75 opal/mca/pmix/pmix4x/pmix/src/mca/psec/none/psec_none.c static pmix_status_t validate_cred(struct pmix_peer_t *peer, pmix_peer_t 41 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h struct pmix_peer_t; pmix_peer_t 67 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h typedef pmix_status_t (*pmix_psec_base_module_create_cred_fn_t)(struct pmix_peer_t *peer, pmix_peer_t 91 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h typedef pmix_status_t (*pmix_psec_base_module_validate_cred_fn_t)(struct pmix_peer_t *peer, pmix_peer_t 132 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h (r) = (p)->nptr->compat.psec->create_cred((struct pmix_peer_t*)(p), \ pmix_peer_t 139 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h (r) = (p)->nptr->compat.psec->validate_cred((struct pmix_peer_t*)(p), \ pmix_peer_t 148 opal/mca/pmix/pmix4x/pmix/src/mca/psec/psec.h _r = (p)->nptr->compat.psec->validate_cred((struct pmix_peer_t*)(p), \ pmix_peer_t 51 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/base/base.h PMIX_EXPORT pmix_status_t pmix_psensor_base_start(pmix_peer_t *requestor, pmix_status_t error, pmix_peer_t 55 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/base/base.h PMIX_EXPORT pmix_status_t pmix_psensor_base_stop(pmix_peer_t *requestor, pmix_peer_t 21 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/base/psensor_base_stubs.c pmix_status_t pmix_psensor_base_start(pmix_peer_t *requestor, pmix_status_t error, pmix_peer_t 54 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/base/psensor_base_stubs.c pmix_status_t pmix_psensor_base_stop(pmix_peer_t *requestor, pmix_peer_t 53 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c static pmix_status_t start(pmix_peer_t *requestor, pmix_status_t error, pmix_peer_t 56 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c static pmix_status_t stop(pmix_peer_t *requestor, char *id); pmix_peer_t 67 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c pmix_peer_t *requestor; pmix_peer_t 135 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c pmix_peer_t *requestor; pmix_peer_t 177 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c static pmix_status_t start(pmix_peer_t *requestor, pmix_status_t error, pmix_peer_t 255 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/file/psensor_file.c static pmix_status_t stop(pmix_peer_t *requestor, char *id) pmix_peer_t 39 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c static pmix_status_t heartbeat_start(pmix_peer_t *requestor, pmix_status_t error, pmix_peer_t 42 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c static pmix_status_t heartbeat_stop(pmix_peer_t *requestor, char *id); pmix_peer_t 53 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_peer_t *requestor; pmix_peer_t 108 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_peer_t *requestor; pmix_peer_t 132 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c pmix_peer_t *peer; pmix_peer_t 167 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c static pmix_status_t heartbeat_start(pmix_peer_t *requestor, pmix_status_t error, pmix_peer_t 249 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c static pmix_status_t heartbeat_stop(pmix_peer_t *requestor, char *id) pmix_peer_t 346 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.c void pmix_psensor_heartbeat_recv_beats(struct pmix_peer_t *peer, pmix_peer_t 38 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/heartbeat/psensor_heartbeat.h void pmix_psensor_heartbeat_recv_beats(struct pmix_peer_t *peer, pmix_peer_t 40 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/psensor.h typedef pmix_status_t (*pmix_psensor_base_module_start_fn_t)(pmix_peer_t *requestor, pmix_status_t error, pmix_peer_t 52 opal/mca/pmix/pmix4x/pmix/src/mca/psensor/psensor.h typedef pmix_status_t (*pmix_psensor_base_module_stop_fn_t)(pmix_peer_t *requestor, pmix_peer_t 92 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT pmix_status_t pmix_ptl_base_connect_to_peer(struct pmix_peer_t *peer, pmix_peer_t 95 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT pmix_status_t pmix_ptl_base_register_recv(struct pmix_peer_t *peer, pmix_peer_t 98 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT pmix_status_t pmix_ptl_base_cancel_recv(struct pmix_peer_t *peer, pmix_peer_t 120 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/base.h PMIX_EXPORT void pmix_ptl_base_lost_connection(pmix_peer_t *peer, pmix_status_t err); pmix_peer_t 59 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_peer_t *peer = (pmix_peer_t*)cbdata; pmix_peer_t 63 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c void pmix_ptl_base_lost_connection(pmix_peer_t *peer, pmix_status_t err) pmix_peer_t 388 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_peer_t *peer = (pmix_peer_t*)cbdata; pmix_peer_t 467 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_sendrecv.c pmix_peer_t *peer = (pmix_peer_t*)cbdata; pmix_peer_t 106 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pmix_status_t pmix_ptl_base_connect_to_peer(struct pmix_peer_t *peer, pmix_peer_t 109 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pmix_peer_t *pr = (pmix_peer_t*)peer; pmix_peer_t 160 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pmix_status_t pmix_ptl_base_register_recv(struct pmix_peer_t *peer, pmix_peer_t 196 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/base/ptl_base_stubs.c pmix_status_t pmix_ptl_base_cancel_recv(struct pmix_peer_t *peer, pmix_peer_t 48 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h struct pmix_peer_t; pmix_peer_t 102 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h typedef pmix_status_t (*pmix_ptl_send_recv_fn_t)(struct pmix_peer_t *peer, pmix_peer_t 109 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h typedef pmix_status_t (*pmix_ptl_send_fn_t)(struct pmix_peer_t *peer, pmix_peer_t 114 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h typedef pmix_status_t (*pmix_ptl_recv_fn_t)(struct pmix_peer_t *peer, pmix_peer_t 119 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h typedef pmix_status_t (*pmix_ptl_cancel_fn_t)(struct pmix_peer_t *peer, pmix_peer_t 126 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h typedef pmix_status_t (*pmix_ptl_connect_to_peer_fn_t)(struct pmix_peer_t *peer, pmix_peer_t 151 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h (r) = (p)->nptr->compat.ptl->send_recv((struct pmix_peer_t*)(p), b, c, d); \ pmix_peer_t 160 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h (r) = (p)->nptr->compat.ptl->send((struct pmix_peer_t*)(p), b, t); \ pmix_peer_t 165 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h (r) = (p)->nptr->compat.ptl->recv((struct pmix_peer_t*)(p), c, t) pmix_peer_t 168 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h (r) = (p)->nptr->compat.ptl->cancel((struct pmix_peer_t*)(p), t) pmix_peer_t 170 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl.h extern pmix_status_t pmix_ptl_base_connect_to_peer(struct pmix_peer_t* peer, pmix_peer_t 61 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h struct pmix_peer_t; pmix_peer_t 117 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h typedef void (*pmix_ptl_cbfunc_t)(struct pmix_peer_t *peer, pmix_peer_t 145 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h struct pmix_peer_t *peer; pmix_peer_t 170 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h struct pmix_peer_t *peer; pmix_peer_t 182 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h struct pmix_peer_t *peer; pmix_peer_t 207 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/ptl_types.h struct pmix_peer_t *peer; pmix_peer_t 69 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c static pmix_status_t connect_to_peer(struct pmix_peer_t *peer, pmix_peer_t 71 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c static pmix_status_t send_recv(struct pmix_peer_t *peer, pmix_peer_t 75 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c static pmix_status_t send_oneway(struct pmix_peer_t *peer, pmix_peer_t 125 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c static pmix_status_t connect_to_peer(struct pmix_peer_t *peer, pmix_peer_t 682 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c static pmix_status_t send_recv(struct pmix_peer_t *peer, pmix_peer_t 688 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c pmix_peer_t *pr = (pmix_peer_t*)peer; pmix_peer_t 704 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c static pmix_status_t send_oneway(struct pmix_peer_t *peer, pmix_peer_t 709 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp.c pmix_peer_t *pr = (pmix_peer_t*)peer; pmix_peer_t 958 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_peer_t *peer; pmix_peer_t 1329 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c peer = PMIX_NEW(pmix_peer_t); pmix_peer_t 1531 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c peer = PMIX_NEW(pmix_peer_t); pmix_peer_t 1711 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c pmix_peer_t *peer; pmix_peer_t 1786 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/tcp/ptl_tcp_component.c peer = (pmix_peer_t*)pnd->peer; pmix_peer_t 65 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c static pmix_status_t connect_to_peer(struct pmix_peer_t *peer, pmix_peer_t 67 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c static pmix_status_t send_recv(struct pmix_peer_t *peer, pmix_peer_t 71 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c static pmix_status_t send_oneway(struct pmix_peer_t *peer, pmix_peer_t 98 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c static pmix_status_t connect_to_peer(struct pmix_peer_t *peer, pmix_peer_t 234 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c static pmix_status_t send_recv(struct pmix_peer_t *peer, pmix_peer_t 240 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_peer_t *pr = (pmix_peer_t*)peer; pmix_peer_t 256 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c static pmix_status_t send_oneway(struct pmix_peer_t *peer, pmix_peer_t 261 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_peer_t *pr = (pmix_peer_t*)peer; pmix_peer_t 554 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_peer_t *peer = (pmix_peer_t*)cbdata; pmix_peer_t 692 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock.c pmix_peer_t *peer = (pmix_peer_t*)cbdata; pmix_peer_t 347 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c pmix_peer_t *psave = NULL; pmix_peer_t 582 opal/mca/pmix/pmix4x/pmix/src/mca/ptl/usock/ptl_usock_component.c psave = PMIX_NEW(pmix_peer_t); pmix_peer_t 244 opal/mca/pmix/pmix4x/pmix/src/runtime/pmix_init.c pmix_globals.mypeer = PMIX_NEW(pmix_peer_t); pmix_peer_t 271 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_client_globals.myserver = PMIX_NEW(pmix_peer_t); pmix_peer_t 433 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_peer_t *peer; pmix_peer_t 463 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (NULL != (peer = (pmix_peer_t*)pmix_pointer_array_get_item(&pmix_server_globals.clients, i))) { pmix_peer_t 625 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c void pmix_server_purge_events(pmix_peer_t *peer, pmix_peer_t 797 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_peer_t *peer; pmix_peer_t 1109 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_peer_t *peer; pmix_peer_t 1134 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c if (NULL == (peer = (pmix_peer_t*)pmix_pointer_array_get_item(&pmix_server_globals.clients, info->peerid))) { pmix_peer_t 3246 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c static pmix_status_t server_switchyard(pmix_peer_t *peer, uint32_t tag, pmix_peer_t 3548 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c void pmix_server_message_handler(struct pmix_peer_t *pr, pmix_peer_t 3552 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server.c pmix_peer_t *peer = (pmix_peer_t*)pr; pmix_peer_t 135 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_peer_t *peer; pmix_peer_t 601 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_peer_t *peer = NULL; pmix_peer_t 633 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c peer = (pmix_peer_t*)pmix_pointer_array_get_item(&pmix_server_globals.clients, iptr->peerid); pmix_peer_t 876 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c pmix_peer_t *peer; pmix_peer_t 958 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_get.c peer = (pmix_peer_t*)pmix_pointer_array_get_item(&pmix_server_globals.clients, rinfo->peerid); pmix_peer_t 84 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_abort(pmix_peer_t *peer, pmix_buffer_t *buf, pmix_peer_t 156 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_commit(pmix_peer_t *peer, pmix_buffer_t *buf) pmix_peer_t 1040 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_publish(pmix_peer_t *peer, pmix_peer_t 1133 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_lookup(pmix_peer_t *peer, pmix_peer_t 1230 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_unpublish(pmix_peer_t *peer, pmix_peer_t 1422 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_spawn(pmix_peer_t *peer, pmix_peer_t 2010 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_register_events(pmix_peer_t *peer, pmix_peer_t 2303 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c void pmix_server_deregister_events(pmix_peer_t *peer, pmix_peer_t 2410 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_event_recvd_from_client(pmix_peer_t *peer, pmix_peer_t 2504 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_query(pmix_peer_t *peer, pmix_peer_t 2682 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_log(pmix_peer_t *peer, pmix_peer_t 2778 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_alloc(pmix_peer_t *peer, pmix_peer_t 2853 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_job_ctrl(pmix_peer_t *peer, pmix_peer_t 2862 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_peer_t *pr; pmix_peer_t 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))) { pmix_peer_t 3152 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_monitor(pmix_peer_t *peer, pmix_peer_t 3244 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_get_credential(pmix_peer_t *peer, pmix_peer_t 3301 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_validate_credential(pmix_peer_t *peer, pmix_peer_t 3367 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_iofreg(pmix_peer_t *peer, pmix_peer_t 3567 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_status_t pmix_server_iofstdin(pmix_peer_t *peer, pmix_peer_t 3881 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_peer_t *peer = (pmix_peer_t*)cd->peer; pmix_peer_t 3882 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_peer_t *pr; pmix_peer_t 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))) { pmix_peer_t 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))) { pmix_peer_t 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))) { pmix_peer_t 4211 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.c pmix_peer_t *peer = (pmix_peer_t*)cd->peer; pmix_peer_t 46 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_peer_t *peer; pmix_peer_t 132 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_peer_t *peer; pmix_peer_t 242 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_abort(pmix_peer_t *peer, pmix_buffer_t *buf, pmix_peer_t 245 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_commit(pmix_peer_t *peer, pmix_buffer_t *buf); pmix_peer_t 256 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_publish(pmix_peer_t *peer, pmix_peer_t 261 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_lookup(pmix_peer_t *peer, pmix_peer_t 266 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_unpublish(pmix_peer_t *peer, pmix_peer_t 271 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_spawn(pmix_peer_t *peer, pmix_peer_t 290 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_register_events(pmix_peer_t *peer, pmix_peer_t 295 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h void pmix_server_deregister_events(pmix_peer_t *peer, pmix_peer_t 298 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_query(pmix_peer_t *peer, pmix_peer_t 303 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_log(pmix_peer_t *peer, pmix_peer_t 308 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_alloc(pmix_peer_t *peer, pmix_peer_t 313 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_job_ctrl(pmix_peer_t *peer, pmix_peer_t 318 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_monitor(pmix_peer_t *peer, pmix_peer_t 323 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_get_credential(pmix_peer_t *peer, pmix_peer_t 328 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_validate_credential(pmix_peer_t *peer, pmix_peer_t 333 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_iofreg(pmix_peer_t *peer, pmix_peer_t 338 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_iofstdin(pmix_peer_t *peer, pmix_peer_t 349 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h pmix_status_t pmix_server_event_recvd_from_client(pmix_peer_t *peer, pmix_peer_t 357 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h void pmix_server_message_handler(struct pmix_peer_t *pr, pmix_peer_t 361 opal/mca/pmix/pmix4x/pmix/src/server/pmix_server_ops.h void pmix_server_purge_events(pmix_peer_t *peer, pmix_peer_t 82 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c static void pmix_tool_notify_recv(struct pmix_peer_t *peer, pmix_peer_t 184 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c static void tool_iof_handler(struct pmix_peer_t *pr, pmix_peer_t 188 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_peer_t *peer = (pmix_peer_t*)pr; pmix_peer_t 228 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c static void job_data(struct pmix_peer_t *pr, pmix_peer_t 454 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_client_globals.myserver = PMIX_NEW(pmix_peer_t); pmix_peer_t 584 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c rc = pmix_ptl_base_connect_to_peer((struct pmix_peer_t*)pmix_client_globals.myserver, info, ninfo); pmix_peer_t 1106 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c static void finwait_cbfunc(struct pmix_peer_t *pr, pmix_peer_t 1130 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c pmix_peer_t *peer; pmix_peer_t 1207 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c if (NULL != (peer = (pmix_peer_t*)pmix_pointer_array_get_item(&pmix_client_globals.peers, n))) { pmix_peer_t 1216 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c if (NULL != (peer = (pmix_peer_t*)pmix_pointer_array_get_item(&pmix_server_globals.clients, n))) { pmix_peer_t 1313 opal/mca/pmix/pmix4x/pmix/src/tool/pmix_tool.c rc = pmix_ptl_base_connect_to_peer((struct pmix_peer_t*)pmix_client_globals.myserver, info, ninfo);