Home
last modified time | relevance | path

Searched refs:recv_cq (Results 1 – 25 of 53) sorted by relevance

123

/freebsd/contrib/ofed/libmlx4/
H A Dverbs.c1041 if (qp->recv_cq) in mlx4_modify_qp()
1042 mlx4_cq_clean(to_mcq(qp->recv_cq), qp->qp_num, in mlx4_modify_qp()
1044 if (qp->send_cq && qp->send_cq != qp->recv_cq) in mlx4_modify_qp()
1058 struct mlx4_cq *recv_cq = to_mcq(qp->recv_cq); in mlx4_lock_cqs() local
1060 if (!qp->send_cq || !qp->recv_cq) { in mlx4_lock_cqs()
1063 else if (qp->recv_cq) in mlx4_lock_cqs()
1064 pthread_spin_lock(&recv_cq->lock); in mlx4_lock_cqs()
1065 } else if (send_cq == recv_cq) { in mlx4_lock_cqs()
1067 } else if (send_cq->cqn < recv_cq->cqn) { in mlx4_lock_cqs()
1069 pthread_spin_lock(&recv_cq->lock); in mlx4_lock_cqs()
[all …]
/freebsd/sys/ofed/drivers/infiniband/ulp/ipoib/
H A Dipoib_verbs.c167 priv->recv_cq = ib_create_cq(priv->ca, ipoib_ib_completion, NULL, priv, &cq_attr); in ipoib_transport_dev_init()
168 if (IS_ERR(priv->recv_cq)) { in ipoib_transport_dev_init()
181 if (ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP)) in ipoib_transport_dev_init()
198 init_attr.recv_cq = priv->recv_cq; in ipoib_transport_dev_init()
237 ib_destroy_cq(priv->recv_cq); in ipoib_transport_dev_init()
259 ib_destroy_cq(priv->recv_cq); in ipoib_transport_dev_cleanup()
H A Dipoib_ethtool.c90 ret = ib_modify_cq(priv->recv_cq, coal->rx_max_coalesced_frames, in ipoib_set_coalesce()
H A Dipoib_ib.c397 n = ib_poll_cq(priv->recv_cq, IPOIB_NUM_WC, priv->ibwc); in ipoib_poll()
415 if (ib_req_notify_cq(priv->recv_cq, in ipoib_poll()
747 n = ib_poll_cq(priv->recv_cq, IPOIB_NUM_WC, priv->ibwc); in ipoib_drain_cq()
850 ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP); in ipoib_ib_dev_stop()
H A Dipoib_cm.c214 .send_cq = priv->recv_cq, /* For drain WR */ in ipoib_cm_create_rx_qp()
215 .recv_cq = priv->recv_cq, in ipoib_cm_create_rx_qp()
930 .recv_cq = priv->recv_cq, in ipoib_cm_create_tx_qp()
/freebsd/sys/dev/mthca/
H A Dmthca_qp.c762 qp_context->cqn_rcv = cpu_to_be32(to_mcq(ibqp->recv_cq)->cqn); in __mthca_modify_qp()
823 mthca_cq_clean(dev, to_mcq(qp->ibqp.recv_cq), qp->qpn, in __mthca_modify_qp()
825 if (qp->ibqp.send_cq != qp->ibqp.recv_cq) in __mthca_modify_qp()
1148 struct mthca_cq *recv_cq, in mthca_alloc_qp_common() argument
1276 struct mthca_cq *recv_cq, in mthca_alloc_qp() argument
1303 err = mthca_alloc_qp_common(dev, pd, send_cq, recv_cq, in mthca_alloc_qp()
1318 static void mthca_lock_cqs(struct mthca_cq *send_cq, struct mthca_cq *recv_cq) in mthca_lock_cqs() argument
1319 __acquires(&send_cq->lock) __acquires(&recv_cq->lock) in mthca_lock_cqs()
1321 if (send_cq == recv_cq) { in mthca_lock_cqs()
1323 __acquire(&recv_cq->lock); in mthca_lock_cqs()
[all …]
H A Dmthca_dev.h549 struct mthca_cq *recv_cq,
558 struct mthca_cq *recv_cq,
/freebsd/sys/dev/mlx5/mlx5_ib/
H A Dmlx5_ib_qp.c88 struct mlx5_ib_cq **send_cq, struct mlx5_ib_cq **recv_cq);
613 struct mlx5_ib_cq *recv_cq);
615 struct mlx5_ib_cq *recv_cq);
1595 struct mlx5_ib_cq *recv_cq; in create_qp_common() local
1768 rcqe_sz = mlx5_ib_get_cqe_size(dev, init_attr->recv_cq); in create_qp_common()
1825 if (init_attr->recv_cq) in create_qp_common()
1826 MLX5_SET(qpc, qpc, cqn_rcv, to_mcq(init_attr->recv_cq)->mcq.cqn); in create_qp_common()
1859 get_cqs(init_attr->qp_type, init_attr->send_cq, init_attr->recv_cq, in create_qp_common()
1860 &send_cq, &recv_cq); in create_qp_common()
1862 mlx5_ib_lock_cqs(send_cq, recv_cq); in create_qp_common()
[all …]
H A Dmlx5_ib_gsi.c254 .recv_cq = gsi->rx_qp->recv_cq, in create_gsi_ud_qp()
/freebsd/contrib/ofed/librdmacm/
H A Drdma_verbs.h290 ret = ibv_poll_cq(id->recv_cq, 1, wc); in rdma_get_recv_comp()
294 ret = ibv_req_notify_cq(id->recv_cq, 0); in rdma_get_recv_comp()
298 ret = ibv_poll_cq(id->recv_cq, 1, wc); in rdma_get_recv_comp()
306 assert(cq == id->recv_cq && context == id); in rdma_get_recv_comp()
307 ibv_ack_cq_events(id->recv_cq, 1); in rdma_get_recv_comp()
H A Dcma.c1207 if (id->recv_cq) { in ucma_destroy_cqs()
1208 ibv_destroy_cq(id->recv_cq); in ucma_destroy_cqs()
1209 if (id->send_cq && (id->send_cq != id->recv_cq)) { in ucma_destroy_cqs()
1213 id->recv_cq = NULL; in ucma_destroy_cqs()
1233 id->recv_cq = ibv_create_cq(id->verbs, recv_size, in ucma_create_cqs()
1235 if (!id->recv_cq) in ucma_create_cqs()
1281 attr->cq = id->recv_cq; in rdma_create_srq_ex()
1344 if ((id->recv_cq && attr->recv_cq && id->recv_cq != attr->recv_cq) || in rdma_create_qp_ex()
1358 attr->recv_cq || id->recv_cq ? 0 : attr->cap.max_recv_wr); in rdma_create_qp_ex()
1364 if (!attr->recv_cq) in rdma_create_qp_ex()
[all …]
H A Drsocket.c787 cm_id->recv_cq = ibv_create_cq(cm_id->verbs, rs->sq_size + rs->rq_size, in rs_create_cq()
789 if (!cm_id->recv_cq) in rs_create_cq()
797 ibv_req_notify_cq(cm_id->recv_cq, 0); in rs_create_cq()
799 cm_id->send_cq = cm_id->recv_cq; in rs_create_cq()
803 ibv_destroy_cq(cm_id->recv_cq); in rs_create_cq()
804 cm_id->recv_cq = NULL; in rs_create_cq()
872 qp_attr.recv_cq = rs->cm_id->recv_cq; in rs_create_ep()
1018 ibv_ack_cq_events(rs->cm_id->recv_cq, rs->unack_cqe); in rs_free()
1519 qp_attr.recv_cq = qp->cm_id->recv_cq; in ds_create_qp()
1906 while ((ret = ibv_poll_cq(rs->cm_id->recv_cq, 1, &wc)) > 0) { in rs_poll_cq()
[all …]
H A Drdma_cma.h134 struct ibv_cq *recv_cq; member
/freebsd/contrib/ofed/libibverbs/examples/
H A Dxsrq_pingpong.c81 struct ibv_cq *recv_cq; member
274 ctx.recv_cq = ibv_create_cq(ctx.context, ctx.num_clients, &ctx.recv_cq, in pp_init_ctx()
276 if (!ctx.recv_cq) { in pp_init_ctx()
282 if (ibv_req_notify_cq(ctx.recv_cq, 0)) { in pp_init_ctx()
301 attr.cq = ctx.recv_cq; in pp_init_ctx()
700 if (ibv_destroy_cq(ctx.recv_cq)) { in pp_close_ctx()
811 if (ev_cq != ctx.recv_cq) { in get_cq_event()
816 if (ibv_req_notify_cq(ctx.recv_cq, 0)) { in get_cq_event()
976 ne = ibv_poll_cq(ctx.recv_cq, 1, &wc); in main()
1006 ibv_ack_cq_events(ctx.recv_cq, num_cq_events); in main()
/freebsd/contrib/ofed/libmlx5/
H A Dverbs.c1454 struct mlx5_cq *recv_cq = to_mcq(qp->recv_cq); in mlx5_lock_cqs() local
1456 if (send_cq && recv_cq) { in mlx5_lock_cqs()
1457 if (send_cq == recv_cq) { in mlx5_lock_cqs()
1459 } else if (send_cq->cqn < recv_cq->cqn) { in mlx5_lock_cqs()
1461 mlx5_spin_lock(&recv_cq->lock); in mlx5_lock_cqs()
1463 mlx5_spin_lock(&recv_cq->lock); in mlx5_lock_cqs()
1468 } else if (recv_cq) { in mlx5_lock_cqs()
1469 mlx5_spin_lock(&recv_cq->lock); in mlx5_lock_cqs()
1476 struct mlx5_cq *recv_cq in mlx5_unlock_cqs() local
[all...]
/freebsd/sys/dev/mlx4/mlx4_ib/
H A Dmlx4_ib_qp.c56 struct mlx4_ib_cq *recv_cq);
58 struct mlx4_ib_cq *recv_cq);
889 to_mcq(init_attr->recv_cq)); in create_qp_common()
899 mcq = to_mcq(init_attr->recv_cq); in create_qp_common()
902 to_mcq(init_attr->recv_cq)); in create_qp_common()
958 static void mlx4_ib_lock_cqs(struct mlx4_ib_cq *send_cq, struct mlx4_ib_cq *recv_cq) in mlx4_ib_lock_cqs() argument
959 __acquires(&send_cq->lock) __acquires(&recv_cq->lock) in mlx4_ib_lock_cqs()
961 if (send_cq == recv_cq) { in mlx4_ib_lock_cqs()
963 __acquire(&recv_cq->lock); in mlx4_ib_lock_cqs()
964 } else if (send_cq->mcq.cqn < recv_cq->mcq.cqn) { in mlx4_ib_lock_cqs()
[all …]
/freebsd/contrib/ofed/libibverbs/
H A Dcompat-1_0.c76 struct ibv_cq_1_0 *recv_cq; member
122 struct ibv_cq_1_0 *recv_cq; member
879 real_init_attr.recv_cq = qp_init_attr->recv_cq->real_cq; in __ibv_create_qp_1_0()
896 qp->recv_cq = qp_init_attr->recv_cq; in __ibv_create_qp_1_0()
923 init_attr->recv_cq = real_init_attr.recv_cq->cq_context; in __ibv_query_qp_1_0()
H A Dcmd.c887 cmd->recv_cq_handle = qp_attr->recv_cq->handle; in create_qp_ex_common()
953 qp->qp.recv_cq = qp_attr->recv_cq; in create_qp_handle_resp_common()
1110 cmd->recv_cq_handle = attr->recv_cq->handle; in ibv_cmd_create_qp()
1202 qp->qp.recv_cq = NULL; in ibv_cmd_open_qp()
1300 init_attr->recv_cq = qp->recv_cq; in ibv_cmd_query_qp()
H A Dverbs.h776 struct ibv_cq *recv_cq; member
811 struct ibv_cq *recv_cq; member
1043 struct ibv_cq *recv_cq; member
H A Dverbs.c597 qp->recv_cq = qp_init_attr->recv_cq; in __ibv_create_qp()
/freebsd/sys/ofed/drivers/infiniband/core/
H A Dcore_priv.h171 qp->recv_cq = attr->recv_cq; in _ib_create_qp()
H A Dib_verbs.c860 qp->send_cq = qp->recv_cq = NULL; in ib_create_xrc_qp()
882 (qp_init_attr->recv_cq || in ib_create_qp()
906 qp->recv_cq = NULL; in ib_create_qp()
909 qp->recv_cq = qp_init_attr->recv_cq; in ib_create_qp()
910 if (qp_init_attr->recv_cq) in ib_create_qp()
911 atomic_inc(&qp_init_attr->recv_cq->usecnt); in ib_create_qp()
1502 rcq = qp->recv_cq; in ib_destroy_qp_user()
2193 if (qp->recv_cq->poll_ctx == IB_POLL_DIRECT) { in __ib_drain_rq()
2194 WARN_ONCE(qp->recv_cq->poll_ctx == IB_POLL_DIRECT, in __ib_drain_rq()
/freebsd/contrib/ofed/libirdma/
H A Dirdma_umain.h131 struct irdma_ucq *recv_cq; member
H A Dirdma_uverbs.c1338 iwuqp->recv_cq = container_of(attr->recv_cq, struct irdma_ucq, in irdma_vmapped_qp()
1341 iwuqp->recv_cq->uqp = iwuqp; in irdma_vmapped_qp()
1620 if (iwuqp->recv_cq && iwuqp->recv_cq != iwuqp->send_cq) in irdma_udestroy_qp()
1621 irdma_clean_cqes(&iwuqp->qp, iwuqp->recv_cq); in irdma_udestroy_qp()
/freebsd/sys/dev/qlnx/qlnxr/
H A Dqlnxr_cm.c48 dev->gsi_rqcq = get_qlnxr_cq((attrs->recv_cq)); in qlnxr_store_gsi_qp_cq()
172 cq = get_qlnxr_cq((attrs->recv_cq)); in qlnxr_destroy_gsi_cq()

123