| /drivers/infiniband/hw/amso1100/ |
| D | c2_cm.c | 41 int c2_llp_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *iw_param) in c2_llp_connect() argument
43 struct c2_dev *c2dev = to_c2dev(cm_id->device); in c2_llp_connect()
50 ibqp = c2_get_qp(cm_id->device, iw_param->qpn); in c2_llp_connect()
56 cm_id->provider_data = qp; in c2_llp_connect()
57 cm_id->add_ref(cm_id); in c2_llp_connect()
58 qp->cm_id = cm_id; in c2_llp_connect()
94 wr->remote_addr = cm_id->remote_addr.sin_addr.s_addr; in c2_llp_connect()
95 wr->remote_port = cm_id->remote_addr.sin_port; in c2_llp_connect()
124 cm_id->provider_data = NULL; in c2_llp_connect()
125 qp->cm_id = NULL; in c2_llp_connect()
[all …]
|
| D | c2_ae.c | 185 struct iw_cm_id *cm_id = qp->cm_id; in c2_ae_event() local
188 if (!cm_id) { in c2_ae_event()
219 if (qp->cm_id) { in c2_ae_event()
220 qp->cm_id->rem_ref(qp->cm_id); in c2_ae_event()
221 qp->cm_id = NULL; in c2_ae_event()
227 if (cm_id->event_handler) in c2_ae_event()
228 cm_id->event_handler(cm_id, &cm_event); in c2_ae_event()
245 BUG_ON(cm_id->event_handler==(void*)0x6b6b6b6b); in c2_ae_event()
248 if (qp->cm_id) { in c2_ae_event()
249 qp->cm_id->rem_ref(qp->cm_id); in c2_ae_event()
[all …]
|
| D | c2_qp.c | 174 if (qp->cm_id && qp->state == IB_QPS_RTS) { in c2_qp_modify()
176 "qp=%p, cm_id=%p\n",qp,qp->cm_id); in c2_qp_modify()
178 vq_req->cm_id = qp->cm_id; in c2_qp_modify()
236 if (vq_req->event==IW_CM_EVENT_CLOSE && qp->cm_id) { in c2_qp_modify()
237 qp->cm_id->rem_ref(qp->cm_id); in c2_qp_modify()
238 qp->cm_id = NULL; in c2_qp_modify()
332 if (qp->cm_id && qp->state == IB_QPS_RTS) { in destroy_qp()
334 "qp=%p, cm_id=%p\n",qp,qp->cm_id); in destroy_qp()
337 vq_req->cm_id = qp->cm_id; in destroy_qp()
369 if (qp->cm_id) { in destroy_qp()
[all …]
|
| D | c2_intr.c | 199 cm_event.local_addr = req->cm_id->local_addr; in handle_vq()
200 cm_event.remote_addr = req->cm_id->remote_addr; in handle_vq()
203 req->cm_id->event_handler(req->cm_id, &cm_event); in handle_vq()
|
| D | c2_provider.c | 598 static int c2_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *iw_param) in c2_connect() argument
603 return c2_llp_connect(cm_id, iw_param); in c2_connect()
606 static int c2_accept(struct iw_cm_id *cm_id, struct iw_cm_conn_param *iw_param) in c2_accept() argument
611 return c2_llp_accept(cm_id, iw_param); in c2_accept()
614 static int c2_reject(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len) in c2_reject() argument
620 err = c2_llp_reject(cm_id, pdata, pdata_len); in c2_reject()
624 static int c2_service_create(struct iw_cm_id *cm_id, int backlog) in c2_service_create() argument
629 err = c2_llp_service_create(cm_id, backlog); in c2_service_create()
636 static int c2_service_destroy(struct iw_cm_id *cm_id) in c2_service_destroy() argument
641 err = c2_llp_service_destroy(cm_id); in c2_service_destroy()
|
| D | c2.h | 522 extern int c2_llp_connect(struct iw_cm_id *cm_id,
524 extern int c2_llp_accept(struct iw_cm_id *cm_id,
526 extern int c2_llp_reject(struct iw_cm_id *cm_id, const void *pdata,
528 extern int c2_llp_service_create(struct iw_cm_id *cm_id, int backlog);
529 extern int c2_llp_service_destroy(struct iw_cm_id *cm_id);
|
| D | c2_vq.h | 46 struct iw_cm_id *cm_id; member
|
| D | c2_provider.h | 109 struct iw_cm_id *cm_id; member
|
| /drivers/infiniband/core/ |
| D | iwcm.c | 62 struct iwcm_id_private *cm_id; member
106 list_add(&work->free_list, &work->cm_id->work_free_list); in put_work()
128 work->cm_id = cm_id_priv; in alloc_work_entries()
174 static void add_ref(struct iw_cm_id *cm_id) in add_ref() argument
177 cm_id_priv = container_of(cm_id, struct iwcm_id_private, id); in add_ref()
181 static void rem_ref(struct iw_cm_id *cm_id) in rem_ref() argument
184 cm_id_priv = container_of(cm_id, struct iwcm_id_private, id); in rem_ref()
192 static int cm_event_handler(struct iw_cm_id *cm_id, struct iw_cm_event *event);
259 int iw_cm_disconnect(struct iw_cm_id *cm_id, int abrupt) in iw_cm_disconnect() argument
266 cm_id_priv = container_of(cm_id, struct iwcm_id_private, id); in iw_cm_disconnect()
[all …]
|
| D | ucma.c | 91 struct rdma_cm_id *cm_id; member
112 struct rdma_cm_id *cm_id; member
265 static int ucma_event_handler(struct rdma_cm_id *cm_id, in ucma_event_handler() argument
269 struct ucma_context *ctx = cm_id->context; in ucma_event_handler()
276 uevent->cm_id = cm_id; in ucma_event_handler()
280 if (cm_id->qp_type == IB_QPT_UD) in ucma_event_handler()
350 ctx->cm_id = uevent->cm_id; in ucma_get_event()
351 ctx->cm_id->context = ctx; in ucma_get_event()
415 ctx->cm_id = rdma_create_id(ucma_event_handler, ctx, cmd.ps, qp_type); in ucma_create_id()
416 if (IS_ERR(ctx->cm_id)) { in ucma_create_id()
[all …]
|
| D | cm.c | 835 static void cm_destroy_id(struct ib_cm_id *cm_id, int err) in cm_destroy_id() argument
840 cm_id_priv = container_of(cm_id, struct cm_id_private, id); in cm_destroy_id()
843 switch (cm_id->state) { in cm_destroy_id()
845 cm_id->state = IB_CM_IDLE; in cm_destroy_id()
852 cm_id->state = IB_CM_IDLE; in cm_destroy_id()
863 ib_send_cm_rej(cm_id, IB_CM_REJ_TIMEOUT, in cm_destroy_id()
875 ib_send_cm_rej(cm_id, IB_CM_REJ_CONSUMER_DEFINED, in cm_destroy_id()
888 ib_send_cm_rej(cm_id, IB_CM_REJ_CONSUMER_DEFINED, in cm_destroy_id()
895 ib_send_cm_dreq(cm_id, NULL, 0); in cm_destroy_id()
904 ib_send_cm_drep(cm_id, NULL, 0); in cm_destroy_id()
[all …]
|
| D | ucm.c | 83 struct ib_cm_id *cm_id; member
95 struct ib_cm_id *cm_id; member
168 ib_destroy_cm_id(uevent->cm_id); in ib_ucm_cleanup_events()
355 static int ib_ucm_event_handler(struct ib_cm_id *cm_id, in ib_ucm_event_handler() argument
362 ctx = cm_id->context; in ib_ucm_event_handler()
369 uevent->cm_id = cm_id; in ib_ucm_event_handler()
431 ctx->cm_id = uevent->cm_id; in ib_ucm_event()
432 ctx->cm_id->context = ctx; in ib_ucm_event()
500 ctx->cm_id = ib_create_cm_id(file->device->ib_dev, in ib_ucm_create_id()
502 if (IS_ERR(ctx->cm_id)) { in ib_ucm_create_id()
[all …]
|
| D | cma.c | 133 } cm_id; member
649 if (!id_priv->cm_id.ib || (id_priv->id.qp_type == IB_QPT_UD)) in rdma_init_qp_attr()
652 ret = ib_cm_init_qp_attr(id_priv->cm_id.ib, qp_attr, in rdma_init_qp_attr()
658 if (!id_priv->cm_id.iw) { in rdma_init_qp_attr()
662 ret = iw_cm_init_qp_attr(id_priv->cm_id.iw, qp_attr, in rdma_init_qp_attr()
924 if (id_priv->cm_id.ib) in rdma_destroy_id()
925 ib_destroy_cm_id(id_priv->cm_id.ib); in rdma_destroy_id()
928 if (id_priv->cm_id.iw) in rdma_destroy_id()
929 iw_destroy_cm_id(id_priv->cm_id.iw); in rdma_destroy_id()
962 ret = ib_send_cm_rtu(id_priv->cm_id.ib, NULL, 0); in cma_rep_recv()
[all …]
|
| /drivers/infiniband/hw/nes/ |
| D | nes_cm.c | 177 if (!cm_node->cm_id) in create_event()
192 event->cm_info.cm_id = cm_node->cm_id; in create_event()
736 struct iw_cm_id *cm_id = cm_node->cm_id; in nes_retrans_expired() local
747 if (cm_node->cm_id) in nes_retrans_expired()
748 cm_id->rem_ref(cm_id); in nes_retrans_expired()
761 struct iw_cm_id *cm_id = cm_node->cm_id; in handle_recv_entry() local
770 if (nesqp->cm_id) { in handle_recv_entry()
774 "to do!!!\n", nesqp->hwqp.qp_id, cm_id, in handle_recv_entry()
786 "to do!!!\n", nesqp->hwqp.qp_id, cm_id, in handle_recv_entry()
793 if (cm_node->cm_id) in handle_recv_entry()
[all …]
|
| D | nes_cm.h | 296 struct iw_cm_id *cm_id; member
338 struct iw_cm_id *cm_id; member
356 struct iw_cm_id *cm_id; member
|
| /drivers/infiniband/hw/cxgb3/ |
| D | iwch_cm.h | 155 struct iw_cm_id *cm_id; member
196 static inline struct iwch_ep *to_ep(struct iw_cm_id *cm_id) in to_ep() argument
198 return cm_id->provider_data; in to_ep()
201 static inline struct iwch_listen_ep *to_listen_ep(struct iw_cm_id *cm_id) in to_listen_ep() argument
203 return cm_id->provider_data; in to_listen_ep()
217 int iwch_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
218 int iwch_create_listen(struct iw_cm_id *cm_id, int backlog);
219 int iwch_destroy_listen(struct iw_cm_id *cm_id);
220 int iwch_reject_cr(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len);
221 int iwch_accept_cr(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
|
| D | iwch_cm.c | 675 if (ep->com.cm_id) { in close_complete_upcall()
677 ep, ep->com.cm_id, ep->hwtid); in close_complete_upcall()
678 ep->com.cm_id->event_handler(ep->com.cm_id, &event); in close_complete_upcall()
679 ep->com.cm_id->rem_ref(ep->com.cm_id); in close_complete_upcall()
680 ep->com.cm_id = NULL; in close_complete_upcall()
692 if (ep->com.cm_id) { in peer_close_upcall()
694 ep, ep->com.cm_id, ep->hwtid); in peer_close_upcall()
695 ep->com.cm_id->event_handler(ep->com.cm_id, &event); in peer_close_upcall()
707 if (ep->com.cm_id) { in peer_abort_upcall()
709 ep->com.cm_id, ep->hwtid); in peer_abort_upcall()
[all …]
|
| /drivers/infiniband/hw/cxgb4/ |
| D | cm.c | 800 if (ep->com.cm_id) { in close_complete_upcall()
802 ep, ep->com.cm_id, ep->hwtid); in close_complete_upcall()
803 ep->com.cm_id->event_handler(ep->com.cm_id, &event); in close_complete_upcall()
804 ep->com.cm_id->rem_ref(ep->com.cm_id); in close_complete_upcall()
805 ep->com.cm_id = NULL; in close_complete_upcall()
825 if (ep->com.cm_id) { in peer_close_upcall()
827 ep, ep->com.cm_id, ep->hwtid); in peer_close_upcall()
828 ep->com.cm_id->event_handler(ep->com.cm_id, &event); in peer_close_upcall()
840 if (ep->com.cm_id) { in peer_abort_upcall()
842 ep->com.cm_id, ep->hwtid); in peer_abort_upcall()
[all …]
|
| D | iw_cxgb4.h | 628 struct iw_cm_id *cm_id; member
677 static inline struct c4iw_ep *to_ep(struct iw_cm_id *cm_id) in to_ep() argument
679 return cm_id->provider_data; in to_ep()
682 static inline struct c4iw_listen_ep *to_listen_ep(struct iw_cm_id *cm_id) in to_listen_ep() argument
684 return cm_id->provider_data; in to_listen_ep()
729 int c4iw_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
730 int c4iw_create_listen(struct iw_cm_id *cm_id, int backlog);
731 int c4iw_destroy_listen(struct iw_cm_id *cm_id);
732 int c4iw_accept_cr(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
733 int c4iw_reject_cr(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len);
|
| /drivers/infiniband/ulp/srpt/ |
| D | ib_srpt.c | 229 event->event, ch->cm_id, ch->sess_name, srpt_get_ch_state(ch)); in srpt_qp_event()
233 ib_cm_notify(ch->cm_id, event->event); in srpt_qp_event()
992 ret = ib_cm_init_qp_attr(ch->cm_id, &qp_attr, &attr_mask); in srpt_ch_qp_rtr()
1022 ret = ib_cm_init_qp_attr(ch->cm_id, &qp_attr, &attr_mask); in srpt_ch_qp_rts()
1873 srp_tsk->task_tag, srp_tsk->tag, ch->cm_id, ch->sess); in srpt_handle_tsk_mgmt()
2176 qp_init->cap.max_send_wr, ch->cm_id); in srpt_create_ch_ib()
2244 ib_send_cm_rej(ch->cm_id, IB_CM_REJ_NO_RESOURCES, NULL, 0, in __srpt_close_ch()
2248 if (ib_send_cm_dreq(ch->cm_id, NULL, 0) < 0) in __srpt_close_ch()
2284 static void srpt_drain_channel(struct ib_cm_id *cm_id) in srpt_drain_channel() argument
2293 sdev = cm_id->context; in srpt_drain_channel()
[all …]
|
| D | ib_srpt.h | 306 struct ib_cm_id *cm_id; member
399 struct ib_cm_id *cm_id; member
|
| /drivers/infiniband/ulp/ipoib/ |
| D | ipoib_cm.c | 77 static int ipoib_cm_tx_handler(struct ib_cm_id *cm_id,
272 struct ib_cm_id *cm_id, struct ib_qp *qp, in ipoib_cm_modify_rx_qp() argument
280 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask); in ipoib_cm_modify_rx_qp()
291 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask); in ipoib_cm_modify_rx_qp()
312 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask); in ipoib_cm_modify_rx_qp()
345 static int ipoib_cm_nonsrq_init_rx(struct net_device *dev, struct ib_cm_id *cm_id, in ipoib_cm_nonsrq_init_rx() argument
375 ib_send_cm_rej(cm_id, IB_CM_REJ_NO_QP, NULL, 0, NULL, 0); in ipoib_cm_nonsrq_init_rx()
417 static int ipoib_cm_send_rep(struct net_device *dev, struct ib_cm_id *cm_id, in ipoib_cm_send_rep() argument
435 return ib_send_cm_rep(cm_id, &rep); in ipoib_cm_send_rep()
438 static int ipoib_cm_req_handler(struct ib_cm_id *cm_id, struct ib_cm_event *event) in ipoib_cm_req_handler() argument
[all …]
|
| /drivers/infiniband/ulp/srp/ |
| D | ib_srp.c | 93 static int srp_cm_handler(struct ib_cm_id *cm_id, struct ib_cm_event *event);
215 if (target->cm_id) in srp_new_cm_id()
216 ib_destroy_cm_id(target->cm_id); in srp_new_cm_id()
217 target->cm_id = new_cm_id; in srp_new_cm_id()
424 status = ib_send_cm_req(target->cm_id, &req->param); in srp_send_req()
436 if (ib_send_cm_dreq(target->cm_id, NULL, 0)) { in srp_disconnect_target()
507 ib_destroy_cm_id(target->cm_id); in srp_remove_work()
1422 static void srp_cm_rep_handler(struct ib_cm_id *cm_id, in srp_cm_rep_handler() argument
1461 ret = ib_cm_init_qp_attr(cm_id, qp_attr, &attr_mask); in srp_cm_rep_handler()
1477 ret = ib_cm_init_qp_attr(cm_id, qp_attr, &attr_mask); in srp_cm_rep_handler()
[all …]
|
| D | ib_srp.h | 166 struct ib_cm_id *cm_id; member
|
| /drivers/char/ |
| D | mbcs.h | 79 union cm_id { union
145 uint64_t cm_id:2, // 1:0 member
342 union cm_id id;
|