Searched refs:cm_id (Results 1 - 22 of 22) sorted by path

/freebsd-11-stable/contrib/ofed/libibcm/
H A Dcm.c246 struct ib_cm_id **cm_id, void *context)
269 *cm_id = &cm_id_priv->id;
276 int ib_cm_destroy_id(struct ib_cm_id *cm_id) argument
286 cmd->id = cm_id->handle;
288 result = write(cm_id->device->fd, msg, size);
294 cm_id_priv = container_of(cm_id, struct cm_id_private, id);
305 int ib_cm_attr_id(struct ib_cm_id *cm_id, struct ib_cm_attr_param *param) argument
317 cmd->id = cm_id->handle;
319 result = write(cm_id->device->fd, msg, size);
332 int ib_cm_init_qp_attr(struct ib_cm_id *cm_id, argument
245 ib_cm_create_id(struct ib_cm_device *device, struct ib_cm_id **cm_id, void *context) argument
361 ib_cm_listen(struct ib_cm_id *cm_id, __be64 service_id, __be64 service_mask) argument
382 ib_cm_send_req(struct ib_cm_id *cm_id, struct ib_cm_req_param *param) argument
435 ib_cm_send_rep(struct ib_cm_id *cm_id, struct ib_cm_rep_param *param) argument
470 cm_send_private_data(struct ib_cm_id *cm_id, uint32_t type, void *private_data, uint8_t private_data_len) argument
495 ib_cm_send_rtu(struct ib_cm_id *cm_id, void *private_data, uint8_t private_data_len) argument
503 ib_cm_send_dreq(struct ib_cm_id *cm_id, void *private_data, uint8_t private_data_len) argument
511 ib_cm_send_drep(struct ib_cm_id *cm_id, void *private_data, uint8_t private_data_len) argument
519 cm_establish(struct ib_cm_id *cm_id) argument
544 ib_cm_notify(struct ib_cm_id *cm_id, enum ibv_event_type event) argument
569 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
603 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
615 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
627 ib_cm_send_mra(struct ib_cm_id *cm_id, uint8_t service_timeout, void *private_data, uint8_t private_data_len) argument
653 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
682 ib_cm_send_sidr_req(struct ib_cm_id *cm_id, struct ib_cm_sidr_req_param *param) argument
715 ib_cm_send_sidr_rep(struct ib_cm_id *cm_id, struct ib_cm_sidr_rep_param *param) argument
[all...]
H A Dcm.h236 struct ib_cm_id *cm_id; member in struct:ib_cm_event
264 * new @cm_id.
265 * Clients are responsible for destroying the new @cm_id. For peer-to-peer
266 * IB_CM_REQ_RECEIVED and all other events, the returned @cm_id corresponds
309 struct ib_cm_id **cm_id, void *context);
313 * @cm_id: Connection identifier to destroy.
315 int ib_cm_destroy_id(struct ib_cm_id *cm_id);
326 * @cm_id: Connection identifier to retrieve attributes.
331 int ib_cm_attr_id(struct ib_cm_id *cm_id,
340 * @cm_id
[all...]
/freebsd-11-stable/contrib/ofed/librdmacm/
H A Dcma.c2341 struct rdma_cm_id *cm_id; local
2345 ret = rdma_create_id2(NULL, &cm_id, NULL, res->ai_port_space, res->ai_qp_type);
2350 ret = ucma_passive_ep(cm_id, res, pd, qp_init_attr);
2357 ret = rdma_resolve_addr2(cm_id, res->ai_src_addr, res->ai_src_len,
2360 ret = rdma_resolve_addr(cm_id, res->ai_src_addr, res->ai_dst_addr, 2000);
2365 ret = rdma_set_option(cm_id, RDMA_OPTION_IB, RDMA_OPTION_IB_PATH,
2368 ret = ucma_complete(cm_id);
2370 ret = rdma_resolve_route(cm_id, 2000);
2377 ret = rdma_create_qp(cm_id, pd, qp_init_attr);
2383 id_priv = container_of(cm_id, struc
[all...]
H A Drsocket.c285 struct rdma_cm_id *cm_id; member in struct:ds_qp
308 struct rdma_cm_id *cm_id; member in struct:rsocket::__anon3896::__anon3897
642 if (rs->cm_id->recv_cq_channel)
643 ret = fcntl(rs->cm_id->recv_cq_channel->fd, F_SETFL, arg);
646 ret = fcntl(rs->cm_id->channel->fd, F_SETFL, arg);
652 ret = fcntl(qp->cm_id->recv_cq_channel->fd,
666 max_size = min(ucma_max_qpsize(rs->cm_id), RS_QP_MAX_SIZE);
717 rs->smr = rdma_reg_msgs(rs->cm_id, rs->sbuf, total_sbuf_size);
727 rs->target_mr = rdma_reg_write(rs->cm_id, rs->target_buffer_list, len);
743 rs->rmr = rdma_reg_write(rs->cm_id, r
781 rs_create_cq(struct rsocket *rs, struct rdma_cm_id *cm_id) argument
[all...]
/freebsd-11-stable/contrib/ofed/librdmacm/examples/
H A Drping.c155 struct rdma_cm_id *cm_id; /* connection on client side,*/ member in struct:rping_cb
168 (cma_id == cb->cm_id) ? "parent" : "child");
499 ret = rdma_create_qp(cb->cm_id, cb->pd, &init_attr);
501 cb->qp = cb->cm_id->qp;
515 static int rping_setup_qp(struct rping_cb *cb, struct rdma_cm_id *cm_id) argument
519 cb->pd = ibv_alloc_pd(cm_id->verbs);
526 cb->channel = ibv_create_comp_channel(cm_id->verbs);
534 cb->cq = ibv_create_cq(cm_id->verbs, RPING_SQ_DEPTH * 2, cb,
740 ret = rdma_bind_addr(cb->cm_id, (struct sockaddr *) &cb->sin);
748 ret = rdma_listen(cb->cm_id,
[all...]
/freebsd-11-stable/sys/contrib/rdma/krping_compat/
H A Dkrping.c245 struct rdma_cm_id *cm_id; /* connection on client side,*/ member in struct:krping_cb
258 cma_id, (cma_id == cb->cm_id) ? "parent" : "child");
797 ret = rdma_create_qp(cb->cm_id, cb->pd, &init_attr);
799 cb->qp = cb->cm_id->qp;
812 static int krping_setup_qp(struct krping_cb *cb, struct rdma_cm_id *cm_id) argument
815 cb->pd = ib_alloc_pd(cm_id->device);
824 cb->cq = ib_create_cq(cm_id->device, krping_cq_event_handler, NULL,
1587 cb->cm_id->device;
1633 ret = rdma_bind_addr(cb->cm_id, (struct sockaddr *) &sin);
1641 ret = rdma_listen(cb->cm_id,
[all...]
/freebsd-11-stable/sys/dev/cxgb/ulp/iw_cxgb/
H A Diw_cxgb_cm.c434 if (ep->com.cm_id) {
435 CTR3(KTR_IW_CXGB, "close complete delivered ep %p cm_id %p tid %d",
436 ep, ep->com.cm_id, ep->hwtid);
437 ep->com.cm_id->event_handler(ep->com.cm_id, &event);
438 ep->com.cm_id->rem_ref(ep->com.cm_id);
439 ep->com.cm_id = NULL;
464 if (ep->com.cm_id) {
465 CTR3(KTR_IW_CXGB, "peer close delivered ep %p cm_id
1154 iwch_reject_cr(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len) argument
1176 iwch_accept_cr(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param) argument
1272 is_loopback_dst(struct iw_cm_id *cm_id) argument
1285 iwch_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param) argument
1363 iwch_create_listen_ep(struct iw_cm_id *cm_id, int backlog) argument
1389 iwch_destroy_listen_ep(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_ep(struct iw_cm_id *cm_id, int backlog);
235 void iwch_destroy_listen_ep(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-11-stable/sys/dev/mlx4/mlx4_ib/
H A Dmlx4_ib_cm.c75 static void set_local_comm_id(struct ib_mad *mad, u32 cm_id) argument
80 msg->request_id = cpu_to_be32(cm_id);
86 msg->local_comm_id = cpu_to_be32(cm_id);
105 static void set_remote_comm_id(struct ib_mad *mad, u32 cm_id) argument
110 msg->request_id = cpu_to_be32(cm_id);
116 msg->remote_comm_id = cpu_to_be32(cm_id);
220 pr_debug("overriding existing sl_id_map entry (cm_id = %x)\n",
/freebsd-11-stable/sys/dev/xen/blkfront/
H A Dblkfront.c239 ring_req->id = cm->cm_id;
256 ring_req->id = cm->cm_id;
1329 cm->cm_id = i;
H A Dblock.h117 uint64_t cm_id; member in struct:xbd_command
/freebsd-11-stable/sys/ofed/include/rdma/
H A Dib_cm.h302 * @cm_id: Communication identifier associated with the reported event.
307 * new @cm_id. The new @cm_id is returned to the user through this callback.
308 * Clients are responsible for destroying the new @cm_id. For peer-to-peer
309 * IB_CM_REQ_RECEIVED and all other events, the returned @cm_id corresponds
314 * destroy the @cm_id after the callback completes.
316 typedef int (*ib_cm_handler)(struct ib_cm_id *cm_id,
334 * @device: Device associated with the cm_id. All related communication will
349 * @cm_id: Connection identifier to destroy.
353 void ib_destroy_cm_id(struct ib_cm_id *cm_id);
[all...]
H A Diw_cm.h68 * @cm_id: The IW CM identifier associated with the event.
71 typedef int (*iw_cm_handler)(struct iw_cm_id *cm_id,
79 * @cm_id: The IW CM identifier associated with the event.
82 typedef int (*iw_event_handler)(struct iw_cm_id *cm_id,
96 /* Used by provider to add and remove refs on IW cm_id */
118 int (*connect)(struct iw_cm_id *cm_id,
121 int (*accept)(struct iw_cm_id *cm_id,
124 int (*reject)(struct iw_cm_id *cm_id,
127 int (*create_listen)(struct iw_cm_id *cm_id,
130 int (*destroy_listen)(struct iw_cm_id *cm_id);
[all...]
/freebsd-11-stable/sys/contrib/rdma/krping/
H A Dkrping.c241 struct rdma_cm_id *cm_id; /* connection on client side,*/ member in struct:krping_cb
254 (cma_id == cb->cm_id) ? "parent" : "child");
639 ret = rdma_create_qp(cb->cm_id, cb->pd, &init_attr);
641 cb->qp = cb->cm_id->qp;
654 static int krping_setup_qp(struct krping_cb *cb, struct rdma_cm_id *cm_id) argument
659 cb->pd = ib_alloc_pd(cm_id->device, 0);
670 cb->cq = ib_create_cq(cm_id->device, krping_cq_event_handler, NULL,
1409 ret = rdma_bind_addr(cb->cm_id, (struct sockaddr *)&sin);
1417 ret = rdma_listen(cb->cm_id, 3);
1740 rdma_disconnect(cb->cm_id);
[all...]
/freebsd-11-stable/sys/dev/cxgbe/iw_cxgbe/
H A Dcm.c193 epc->cm_id->rem_ref(epc->cm_id);
194 epc->cm_id = NULL;
201 epc->cm_id->add_ref(epc->cm_id);
413 if (ep->com.cm_id && ep->com.qp) {
650 if (ep->com.cm_id && ep->com.qp) {
727 if (ep->com.cm_id && ep->com.qp) {
772 /* The cm_id may be null if we failed to connect */
788 if ((ep->com.cm_id)
2362 c4iw_reject_cr(struct iw_cm_id *cm_id, const void *pdata, u8 pdata_len) argument
2399 c4iw_accept_cr(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param) argument
2591 c4iw_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param) argument
2699 c4iw_create_listen(struct iw_cm_id *cm_id, int backlog) argument
2774 c4iw_destroy_listen(struct iw_cm_id *cm_id) argument
[all...]
H A Diw_cxgbe.h819 struct iw_cm_id *cm_id; member in struct:c4iw_ep_common
872 static inline struct c4iw_ep *to_ep(struct iw_cm_id *cm_id) argument
874 return cm_id->provider_data;
877 static inline struct c4iw_listen_ep *to_listen_ep(struct iw_cm_id *cm_id) argument
879 return cm_id->provider_data;
924 int c4iw_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
925 int c4iw_create_listen(struct iw_cm_id *cm_id, int backlog);
926 int c4iw_destroy_listen(struct iw_cm_id *cm_id);
927 int c4iw_accept_cr(struct iw_cm_id *cm_id, struct iw_cm_conn_param *conn_param);
928 int c4iw_reject_cr(struct iw_cm_id *cm_id, cons
[all...]
/freebsd-11-stable/sys/ofed/drivers/infiniband/core/
H A Dib_cm.c861 * The cm_id could be destroyed by the user before we exit timewait.
862 * To protect against this, we search for the cm_id after exiting
892 static void cm_destroy_id(struct ib_cm_id *cm_id, int err) argument
897 cm_id_priv = container_of(cm_id, struct cm_id_private, id);
900 switch (cm_id->state) {
915 cm_id->state = IB_CM_IDLE;
932 ib_send_cm_rej(cm_id, IB_CM_REJ_TIMEOUT,
944 ib_send_cm_rej(cm_id, IB_CM_REJ_CONSUMER_DEFINED,
956 ib_send_cm_rej(cm_id, IB_CM_REJ_CONSUMER_DEFINED,
963 ib_send_cm_dreq(cm_id, NUL
997 ib_destroy_cm_id(struct ib_cm_id *cm_id) argument
1016 __ib_cm_listen(struct ib_cm_id *cm_id, __be64 service_id, __be64 service_mask) argument
1052 ib_cm_listen(struct ib_cm_id *cm_id, __be64 service_id, __be64 service_mask) argument
1086 struct ib_cm_id *cm_id; local
1259 ib_send_cm_req(struct ib_cm_id *cm_id, struct ib_cm_req_param *param) argument
1687 struct ib_cm_id *cm_id; local
1831 ib_send_cm_rep(struct ib_cm_id *cm_id, struct ib_cm_rep_param *param) argument
1893 ib_send_cm_rtu(struct ib_cm_id *cm_id, const void *private_data, u8 private_data_len) argument
2182 ib_send_cm_dreq(struct ib_cm_id *cm_id, const void *private_data, u8 private_data_len) argument
2244 ib_send_cm_drep(struct ib_cm_id *cm_id, const void *private_data, u8 private_data_len) argument
2431 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
2605 ib_send_cm_mra(struct ib_cm_id *cm_id, u8 service_timeout, const void *private_data, u8 private_data_len) argument
2801 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
2982 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
3122 ib_send_cm_sidr_req(struct ib_cm_id *cm_id, struct ib_cm_sidr_req_param *param) argument
3192 struct ib_cm_id *cm_id; local
3272 ib_send_cm_sidr_rep(struct ib_cm_id *cm_id, struct ib_cm_sidr_rep_param *param) argument
3510 cm_establish(struct ib_cm_id *cm_id) argument
3574 cm_migrate(struct ib_cm_id *cm_id) argument
3603 ib_cm_notify(struct ib_cm_id *cm_id, enum ib_event_type event) argument
3846 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 Dib_cma.c310 } cm_id; member in struct:rdma_id_private
979 if (!id_priv->cm_id.ib || (id_priv->id.qp_type == IB_QPT_UD))
982 ret = ib_cm_init_qp_attr(id_priv->cm_id.ib, qp_attr,
988 if (!id_priv->cm_id.iw) {
992 ret = iw_cm_init_qp_attr(id_priv->cm_id.iw, qp_attr,
1538 const struct ib_cm_id *cm_id,
1550 if (id_priv->id.device == cm_id->device &&
1556 if (id_priv_dev->id.device == cm_id->device &&
1566 static struct rdma_id_private *cma_id_from_event(struct ib_cm_id *cm_id, argument
1592 id_priv = cma_find_listener(bind_list, cm_id, ib_even
1536 cma_find_listener( const struct rdma_bind_list *bind_list, const struct ib_cm_id *cm_id, const struct ib_cm_event *ib_event, const struct cma_req_info *req, const struct net_device *net_dev) argument
1786 cma_ib_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) argument
1990 cma_req_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) argument
2158 iw_conn_req_handler(struct iw_cm_id *cm_id, struct iw_cm_event *iw_event) argument
3328 cma_sidr_rep_handler(struct ib_cm_id *cm_id, struct ib_cm_event *ib_event) argument
3524 struct iw_cm_id *cm_id; local
[all...]
H A Dib_iwcm.c69 struct iwcm_id_private *cm_id; member in struct:iwcm_work
79 * elements. The design pre-allocates them based on the cm_id type:
89 * One exception is when creating the cm_id for incoming connection requests.
91 * 1) in the event upcall, cm_event_handler(), for a listening cm_id. If
96 * If work elements cannot be allocated for the new connect request cm_id,
115 list_add(&work->free_list, &work->cm_id->work_free_list);
137 work->cm_id = cm_id_priv;
167 * Release a reference on cm_id. If the last reference is being
168 * released, free the cm_id and return 1.
182 static void add_ref(struct iw_cm_id *cm_id) argument
189 rem_ref(struct iw_cm_id *cm_id) argument
265 iw_cm_disconnect(struct iw_cm_id *cm_id, int abrupt) argument
332 destroy_cm_id(struct iw_cm_id *cm_id) argument
404 iw_destroy_cm_id(struct iw_cm_id *cm_id) argument
424 iw_cm_map(struct iw_cm_id *cm_id, bool active) argument
438 iw_cm_listen(struct iw_cm_id *cm_id, int backlog) argument
479 iw_cm_reject(struct iw_cm_id *cm_id, const void *private_data, u8 private_data_len) argument
517 iw_cm_accept(struct iw_cm_id *cm_id, struct iw_cm_conn_param *iw_param) argument
573 iw_cm_connect(struct iw_cm_id *cm_id, struct iw_cm_conn_param *iw_param) argument
644 struct iw_cm_id *cm_id; local
923 cm_event_handler(struct iw_cm_id *cm_id, struct iw_cm_event *iw_event) argument
1015 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 Dib_ucm.c87 struct ib_cm_id *cm_id; member in struct:ib_ucm_context
99 struct ib_cm_id *cm_id; member in struct:ib_ucm_event
172 ib_destroy_cm_id(uevent->cm_id);
351 static int ib_ucm_event_handler(struct ib_cm_id *cm_id, argument
358 ctx = cm_id->context;
365 uevent->cm_id = cm_id;
384 /* Destroy new cm_id's */
426 ctx->cm_id = uevent->cm_id;
832 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
882 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 Dib_ucma.c82 struct rdma_cm_id *cm_id; member in struct:ucma_context
111 struct rdma_cm_id *cm_id; member in struct:ucma_event
128 else if (ctx->file != file || !ctx->cm_id)
156 * Same as ucm_get_ctx but requires that ->cm_id->device is valid, eg that the
165 if (!ctx->cm_id->device) {
176 rdma_destroy_id(uevent_close->cm_id);
191 rdma_destroy_id(ctx->cm_id);
294 static void ucma_removal_event_handler(struct rdma_cm_id *cm_id) argument
296 struct ucma_context *ctx = cm_id->context;
303 /* only if context is pointing to cm_id tha
331 ucma_event_handler(struct rdma_cm_id *cm_id, struct rdma_cm_event *event) argument
467 struct rdma_cm_id *cm_id; local
861 ucma_query_device_addr(struct rdma_cm_id *cm_id, struct rdma_ucm_query_addr_resp *resp) argument
[all...]
/freebsd-11-stable/sys/ofed/drivers/infiniband/ulp/ipoib/
H A Dipoib_cm.c81 static int ipoib_cm_tx_handler(struct ib_cm_id *cm_id,
233 struct ib_cm_id *cm_id, struct ib_qp *qp,
240 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask);
251 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask);
272 ret = ib_cm_init_qp_attr(cm_id, &qp_attr, &qp_attr_mask);
301 struct ib_cm_id *cm_id, struct ipoib_cm_rx *rx)
331 ib_send_cm_rej(cm_id, IB_CM_REJ_NO_QP, NULL, 0, NULL, 0);
372 static int ipoib_cm_send_rep(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, argument
389 return ib_send_cm_rep(cm_id, &rep);
392 static int ipoib_cm_req_handler(struct ib_cm_id *cm_id, struc argument
232 ipoib_cm_modify_rx_qp(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, struct ib_qp *qp, unsigned psn) argument
300 ipoib_cm_nonsrq_init_rx(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, struct ipoib_cm_rx *rx) argument
452 ipoib_cm_rx_handler(struct ib_cm_id *cm_id, struct ib_cm_event *event) argument
841 ipoib_cm_rep_handler(struct ib_cm_id *cm_id, struct ib_cm_event *event) argument
973 ipoib_cm_modify_tx_init(struct ipoib_dev_priv *priv, struct ib_cm_id *cm_id, struct ib_qp *qp) argument
1105 ipoib_cm_tx_handler(struct ib_cm_id *cm_id, struct ib_cm_event *event) argument
[all...]

Completed in 243 milliseconds