/linux-4.1.27/drivers/infiniband/hw/amso1100/ |
D | c2_qp.c | 423 struct c2_cq *recv_cq = to_c2cq(qp_attrs->recv_cq); in c2_alloc_qp() local 463 wr.rq_cq_handle = recv_cq->adapter_handle; in c2_alloc_qp() 574 static inline void c2_lock_cqs(struct c2_cq *send_cq, struct c2_cq *recv_cq) in c2_lock_cqs() argument 576 if (send_cq == recv_cq) in c2_lock_cqs() 578 else if (send_cq > recv_cq) { in c2_lock_cqs() 580 spin_lock_nested(&recv_cq->lock, SINGLE_DEPTH_NESTING); in c2_lock_cqs() 582 spin_lock_irq(&recv_cq->lock); in c2_lock_cqs() 587 static inline void c2_unlock_cqs(struct c2_cq *send_cq, struct c2_cq *recv_cq) in c2_unlock_cqs() argument 589 if (send_cq == recv_cq) in c2_unlock_cqs() 591 else if (send_cq > recv_cq) { in c2_unlock_cqs() [all …]
|
/linux-4.1.27/drivers/infiniband/ulp/ipoib/ |
D | ipoib_verbs.c | 182 priv->recv_cq = ib_create_cq(priv->ca, ipoib_ib_completion, NULL, dev, size, 0); in ipoib_transport_dev_init() 183 if (IS_ERR(priv->recv_cq)) { in ipoib_transport_dev_init() 195 if (ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP)) in ipoib_transport_dev_init() 199 init_attr.recv_cq = priv->recv_cq; in ipoib_transport_dev_init() 244 ib_destroy_cq(priv->recv_cq); in ipoib_transport_dev_init() 277 if (ib_destroy_cq(priv->recv_cq)) in ipoib_transport_dev_cleanup()
|
D | ipoib_ethtool.c | 87 ret = ib_modify_cq(priv->recv_cq, coal->rx_max_coalesced_frames, in ipoib_set_coalesce()
|
D | ipoib_ib.c | 450 n = ib_poll_cq(priv->recv_cq, t, priv->ibwc); in ipoib_poll() 471 if (unlikely(ib_req_notify_cq(priv->recv_cq, in ipoib_poll() 809 n = ib_poll_cq(priv->recv_cq, IPOIB_NUM_WC, priv->ibwc); in ipoib_drain_cq() 907 ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP); in ipoib_ib_dev_stop()
|
D | ipoib_cm.c | 254 .send_cq = priv->recv_cq, /* For drain WR */ in ipoib_cm_create_rx_qp() 255 .recv_cq = priv->recv_cq, in ipoib_cm_create_rx_qp() 1026 .send_cq = priv->recv_cq, in ipoib_cm_create_tx_qp() 1027 .recv_cq = priv->recv_cq, in ipoib_cm_create_tx_qp()
|
D | ipoib.h | 346 struct ib_cq *recv_cq; member
|
/linux-4.1.27/drivers/infiniband/hw/mlx5/ |
D | qp.c | 970 rcqe_sz = mlx5_ib_get_cqe_size(dev, init_attr->recv_cq); in create_qp_common() 1024 if (init_attr->recv_cq) in create_qp_common() 1025 in->ctx.cqn_recv = cpu_to_be32(to_mcq(init_attr->recv_cq)->mcq.cqn); in create_qp_common() 1056 static void mlx5_ib_lock_cqs(struct mlx5_ib_cq *send_cq, struct mlx5_ib_cq *recv_cq) in mlx5_ib_lock_cqs() argument 1057 __acquires(&send_cq->lock) __acquires(&recv_cq->lock) in mlx5_ib_lock_cqs() 1060 if (recv_cq) { in mlx5_ib_lock_cqs() 1061 if (send_cq->mcq.cqn < recv_cq->mcq.cqn) { in mlx5_ib_lock_cqs() 1063 spin_lock_nested(&recv_cq->lock, in mlx5_ib_lock_cqs() 1065 } else if (send_cq->mcq.cqn == recv_cq->mcq.cqn) { in mlx5_ib_lock_cqs() 1067 __acquire(&recv_cq->lock); in mlx5_ib_lock_cqs() [all …]
|
D | main.c | 1007 init_attr->recv_cq = cq; in create_umr_res()
|
/linux-4.1.27/drivers/infiniband/hw/mthca/ |
D | mthca_qp.c | 758 qp_context->cqn_rcv = cpu_to_be32(to_mcq(ibqp->recv_cq)->cqn); in __mthca_modify_qp() 819 mthca_cq_clean(dev, to_mcq(qp->ibqp.recv_cq), qp->qpn, in __mthca_modify_qp() 821 if (qp->ibqp.send_cq != qp->ibqp.recv_cq) in __mthca_modify_qp() 1144 struct mthca_cq *recv_cq, in mthca_alloc_qp_common() argument 1272 struct mthca_cq *recv_cq, in mthca_alloc_qp() argument 1298 err = mthca_alloc_qp_common(dev, pd, send_cq, recv_cq, in mthca_alloc_qp() 1313 static void mthca_lock_cqs(struct mthca_cq *send_cq, struct mthca_cq *recv_cq) in mthca_lock_cqs() argument 1314 __acquires(&send_cq->lock) __acquires(&recv_cq->lock) in mthca_lock_cqs() 1316 if (send_cq == recv_cq) { in mthca_lock_cqs() 1318 __acquire(&recv_cq->lock); in mthca_lock_cqs() [all …]
|
D | mthca_dev.h | 546 struct mthca_cq *recv_cq, 554 struct mthca_cq *recv_cq,
|
D | mthca_provider.c | 567 to_mcq(init_attr->recv_cq), in mthca_create_qp() 602 to_mcq(init_attr->recv_cq), in mthca_create_qp()
|
/linux-4.1.27/net/rds/ |
D | iw_cm.c | 211 attr->recv_cq = ib_create_cq(dev, recv_cq_handler, in rds_iw_init_qp_attrs() 214 if (IS_ERR(attr->recv_cq)) { in rds_iw_init_qp_attrs() 215 ret = PTR_ERR(attr->recv_cq); in rds_iw_init_qp_attrs() 216 attr->recv_cq = NULL; in rds_iw_init_qp_attrs() 227 ret = ib_req_notify_cq(attr->recv_cq, IB_CQ_SOLICITED); in rds_iw_init_qp_attrs() 237 if (attr->recv_cq) in rds_iw_init_qp_attrs() 238 ib_destroy_cq(attr->recv_cq); in rds_iw_init_qp_attrs() 279 ic->i_recv_cq = attr.recv_cq; in rds_iw_setup_qp()
|
D | ib_cm.c | 347 attr.recv_cq = ic->i_recv_cq; in rds_ib_setup_qp()
|
/linux-4.1.27/drivers/infiniband/hw/mlx4/ |
D | qp.c | 50 struct mlx4_ib_cq *recv_cq); 52 struct mlx4_ib_cq *recv_cq); 845 to_mcq(init_attr->recv_cq)); in create_qp_common() 855 mcq = to_mcq(init_attr->recv_cq); in create_qp_common() 858 to_mcq(init_attr->recv_cq)); in create_qp_common() 914 static void mlx4_ib_lock_cqs(struct mlx4_ib_cq *send_cq, struct mlx4_ib_cq *recv_cq) in mlx4_ib_lock_cqs() argument 915 __acquires(&send_cq->lock) __acquires(&recv_cq->lock) in mlx4_ib_lock_cqs() 917 if (send_cq == recv_cq) { in mlx4_ib_lock_cqs() 919 __acquire(&recv_cq->lock); in mlx4_ib_lock_cqs() 920 } else if (send_cq->mcq.cqn < recv_cq->mcq.cqn) { in mlx4_ib_lock_cqs() [all …]
|
D | main.c | 2663 recv_mcq = to_mcq(mqp->ibqp.recv_cq); in mlx4_ib_handle_catas_error() 2666 mqp->ibqp.recv_cq->comp_handler) { in mlx4_ib_handle_catas_error()
|
D | mad.c | 1602 qp_init_attr.init_attr.recv_cq = ctx->cq; in create_pv_sqp()
|
/linux-4.1.27/drivers/infiniband/hw/ehca/ |
D | ehca_qp.c | 412 list = &qp->recv_cq->rqp_err_list; in ehca_add_to_err_list() 632 if (init_attr->recv_cq) in internal_create_qp() 633 my_qp->recv_cq = in internal_create_qp() 634 container_of(init_attr->recv_cq, struct ehca_cq, ib_cq); in internal_create_qp() 685 if (my_qp->recv_cq) in internal_create_qp() 686 parms.recv_cq_handle = my_qp->recv_cq->ipz_cq_handle; in internal_create_qp() 828 my_qp->ib_qp.recv_cq = init_attr->recv_cq; in internal_create_qp() 1193 spin_lock_irqsave(&my_qp->recv_cq->spinlock, flags); in check_for_left_cqes() 1196 spin_unlock_irqrestore(&my_qp->recv_cq->spinlock, flags); in check_for_left_cqes() 1206 spin_lock_irqsave(&my_qp->recv_cq->spinlock, flags); in check_for_left_cqes() [all …]
|
D | ehca_classes.h | 208 struct ehca_cq *recv_cq; member
|
D | ehca_main.c | 559 qp_init_attr.recv_cq = ibcq; in ehca_create_aqp1()
|
/linux-4.1.27/drivers/infiniband/ulp/srp/ |
D | ib_srp.h | 146 struct ib_cq *recv_cq; member
|
D | ib_srp.c | 496 struct ib_cq *recv_cq, *send_cq; in srp_create_ch_ib() local 508 recv_cq = ib_create_cq(dev->dev, srp_recv_completion, NULL, ch, in srp_create_ch_ib() 510 if (IS_ERR(recv_cq)) { in srp_create_ch_ib() 511 ret = PTR_ERR(recv_cq); in srp_create_ch_ib() 522 ib_req_notify_cq(recv_cq, IB_CQ_NEXT_COMP); in srp_create_ch_ib() 532 init_attr->recv_cq = recv_cq; in srp_create_ch_ib() 570 if (ch->recv_cq) in srp_create_ch_ib() 571 ib_destroy_cq(ch->recv_cq); in srp_create_ch_ib() 576 ch->recv_cq = recv_cq; in srp_create_ch_ib() 589 ib_destroy_cq(recv_cq); in srp_create_ch_ib() [all …]
|
/linux-4.1.27/drivers/infiniband/core/ |
D | verbs.c | 462 qp->send_cq = qp->recv_cq = NULL; in ib_create_qp() 479 qp->recv_cq = NULL; in ib_create_qp() 482 qp->recv_cq = qp_init_attr->recv_cq; in ib_create_qp() 483 atomic_inc(&qp_init_attr->recv_cq->usecnt); in ib_create_qp() 991 rcq = qp->recv_cq; in ib_destroy_qp()
|
D | uverbs_cmd.c | 1702 attr.recv_cq = rcq; in ib_uverbs_create_qp() 1734 qp->recv_cq = attr.recv_cq; in ib_uverbs_create_qp() 1742 if (attr.recv_cq) in ib_uverbs_create_qp() 1743 atomic_inc(&attr.recv_cq->usecnt); in ib_uverbs_create_qp()
|
D | mad.c | 2877 qp_init_attr.recv_cq = qp_info->port_priv->cq; in create_mad_qp()
|
/linux-4.1.27/drivers/infiniband/hw/ipath/ |
D | ipath_qp.c | 406 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, 1); in ipath_error_qp() 429 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, 1); in ipath_error_qp() 659 init_attr->recv_cq = qp->ibqp.recv_cq; in ipath_query_qp()
|
D | ipath_ud.c | 227 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in ipath_ud_loopback() 575 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in ipath_ud_rcv()
|
D | ipath_ruc.c | 151 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, 1); in ipath_init_sge() 445 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in ipath_ruc_loopback()
|
D | ipath_uc.c | 420 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in ipath_uc_rcv()
|
D | ipath_rc.c | 1745 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in ipath_rc_rcv()
|
/linux-4.1.27/drivers/infiniband/hw/qib/ |
D | qib_ud.c | 219 qib_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in qib_ud_loopback() 583 qib_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in qib_ud_rcv()
|
D | qib_qp.c | 525 qib_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, 1); in qib_error_qp() 548 qib_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, 1); in qib_error_qp() 893 init_attr->recv_cq = qp->ibqp.recv_cq; in qib_query_qp()
|
D | qib_ruc.c | 122 qib_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, 1); in qib_init_sge() 563 qib_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in qib_ruc_loopback()
|
D | qib_uc.c | 417 qib_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in qib_uc_rcv()
|
D | qib_rc.c | 2048 qib_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in qib_rc_rcv()
|
/linux-4.1.27/net/sunrpc/xprtrdma/ |
D | verbs.c | 381 while (ib_poll_cq(ep->rep_attr.recv_cq, 1, &wc) > 0) in rpcrdma_flush_cqs() 810 ep->rep_attr.recv_cq = recvcq; in rpcrdma_ep_create() 867 rpcrdma_clean_cq(ep->rep_attr.recv_cq); in rpcrdma_ep_destroy() 868 rc = ib_destroy_cq(ep->rep_attr.recv_cq); in rpcrdma_ep_destroy()
|
D | svc_rdma_transport.c | 934 qp_attr.recv_cq = newxprt->sc_rq_cq; in svc_rdma_accept()
|
/linux-4.1.27/drivers/net/ethernet/ibm/ehea/ |
D | ehea_main.c | 211 arr[i++].fwh = pr->recv_cq->fw_handle; in ehea_update_firmware_handles() 904 ehea_reset_cq_ep(pr->recv_cq); in ehea_poll() 906 ehea_reset_cq_n1(pr->recv_cq); in ehea_poll() 1493 pr->recv_cq = ehea_create_cq(adapter, pr_cfg->max_entries_rcq, in ehea_init_port_res() 1496 if (!pr->recv_cq) { in ehea_init_port_res() 1512 pr->recv_cq->attr.act_nr_of_cqes); in ehea_init_port_res() 1537 init_attr->recv_cq_handle = pr->recv_cq->fw_handle; in ehea_init_port_res() 1587 ehea_destroy_cq(pr->recv_cq); in ehea_init_port_res() 1604 ehea_destroy_cq(pr->recv_cq); in ehea_clean_portres()
|
D | ehea.h | 365 struct ehea_cq *recv_cq; member
|
/linux-4.1.27/net/9p/ |
D | trans_rdma.c | 742 qp_attr.recv_cq = rdma->cq; in rdma_create_trans()
|
/linux-4.1.27/include/rdma/ |
D | ib_verbs.h | 822 struct ib_cq *recv_cq; member 1250 struct ib_cq *recv_cq; member
|
/linux-4.1.27/drivers/infiniband/hw/cxgb4/ |
D | qp.c | 1168 rchp = to_c4iw_cq(qhp->ibqp.recv_cq); in flush_qp() 1630 rchp = get_chp(rhp, ((struct c4iw_cq *)attrs->recv_cq)->cq.cqid); in c4iw_create_qp() 1681 qhp->attr.rcq = ((struct c4iw_cq *) attrs->recv_cq)->cq.cqid; in c4iw_create_qp()
|
/linux-4.1.27/drivers/infiniband/hw/usnic/ |
D | usnic_ib_verbs.c | 494 cq_cnt = (init_attr->send_cq == init_attr->recv_cq) ? 1 : 2; in usnic_ib_create_qp()
|
/linux-4.1.27/drivers/infiniband/hw/cxgb3/ |
D | iwch_provider.c | 907 rchp = get_chp(rhp, ((struct iwch_cq *) attrs->recv_cq)->cq.cqid); in iwch_create_qp() 963 qhp->attr.rcq = ((struct iwch_cq *) attrs->recv_cq)->cq.cqid; in iwch_create_qp()
|
/linux-4.1.27/drivers/infiniband/ulp/iser/ |
D | iser_verbs.c | 479 init_attr.recv_cq = ib_conn->comp->cq; in iser_create_ib_conn_res()
|
/linux-4.1.27/drivers/infiniband/hw/nes/ |
D | nes_verbs.c | 1270 nescq = to_nescq(init_attr->recv_cq); in nes_create_qp() 2838 init_attr->recv_cq = nesqp->ibqp.recv_cq; in nes_query_qp()
|
/linux-4.1.27/drivers/infiniband/hw/ocrdma/ |
D | ocrdma_verbs.c | 1205 (dev->gsi_rqcq == get_ocrdma_cq(attrs->recv_cq))) { in ocrdma_check_qp_params() 1332 dev->gsi_rqcq = get_ocrdma_cq(attrs->recv_cq); in ocrdma_store_gsi_qp_cq()
|
D | ocrdma_hw.c | 2376 cq = get_ocrdma_cq(attrs->recv_cq); in ocrdma_mbx_create_qp()
|
/linux-4.1.27/drivers/infiniband/ulp/isert/ |
D | ib_isert.c | 155 attr.recv_cq = comp->cq; in isert_create_qp() 813 struct isert_comp *comp = isert_conn->qp->recv_cq->cq_context; in isert_connect_release()
|
/linux-4.1.27/drivers/staging/lustre/lnet/klnds/o2iblnd/ |
D | o2iblnd.c | 772 init_qp_attr->recv_cq = cq; in kiblnd_create_conn()
|
/linux-4.1.27/drivers/infiniband/ulp/srpt/ |
D | ib_srpt.c | 2049 qp_init->recv_cq = ch->cq; in srpt_create_ch_ib()
|