Home
last modified time | relevance | path

Searched refs:FI_ADDR_UNSPEC (Results 1 – 25 of 51) sorted by relevance

123

/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/rxd/src/
H A Drxd_av.c110 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 Drxd_msg.c233 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 Drxd_rma.c117 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 Drxd_cq.c210 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 Drxd_atomic.c148 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 Drxd_ep.c237 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 Dsock_rx_entry.c146 (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 Dsock_msg.c124 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 Dutil_shm.c64 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 Dofi_cm.c107 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 Dofi_impl.h205 remote_proc = FI_ADDR_UNSPEC; \
/dports/net/mpich/mpich-3.4.3/src/mpid/ch4/netmod/ofi/
H A Dofi_recv.h80 (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 Dofi_spawn.c247 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 Dofi_probe.h33 remote_proc = FI_ADDR_UNSPEC; in MPIDI_OFI_do_iprobe()
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/gni/test/
H A Dsep.c747 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 Drdm_multi_recv.c506 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 Drdm_addr_str_sr.c315 sz = fi_recv(ep[1], target, len, NULL, FI_ADDR_UNSPEC, source); in do_send()
H A Dcancel.c326 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 Dsmr.h149 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 Defa_av.c79 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 Dinj_complete.c87 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 Dpsmx2_tagged.c54 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 Dbtl_ofi_module.c359 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 Dpsmx_msg.c75 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 Dmtl_ofi_component.c584 ompi_mtl_ofi.any_addr = FI_ADDR_UNSPEC; in ompi_mtl_ofi_component_init()

123