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

12

/freebsd-9.3-release/sys/ofed/drivers/infiniband/ulp/ipoib/
H A Dipoib_verbs.c167 priv->recv_cq = ib_create_cq(priv->ca, ipoib_ib_completion, NULL, priv, size, 0);
168 if (IS_ERR(priv->recv_cq)) {
180 if (ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP))
197 init_attr.recv_cq = priv->recv_cq;
235 ib_destroy_cq(priv->recv_cq);
260 if (ib_destroy_cq(priv->recv_cq))
H A Dipoib_ethtool.c88 ret = ib_modify_cq(priv->recv_cq, coal->rx_max_coalesced_frames,
H A Dipoib_ib.c388 n = ib_poll_cq(priv->recv_cq, IPOIB_NUM_WC, priv->ibwc);
406 if (ib_req_notify_cq(priv->recv_cq,
712 n = ib_poll_cq(priv->recv_cq, IPOIB_NUM_WC, priv->ibwc);
812 ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP);
H A Dipoib_cm.c211 .send_cq = priv->recv_cq, /* For drain WR */
212 .recv_cq = priv->recv_cq,
914 .recv_cq = priv->recv_cq,
H A Dipoib.h345 struct ib_cq *recv_cq; member in struct:ipoib_dev_priv
/freebsd-9.3-release/contrib/ofed/libmlx4/src/
H A Dverbs.c597 mlx4_cq_clean(to_mcq(qp->recv_cq), qp->qp_num,
599 if (qp->send_cq != qp->recv_cq)
613 struct mlx4_cq *recv_cq = to_mcq(qp->recv_cq); local
615 if (send_cq == recv_cq)
617 else if (send_cq->cqn < recv_cq->cqn) {
619 pthread_spin_lock(&recv_cq->lock);
621 pthread_spin_lock(&recv_cq->lock);
629 struct mlx4_cq *recv_cq = to_mcq(qp->recv_cq); local
[all...]
H A Dqp.c462 if (wq_overflow(&qp->rq, nreq, to_mcq(qp->ibv_qp.recv_cq))) {
/freebsd-9.3-release/contrib/ofed/libmthca/src/
H A Dverbs.c640 mthca_cq_clean(to_mcq(qp->recv_cq), qp->qp_num,
642 if (qp->send_cq != qp->recv_cq)
659 struct mthca_cq *recv_cq = to_mcq(qp->recv_cq); local
661 if (send_cq == recv_cq)
663 else if (send_cq->cqn < recv_cq->cqn) {
665 pthread_spin_lock(&recv_cq->lock);
667 pthread_spin_lock(&recv_cq->lock);
675 struct mthca_cq *recv_cq = to_mcq(qp->recv_cq); local
[all...]
H A Dqp.c353 if (wq_overflow(&qp->rq, nreq, to_mcq(qp->ibv_qp.recv_cq))) {
724 if (wq_overflow(&qp->rq, nreq, to_mcq(qp->ibv_qp.recv_cq))) {
/freebsd-9.3-release/sys/ofed/drivers/infiniband/hw/mthca/
H A Dmthca_qp.c765 qp_context->cqn_rcv = cpu_to_be32(to_mcq(ibqp->recv_cq)->cqn);
829 mthca_cq_clean(dev, to_mcq(qp->ibqp.recv_cq), qp->qpn,
831 if (qp->ibqp.send_cq != qp->ibqp.recv_cq)
1153 struct mthca_cq *recv_cq,
1287 struct mthca_cq *recv_cq,
1313 err = mthca_alloc_qp_common(dev, pd, send_cq, recv_cq,
1328 static void mthca_lock_cqs(struct mthca_cq *send_cq, struct mthca_cq *recv_cq) argument
1330 if (send_cq == recv_cq)
1332 else if (send_cq->cqn < recv_cq->cqn) {
1334 spin_lock_nested(&recv_cq
1150 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
1284 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
1341 mthca_unlock_cqs(struct mthca_cq *send_cq, struct mthca_cq *recv_cq) argument
1354 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
1437 struct mthca_cq *recv_cq; local
[all...]
H A Dmthca_dev.h546 struct mthca_cq *recv_cq,
554 struct mthca_cq *recv_cq,
/freebsd-9.3-release/contrib/ofed/libibverbs/src/
H A Dcompat-1_0.c78 struct ibv_cq_1_0 *recv_cq; member in struct:ibv_qp_init_attr_1_0
124 struct ibv_cq_1_0 *recv_cq; member in struct:ibv_qp_1_0
777 real_init_attr.recv_cq = qp_init_attr->recv_cq->real_cq;
794 qp->recv_cq = qp_init_attr->recv_cq;
821 init_attr->recv_cq = real_init_attr.recv_cq->cq_context;
H A Dverbs.c437 qp->recv_cq = qp_init_attr->recv_cq;
/freebsd-9.3-release/sys/contrib/rdma/
H A Drdma_verbs.c285 qp->recv_cq = qp_init_attr->recv_cq;
293 atomic_add_acq_int(&qp_init_attr->recv_cq->usecnt, 1);
578 rcq = qp->recv_cq;
H A Dib_verbs.h501 struct ib_cq *recv_cq; member in struct:ib_qp_init_attr
790 struct ib_cq *recv_cq; member in struct:ib_qp
/freebsd-9.3-release/sys/ofed/drivers/infiniband/hw/mlx4/
H A Dqp.c729 static void mlx4_ib_lock_cqs(struct mlx4_ib_cq *send_cq, struct mlx4_ib_cq *recv_cq) argument
731 if (send_cq == recv_cq)
733 else if (send_cq->mcq.cqn < recv_cq->mcq.cqn) {
735 spin_lock_nested(&recv_cq->lock, SINGLE_DEPTH_NESTING);
737 spin_lock_irq(&recv_cq->lock);
742 static void mlx4_ib_unlock_cqs(struct mlx4_ib_cq *send_cq, struct mlx4_ib_cq *recv_cq) argument
744 if (send_cq == recv_cq)
746 else if (send_cq->mcq.cqn < recv_cq->mcq.cqn) {
747 spin_unlock(&recv_cq->lock);
751 spin_unlock_irq(&recv_cq
768 struct mlx4_ib_cq *send_cq, *recv_cq; local
[all...]
/freebsd-9.3-release/sys/ofed/drivers/infiniband/core/
H A Dverbs.c351 qp->recv_cq = qp_init_attr->recv_cq;
361 atomic_inc(&qp_init_attr->recv_cq->usecnt);
702 rcq = qp->recv_cq;
/freebsd-9.3-release/contrib/ofed/libibverbs/include/infiniband/
H A Dverbs.h429 struct ibv_cq *recv_cq; member in struct:ibv_qp_init_attr
593 struct ibv_cq *recv_cq; member in struct:ibv_qp
/freebsd-9.3-release/contrib/ofed/librdmacm/examples/
H A Dmckey.c160 init_qp_attr.recv_cq = node->cq;
H A Dcmatose.c147 init_qp_attr.recv_cq = node->cq[RECV_CQ_INDEX];
H A Dudaddy.c158 init_qp_attr.recv_cq = node->cq;
/freebsd-9.3-release/sys/ofed/drivers/infiniband/ulp/sdp/
H A Dsdp_cma.c111 qp_init_attr.recv_cq = ssk->rx_ring.cq;
/freebsd-9.3-release/contrib/ofed/libibverbs/examples/
H A Drc_pingpong.c368 .recv_cq = ctx->cq,
H A Duc_pingpong.c353 .recv_cq = ctx->cq,
H A Dud_pingpong.c351 .recv_cq = ctx->cq,

Completed in 303 milliseconds

12