/freebsd-12-stable/sys/ofed/drivers/infiniband/ulp/ipoib/ |
H A D | ipoib_verbs.c | 175 priv->send_cq = ib_create_cq(priv->ca, ipoib_send_comp_handler, NULL, 177 if (IS_ERR(priv->send_cq)) { 198 init_attr.send_cq = priv->send_cq; 234 ib_destroy_cq(priv->send_cq); 257 if (ib_destroy_cq(priv->send_cq))
|
H A D | ipoib_cm.c | 216 .send_cq = priv->recv_cq, /* For drain WR */ 671 if (ib_req_notify_cq(priv->send_cq, IB_CQ_NEXT_COMP)) 928 .send_cq = priv->send_cq,
|
H A D | ipoib_ib.c | 376 n = ib_poll_cq(priv->send_cq, MAX_SEND_CQE, priv->send_wc); 543 if (ib_req_notify_cq(priv->send_cq, IB_CQ_NEXT_COMP))
|
/freebsd-12-stable/contrib/ofed/libmlx4/ |
H A D | verbs.c | 1031 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-12-stable/contrib/ofed/librdmacm/ |
H A D | rdma_verbs.h | 259 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 D | cma.c | 1208 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 D | rdma_cma.h | 132 struct ibv_cq *send_cq; member in struct:rdma_cm_id
|
/freebsd-12-stable/sys/dev/mthca/ |
H A D | mthca_qp.c | 719 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 D | mthca_dev.h | 547 struct mthca_cq *send_cq, 555 struct mthca_cq *send_cq,
|
/freebsd-12-stable/sys/dev/mlx5/mlx5_ib/ |
H A D | mlx5_ib_qp.c | 86 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 D | mlx5_ib_gsi.c | 70 struct ib_cq *gsi_cq = gsi->ibqp.send_cq; 176 hw_init_attr.send_cq = gsi->cq; 252 .send_cq = gsi->cq,
|
/freebsd-12-stable/sys/dev/mlx4/mlx4_ib/ |
H A D | mlx4_ib_qp.c | 54 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-12-stable/contrib/ofed/libmlx5/ |
H A D | verbs.c | 1429 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-12-stable/contrib/ofed/libibverbs/ |
H A D | compat-1_0.c | 75 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 D | cmd.c | 863 /* 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 D | verbs.h | 775 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 D | verbs.c | 574 qp->send_cq = qp_init_attr->send_cq;
|
/freebsd-12-stable/contrib/ofed/libibverbs/examples/ |
H A D | xsrq_pingpong.c | 80 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 D | uc_pingpong.c | 359 .send_cq = ctx->cq,
|
/freebsd-12-stable/sys/ofed/drivers/infiniband/core/ |
H A D | ib_verbs.c | 777 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-12-stable/contrib/ofed/librdmacm/examples/ |
H A D | mckey.c | 158 init_qp_attr.send_cq = node->cq;
|
/freebsd-12-stable/contrib/libpcap/ |
H A D | pcap-rdmasniff.c | 230 qp_init_attr.send_cq = qp_init_attr.recv_cq = priv->cq;
|
/freebsd-12-stable/sys/ofed/drivers/infiniband/ulp/sdp/ |
H A D | sdp_cma.c | 113 qp_init_attr.send_cq = ssk->tx_ring.cq;
|
/freebsd-12-stable/contrib/ofed/libcxgb4/ |
H A D | cq.c | 99 struct c4iw_cq *chp = to_c4iw_cq(qhp->ibv_qp.send_cq);
|
H A D | qp.c | 513 schp = to_c4iw_cq(qhp->ibv_qp.send_cq);
|