Home
last modified time | relevance | path

Searched refs:sqp (Results 1 – 14 of 14) sorted by relevance

/drivers/staging/rdma/ipath/
Dipath_ruc.c259 static void ipath_ruc_loopback(struct ipath_qp *sqp) in ipath_ruc_loopback() argument
261 struct ipath_ibdev *dev = to_idev(sqp->ibqp.device); in ipath_ruc_loopback()
275 qp = ipath_lookup_qpn(&dev->qp_table, sqp->remote_qpn); in ipath_ruc_loopback()
277 spin_lock_irqsave(&sqp->s_lock, flags); in ipath_ruc_loopback()
280 if ((sqp->s_flags & (IPATH_S_BUSY | IPATH_S_ANY_WAIT)) || in ipath_ruc_loopback()
281 !(ib_ipath_state_ops[sqp->state] & IPATH_PROCESS_OR_FLUSH_SEND)) in ipath_ruc_loopback()
284 sqp->s_flags |= IPATH_S_BUSY; in ipath_ruc_loopback()
287 if (sqp->s_last == sqp->s_head) in ipath_ruc_loopback()
289 wqe = get_swqe_ptr(sqp, sqp->s_last); in ipath_ruc_loopback()
292 if (!(ib_ipath_state_ops[sqp->state] & IPATH_PROCESS_NEXT_SEND_OK)) { in ipath_ruc_loopback()
[all …]
Dipath_ud.c49 static void ipath_ud_loopback(struct ipath_qp *sqp, struct ipath_swqe *swqe) in ipath_ud_loopback() argument
51 struct ipath_ibdev *dev = to_idev(sqp->ibqp.device); in ipath_ud_loopback()
80 sqp->qkey : swqe->ud_wr.remote_qkey) != qp->qkey)) { in ipath_ud_loopback()
215 wc.src_qp = sqp->ibqp.qp_num; in ipath_ud_loopback()
/drivers/infiniband/hw/qib/
Dqib_ruc.c356 static void qib_ruc_loopback(struct qib_qp *sqp) in qib_ruc_loopback() argument
358 struct qib_ibport *ibp = to_iport(sqp->ibqp.device, sqp->port_num); in qib_ruc_loopback()
374 qp = qib_lookup_qpn(ibp, sqp->remote_qpn); in qib_ruc_loopback()
376 spin_lock_irqsave(&sqp->s_lock, flags); in qib_ruc_loopback()
379 if ((sqp->s_flags & (QIB_S_BUSY | QIB_S_ANY_WAIT)) || in qib_ruc_loopback()
380 !(ib_qib_state_ops[sqp->state] & QIB_PROCESS_OR_FLUSH_SEND)) in qib_ruc_loopback()
383 sqp->s_flags |= QIB_S_BUSY; in qib_ruc_loopback()
386 if (sqp->s_last == sqp->s_head) in qib_ruc_loopback()
388 wqe = get_swqe_ptr(sqp, sqp->s_last); in qib_ruc_loopback()
391 if (!(ib_qib_state_ops[sqp->state] & QIB_PROCESS_NEXT_SEND_OK)) { in qib_ruc_loopback()
[all …]
Dqib_ud.c49 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()
68 sqptype = sqp->ibqp.qp_type == IB_QPT_GSI ? in qib_ud_loopback()
69 IB_QPT_UD : sqp->ibqp.qp_type; in qib_ud_loopback()
87 pkey1 = qib_get_pkey(ibp, sqp->s_pkey_index); in qib_ud_loopback()
94 sqp->ibqp.qp_num, qp->ibqp.qp_num, in qib_ud_loopback()
110 sqp->qkey : swqe->ud_wr.remote_qkey; in qib_ud_loopback()
118 sqp->ibqp.qp_num, qp->ibqp.qp_num, in qib_ud_loopback()
211 wc.src_qp = sqp->ibqp.qp_num; in qib_ud_loopback()
/drivers/staging/rdma/hfi1/
Druc.c376 static void ruc_loopback(struct hfi1_qp *sqp) in ruc_loopback() argument
378 struct hfi1_ibport *ibp = to_iport(sqp->ibqp.device, sqp->port_num); in ruc_loopback()
396 qp = hfi1_lookup_qpn(ibp, sqp->remote_qpn); in ruc_loopback()
398 spin_lock_irqsave(&sqp->s_lock, flags); in ruc_loopback()
401 if ((sqp->s_flags & (HFI1_S_BUSY | HFI1_S_ANY_WAIT)) || in ruc_loopback()
402 !(ib_hfi1_state_ops[sqp->state] & HFI1_PROCESS_OR_FLUSH_SEND)) in ruc_loopback()
405 sqp->s_flags |= HFI1_S_BUSY; in ruc_loopback()
408 if (sqp->s_last == sqp->s_head) in ruc_loopback()
410 wqe = get_swqe_ptr(sqp, sqp->s_last); in ruc_loopback()
413 if (!(ib_hfi1_state_ops[sqp->state] & HFI1_PROCESS_NEXT_SEND_OK)) { in ruc_loopback()
[all …]
Dud.c68 static void ud_loopback(struct hfi1_qp *sqp, struct hfi1_swqe *swqe) in ud_loopback() argument
70 struct hfi1_ibport *ibp = to_iport(sqp->ibqp.device, sqp->port_num); in ud_loopback()
90 sqptype = sqp->ibqp.qp_type == IB_QPT_GSI ? in ud_loopback()
91 IB_QPT_UD : sqp->ibqp.qp_type; in ud_loopback()
109 pkey = hfi1_get_pkey(ibp, sqp->s_pkey_index); in ud_loopback()
116 sqp->ibqp.qp_num, qp->ibqp.qp_num, in ud_loopback()
132 sqp->qkey : swqe->ud_wr.remote_qkey; in ud_loopback()
140 sqp->ibqp.qp_num, qp->ibqp.qp_num, in ud_loopback()
233 wc.src_qp = sqp->ibqp.qp_num; in ud_loopback()
235 if (sqp->ibqp.qp_type == IB_QPT_GSI || in ud_loopback()
[all …]
/drivers/infiniband/hw/mlx4/
Dqp.c640 struct mlx4_ib_sqp *sqp; in create_qp_common() local
691 sqp = kzalloc(sizeof (struct mlx4_ib_sqp), gfp); in create_qp_common()
692 if (!sqp) in create_qp_common()
694 qp = &sqp->qp; in create_qp_common()
1287 static void store_sqp_attrs(struct mlx4_ib_sqp *sqp, const struct ib_qp_attr *attr, in store_sqp_attrs() argument
1291 sqp->pkey_index = attr->pkey_index; in store_sqp_attrs()
1293 sqp->qkey = attr->qkey; in store_sqp_attrs()
1295 sqp->send_psn = attr->sq_psn; in store_sqp_attrs()
2147 static int build_sriov_qp0_header(struct mlx4_ib_sqp *sqp, in build_sriov_qp0_header() argument
2151 struct mlx4_ib_dev *mdev = to_mdev(sqp->qp.ibqp.device); in build_sriov_qp0_header()
[all …]
Dmad.c1220 struct mlx4_ib_demux_pv_qp *sqp; in mlx4_ib_send_to_wire() local
1239 sqp = &sqp_ctx->qp[0]; in mlx4_ib_send_to_wire()
1243 sqp = &sqp_ctx->qp[1]; in mlx4_ib_send_to_wire()
1247 send_qp = sqp->qp; in mlx4_ib_send_to_wire()
1259 spin_lock(&sqp->tx_lock); in mlx4_ib_send_to_wire()
1260 if (sqp->tx_ix_head - sqp->tx_ix_tail >= in mlx4_ib_send_to_wire()
1264 wire_tx_ix = (++sqp->tx_ix_head) & (MLX4_NUM_TUNNEL_BUFS - 1); in mlx4_ib_send_to_wire()
1265 spin_unlock(&sqp->tx_lock); in mlx4_ib_send_to_wire()
1269 sqp_mad = (struct mlx4_mad_snd_buf *) (sqp->tx_ring[wire_tx_ix].buf.addr); in mlx4_ib_send_to_wire()
1270 if (sqp->tx_ring[wire_tx_ix].ah) in mlx4_ib_send_to_wire()
[all …]
/drivers/infiniband/hw/mthca/
Dmthca_qp.c298 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()
1351 struct mthca_sqp *sqp) in mthca_alloc_sqp() argument
1356 sqp->qp.transport = MLX; in mthca_alloc_sqp()
1357 err = mthca_set_qp_size(dev, cap, pd, &sqp->qp); in mthca_alloc_sqp()
1361 sqp->header_buf_size = sqp->qp.sq.max * MTHCA_UD_HEADER_SIZE; in mthca_alloc_sqp()
1362 sqp->header_buf = dma_alloc_coherent(&dev->pdev->dev, sqp->header_buf_size, in mthca_alloc_sqp()
1363 &sqp->header_dma, GFP_KERNEL); in mthca_alloc_sqp()
[all …]
Dmthca_dev.h558 struct mthca_sqp *sqp);
/drivers/infiniband/hw/cxgb3/
Dcxio_hal.c387 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()
1075 struct t3_swsq *sqp; in flush_completed_wrs() local
1079 sqp = wq->sq + Q_PTR2IDX(ptr, wq->sq_size_log2); in flush_completed_wrs()
[all …]
Diwch_qp.c363 struct t3_swsq *sqp; in iwch_post_send() local
392 sqp = qhp->wq.sq + in iwch_post_send()
414 sqp->read_len = wqe->read.local_len; in iwch_post_send()
416 qhp->wq.oldest_read = sqp; in iwch_post_send()
437 sqp->wr_id = wr->wr_id; in iwch_post_send()
438 sqp->opcode = wr2opcode(t3_wr_opcode); in iwch_post_send()
439 sqp->sq_wptr = qhp->wq.sq_wptr; in iwch_post_send()
440 sqp->complete = 0; in iwch_post_send()
441 sqp->signaled = (wr->send_flags & IB_SEND_SIGNALED); in iwch_post_send()
450 sqp->opcode); in iwch_post_send()
[all …]
/drivers/staging/rdma/ehca/
Dehca_qp.c1843 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()
Dehca_iverbs.h216 void ehca_recover_sqp(struct ib_qp *sqp);