/freebsd-9.3-release/sys/ofed/drivers/infiniband/ulp/ipoib/ |
H A D | ipoib_verbs.c | 167 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 D | ipoib_ethtool.c | 88 ret = ib_modify_cq(priv->recv_cq, coal->rx_max_coalesced_frames,
|
H A D | ipoib_ib.c | 388 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 D | ipoib_cm.c | 211 .send_cq = priv->recv_cq, /* For drain WR */ 212 .recv_cq = priv->recv_cq, 914 .recv_cq = priv->recv_cq,
|
H A D | ipoib.h | 345 struct ib_cq *recv_cq; member in struct:ipoib_dev_priv
|
/freebsd-9.3-release/contrib/ofed/libmlx4/src/ |
H A D | verbs.c | 597 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 D | qp.c | 462 if (wq_overflow(&qp->rq, nreq, to_mcq(qp->ibv_qp.recv_cq))) {
|
/freebsd-9.3-release/contrib/ofed/libmthca/src/ |
H A D | verbs.c | 640 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 D | qp.c | 353 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 D | mthca_qp.c | 765 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 D | mthca_dev.h | 546 struct mthca_cq *recv_cq, 554 struct mthca_cq *recv_cq,
|
/freebsd-9.3-release/contrib/ofed/libibverbs/src/ |
H A D | compat-1_0.c | 78 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 D | verbs.c | 437 qp->recv_cq = qp_init_attr->recv_cq;
|
/freebsd-9.3-release/sys/contrib/rdma/ |
H A D | rdma_verbs.c | 285 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 D | ib_verbs.h | 501 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 D | qp.c | 729 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 D | verbs.c | 351 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 D | verbs.h | 429 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 D | mckey.c | 160 init_qp_attr.recv_cq = node->cq;
|
H A D | cmatose.c | 147 init_qp_attr.recv_cq = node->cq[RECV_CQ_INDEX];
|
H A D | udaddy.c | 158 init_qp_attr.recv_cq = node->cq;
|
/freebsd-9.3-release/sys/ofed/drivers/infiniband/ulp/sdp/ |
H A D | sdp_cma.c | 111 qp_init_attr.recv_cq = ssk->rx_ring.cq;
|
/freebsd-9.3-release/contrib/ofed/libibverbs/examples/ |
H A D | rc_pingpong.c | 368 .recv_cq = ctx->cq,
|
H A D | uc_pingpong.c | 353 .recv_cq = ctx->cq,
|
H A D | ud_pingpong.c | 351 .recv_cq = ctx->cq,
|