| /dports/net/mpich/mpich-3.4.3/modules/libfabric/prov/verbs/src/ |
| H A D | verbs_cm_xrc.c | 280 struct rdma_conn_param conn_param = { 0 }; in vrb_resend_shared_accept_xrc() local
290 conn_param.private_data = cm_data; in vrb_resend_shared_accept_xrc()
295 conn_param.flow_control = 1; in vrb_resend_shared_accept_xrc()
296 conn_param.rnr_retry_count = 7; in vrb_resend_shared_accept_xrc()
298 conn_param.srq = 1; in vrb_resend_shared_accept_xrc()
301 return rdma_accept(id, &conn_param); in vrb_resend_shared_accept_xrc()
335 conn_param.private_data = cm_data; in vrb_accept_xrc()
336 conn_param.private_data_len = paramlen; in vrb_accept_xrc()
339 conn_param.flow_control = 1; in vrb_accept_xrc()
340 conn_param.rnr_retry_count = 7; in vrb_accept_xrc()
[all …]
|
| H A D | verbs_cm.c | 131 conn_param->private_data = cm_hdr; in vrb_ep_prepare_rdma_cm_param()
133 conn_param->responder_resources = RDMA_MAX_RESP_RES; in vrb_ep_prepare_rdma_cm_param()
134 conn_param->initiator_depth = RDMA_MAX_INIT_DEPTH; in vrb_ep_prepare_rdma_cm_param()
135 conn_param->flow_control = 1; in vrb_ep_prepare_rdma_cm_param()
136 conn_param->rnr_retry_count = 7; in vrb_ep_prepare_rdma_cm_param()
163 ep->conn_param.retry_count = 15; in vrb_msg_ep_connect()
166 ep->conn_param.srq = 1; in vrb_msg_ep_connect()
183 struct rdma_conn_param conn_param; in vrb_msg_ep_accept() local
201 vrb_ep_prepare_rdma_cm_param(&conn_param, cm_hdr, in vrb_msg_ep_accept()
205 conn_param.srq = 1; in vrb_msg_ep_accept()
[all …]
|
| H A D | verbs_domain_xrc.c | 217 void *conn_param, size_t conn_paramlen) in vrb_add_pending_ini_conn() argument
222 memcpy(ep->conn_setup->pending_param, conn_param, in vrb_add_pending_ini_conn()
349 ep->base_ep.conn_param.private_data = cm_data; in vrb_process_ini_conn()
350 ep->base_ep.conn_param.private_data_len = paramlen; in vrb_process_ini_conn()
351 ep->base_ep.conn_param.responder_resources = RDMA_MAX_RESP_RES; in vrb_process_ini_conn()
352 ep->base_ep.conn_param.initiator_depth = RDMA_MAX_INIT_DEPTH; in vrb_process_ini_conn()
353 ep->base_ep.conn_param.flow_control = 1; in vrb_process_ini_conn()
354 ep->base_ep.conn_param.retry_count = 15; in vrb_process_ini_conn()
355 ep->base_ep.conn_param.rnr_retry_count = 7; in vrb_process_ini_conn()
356 ep->base_ep.conn_param.srq = 1; in vrb_process_ini_conn()
[all …]
|
| /dports/net/mpich/mpich-3.4.3/modules/ucx/src/uct/ib/rdmacm/ |
| H A D | rdmacm_cm_ep.c | 217 uct_rdamcm_cm_ep_set_qp_num(struct rdma_conn_param *conn_param, in uct_rdamcm_cm_ep_set_qp_num() argument
232 conn_param->qp_num = qp->qp_num; in uct_rdamcm_cm_ep_set_qp_num()
237 struct rdma_conn_param *conn_param) in uct_rdmacm_cm_ep_conn_param_init() argument
248 hdr = (uct_rdmacm_priv_data_hdr_t*)conn_param->private_data; in uct_rdmacm_cm_ep_conn_param_init()
264 status = uct_rdamcm_cm_ep_set_qp_num(conn_param, cep); in uct_rdmacm_cm_ep_conn_param_init()
269 conn_param->private_data_len = sizeof(*hdr) + hdr->length; in uct_rdmacm_cm_ep_conn_param_init()
336 struct rdma_conn_param conn_param; in uct_rdamcm_cm_ep_server_init() local
370 memset(&conn_param, 0, sizeof(conn_param)); in uct_rdamcm_cm_ep_server_init()
371 conn_param.private_data = ucs_alloca(uct_rdmacm_cm_get_max_conn_priv() + in uct_rdamcm_cm_ep_server_init()
374 status = uct_rdmacm_cm_ep_conn_param_init(cep, &conn_param); in uct_rdamcm_cm_ep_server_init()
[all …]
|
| H A D | rdmacm_iface.c | 81 struct rdma_conn_param conn_param = {0}; in uct_rdmacm_accept() local
85 if (rdma_accept(id, &conn_param)) { in uct_rdmacm_accept()
281 struct rdma_conn_param conn_param; in uct_rdmacm_iface_process_event() local
324 memset(&conn_param, 0, sizeof(conn_param)); in uct_rdmacm_iface_process_event()
325 conn_param.private_data = ucs_alloca(UCT_RDMACM_MAX_CONN_PRIV + in uct_rdmacm_iface_process_event()
330 hdr = (uct_rdmacm_priv_data_hdr_t*)conn_param.private_data; in uct_rdmacm_iface_process_event()
350 conn_param.private_data_len = sizeof(*hdr) + hdr->length; in uct_rdmacm_iface_process_event()
352 if (rdma_connect(event->id, &conn_param)) { in uct_rdmacm_iface_process_event()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/infiniband/hw/qedr/ |
| H A D | qedr_iw_cm.c | 569 qp = qedr_iw_load_qp(dev, conn_param->qpn); in qedr_iw_connect()
628 conn_param->ord, conn_param->ird, conn_param->private_data, in qedr_iw_connect()
629 conn_param->private_data_len, qp->rq_psn); in qedr_iw_connect()
631 cm_info->ord = conn_param->ord; in qedr_iw_connect()
632 cm_info->ird = conn_param->ird; in qedr_iw_connect()
633 cm_info->private_data = conn_param->private_data; in qedr_iw_connect()
746 qp = qedr_iw_load_qp(dev, conn_param->qpn); in qedr_iw_accept()
759 params.private_data = conn_param->private_data; in qedr_iw_accept()
760 params.private_data_len = conn_param->private_data_len; in qedr_iw_accept()
761 params.ird = conn_param->ird; in qedr_iw_accept()
[all …]
|
| H A D | qedr_iw_cm.h | 35 struct iw_cm_conn_param *conn_param);
41 int qedr_iw_accept(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/infiniband/hw/qedr/ |
| H A D | qedr_iw_cm.c | 569 qp = qedr_iw_load_qp(dev, conn_param->qpn); in qedr_iw_connect()
628 conn_param->ord, conn_param->ird, conn_param->private_data, in qedr_iw_connect()
629 conn_param->private_data_len, qp->rq_psn); in qedr_iw_connect()
631 cm_info->ord = conn_param->ord; in qedr_iw_connect()
632 cm_info->ird = conn_param->ird; in qedr_iw_connect()
633 cm_info->private_data = conn_param->private_data; in qedr_iw_connect()
746 qp = qedr_iw_load_qp(dev, conn_param->qpn); in qedr_iw_accept()
759 params.private_data = conn_param->private_data; in qedr_iw_accept()
760 params.private_data_len = conn_param->private_data_len; in qedr_iw_accept()
761 params.ird = conn_param->ird; in qedr_iw_accept()
[all …]
|
| H A D | qedr_iw_cm.h | 35 struct iw_cm_conn_param *conn_param);
41 int qedr_iw_accept(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/infiniband/hw/qedr/ |
| H A D | qedr_iw_cm.c | 569 qp = qedr_iw_load_qp(dev, conn_param->qpn); in qedr_iw_connect()
628 conn_param->ord, conn_param->ird, conn_param->private_data, in qedr_iw_connect()
629 conn_param->private_data_len, qp->rq_psn); in qedr_iw_connect()
631 cm_info->ord = conn_param->ord; in qedr_iw_connect()
632 cm_info->ird = conn_param->ird; in qedr_iw_connect()
633 cm_info->private_data = conn_param->private_data; in qedr_iw_connect()
746 qp = qedr_iw_load_qp(dev, conn_param->qpn); in qedr_iw_accept()
759 params.private_data = conn_param->private_data; in qedr_iw_accept()
760 params.private_data_len = conn_param->private_data_len; in qedr_iw_accept()
761 params.ird = conn_param->ird; in qedr_iw_accept()
[all …]
|
| H A D | qedr_iw_cm.h | 35 struct iw_cm_conn_param *conn_param);
41 int qedr_iw_accept(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
|
| /dports/net/mpich/mpich-3.4.3/modules/ucx/src/uct/tcp/sockcm/ |
| H A D | sockcm_iface.c | 151 uct_sockcm_conn_param_t *conn_param = &sock_id_ctx->conn_param; in uct_sockcm_iface_process_conn_req() local
154 conn_param, conn_param->length); in uct_sockcm_iface_process_conn_req()
156 conn_param->private_data, conn_param->length); in uct_sockcm_iface_process_conn_req()
173 UCS_PTR_BYTE_OFFSET(&sock_id_ctx->conn_param, in uct_sockcm_iface_recv_handler()
248 recv_len = sizeof(sock_id_ctx->conn_param); in uct_sockcm_iface_event_handler()
250 status = ucs_socket_recv_nb(accept_fd, &sock_id_ctx->conn_param, &recv_len, in uct_sockcm_iface_event_handler()
|
| H A D | sockcm_ep.c | 59 uct_sockcm_conn_param_t conn_param; in uct_sockcm_ep_send_client_info() local
63 memset(&conn_param, 0, sizeof(uct_sockcm_conn_param_t)); in uct_sockcm_ep_send_client_info()
75 conn_param.length = ep->pack_cb(ep->pack_cb_arg, &pack_args, in uct_sockcm_ep_send_client_info()
76 (void*)conn_param.private_data); in uct_sockcm_ep_send_client_info()
77 if (conn_param.length < 0) { in uct_sockcm_ep_send_client_info()
80 iface, ep, ucs_status_string((ucs_status_t)conn_param.length)); in uct_sockcm_ep_send_client_info()
85 ucs_assert(conn_param.length <= UCT_SOCKCM_PRIV_DATA_LEN); in uct_sockcm_ep_send_client_info()
87 status = ucs_socket_send(ep->sock_id_ctx->sock_fd, &conn_param, in uct_sockcm_ep_send_client_info()
|
| /dports/multimedia/libv4l/linux-5.13-rc2/include/rdma/ |
| H A D | rdma_cm.h | 230 int rdma_connect(struct rdma_cm_id *id, struct rdma_conn_param *conn_param);
232 struct rdma_conn_param *conn_param);
234 int rdma_connect_ece(struct rdma_cm_id *id, struct rdma_conn_param *conn_param,
246 int rdma_accept(struct rdma_cm_id *id, struct rdma_conn_param *conn_param);
250 int rdma_accept_ece(struct rdma_cm_id *id, struct rdma_conn_param *conn_param,
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/include/rdma/ |
| H A D | rdma_cm.h | 230 int rdma_connect(struct rdma_cm_id *id, struct rdma_conn_param *conn_param);
232 struct rdma_conn_param *conn_param);
234 int rdma_connect_ece(struct rdma_cm_id *id, struct rdma_conn_param *conn_param,
246 int rdma_accept(struct rdma_cm_id *id, struct rdma_conn_param *conn_param);
250 int rdma_accept_ece(struct rdma_cm_id *id, struct rdma_conn_param *conn_param,
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/include/rdma/ |
| H A D | rdma_cm.h | 230 int rdma_connect(struct rdma_cm_id *id, struct rdma_conn_param *conn_param);
232 struct rdma_conn_param *conn_param);
234 int rdma_connect_ece(struct rdma_cm_id *id, struct rdma_conn_param *conn_param,
246 int rdma_accept(struct rdma_cm_id *id, struct rdma_conn_param *conn_param);
250 int rdma_accept_ece(struct rdma_cm_id *id, struct rdma_conn_param *conn_param,
|
| /dports/multimedia/libv4l/linux-5.13-rc2/net/sunrpc/xprtrdma/ |
| H A D | svc_rdma_transport.c | 370 struct rdma_conn_param conn_param; in svc_rdma_accept() local
490 memset(&conn_param, 0, sizeof conn_param); in svc_rdma_accept()
491 conn_param.responder_resources = 0; in svc_rdma_accept()
492 conn_param.initiator_depth = min_t(int, newxprt->sc_ord, in svc_rdma_accept()
494 if (!conn_param.initiator_depth) { in svc_rdma_accept()
499 conn_param.private_data = &pmsg; in svc_rdma_accept()
500 conn_param.private_data_len = sizeof(pmsg); in svc_rdma_accept()
503 ret = rdma_accept(newxprt->sc_cm_id, &conn_param); in svc_rdma_accept()
520 dprintk(" ord : %d\n", conn_param.initiator_depth); in svc_rdma_accept()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/net/sunrpc/xprtrdma/ |
| H A D | svc_rdma_transport.c | 370 struct rdma_conn_param conn_param; in svc_rdma_accept() local
490 memset(&conn_param, 0, sizeof conn_param); in svc_rdma_accept()
491 conn_param.responder_resources = 0; in svc_rdma_accept()
492 conn_param.initiator_depth = min_t(int, newxprt->sc_ord, in svc_rdma_accept()
494 if (!conn_param.initiator_depth) { in svc_rdma_accept()
499 conn_param.private_data = &pmsg; in svc_rdma_accept()
500 conn_param.private_data_len = sizeof(pmsg); in svc_rdma_accept()
503 ret = rdma_accept(newxprt->sc_cm_id, &conn_param); in svc_rdma_accept()
520 dprintk(" ord : %d\n", conn_param.initiator_depth); in svc_rdma_accept()
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/net/sunrpc/xprtrdma/ |
| H A D | svc_rdma_transport.c | 370 struct rdma_conn_param conn_param; in svc_rdma_accept() local
490 memset(&conn_param, 0, sizeof conn_param); in svc_rdma_accept()
491 conn_param.responder_resources = 0; in svc_rdma_accept()
492 conn_param.initiator_depth = min_t(int, newxprt->sc_ord, in svc_rdma_accept()
494 if (!conn_param.initiator_depth) { in svc_rdma_accept()
499 conn_param.private_data = &pmsg; in svc_rdma_accept()
500 conn_param.private_data_len = sizeof(pmsg); in svc_rdma_accept()
503 ret = rdma_accept(newxprt->sc_cm_id, &conn_param); in svc_rdma_accept()
520 dprintk(" ord : %d\n", conn_param.initiator_depth); in svc_rdma_accept()
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/drivers/infiniband/core/ |
| H A D | cma.c | 1023 if (conn_param) in cma_modify_qp_rtr()
1048 if (conn_param) in cma_modify_qp_rts()
3985 if (conn_param->private_data && conn_param->private_data_len) in cma_resolve_ib_udp()
4045 if (conn_param->private_data && conn_param->private_data_len) in cma_connect_ib()
4122 if (conn_param) { in cma_connect_iw()
4269 if (!conn_param) in cma_accept_iw()
4344 if (!id->qp && conn_param) { in rdma_accept()
4351 if (conn_param) in rdma_accept()
4353 conn_param->qkey, in rdma_accept()
4354 conn_param->private_data, in rdma_accept()
[all …]
|
| /dports/multimedia/v4l-utils/linux-5.13-rc2/drivers/infiniband/core/ |
| H A D | cma.c | 1023 if (conn_param) in cma_modify_qp_rtr()
1048 if (conn_param) in cma_modify_qp_rts()
3985 if (conn_param->private_data && conn_param->private_data_len) in cma_resolve_ib_udp()
4045 if (conn_param->private_data && conn_param->private_data_len) in cma_connect_ib()
4122 if (conn_param) { in cma_connect_iw()
4269 if (!conn_param) in cma_accept_iw()
4344 if (!id->qp && conn_param) { in rdma_accept()
4351 if (conn_param) in rdma_accept()
4353 conn_param->qkey, in rdma_accept()
4354 conn_param->private_data, in rdma_accept()
[all …]
|
| /dports/multimedia/libv4l/linux-5.13-rc2/drivers/infiniband/core/ |
| H A D | cma.c | 1023 if (conn_param) in cma_modify_qp_rtr()
1048 if (conn_param) in cma_modify_qp_rts()
3985 if (conn_param->private_data && conn_param->private_data_len) in cma_resolve_ib_udp()
4045 if (conn_param->private_data && conn_param->private_data_len) in cma_connect_ib()
4122 if (conn_param) { in cma_connect_iw()
4269 if (!conn_param) in cma_accept_iw()
4344 if (!id->qp && conn_param) { in rdma_accept()
4351 if (conn_param) in rdma_accept()
4353 conn_param->qkey, in rdma_accept()
4354 conn_param->private_data, in rdma_accept()
[all …]
|
| /dports/net/openmpi/openmpi-4.1.1/opal/mca/btl/openib/connect/ |
| H A D | btl_openib_connect_rdmacm.c | 942 struct rdma_conn_param conn_param; local
1084 memset(&conn_param, 0, sizeof(conn_param));
1088 conn_param.responder_resources =
1091 conn_param.initiator_depth =
1098 conn_param.private_data = &msg;
1498 struct rdma_conn_param conn_param; local
1574 memset(&conn_param, 0, sizeof(conn_param));
1576 conn_param.responder_resources =
1579 conn_param.initiator_depth =
1582 conn_param.flow_control = 0;
[all …]
|
| /dports/net/openmpi3/openmpi-3.1.6/opal/mca/btl/openib/connect/ |
| H A D | btl_openib_connect_rdmacm.c | 942 struct rdma_conn_param conn_param; local
1084 memset(&conn_param, 0, sizeof(conn_param));
1088 conn_param.responder_resources =
1091 conn_param.initiator_depth =
1098 conn_param.private_data = &msg;
1489 struct rdma_conn_param conn_param; local
1561 memset(&conn_param, 0, sizeof(conn_param));
1563 conn_param.responder_resources =
1566 conn_param.initiator_depth =
1569 conn_param.flow_control = 0;
[all …]
|
| /dports/multimedia/v4l_compat/linux-5.13-rc2/net/rds/ |
| H A D | ib_cm.c | 164 struct rdma_conn_param *conn_param, in rds_ib_cm_fill_conn_param() argument
176 conn_param->responder_resources = in rds_ib_cm_fill_conn_param()
178 conn_param->initiator_depth = in rds_ib_cm_fill_conn_param()
181 conn_param->rnr_retry_count = 7; in rds_ib_cm_fill_conn_param()
198 conn_param->private_data = &dp->ricp_v6; in rds_ib_cm_fill_conn_param()
213 conn_param->private_data = &dp->ricp_v4; in rds_ib_cm_fill_conn_param()
790 struct rdma_conn_param conn_param; in rds_ib_cm_handle_connect() local
918 if (rdma_accept(cm_id, &conn_param)) in rds_ib_cm_handle_connect()
935 struct rdma_conn_param conn_param; in rds_ib_cm_initiate_connect() local
950 rds_ib_cm_fill_conn_param(conn, &conn_param, &dp, in rds_ib_cm_initiate_connect()
[all …]
|