Searched refs:cm_id (Results 1 - 19 of 19) sorted by relevance

/freebsd-9.3-release/sys/contrib/rdma/
H A Diw_cm.h77 * @cm_id: The IW CM identifier associated with the event.
80 typedef int (*iw_cm_handler)(struct iw_cm_id *cm_id,
88 * @cm_id: The IW CM identifier associated with the event.
91 typedef int (*iw_event_handler)(struct iw_cm_id *cm_id,
103 /* Used by provider to add and remove refs on IW cm_id */
125 int (*connect)(struct iw_cm_id *cm_id,
128 int (*accept)(struct iw_cm_id *cm_id,
131 int (*reject)(struct iw_cm_id *cm_id,
134 int (*create_listen)(struct iw_cm_id *cm_id,
137 int (*destroy_listen)(struct iw_cm_id *cm_id);
[all...]
H A Dib_cm.h270 * @cm_id: Communication identifier associated with the reported event.
275 * new @cm_id. The new @cm_id is returned to the user through this callback.
276 * Clients are responsible for destroying the new @cm_id. For peer-to-peer
277 * IB_CM_REQ_RECEIVED and all other events, the returned @cm_id corresponds
282 * destroy the @cm_id after the callback completes.
284 typedef int (*ib_cm_handler)(struct ib_cm_id *cm_id,
302 * @device: Device associated with the cm_id. All related communication will
317 * @cm_id: Connection identifier to destroy.
321 void ib_destroy_cm_id(struct ib_cm_id *cm_id);
[all...]
H A Drdma_iwcm.c94 struct iwcm_id_private *cm_id; member in struct:iwcm_work
102 * elements. The design pre-allocates them based on the cm_id type:
112 * One exception is when creating the cm_id for incoming connection requests.
114 * 1) in the event upcall, cm_event_handler(), for a listening cm_id. If
119 * If work elements cannot be allocated for the new connect request cm_id,
137 TAILQ_INSERT_HEAD(&work->cm_id->work_free_list, work, free_list);
159 work->cm_id = cm_id_priv;
189 * Release a reference on cm_id. If the last reference is being
208 static void add_ref(struct iw_cm_id *cm_id) argument
211 cm_id_priv = container_of(cm_id, struc
217 rem_ref(struct iw_cm_id *cm_id) argument
296 iw_cm_disconnect(struct iw_cm_id *cm_id, int abrupt) argument
361 destroy_cm_id(struct iw_cm_id *cm_id) argument
424 iw_destroy_cm_id(struct iw_cm_id *cm_id) argument
447 iw_cm_listen(struct iw_cm_id *cm_id, int backlog) argument
481 iw_cm_reject(struct iw_cm_id *cm_id, const void *private_data, u8 private_data_len) argument
519 iw_cm_accept(struct iw_cm_id *cm_id, struct iw_cm_conn_param *iw_param) argument
572 iw_cm_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *iw_param) argument
642 struct iw_cm_id *cm_id; local
921 cm_event_handler(struct iw_cm_id *cm_id, struct iw_cm_event *iw_event) argument
1011 iw_cm_init_qp_attr(struct iw_cm_id *cm_id, struct ib_qp_attr *qp_attr, int *qp_attr_mask) argument
[all...]
H A Drdma_cma.c149 } cm_id; member in struct:rdma_id_private
400 return (id_priv->id.device && id_priv->cm_id.ib);
593 if (!id_priv->cm_id.ib || cma_is_ud_ps(id_priv->id.ps))
596 ret = ib_cm_init_qp_attr(id_priv->cm_id.ib, qp_attr,
603 if (!id_priv->cm_id.iw) {
607 ret = iw_cm_init_qp_attr(id_priv->cm_id.iw, qp_attr,
765 if (id_priv->cm_id.ib && !IS_ERR(id_priv->cm_id.ib))
766 ib_destroy_cm_id(id_priv->cm_id.ib);
770 if (id_priv->cm_id
950 cma_ib_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) argument
1121 cma_req_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) argument
1296 iw_conn_req_handler(struct iw_cm_id *cm_id, struct iw_cm_event *iw_event) argument
2161 cma_sidr_rep_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) argument
2332 struct iw_cm_id *cm_id; local
[all...]
/freebsd-9.3-release/sys/ofed/include/rdma/
H A Diw_cm.h73 * @cm_id: The IW CM identifier associated with the event.
76 typedef int (*iw_cm_handler)(struct iw_cm_id *cm_id,
84 * @cm_id: The IW CM identifier associated with the event.
87 typedef int (*iw_event_handler)(struct iw_cm_id *cm_id,
99 /* Used by provider to add and remove refs on IW cm_id */
121 int (*connect)(struct iw_cm_id *cm_id,
124 int (*accept)(struct iw_cm_id *cm_id,
127 int (*reject)(struct iw_cm_id *cm_id,
130 int (*create_listen)(struct iw_cm_id *cm_id,
133 int (*destroy_listen)(struct iw_cm_id *cm_id);
[all...]
H A Dib_cm.h264 * @cm_id: Communication identifier associated with the reported event.
269 * new @cm_id. The new @cm_id is returned to the user through this callback.
270 * Clients are responsible for destroying the new @cm_id. For peer-to-peer
271 * IB_CM_REQ_RECEIVED and all other events, the returned @cm_id corresponds
276 * destroy the @cm_id after the callback completes.
278 typedef int (*ib_cm_handler)(struct ib_cm_id *cm_id,
296 * @device: Device associated with the cm_id. All related communication will
311 * @cm_id: Connection identifier to destroy.
315 void ib_destroy_cm_id(struct ib_cm_id *cm_id);
[all...]
/freebsd-9.3-release/contrib/ofed/libibcm/include/infiniband/
H A Dcm.h230 struct ib_cm_id *cm_id; member in struct:ib_cm_event
258 * new @cm_id.
259 * Clients are responsible for destroying the new @cm_id. For peer-to-peer
260 * IB_CM_REQ_RECEIVED and all other events, the returned @cm_id corresponds
303 struct ib_cm_id **cm_id, void *context);
307 * @cm_id: Connection identifier to destroy.
309 int ib_cm_destroy_id(struct ib_cm_id *cm_id);
320 * @cm_id: Connection identifier to retrieve attributes.
325 int ib_cm_attr_id(struct ib_cm_id *cm_id,
334 * @cm_id
[all...]
/freebsd-9.3-release/contrib/ofed/libibcm/src/
H A Dcm.c259 struct ib_cm_id **cm_id, void *context)
282 *cm_id = &cm_id_priv->id;
289 int ib_cm_destroy_id(struct ib_cm_id *cm_id) argument
299 cmd->id = cm_id->handle;
301 result = write(cm_id->device->fd, msg, size);
307 cm_id_priv = container_of(cm_id, struct cm_id_private, id);
318 int ib_cm_attr_id(struct ib_cm_id *cm_id, struct ib_cm_attr_param *param) argument
330 cmd->id = cm_id->handle;
332 result = write(cm_id->device->fd, msg, size);
345 int ib_cm_init_qp_attr(struct ib_cm_id *cm_id, argument
258 ib_cm_create_id(struct ib_cm_device *device, struct ib_cm_id **cm_id, void *context) argument
374 ib_cm_listen(struct ib_cm_id *cm_id, uint64_t service_id, uint64_t service_mask) argument
395 ib_cm_send_req(struct ib_cm_id *cm_id, struct ib_cm_req_param *param) argument
454 ib_cm_send_rep(struct ib_cm_id *cm_id, struct ib_cm_rep_param *param) argument
489 cm_send_private_data(struct ib_cm_id *cm_id, uint32_t type, void *private_data, uint8_t private_data_len) argument
514 ib_cm_send_rtu(struct ib_cm_id *cm_id, void *private_data, uint8_t private_data_len) argument
522 ib_cm_send_dreq(struct ib_cm_id *cm_id, void *private_data, uint8_t private_data_len) argument
530 ib_cm_send_drep(struct ib_cm_id *cm_id, void *private_data, uint8_t private_data_len) argument
538 cm_establish(struct ib_cm_id *cm_id) argument
555 ib_cm_notify(struct ib_cm_id *cm_id, enum ibv_event_type event) argument
580 cm_send_status(struct ib_cm_id *cm_id, uint32_t type, int status, void *info, uint8_t info_length, void *private_data, uint8_t private_data_len) argument
614 ib_cm_send_rej(struct ib_cm_id *cm_id, enum ib_cm_rej_reason reason, void *ari, uint8_t ari_length, void *private_data, uint8_t private_data_len) argument
626 ib_cm_send_apr(struct ib_cm_id *cm_id, enum ib_cm_apr_status status, void *info, uint8_t info_length, void *private_data, uint8_t private_data_len) argument
638 ib_cm_send_mra(struct ib_cm_id *cm_id, uint8_t service_timeout, void *private_data, uint8_t private_data_len) argument
664 ib_cm_send_lap(struct ib_cm_id *cm_id, struct ibv_sa_path_rec *alternate_path, void *private_data, uint8_t private_data_len) argument
699 ib_cm_send_sidr_req(struct ib_cm_id *cm_id, struct ib_cm_sidr_req_param *param) argument
739 ib_cm_send_sidr_rep(struct ib_cm_id *cm_id, struct ib_cm_sidr_rep_param *param) argument
[all...]
/freebsd-9.3-release/sys/ofed/drivers/infiniband/core/
H A Diwcm.c59 struct iwcm_id_private *cm_id; member in struct:iwcm_work
67 * elements. The design pre-allocates them based on the cm_id type:
77 * One exception is when creating the cm_id for incoming connection requests.
79 * 1) in the event upcall, cm_event_handler(), for a listening cm_id. If
84 * If work elements cannot be allocated for the new connect request cm_id,
103 list_add(&work->free_list, &work->cm_id->work_free_list);
125 work->cm_id = cm_id_priv;
155 * Release a reference on cm_id. If the last reference is being
171 static void add_ref(struct iw_cm_id *cm_id) argument
174 cm_id_priv = container_of(cm_id, struc
178 rem_ref(struct iw_cm_id *cm_id) argument
258 iw_cm_disconnect(struct iw_cm_id *cm_id, int abrupt) argument
325 destroy_cm_id(struct iw_cm_id *cm_id) argument
392 iw_destroy_cm_id(struct iw_cm_id *cm_id) argument
413 iw_cm_listen(struct iw_cm_id *cm_id, int backlog) argument
449 iw_cm_reject(struct iw_cm_id *cm_id, const void *private_data, u8 private_data_len) argument
487 iw_cm_accept(struct iw_cm_id *cm_id, struct iw_cm_conn_param *iw_param) argument
541 iw_cm_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *iw_param) argument
612 struct iw_cm_id *cm_id; local
895 cm_event_handler(struct iw_cm_id *cm_id, struct iw_cm_event *iw_event) argument
987 iw_cm_init_qp_attr(struct iw_cm_id *cm_id, struct ib_qp_attr *qp_attr, int *qp_attr_mask) argument
[all...]
H A Ducma.c71 struct rdma_cm_id *cm_id; member in struct:ucma_context
92 struct rdma_cm_id *cm_id; member in struct:ucma_event
245 static int ucma_event_handler(struct rdma_cm_id *cm_id, argument
249 struct ucma_context *ctx = cm_id->context;
256 uevent->cm_id = cm_id;
260 if (cm_id->ps == RDMA_PS_UDP || cm_id->ps == RDMA_PS_IPOIB)
332 ctx->cm_id = uevent->cm_id;
[all...]
H A Dcm.c819 * The cm_id could be destroyed by the user before we exit timewait.
820 * To protect against this, we search for the cm_id after exiting
844 static void cm_destroy_id(struct ib_cm_id *cm_id, int err) argument
849 cm_id_priv = container_of(cm_id, struct cm_id_private, id);
852 switch (cm_id->state) {
854 cm_id->state = IB_CM_IDLE;
861 cm_id->state = IB_CM_IDLE;
872 ib_send_cm_rej(cm_id, IB_CM_REJ_TIMEOUT,
884 ib_send_cm_rej(cm_id, IB_CM_REJ_CONSUMER_DEFINED,
897 ib_send_cm_rej(cm_id, IB_CM_REJ_CONSUMER_DEFINE
928 ib_destroy_cm_id(struct ib_cm_id *cm_id) argument
934 ib_cm_listen(struct ib_cm_id *cm_id, __be64 service_id, __be64 service_mask, struct ib_cm_compare_data *compare_data) argument
1120 ib_send_cm_req(struct ib_cm_id *cm_id, struct ib_cm_req_param *param) argument
1539 struct ib_cm_id *cm_id; local
1655 ib_send_cm_rep(struct ib_cm_id *cm_id, struct ib_cm_rep_param *param) argument
1717 ib_send_cm_rtu(struct ib_cm_id *cm_id, const void *private_data, u8 private_data_len) argument
2006 ib_send_cm_dreq(struct ib_cm_id *cm_id, const void *private_data, u8 private_data_len) argument
2064 ib_send_cm_drep(struct ib_cm_id *cm_id, const void *private_data, u8 private_data_len) argument
2245 ib_send_cm_rej(struct ib_cm_id *cm_id, enum ib_cm_rej_reason reason, void *ari, u8 ari_length, const void *private_data, u8 private_data_len) argument
2410 ib_send_cm_mra(struct ib_cm_id *cm_id, u8 service_timeout, const void *private_data, u8 private_data_len) argument
2612 ib_send_cm_lap(struct ib_cm_id *cm_id, struct ib_sa_path_rec *alternate_path, const void *private_data, u8 private_data_len) argument
2785 ib_send_cm_apr(struct ib_cm_id *cm_id, enum ib_cm_apr_status status, void *info, u8 info_length, const void *private_data, u8 private_data_len) argument
2925 ib_send_cm_sidr_req(struct ib_cm_id *cm_id, struct ib_cm_sidr_req_param *param) argument
2997 struct ib_cm_id *cm_id; local
3074 ib_send_cm_sidr_rep(struct ib_cm_id *cm_id, struct ib_cm_sidr_rep_param *param) argument
3309 cm_establish(struct ib_cm_id *cm_id) argument
3358 cm_migrate(struct ib_cm_id *cm_id) argument
3378 ib_cm_notify(struct ib_cm_id *cm_id, enum ib_event_type event) argument
3600 ib_cm_init_qp_attr(struct ib_cm_id *cm_id, struct ib_qp_attr *qp_attr, int *qp_attr_mask) argument
[all...]
H A Ducm.c81 struct ib_cm_id *cm_id; member in struct:ib_ucm_context
93 struct ib_cm_id *cm_id; member in struct:ib_ucm_event
169 ib_destroy_cm_id(uevent->cm_id);
356 static int ib_ucm_event_handler(struct ib_cm_id *cm_id, argument
363 ctx = cm_id->context;
370 uevent->cm_id = cm_id;
391 /* Destroy new cm_id's */
434 ctx->cm_id = uevent->cm_id;
846 ib_ucm_send_private_data(struct ib_ucm_file *file, const char __user *inbuf, int in_len, int (*func)(struct ib_cm_id *cm_id, const void *private_data, u8 private_data_len)) argument
896 ib_ucm_send_info(struct ib_ucm_file *file, const char __user *inbuf, int in_len, int (*func)(struct ib_cm_id *cm_id, int status, const void *info, u8 info_len, const void *data, u8 data_len)) argument
[all...]
H A Dcma.c164 } cm_id; member in struct:rdma_id_private
416 return (id_priv->id.device && id_priv->cm_id.ib);
650 if (!id_priv->cm_id.ib || cma_is_ud_ps(id_priv->id.ps))
653 ret = ib_cm_init_qp_attr(id_priv->cm_id.ib, qp_attr,
659 if (!id_priv->cm_id.iw) {
663 ret = iw_cm_init_qp_attr(id_priv->cm_id.iw, qp_attr,
907 if (id_priv->cm_id.ib && !IS_ERR(id_priv->cm_id.ib))
908 ib_destroy_cm_id(id_priv->cm_id.ib);
911 if (id_priv->cm_id
983 cma_ib_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) argument
1169 cma_req_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) argument
1355 iw_conn_req_handler(struct iw_cm_id *cm_id, struct iw_cm_event *iw_event) argument
[all...]
/freebsd-9.3-release/sys/dev/cxgb/ulp/iw_cxgb/
H A Diw_cxgb_cm.c448 if (ep->com.cm_id) {
449 CTR3(KTR_IW_CXGB, "close complete delivered ep %p cm_id %p tid %d",
450 ep, ep->com.cm_id, ep->hwtid);
451 ep->com.cm_id->event_handler(ep->com.cm_id, &event);
452 ep->com.cm_id->rem_ref(ep->com.cm_id);
453 ep->com.cm_id = NULL;
478 if (ep->com.cm_id) {
479 CTR3(KTR_IW_CXGB, "peer close delivered ep %p cm_id
1168 iwch_reject_cr(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len) argument
1190 iwch_accept_cr(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param) argument
1286 is_loopback_dst(struct iw_cm_id *cm_id) argument
1299 iwch_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param) argument
1377 iwch_create_listen(struct iw_cm_id *cm_id, int backlog) argument
1415 iwch_destroy_listen(struct iw_cm_id *cm_id) argument
[all...]
H A Diw_cxgb_cm.h149 struct iw_cm_id *cm_id; member in struct:iwch_ep_common
191 static inline struct iwch_ep *to_ep(struct iw_cm_id *cm_id) argument
193 return cm_id->provider_data;
196 static inline struct iwch_listen_ep *to_listen_ep(struct iw_cm_id *cm_id) argument
198 return cm_id->provider_data;
233 int iwch_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
234 int iwch_create_listen(struct iw_cm_id *cm_id, int backlog);
235 int iwch_destroy_listen(struct iw_cm_id *cm_id);
236 int iwch_reject_cr(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len);
237 int iwch_accept_cr(struct iw_cm_id *cm_id, struc
[all...]
/freebsd-9.3-release/contrib/ofed/librdmacm/examples/
H A Drping.c156 struct rdma_cm_id *cm_id; /* connection on client side,*/ member in struct:rping_cb
169 (cma_id == cb->cm_id) ? "parent" : "child");
496 ret = rdma_create_qp(cb->cm_id, cb->pd, &init_attr);
498 cb->qp = cb->cm_id->qp;
512 static int rping_setup_qp(struct rping_cb *cb, struct rdma_cm_id *cm_id) argument
516 cb->pd = ibv_alloc_pd(cm_id->verbs);
523 cb->channel = ibv_create_comp_channel(cm_id->verbs);
531 cb->cq = ibv_create_cq(cm_id->verbs, RPING_SQ_DEPTH * 2, cb,
737 ret = rdma_bind_addr(cb->cm_id, (struct sockaddr *) &cb->sin);
745 ret = rdma_listen(cb->cm_id,
[all...]
/freebsd-9.3-release/sys/ofed/drivers/infiniband/ulp/ipoib/
H A Dipoib_cm.c78 static int ipoib_cm_tx_handler(struct ib_cm_id *cm_id,
230 struct ib_cm_id *cm_id, struct ib_qp *qp,
237 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask);
248 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask);
269 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask);
298 struct ib_cm_id *cm_id, struct ipoib_cm_rx *rx)
328 ib_send_cm_rej(cm_id, IB_CM_REJ_NO_QP, NULL, 0, NULL, 0);
369 static int ipoib_cm_send_rep(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, argument
386 return ib_send_cm_rep(cm_id, &rep);
389 static int ipoib_cm_req_handler(struct ib_cm_id *cm_id, struc argument
229 ipoib_cm_modify_rx_qp(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, struct ib_qp *qp, unsigned psn) argument
297 ipoib_cm_nonsrq_init_rx(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, struct ipoib_cm_rx *rx) argument
449 ipoib_cm_rx_handler(struct ib_cm_id *cm_id, struct ib_cm_event *event) argument
832 ipoib_cm_rep_handler(struct ib_cm_id *cm_id, struct ib_cm_event *event) argument
964 ipoib_cm_modify_tx_init(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, struct ib_qp *qp) argument
1096 ipoib_cm_tx_handler(struct ib_cm_id *cm_id, struct ib_cm_event *event) argument
[all...]
/freebsd-9.3-release/sys/contrib/rdma/krping/
H A Dkrping.h99 struct rdma_cm_id *cm_id; /* connection on client side,*/ member in struct:krping_cb
H A Dkrping.c138 (cma_id == cb->cm_id) ? "parent" : "child");
581 ret = rdma_create_qp(cb->cm_id, cb->pd, &init_attr);
583 cb->qp = cb->cm_id->qp;
596 static int krping_setup_qp(struct krping_cb *cb, struct rdma_cm_id *cm_id) argument
599 cb->pd = ib_alloc_pd(cm_id->device);
606 cb->cq = ib_create_cq(cm_id->device, krping_cq_event_handler, NULL,
1219 ret = rdma_bind_addr(cb->cm_id, (struct sockaddr *) &sin);
1227 ret = rdma_listen(cb->cm_id, 3);
1542 ret = rdma_connect(cb->cm_id, &conn_param);
1569 ret = rdma_resolve_addr(cb->cm_id, NUL
[all...]

Completed in 188 milliseconds