Lines Matching refs:wqe
81 static int qib_init_sge(struct qib_qp *qp, struct qib_rwqe *wqe)
94 for (i = j = 0; i < wqe->num_sge; i++) {
95 if (wqe->sg_list[i].length == 0)
99 &wqe->sg_list[i], IB_ACCESS_LOCAL_WRITE))
101 qp->r_len += wqe->sg_list[i].length;
117 wc.wr_id = wqe->wr_id;
144 struct qib_rwqe *wqe;
176 wqe = get_rwqe_ptr(rq, tail);
185 if (!wr_id_only && !qib_init_sge(qp, wqe)) {
189 qp->r_wr_id = wqe->wr_id;
354 struct qib_swqe *wqe;
382 wqe = get_swqe_ptr(sqp, sqp->s_last);
422 sqp->s_sge.sge = wqe->sg_list[0];
423 sqp->s_sge.sg_list = wqe->sg_list + 1;
424 sqp->s_sge.num_sge = wqe->wr.num_sge;
425 sqp->s_len = wqe->length;
426 switch (wqe->wr.opcode) {
429 wc.ex.imm_data = wqe->wr.ex.imm_data;
443 wc.ex.imm_data = wqe->wr.ex.imm_data;
453 if (wqe->length == 0)
455 if (unlikely(!qib_rkey_ok(qp, &qp->r_sge.sge, wqe->length,
456 wqe->wr.wr.rdma.remote_addr,
457 wqe->wr.wr.rdma.rkey,
462 qp->r_sge.total_len = wqe->length;
468 if (unlikely(!qib_rkey_ok(qp, &sqp->s_sge.sge, wqe->length,
469 wqe->wr.wr.rdma.remote_addr,
470 wqe->wr.wr.rdma.rkey,
476 qp->r_sge.sge = wqe->sg_list[0];
477 qp->r_sge.sg_list = wqe->sg_list + 1;
478 qp->r_sge.num_sge = wqe->wr.num_sge;
479 qp->r_sge.total_len = wqe->length;
487 wqe->wr.wr.atomic.remote_addr,
488 wqe->wr.wr.atomic.rkey,
493 sdata = wqe->wr.wr.atomic.compare_add;
495 (wqe->wr.opcode == IB_WR_ATOMIC_FETCH_AND_ADD) ?
498 sdata, wqe->wr.wr.atomic.swap);
549 if (wqe->wr.opcode == IB_WR_RDMA_WRITE_WITH_IMM)
555 wc.byte_len = wqe->length;
563 wqe->wr.send_flags & IB_SEND_SOLICITED);
570 qib_send_complete(sqp, wqe, send_status);
617 qib_send_complete(sqp, wqe, send_status);
768 void qib_send_complete(struct qib_qp *qp, struct qib_swqe *wqe,
777 for (i = 0; i < wqe->wr.num_sge; i++) {
778 struct qib_sge *sge = &wqe->sg_list[i];
785 atomic_dec(&to_iah(wqe->wr.wr.ud.ah)->refcount);
789 (wqe->wr.send_flags & IB_SEND_SIGNALED) ||
794 wc.wr_id = wqe->wr.wr_id;
796 wc.opcode = ib_qib_wc_opcode[wqe->wr.opcode];
799 wc.byte_len = wqe->length;