Home
last modified time | relevance | path

Searched refs:tx_attr (Results 1 – 25 of 114) sorted by relevance

12345

/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/rxm/src/
H A Drxm_init.c114 if (hints->tx_attr) { in rxm_info_to_core()
117 core_info->tx_attr->msg_order = hints->tx_attr->msg_order; in rxm_info_to_core()
118 core_info->tx_attr->comp_order = hints->tx_attr->comp_order; in rxm_info_to_core()
150 info->tx_attr->caps = rxm_info.tx_attr->caps; in rxm_info_to_rxm()
152 info->tx_attr->msg_order = core_info->tx_attr->msg_order; in rxm_info_to_rxm()
153 info->tx_attr->comp_order = rxm_info.tx_attr->comp_order; in rxm_info_to_rxm()
154 info->tx_attr->inject_size = rxm_info.tx_attr->inject_size; in rxm_info_to_rxm()
155 info->tx_attr->size = rxm_info.tx_attr->size; in rxm_info_to_rxm()
156 info->tx_attr->iov_limit = MIN(rxm_info.tx_attr->iov_limit, in rxm_info_to_rxm()
158 info->tx_attr->rma_iov_limit = MIN(rxm_info.tx_attr->rma_iov_limit, in rxm_info_to_rxm()
[all …]
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/psm/src/
H A Dpsmx_init.c382 if (hints->tx_attr) { in psmx_getinfo()
384 hints->tx_attr->op_flags) { in psmx_getinfo()
395 hints->tx_attr->inject_size, in psmx_getinfo()
517 if (hints->tx_attr) { in psmx_getinfo()
519 hints->tx_attr->msg_order) { in psmx_getinfo()
527 hints->tx_attr->comp_order) { in psmx_getinfo()
538 hints->tx_attr->inject_size, in psmx_getinfo()
546 hints->tx_attr->iov_limit); in psmx_getinfo()
553 hints->tx_attr->rma_iov_limit); in psmx_getinfo()
646 psmx_info->tx_attr->op_flags = (hints && hints->tx_attr && hints->tx_attr->op_flags) in psmx_getinfo()
[all …]
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/bgq/src/
H A Dfi_bgq_init.c49 if ((info->tx_attr) && ((info->tx_attr->caps | info->caps) != info->caps)) { in fi_bgq_check_info()
52 info->tx_attr->caps, info->caps); in fi_bgq_check_info()
75 if (info->tx_attr) { in fi_bgq_check_info()
76 ret = fi_bgq_check_tx_attr(info->tx_attr); in fi_bgq_check_info()
174 memcpy(fi->tx_attr, fi_bgq_global.default_tx_attr, sizeof(*fi->tx_attr)); in fi_bgq_fillinfo()
176 if (hints->tx_attr) { in fi_bgq_fillinfo()
186 if (hints->tx_attr->caps) { in fi_bgq_fillinfo()
187 fi->tx_attr->caps = hints->tx_attr->caps; in fi_bgq_fillinfo()
191 fi->tx_attr->op_flags = hints->tx_attr->op_flags; in fi_bgq_fillinfo()
193 fi->tx_attr->caps = hints->caps; in fi_bgq_fillinfo()
[all …]
H A Dfi_bgq_sep.c91 struct fi_tx_attr tx_attr = {0}; in fi_bgq_tx_ctx() local
154 info.tx_attr = &tx_attr; in fi_bgq_tx_ctx()
155 memcpy(info.tx_attr, attr, sizeof(*info.tx_attr)); in fi_bgq_tx_ctx()
327 if (info.tx_attr) in fi_bgq_rx_ctx()
328 free(info.tx_attr); in fi_bgq_rx_ctx()
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/efa/src/rxr/
H A Drxr_init.c271 core_info->tx_attr->inject_size = in rxr_reset_rx_tx_to_core()
272 user_info->tx_attr->inject_size < core_info->tx_attr->inject_size ? in rxr_reset_rx_tx_to_core()
273 user_info->tx_attr->inject_size : core_info->tx_attr->inject_size; in rxr_reset_rx_tx_to_core()
274 core_info->tx_attr->size = in rxr_reset_rx_tx_to_core()
275 user_info->tx_attr->size < core_info->tx_attr->size ? in rxr_reset_rx_tx_to_core()
276 user_info->tx_attr->size : core_info->tx_attr->size; in rxr_reset_rx_tx_to_core()
285 info->tx_attr->size = core_info->tx_attr->size; in rxr_set_rx_tx_size()
315 *info->tx_attr = *rxr_info.tx_attr; in rxr_info_to_rxr()
321 info->tx_attr->inject_size = 0; in rxr_info_to_rxr()
322 rxr_info.tx_attr->inject_size = info->tx_attr->inject_size; in rxr_info_to_rxr()
[all …]
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/netdir/src/
H A Dnetdir_init.c103 info->tx_attr->caps = FI_MSG | FI_SEND; in ofi_nd_adapter_cb()
104 info->tx_attr->comp_order = FI_ORDER_STRICT; in ofi_nd_adapter_cb()
105 info->tx_attr->inject_size = (size_t)gl_data.inline_thr; in ofi_nd_adapter_cb()
106 info->tx_attr->size = (size_t)adapter->MaxTransferLength; in ofi_nd_adapter_cb()
109 info->tx_attr->iov_limit = ND_MSG_IOV_LIMIT; in ofi_nd_adapter_cb()
110 info->tx_attr->rma_iov_limit = ND_MSG_IOV_LIMIT; in ofi_nd_adapter_cb()
111 info->tx_attr->op_flags = OFI_ND_TX_OP_FLAGS; in ofi_nd_adapter_cb()
112 info->tx_attr->msg_order = OFI_ND_MSG_ORDER; in ofi_nd_adapter_cb()
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/usnic/src/
H A Dusdf_ep_dgram.c611 if (!hints || !hints->tx_attr) in usdf_dgram_fill_tx_attr()
642 if (hints->tx_attr->iov_limit && hints->tx_attr->size) { in usdf_dgram_fill_tx_attr()
643 defaults.size = hints->tx_attr->size; in usdf_dgram_fill_tx_attr()
645 } else if (hints->tx_attr->iov_limit) { in usdf_dgram_fill_tx_attr()
649 } else if (hints->tx_attr->size) { in usdf_dgram_fill_tx_attr()
650 defaults.size = hints->tx_attr->size; in usdf_dgram_fill_tx_attr()
673 *fi->tx_attr = defaults; in usdf_dgram_fill_tx_attr()
876 if (info->tx_attr) { in usdf_ep_dgram_open()
878 if (info->tx_attr->iov_limit) in usdf_ep_dgram_open()
880 if (info->tx_attr->size) in usdf_ep_dgram_open()
[all …]
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/rstream/src/
H A Drstream_init.c61 core_info->tx_attr->op_flags = FI_COMPLETION; in rstream_info_to_core()
73 rstream_info.tx_attr->iov_limit = core_info->tx_attr->iov_limit; in update_rstream_info()
75 rstream_info.tx_attr->size = core_info->tx_attr->size; in update_rstream_info()
98 *info->tx_attr = *rstream_info.tx_attr; in rstream_info_to_rstream()
123 rstream_info.tx_attr->iov_limit = 3; in rstream_getinfo()
H A Drstream_attr.c78 .tx_attr = &rstream_tx_attr,
95 *info->tx_attr = rstream_tx_attr; in rstream_set_info()
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/mrail/src/
H A Dmrail_init.c174 if (hints->tx_attr) { in mrail_create_core_hints()
175 if (hints->tx_attr->iov_limit) in mrail_create_core_hints()
176 core_hints->tx_attr->iov_limit = in mrail_create_core_hints()
177 hints->tx_attr->iov_limit + 1; in mrail_create_core_hints()
181 core_hints->tx_attr->op_flags &= ~FI_COMPLETION; in mrail_create_core_hints()
394 if (hints->tx_attr) { in mrail_adjust_info()
395 if (hints->tx_attr->op_flags & FI_COMPLETION) in mrail_adjust_info()
396 info->tx_attr->op_flags |= FI_COMPLETION; in mrail_adjust_info()
435 assert(fi->tx_attr->iov_limit); in mrail_get_prefix_info()
436 fi->tx_attr->iov_limit--; in mrail_get_prefix_info()
[all …]
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/efa/src/
H A Defa_ep.c330 struct fi_tx_attr *tx_attr = ep->info->tx_attr; in efa_ep_getflags() local
336 } else if (tx_attr && (*flags & FI_TRANSMIT)) { in efa_ep_getflags()
337 *flags = tx_attr->op_flags; in efa_ep_getflags()
350 struct fi_tx_attr *tx_attr = ep->info->tx_attr; in efa_ep_setflags() local
356 } else if (tx_attr && (flags & FI_TRANSMIT)) { in efa_ep_setflags()
357 tx_attr->op_flags = flags; in efa_ep_setflags()
358 tx_attr->op_flags &= ~FI_TRANSMIT; in efa_ep_setflags()
404 attr_ex.cap.max_send_wr = ep->info->tx_attr->size; in efa_ep_enable()
603 if (info->tx_attr) { in efa_ep_open()
604 ret = ofi_check_tx_attr(&efa_prov, fi->tx_attr, in efa_ep_open()
[all …]
H A Defa_fabric.c244 if (hints->tx_attr) { in efa_check_hints()
245 ret = ofi_check_tx_attr(&efa_prov, info->tx_attr, hints->tx_attr, hints->mode); in efa_check_hints()
532 info->tx_attr->iov_limit = efadv_attr.max_sq_sge; in efa_get_device_attrs()
533 info->tx_attr->size = align_down_to_power_of_2(efadv_attr.max_sq_wr); in efa_get_device_attrs()
535 info->tx_attr->inject_size = efadv_attr.inline_buf_size; in efa_get_device_attrs()
545 info->tx_attr->inject_size = 0; in efa_get_device_attrs()
556 info->tx_attr->iov_limit, in efa_get_device_attrs()
557 info->tx_attr->size, in efa_get_device_attrs()
558 info->tx_attr->inject_size, in efa_get_device_attrs()
643 *fi->tx_attr = efa_rdm_tx_attr; in efa_alloc_info()
[all …]
H A Defa_msg.c112 msg->iov_count, ep->info->tx_attr->iov_limit); in efa_post_recv_validate()
228 if (OFI_UNLIKELY(msg->iov_count > ep->info->tx_attr->iov_limit)) { in efa_post_send_validate()
230 msg->iov_count, ep->info->tx_attr->iov_limit); in efa_post_send_validate()
367 flags = ep->info->tx_attr->op_flags; in efa_ep_send()
383 flags = ep->info->tx_attr->op_flags | FI_REMOTE_CQ_DATA; in efa_ep_senddata()
397 flags = ep->info->tx_attr->op_flags; in efa_ep_sendv()
/dports/net/mpich/mpich-3.4.3/modules/libfabric/fabtests/unit/
H A Dgetinfo_test.c166 hints->tx_attr->msg_order = order; in init_tx_order()
250 info->tx_attr->caps); in check_no_extra_caps()
313 hints->tx_attr->msg_order = FI_ORDER_RAW; in init_valid_rma_RAW_ordering_no_set_size()
326 hints->tx_attr->msg_order = FI_ORDER_RAW; in init_valid_rma_RAW_ordering_set_size()
346 hints->tx_attr->msg_order = FI_ORDER_WAR; in init_valid_rma_WAR_ordering_no_set_size()
359 hints->tx_attr->msg_order = FI_ORDER_WAR; in init_valid_rma_WAR_ordering_set_size()
379 hints->tx_attr->msg_order = FI_ORDER_WAW; in init_valid_rma_WAW_ordering_no_set_size()
392 hints->tx_attr->msg_order = FI_ORDER_WAW; in init_valid_rma_WAW_ordering_set_size()
447 hints->tx_attr->msg_order = FI_ORDER_RAW; in init_invalid_rma_RAW_ordering_size()
473 hints->tx_attr->msg_order = FI_ORDER_WAR; in init_invalid_rma_WAR_ordering_size()
[all …]
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/gni/src/
H A Dgnix_fabric.c250 gnix_info->tx_attr->op_flags = 0; in _gnix_allocinfo()
293 gnix_info->tx_attr->msg_order = FI_ORDER_SAS; in _gnix_allocinfo()
294 gnix_info->tx_attr->comp_order = FI_ORDER_NONE; in _gnix_allocinfo()
295 gnix_info->tx_attr->size = GNIX_TX_SIZE_DEFAULT; in _gnix_allocinfo()
297 gnix_info->tx_attr->inject_size = GNIX_INJECT_SIZE; in _gnix_allocinfo()
534 if (hints->tx_attr) { in _gnix_ep_getinfo()
536 hints->tx_attr->op_flags) { in _gnix_ep_getinfo()
543 gnix_info->tx_attr->op_flags = in _gnix_ep_getinfo()
544 hints->tx_attr->op_flags & GNIX_EP_OP_FLAGS; in _gnix_ep_getinfo()
669 gnix_info->tx_attr->caps = gnix_info->caps; in _gnix_ep_getinfo()
[all …]
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/shm/src/
H A Dsmr_init.c47 fi_param_get_size_t(&smr_prov, "tx_size", &smr_info.tx_attr->size); in smr_init_env()
129 msg_order = hints && hints->tx_attr ? hints->tx_attr->msg_order : 0; in smr_getinfo()
137 ret = smr_shm_space_check((*info)->tx_attr->size, (*info)->rx_attr->size); in smr_getinfo()
158 cur->tx_attr->msg_order = FI_ORDER_SAS; in smr_getinfo()
/dports/net/mpich/mpich-3.4.3/modules/libfabric/fabtests/benchmarks/
H A Dbenchmark_shared.c52 hints->tx_attr->inject_size = atoi(optarg); in ft_parse_benchmark_opts()
86 if (opts.transfer_size < fi->tx_attr->inject_size) in pingpong()
106 if (opts.transfer_size < fi->tx_attr->inject_size) in pingpong()
166 if (opts.transfer_size < fi->tx_attr->inject_size) in bandwidth()
248 if (opts.transfer_size < fi->tx_attr->inject_size) { in bandwidth_rma()
268 if (opts.transfer_size < fi->tx_attr->inject_size) { in bandwidth_rma()
/dports/net/mpich/mpich-3.4.3/modules/libfabric/src/
H A Dabi_1_0.c101 struct fi_tx_attr *tx_attr; member
118 struct fi_tx_attr *tx_attr; member
192 struct fi_tx_attr_1_2 *tx_attr; member
232 dup->tx_attr = NULL; in fi_dupinfo_1_0()
249 if (info->tx_attr != NULL) { in fi_dupinfo_1_0()
250 ofi_dup_attr(dup->tx_attr, info->tx_attr); in fi_dupinfo_1_0()
251 if (dup->tx_attr == NULL) in fi_dupinfo_1_0()
/dports/net/mpich/mpich-3.4.3/src/mpid/ch4/netmod/ofi/
H A Dofi_init.c1193 struct fi_tx_attr tx_attr; in create_sep_tx() local
1194 tx_attr = *(MPIDI_OFI_global.prov_use->tx_attr); in create_sep_tx()
1195 tx_attr.op_flags = FI_COMPLETION; in create_sep_tx()
1198 tx_attr.caps = 0; in create_sep_tx()
1201 tx_attr.caps = FI_TAGGED; in create_sep_tx()
1205 tx_attr.caps |= FI_RMA; in create_sep_tx()
1207 tx_attr.caps |= FI_ATOMICS; in create_sep_tx()
1209 tx_attr.caps |= FI_MSG; in create_sep_tx()
1301 struct fi_tx_attr tx_attr; in create_rma_stx_ctx() local
1302 memset(&tx_attr, 0, sizeof(tx_attr)); in create_rma_stx_ctx()
[all …]
H A Dofi_win.c83 finfo->tx_attr->caps = FI_RMA | FI_WRITE | FI_READ | FI_ATOMIC; in set_rma_fi_info()
89 finfo->tx_attr->msg_order = FI_ORDER_NONE; /* FI_ORDER_NONE is an alias for the value 0 */ in set_rma_fi_info()
93 finfo->tx_attr->msg_order |= FI_ORDER_ATOMIC_RAR; in set_rma_fi_info()
95 finfo->tx_attr->msg_order |= FI_ORDER_RAR; in set_rma_fi_info()
100 finfo->tx_attr->msg_order |= FI_ORDER_ATOMIC_RAW; in set_rma_fi_info()
102 finfo->tx_attr->msg_order |= FI_ORDER_RAW; in set_rma_fi_info()
107 finfo->tx_attr->msg_order |= FI_ORDER_ATOMIC_WAR; in set_rma_fi_info()
109 finfo->tx_attr->msg_order |= FI_ORDER_WAR; in set_rma_fi_info()
114 finfo->tx_attr->msg_order |= FI_ORDER_ATOMIC_WAW; in set_rma_fi_info()
116 finfo->tx_attr->msg_order |= FI_ORDER_WAW; in set_rma_fi_info()
[all …]
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/verbs/src/
H A Dverbs_info.c285 if (hints->tx_attr) { in vrb_check_hints()
287 hints->tx_attr, hints->mode); in vrb_check_hints()
454 assert(info->tx_attr->size && in vrb_get_qp_cap()
455 info->tx_attr->iov_limit && in vrb_get_qp_cap()
460 info->tx_attr->size); in vrb_get_qp_cap()
462 info->tx_attr->iov_limit); in vrb_get_qp_cap()
803 *(fi->tx_attr) = verbs_tx_attr; in vrb_alloc_info()
1388 info->tx_attr->mode = prov_info->tx_attr->mode; in vrb_get_passive_info()
1738 if (!hints || !hints->tx_attr || !hints->tx_attr->inject_size) { in vrb_alter_info()
1744 cur->tx_attr->inject_size = in vrb_alter_info()
[all …]
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/sockets/src/
H A Dsock_ep.c300 *flags = tx_attr->op_flags; in sock_getopflags()
317 tx_attr->op_flags = flags; in sock_setopflags()
318 tx_attr->op_flags &= ~FI_TRANSMIT; in sock_setopflags()
932 memcpy(&new_ep->tx_attr, &sock_ep->tx_attr, sizeof(struct fi_tx_attr)); in sock_ep_control()
1125 sock_ep->attr->info.tx_attr->caps, in sock_ep_tx_ctx()
1535 if (hints->tx_attr) in sock_fi_info()
1536 *(info->tx_attr) = *(hints->tx_attr); in sock_fi_info()
1678 if (info->tx_attr) { in sock_alloc_endpoint()
1679 sock_ep->tx_attr = *info->tx_attr; in sock_alloc_endpoint()
1683 sock_ep->tx_attr.size = sock_ep->tx_attr.size ? in sock_alloc_endpoint()
[all …]
/dports/net/mpich/mpich-3.4.3/modules/libfabric/fabtests/ubertest/
H A Dxfer.c160 ft_next_iov_cnt(&ft_tx_ctrl, fabric_info->tx_attr->iov_limit); in ft_post_send()
172 ft_next_iov_cnt(&ft_tx_ctrl, fabric_info->tx_attr->iov_limit); in ft_post_send()
220 ft_next_iov_cnt(&ft_tx_ctrl, fabric_info->tx_attr->iov_limit); in ft_post_tsend()
233 ft_next_iov_cnt(&ft_tx_ctrl, fabric_info->tx_attr->iov_limit); in ft_post_tsend()
294 ft_next_iov_cnt(&ft_tx_ctrl, fabric_info->tx_attr->iov_limit); in ft_post_send_rma()
315 ft_next_iov_cnt(&ft_tx_ctrl, fabric_info->tx_attr->iov_limit); in ft_post_send_rma()
324 ft_next_iov_cnt(&ft_tx_ctrl, fabric_info->tx_attr->iov_limit); in ft_post_send_rma()
346 ft_next_iov_cnt(&ft_tx_ctrl, fabric_info->tx_attr->iov_limit); in ft_post_send_rma()
400 ft_next_iov_cnt(&ft_tx_ctrl, fabric_info->tx_attr->iov_limit); in ft_post_send_atomic()
422 ft_next_iov_cnt(&ft_tx_ctrl, fabric_info->tx_attr->iov_limit); in ft_post_send_atomic()
[all …]
/dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/rxd/src/
H A Drxd_init.c97 *info->tx_attr = *rxd_info.tx_attr; in rxd_info_to_rxd()
98 info->tx_attr->inject_size = MIN(core_info->ep_attr->max_msg_size, in rxd_info_to_rxd()
/dports/net/openmpi/openmpi-4.1.1/opal/mca/btl/ofi/
H A Dbtl_ofi_component.c116 if (!(info->tx_attr->op_flags | FI_DELIVERY_COMPLETE)) { in validate_info()
274 struct fi_tx_attr tx_attr = {0}; in mca_btl_ofi_component_init() local
343 hints.tx_attr = &tx_attr; in mca_btl_ofi_component_init()
347 tx_attr.iov_limit = 1; in mca_btl_ofi_component_init()
350 tx_attr.op_flags = FI_DELIVERY_COMPLETE; in mca_btl_ofi_component_init()

12345