Searched refs:recv_cq (Results 1 - 25 of 45) sorted by relevance

12

/freebsd-12-stable/sys/ofed/drivers/infiniband/ulp/ipoib/
H A Dipoib_verbs.c168 priv->recv_cq = ib_create_cq(priv->ca, ipoib_ib_completion, NULL, priv, &cq_attr);
169 if (IS_ERR(priv->recv_cq)) {
182 if (ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP))
199 init_attr.recv_cq = priv->recv_cq;
237 ib_destroy_cq(priv->recv_cq);
260 if (ib_destroy_cq(priv->recv_cq))
H A Dipoib_ethtool.c92 ret = ib_modify_cq(priv->recv_cq, coal->rx_max_coalesced_frames,
H A Dipoib_ib.c399 n = ib_poll_cq(priv->recv_cq, IPOIB_NUM_WC, priv->ibwc);
417 if (ib_req_notify_cq(priv->recv_cq,
749 n = ib_poll_cq(priv->recv_cq, IPOIB_NUM_WC, priv->ibwc);
852 ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP);
H A Dipoib_cm.c216 .send_cq = priv->recv_cq, /* For drain WR */
217 .recv_cq = priv->recv_cq,
929 .recv_cq = priv->recv_cq,
/freebsd-12-stable/contrib/ofed/libmlx4/
H A Dverbs.c1028 if (qp->recv_cq)
1029 mlx4_cq_clean(to_mcq(qp->recv_cq), qp->qp_num,
1031 if (qp->send_cq && qp->send_cq != qp->recv_cq)
1045 struct mlx4_cq *recv_cq = to_mcq(qp->recv_cq); local
1047 if (!qp->send_cq || !qp->recv_cq) {
1050 else if (qp->recv_cq)
1051 pthread_spin_lock(&recv_cq->lock);
1052 } else if (send_cq == recv_cq) {
1054 } else if (send_cq->cqn < recv_cq
1066 struct mlx4_cq *recv_cq = to_mcq(qp->recv_cq); local
[all...]
/freebsd-12-stable/contrib/ofed/librdmacm/
H A Drdma_verbs.h290 ret = ibv_poll_cq(id->recv_cq, 1, wc);
294 ret = ibv_req_notify_cq(id->recv_cq, 0);
298 ret = ibv_poll_cq(id->recv_cq, 1, wc);
306 assert(cq == id->recv_cq && context == id);
307 ibv_ack_cq_events(id->recv_cq, 1);
H A Dcma.c1206 if (id->recv_cq) {
1207 ibv_destroy_cq(id->recv_cq);
1208 if (id->send_cq && (id->send_cq != id->recv_cq)) {
1212 id->recv_cq = NULL;
1232 id->recv_cq = ibv_create_cq(id->verbs, recv_size,
1234 if (!id->recv_cq)
1280 attr->cq = id->recv_cq;
1343 if ((id->recv_cq && attr->recv_cq && id->recv_cq !
[all...]
H A Drdma_cma.h134 struct ibv_cq *recv_cq; member in struct:rdma_cm_id
H A Drsocket.c787 cm_id->recv_cq = ibv_create_cq(cm_id->verbs, rs->sq_size + rs->rq_size,
789 if (!cm_id->recv_cq)
797 ibv_req_notify_cq(cm_id->recv_cq, 0);
799 cm_id->send_cq = cm_id->recv_cq;
803 ibv_destroy_cq(cm_id->recv_cq);
804 cm_id->recv_cq = NULL;
872 qp_attr.recv_cq = rs->cm_id->recv_cq;
1018 ibv_ack_cq_events(rs->cm_id->recv_cq, rs->unack_cqe);
1519 qp_attr.recv_cq
[all...]
/freebsd-12-stable/sys/dev/mthca/
H A Dmthca_qp.c758 qp_context->cqn_rcv = cpu_to_be32(to_mcq(ibqp->recv_cq)->cqn);
819 mthca_cq_clean(dev, to_mcq(qp->ibqp.recv_cq), qp->qpn,
821 if (qp->ibqp.send_cq != qp->ibqp.recv_cq)
1144 struct mthca_cq *recv_cq,
1272 struct mthca_cq *recv_cq,
1298 err = mthca_alloc_qp_common(dev, pd, send_cq, recv_cq,
1313 static void mthca_lock_cqs(struct mthca_cq *send_cq, struct mthca_cq *recv_cq)
1314 __acquires(&send_cq->lock) __acquires(&recv_cq->lock)
1316 if (send_cq == recv_cq) {
1318 __acquire(&recv_cq
1141 mthca_alloc_qp_common(struct mthca_dev *dev, struct mthca_pd *pd, struct mthca_cq *send_cq, struct mthca_cq *recv_cq, enum ib_sig_type send_policy, struct mthca_qp *qp) argument
1269 mthca_alloc_qp(struct mthca_dev *dev, struct mthca_pd *pd, struct mthca_cq *send_cq, struct mthca_cq *recv_cq, enum ib_qp_type type, enum ib_sig_type send_policy, struct ib_qp_cap *cap, struct mthca_qp *qp) argument
1343 mthca_alloc_sqp(struct mthca_dev *dev, struct mthca_pd *pd, struct mthca_cq *send_cq, struct mthca_cq *recv_cq, enum ib_sig_type send_policy, struct ib_qp_cap *cap, int qpn, int port, struct mthca_sqp *sqp) argument
1425 struct mthca_cq *recv_cq; local
[all...]
H A Dmthca_dev.h548 struct mthca_cq *recv_cq,
556 struct mthca_cq *recv_cq,
/freebsd-12-stable/sys/dev/mlx5/mlx5_ib/
H A Dmlx5_ib_qp.c86 struct mlx5_ib_cq **send_cq, struct mlx5_ib_cq **recv_cq);
648 struct mlx5_ib_cq *recv_cq);
650 struct mlx5_ib_cq *recv_cq);
1509 struct mlx5_ib_cq *recv_cq; local
1682 rcqe_sz = mlx5_ib_get_cqe_size(dev, init_attr->recv_cq);
1736 if (init_attr->recv_cq)
1737 MLX5_SET(qpc, qpc, cqn_rcv, to_mcq(init_attr->recv_cq)->mcq.cqn);
1770 get_cqs(init_attr->qp_type, init_attr->send_cq, init_attr->recv_cq,
1771 &send_cq, &recv_cq);
1773 mlx5_ib_lock_cqs(send_cq, recv_cq);
1862 get_cqs(enum ib_qp_type qp_type, struct ib_cq *ib_send_cq, struct ib_cq *ib_recv_cq, struct mlx5_ib_cq **send_cq, struct mlx5_ib_cq **recv_cq) argument
1903 struct mlx5_ib_cq *send_cq, *recv_cq; local
2606 struct mlx5_ib_cq *send_cq, *recv_cq; local
[all...]
H A Dmlx5_ib_gsi.c253 .recv_cq = gsi->rx_qp->recv_cq,
/freebsd-12-stable/contrib/ofed/libibverbs/examples/
H A Dxsrq_pingpong.c81 struct ibv_cq *recv_cq; member in struct:pingpong_context
274 ctx.recv_cq = ibv_create_cq(ctx.context, ctx.num_clients, &ctx.recv_cq,
276 if (!ctx.recv_cq) {
282 if (ibv_req_notify_cq(ctx.recv_cq, 0)) {
301 attr.cq = ctx.recv_cq;
696 if (ibv_destroy_cq(ctx.recv_cq)) {
807 if (ev_cq != ctx.recv_cq) {
812 if (ibv_req_notify_cq(ctx.recv_cq, 0)) {
972 ne = ibv_poll_cq(ctx.recv_cq,
[all...]
/freebsd-12-stable/sys/dev/mlx4/mlx4_ib/
H A Dmlx4_ib_qp.c55 struct mlx4_ib_cq *recv_cq);
57 struct mlx4_ib_cq *recv_cq);
888 to_mcq(init_attr->recv_cq));
898 mcq = to_mcq(init_attr->recv_cq);
901 to_mcq(init_attr->recv_cq));
957 static void mlx4_ib_lock_cqs(struct mlx4_ib_cq *send_cq, struct mlx4_ib_cq *recv_cq)
958 __acquires(&send_cq->lock) __acquires(&recv_cq->lock)
960 if (send_cq == recv_cq) {
962 __acquire(&recv_cq->lock);
963 } else if (send_cq->mcq.cqn < recv_cq
1005 get_cqs(struct mlx4_ib_qp *qp, struct mlx4_ib_cq **send_cq, struct mlx4_ib_cq **recv_cq) argument
1027 struct mlx4_ib_cq *send_cq, *recv_cq; local
1626 struct mlx4_ib_cq *send_cq, *recv_cq; local
[all...]
/freebsd-12-stable/contrib/ofed/libmlx5/
H A Dverbs.c1430 struct mlx5_cq *recv_cq = to_mcq(qp->recv_cq); local
1432 if (send_cq && recv_cq) {
1433 if (send_cq == recv_cq) {
1435 } else if (send_cq->cqn < recv_cq->cqn) {
1437 mlx5_spin_lock(&recv_cq->lock);
1439 mlx5_spin_lock(&recv_cq->lock);
1444 } else if (recv_cq) {
1445 mlx5_spin_lock(&recv_cq->lock);
1452 struct mlx5_cq *recv_cq local
[all...]
/freebsd-12-stable/contrib/ofed/libibverbs/
H A Dcompat-1_0.c76 struct ibv_cq_1_0 *recv_cq; member in struct:ibv_qp_init_attr_1_0
122 struct ibv_cq_1_0 *recv_cq; member in struct:ibv_qp_1_0
879 real_init_attr.recv_cq = qp_init_attr->recv_cq->real_cq;
896 qp->recv_cq = qp_init_attr->recv_cq;
923 init_attr->recv_cq = real_init_attr.recv_cq->cq_context;
H A Dcmd.c870 cmd->recv_cq_handle = qp_attr->recv_cq->handle;
911 qp->qp.recv_cq = qp_attr->recv_cq;
1047 cmd->recv_cq_handle = attr->recv_cq->handle;
1128 qp->qp.recv_cq = NULL;
1221 init_attr->recv_cq = qp->recv_cq;
H A Dverbs.h776 struct ibv_cq *recv_cq; member in struct:ibv_qp_init_attr
811 struct ibv_cq *recv_cq; member in struct:ibv_qp_init_attr_ex
1043 struct ibv_cq *recv_cq; member in struct:ibv_qp
H A Dverbs.c575 qp->recv_cq = qp_init_attr->recv_cq;
/freebsd-12-stable/sys/ofed/drivers/infiniband/core/
H A Dib_verbs.c777 qp->send_cq = qp->recv_cq = NULL;
799 (qp_init_attr->recv_cq ||
823 qp->recv_cq = NULL;
826 qp->recv_cq = qp_init_attr->recv_cq;
827 if (qp_init_attr->recv_cq)
828 atomic_inc(&qp_init_attr->recv_cq->usecnt);
1333 rcq = qp->recv_cq;
2022 if (qp->recv_cq->poll_ctx == IB_POLL_DIRECT) {
2023 WARN_ONCE(qp->recv_cq
[all...]
/freebsd-12-stable/contrib/ofed/librdmacm/examples/
H A Dmckey.c159 init_qp_attr.recv_cq = node->cq;
/freebsd-12-stable/contrib/libpcap/
H A Dpcap-rdmasniff.c230 qp_init_attr.send_cq = qp_init_attr.recv_cq = priv->cq;
/freebsd-12-stable/sys/ofed/drivers/infiniband/ulp/sdp/
H A Dsdp_cma.c112 qp_init_attr.recv_cq = ssk->rx_ring.cq;
/freebsd-12-stable/contrib/ofed/libcxgb4/
H A Dqp.c512 rchp = to_c4iw_cq(qhp->ibv_qp.recv_cq);

Completed in 333 milliseconds

12