Searched refs:send_cq (Results 1 - 25 of 48) sorted by relevance

12

/freebsd-11-stable/sys/ofed/drivers/infiniband/ulp/ipoib/
H A Dipoib_verbs.c173 priv->send_cq = ib_create_cq(priv->ca, ipoib_send_comp_handler, NULL,
175 if (IS_ERR(priv->send_cq)) {
196 init_attr.send_cq = priv->send_cq;
232 ib_destroy_cq(priv->send_cq);
255 if (ib_destroy_cq(priv->send_cq))
H A Dipoib_cm.c214 .send_cq = priv->recv_cq, /* For drain WR */
665 if (ib_req_notify_cq(priv->send_cq, IB_CQ_NEXT_COMP))
922 .send_cq = priv->send_cq,
H A Dipoib_ib.c372 n = ib_poll_cq(priv->send_cq, MAX_SEND_CQE, priv->send_wc);
539 if (ib_req_notify_cq(priv->send_cq, IB_CQ_NEXT_COMP))
/freebsd-11-stable/contrib/ofed/libmlx4/
H A Dverbs.c1031 if (qp->send_cq && qp->send_cq != qp->recv_cq)
1032 mlx4_cq_clean(to_mcq(qp->send_cq), qp->qp_num, NULL);
1044 struct mlx4_cq *send_cq = to_mcq(qp->send_cq); local
1047 if (!qp->send_cq || !qp->recv_cq) {
1048 if (qp->send_cq)
1049 pthread_spin_lock(&send_cq->lock);
1052 } else if (send_cq == recv_cq) {
1053 pthread_spin_lock(&send_cq
1065 struct mlx4_cq *send_cq = to_mcq(qp->send_cq); local
[all...]
/freebsd-11-stable/contrib/ofed/librdmacm/
H A Drdma_verbs.h259 ret = ibv_poll_cq(id->send_cq, 1, wc);
263 ret = ibv_req_notify_cq(id->send_cq, 0);
267 ret = ibv_poll_cq(id->send_cq, 1, wc);
275 assert(cq == id->send_cq && context == id);
276 ibv_ack_cq_events(id->send_cq, 1);
H A Dcma.c1208 if (id->send_cq && (id->send_cq != id->recv_cq)) {
1209 ibv_destroy_cq(id->send_cq);
1210 id->send_cq = NULL;
1243 id->send_cq = ibv_create_cq(id->verbs, send_size,
1245 if (!id->send_cq)
1344 (id->send_cq && attr->send_cq && id->send_cq != attr->send_cq))
[all...]
H A Drdma_cma.h132 struct ibv_cq *send_cq; member in struct:rdma_cm_id
/freebsd-11-stable/sys/dev/mthca/
H A Dmthca_qp.c719 qp_context->cqn_snd = cpu_to_be32(to_mcq(ibqp->send_cq)->cqn);
821 if (qp->ibqp.send_cq != qp->ibqp.recv_cq)
822 mthca_cq_clean(dev, to_mcq(qp->ibqp.send_cq), qp->qpn, NULL);
1143 struct mthca_cq *send_cq,
1271 struct mthca_cq *send_cq,
1298 err = mthca_alloc_qp_common(dev, pd, send_cq, recv_cq,
1313 static void mthca_lock_cqs(struct mthca_cq *send_cq, struct mthca_cq *recv_cq)
1314 __acquires(&send_cq->lock) __acquires(&recv_cq->lock)
1316 if (send_cq == recv_cq) {
1317 spin_lock_irq(&send_cq
1141 mthca_alloc_qp_common(struct mthca_dev *dev, struct mthca_pd *pd, struct mthca_cq *send_cq, struct mthca_cq *recv_cq, enum ib_sig_type send_policy, struct mthca_qp *qp) argument
1269 mthca_alloc_qp(struct mthca_dev *dev, struct mthca_pd *pd, struct mthca_cq *send_cq, struct mthca_cq *recv_cq, enum ib_qp_type type, enum ib_sig_type send_policy, struct ib_qp_cap *cap, struct mthca_qp *qp) argument
1343 mthca_alloc_sqp(struct mthca_dev *dev, struct mthca_pd *pd, struct mthca_cq *send_cq, struct mthca_cq *recv_cq, enum ib_sig_type send_policy, struct ib_qp_cap *cap, int qpn, int port, struct mthca_sqp *sqp) argument
1424 struct mthca_cq *send_cq; local
[all...]
H A Dmthca_dev.h547 struct mthca_cq *send_cq,
555 struct mthca_cq *send_cq,
/freebsd-11-stable/sys/dev/mlx5/mlx5_ib/
H A Dmlx5_ib_qp.c86 struct mlx5_ib_cq **send_cq, struct mlx5_ib_cq **recv_cq);
647 static void mlx5_ib_lock_cqs(struct mlx5_ib_cq *send_cq,
649 static void mlx5_ib_unlock_cqs(struct mlx5_ib_cq *send_cq,
1346 if (init_attr->create_flags || init_attr->send_cq)
1508 struct mlx5_ib_cq *send_cq; local
1683 scqe_sz = mlx5_ib_get_cqe_size(dev, init_attr->send_cq);
1733 if (init_attr->send_cq)
1734 MLX5_SET(qpc, qpc, cqn_snd, to_mcq(init_attr->send_cq)->mcq.cqn);
1770 get_cqs(init_attr->qp_type, init_attr->send_cq, init_attr->recv_cq,
1771 &send_cq,
1862 get_cqs(enum ib_qp_type qp_type, struct ib_cq *ib_send_cq, struct ib_cq *ib_recv_cq, struct mlx5_ib_cq **send_cq, struct mlx5_ib_cq **recv_cq) argument
1903 struct mlx5_ib_cq *send_cq, *recv_cq; local
2606 struct mlx5_ib_cq *send_cq, *recv_cq; local
[all...]
H A Dmlx5_ib_gsi.c70 struct ib_cq *gsi_cq = gsi->ibqp.send_cq;
176 hw_init_attr.send_cq = gsi->cq;
252 .send_cq = gsi->cq,
/freebsd-11-stable/sys/dev/mlx4/mlx4_ib/
H A Dmlx4_ib_qp.c54 static void mlx4_ib_lock_cqs(struct mlx4_ib_cq *send_cq,
56 static void mlx4_ib_unlock_cqs(struct mlx4_ib_cq *send_cq,
887 mlx4_ib_lock_cqs(to_mcq(init_attr->send_cq),
896 mcq = to_mcq(init_attr->send_cq);
900 mlx4_ib_unlock_cqs(to_mcq(init_attr->send_cq),
957 static void mlx4_ib_lock_cqs(struct mlx4_ib_cq *send_cq, struct mlx4_ib_cq *recv_cq)
958 __acquires(&send_cq->lock) __acquires(&recv_cq->lock)
960 if (send_cq == recv_cq) {
961 spin_lock(&send_cq->lock);
963 } else if (send_cq
1005 get_cqs(struct mlx4_ib_qp *qp, struct mlx4_ib_cq **send_cq, struct mlx4_ib_cq **recv_cq) argument
1027 struct mlx4_ib_cq *send_cq, *recv_cq; local
1626 struct mlx4_ib_cq *send_cq, *recv_cq; local
[all...]
/freebsd-11-stable/contrib/ofed/libmlx5/
H A Dverbs.c1429 struct mlx5_cq *send_cq = to_mcq(qp->send_cq); local
1432 if (send_cq && recv_cq) {
1433 if (send_cq == recv_cq) {
1434 mlx5_spin_lock(&send_cq->lock);
1435 } else if (send_cq->cqn < recv_cq->cqn) {
1436 mlx5_spin_lock(&send_cq->lock);
1440 mlx5_spin_lock(&send_cq->lock);
1442 } else if (send_cq) {
1443 mlx5_spin_lock(&send_cq
1451 struct mlx5_cq *send_cq = to_mcq(qp->send_cq); local
[all...]
/freebsd-11-stable/contrib/ofed/libibverbs/
H A Dcompat-1_0.c75 struct ibv_cq_1_0 *send_cq; member in struct:ibv_qp_init_attr_1_0
121 struct ibv_cq_1_0 *send_cq; member in struct:ibv_qp_1_0
878 real_init_attr.send_cq = qp_init_attr->send_cq->real_cq;
895 qp->send_cq = qp_init_attr->send_cq;
922 init_attr->send_cq = real_init_attr.send_cq->cq_context;
H A Dcmd.c863 /* send_cq is optinal */
865 cmd->send_cq_handle = qp_attr->send_cq->handle;
867 cmd->send_cq_handle = qp_attr->send_cq->handle;
910 qp->qp.send_cq = qp_attr->send_cq;
1046 cmd->send_cq_handle = attr->send_cq->handle;
1127 qp->qp.send_cq = NULL;
1220 init_attr->send_cq = qp->send_cq;
H A Dverbs.h775 struct ibv_cq *send_cq; member in struct:ibv_qp_init_attr
810 struct ibv_cq *send_cq; member in struct:ibv_qp_init_attr_ex
1042 struct ibv_cq *send_cq; member in struct:ibv_qp
H A Dverbs.c574 qp->send_cq = qp_init_attr->send_cq;
/freebsd-11-stable/contrib/ofed/libibverbs/examples/
H A Dxsrq_pingpong.c80 struct ibv_cq *send_cq; member in struct:pingpong_context
171 init.send_cq = ctx.send_cq;
288 ctx.send_cq = ibv_create_cq(ctx.context, ctx.num_clients, NULL, NULL, 0);
289 if (!ctx.send_cq) {
691 if (ibv_destroy_cq(ctx.send_cq)) {
994 ne = ibv_poll_cq(ctx.send_cq, 1, &wc);
H A Dud_pingpong.c370 .send_cq = ctx->cq,
H A Duc_pingpong.c359 .send_cq = ctx->cq,
/freebsd-11-stable/sys/ofed/drivers/infiniband/core/
H A Dib_verbs.c777 qp->send_cq = qp->recv_cq = NULL;
835 qp->send_cq = qp_init_attr->send_cq;
839 if (qp_init_attr->send_cq)
840 atomic_inc(&qp_init_attr->send_cq->usecnt);
1332 scq = qp->send_cq;
1988 if (qp->send_cq->poll_ctx == IB_POLL_DIRECT) {
1989 WARN_ONCE(qp->send_cq->poll_ctx == IB_POLL_DIRECT,
/freebsd-11-stable/contrib/libpcap/
H A Dpcap-rdmasniff.c230 qp_init_attr.send_cq = qp_init_attr.recv_cq = priv->cq;
/freebsd-11-stable/contrib/ofed/librdmacm/examples/
H A Dmckey.c158 init_qp_attr.send_cq = node->cq;
H A Dcmatose.c138 init_qp_attr.send_cq = node->cq[SEND_CQ_INDEX];
/freebsd-11-stable/sys/ofed/drivers/infiniband/ulp/sdp/
H A Dsdp_cma.c111 qp_init_attr.send_cq = ssk->tx_ring.cq;

Completed in 227 milliseconds

12