| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/sockets/src/ |
| H A D | sock_msg.c | 255 if (flags & FI_REMOTE_CQ_DATA) in sock_ep_sendmsg()
269 if (flags & FI_REMOTE_CQ_DATA) in sock_ep_sendmsg()
345 return sock_ep_sendmsg(ep, &msg, FI_REMOTE_CQ_DATA | SOCK_USE_OP_FLAGS); in sock_ep_senddata()
384 return sock_ep_sendmsg(ep, &msg, FI_REMOTE_CQ_DATA | FI_INJECT | in sock_ep_injectdata()
599 if (flags & FI_REMOTE_CQ_DATA) in sock_ep_tsendmsg()
614 if (flags & FI_REMOTE_CQ_DATA) in sock_ep_tsendmsg()
697 return sock_ep_tsendmsg(ep, &msg, FI_REMOTE_CQ_DATA | SOCK_USE_OP_FLAGS); in sock_ep_tsenddata()
741 return sock_ep_tsendmsg(ep, &msg, FI_REMOTE_CQ_DATA | FI_INJECT | in sock_ep_tinjectdata()
|
| H A D | sock_rma.c | 309 if (flags & FI_REMOTE_CQ_DATA) in sock_ep_rma_writemsg()
428 return sock_ep_rma_writemsg(ep, &msg, FI_REMOTE_CQ_DATA | in sock_ep_rma_writedata()
485 return sock_ep_rma_writemsg(ep, &msg, FI_INJECT | FI_REMOTE_CQ_DATA | in sock_ep_rma_injectdata()
|
| H A D | sock_progress.c | 342 if (pe_entry->flags & FI_REMOTE_CQ_DATA) { in sock_pe_report_remote_write()
786 if (pe_entry->msg_hdr.flags & FI_REMOTE_CQ_DATA) { in sock_pe_process_rx_write()
1055 if (pe_entry->msg_hdr.flags & FI_REMOTE_CQ_DATA) in sock_pe_process_rx_tatomic()
1056 rx_entry->flags |= FI_REMOTE_CQ_DATA; in sock_pe_process_rx_tatomic()
1355 rx_entry->flags |= FI_REMOTE_CQ_DATA; in sock_pe_process_rx_send()
1405 if (pe_entry->msg_hdr.flags & FI_REMOTE_CQ_DATA) in sock_pe_process_rx_send()
1406 pe_entry->flags |= FI_REMOTE_CQ_DATA; in sock_pe_process_rx_send()
1646 if (pe_entry->flags & FI_REMOTE_CQ_DATA) { in sock_pe_progress_tx_atomic()
1732 if (pe_entry->flags & FI_REMOTE_CQ_DATA) { in sock_pe_progress_tx_write()
1841 if (pe_entry->flags & FI_REMOTE_CQ_DATA) { in sock_pe_progress_tx_send()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/fabtests/test_configs/verbs/ |
| H A D | all.test | 51 msg_flags: FI_REMOTE_CQ_DATA,
99 msg_flags: FI_REMOTE_CQ_DATA,
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/fabtests/test_configs/sockets/ |
| H A D | verify.test | 231 msg_flags: FI_REMOTE_CQ_DATA,
256 msg_flags: FI_REMOTE_CQ_DATA,
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/tcp/src/ |
| H A D | tcpx_rma.c | 204 if (flags & FI_REMOTE_CQ_DATA) { in tcpx_rma_writemsg()
330 return tcpx_rma_writemsg(ep, &msg, FI_REMOTE_CQ_DATA); in tcpx_rma_writedata()
356 if (flags & FI_REMOTE_CQ_DATA) { in tcpx_rma_inject_common()
402 FI_INJECT | FI_REMOTE_CQ_DATA); in tcpx_rma_injectdata()
|
| H A D | tcpx_cq.c | 162 flags |= FI_REMOTE_CQ_DATA; in tcpx_cq_report_success()
180 xfer_entry->flags |= FI_REMOTE_CQ_DATA; in tcpx_cq_report_error()
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/psm2/src/ |
| H A D | psmx2_rma.c | 151 FI_REMOTE_WRITE | FI_RMA | FI_REMOTE_CQ_DATA, in psmx2_am_rma_handler()
217 (has_data ? FI_REMOTE_CQ_DATA : 0), in psmx2_am_rma_handler()
476 if (flags & FI_REMOTE_CQ_DATA) in psmx2_rma_self()
485 if (flags & FI_REMOTE_CQ_DATA) in psmx2_rma_self()
518 FI_REMOTE_WRITE | FI_RMA | FI_REMOTE_CQ_DATA, in psmx2_rma_self()
1012 if (flags & FI_REMOTE_CQ_DATA) { in psmx2_write_generic()
1055 if (flags & FI_REMOTE_CQ_DATA) { in psmx2_write_generic()
1158 if (flags & FI_REMOTE_CQ_DATA) { in psmx2_writev_generic()
1210 if (flags & FI_REMOTE_CQ_DATA) { in psmx2_writev_generic()
1259 if (flags & FI_REMOTE_CQ_DATA) { in psmx2_writev_generic()
[all …]
|
| H A D | psmx2_msg.c | 202 int have_data = (flags & FI_REMOTE_CQ_DATA) > 0; in psmx2_send_generic()
356 if (flags & FI_REMOTE_CQ_DATA) in psmx2_sendv_generic()
496 rep->comp_flag |= FI_REMOTE_CQ_DATA; in psmx2_handle_sendv_req()
630 ep_priv->tx_flags | FI_REMOTE_CQ_DATA, data); in psmx2_senddata()
643 FI_REMOTE_CQ_DATA, in psmx2_injectdata()
|
| H A D | psmx2_cq.c | 438 flags |= FI_REMOTE_CQ_DATA; in psmx2_mq_status_copy()
462 flags |= FI_REMOTE_CQ_DATA; in psmx2_mq_status_copy()
486 flags |= FI_REMOTE_CQ_DATA; in psmx2_mq_status_copy()
624 flags |= FI_REMOTE_CQ_DATA; in psmx2_mq_status_copy()
667 if (am_req->ep->recv_cq && (am_req->cq_flags & FI_REMOTE_CQ_DATA)) { in psmx2_mq_status_copy()
668 flags |= FI_REMOTE_CQ_DATA; in psmx2_mq_status_copy()
1140 flags |= FI_REMOTE_CQ_DATA; in psmx2_cq_poll_mq()
1166 flags |= FI_REMOTE_CQ_DATA; in psmx2_cq_poll_mq()
1195 flags |= FI_REMOTE_CQ_DATA; in psmx2_cq_poll_mq()
1351 flags |= FI_REMOTE_CQ_DATA; in psmx2_cq_poll_mq()
[all …]
|
| H A D | psmx2_tagged.c | 88 flags |= FI_REMOTE_CQ_DATA; in psmx2_tagged_peek_generic()
523 int have_data = (flags & FI_REMOTE_CQ_DATA) > 0; in PSMX2_TAGGED_RECVV_FUNC()
833 int have_data = (flags & FI_REMOTE_CQ_DATA) > 0; in psmx2_tagged_sendv_generic()
1037 ep_priv->tx_flags | FI_REMOTE_CQ_DATA, in psmx2_tagged_senddata()
1101 ep_priv->tx_flags | FI_INJECT | FI_REMOTE_CQ_DATA | in psmx2_tagged_injectdata()
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/psm/src/ |
| H A D | psmx_rma.c | 112 FI_REMOTE_WRITE | FI_RMA | FI_REMOTE_CQ_DATA, in psmx_am_rma_handler()
176 req->cq_flags = FI_REMOTE_WRITE | FI_RMA | (has_data ? FI_REMOTE_CQ_DATA : 0), in psmx_am_rma_handler()
365 if (flags & FI_REMOTE_CQ_DATA) in psmx_rma_self()
382 FI_REMOTE_WRITE | FI_RMA | FI_REMOTE_CQ_DATA, in psmx_rma_self()
758 if (flags & FI_REMOTE_CQ_DATA) { in _psmx_write()
809 if (flags & FI_REMOTE_CQ_DATA) { in _psmx_write()
877 ep_priv->tx_flags | FI_REMOTE_CQ_DATA, data); in psmx_writedata()
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/shm/src/ |
| H A D | smr_rma.c | 131 (FI_REMOTE_CQ_DATA | FI_DELIVERY_COMPLETE)) && in smr_generic_rma()
376 cmds = 1 + !(domain->fast_rma && !(flags & FI_REMOTE_CQ_DATA) && in smr_generic_rma_inject()
443 FI_REMOTE_CQ_DATA | smr_ep_tx_flags(ep)); in smr_writedata()
458 data, FI_REMOTE_CQ_DATA); in smr_inject_writedata()
|
| H A D | smr_msg.c | 359 FI_REMOTE_CQ_DATA | smr_ep_tx_flags(ep)); in smr_senddata()
366 ofi_op_msg, FI_REMOTE_CQ_DATA); in smr_injectdata()
486 FI_REMOTE_CQ_DATA | smr_ep_tx_flags(ep)); in smr_tsenddata()
493 ofi_op_tagged, FI_REMOTE_CQ_DATA); in smr_tinjectdata()
|
| /dports/net/openmpi/openmpi-4.1.1/ompi/mca/mtl/ofi/ |
| H A D | README | 36 FI_REMOTE_CQ_DATA and FI_DIRECTED_RECV support (see fi_tagged(3), fi_msg(2)
41 For providers that do not support FI_REMOTE_CQ_DATA, the OFI MTL will
61 of the matching receive operation. Since the minimum size for FI_REMOTE_CQ_DATA
65 and FI_REMOTE_CQ_DATA or FI_DIRECTED_RECV are not supported, the execution will abort.
241 send functionality based on FI_REMOTE_CQ_DATA & OFI Scalable Endpoint support
243 runtime based on if FI_REMOTE_CQ_DATA is supported and/or if OFI Scalable
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/fabtests/functional/ |
| H A D | cq_data.c | 68 if (comp.flags & FI_REMOTE_CQ_DATA) { in run_test()
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/fabtests/test_configs/ofi_rxm/ |
| H A D | verbs.test | 84 msg_flags: FI_REMOTE_CQ_DATA,
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/rxm/src/ |
| H A D | rxm_rma.c | 283 if (flags & FI_REMOTE_CQ_DATA) { in rxm_ep_rma_inject_common()
382 FI_REMOTE_CQ_DATA); in rxm_ep_writedata()
467 addr, key, FI_REMOTE_CQ_DATA | FI_INJECT); in rxm_ep_inject_writedata()
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/man/ |
| H A D | fi_rma.3.md | 190 of remote CQ data (see FI_REMOTE_CQ_DATA flag) as part of the
196 of remote CQ data (see FI_REMOTE_CQ_DATA flag) as part of the
228 *FI_REMOTE_CQ_DATA*
232 FI_REMOTE_CQ_DATA.
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/mrail/src/ |
| H A D | mrail_rma.c | 91 if (flags & FI_REMOTE_CQ_DATA) { in mrail_post_subreq()
93 flags &= ~FI_REMOTE_CQ_DATA; in mrail_post_subreq()
|
| H A D | mrail_cq.c | 80 (comp->flags & FI_REMOTE_CQ_DATA), in mrail_cq_write_recv_comp()
149 recv->rndv.flags = comp->flags & FI_REMOTE_CQ_DATA; in mrail_cq_process_rndv_req()
267 recv->comp_flags | (comp->flags & FI_REMOTE_CQ_DATA), in mrail_cq_process_buf_recv()
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/gni/test/ |
| H A D | rdm_sr.c | 619 if (flags & FI_REMOTE_CQ_DATA) in rdm_sr_check_err_cqe()
1156 sz = fi_sendmsg(ep[0], &msg, FI_REMOTE_CQ_DATA); in do_sendmsgdata()
1176 (FI_MSG|FI_RECV|FI_REMOTE_CQ_DATA), in do_sendmsgdata()
1352 sz = fi_sendmsg(ep[0], &msg, FI_REMOTE_CQ_DATA); in do_senddata_eager_auto()
1359 sz = fi_sendmsg(ep[0], &msg, FI_REMOTE_CQ_DATA | FI_FENCE); in do_senddata_eager_auto()
1375 rdm_sr_check_cqe(&d_cqe[0], source2, (FI_MSG|FI_RECV|FI_REMOTE_CQ_DATA), in do_senddata_eager_auto()
1377 rdm_sr_check_cqe(&d_cqe[1], source, (FI_MSG|FI_RECV|FI_REMOTE_CQ_DATA), in do_senddata_eager_auto()
1451 (FI_MSG|FI_RECV|FI_REMOTE_CQ_DATA), in do_senddata()
1501 rdm_sr_check_cqe(&cqe, source, (FI_MSG|FI_RECV|FI_REMOTE_CQ_DATA), in do_injectdata()
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/verbs/src/ |
| H A D | verbs_msg.c | 94 if (flags & FI_REMOTE_CQ_DATA) { in vrb_msg_ep_sendmsg()
246 if (flags & FI_REMOTE_CQ_DATA) { in vrb_msg_xrc_ep_sendmsg()
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/fabtests/ubertest/ |
| H A D | verify.c | 180 if (comp->flags & FI_REMOTE_CQ_DATA) { in ft_verify_comp()
|
| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/efa/src/rxr/ |
| H A D | rxr_msg.c | 246 rxr_tx_flags(rxr_ep) | FI_REMOTE_CQ_DATA); in rxr_msg_senddata()
299 FI_REMOTE_CQ_DATA | FI_INJECT); in rxr_msg_injectdata()
374 rxr_tx_flags(rxr_ep) | FI_REMOTE_CQ_DATA); in rxr_msg_tsenddata()
427 FI_REMOTE_CQ_DATA | FI_INJECT); in rxr_msg_tinjectdata()
|