Home
last modified time | relevance | path

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

12

/NextBSD/contrib/ofed/libmthca/src/
HDverbs.c640 mthca_cq_clean(to_mcq(qp->recv_cq), qp->qp_num, in mthca_modify_qp()
642 if (qp->send_cq != qp->recv_cq) in mthca_modify_qp()
659 struct mthca_cq *recv_cq = to_mcq(qp->recv_cq); in mthca_lock_cqs() local
661 if (send_cq == recv_cq) in mthca_lock_cqs()
663 else if (send_cq->cqn < recv_cq->cqn) { in mthca_lock_cqs()
665 pthread_spin_lock(&recv_cq->lock); in mthca_lock_cqs()
667 pthread_spin_lock(&recv_cq->lock); in mthca_lock_cqs()
675 struct mthca_cq *recv_cq = to_mcq(qp->recv_cq); in mthca_unlock_cqs() local
677 if (send_cq == recv_cq) in mthca_unlock_cqs()
679 else if (send_cq->cqn < recv_cq->cqn) { in mthca_unlock_cqs()
[all …]
HDqp.c353 if (wq_overflow(&qp->rq, nreq, to_mcq(qp->ibv_qp.recv_cq))) { in mthca_tavor_post_recv()
724 if (wq_overflow(&qp->rq, nreq, to_mcq(qp->ibv_qp.recv_cq))) { in mthca_arbel_post_recv()
/NextBSD/sys/ofed/drivers/infiniband/ulp/ipoib/
HDipoib_verbs.c166 priv->recv_cq = ib_create_cq(priv->ca, ipoib_ib_completion, NULL, priv, size, 0); in ipoib_transport_dev_init()
167 if (IS_ERR(priv->recv_cq)) { in ipoib_transport_dev_init()
179 if (ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP)) in ipoib_transport_dev_init()
196 init_attr.recv_cq = priv->recv_cq; in ipoib_transport_dev_init()
234 ib_destroy_cq(priv->recv_cq); in ipoib_transport_dev_init()
259 if (ib_destroy_cq(priv->recv_cq)) in ipoib_transport_dev_cleanup()
HDipoib_ib.c388 n = ib_poll_cq(priv->recv_cq, IPOIB_NUM_WC, priv->ibwc); in ipoib_poll()
407 if (ib_req_notify_cq(priv->recv_cq, in ipoib_poll()
714 n = ib_poll_cq(priv->recv_cq, IPOIB_NUM_WC, priv->ibwc); in ipoib_drain_cq()
815 ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP); in ipoib_ib_dev_stop()
HDipoib_ethtool.c87 ret = ib_modify_cq(priv->recv_cq, coal->rx_max_coalesced_frames, in ipoib_set_coalesce()
HDipoib_cm.c211 .send_cq = priv->recv_cq, /* For drain WR */ in ipoib_cm_create_rx_qp()
212 .recv_cq = priv->recv_cq, in ipoib_cm_create_rx_qp()
914 .recv_cq = priv->recv_cq, in ipoib_cm_create_tx_qp()
HDipoib.h349 struct ib_cq *recv_cq; member
/NextBSD/contrib/ofed/libmlx4/src/
HDverbs.c601 mlx4_cq_clean(to_mcq(qp->recv_cq), qp->qp_num, in mlx4_modify_qp()
603 if (qp->send_cq != qp->recv_cq) in mlx4_modify_qp()
617 struct mlx4_cq *recv_cq = to_mcq(qp->recv_cq); in mlx4_lock_cqs() local
619 if (send_cq == recv_cq) in mlx4_lock_cqs()
621 else if (send_cq->cqn < recv_cq->cqn) { in mlx4_lock_cqs()
623 pthread_spin_lock(&recv_cq->lock); in mlx4_lock_cqs()
625 pthread_spin_lock(&recv_cq->lock); in mlx4_lock_cqs()
633 struct mlx4_cq *recv_cq = to_mcq(qp->recv_cq); in mlx4_unlock_cqs() local
635 if (send_cq == recv_cq) in mlx4_unlock_cqs()
637 else if (send_cq->cqn < recv_cq->cqn) { in mlx4_unlock_cqs()
[all …]
/NextBSD/sys/ofed/drivers/infiniband/hw/mthca/
HDmthca_qp.c765 qp_context->cqn_rcv = cpu_to_be32(to_mcq(ibqp->recv_cq)->cqn); in __mthca_modify_qp()
829 mthca_cq_clean(dev, to_mcq(qp->ibqp.recv_cq), qp->qpn, in __mthca_modify_qp()
831 if (qp->ibqp.send_cq != qp->ibqp.recv_cq) in __mthca_modify_qp()
1154 struct mthca_cq *recv_cq, in mthca_alloc_qp_common() argument
1288 struct mthca_cq *recv_cq, in mthca_alloc_qp() argument
1314 err = mthca_alloc_qp_common(dev, pd, send_cq, recv_cq, in mthca_alloc_qp()
1329 static void mthca_lock_cqs(struct mthca_cq *send_cq, struct mthca_cq *recv_cq) in mthca_lock_cqs() argument
1331 if (send_cq == recv_cq) in mthca_lock_cqs()
1333 else if (send_cq->cqn < recv_cq->cqn) { in mthca_lock_cqs()
1335 spin_lock_nested(&recv_cq->lock, SINGLE_DEPTH_NESTING); in mthca_lock_cqs()
[all …]
HDmthca_dev.h546 struct mthca_cq *recv_cq,
554 struct mthca_cq *recv_cq,
/NextBSD/contrib/ofed/libibverbs/src/
HDcompat-1_0.c78 struct ibv_cq_1_0 *recv_cq; member
124 struct ibv_cq_1_0 *recv_cq; member
777 real_init_attr.recv_cq = qp_init_attr->recv_cq->real_cq; in __ibv_create_qp_1_0()
794 qp->recv_cq = qp_init_attr->recv_cq; in __ibv_create_qp_1_0()
821 init_attr->recv_cq = real_init_attr.recv_cq->cq_context; in __ibv_query_qp_1_0()
HDverbs.c437 qp->recv_cq = qp_init_attr->recv_cq; in __ibv_create_qp()
HDcmd.c634 cmd->recv_cq_handle = attr->recv_cq->handle; in ibv_cmd_create_qp()
753 init_attr->recv_cq = qp->recv_cq; in ibv_cmd_query_qp()
/NextBSD/sys/ofed/drivers/infiniband/hw/mlx4/
HDqp.c1143 static void mlx4_ib_lock_cqs(struct mlx4_ib_cq *send_cq, struct mlx4_ib_cq *recv_cq) in mlx4_ib_lock_cqs() argument
1144 __acquires(&send_cq->lock) __acquires(&recv_cq->lock) in mlx4_ib_lock_cqs()
1146 if (send_cq == recv_cq) { in mlx4_ib_lock_cqs()
1148 __acquire(&recv_cq->lock); in mlx4_ib_lock_cqs()
1149 } else if (send_cq->mcq.cqn < recv_cq->mcq.cqn) { in mlx4_ib_lock_cqs()
1151 spin_lock_nested(&recv_cq->lock, SINGLE_DEPTH_NESTING); in mlx4_ib_lock_cqs()
1153 spin_lock_irq(&recv_cq->lock); in mlx4_ib_lock_cqs()
1158 static void mlx4_ib_unlock_cqs(struct mlx4_ib_cq *send_cq, struct mlx4_ib_cq *recv_cq) in mlx4_ib_unlock_cqs() argument
1159 __releases(&send_cq->lock) __releases(&recv_cq->lock) in mlx4_ib_unlock_cqs()
1161 if (send_cq == recv_cq) { in mlx4_ib_unlock_cqs()
[all …]
/NextBSD/sys/ofed/include/rdma/
HDib_verbs_exp.h77 struct ib_cq *recv_cq; member
/NextBSD/sys/ofed/drivers/infiniband/core/
HDverbs.c470 qp->send_cq = qp->recv_cq = NULL; in ib_create_qp()
487 qp->recv_cq = NULL; in ib_create_qp()
490 qp->recv_cq = qp_init_attr->recv_cq; in ib_create_qp()
491 atomic_inc(&qp_init_attr->recv_cq->usecnt); in ib_create_qp()
995 rcq = qp->recv_cq; in ib_destroy_qp()
HDuverbs_cmd.c1673 attr.recv_cq = rcq; in ib_uverbs_create_qp()
1705 qp->recv_cq = attr.recv_cq; in ib_uverbs_create_qp()
1713 if (attr.recv_cq) in ib_uverbs_create_qp()
1714 atomic_inc(&attr.recv_cq->usecnt); in ib_uverbs_create_qp()
3745 attr.recv_cq = rcq; in ib_uverbs_exp_create_qp()
3818 qp->recv_cq = attr.recv_cq; in ib_uverbs_exp_create_qp()
3826 if (attr.recv_cq) in ib_uverbs_exp_create_qp()
3827 atomic_inc(&attr.recv_cq->usecnt); in ib_uverbs_exp_create_qp()
/NextBSD/contrib/ofed/libmlx4/fixes/
HDxrc_rcv_qp_v2.patch91 + init_attr->recv_cq = init_attr->send_cq = NULL;
/NextBSD/contrib/ofed/libibverbs/fixes/
HDXRC_base_implementation.patch338 cmd->recv_cq_handle = attr->recv_cq->handle;
354 init_attr->recv_cq = qp->recv_cq;
/NextBSD/contrib/ofed/libibverbs/include/infiniband/
HDverbs.h429 struct ibv_cq *recv_cq; member
593 struct ibv_cq *recv_cq; member
/NextBSD/sys/ofed/drivers/infiniband/ulp/sdp/
HDsdp_cma.c111 qp_init_attr.recv_cq = ssk->rx_ring.cq; in sdp_init_qp()
/NextBSD/contrib/ofed/librdmacm/examples/
HDmckey.c160 init_qp_attr.recv_cq = node->cq; in init_node()
HDudaddy.c158 init_qp_attr.recv_cq = node->cq; in init_node()
HDcmatose.c147 init_qp_attr.recv_cq = node->cq[RECV_CQ_INDEX]; in init_node()
/NextBSD/contrib/ofed/libmthca/
HDChangeLog38 the recv_cq of another QP destroyed at the same time. This bug
180 recv_cq to wq_overflow() so we lock the correct CQ. Noticed by

12