ompi_osc_rdma_peer_t 160 ompi/mca/osc/rdma/osc_rdma.h ompi_osc_rdma_peer_t *leader; ompi_osc_rdma_peer_t 163 ompi/mca/osc/rdma/osc_rdma.h ompi_osc_rdma_peer_t *my_peer; ompi_osc_rdma_peer_t 236 ompi/mca/osc/rdma/osc_rdma.h ompi_osc_rdma_peer_t **peer_array; ompi_osc_rdma_peer_t 291 ompi/mca/osc/rdma/osc_rdma.h int ompi_osc_module_add_peer (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer); ompi_osc_rdma_peer_t 301 ompi/mca/osc/rdma/osc_rdma.h int ompi_osc_rdma_demand_lock_peer (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer); ompi_osc_rdma_peer_t 312 ompi/mca/osc/rdma/osc_rdma.h static inline ompi_osc_rdma_peer_t *ompi_osc_module_get_peer (ompi_osc_rdma_module_t *module, int peer_id) ompi_osc_rdma_peer_t 315 ompi/mca/osc/rdma/osc_rdma.h ompi_osc_rdma_peer_t *peer = NULL; ompi_osc_rdma_peer_t 329 ompi/mca/osc/rdma/osc_rdma.h static inline ompi_osc_rdma_peer_t *ompi_osc_rdma_module_peer (ompi_osc_rdma_module_t *module, int peer_id) ompi_osc_rdma_peer_t 331 ompi/mca/osc/rdma/osc_rdma.h ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 398 ompi/mca/osc/rdma/osc_rdma.h ompi_osc_rdma_peer_t **peer) ompi_osc_rdma_peer_t 465 ompi/mca/osc/rdma/osc_rdma.h static inline ompi_osc_rdma_sync_t *ompi_osc_rdma_module_sync_lookup (ompi_osc_rdma_module_t *module, int target, struct ompi_osc_rdma_peer_t **peer) ompi_osc_rdma_peer_t 24 ompi/mca/osc/rdma/osc_rdma_accumulate.c static inline void ompi_osc_rdma_peer_accumulate_cleanup (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer, bool lock_acquired) ompi_osc_rdma_peer_t 123 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_osc_rdma_peer_t *peer, uint64_t target_address, ompi_osc_rdma_peer_t 171 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_datatype_t *datatype, ompi_osc_rdma_peer_t *peer, ompi_osc_rdma_peer_t 190 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_datatype_t *result_datatype, ompi_osc_rdma_peer_t *peer, uint64_t target_address, ompi_osc_rdma_peer_t 262 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_datatype_t *result_datatype, ompi_osc_rdma_peer_t *peer, uint64_t target_address, ompi_osc_rdma_peer_t 477 ompi/mca/osc/rdma/osc_rdma_accumulate.c void *result_addr, ompi_datatype_t *datatype, ompi_osc_rdma_peer_t *peer, ompi_osc_rdma_peer_t 521 ompi/mca/osc/rdma/osc_rdma_accumulate.c ptrdiff_t extent, ompi_osc_rdma_peer_t *peer, uint64_t target_address, ompi_osc_rdma_peer_t 566 ompi/mca/osc/rdma/osc_rdma_accumulate.c ptrdiff_t extent, ompi_osc_rdma_peer_t *peer, uint64_t target_address, ompi_osc_rdma_peer_t 625 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_osc_rdma_peer_t *peer, uint64_t target_address, mca_btl_base_registration_handle_t *target_handle, ompi_osc_rdma_peer_t 696 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_datatype_t *datatype, ompi_osc_rdma_peer_t *peer, uint64_t target_address, ompi_osc_rdma_peer_t 777 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 853 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_datatype_t *result_datatype, ompi_osc_rdma_peer_t *peer, ompi_osc_rdma_peer_t 953 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 980 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 1016 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 1050 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 1072 ompi/mca/osc/rdma/osc_rdma_accumulate.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 145 ompi/mca/osc/rdma/osc_rdma_active_target.c static ompi_osc_rdma_peer_t **ompi_osc_rdma_get_peers (ompi_osc_rdma_module_t *module, ompi_group_t *sub_group) ompi_osc_rdma_peer_t 148 ompi/mca/osc/rdma/osc_rdma_active_target.c ompi_osc_rdma_peer_t **peers; ompi_osc_rdma_peer_t 154 ompi/mca/osc/rdma/osc_rdma_active_target.c peers = calloc (size, sizeof (ompi_osc_rdma_peer_t *)); ompi_osc_rdma_peer_t 191 ompi/mca/osc/rdma/osc_rdma_active_target.c static void ompi_osc_rdma_release_peers (ompi_osc_rdma_peer_t **peers, int npeers) ompi_osc_rdma_peer_t 200 ompi/mca/osc/rdma/osc_rdma_active_target.c static void ompi_osc_rdma_handle_post (ompi_osc_rdma_module_t *module, int rank, ompi_osc_rdma_peer_t **peers, int npeers) { ompi_osc_rdma_peer_t 243 ompi/mca/osc/rdma/osc_rdma_active_target.c static int ompi_osc_rdma_post_peer (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer) ompi_osc_rdma_peer_t 303 ompi/mca/osc/rdma/osc_rdma_active_target.c ompi_osc_rdma_peer_t **peers; ompi_osc_rdma_peer_t 415 ompi/mca/osc/rdma/osc_rdma_active_target.c ompi_osc_rdma_peer_t *peer = sync->peer_list.peers[i]; ompi_osc_rdma_peer_t 449 ompi/mca/osc/rdma/osc_rdma_active_target.c ompi_osc_rdma_peer_t **peers; ompi_osc_rdma_peer_t 487 ompi/mca/osc/rdma/osc_rdma_active_target.c ompi_osc_rdma_peer_t *peer = peers[i]; ompi_osc_rdma_peer_t 45 ompi/mca/osc/rdma/osc_rdma_comm.c static int ompi_osc_rdma_get_contig (ompi_osc_rdma_sync_t *sync, ompi_osc_rdma_peer_t *peer, uint64_t source_address, ompi_osc_rdma_peer_t 154 ompi/mca/osc/rdma/osc_rdma_comm.c typedef int (*ompi_osc_rdma_fn_t) (ompi_osc_rdma_sync_t *sync, ompi_osc_rdma_peer_t *peer, uint64_t remote_address, ompi_osc_rdma_peer_t 179 ompi/mca/osc/rdma/osc_rdma_comm.c ompi_osc_rdma_peer_t *peer, uint64_t remote_address, ompi_osc_rdma_peer_t 314 ompi/mca/osc/rdma/osc_rdma_comm.c ompi_datatype_t *local_datatype, ompi_osc_rdma_peer_t *peer, ompi_osc_rdma_peer_t 437 ompi/mca/osc/rdma/osc_rdma_comm.c static int ompi_osc_rdma_put_real (ompi_osc_rdma_sync_t *sync, ompi_osc_rdma_peer_t *peer, uint64_t target_address, ompi_osc_rdma_peer_t 473 ompi/mca/osc/rdma/osc_rdma_comm.c int ompi_osc_rdma_put_contig (ompi_osc_rdma_sync_t *sync, ompi_osc_rdma_peer_t *peer, uint64_t target_address, ompi_osc_rdma_peer_t 569 ompi/mca/osc/rdma/osc_rdma_comm.c static int ompi_osc_rdma_get_partial (ompi_osc_rdma_sync_t *sync, ompi_osc_rdma_peer_t *peer, uint64_t source_address, ompi_osc_rdma_peer_t 591 ompi/mca/osc/rdma/osc_rdma_comm.c static int ompi_osc_rdma_get_contig (ompi_osc_rdma_sync_t *sync, ompi_osc_rdma_peer_t *peer, uint64_t source_address, ompi_osc_rdma_peer_t 726 ompi/mca/osc/rdma/osc_rdma_comm.c ompi_datatype_t *origin_datatype, ompi_osc_rdma_peer_t *peer, ompi_osc_rdma_peer_t 769 ompi/mca/osc/rdma/osc_rdma_comm.c ompi_osc_rdma_peer_t *peer, ptrdiff_t source_disp, int source_count, ompi_osc_rdma_peer_t 812 ompi/mca/osc/rdma/osc_rdma_comm.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 834 ompi/mca/osc/rdma/osc_rdma_comm.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 868 ompi/mca/osc/rdma/osc_rdma_comm.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 890 ompi/mca/osc/rdma/osc_rdma_comm.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 41 ompi/mca/osc/rdma/osc_rdma_comm.h static inline int osc_rdma_get_remote_segment (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer, ptrdiff_t target_disp, ompi_osc_rdma_peer_t 120 ompi/mca/osc/rdma/osc_rdma_comm.h int ompi_osc_rdma_put_contig (ompi_osc_rdma_sync_t *sync, ompi_osc_rdma_peer_t *peer, uint64_t target_address, ompi_osc_rdma_peer_t 419 ompi/mca/osc/rdma/osc_rdma_component.c ompi_osc_rdma_peer_t *my_peer; ompi_osc_rdma_peer_t 686 ompi/mca/osc/rdma/osc_rdma_component.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 1182 ompi/mca/osc/rdma/osc_rdma_component.c module->peer_array = calloc (world_size, sizeof (ompi_osc_rdma_peer_t *)); ompi_osc_rdma_peer_t 93 ompi/mca/osc/rdma/osc_rdma_dynamic.c ompi_osc_rdma_peer_t *my_peer = ompi_osc_rdma_module_peer (module, my_rank); ompi_osc_rdma_peer_t 365 ompi/mca/osc/rdma/osc_rdma_dynamic.c int ompi_osc_rdma_find_dynamic_region (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer, uint64_t base, size_t len, ompi_osc_rdma_peer_t 59 ompi/mca/osc/rdma/osc_rdma_dynamic.h int ompi_osc_rdma_find_dynamic_region (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer, uint64_t base, size_t len, ompi_osc_rdma_peer_t 106 ompi/mca/osc/rdma/osc_rdma_lock.h static inline int ompi_osc_rdma_lock_btl_fop (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer, uint64_t address, ompi_osc_rdma_peer_t 176 ompi/mca/osc/rdma/osc_rdma_lock.h static inline int ompi_osc_rdma_lock_btl_op (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer, uint64_t address, ompi_osc_rdma_peer_t 237 ompi/mca/osc/rdma/osc_rdma_lock.h static inline int ompi_osc_rdma_lock_btl_cswap (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer, uint64_t address, ompi_osc_rdma_peer_t 257 ompi/mca/osc/rdma/osc_rdma_lock.h static inline int ompi_osc_rdma_lock_release_shared (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer, ompi_osc_rdma_peer_t 289 ompi/mca/osc/rdma/osc_rdma_lock.h static inline int ompi_osc_rdma_lock_acquire_shared (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer, ompi_osc_rdma_peer_t 351 ompi/mca/osc/rdma/osc_rdma_lock.h static inline int ompi_osc_rdma_lock_try_acquire_exclusive (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer, ompi_osc_rdma_peer_t 395 ompi/mca/osc/rdma/osc_rdma_lock.h static inline int ompi_osc_rdma_lock_acquire_exclusive (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer, ompi_osc_rdma_peer_t 419 ompi/mca/osc/rdma/osc_rdma_lock.h static inline int ompi_osc_rdma_lock_release_exclusive (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer, ompi_osc_rdma_peer_t 29 ompi/mca/osc/rdma/osc_rdma_module.c int ompi_osc_module_add_peer (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer) ompi_osc_rdma_peer_t 46 ompi/mca/osc/rdma/osc_rdma_module.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 41 ompi/mca/osc/rdma/osc_rdma_passive_target.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 114 ompi/mca/osc/rdma/osc_rdma_passive_target.c static inline int ompi_osc_rdma_lock_atomic_internal (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer, ompi_osc_rdma_peer_t 164 ompi/mca/osc/rdma/osc_rdma_passive_target.c static inline int ompi_osc_rdma_unlock_atomic_internal (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer, ompi_osc_rdma_peer_t 188 ompi/mca/osc/rdma/osc_rdma_passive_target.c int ompi_osc_rdma_demand_lock_peer (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer) ompi_osc_rdma_peer_t 212 ompi/mca/osc/rdma/osc_rdma_passive_target.c ompi_osc_rdma_peer_t *peer = ompi_osc_rdma_module_peer (module, target); ompi_osc_rdma_peer_t 270 ompi/mca/osc/rdma/osc_rdma_passive_target.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 401 ompi/mca/osc/rdma/osc_rdma_passive_target.c ompi_osc_rdma_peer_t *peer, *next; ompi_osc_rdma_peer_t 404 ompi/mca/osc/rdma/osc_rdma_passive_target.c OPAL_LIST_FOREACH_SAFE(peer, next, &lock->demand_locked_peers, ompi_osc_rdma_peer_t) { ompi_osc_rdma_peer_t 57 ompi/mca/osc/rdma/osc_rdma_peer.c int ompi_osc_rdma_new_peer (struct ompi_osc_rdma_module_t *module, int peer_id, ompi_osc_rdma_peer_t **peer_out) { ompi_osc_rdma_peer_t 59 ompi/mca/osc/rdma/osc_rdma_peer.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 70 ompi/mca/osc/rdma/osc_rdma_peer.c peer = (ompi_osc_rdma_peer_t *) OBJ_NEW(ompi_osc_rdma_peer_dynamic_t); ompi_osc_rdma_peer_t 73 ompi/mca/osc/rdma/osc_rdma_peer.c peer = (ompi_osc_rdma_peer_t *) OBJ_NEW(ompi_osc_rdma_peer_basic_t); ompi_osc_rdma_peer_t 75 ompi/mca/osc/rdma/osc_rdma_peer.c peer = (ompi_osc_rdma_peer_t *) OBJ_NEW(ompi_osc_rdma_peer_extended_t); ompi_osc_rdma_peer_t 96 ompi/mca/osc/rdma/osc_rdma_peer.c static int ompi_osc_rdma_peer_setup (ompi_osc_rdma_module_t *module, ompi_osc_rdma_peer_t *peer) ompi_osc_rdma_peer_t 242 ompi/mca/osc/rdma/osc_rdma_peer.c static struct ompi_osc_rdma_peer_t *ompi_osc_rdma_peer_lookup_internal (struct ompi_osc_rdma_module_t *module, int peer_id) ompi_osc_rdma_peer_t 244 ompi/mca/osc/rdma/osc_rdma_peer.c ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 278 ompi/mca/osc/rdma/osc_rdma_peer.c struct ompi_osc_rdma_peer_t *ompi_osc_rdma_peer_lookup (struct ompi_osc_rdma_module_t *module, int peer_id) ompi_osc_rdma_peer_t 280 ompi/mca/osc/rdma/osc_rdma_peer.c struct ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 292 ompi/mca/osc/rdma/osc_rdma_peer.c static void ompi_osc_rdma_peer_construct (ompi_osc_rdma_peer_t *peer) ompi_osc_rdma_peer_t 297 ompi/mca/osc/rdma/osc_rdma_peer.c static void ompi_osc_rdma_peer_destruct (ompi_osc_rdma_peer_t *peer) ompi_osc_rdma_peer_t 304 ompi/mca/osc/rdma/osc_rdma_peer.c OBJ_CLASS_INSTANCE(ompi_osc_rdma_peer_t, opal_list_item_t, ompi_osc_rdma_peer_t 320 ompi/mca/osc/rdma/osc_rdma_peer.c OBJ_CLASS_INSTANCE(ompi_osc_rdma_peer_basic_t, ompi_osc_rdma_peer_t, ompi_osc_rdma_peer_t 339 ompi/mca/osc/rdma/osc_rdma_peer.c OBJ_CLASS_INSTANCE(ompi_osc_rdma_peer_dynamic_t, ompi_osc_rdma_peer_t, ompi_osc_rdma_peer_t 48 ompi/mca/osc/rdma/osc_rdma_peer.h typedef struct ompi_osc_rdma_peer_t ompi_osc_rdma_peer_t; ompi_osc_rdma_peer_t 54 ompi/mca/osc/rdma/osc_rdma_peer.h ompi_osc_rdma_peer_t super; ompi_osc_rdma_peer_t 73 ompi/mca/osc/rdma/osc_rdma_peer.h ompi_osc_rdma_peer_t super; ompi_osc_rdma_peer_t 106 ompi/mca/osc/rdma/osc_rdma_peer.h OBJ_CLASS_DECLARATION(ompi_osc_rdma_peer_t); ompi_osc_rdma_peer_t 151 ompi/mca/osc/rdma/osc_rdma_peer.h int ompi_osc_rdma_new_peer (struct ompi_osc_rdma_module_t *module, int peer_id, ompi_osc_rdma_peer_t **peer_out); ompi_osc_rdma_peer_t 162 ompi/mca/osc/rdma/osc_rdma_peer.h struct ompi_osc_rdma_peer_t *ompi_osc_rdma_peer_lookup (struct ompi_osc_rdma_module_t *module, int peer_id); ompi_osc_rdma_peer_t 180 ompi/mca/osc/rdma/osc_rdma_peer.h static inline bool ompi_osc_rdma_peer_is_exclusive (ompi_osc_rdma_peer_t *peer) ompi_osc_rdma_peer_t 194 ompi/mca/osc/rdma/osc_rdma_peer.h static inline bool ompi_osc_rdma_peer_test_set_flag (ompi_osc_rdma_peer_t *peer, int flag) ompi_osc_rdma_peer_t 216 ompi/mca/osc/rdma/osc_rdma_peer.h static inline void ompi_osc_rdma_peer_clear_flag (ompi_osc_rdma_peer_t *peer, int flag) ompi_osc_rdma_peer_t 227 ompi/mca/osc/rdma/osc_rdma_peer.h static inline bool ompi_osc_rdma_peer_local_base (ompi_osc_rdma_peer_t *peer) ompi_osc_rdma_peer_t 241 ompi/mca/osc/rdma/osc_rdma_peer.h static inline bool ompi_osc_rdma_peer_local_state (ompi_osc_rdma_peer_t *peer) ompi_osc_rdma_peer_t 252 ompi/mca/osc/rdma/osc_rdma_peer.h static inline bool ompi_osc_rdma_peer_is_demand_locked (ompi_osc_rdma_peer_t *peer) ompi_osc_rdma_peer_t 35 ompi/mca/osc/rdma/osc_rdma_request.h ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 51 ompi/mca/osc/rdma/osc_rdma_sync.c static inline bool ompi_osc_rdma_sync_array_peer (int rank, ompi_osc_rdma_peer_t **peers, size_t nranks, ompi_osc_rdma_peer_t 52 ompi/mca/osc/rdma/osc_rdma_sync.c struct ompi_osc_rdma_peer_t **peer) ompi_osc_rdma_peer_t 72 ompi/mca/osc/rdma/osc_rdma_sync.c bool ompi_osc_rdma_sync_pscw_peer (ompi_osc_rdma_module_t *module, int target, struct ompi_osc_rdma_peer_t **peer) ompi_osc_rdma_peer_t 83 ompi/mca/osc/rdma/osc_rdma_sync.h struct ompi_osc_rdma_peer_t **peers; ompi_osc_rdma_peer_t 85 ompi/mca/osc/rdma/osc_rdma_sync.h struct ompi_osc_rdma_peer_t *peer; ompi_osc_rdma_peer_t 137 ompi/mca/osc/rdma/osc_rdma_sync.h bool ompi_osc_rdma_sync_pscw_peer (struct ompi_osc_rdma_module_t *module, int target, struct ompi_osc_rdma_peer_t **peer); ompi_osc_rdma_peer_t 20 ompi/mca/osc/rdma/osc_rdma_types.h struct ompi_osc_rdma_peer_t;