Home
last modified time | relevance | path

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

123

/linux/drivers/infiniband/hw/hns/
A Dhns_roce_qp.c281 hr_send_cq = send_cq ? to_hr_cq(send_cq) : NULL; in add_qp_to_list()
1349 __acquire(&send_cq->lock); in hns_roce_lock_cqs()
1352 spin_lock_irq(&send_cq->lock); in hns_roce_lock_cqs()
1356 __acquire(&send_cq->lock); in hns_roce_lock_cqs()
1357 } else if (send_cq == recv_cq) { in hns_roce_lock_cqs()
1358 spin_lock_irq(&send_cq->lock); in hns_roce_lock_cqs()
1361 spin_lock_irq(&send_cq->lock); in hns_roce_lock_cqs()
1375 __release(&send_cq->lock); in hns_roce_unlock_cqs()
1378 spin_unlock(&send_cq->lock); in hns_roce_unlock_cqs()
1380 __release(&send_cq->lock); in hns_roce_unlock_cqs()
[all …]
A Dhns_roce_hw_v1.c880 hr_qp->ibqp.send_cq = cq; in hns_roce_v1_rsv_lp_qp()
2649 to_hr_cq(ibqp->send_cq)->cqn); in hns_roce_v1_m_sqp()
2692 if (ibqp->send_cq != ibqp->recv_cq) in hns_roce_v1_m_sqp()
2819 to_hr_cq(ibqp->send_cq)->cqn); in hns_roce_v1_m_qp()
2884 to_hr_cq(ibqp->send_cq)->cqn); in hns_roce_v1_m_qp()
3312 if (ibqp->send_cq != ibqp->recv_cq) in hns_roce_v1_m_qp()
3612 struct hns_roce_cq *send_cq, *recv_cq; in hns_roce_v1_destroy_qp() local
3619 send_cq = hr_qp->ibqp.send_cq ? to_hr_cq(hr_qp->ibqp.send_cq) : NULL; in hns_roce_v1_destroy_qp()
3622 hns_roce_lock_cqs(send_cq, recv_cq); in hns_roce_v1_destroy_qp()
3630 if (send_cq && send_cq != recv_cq) in hns_roce_v1_destroy_qp()
[all …]
A Dhns_roce_hw_v2.c4138 hr_reg_write(context, QPC_TX_CQN, get_cqn(ibqp->send_cq)); in modify_qp_reset_to_init()
4959 if (ibqp->send_cq) in clear_qp()
4960 hns_roce_v2_cq_clean(to_hr_cq(ibqp->send_cq), in clear_qp()
4963 if (ibqp->recv_cq && ibqp->recv_cq != ibqp->send_cq) in clear_qp()
5202 qp_init_attr->send_cq = ibqp->send_cq; in hns_roce_v2_query_qp()
5226 struct hns_roce_cq *send_cq, *recv_cq; in hns_roce_v2_destroy_qp_common() local
5240 send_cq = hr_qp->ibqp.send_cq ? to_hr_cq(hr_qp->ibqp.send_cq) : NULL; in hns_roce_v2_destroy_qp_common()
5244 hns_roce_lock_cqs(send_cq, recv_cq); in hns_roce_v2_destroy_qp_common()
5253 if (send_cq && send_cq != recv_cq) in hns_roce_v2_destroy_qp_common()
5254 __hns_roce_v2_cq_clean(send_cq, hr_qp->qpn, NULL); in hns_roce_v2_destroy_qp_common()
[all …]
/linux/drivers/infiniband/core/
A Duverbs_std_types_qp.c95 struct ib_cq *send_cq = NULL; in UVERBS_HANDLER() local
168 send_cq = uverbs_attr_get_obj(attrs, in UVERBS_HANDLER()
170 if (IS_ERR(send_cq)) in UVERBS_HANDLER()
171 return PTR_ERR(send_cq); in UVERBS_HANDLER()
175 send_cq = uverbs_attr_get_obj(attrs, in UVERBS_HANDLER()
177 if (IS_ERR(send_cq)) in UVERBS_HANDLER()
178 return PTR_ERR(send_cq); in UVERBS_HANDLER()
234 attr.send_cq = send_cq; in UVERBS_HANDLER()
A Dverbs.c1183 qp->send_cq = qp->recv_cq = NULL; in create_xrc_qp_user()
1235 qp->send_cq = attr->send_cq; in create_qp()
1249 qp->send_cq = attr->send_cq; in create_qp()
1309 if (qp->send_cq) in ib_qp_usecnt_inc()
1310 atomic_inc(&qp->send_cq->usecnt); in ib_qp_usecnt_inc()
1328 if (qp->send_cq) in ib_qp_usecnt_dec()
1329 atomic_dec(&qp->send_cq->usecnt); in ib_qp_usecnt_dec()
2752 struct ib_cq *cq = qp->send_cq; in __ib_drain_sq()
2845 trace_cq_drain_complete(qp->send_cq); in ib_drain_sq()
/linux/drivers/infiniband/ulp/ipoib/
A Dipoib_verbs.c187 priv->send_cq = ib_create_cq(priv->ca, ipoib_ib_tx_completion, NULL, in ipoib_transport_dev_init()
189 if (IS_ERR(priv->send_cq)) { in ipoib_transport_dev_init()
197 init_attr.send_cq = priv->send_cq; in ipoib_transport_dev_init()
218 if (ib_req_notify_cq(priv->send_cq, IB_CQ_NEXT_COMP)) in ipoib_transport_dev_init()
244 ib_destroy_cq(priv->send_cq); in ipoib_transport_dev_init()
266 ib_destroy_cq(priv->send_cq); in ipoib_transport_dev_cleanup()
A Dipoib_ib.c439 n = ib_poll_cq(priv->send_cq, MAX_SEND_CQE, priv->send_wc); in poll_tx()
507 n = ib_poll_cq(priv->send_cq, MAX_SEND_CQE, priv->send_wc); in ipoib_tx_poll()
519 if (unlikely(ib_req_notify_cq(priv->send_cq, IB_CQ_NEXT_COMP | in ipoib_tx_poll()
649 if (ib_req_notify_cq(priv->send_cq, IB_CQ_NEXT_COMP | in ipoib_send()
/linux/drivers/infiniband/hw/mlx5/
A Dqp.c1230 send_cq ? get_ts_format(dev, send_cq, fr_sup, rt_sup) : in get_qp_ts_format()
2129 if (send_cq) in create_dci()
2332 if (send_cq) in create_user_qp()
2461 if (send_cq) in create_kernel_qp()
2478 if (send_cq) { in mlx5_ib_lock_cqs()
2508 if (send_cq) { in mlx5_ib_unlock_cqs()
2539 *send_cq = NULL; in get_cqs()
2603 get_cqs(qp->type, qp->ibqp.send_cq, qp->ibqp.recv_cq, &send_cq, in destroy_qp_common()
2610 if (send_cq) in destroy_qp_common()
4144 if (send_cq) in __mlx5_ib_modify_qp()
[all …]
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()
205 .send_cq = gsi->cq, in create_gsi_ud_qp()
A Dmem.c247 qp_init_attr.send_cq = cq; in mlx5_ib_test_wc()
/linux/drivers/infiniband/hw/mthca/
A Dmthca_qp.c1164 struct mthca_cq *send_cq, in mthca_alloc_qp_common() argument
1293 struct mthca_cq *send_cq, in mthca_alloc_qp() argument
1339 if (send_cq == recv_cq) { in mthca_lock_cqs()
1340 spin_lock_irq(&send_cq->lock); in mthca_lock_cqs()
1343 spin_lock_irq(&send_cq->lock); in mthca_lock_cqs()
1354 if (send_cq == recv_cq) { in mthca_unlock_cqs()
1361 spin_unlock(&send_cq->lock); in mthca_unlock_cqs()
1368 struct mthca_cq *send_cq, in mthca_alloc_sqp() argument
1448 struct mthca_cq *send_cq; in mthca_free_qp() local
1451 send_cq = to_mcq(qp->ibqp.send_cq); in mthca_free_qp()
[all …]
A Dmthca_dev.h535 struct mthca_cq *send_cq,
544 struct mthca_cq *send_cq,
/linux/include/rdma/
A Drdmavt_qp.h805 struct rvt_cq *cq = ibcq_to_rvtcq(qp->ibqp.send_cq); in rvt_send_cq()
920 static inline u32 ib_cq_tail(struct ib_cq *send_cq) in ib_cq_tail() argument
922 struct rvt_cq *cq = ibcq_to_rvtcq(send_cq); in ib_cq_tail()
924 return ibcq_to_rvtcq(send_cq)->ip ? in ib_cq_tail()
926 ibcq_to_rvtcq(send_cq)->kqueue->tail; in ib_cq_tail()
936 static inline u32 ib_cq_head(struct ib_cq *send_cq) in ib_cq_head() argument
938 struct rvt_cq *cq = ibcq_to_rvtcq(send_cq); in ib_cq_head()
940 return ibcq_to_rvtcq(send_cq)->ip ? in ib_cq_head()
942 ibcq_to_rvtcq(send_cq)->kqueue->head; in ib_cq_head()
/linux/drivers/infiniband/hw/mlx4/
A Dqp.c1266 if (send_cq == recv_cq) { in mlx4_ib_lock_cqs()
1267 spin_lock(&send_cq->lock); in mlx4_ib_lock_cqs()
1270 spin_lock(&send_cq->lock); in mlx4_ib_lock_cqs()
1281 if (send_cq == recv_cq) { in mlx4_ib_unlock_cqs()
1317 *recv_cq = *send_cq; in get_cqs()
1320 *send_cq = to_mcq(qp->ibqp.send_cq); in get_cqs()
1321 *recv_cq = *send_cq; in get_cqs()
1326 *send_cq = (src == MLX4_IB_QP_SRC) ? to_mcq(qp->ibqp.send_cq) : in get_cqs()
1408 if (send_cq != recv_cq) in destroy_qp_common()
2320 recv_cq = send_cq; in __mlx4_ib_modify_qp()
[all …]
/linux/fs/ksmbd/
A Dtransport_rdma.c103 struct ib_cq *send_cq; member
435 if (t->send_cq) in free_transport()
436 ib_free_cq(t->send_cq); in free_transport()
1818 t->send_cq = ib_alloc_cq(t->cm_id->device, t, in smb_direct_create_qpair()
1820 if (IS_ERR(t->send_cq)) { in smb_direct_create_qpair()
1822 ret = PTR_ERR(t->send_cq); in smb_direct_create_qpair()
1823 t->send_cq = NULL; in smb_direct_create_qpair()
1843 qp_attr.send_cq = t->send_cq; in smb_direct_create_qpair()
1866 if (t->send_cq) { in smb_direct_create_qpair()
1867 ib_destroy_cq(t->send_cq); in smb_direct_create_qpair()
[all …]
/linux/net/sunrpc/xprtrdma/
A Dverbs.c357 if (ep->re_attr.send_cq) in rpcrdma_ep_destroy()
358 ib_free_cq(ep->re_attr.send_cq); in rpcrdma_ep_destroy()
359 ep->re_attr.send_cq = NULL; in rpcrdma_ep_destroy()
434 ep->re_attr.send_cq = ib_alloc_cq_any(device, r_xprt, in rpcrdma_ep_create()
437 if (IS_ERR(ep->re_attr.send_cq)) { in rpcrdma_ep_create()
438 rc = PTR_ERR(ep->re_attr.send_cq); in rpcrdma_ep_create()
634 sc->sc_cid.ci_queue_id = ep->re_attr.send_cq->res.id; in rpcrdma_sendctx_create()
/linux/Documentation/translations/zh_CN/infiniband/
A Dtag_matching.rst39 1. Eager协议--当发送方处理完发送时，完整的信息就会被发送。在send_cq中会收到
/linux/drivers/net/ethernet/ibm/ehea/
A Dehea_main.c801 struct ehea_cq *send_cq = pr->send_cq; in ehea_proc_cqes() local
810 cqe = ehea_poll_cq(send_cq); in ehea_proc_cqes()
812 ehea_inc_cq(send_cq); in ehea_proc_cqes()
852 cqe = ehea_poll_cq(send_cq); in ehea_proc_cqes()
890 ehea_reset_cq_ep(pr->send_cq); in ehea_poll()
892 ehea_reset_cq_n1(pr->send_cq); in ehea_poll()
895 cqe_skb = ehea_poll_cq(pr->send_cq); in ehea_poll()
1477 if (!pr->send_cq) { in ehea_init_port_res()
1484 pr->send_cq->attr.act_nr_of_cqes, in ehea_init_port_res()
1559 ehea_destroy_cq(pr->send_cq); in ehea_init_port_res()
[all …]
/linux/drivers/infiniband/hw/vmw_pvrdma/
A Dpvrdma_qp.c58 static inline void get_cqs(struct pvrdma_qp *qp, struct pvrdma_cq **send_cq, in get_cqs() argument
61 *send_cq = to_vcq(qp->ibqp.send_cq); in get_cqs()
359 cmd->send_cq_handle = to_vcq(init_attr->send_cq)->cq_handle; in pvrdma_create_qp()
1042 init_attr->send_cq = qp->ibqp.send_cq; in pvrdma_query_qp()
/linux/fs/cifs/
A Dsmbdirect.c1391 ib_free_cq(info->send_cq); in smbd_destroy()
1578 info->send_cq = NULL; in _smbd_get_connection()
1580 info->send_cq = in _smbd_get_connection()
1583 if (IS_ERR(info->send_cq)) { in _smbd_get_connection()
1584 info->send_cq = NULL; in _smbd_get_connection()
1606 qp_attr.send_cq = info->send_cq; in _smbd_get_connection()
1722 if (info->send_cq) in _smbd_get_connection()
1723 ib_free_cq(info->send_cq); in _smbd_get_connection()
A Dsmbdirect.h59 struct ib_cq *send_cq, *recv_cq; member
/linux/drivers/infiniband/sw/rxe/
A Drxe_qp.c76 if (!init->recv_cq || !init->send_cq) { in rxe_qp_chk_init()
331 struct rxe_cq *scq = to_rcq(init->send_cq); in rxe_qp_from_init()
383 init->send_cq = qp->ibqp.send_cq; in rxe_qp_to_init()
/linux/drivers/infiniband/ulp/srp/
A Dib_srp.c521 ib_process_cq_direct(ch->send_cq, -1); in srp_destroy_qp()
534 struct ib_cq *recv_cq, *send_cq; in srp_create_ch_ib() local
554 if (IS_ERR(send_cq)) { in srp_create_ch_ib()
555 ret = PTR_ERR(send_cq); in srp_create_ch_ib()
566 init_attr->send_cq = send_cq; in srp_create_ch_ib()
604 if (ch->send_cq) in srp_create_ch_ib()
605 ib_free_cq(ch->send_cq); in srp_create_ch_ib()
609 ch->send_cq = send_cq; in srp_create_ch_ib()
627 ib_free_cq(send_cq); in srp_create_ch_ib()
672 ib_free_cq(ch->send_cq); in srp_free_ch_ib()
[all …]
A Dib_srp.h147 struct ib_cq *send_cq; member
/linux/drivers/infiniband/sw/siw/
A Dsiw_verbs.c345 if (!attrs->send_cq || (!attrs->recv_cq && !attrs->srq)) { in siw_create_qp()
396 qp->scq = to_siw_cq(attrs->send_cq); in siw_create_qp()
527 qp_init_attr->send_cq = base_qp->send_cq; in siw_query_qp()

Completed in 1003 milliseconds

123