Home
last modified time | relevance | path

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

/linux-4.4.14/drivers/staging/rdma/amso1100/
Dc2_qp.c423 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.4.14/drivers/infiniband/ulp/ipoib/
Dipoib_verbs.c178 priv->recv_cq = ib_create_cq(priv->ca, ipoib_ib_completion, NULL, in ipoib_transport_dev_init()
180 if (IS_ERR(priv->recv_cq)) { in ipoib_transport_dev_init()
193 if (ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP)) in ipoib_transport_dev_init()
197 init_attr.recv_cq = priv->recv_cq; in ipoib_transport_dev_init()
242 ib_destroy_cq(priv->recv_cq); in ipoib_transport_dev_init()
272 if (ib_destroy_cq(priv->recv_cq)) in ipoib_transport_dev_cleanup()
Dipoib_ethtool.c87 ret = ib_modify_cq(priv->recv_cq, coal->rx_max_coalesced_frames, in ipoib_set_coalesce()
Dipoib_ib.c450 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()
795 n = ib_poll_cq(priv->recv_cq, IPOIB_NUM_WC, priv->ibwc); in ipoib_drain_cq()
893 ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP); in ipoib_ib_dev_stop()
Dipoib_cm.c254 .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()
1020 .send_cq = priv->recv_cq, in ipoib_cm_create_tx_qp()
1021 .recv_cq = priv->recv_cq, in ipoib_cm_create_tx_qp()
Dipoib.h345 struct ib_cq *recv_cq; member
/linux-4.4.14/drivers/infiniband/hw/mlx5/
Dqp.c961 rcqe_sz = mlx5_ib_get_cqe_size(dev, init_attr->recv_cq); in create_qp_common()
1016 if (init_attr->recv_cq) in create_qp_common()
1017 in->ctx.cqn_recv = cpu_to_be32(to_mcq(init_attr->recv_cq)->mcq.cqn); in create_qp_common()
1048 static void mlx5_ib_lock_cqs(struct mlx5_ib_cq *send_cq, struct mlx5_ib_cq *recv_cq) in mlx5_ib_lock_cqs() argument
1049 __acquires(&send_cq->lock) __acquires(&recv_cq->lock) in mlx5_ib_lock_cqs()
1052 if (recv_cq) { in mlx5_ib_lock_cqs()
1053 if (send_cq->mcq.cqn < recv_cq->mcq.cqn) { in mlx5_ib_lock_cqs()
1055 spin_lock_nested(&recv_cq->lock, in mlx5_ib_lock_cqs()
1057 } else if (send_cq->mcq.cqn == recv_cq->mcq.cqn) { in mlx5_ib_lock_cqs()
1059 __acquire(&recv_cq->lock); in mlx5_ib_lock_cqs()
[all …]
Dmain.c1110 init_attr->recv_cq = cq; in create_umr_res()
/linux-4.4.14/drivers/infiniband/hw/mthca/
Dmthca_qp.c758 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 …]
Dmthca_dev.h546 struct mthca_cq *recv_cq,
554 struct mthca_cq *recv_cq,
Dmthca_provider.c571 to_mcq(init_attr->recv_cq), in mthca_create_qp()
606 to_mcq(init_attr->recv_cq), in mthca_create_qp()
/linux-4.4.14/net/rds/
Diw_cm.c214 attr->recv_cq = ib_create_cq(dev, recv_cq_handler, in rds_iw_init_qp_attrs()
217 if (IS_ERR(attr->recv_cq)) { in rds_iw_init_qp_attrs()
218 ret = PTR_ERR(attr->recv_cq); in rds_iw_init_qp_attrs()
219 attr->recv_cq = NULL; in rds_iw_init_qp_attrs()
230 ret = ib_req_notify_cq(attr->recv_cq, IB_CQ_SOLICITED); in rds_iw_init_qp_attrs()
240 if (attr->recv_cq) in rds_iw_init_qp_attrs()
241 ib_destroy_cq(attr->recv_cq); in rds_iw_init_qp_attrs()
282 ic->i_recv_cq = attr.recv_cq; in rds_iw_setup_qp()
Dib_cm.c422 attr.recv_cq = ic->i_recv_cq; in rds_ib_setup_qp()
/linux-4.4.14/drivers/infiniband/hw/mlx4/
Dqp.c51 struct mlx4_ib_cq *recv_cq);
53 struct mlx4_ib_cq *recv_cq);
864 to_mcq(init_attr->recv_cq)); in create_qp_common()
874 mcq = to_mcq(init_attr->recv_cq); in create_qp_common()
877 to_mcq(init_attr->recv_cq)); in create_qp_common()
933 static void mlx4_ib_lock_cqs(struct mlx4_ib_cq *send_cq, struct mlx4_ib_cq *recv_cq) in mlx4_ib_lock_cqs() argument
934 __acquires(&send_cq->lock) __acquires(&recv_cq->lock) in mlx4_ib_lock_cqs()
936 if (send_cq == recv_cq) { in mlx4_ib_lock_cqs()
938 __acquire(&recv_cq->lock); in mlx4_ib_lock_cqs()
939 } else if (send_cq->mcq.cqn < recv_cq->mcq.cqn) { in mlx4_ib_lock_cqs()
[all …]
Dmain.c2691 recv_mcq = to_mcq(mqp->ibqp.recv_cq); in mlx4_ib_handle_catas_error()
2694 mqp->ibqp.recv_cq->comp_handler) { in mlx4_ib_handle_catas_error()
Dmad.c1628 qp_init_attr.init_attr.recv_cq = ctx->cq; in create_pv_sqp()
/linux-4.4.14/drivers/staging/rdma/ehca/
Dehca_qp.c412 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 …]
Dehca_classes.h208 struct ehca_cq *recv_cq; member
Dehca_main.c582 qp_init_attr.recv_cq = ibcq; in ehca_create_aqp1()
/linux-4.4.14/drivers/infiniband/core/
Dverbs.c621 qp->send_cq = qp->recv_cq = NULL; in ib_create_qp()
638 qp->recv_cq = NULL; in ib_create_qp()
641 qp->recv_cq = qp_init_attr->recv_cq; in ib_create_qp()
642 atomic_inc(&qp_init_attr->recv_cq->usecnt); in ib_create_qp()
1133 rcq = qp->recv_cq; in ib_destroy_qp()
Duverbs_cmd.c1826 attr.recv_cq = rcq; in create_qp()
1876 qp->recv_cq = attr.recv_cq; in create_qp()
1884 if (attr.recv_cq) in create_qp()
1885 atomic_inc(&attr.recv_cq->usecnt); in create_qp()
Dmad.c3106 qp_init_attr.recv_cq = qp_info->port_priv->cq; in create_mad_qp()
/linux-4.4.14/drivers/infiniband/ulp/srp/
Dib_srp.h146 struct ib_cq *recv_cq; member
Dib_srp.c487 struct ib_cq *recv_cq, *send_cq; in srp_create_ch_ib() local
502 recv_cq = ib_create_cq(dev->dev, srp_recv_completion, NULL, ch, in srp_create_ch_ib()
504 if (IS_ERR(recv_cq)) { in srp_create_ch_ib()
505 ret = PTR_ERR(recv_cq); in srp_create_ch_ib()
518 ib_req_notify_cq(recv_cq, IB_CQ_NEXT_COMP); in srp_create_ch_ib()
528 init_attr->recv_cq = recv_cq; in srp_create_ch_ib()
560 if (ch->recv_cq) in srp_create_ch_ib()
561 ib_destroy_cq(ch->recv_cq); in srp_create_ch_ib()
566 ch->recv_cq = recv_cq; in srp_create_ch_ib()
589 ib_destroy_cq(recv_cq); in srp_create_ch_ib()
[all …]
/linux-4.4.14/drivers/staging/rdma/ipath/
Dipath_qp.c405 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, 1); in ipath_error_qp()
428 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, 1); in ipath_error_qp()
658 init_attr->recv_cq = qp->ibqp.recv_cq; in ipath_query_qp()
Dipath_ud.c226 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in ipath_ud_loopback()
574 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in ipath_ud_rcv()
Dipath_ruc.c150 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, 1); in ipath_init_sge()
444 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in ipath_ruc_loopback()
Dipath_uc.c420 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in ipath_uc_rcv()
Dipath_rc.c1745 ipath_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in ipath_rc_rcv()
/linux-4.4.14/net/sunrpc/xprtrdma/
Dverbs.c269 while (ib_poll_cq(ep->rep_attr.recv_cq, 1, &wc) > 0) in rpcrdma_flush_cqs()
663 ep->rep_attr.recv_cq = recvcq; in rpcrdma_ep_create()
716 rpcrdma_clean_cq(ep->rep_attr.recv_cq); in rpcrdma_ep_destroy()
724 rc = ib_destroy_cq(ep->rep_attr.recv_cq); in rpcrdma_ep_destroy()
Dsvc_rdma_transport.c973 qp_attr.recv_cq = newxprt->sc_rq_cq; in svc_rdma_accept()
/linux-4.4.14/drivers/infiniband/hw/qib/
Dqib_ud.c219 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()
Dqib_qp.c525 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()
Dqib_ruc.c123 qib_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, 1); in qib_init_sge()
564 qib_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in qib_ruc_loopback()
Dqib_uc.c417 qib_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in qib_uc_rcv()
Dqib_rc.c2050 qib_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in qib_rc_rcv()
/linux-4.4.14/drivers/net/ethernet/ibm/ehea/
Dehea_main.c211 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()
Dehea.h365 struct ehea_cq *recv_cq; member
/linux-4.4.14/drivers/staging/rdma/hfi1/
Dqp.c509 hfi1_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, 1); in hfi1_error_qp()
532 hfi1_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, 1); in hfi1_error_qp()
929 init_attr->recv_cq = qp->ibqp.recv_cq; in hfi1_query_qp()
Dud.c251 hfi1_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in ud_loopback()
878 hfi1_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in hfi1_ud_rcv()
Druc.c141 hfi1_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, 1); in init_sge()
586 hfi1_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in ruc_loopback()
Duc.c468 hfi1_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in hfi1_uc_rcv()
Drc.c2140 hfi1_cq_enter(to_icq(qp->ibqp.recv_cq), &wc, in hfi1_rc_rcv()
/linux-4.4.14/net/9p/
Dtrans_rdma.c722 qp_attr.recv_cq = rdma->cq; in rdma_create_trans()
/linux-4.4.14/drivers/infiniband/hw/cxgb4/
Dqp.c1181 rchp = to_c4iw_cq(qhp->ibqp.recv_cq); in flush_qp()
1643 rchp = get_chp(rhp, ((struct c4iw_cq *)attrs->recv_cq)->cq.cqid); in c4iw_create_qp()
1694 qhp->attr.rcq = ((struct c4iw_cq *) attrs->recv_cq)->cq.cqid; in c4iw_create_qp()
/linux-4.4.14/drivers/infiniband/hw/usnic/
Dusnic_ib_verbs.c513 cq_cnt = (init_attr->send_cq == init_attr->recv_cq) ? 1 : 2; in usnic_ib_create_qp()
/linux-4.4.14/include/rdma/
Dib_verbs.h886 struct ib_cq *recv_cq; member
1342 struct ib_cq *recv_cq; member
/linux-4.4.14/drivers/infiniband/hw/cxgb3/
Diwch_provider.c936 rchp = get_chp(rhp, ((struct iwch_cq *) attrs->recv_cq)->cq.cqid); in iwch_create_qp()
992 qhp->attr.rcq = ((struct iwch_cq *) attrs->recv_cq)->cq.cqid; in iwch_create_qp()
/linux-4.4.14/drivers/infiniband/ulp/iser/
Diser_verbs.c494 init_attr.recv_cq = ib_conn->comp->cq; in iser_create_ib_conn_res()
/linux-4.4.14/drivers/infiniband/hw/nes/
Dnes_verbs.c1250 nescq = to_nescq(init_attr->recv_cq); in nes_create_qp()
2830 init_attr->recv_cq = nesqp->ibqp.recv_cq; in nes_query_qp()
/linux-4.4.14/drivers/infiniband/ulp/isert/
Dib_isert.c158 attr.recv_cq = comp->cq; in isert_create_qp()
766 struct isert_comp *comp = isert_conn->qp->recv_cq->cq_context; in isert_connect_release()
/linux-4.4.14/drivers/infiniband/hw/ocrdma/
Docrdma_verbs.c1276 (dev->gsi_rqcq == get_ocrdma_cq(attrs->recv_cq))) { in ocrdma_check_qp_params()
1403 dev->gsi_rqcq = get_ocrdma_cq(attrs->recv_cq); in ocrdma_store_gsi_qp_cq()
Docrdma_hw.c2442 cq = get_ocrdma_cq(attrs->recv_cq); in ocrdma_mbx_create_qp()
/linux-4.4.14/drivers/staging/lustre/lnet/klnds/o2iblnd/
Do2iblnd.c775 init_qp_attr->recv_cq = cq; in kiblnd_create_conn()
/linux-4.4.14/drivers/infiniband/ulp/srpt/
Dib_srpt.c2046 qp_init->recv_cq = ch->cq; in srpt_create_ch_ib()