Home
last modified time | relevance | path

Searched refs:send_cq (Results 1 – 25 of 30) sorted by relevance

12

/linux/drivers/infiniband/hw/mthca/
H A Dmthca_qp.c735 qp_context->cqn_snd = cpu_to_be32(to_mcq(ibqp->send_cq)->cqn); in __mthca_modify_qp()
837 if (qp->ibqp.send_cq != qp->ibqp.recv_cq) in __mthca_modify_qp()
838 mthca_cq_clean(dev, to_mcq(qp->ibqp.send_cq), qp->qpn, NULL); in __mthca_modify_qp()
1164 struct mthca_cq *send_cq, in mthca_alloc_qp_common() argument
1293 struct mthca_cq *send_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()
1340 spin_lock_irq(&send_cq->lock); in mthca_lock_cqs()
[all …]
H A Dmthca_dev.h535 struct mthca_cq *send_cq,
544 struct mthca_cq *send_cq,
/linux/include/rdma/
H A Drdmavt_qp.h808 struct rvt_cq *cq = ibcq_to_rvtcq(qp->ibqp.send_cq); in rvt_send_cq()
923 static inline u32 ib_cq_tail(struct ib_cq *send_cq) in ib_cq_tail() argument
925 struct rvt_cq *cq = ibcq_to_rvtcq(send_cq); in ib_cq_tail()
927 return ibcq_to_rvtcq(send_cq)->ip ? in ib_cq_tail()
929 ibcq_to_rvtcq(send_cq)->kqueue->tail; in ib_cq_tail()
939 static inline u32 ib_cq_head(struct ib_cq *send_cq) in ib_cq_head() argument
941 struct rvt_cq *cq = ibcq_to_rvtcq(send_cq); in ib_cq_head()
943 return ibcq_to_rvtcq(send_cq)->ip ? in ib_cq_head()
945 ibcq_to_rvtcq(send_cq)->kqueue->head; in ib_cq_head()
/linux/net/sunrpc/xprtrdma/
H A Dverbs.c363 if (ep->re_attr.send_cq)
364 ib_free_cq(ep->re_attr.send_cq); in rpcrdma_ep_get()
365 ep->re_attr.send_cq = NULL; in rpcrdma_ep_get()
433 ep->re_attr.send_cq = ib_alloc_cq_any(device, r_xprt, in rpcrdma_ep_create()
436 if (IS_ERR(ep->re_attr.send_cq)) { in rpcrdma_ep_create()
437 rc = PTR_ERR(ep->re_attr.send_cq); in rpcrdma_ep_create()
438 ep->re_attr.send_cq = NULL; in rpcrdma_ep_create()
665 sc->sc_cid.ci_queue_id = ep->re_attr.send_cq->res.id; in rpcrdma_sendctx_next()
H A Dsvc_rdma_transport.c539 qp_attr.send_cq = newxprt->sc_sq_cq; in svc_rdma_accept()
H A Dfrwr_ops.c53 cid->ci_queue_id = ep->re_attr.send_cq->res.id; in frwr_cid_init()
/linux/Documentation/translations/zh_CN/infiniband/
H A Dtag_matching.rst39 1. Eager协议--当发送方处理完发送时，完整的信息就会被发送。在send_cq中会收到
/linux/drivers/infiniband/hw/mlx5/
H A Dgsi.c50 struct ib_cq *gsi_cq = mqp->ibqp.send_cq; in generate_completions()
141 hw_init_attr.send_cq = gsi->cq; in mlx5_ib_create_gsi()
206 .send_cq = gsi->cq, in create_gsi_ud_qp()
H A Dwr.c729 if (unlikely(mlx5r_wq_overflow(&qp->sq, nreq, qp->ibqp.send_cq))) in mlx5r_begin_wqe()
/linux/drivers/infiniband/core/
H A Dverbs.c1254 qp->send_cq = qp->recv_cq = NULL; in create_xrc_qp_user()
1308 qp->send_cq = attr->send_cq; in create_qp()
1323 qp->send_cq = attr->send_cq; in create_qp()
1385 if (qp->send_cq) in ib_qp_usecnt_inc()
1386 atomic_inc(&qp->send_cq->usecnt); in ib_qp_usecnt_inc()
1404 if (qp->send_cq) in ib_qp_usecnt_dec()
1405 atomic_dec(&qp->send_cq->usecnt); in ib_qp_usecnt_dec()
2907 struct ib_cq *cq = qp->send_cq; in __ib_drain_sq()
3066 trace_cq_drain_complete(qp->send_cq); in ib_drain_sq()
/linux/drivers/infiniband/ulp/srp/
H A Dib_srp.c518 ib_process_cq_direct(ch->send_cq, -1); in srp_destroy_qp()
531 struct ib_cq *recv_cq, *send_cq; in srp_create_ch_ib() local
549 send_cq = ib_alloc_cq(dev->dev, ch, m * target->queue_size, in srp_create_ch_ib()
551 if (IS_ERR(send_cq)) { in srp_create_ch_ib()
552 ret = PTR_ERR(send_cq); in srp_create_ch_ib()
563 init_attr->send_cq = send_cq; in srp_create_ch_ib()
601 if (ch->send_cq) in srp_create_ch_ib()
602 ib_free_cq(ch->send_cq); in srp_create_ch_ib()
606 ch->send_cq = send_cq; in srp_create_ch_ib()
624 ib_free_cq(send_cq); in srp_create_ch_ib()
[all …]
H A Dib_srp.h157 struct ib_cq *send_cq; member
/linux/drivers/net/ethernet/mellanox/mlx5/core/steering/hws/
H A Dsend.c628 struct mlx5hws_send_ring_cq *cq = &send_ring->send_cq; in hws_send_engine_poll_cq()
1015 hws_send_ring_close_cq(&queue->send_ring.send_cq); in hws_send_ring_close()
1025 err = hws_send_ring_open_cq(ctx->mdev, queue, numa_node, &ring->send_cq); in mlx5hws_send_ring_open()
1030 &ring->send_cq); in mlx5hws_send_ring_open()
1037 hws_send_ring_close_cq(&ring->send_cq); in mlx5hws_send_ring_open()
H A Ddebug.c245 cq = &send_ring->send_cq; in hws_debug_dump_context_send_engine()
/linux/drivers/infiniband/ulp/ipoib/
H A Dipoib_ib.c440 n = ib_poll_cq(priv->send_cq, MAX_SEND_CQE, priv->send_wc); in poll_tx()
508 n = ib_poll_cq(priv->send_cq, MAX_SEND_CQE, priv->send_wc); in ipoib_tx_poll()
520 if (unlikely(ib_req_notify_cq(priv->send_cq, IB_CQ_NEXT_COMP | in ipoib_tx_poll()
674 if (ib_req_notify_cq(priv->send_cq, IB_CQ_NEXT_COMP | in ipoib_send()
H A Dipoib.h361 struct ib_cq *send_cq; member
/linux/Documentation/infiniband/
H A Dtag_matching.rst32 processed by the sender. A completion send is received in the send_cq
/linux/drivers/infiniband/hw/qedr/
H A Dqedr_roce_cm.c62 dev->gsi_sqcq = get_qedr_cq(attrs->send_cq); in qedr_store_gsi_qp_cq()
139 cq = get_qedr_cq(attrs->send_cq); in qedr_destroy_gsi_cq()
/linux/drivers/infiniband/ulp/rtrs/
H A Drtrs.c270 init_attr.send_cq = con->cq; in create_qp()
/linux/net/smc/
H A Dsmc_ib.c674 .send_cq = lnk->smcibdev->roce_cq_send, in smc_ib_create_queue_pair()
/linux/net/rds/
H A Dib_cm.c593 attr.send_cq = ic->i_send_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()
1014 qp->scq = to_ecq(attrs->send_cq); in erdma_create_qp()
/linux/drivers/infiniband/hw/irdma/
H A Dverbs.c1052 iwqp->iwscq = to_iwcq(init_attr->send_cq); in irdma_create_qp()
1241 init_attr->send_cq = iwqp->ibqp.send_cq; in irdma_query_qp()
/linux/drivers/nvme/target/
H A Drdma.c1296 qp_attr.send_cq = queue->cq; in nvmet_rdma_create_queue_ib()
/linux/drivers/nvme/host/
H A Drdma.c281 init_attr.send_cq = queue->ib_cq; in nvme_rdma_create_qp()

12