| /linux/net/rds/ |
| H A D | rdma_transport.c | 40 /* Global IPv4 and IPv6 RDS RDMA listener cm_id */
49 static int rds_rdma_cm_event_handler_cmn(struct rdma_cm_id *cm_id, in rds_rdma_cm_event_handler_cmn() argument
54 struct rds_connection *conn = cm_id->context; in rds_rdma_cm_event_handler_cmn()
60 rdsdebug("conn %p id %p handling event %u (%s)\n", conn, cm_id, in rds_rdma_cm_event_handler_cmn()
69 * right away. We return 0 so cm_id doesn't get in rds_rdma_cm_event_handler_cmn()
87 if (cm_id->device->node_type != RDMA_NODE_IB_CA) { in rds_rdma_cm_event_handler_cmn()
91 ret = trans->cm_handle_connect(cm_id, event, isv6); in rds_rdma_cm_event_handler_cmn()
98 * an iWARP route leaves cm_id->route.path_rec in rds_rdma_cm_event_handler_cmn()
104 if (cm_id->device->node_type != RDMA_NODE_IB_CA) { in rds_rdma_cm_event_handler_cmn()
108 rdma_set_service_type(cm_id, con in rds_rdma_cm_event_handler_cmn()
183 rds_rdma_cm_event_handler(struct rdma_cm_id * cm_id,struct rdma_cm_event * event) rds_rdma_cm_event_handler() argument
190 rds6_rdma_cm_event_handler(struct rdma_cm_id * cm_id,struct rdma_cm_event * event) rds6_rdma_cm_event_handler() argument
201 struct rdma_cm_id *cm_id; rds_rdma_listen_init_common() local
[all...] |
| H A D | ib.c | 408 struct rdma_cm_id *cm_id; in rds_ib_laddr_check_cm() local
420 cm_id = rdma_create_id(&init_net, rds_rdma_cm_event_handler, in rds_ib_laddr_check_cm()
422 if (IS_ERR(cm_id)) in rds_ib_laddr_check_cm()
423 return PTR_ERR(cm_id); in rds_ib_laddr_check_cm()
477 ret = rdma_bind_addr(cm_id, sa); in rds_ib_laddr_check_cm()
480 if (ret || !cm_id->device || in rds_ib_laddr_check_cm()
481 cm_id->device->node_type != RDMA_NODE_IB_CA) in rds_ib_laddr_check_cm()
486 cm_id->device ? cm_id->device->node_type : -1); in rds_ib_laddr_check_cm()
489 rdma_destroy_id(cm_id); in rds_ib_laddr_check_cm()
[all...] |
| H A D | rdma_transport.h | 20 int rds_rdma_cm_event_handler(struct rdma_cm_id *cm_id,
22 int rds6_rdma_cm_event_handler(struct rdma_cm_id *cm_id,
|
| H A D | ib_cm.c | 783 int rds_ib_cm_handle_connect(struct rdma_cm_id *cm_id, in rds_ib_cm_handle_connect() argument
786 __be64 lguid = cm_id->route.path_rec->sgid.global.interface_id; in rds_ib_cm_handle_connect()
787 __be64 fguid = cm_id->route.path_rec->dgid.global.interface_id; in rds_ib_cm_handle_connect()
901 BUG_ON(cm_id->context); in rds_ib_cm_handle_connect()
904 ic->i_cm_id = cm_id; in rds_ib_cm_handle_connect()
905 cm_id->context = conn; in rds_ib_cm_handle_connect()
921 rdma_set_min_rnr_timer(cm_id, IB_RNR_TIMER_000_32); in rds_ib_cm_handle_connect()
923 if (rdma_accept(cm_id, &conn_param)) in rds_ib_cm_handle_connect()
930 rdma_reject(cm_id, &err, sizeof(int), in rds_ib_cm_handle_connect()
936 int rds_ib_cm_initiate_connect(struct rdma_cm_id *cm_id, bool isv6) in rds_ib_cm_initiate_connect() argument
[all …]
|
| /linux/drivers/infiniband/hw/qedr/ |
| H A D | qedr_iw_cm.c | 97 if (ep->cm_id) in qedr_iw_free_ep()
98 ep->cm_id->rem_ref(ep->cm_id); in qedr_iw_free_ep()
135 listener->cm_id->event_handler(listener->cm_id, &event); in qedr_iw_mpa_request()
166 if (ep->cm_id) in qedr_iw_issue_event()
167 ep->cm_id->event_handler(ep->cm_id, &event); in qedr_iw_issue_event()
175 if (ep->cm_id) in qedr_iw_close_event()
239 if (ep->cm_id) in qedr_iw_disconnect_worker()
240 ep->cm_id->event_handler(ep->cm_id, &event); in qedr_iw_disconnect_worker()
532 int qedr_iw_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param) in qedr_iw_connect() argument
534 struct qedr_dev *dev = get_qedr_dev(cm_id->device); in qedr_iw_connect()
[all …]
|
| H A D | qedr_iw_cm.h | 34 int qedr_iw_connect(struct iw_cm_id *cm_id,
37 int qedr_iw_create_listen(struct iw_cm_id *cm_id, int backlog);
39 int qedr_iw_destroy_listen(struct iw_cm_id *cm_id);
41 int qedr_iw_accept(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
43 int qedr_iw_reject(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len);
|
| /linux/drivers/infiniband/core/ |
| H A D | ucma.c | 94 struct rdma_cm_id *cm_id; member
170 if (!ctx->cm_id->device) { in ucma_get_ctx_dev()
188 rdma_destroy_id(ctx->cm_id); in ucma_close_id()
191 ctx->cm_id = NULL; in ucma_close_id()
218 struct rdma_cm_id *cm_id) in ucma_set_ctx_cm_id() argument
221 ctx->cm_id = cm_id; in ucma_set_ctx_cm_id()
289 if (ctx->cm_id->qp_type == IB_QPT_UD) in ucma_create_uevent()
290 ucma_copy_ud_event(ctx->cm_id->device, &uevent->resp.param.ud, in ucma_create_uevent()
302 static int ucma_connect_event_handler(struct rdma_cm_id *cm_id, in ucma_connect_event_handler() argument
305 struct ucma_context *listen_ctx = cm_id->context; in ucma_connect_event_handler()
[all …]
|
| H A D | cm_trace.h | 139 const struct ib_cm_id *cm_id
142 TP_ARGS(cm_id),
145 __field(const void *, cm_id) /* for eBPF scripts */
153 __entry->cm_id = cm_id;
154 __entry->local_id = be32_to_cpu(cm_id->local_id);
155 __entry->remote_id = be32_to_cpu(cm_id->remote_id);
156 __entry->state = cm_id->state;
157 __entry->lap_state = cm_id->lap_state;
171 const struct ib_cm_id *cm_id \
173 TP_ARGS(cm_id))
[all …]
|
| H A D | cma_trace.h | 29 __field(u32, cm_id)
36 __entry->cm_id = id_priv->res.id;
45 __entry->cm_id, __entry->srcaddr, __entry->dstaddr, __entry->tos
75 __field(u32, cm_id)
82 __entry->cm_id = id_priv->res.id;
91 __entry->cm_id, __entry->srcaddr, __entry->dstaddr,
104 __field(u32, cm_id)
112 __entry->cm_id = id_priv->res.id;
122 __entry->cm_id, __entry->srcaddr, __entry->dstaddr, __entry->tos,
182 __field(u32, cm_id)
[all …]
|
| /linux/drivers/nvme/target/ |
| H A D | rdma.c | 90 struct rdma_cm_id *cm_id; member
123 struct rdma_cm_id *cm_id; member
629 struct rdma_cm_id *cm_id = rsp->queue->cm_id; in nvmet_rdma_rw_ctx_init() local
634 ret = rdma_rw_ctx_signature_init(&rsp->rw, cm_id->qp, in nvmet_rdma_rw_ctx_init()
635 cm_id->port_num, req->sg, req->sg_cnt, in nvmet_rdma_rw_ctx_init()
639 ret = rdma_rw_ctx_init(&rsp->rw, cm_id->qp, cm_id->port_num, in nvmet_rdma_rw_ctx_init()
648 struct rdma_cm_id *cm_id = rsp->queue->cm_id; in nvmet_rdma_rw_ctx_destroy() local
652 rdma_rw_ctx_destroy_signature(&rsp->rw, cm_id->qp, in nvmet_rdma_rw_ctx_destroy()
653 cm_id->port_num, req->sg, req->sg_cnt, in nvmet_rdma_rw_ctx_destroy()
657 rdma_rw_ctx_destroy(&rsp->rw, cm_id->qp, cm_id->port_num, in nvmet_rdma_rw_ctx_destroy()
[all …]
|
| /linux/fs/smb/smbdirect/ |
| H A D | listen.c | 28 if (WARN_ON_ONCE(!sc->rdma.cm_id)) in smbdirect_socket_listen()
31 if (sc->rdma.cm_id->device) in smbdirect_socket_listen()
34 &sc->rdma.cm_id->route.addr.src_addr, in smbdirect_socket_listen()
36 sc->rdma.cm_id->device->name); in smbdirect_socket_listen()
40 &sc->rdma.cm_id->route.addr.src_addr); in smbdirect_socket_listen()
46 rdma_lock_handler(sc->rdma.cm_id); in smbdirect_socket_listen()
47 sc->rdma.cm_id->event_handler = smbdirect_listen_rdma_event_handler; in smbdirect_socket_listen()
48 rdma_unlock_handler(sc->rdma.cm_id); in smbdirect_socket_listen()
50 ret = rdma_listen(sc->rdma.cm_id, backlog); in smbdirect_socket_listen()
54 if (sc->rdma.cm_id->device) in smbdirect_socket_listen()
[all …]
|
| /linux/include/rdma/ |
| H A D | ib_cm.h | 289 typedef int (*ib_cm_handler)(struct ib_cm_id *cm_id,
325 void ib_destroy_cm_id(struct ib_cm_id *cm_id);
343 int ib_cm_listen(struct ib_cm_id *cm_id, __be64 service_id);
380 int ib_send_cm_req(struct ib_cm_id *cm_id,
405 int ib_send_cm_rep(struct ib_cm_id *cm_id,
416 int ib_send_cm_rtu(struct ib_cm_id *cm_id,
429 int ib_send_cm_dreq(struct ib_cm_id *cm_id,
444 int ib_send_cm_drep(struct ib_cm_id *cm_id,
462 int ib_cm_notify(struct ib_cm_id *cm_id, enum ib_event_type event);
476 int ib_send_cm_rej(struct ib_cm_id *cm_id,
[all …]
|
| /linux/drivers/infiniband/hw/irdma/ |
| H A D | cm.c | 137 struct iw_cm_id *cm_id, in irdma_get_cmevent_info() argument
140 memcpy(&event->local_addr, &cm_id->m_local_addr, in irdma_get_cmevent_info()
142 memcpy(&event->remote_addr, &cm_id->m_remote_addr, in irdma_get_cmevent_info()
160 struct iw_cm_id *cm_id, in irdma_send_cm_event() argument
167 trace_irdma_send_cm_event(cm_node, cm_id, type, status, in irdma_send_cm_event()
172 cm_node, cm_id, cm_node->accelerated, cm_node->state, type, in irdma_send_cm_event()
187 irdma_get_cmevent_info(cm_node, cm_id, &event); in irdma_send_cm_event()
203 return cm_id->event_handler(cm_id, &event); in irdma_send_cm_event()
234 if (!cm_node->cm_id) in irdma_create_event()
250 event->cm_info.cm_id = cm_node->cm_id; in irdma_create_event()
[all …]
|
| H A D | cm.h | 245 struct iw_cm_id *cm_id; member
296 struct iw_cm_id *cm_id; member
330 struct iw_cm_id *cm_id; member
394 int irdma_accept(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
395 int irdma_reject(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len);
396 int irdma_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
397 int irdma_create_listen(struct iw_cm_id *cm_id, int backlog);
398 int irdma_destroy_listen(struct iw_cm_id *cm_id);
|
| H A D | trace_cm.h | 201 TP_PROTO(struct irdma_cm_node *cm_node, struct iw_cm_id *cm_id,
203 TP_ARGS(cm_node, cm_id, type, status, caller),
206 __field(struct iw_cm_id *, cm_id)
222 __entry->cm_id = cm_id;
241 __entry->cm_id,
257 TP_PROTO(struct iw_cm_id *cm_id, enum iw_cm_event_type type,
259 TP_ARGS(cm_id, type, status, caller),
260 TP_STRUCT__entry(__field(struct iw_cm_id *, cm_id)
265 TP_fast_assign(__entry->cm_id = cm_id;
271 __entry->cm_id,
|
| /linux/drivers/infiniband/hw/cxgb4/ |
| H A D | cm.c | 152 epc->cm_id->rem_ref(epc->cm_id); in deref_cm_id()
153 epc->cm_id = NULL; in deref_cm_id()
160 epc->cm_id->add_ref(epc->cm_id); in ref_cm_id()
1277 if (ep->com.cm_id) { in close_complete_upcall()
1279 ep, ep->com.cm_id, ep->hwtid); in close_complete_upcall()
1280 ep->com.cm_id->event_handler(ep->com.cm_id, &event); in close_complete_upcall()
1293 if (ep->com.cm_id) { in peer_close_upcall()
1295 ep, ep->com.cm_id, ep->hwtid); in peer_close_upcall()
1296 ep->com.cm_id->event_handler(ep->com.cm_id, &event); in peer_close_upcall()
1309 if (ep->com.cm_id) { in peer_abort_upcall()
[all …]
|
| /linux/drivers/infiniband/ulp/rtrs/ |
| H A D | rtrs.c | 218 rdma_notify(con->cm_id, IB_EVENT_COMM_EST); in qp_event_handler()
235 struct rdma_cm_id *cm_id = con->cm_id; in create_cq() local
239 cq = ib_alloc_cq(cm_id->device, con, nr_cqe, cq_vector, in create_cq()
242 cq = ib_cq_pool_get(cm_id->device, nr_cqe, cq_vector, poll_ctx); in create_cq()
259 struct rdma_cm_id *cm_id = con->cm_id; in create_qp() local
274 ret = rdma_create_qp(cm_id, pd, &init_attr); in create_qp()
280 con->qp = cm_id->qp; in create_qp()
322 rdma_destroy_qp(con->cm_id); in rtrs_cq_qp_destroy()
|
| H A D | rtrs-clt.c | 1661 clt_path->s.dev = rtrs_ib_dev_find_or_add(con->c.cm_id->device, in create_con_cq_qp()
1754 rdma_disconnect(con->c.cm_id); in stop_cm()
1761 rdma_destroy_id(con->c.cm_id); in destroy_cm()
1762 con->c.cm_id = NULL; in destroy_cm()
1781 err = rdma_resolve_route(con->c.cm_id, RTRS_CONNECT_TIMEOUT_MS); in rtrs_rdma_addr_resolved()
1815 err = rdma_connect_locked(con->c.cm_id, ¶m); in rtrs_rdma_route_resolved()
1900 clt_path->hca_port = con->c.cm_id->port_num; in rtrs_rdma_conn_established()
1903 clt_path->s.src_addr = con->c.cm_id->route.addr.src_addr; in rtrs_rdma_conn_established()
1929 rej_msg = rdma_reject_msg(con->c.cm_id, status); in rtrs_rdma_conn_rejected()
1930 msg = rdma_consumer_reject_data(con->c.cm_id, ev, &data_len); in rtrs_rdma_conn_rejected()
[all …]
|
| /linux/drivers/nvme/host/ |
| H A D | rdma.c | 103 struct rdma_cm_id *cm_id; member
159 static int nvme_rdma_cm_handler(struct rdma_cm_id *cm_id,
287 ret = rdma_create_qp(queue->cm_id, dev->pd, &init_attr); in nvme_rdma_create_qp()
289 queue->qp = queue->cm_id->qp; in nvme_rdma_create_qp()
375 nvme_rdma_find_get_device(struct rdma_cm_id *cm_id) in nvme_rdma_find_get_device() argument
381 if (ndev->dev->node_guid == cm_id->device->node_guid && in nvme_rdma_find_get_device()
390 ndev->dev = cm_id->device; in nvme_rdma_find_get_device()
506 queue->device = nvme_rdma_find_get_device(queue->cm_id); in nvme_rdma_create_queue_ib()
508 dev_err(queue->cm_id->device->dev.parent, in nvme_rdma_create_queue_ib()
571 rdma_destroy_qp(queue->cm_id); in nvme_rdma_create_queue_ib()
[all …]
|
| /linux/drivers/infiniband/ulp/isert/ |
| H A D | ib_isert.c | 95 rdma_notify(isert_conn->cm_id, IB_EVENT_COMM_EST); in isert_qp_event_callback()
438 isert_conn->cm_id = cma_id; in isert_connect_request()
495 if (isert_conn->cm_id && in isert_connect_release()
497 rdma_destroy_id(isert_conn->cm_id); in isert_connect_release()
557 struct isert_np *isert_np = isert_conn->cm_id->context; in isert_handle_unbound_conn()
595 err = rdma_disconnect(isert_conn->cm_id); in isert_conn_terminate()
610 isert_np->cm_id = NULL; in isert_np_cma_handler()
613 isert_np->cm_id = isert_setup_id(isert_np); in isert_np_cma_handler()
614 if (IS_ERR(isert_np->cm_id)) { in isert_np_cma_handler()
616 isert_np, PTR_ERR(isert_np->cm_id)); in isert_np_cma_handler()
[all …]
|
| /linux/drivers/infiniband/ulp/srpt/ |
| H A D | ib_srpt.h | 297 struct ib_cm_id *cm_id; member
300 struct rdma_cm_id *cm_id; member
458 struct ib_cm_id *cm_id; member
|
| /linux/drivers/infiniband/sw/siw/ |
| H A D | siw_cm.c | 368 id = cep->listen_cep->cm_id; in siw_cm_upcall()
370 id = cep->cm_id; in siw_cm_upcall()
413 if (!cep->cm_id) in siw_free_cm_id()
416 cep->cm_id->rem_ref(cep->cm_id); in siw_free_cm_id()
417 cep->cm_id = NULL; in siw_free_cm_id()
461 if (cep->cm_id) { in siw_qp_cm_drop()
1126 if (cep->cm_id) in siw_cm_work_handler()
1133 if (cep->cm_id) { in siw_cm_work_handler()
1185 if (cep->cm_id) in siw_cm_work_handler()
1237 if (cep->cm_id) { in siw_cm_work_handler()
[all …]
|
| /linux/drivers/infiniband/ulp/srp/ |
| H A D | ib_srp.c | 147 static int srp_ib_cm_handler(struct ib_cm_id *cm_id,
149 static int srp_rdma_cm_handler(struct rdma_cm_id *cm_id,
315 if (ch->ib_cm.cm_id) in srp_new_ib_cm_id()
316 ib_destroy_cm_id(ch->ib_cm.cm_id); in srp_new_ib_cm_id()
317 ch->ib_cm.cm_id = new_cm_id; in srp_new_ib_cm_id()
366 swap(ch->rdma_cm.cm_id, new_cm_id); in srp_new_rdma_cm_id()
569 ret = rdma_create_qp(ch->rdma_cm.cm_id, dev->pd, init_attr); in srp_create_ch_ib()
570 qp = ch->rdma_cm.cm_id->qp; in srp_create_ch_ib()
619 rdma_destroy_qp(ch->rdma_cm.cm_id); in srp_create_ch_ib()
648 if (ch->rdma_cm.cm_id) { in srp_free_ch_ib()
[all …]
|
| H A D | ib_srp.h | 178 struct ib_cm_id *cm_id; member
181 struct rdma_cm_id *cm_id; member
|
| /linux/drivers/gpu/drm/amd/display/dc/link/protocols/ |
| H A D | link_dp_dpia_bw.c | 408 router_sets[j].cm_id = dp_tunnel_settings->cm_id; in link_dpia_validate_dp_tunnel_bandwidth()
412 if (router_sets[j].cm_id == dp_tunnel_settings->cm_id) { in link_dpia_validate_dp_tunnel_bandwidth()
|