| /linux/net/rds/ |
| H A D | rdma_transport.c | 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()
63 if (cm_id->device->node_type == RDMA_NODE_IB_CA) in rds_rdma_cm_event_handler_cmn()
85 ret = trans->cm_handle_connect(cm_id, event, isv6); in rds_rdma_cm_event_handler_cmn()
90 rdma_set_service_type(cm_id, conn->c_tos); in rds_rdma_cm_event_handler_cmn()
91 rdma_set_min_rnr_timer(cm_id, IB_RNR_TIMER_000_32); in rds_rdma_cm_event_handler_cmn()
93 ret = rdma_resolve_route(cm_id, in rds_rdma_cm_event_handler_cmn()
106 if (ibic && ibic->i_cm_id == cm_id) { in rds_rdma_cm_event_handler_cmn()
107 cm_id->route.path_rec[0].sl = in rds_rdma_cm_event_handler_cmn()
[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, boo argument
[all...] |
| H A D | ib.h | 374 int rds_ib_cm_handle_connect(struct rdma_cm_id *cm_id,
376 int rds_ib_cm_initiate_connect(struct rdma_cm_id *cm_id, bool isv6);
|
| H A D | rds.h | 603 int (*cm_handle_connect)(struct rdma_cm_id *cm_id,
605 int (*cm_initiate_connect)(struct rdma_cm_id *cm_id, bool isv6);
|
| /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 | 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/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 …]
|
| H A D | rdma_cm.h | 423 void rdma_read_gids(struct rdma_cm_id *cm_id, union ib_gid *sgid,
426 struct iw_cm_id *rdma_iw_cm_id(struct rdma_cm_id *cm_id);
|
| /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 …]
|
| H A D | restrack.c | 197 struct rdma_cm_id *cm_id) in c4iw_fill_res_cm_id_entry() argument
206 iw_cm_id = rdma_iw_cm_id(cm_id); in c4iw_fill_res_cm_id_entry()
|
| /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-pri.h | 95 struct rdma_cm_id *cm_id; member
|
| H A D | rtrs-srv-sysfs.c | 76 return sysfs_emit(page, "%u\n", usr_con->cm_id->port_num); in rtrs_srv_hca_port_show()
|
| /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/ulp/srp/ |
| H A D | ib_srp.h | 178 struct ib_cm_id *cm_id; member
181 struct rdma_cm_id *cm_id; member
|
| /linux/drivers/infiniband/sw/siw/ |
| H A D | siw_cm.h | 38 struct iw_cm_id *cm_id; member
|
| /linux/drivers/infiniband/hw/erdma/ |
| H A D | erdma_cm.h | 87 struct iw_cm_id *cm_id; member
|