/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/rxd/src/ |
H A D | rxd_av.c | 110 return rxd_addr == FI_ADDR_UNSPEC ? rxd_addr : in rxd_av_dg_addr() 118 while (av->rxd_addr_table[av->rxd_addr_idx].dg_addr != FI_ADDR_UNSPEC && in rxd_set_rxd_addr() 134 while (av->fi_addr_table[av->fi_addr_idx] != FI_ADDR_UNSPEC && in rxd_set_fi_addr() 198 util_addr = av->rxd_addr_table[rxd_addr].fi_addr == FI_ADDR_UNSPEC ? in rxd_av_insert() 279 av->fi_addr_table[fi_addr[i]] = FI_ADDR_UNSPEC; in rxd_av_remove() 280 av->rxd_addr_table[rxd_addr].fi_addr = FI_ADDR_UNSPEC; in rxd_av_remove() 281 av->rxd_addr_table[rxd_addr].dg_addr = FI_ADDR_UNSPEC; in rxd_av_remove() 309 if (dg_fiaddr == FI_ADDR_UNSPEC) in rxd_av_lookup() 400 for (i = 0; i < attr->count; av->fi_addr_table[i++] = FI_ADDR_UNSPEC) in rxd_av_create() 403 av->rxd_addr_table[i].fi_addr = FI_ADDR_UNSPEC; in rxd_av_create() [all …]
|
H A D | rxd_msg.c | 233 addr != FI_ADDR_UNSPEC) ? in rxd_ep_generic_recvmsg() 235 FI_ADDR_UNSPEC, op, rxd_flags); in rxd_ep_generic_recvmsg() 374 if (rxd_ep->peers[rxd_addr].peer_addr != FI_ADDR_UNSPEC) in rxd_ep_generic_inject() 412 if (rxd_ep->peers[rxd_addr].peer_addr == FI_ADDR_UNSPEC) in rxd_ep_generic_sendmsg()
|
H A D | rxd_rma.c | 117 if (rxd_ep->peers[rxd_addr].peer_addr == FI_ADDR_UNSPEC) in rxd_generic_write_inject() 164 if (rxd_ep->peers[rxd_addr].peer_addr == FI_ADDR_UNSPEC) in rxd_generic_rma()
|
H A D | rxd_cq.c | 210 if (ep->peers[addr].peer_addr != FI_ADDR_UNSPEC && in rxd_verify_active() 282 if (peer->peer_addr == FI_ADDR_UNSPEC) in rxd_progress_tx_list() 980 } else if (ep->peers[pkt->base_hdr.peer].peer_addr != FI_ADDR_UNSPEC) { in rxd_handle_data() 1007 if (ep->peers[base_hdr->peer].peer_addr != FI_ADDR_UNSPEC) in rxd_handle_op() 1012 if (ep->peers[base_hdr->peer].peer_addr == FI_ADDR_UNSPEC) in rxd_handle_op()
|
H A D | rxd_atomic.c | 148 if (rxd_ep->peers[rxd_addr].peer_addr != FI_ADDR_UNSPEC) in rxd_generic_atomic() 249 if (rxd_ep->peers[rxd_addr].peer_addr == FI_ADDR_UNSPEC) in rxd_atomic_inject()
|
H A D | rxd_ep.c | 237 pkt_entry->desc, FI_ADDR_UNSPEC, in rxd_ep_post_buf() 471 if (ep->peers[addr].peer_addr == FI_ADDR_UNSPEC && in rxd_send_rts_if_needed() 1141 ep->peers[rxd_addr].peer_addr = FI_ADDR_UNSPEC; in rxd_init_peer()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/sockets/src/ |
H A D | sock_rx_entry.c | 146 (rx_entry->addr == FI_ADDR_UNSPEC || addr == FI_ADDR_UNSPEC || in sock_rx_get_entry() 174 (rx_entry->addr == FI_ADDR_UNSPEC || addr == FI_ADDR_UNSPEC || in sock_rx_get_buffered_entry()
|
H A D | sock_msg.c | 124 msg->addr : FI_ADDR_UNSPEC; in sock_ep_recvmsg() 467 msg->addr : FI_ADDR_UNSPEC; in sock_ep_trecvmsg()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/util/src/ |
H A D | util_shm.c | 64 peer->addr = FI_ADDR_UNSPEC; in smr_peer_addr_init() 324 if (region->map->peers[index].peer.addr == FI_ADDR_UNSPEC) in smr_map_to_endpoint() 354 if (peer_index == FI_ADDR_UNSPEC) in smr_unmap_from_endpoint() 360 peer_peers[peer_index].addr.addr = FI_ADDR_UNSPEC; in smr_unmap_from_endpoint() 391 map->peers[id].peer.addr == FI_ADDR_UNSPEC) in smr_map_del() 401 map->peers[id].peer.addr = FI_ADDR_UNSPEC; in smr_map_del()
|
/dports/net/mpich/mpich-3.4.3/src/mpid/ch3/channels/nemesis/netmod/ofi/ |
H A D | ofi_cm.c | 107 FI_ADDR_UNSPEC, in MPID_nem_ofi_conn_req_callback() 256 FI_ADDR_UNSPEC, in MPID_nem_ofi_preposted_callback() 332 FI_ADDR_UNSPEC, in MPID_nem_ofi_cm_init() 351 FI_ADDR_UNSPEC, in MPID_nem_ofi_cm_init()
|
H A D | ofi_impl.h | 205 remote_proc = FI_ADDR_UNSPEC; \
|
/dports/net/mpich/mpich-3.4.3/src/mpid/ch4/netmod/ofi/ |
H A D | ofi_recv.h | 80 (MPI_ANY_SOURCE == rank) ? FI_ADDR_UNSPEC : MPIDI_OFI_av_to_phys(addr, vni_local, in MPIDI_OFI_recv_iov() 219 (MPI_ANY_SOURCE == rank) ? FI_ADDR_UNSPEC : in MPIDI_OFI_do_irecv() 235 msg.addr = FI_ADDR_UNSPEC; in MPIDI_OFI_do_irecv()
|
H A D | ofi_spawn.c | 247 msg.addr = FI_ADDR_UNSPEC; in dynproc_handshake() 373 msg.addr = FI_ADDR_UNSPEC; in dynproc_exchange_map() 406 FI_ADDR_UNSPEC, in dynproc_exchange_map() 419 FI_ADDR_UNSPEC, in dynproc_exchange_map() 426 FI_ADDR_UNSPEC, in dynproc_exchange_map()
|
H A D | ofi_probe.h | 33 remote_proc = FI_ADDR_UNSPEC; in MPIDI_OFI_do_iprobe()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/gni/test/ |
H A D | sep.c | 747 FI_ADDR_UNSPEC, source); in sep_send_recv() 798 msg.addr = FI_ADDR_UNSPEC; in sep_recvmsg() 831 tmsg.addr = FI_ADDR_UNSPEC; in sep_trecvmsg() 956 FI_ADDR_UNSPEC, iov_src_buf); in sep_recvv() 1028 FI_ADDR_UNSPEC, source); in _sendmsg() 1098 FI_ADDR_UNSPEC, source); in sep_sendmsgdata() 1129 FI_ADDR_UNSPEC, source); in sep_inject() 1171 FI_ADDR_UNSPEC, len, 0, source); in sep_tinject() 1215 FI_ADDR_UNSPEC, source); in sep_senddata() 1281 FI_ADDR_UNSPEC, source); in sep_injectdata() [all …]
|
H A D | rdm_multi_recv.c | 506 msg.addr = FI_ADDR_UNSPEC; in do_multirecv() 700 msg.addr = FI_ADDR_UNSPEC; in do_multirecv_send_first() 816 msg.addr = FI_ADDR_UNSPEC; in do_multirecv_trunc_last()
|
H A D | rdm_addr_str_sr.c | 315 sz = fi_recv(ep[1], target, len, NULL, FI_ADDR_UNSPEC, source); in do_send()
|
H A D | cancel.c | 326 ret = fi_recv(ep[0], (void *) 0xdeadbeef, 128, 0, FI_ADDR_UNSPEC, in Test()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/shm/src/ |
H A D | smr.h | 149 return (addr == FI_ADDR_UNSPEC) || (match_addr == FI_ADDR_UNSPEC) || in smr_match_addr()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/efa/src/ |
H A D | efa_av.c | 79 if (OFI_UNLIKELY(addr == FI_ADDR_UNSPEC)) in efa_av_tbl_idx_to_conn() 86 if (OFI_UNLIKELY(addr == FI_ADDR_UNSPEC)) in efa_av_map_addr_to_conn() 558 av->shm_rdm_addr_map[av_entry->shm_rdm_addr] = FI_ADDR_UNSPEC; in efa_av_remove() 738 av->shm_rdm_addr_map[i] = FI_ADDR_UNSPEC; in efa_av_open()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/fabtests/functional/ |
H A D | inj_complete.c | 87 ret = ft_recvmsg(ep, FI_ADDR_UNSPEC, size, in receive_msg()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/psm2/src/ |
H A D | psmx2_tagged.c | 54 if ((ep_priv->caps & FI_DIRECTED_RECV) && src_addr != FI_ADDR_UNSPEC) { in psmx2_tagged_peek_generic() 245 if ((ep_priv->caps & FI_DIRECTED_RECV) && src_addr != FI_ADDR_UNSPEC) { in psmx2_tagged_recv_generic() 313 if (directed_receive && src_addr != FI_ADDR_UNSPEC) { in psmx2_tagged_recv_specialized()
|
/dports/net/openmpi/openmpi-4.1.1/opal/mca/btl/ofi/ |
H A D | btl_ofi_module.c | 359 NULL, FI_ADDR_UNSPEC, &comp->comp_ctx); in mca_btl_ofi_post_recvs()
|
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/psm/src/ |
H A D | psmx_msg.c | 75 if ((ep_priv->caps & FI_DIRECTED_RECV) && src_addr != FI_ADDR_UNSPEC) { in _psmx_recv()
|
/dports/net/openmpi3/openmpi-3.1.6/ompi/mca/mtl/ofi/ |
H A D | mtl_ofi_component.c | 584 ompi_mtl_ofi.any_addr = FI_ADDR_UNSPEC; in ompi_mtl_ofi_component_init()
|