| /drivers/infiniband/hw/ipath/ |
| D | ipath_ruc.c | 260 static void ipath_ruc_loopback(struct ipath_qp *sqp) in ipath_ruc_loopback() argument
262 struct ipath_ibdev *dev = to_idev(sqp->ibqp.device); in ipath_ruc_loopback()
276 qp = ipath_lookup_qpn(&dev->qp_table, sqp->remote_qpn); in ipath_ruc_loopback()
278 spin_lock_irqsave(&sqp->s_lock, flags); in ipath_ruc_loopback()
281 if ((sqp->s_flags & (IPATH_S_BUSY | IPATH_S_ANY_WAIT)) || in ipath_ruc_loopback()
282 !(ib_ipath_state_ops[sqp->state] & IPATH_PROCESS_OR_FLUSH_SEND)) in ipath_ruc_loopback()
285 sqp->s_flags |= IPATH_S_BUSY; in ipath_ruc_loopback()
288 if (sqp->s_last == sqp->s_head) in ipath_ruc_loopback()
290 wqe = get_swqe_ptr(sqp, sqp->s_last); in ipath_ruc_loopback()
293 if (!(ib_ipath_state_ops[sqp->state] & IPATH_PROCESS_NEXT_SEND_OK)) { in ipath_ruc_loopback()
[all …]
|
| D | ipath_ud.c | 50 static void ipath_ud_loopback(struct ipath_qp *sqp, struct ipath_swqe *swqe) in ipath_ud_loopback() argument
52 struct ipath_ibdev *dev = to_idev(sqp->ibqp.device); in ipath_ud_loopback()
81 sqp->qkey : swqe->wr.wr.ud.remote_qkey) != qp->qkey)) { in ipath_ud_loopback()
216 wc.src_qp = sqp->ibqp.qp_num; in ipath_ud_loopback()
|
| /drivers/infiniband/hw/qib/ |
| D | qib_ruc.c | 355 static void qib_ruc_loopback(struct qib_qp *sqp) in qib_ruc_loopback() argument
357 struct qib_ibport *ibp = to_iport(sqp->ibqp.device, sqp->port_num); in qib_ruc_loopback()
373 qp = qib_lookup_qpn(ibp, sqp->remote_qpn); in qib_ruc_loopback()
375 spin_lock_irqsave(&sqp->s_lock, flags); in qib_ruc_loopback()
378 if ((sqp->s_flags & (QIB_S_BUSY | QIB_S_ANY_WAIT)) || in qib_ruc_loopback()
379 !(ib_qib_state_ops[sqp->state] & QIB_PROCESS_OR_FLUSH_SEND)) in qib_ruc_loopback()
382 sqp->s_flags |= QIB_S_BUSY; in qib_ruc_loopback()
385 if (sqp->s_last == sqp->s_head) in qib_ruc_loopback()
387 wqe = get_swqe_ptr(sqp, sqp->s_last); in qib_ruc_loopback()
390 if (!(ib_qib_state_ops[sqp->state] & QIB_PROCESS_NEXT_SEND_OK)) { in qib_ruc_loopback()
[all …]
|
| D | qib_ud.c | 49 static void qib_ud_loopback(struct qib_qp *sqp, struct qib_swqe *swqe) in qib_ud_loopback() argument
51 struct qib_ibport *ibp = to_iport(sqp->ibqp.device, sqp->port_num); in qib_ud_loopback()
66 if (qp->ibqp.qp_type != sqp->ibqp.qp_type || in qib_ud_loopback()
80 pkey1 = qib_get_pkey(ibp, sqp->s_pkey_index); in qib_ud_loopback()
87 sqp->ibqp.qp_num, qp->ibqp.qp_num, in qib_ud_loopback()
103 sqp->qkey : swqe->wr.wr.ud.remote_qkey; in qib_ud_loopback()
111 sqp->ibqp.qp_num, qp->ibqp.qp_num, in qib_ud_loopback()
204 wc.src_qp = sqp->ibqp.qp_num; in qib_ud_loopback()
|
| /drivers/infiniband/hw/mlx4/ |
| D | qp.c | 602 struct mlx4_ib_sqp *sqp; in create_qp_common() local
646 sqp = kzalloc(sizeof (struct mlx4_ib_sqp), GFP_KERNEL); in create_qp_common()
647 if (!sqp) in create_qp_common()
649 qp = &sqp->qp; in create_qp_common()
1131 static void store_sqp_attrs(struct mlx4_ib_sqp *sqp, const struct ib_qp_attr *attr, in store_sqp_attrs() argument
1135 sqp->pkey_index = attr->pkey_index; in store_sqp_attrs()
1137 sqp->qkey = attr->qkey; in store_sqp_attrs()
1139 sqp->send_psn = attr->sq_psn; in store_sqp_attrs()
1634 static int build_sriov_qp0_header(struct mlx4_ib_sqp *sqp, in build_sriov_qp0_header() argument
1638 struct mlx4_ib_dev *mdev = to_mdev(sqp->qp.ibqp.device); in build_sriov_qp0_header()
[all …]
|
| D | mad.c | 1085 struct mlx4_ib_demux_pv_qp *sqp; in mlx4_ib_send_to_wire() local
1108 sqp = &sqp_ctx->qp[0]; in mlx4_ib_send_to_wire()
1112 sqp = &sqp_ctx->qp[1]; in mlx4_ib_send_to_wire()
1116 send_qp = sqp->qp; in mlx4_ib_send_to_wire()
1128 spin_lock(&sqp->tx_lock); in mlx4_ib_send_to_wire()
1129 if (sqp->tx_ix_head - sqp->tx_ix_tail >= in mlx4_ib_send_to_wire()
1133 wire_tx_ix = (++sqp->tx_ix_head) & (MLX4_NUM_TUNNEL_BUFS - 1); in mlx4_ib_send_to_wire()
1134 spin_unlock(&sqp->tx_lock); in mlx4_ib_send_to_wire()
1138 sqp_mad = (struct mlx4_mad_snd_buf *) (sqp->tx_ring[wire_tx_ix].buf.addr); in mlx4_ib_send_to_wire()
1139 if (sqp->tx_ring[wire_tx_ix].ah) in mlx4_ib_send_to_wire()
[all …]
|
| /drivers/infiniband/hw/mthca/ |
| D | mthca_qp.c | 298 static void store_attrs(struct mthca_sqp *sqp, const struct ib_qp_attr *attr, in store_attrs() argument
302 sqp->pkey_index = attr->pkey_index; in store_attrs()
304 sqp->qkey = attr->qkey; in store_attrs()
306 sqp->send_psn = attr->sq_psn; in store_attrs()
1350 struct mthca_sqp *sqp) in mthca_alloc_sqp() argument
1355 sqp->qp.transport = MLX; in mthca_alloc_sqp()
1356 err = mthca_set_qp_size(dev, cap, pd, &sqp->qp); in mthca_alloc_sqp()
1360 sqp->header_buf_size = sqp->qp.sq.max * MTHCA_UD_HEADER_SIZE; in mthca_alloc_sqp()
1361 sqp->header_buf = dma_alloc_coherent(&dev->pdev->dev, sqp->header_buf_size, in mthca_alloc_sqp()
1362 &sqp->header_dma, GFP_KERNEL); in mthca_alloc_sqp()
[all …]
|
| D | mthca_dev.h | 559 struct mthca_sqp *sqp);
|
| /drivers/infiniband/hw/cxgb3/ |
| D | cxio_hal.c | 387 struct t3_swsq *sqp) in insert_sq_cqe() argument
395 V_CQE_OPCODE(sqp->opcode) | in insert_sq_cqe()
401 cqe.u.scqe.wrid_hi = sqp->sq_wptr; in insert_sq_cqe()
411 struct t3_swsq *sqp = wq->sq + Q_PTR2IDX(wq->sq_rptr, wq->sq_size_log2); in cxio_flush_sq() local
414 sqp = wq->sq + Q_PTR2IDX(ptr, wq->sq_size_log2); in cxio_flush_sq()
416 sqp->signaled = 0; in cxio_flush_sq()
417 insert_sq_cqe(wq, cq, sqp); in cxio_flush_sq()
419 sqp = wq->sq + Q_PTR2IDX(ptr, wq->sq_size_log2); in cxio_flush_sq()
1077 struct t3_swsq *sqp; in flush_completed_wrs() local
1081 sqp = wq->sq + Q_PTR2IDX(ptr, wq->sq_size_log2); in flush_completed_wrs()
[all …]
|
| D | iwch_qp.c | 362 struct t3_swsq *sqp; in iwch_post_send() local
391 sqp = qhp->wq.sq + in iwch_post_send()
413 sqp->read_len = wqe->read.local_len; in iwch_post_send()
415 qhp->wq.oldest_read = sqp; in iwch_post_send()
436 sqp->wr_id = wr->wr_id; in iwch_post_send()
437 sqp->opcode = wr2opcode(t3_wr_opcode); in iwch_post_send()
438 sqp->sq_wptr = qhp->wq.sq_wptr; in iwch_post_send()
439 sqp->complete = 0; in iwch_post_send()
440 sqp->signaled = (wr->send_flags & IB_SEND_SIGNALED); in iwch_post_send()
449 sqp->opcode); in iwch_post_send()
[all …]
|
| /drivers/infiniband/hw/ehca/ |
| D | ehca_qp.c | 1843 void ehca_recover_sqp(struct ib_qp *sqp) in ehca_recover_sqp() argument
1845 struct ehca_qp *my_sqp = container_of(sqp, struct ehca_qp, ib_qp); in ehca_recover_sqp()
1854 ehca_dbg(sqp->device, "SQP port=%x qp_num=%x", port, sqp->qp_num); in ehca_recover_sqp()
1860 ret = internal_modify_qp(sqp, &attr, qp_parm[i].mask, 0); in ehca_recover_sqp()
1862 ehca_err(sqp->device, "Could not modify SQP port=%x " in ehca_recover_sqp()
1863 "qp_num=%x ret=%x", port, sqp->qp_num, ret); in ehca_recover_sqp()
1866 ehca_dbg(sqp->device, "SQP port=%x qp_num=%x in state=%x", in ehca_recover_sqp()
1867 port, sqp->qp_num, attr.qp_state); in ehca_recover_sqp()
1877 ehca_dbg(sqp->device, "doorbell port=%x qp_num=%x wr_cnt=%lx", in ehca_recover_sqp()
1878 port, sqp->qp_num, wr_cnt); in ehca_recover_sqp()
|
| D | ehca_iverbs.h | 210 void ehca_recover_sqp(struct ib_qp *sqp);
|