Home
last modified time | relevance | path

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

12

/linux/drivers/infiniband/hw/mthca/
H A Dmthca_qp.c774 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 …]
H A Dmthca_dev.h536 struct mthca_cq *recv_cq,
545 struct mthca_cq *recv_cq,
/linux/net/sunrpc/xprtrdma/
H A Dverbs.c360 if (ep->re_attr.recv_cq) in rpcrdma_ep_destroy()
361 ib_free_cq(ep->re_attr.recv_cq); in rpcrdma_ep_destroy()
362 ep->re_attr.recv_cq = NULL; in rpcrdma_ep_destroy()
442 ep->re_attr.recv_cq = ib_alloc_cq_any(device, r_xprt, in rpcrdma_ep_create()
445 if (IS_ERR(ep->re_attr.recv_cq)) { in rpcrdma_ep_create()
446 rc = PTR_ERR(ep->re_attr.recv_cq); in rpcrdma_ep_create()
447 ep->re_attr.recv_cq = NULL; in rpcrdma_ep_create()
1520 rep->rr_cid.ci_queue_id = ep->re_attr.recv_cq->res.id;
H A Dsvc_rdma_transport.c540 qp_attr.recv_cq = newxprt->sc_rq_cq; in svc_rdma_accept()
/linux/drivers/infiniband/core/
H A Dverbs.c1254 qp->send_cq = qp->recv_cq = NULL; in create_xrc_qp_user()
1309 qp->recv_cq = attr->recv_cq; in create_qp()
1324 qp->recv_cq = attr->recv_cq; in create_qp()
1387 if (qp->recv_cq) in ib_qp_usecnt_inc()
1388 atomic_inc(&qp->recv_cq->usecnt); in ib_qp_usecnt_inc()
1402 if (qp->recv_cq) in ib_qp_usecnt_dec()
1403 atomic_dec(&qp->recv_cq->usecnt); in ib_qp_usecnt_dec()
2946 struct ib_cq *cq = qp->recv_cq; in __ib_drain_rq()
3024 } else if (qp->recv_cq) { in __ib_drain_srq()
3025 cq = qp->recv_cq; in __ib_drain_srq()
[all …]
H A Dmad.c3186 qp_init_attr.recv_cq = qp_info->port_priv->cq; in create_mad_qp()
/linux/drivers/infiniband/ulp/srp/
H A Dib_srp.h158 struct ib_cq *recv_cq; member
H A Dib_srp.c531 struct ib_cq *recv_cq, *send_cq; in srp_create_ch_ib() local
542 recv_cq = ib_alloc_cq(dev->dev, ch, target->queue_size + 1, in srp_create_ch_ib()
544 if (IS_ERR(recv_cq)) { in srp_create_ch_ib()
545 ret = PTR_ERR(recv_cq); in srp_create_ch_ib()
564 init_attr->recv_cq = recv_cq; in srp_create_ch_ib()
599 if (ch->recv_cq) in srp_create_ch_ib()
600 ib_free_cq(ch->recv_cq); in srp_create_ch_ib()
605 ch->recv_cq = recv_cq; in srp_create_ch_ib()
627 ib_free_cq(recv_cq); in srp_create_ch_ib()
670 ib_free_cq(ch->recv_cq); in srp_free_ch_ib()
[all …]
/linux/drivers/infiniband/hw/mlx5/
H A Dgsi.c207 .recv_cq = gsi->rx_qp->recv_cq, in create_gsi_ud_qp()
H A Dwr.c1236 if (mlx5r_wq_overflow(&qp->rq, nreq, qp->ibqp.recv_cq)) { in mlx5_ib_post_recv()
H A Dmain.c3000 recv_mcq = to_mcq(mqp->ibqp.recv_cq); in mlx5_ib_handle_internal_error()
3003 mqp->ibqp.recv_cq->comp_handler) { in mlx5_ib_handle_internal_error()
/linux/drivers/infiniband/ulp/ipoib/
H A Dipoib_ib.c467 n = ib_poll_cq(priv->recv_cq, t, priv->ibwc); in ipoib_rx_poll()
489 if (unlikely(ib_req_notify_cq(priv->recv_cq, in ipoib_rx_poll()
872 ib_req_notify_cq(priv->recv_cq, IB_CQ_NEXT_COMP); in ipoib_ib_dev_stop_default()
1005 n = ib_poll_cq(priv->recv_cq, IPOIB_NUM_WC, priv->ibwc); in ipoib_drain_cq()
H A Dipoib.h360 struct ib_cq *recv_cq; member
/linux/drivers/infiniband/hw/qedr/
H A Dqedr_roce_cm.c63 dev->gsi_rqcq = get_qedr_cq(attrs->recv_cq); in qedr_store_gsi_qp_cq()
144 cq = get_qedr_cq(attrs->recv_cq); in qedr_destroy_gsi_cq()
/linux/include/rdma/
H A Drdmavt_qp.h788 struct rvt_cq *cq = ibcq_to_rvtcq(qp->ibqp.recv_cq); in rvt_recv_cq()
/linux/drivers/infiniband/ulp/rtrs/
H A Drtrs.c271 init_attr.recv_cq = con->cq; in create_qp()
/linux/include/trace/events/
H A Drpcrdma.h990 __entry->cq_id = ep ? ep->re_attr.recv_cq->res.id : 0;
1024 __entry->cq_id = ep->re_attr.recv_cq->res.id;
1055 __entry->cq_id = ep->re_attr.recv_cq->res.id;
/linux/net/smc/
H A Dsmc_ib.c675 .recv_cq = lnk->smcibdev->roce_cq_recv, in smc_ib_create_queue_pair()
/linux/net/rds/
H A Dib_cm.c594 attr.recv_cq = ic->i_recv_cq; in rds_ib_setup_qp()
/linux/drivers/infiniband/hw/erdma/
H A Derdma_verbs.c502 if (!attrs->send_cq || !attrs->recv_cq) in erdma_qp_validate_attr()
1015 qp->rcq = to_ecq(attrs->recv_cq); in erdma_create_qp()
/linux/drivers/infiniband/hw/irdma/
H A Dverbs.c1053 iwqp->iwrcq = to_iwcq(init_attr->recv_cq); in irdma_create_qp()
1242 init_attr->recv_cq = iwqp->ibqp.recv_cq; in irdma_query_qp()
/linux/drivers/nvme/target/
H A Drdma.c1297 qp_attr.recv_cq = queue->cq; in nvmet_rdma_create_queue_ib()
/linux/drivers/nvme/host/
H A Drdma.c282 init_attr.recv_cq = queue->ib_cq; in nvme_rdma_create_qp()
/linux/drivers/infiniband/hw/mlx4/
H A Dmad.c1810 qp_init_attr.init_attr.recv_cq = ctx->cq; in create_pv_sqp()
/linux/drivers/infiniband/ulp/isert/
H A Dib_isert.c124 attr.recv_cq = isert_conn->cq; in isert_create_qp()

12