Home
last modified time | relevance | path

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

123

/freebsd/contrib/ofed/libmlx4/
H A Dverbs.c1044 if (qp->send_cq && qp->send_cq != qp->recv_cq) in mlx4_modify_qp()
1045 mlx4_cq_clean(to_mcq(qp->send_cq), qp->qp_num, NULL); in mlx4_modify_qp()
1057 struct mlx4_cq *send_cq = to_mcq(qp->send_cq); in mlx4_lock_cqs() local
1060 if (!qp->send_cq || !qp->recv_cq) { in mlx4_lock_cqs()
1061 if (qp->send_cq) in mlx4_lock_cqs()
1062 pthread_spin_lock(&send_cq->lock); in mlx4_lock_cqs()
1065 } else if (send_cq == recv_cq) { in mlx4_lock_cqs()
1066 pthread_spin_lock(&send_cq->lock); in mlx4_lock_cqs()
1067 } else if (send_cq->cqn < recv_cq->cqn) { in mlx4_lock_cqs()
1068 pthread_spin_lock(&send_cq->lock); in mlx4_lock_cqs()
[all …]
/freebsd/sys/ofed/drivers/infiniband/ulp/ipoib/
H A Dipoib_verbs.c174 priv->send_cq = ib_create_cq(priv->ca, ipoib_send_comp_handler, NULL, in ipoib_transport_dev_init()
176 if (IS_ERR(priv->send_cq)) { in ipoib_transport_dev_init()
197 init_attr.send_cq = priv->send_cq; in ipoib_transport_dev_init()
234 ib_destroy_cq(priv->send_cq); in ipoib_transport_dev_init()
257 ib_destroy_cq(priv->send_cq); in ipoib_transport_dev_cleanup()
H A Dipoib_cm.c214 .send_cq = priv->recv_cq, /* For drain WR */ in ipoib_cm_create_rx_qp()
669 if (ib_req_notify_cq(priv->send_cq, IB_CQ_NEXT_COMP)) in ipoib_cm_send()
929 .send_cq = priv->send_cq, in ipoib_cm_create_tx_qp()
H A Dipoib_ib.c374 n = ib_poll_cq(priv->send_cq, MAX_SEND_CQE, priv->send_wc); in ipoib_poll_tx()
541 if (ib_req_notify_cq(priv->send_cq, IB_CQ_NEXT_COMP)) in ipoib_send()
/freebsd/sys/dev/mthca/
H A Dmthca_qp.c723 qp_context->cqn_snd = cpu_to_be32(to_mcq(ibqp->send_cq)->cqn); in __mthca_modify_qp()
825 if (qp->ibqp.send_cq != qp->ibqp.recv_cq) in __mthca_modify_qp()
826 mthca_cq_clean(dev, to_mcq(qp->ibqp.send_cq), qp->qpn, NULL); in __mthca_modify_qp()
1147 struct mthca_cq *send_cq, in mthca_alloc_qp_common() argument
1275 struct mthca_cq *send_cq, in mthca_alloc_qp() argument
1303 err = mthca_alloc_qp_common(dev, pd, send_cq, recv_cq, in mthca_alloc_qp()
1318 static void mthca_lock_cqs(struct mthca_cq *send_cq, struct mthca_cq *recv_cq) in mthca_lock_cqs() argument
1319 __acquires(&send_cq->lock) __acquires(&recv_cq->lock) in mthca_lock_cqs()
1321 if (send_cq == recv_cq) { in mthca_lock_cqs()
1322 spin_lock_irq(&send_cq->lock); in mthca_lock_cqs()
[all …]
H A Dmthca_dev.h548 struct mthca_cq *send_cq,
557 struct mthca_cq *send_cq,
/freebsd/sys/dev/mlx5/mlx5_ib/
H A Dmlx5_ib_qp.c88 struct mlx5_ib_cq **send_cq, struct mlx5_ib_cq **recv_cq);
612 static void mlx5_ib_lock_cqs(struct mlx5_ib_cq *send_cq,
614 static void mlx5_ib_unlock_cqs(struct mlx5_ib_cq *send_cq,
1385 if (init_attr->create_flags || init_attr->send_cq) in create_rss_raw_qp_tir()
1594 struct mlx5_ib_cq *send_cq; in create_qp_common() local
1769 scqe_sz = mlx5_ib_get_cqe_size(dev, init_attr->send_cq); in create_qp_common()
1822 if (init_attr->send_cq) in create_qp_common()
1823 MLX5_SET(qpc, qpc, cqn_snd, to_mcq(init_attr->send_cq)->mcq.cqn); in create_qp_common()
1859 get_cqs(init_attr->qp_type, init_attr->send_cq, init_attr->recv_cq, in create_qp_common()
1860 &send_cq, &recv_cq); in create_qp_common()
[all …]
H A Dmlx5_ib_gsi.c71 struct ib_cq *gsi_cq = gsi->ibqp.send_cq; in generate_completions()
177 hw_init_attr.send_cq = gsi->cq; in mlx5_ib_gsi_create_qp()
253 .send_cq = gsi->cq, in create_gsi_ud_qp()
/freebsd/contrib/ofed/librdmacm/
H A Drdma_verbs.h259 ret = ibv_poll_cq(id->send_cq, 1, wc); in rdma_get_send_comp()
263 ret = ibv_req_notify_cq(id->send_cq, 0); in rdma_get_send_comp()
267 ret = ibv_poll_cq(id->send_cq, 1, wc); in rdma_get_send_comp()
275 assert(cq == id->send_cq && context == id); in rdma_get_send_comp()
276 ibv_ack_cq_events(id->send_cq, 1); in rdma_get_send_comp()
H A Dcma.c1209 if (id->send_cq && (id->send_cq != id->recv_cq)) { in ucma_destroy_cqs()
1210 ibv_destroy_cq(id->send_cq); in ucma_destroy_cqs()
1211 id->send_cq = NULL; in ucma_destroy_cqs()
1244 id->send_cq = ibv_create_cq(id->verbs, send_size, in ucma_create_cqs()
1246 if (!id->send_cq) in ucma_create_cqs()
1345 (id->send_cq && attr->send_cq && id->send_cq != attr->send_cq)) in rdma_create_qp_ex()
1357 ret = ucma_create_cqs(id, attr->send_cq || id->send_cq ? 0 : attr->cap.max_send_wr, in rdma_create_qp_ex()
1362 if (!attr->send_cq) in rdma_create_qp_ex()
1363 attr->send_cq = id->send_cq; in rdma_create_qp_ex()
H A Drdma_cma.h132 struct ibv_cq *send_cq; member
/freebsd/contrib/ofed/libmlx5/
H A Dverbs.c1453 struct mlx5_cq *send_cq = to_mcq(qp->send_cq); in mlx5_lock_cqs() local
1456 if (send_cq && recv_cq) { in mlx5_lock_cqs()
1457 if (send_cq == recv_cq) { in mlx5_lock_cqs()
1458 mlx5_spin_lock(&send_cq->lock); in mlx5_lock_cqs()
1459 } else if (send_cq->cqn < recv_cq->cqn) { in mlx5_lock_cqs()
1460 mlx5_spin_lock(&send_cq->lock); in mlx5_lock_cqs()
1464 mlx5_spin_lock(&send_cq->lock); in mlx5_lock_cqs()
1466 } else if (send_cq) { in mlx5_lock_cqs()
1467 mlx5_spin_lock(&send_cq in mlx5_lock_cqs()
1475 struct mlx5_cq *send_cq = to_mcq(qp->send_cq); mlx5_unlock_cqs() local
[all...]
/freebsd/sys/dev/mlx4/mlx4_ib/
H A Dmlx4_ib_qp.c55 static void mlx4_ib_lock_cqs(struct mlx4_ib_cq *send_cq,
57 static void mlx4_ib_unlock_cqs(struct mlx4_ib_cq *send_cq,
888 mlx4_ib_lock_cqs(to_mcq(init_attr->send_cq), in create_qp_common()
897 mcq = to_mcq(init_attr->send_cq); in create_qp_common()
901 mlx4_ib_unlock_cqs(to_mcq(init_attr->send_cq), in create_qp_common()
958 static void mlx4_ib_lock_cqs(struct mlx4_ib_cq *send_cq, struct mlx4_ib_cq *recv_cq) in mlx4_ib_lock_cqs() argument
959 __acquires(&send_cq->lock) __acquires(&recv_cq->lock) in mlx4_ib_lock_cqs()
961 if (send_cq == recv_cq) { in mlx4_ib_lock_cqs()
962 spin_lock(&send_cq->lock); in mlx4_ib_lock_cqs()
964 } else if (send_cq->mcq.cqn < recv_cq->mcq.cqn) { in mlx4_ib_lock_cqs()
[all …]
/freebsd/contrib/ofed/libibverbs/
H A Dcompat-1_0.c75 struct ibv_cq_1_0 *send_cq; member
121 struct ibv_cq_1_0 *send_cq; member
878 real_init_attr.send_cq = qp_init_attr->send_cq->real_cq; in __ibv_create_qp_1_0()
895 qp->send_cq = qp_init_attr->send_cq; in __ibv_create_qp_1_0()
922 init_attr->send_cq = real_init_attr.send_cq->cq_context; in __ibv_query_qp_1_0()
H A Dcmd.c882 cmd->send_cq_handle = qp_attr->send_cq->handle; in create_qp_ex_common()
884 cmd->send_cq_handle = qp_attr->send_cq->handle; in create_qp_ex_common()
952 qp->qp.send_cq = qp_attr->send_cq; in create_qp_handle_resp_common()
1109 cmd->send_cq_handle = attr->send_cq->handle; in ibv_cmd_create_qp()
1201 qp->qp.send_cq = NULL; in ibv_cmd_open_qp()
1299 init_attr->send_cq = qp->send_cq; in ibv_cmd_query_qp()
H A Dverbs.h775 struct ibv_cq *send_cq; member
810 struct ibv_cq *send_cq; member
1042 struct ibv_cq *send_cq; member
H A Dverbs.c596 qp->send_cq = qp_init_attr->send_cq; in __ibv_create_qp()
/freebsd/sys/ofed/drivers/infiniband/core/
H A Dcore_priv.h170 qp->send_cq = attr->send_cq; in _ib_create_qp()
H A Dib_verbs.c860 qp->send_cq = qp->recv_cq = NULL; in ib_create_xrc_qp()
918 qp->send_cq = qp_init_attr->send_cq; in ib_create_qp()
922 if (qp_init_attr->send_cq) in ib_create_qp()
923 atomic_inc(&qp_init_attr->send_cq->usecnt); in ib_create_qp()
1501 scq = qp->send_cq; in ib_destroy_qp_user()
2158 if (qp->send_cq->poll_ctx == IB_POLL_DIRECT) { in __ib_drain_sq()
2159 WARN_ONCE(qp->send_cq->poll_ctx == IB_POLL_DIRECT, in __ib_drain_sq()
/freebsd/contrib/ofed/libibverbs/examples/
H A Dxsrq_pingpong.c80 struct ibv_cq *send_cq; member
171 init.send_cq = ctx.send_cq; in create_qps()
288 ctx.send_cq = ibv_create_cq(ctx.context, ctx.num_clients, NULL, NULL, 0); in pp_init_ctx()
289 if (!ctx.send_cq) { in pp_init_ctx()
695 if (ibv_destroy_cq(ctx.send_cq)) { in pp_close_ctx()
998 ne = ibv_poll_cq(ctx.send_cq, 1, &wc); in main()
/freebsd/contrib/ofed/libirdma/
H A Dirdma_umain.h130 struct irdma_ucq *send_cq; member
H A Dirdma_uverbs.c1336 iwuqp->send_cq = container_of(attr->send_cq, struct irdma_ucq, in irdma_vmapped_qp()
1340 iwuqp->send_cq->uqp = iwuqp; in irdma_vmapped_qp()
1617 if (iwuqp->send_cq) in irdma_udestroy_qp()
1618 irdma_clean_cqes(&iwuqp->qp, iwuqp->send_cq); in irdma_udestroy_qp()
1620 if (iwuqp->recv_cq && iwuqp->recv_cq != iwuqp->send_cq) in irdma_udestroy_qp()
/freebsd/sys/dev/qlnx/qlnxr/
H A Dqlnxr_cm.c47 dev->gsi_sqcq = get_qlnxr_cq((attrs->send_cq)); in qlnxr_store_gsi_qp_cq()
167 cq = get_qlnxr_cq((attrs->send_cq)); in qlnxr_destroy_gsi_cq()
/freebsd/contrib/libpcap/
H A Dpcap-rdmasniff.c244 qp_init_attr.send_cq = qp_init_attr.recv_cq = priv->cq; in rdmasniff_activate()
/freebsd/sys/ofed/drivers/infiniband/ulp/sdp/
H A Dsdp_cma.c118 qp_init_attr.send_cq = ssk->tx_ring.cq; in sdp_init_qp()

123