Home
last modified time | relevance | path

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

123

/linux-6.15/drivers/infiniband/hw/hns/
H A Dhns_roce_qp.c290 hr_recv_cq = recv_cq ? to_hr_cq(recv_cq) : NULL; in add_qp_to_list()
321 init_attr->recv_cq); in hns_roce_qp_store()
1489 __acquire(&recv_cq->lock); in hns_roce_lock_cqs()
1492 __acquire(&recv_cq->lock); in hns_roce_lock_cqs()
1494 spin_lock(&recv_cq->lock); in hns_roce_lock_cqs()
1498 __acquire(&recv_cq->lock); in hns_roce_lock_cqs()
1503 spin_lock(&recv_cq->lock); in hns_roce_lock_cqs()
1510 __releases(&recv_cq->lock) in hns_roce_unlock_cqs()
1513 __release(&recv_cq->lock); in hns_roce_unlock_cqs()
1516 __release(&recv_cq->lock); in hns_roce_unlock_cqs()
[all …]
H A Dhns_roce_hw_v2.c835 hr_qp->ibqp.recv_cq))) { in hns_roce_v2_post_recv()
2694 free_mr->rsv_qp[i]->ibqp.recv_cq = cq; in free_mr_init_qp()
2754 qp_init_attr.recv_cq = cq; in free_mr_alloc_res()
5289 if (ibqp->recv_cq && ibqp->recv_cq != ibqp->send_cq) in clear_qp()
5589 qp_init_attr->recv_cq = ibqp->recv_cq; in hns_roce_v2_query_qp()
5614 struct hns_roce_cq *send_cq, *recv_cq; in hns_roce_v2_destroy_qp_common() local
5629 recv_cq = hr_qp->ibqp.recv_cq ? to_hr_cq(hr_qp->ibqp.recv_cq) : NULL; in hns_roce_v2_destroy_qp_common()
5632 hns_roce_lock_cqs(send_cq, recv_cq); in hns_roce_v2_destroy_qp_common()
5635 if (recv_cq) in hns_roce_v2_destroy_qp_common()
5641 if (send_cq && send_cq != recv_cq) in hns_roce_v2_destroy_qp_common()
[all …]
/linux-6.15/drivers/infiniband/ulp/ipoib/
H A Dipoib_verbs.c178 priv->recv_cq = ib_create_cq(priv->ca, ipoib_ib_rx_completion, NULL, in ipoib_transport_dev_init()
180 if (IS_ERR(priv->recv_cq)) { in ipoib_transport_dev_init()
194 if (ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP)) in ipoib_transport_dev_init()
198 init_attr.recv_cq = priv->recv_cq; in ipoib_transport_dev_init()
247 ib_destroy_cq(priv->recv_cq); in ipoib_transport_dev_init()
267 ib_destroy_cq(priv->recv_cq); in ipoib_transport_dev_cleanup()
H A Dipoib_ethtool.c103 ret = rdma_set_cq_moderation(priv->recv_cq, in ipoib_set_coalesce()
H A Dipoib_ib.c466 n = ib_poll_cq(priv->recv_cq, t, priv->ibwc); in ipoib_rx_poll()
488 if (unlikely(ib_req_notify_cq(priv->recv_cq, in ipoib_rx_poll()
867 ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP); in ipoib_ib_dev_stop_default()
1000 n = ib_poll_cq(priv->recv_cq, IPOIB_NUM_WC, priv->ibwc); in ipoib_drain_cq()
H A Dipoib_cm.c255 .send_cq = priv->recv_cq, /* For drain WR */ in ipoib_cm_create_rx_qp()
256 .recv_cq = priv->recv_cq, in ipoib_cm_create_rx_qp()
1062 .recv_cq = priv->recv_cq, in ipoib_cm_create_tx_qp()
/linux-6.15/drivers/infiniband/hw/mlx5/
H A Dqp.c1317 recv_cq ? get_ts_format(dev, recv_cq, fr_sup, rt_sup) : in get_qp_ts_format()
2219 if (recv_cq) in create_dci()
2422 if (recv_cq) in create_user_qp()
2555 if (recv_cq) in create_kernel_qp()
2571 if (recv_cq) { in mlx5_ib_lock_cqs()
2601 if (recv_cq) { in mlx5_ib_unlock_cqs()
2632 *recv_cq = NULL; in get_cqs()
2696 &recv_cq); in destroy_qp_common()
2705 if (recv_cq) in destroy_qp_common()
4286 if (recv_cq) in __mlx5_ib_modify_qp()
[all …]
H A Dgsi.c206 .recv_cq = gsi->rx_qp->recv_cq, in create_gsi_ud_qp()
/linux-6.15/drivers/infiniband/hw/mthca/
H A Dmthca_qp.c1165 struct mthca_cq *recv_cq, in mthca_alloc_qp_common() argument
1294 struct mthca_cq *recv_cq, in mthca_alloc_qp() argument
1339 if (send_cq == recv_cq) { in mthca_lock_cqs()
1341 __acquire(&recv_cq->lock); in mthca_lock_cqs()
1354 if (send_cq == recv_cq) { in mthca_unlock_cqs()
1355 __release(&recv_cq->lock); in mthca_unlock_cqs()
1358 spin_unlock(&recv_cq->lock); in mthca_unlock_cqs()
1369 struct mthca_cq *recv_cq, in mthca_alloc_sqp() argument
1449 struct mthca_cq *recv_cq; in mthca_free_qp() local
1452 recv_cq = to_mcq(qp->ibqp.recv_cq); in mthca_free_qp()
[all …]
H A Dmthca_dev.h536 struct mthca_cq *recv_cq,
545 struct mthca_cq *recv_cq,
/linux-6.15/drivers/infiniband/core/
H A Duverbs_std_types_qp.c94 struct ib_cq *recv_cq = NULL; in UVERBS_HANDLER() local
181 recv_cq = uverbs_attr_get_obj(attrs, in UVERBS_HANDLER()
183 if (IS_ERR(recv_cq)) in UVERBS_HANDLER()
184 return PTR_ERR(recv_cq); in UVERBS_HANDLER()
235 attr.recv_cq = recv_cq; in UVERBS_HANDLER()
H A Dverbs.c1190 qp->send_cq = qp->recv_cq = NULL; in create_xrc_qp_user()
1245 qp->recv_cq = attr->recv_cq; in create_qp()
1259 qp->recv_cq = attr->recv_cq; in create_qp()
1320 if (qp->recv_cq) in ib_qp_usecnt_inc()
1321 atomic_inc(&qp->recv_cq->usecnt); in ib_qp_usecnt_inc()
1335 if (qp->recv_cq) in ib_qp_usecnt_dec()
1336 atomic_dec(&qp->recv_cq->usecnt); in ib_qp_usecnt_dec()
2870 struct ib_cq *cq = qp->recv_cq; in __ib_drain_rq()
2948 } else if (qp->recv_cq) { in __ib_drain_srq()
2949 cq = qp->recv_cq; in __ib_drain_srq()
[all …]
/linux-6.15/drivers/infiniband/hw/mlx4/
H A Dqp.c1313 if (send_cq == recv_cq) { in mlx4_ib_lock_cqs()
1315 __acquire(&recv_cq->lock); in mlx4_ib_lock_cqs()
1320 spin_lock(&recv_cq->lock); in mlx4_ib_lock_cqs()
1328 if (send_cq == recv_cq) { in mlx4_ib_unlock_cqs()
1364 *recv_cq = *send_cq; in get_cqs()
1368 *recv_cq = *send_cq; in get_cqs()
1371 *recv_cq = (src == MLX4_IB_QP_SRC) ? to_mcq(qp->ibqp.recv_cq) : in get_cqs()
1374 *recv_cq; in get_cqs()
1455 if (send_cq != recv_cq) in destroy_qp_common()
2367 recv_cq = send_cq; in __mlx4_ib_modify_qp()
[all …]
/linux-6.15/drivers/infiniband/hw/mana/
H A Dqp.c606 struct mana_ib_cq *recv_cq = container_of(qp->ibqp.recv_cq, struct mana_ib_cq, ibcq); in mana_add_qp_to_cqs() local
613 spin_lock_irqsave(&recv_cq->cq_lock, flags); in mana_add_qp_to_cqs()
614 list_add_tail(&qp->cq_recv_list, &recv_cq->list_recv_qp); in mana_add_qp_to_cqs()
615 spin_unlock_irqrestore(&recv_cq->cq_lock, flags); in mana_add_qp_to_cqs()
621 struct mana_ib_cq *recv_cq = container_of(qp->ibqp.recv_cq, struct mana_ib_cq, ibcq); in mana_remove_qp_from_cqs() local
628 spin_lock_irqsave(&recv_cq->cq_lock, flags); in mana_remove_qp_from_cqs()
630 spin_unlock_irqrestore(&recv_cq->cq_lock, flags); in mana_remove_qp_from_cqs()
H A Dmain.c971 struct mana_ib_cq *recv_cq = container_of(qp->ibqp.recv_cq, struct mana_ib_cq, ibcq); in mana_ib_gd_create_rc_qp() local
983 req.recv_cq_handle = recv_cq->cq_handle; in mana_ib_gd_create_rc_qp()
1030 struct mana_ib_cq *recv_cq = container_of(qp->ibqp.recv_cq, struct mana_ib_cq, ibcq); in mana_ib_gd_create_ud_qp() local
1042 req.recv_cq_handle = recv_cq->cq_handle; in mana_ib_gd_create_ud_qp()
/linux-6.15/net/sunrpc/xprtrdma/
H A Dverbs.c347 if (ep->re_attr.recv_cq) in rpcrdma_ep_destroy()
348 ib_free_cq(ep->re_attr.recv_cq); in rpcrdma_ep_destroy()
349 ep->re_attr.recv_cq = NULL; in rpcrdma_ep_destroy()
430 ep->re_attr.recv_cq = ib_alloc_cq_any(device, r_xprt, in rpcrdma_ep_create()
433 if (IS_ERR(ep->re_attr.recv_cq)) { in rpcrdma_ep_create()
434 rc = PTR_ERR(ep->re_attr.recv_cq); in rpcrdma_ep_create()
435 ep->re_attr.recv_cq = NULL; in rpcrdma_ep_create()
1380 rep->rr_cid.ci_queue_id = ep->re_attr.recv_cq->res.id; in rpcrdma_post_recvs()
/linux-6.15/fs/smb/server/
H A Dtransport_rdma.c106 struct ib_cq *recv_cq; member
449 if (t->recv_cq) in free_transport()
450 ib_free_cq(t->recv_cq); in free_transport()
1895 t->recv_cq = ib_alloc_cq(t->cm_id->device, t, in smb_direct_create_qpair()
1897 if (IS_ERR(t->recv_cq)) { in smb_direct_create_qpair()
1899 ret = PTR_ERR(t->recv_cq); in smb_direct_create_qpair()
1900 t->recv_cq = NULL; in smb_direct_create_qpair()
1911 qp_attr.recv_cq = t->recv_cq; in smb_direct_create_qpair()
1941 if (t->recv_cq) { in smb_direct_create_qpair()
1942 ib_destroy_cq(t->recv_cq); in smb_direct_create_qpair()
[all …]
/linux-6.15/drivers/infiniband/hw/vmw_pvrdma/
H A Dpvrdma_qp.c59 struct pvrdma_cq **recv_cq) in get_cqs() argument
62 *recv_cq = to_vcq(qp->ibqp.recv_cq); in get_cqs()
360 cmd->recv_cq_handle = to_vcq(init_attr->recv_cq)->cq_handle; in pvrdma_create_qp()
1035 init_attr->recv_cq = qp->ibqp.recv_cq; in pvrdma_query_qp()
/linux-6.15/drivers/infiniband/sw/rxe/
H A Drxe_qp.c75 if (!init->recv_cq || !init->send_cq) { in rxe_qp_chk_init()
355 struct rxe_cq *rcq = to_rcq(init->recv_cq); in rxe_qp_from_init()
418 init->recv_cq = qp->ibqp.recv_cq; in rxe_qp_to_init()
/linux-6.15/fs/smb/client/
H A Dsmbdirect.c1359 ib_free_cq(info->recv_cq); in smbd_destroy()
1548 info->recv_cq = NULL; in _smbd_get_connection()
1557 info->recv_cq = in _smbd_get_connection()
1560 if (IS_ERR(info->recv_cq)) { in _smbd_get_connection()
1561 info->recv_cq = NULL; in _smbd_get_connection()
1576 qp_attr.recv_cq = info->recv_cq; in _smbd_get_connection()
1692 if (info->recv_cq) in _smbd_get_connection()
1693 ib_free_cq(info->recv_cq); in _smbd_get_connection()
H A Dsmbdirect.h59 struct ib_cq *send_cq, *recv_cq; member
/linux-6.15/drivers/infiniband/ulp/srp/
H A Dib_srp.h158 struct ib_cq *recv_cq; member
H A Dib_srp.c529 struct ib_cq *recv_cq, *send_cq; in srp_create_ch_ib() local
540 recv_cq = ib_alloc_cq(dev->dev, ch, target->queue_size + 1, in srp_create_ch_ib()
542 if (IS_ERR(recv_cq)) { in srp_create_ch_ib()
543 ret = PTR_ERR(recv_cq); in srp_create_ch_ib()
562 init_attr->recv_cq = recv_cq; in srp_create_ch_ib()
597 if (ch->recv_cq) in srp_create_ch_ib()
598 ib_free_cq(ch->recv_cq); in srp_create_ch_ib()
603 ch->recv_cq = recv_cq; in srp_create_ch_ib()
625 ib_free_cq(recv_cq); in srp_create_ch_ib()
668 ib_free_cq(ch->recv_cq); in srp_free_ch_ib()
[all …]
/linux-6.15/drivers/net/ethernet/ibm/ehea/
H A Dehea_main.c201 arr[i++].fwh = pr->recv_cq->fw_handle; in ehea_update_firmware_handles()
892 ehea_reset_cq_ep(pr->recv_cq); in ehea_poll()
894 ehea_reset_cq_n1(pr->recv_cq); in ehea_poll()
1469 pr->recv_cq = ehea_create_cq(adapter, pr_cfg->max_entries_rcq, in ehea_init_port_res()
1472 if (!pr->recv_cq) { in ehea_init_port_res()
1488 pr->recv_cq->attr.act_nr_of_cqes); in ehea_init_port_res()
1513 init_attr->recv_cq_handle = pr->recv_cq->fw_handle; in ehea_init_port_res()
1563 ehea_destroy_cq(pr->recv_cq); in ehea_init_port_res()
1580 ehea_destroy_cq(pr->recv_cq); in ehea_clean_portres()
H A Dehea.h352 struct ehea_cq *recv_cq; member

123