| /Linux-v6.6/drivers/infiniband/hw/hns/ |
| D | hns_roce_qp.c | 261 struct ib_cq *send_cq, struct ib_cq *recv_cq) in add_qp_to_list() argument
267 hr_recv_cq = recv_cq ? to_hr_cq(recv_cq) : NULL; in add_qp_to_list()
298 init_attr->recv_cq); in hns_roce_qp_store()
1373 void hns_roce_lock_cqs(struct hns_roce_cq *send_cq, struct hns_roce_cq *recv_cq) in hns_roce_lock_cqs() argument
1374 __acquires(&send_cq->lock) __acquires(&recv_cq->lock) in hns_roce_lock_cqs()
1376 if (unlikely(send_cq == NULL && recv_cq == NULL)) { in hns_roce_lock_cqs()
1378 __acquire(&recv_cq->lock); in hns_roce_lock_cqs()
1379 } else if (unlikely(send_cq != NULL && recv_cq == NULL)) { in hns_roce_lock_cqs()
1381 __acquire(&recv_cq->lock); in hns_roce_lock_cqs()
1382 } else if (unlikely(send_cq == NULL && recv_cq != NULL)) { in hns_roce_lock_cqs()
[all …]
|
| D | hns_roce_hw_v2.c | 836 hr_qp->ibqp.recv_cq))) { in hns_roce_v2_post_recv()
2623 free_mr->rsv_qp[i]->ibqp.recv_cq = cq; in free_mr_init_qp()
2681 qp_init_attr.recv_cq = cq; in free_mr_alloc_res()
4272 hr_reg_write(context, QPC_RX_CQN, get_cqn(ibqp->recv_cq)); in modify_qp_reset_to_init()
4307 hr_reg_write(context, QPC_RX_CQN, get_cqn(ibqp->recv_cq)); in modify_qp_init_to_init()
5129 if (ibqp->recv_cq && ibqp->recv_cq != ibqp->send_cq) in clear_qp()
5130 hns_roce_v2_cq_clean(to_hr_cq(ibqp->recv_cq), in clear_qp()
5379 qp_init_attr->recv_cq = ibqp->recv_cq; in hns_roce_v2_query_qp()
5404 struct hns_roce_cq *send_cq, *recv_cq; in hns_roce_v2_destroy_qp_common() local
5419 recv_cq = hr_qp->ibqp.recv_cq ? to_hr_cq(hr_qp->ibqp.recv_cq) : NULL; in hns_roce_v2_destroy_qp_common()
[all …]
|
| /Linux-v6.6/drivers/infiniband/ulp/ipoib/ |
| D | ipoib_verbs.c | 178 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()
|
| D | ipoib_ethtool.c | 103 ret = rdma_set_cq_moderation(priv->recv_cq, in ipoib_set_coalesce()
|
| D | ipoib_ib.c | 466 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()
843 ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP); in ipoib_ib_dev_stop_default()
976 n = ib_poll_cq(priv->recv_cq, IPOIB_NUM_WC, priv->ibwc); in ipoib_drain_cq()
|
| D | ipoib_cm.c | 255 .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-v6.6/drivers/infiniband/hw/mlx5/ |
| D | qp.c | 88 struct mlx5_ib_cq **send_cq, struct mlx5_ib_cq **recv_cq);
828 struct mlx5_ib_cq *recv_cq);
830 struct mlx5_ib_cq *recv_cq);
1291 static int get_rq_ts_format(struct mlx5_ib_dev *dev, struct mlx5_ib_cq *recv_cq) in get_rq_ts_format() argument
1295 return get_ts_format(dev, recv_cq, fr_supported(ts_cap), in get_rq_ts_format()
1308 struct mlx5_ib_cq *recv_cq) in get_qp_ts_format() argument
1319 recv_cq ? get_ts_format(dev, recv_cq, fr_sup, rt_sup) : in get_qp_ts_format()
1616 to_mcq(init_attr->recv_cq)); in create_raw_packet_qp()
2081 struct mlx5_ib_cq *recv_cq; in create_dci() local
2117 to_mcq(init_attr->recv_cq)); in create_dci()
[all …]
|
| D | gsi.c | 206 .recv_cq = gsi->rx_qp->recv_cq, in create_gsi_ud_qp()
|
| D | mem.c | 245 qp_init_attr.recv_cq = cq; in mlx5_ib_test_wc()
|
| /Linux-v6.6/drivers/infiniband/hw/mthca/ |
| D | mthca_qp.c | 774 qp_context->cqn_rcv = cpu_to_be32(to_mcq(ibqp->recv_cq)->cqn); in __mthca_modify_qp()
835 mthca_cq_clean(dev, to_mcq(qp->ibqp.recv_cq), qp->qpn, in __mthca_modify_qp()
837 if (qp->ibqp.send_cq != qp->ibqp.recv_cq) in __mthca_modify_qp()
1165 struct mthca_cq *recv_cq, in mthca_alloc_qp_common() argument
1294 struct mthca_cq *recv_cq, in mthca_alloc_qp() argument
1321 err = mthca_alloc_qp_common(dev, pd, send_cq, recv_cq, in mthca_alloc_qp()
1336 static void mthca_lock_cqs(struct mthca_cq *send_cq, struct mthca_cq *recv_cq) in mthca_lock_cqs() argument
1337 __acquires(&send_cq->lock) __acquires(&recv_cq->lock) in mthca_lock_cqs()
1339 if (send_cq == recv_cq) { in mthca_lock_cqs()
1341 __acquire(&recv_cq->lock); in mthca_lock_cqs()
[all …]
|
| D | mthca_dev.h | 536 struct mthca_cq *recv_cq,
545 struct mthca_cq *recv_cq,
|
| /Linux-v6.6/drivers/infiniband/core/ |
| D | uverbs_std_types_qp.c | 94 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()
|
| D | verbs.c | 1177 qp->send_cq = qp->recv_cq = NULL; in create_xrc_qp_user()
1230 qp->recv_cq = attr->recv_cq; in create_qp()
1244 qp->recv_cq = attr->recv_cq; in create_qp()
1305 if (qp->recv_cq) in ib_qp_usecnt_inc()
1306 atomic_inc(&qp->recv_cq->usecnt); in ib_qp_usecnt_inc()
1320 if (qp->recv_cq) in ib_qp_usecnt_dec()
1321 atomic_dec(&qp->recv_cq->usecnt); in ib_qp_usecnt_dec()
2855 struct ib_cq *cq = qp->recv_cq; in __ib_drain_rq()
2938 trace_cq_drain_complete(qp->recv_cq); in ib_drain_rq()
|
| /Linux-v6.6/drivers/infiniband/hw/mlx4/ |
| D | qp.c | 53 struct mlx4_ib_cq *recv_cq);
55 struct mlx4_ib_cq *recv_cq);
961 to_mcq(init_attr->recv_cq)); in create_rq()
971 mcq = to_mcq(init_attr->recv_cq); in create_rq()
974 to_mcq(init_attr->recv_cq)); in create_rq()
1235 to_mcq(init_attr->recv_cq)); in create_qp_common()
1245 mcq = to_mcq(init_attr->recv_cq); in create_qp_common()
1248 to_mcq(init_attr->recv_cq)); in create_qp_common()
1302 static void mlx4_ib_lock_cqs(struct mlx4_ib_cq *send_cq, struct mlx4_ib_cq *recv_cq) in mlx4_ib_lock_cqs() argument
1303 __acquires(&send_cq->lock) __acquires(&recv_cq->lock) in mlx4_ib_lock_cqs()
[all …]
|
| /Linux-v6.6/net/sunrpc/xprtrdma/ |
| D | verbs.c | 338 if (ep->re_attr.recv_cq) in rpcrdma_ep_destroy()
339 ib_free_cq(ep->re_attr.recv_cq); in rpcrdma_ep_destroy()
340 ep->re_attr.recv_cq = NULL; in rpcrdma_ep_destroy()
419 ep->re_attr.recv_cq = ib_alloc_cq_any(device, r_xprt, in rpcrdma_ep_create()
422 if (IS_ERR(ep->re_attr.recv_cq)) { in rpcrdma_ep_create()
423 rc = PTR_ERR(ep->re_attr.recv_cq); in rpcrdma_ep_create()
424 ep->re_attr.recv_cq = NULL; in rpcrdma_ep_create()
1366 rep->rr_cid.ci_queue_id = ep->re_attr.recv_cq->res.id; in rpcrdma_post_recvs()
|
| /Linux-v6.6/fs/smb/server/ |
| D | transport_rdma.c | 105 struct ib_cq *recv_cq; member
448 if (t->recv_cq) in free_transport()
449 ib_free_cq(t->recv_cq); in free_transport()
1894 t->recv_cq = ib_alloc_cq(t->cm_id->device, t, in smb_direct_create_qpair()
1896 if (IS_ERR(t->recv_cq)) { in smb_direct_create_qpair()
1898 ret = PTR_ERR(t->recv_cq); in smb_direct_create_qpair()
1899 t->recv_cq = NULL; in smb_direct_create_qpair()
1910 qp_attr.recv_cq = t->recv_cq; in smb_direct_create_qpair()
1940 if (t->recv_cq) { in smb_direct_create_qpair()
1941 ib_destroy_cq(t->recv_cq); in smb_direct_create_qpair()
[all …]
|
| /Linux-v6.6/drivers/infiniband/hw/vmw_pvrdma/ |
| D | pvrdma_qp.c | 59 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-v6.6/drivers/infiniband/sw/rxe/ |
| D | rxe_qp.c | 75 if (!init->recv_cq || !init->send_cq) { in rxe_qp_chk_init()
356 struct rxe_cq *rcq = to_rcq(init->recv_cq); in rxe_qp_from_init()
419 init->recv_cq = qp->ibqp.recv_cq; in rxe_qp_to_init()
|
| /Linux-v6.6/fs/smb/client/ |
| D | smbdirect.c | 1358 ib_free_cq(info->recv_cq); in smbd_destroy()
1547 info->recv_cq = NULL; in _smbd_get_connection()
1556 info->recv_cq = in _smbd_get_connection()
1559 if (IS_ERR(info->recv_cq)) { in _smbd_get_connection()
1560 info->recv_cq = NULL; in _smbd_get_connection()
1575 qp_attr.recv_cq = info->recv_cq; in _smbd_get_connection()
1693 if (info->recv_cq) in _smbd_get_connection()
1694 ib_free_cq(info->recv_cq); in _smbd_get_connection()
|
| D | smbdirect.h | 59 struct ib_cq *send_cq, *recv_cq; member
|
| /Linux-v6.6/drivers/infiniband/ulp/srp/ |
| D | ib_srp.h | 158 struct ib_cq *recv_cq; member
|
| D | ib_srp.c | 529 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-v6.6/drivers/net/ethernet/ibm/ehea/ |
| D | ehea_main.c | 201 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()
|
| D | ehea.h | 352 struct ehea_cq *recv_cq; member
|
| /Linux-v6.6/drivers/infiniband/sw/siw/ |
| D | siw_verbs.c | 348 if (!attrs->send_cq || (!attrs->recv_cq && !attrs->srq)) { in siw_create_qp()
400 qp->rcq = to_siw_cq(attrs->recv_cq); in siw_create_qp()
533 qp_init_attr->recv_cq = base_qp->recv_cq; in siw_query_qp()
|
