Lines Matching refs:wqe
123 int ipath_init_sge(struct ipath_qp *qp, struct ipath_rwqe *wqe,
130 for (i = j = 0; i < wqe->num_sge; i++) {
131 if (wqe->sg_list[i].length == 0)
135 &wqe->sg_list[i], IB_ACCESS_LOCAL_WRITE))
137 *lengthp += wqe->sg_list[i].length;
146 wc.wr_id = wqe->wr_id;
172 struct ipath_rwqe *wqe;
205 wqe = get_rwqe_ptr(rq, tail);
211 } while (!ipath_init_sge(qp, wqe, &qp->r_len, &qp->r_sge));
212 qp->r_wr_id = wqe->wr_id;
264 struct ipath_swqe *wqe;
290 wqe = get_swqe_ptr(sqp, sqp->s_last);
328 sqp->s_sge.sge = wqe->sg_list[0];
329 sqp->s_sge.sg_list = wqe->sg_list + 1;
330 sqp->s_sge.num_sge = wqe->wr.num_sge;
331 sqp->s_len = wqe->length;
332 switch (wqe->wr.opcode) {
335 wc.ex.imm_data = wqe->wr.ex.imm_data;
346 wc.ex.imm_data = wqe->wr.ex.imm_data;
353 if (wqe->length == 0)
355 if (unlikely(!ipath_rkey_ok(qp, &qp->r_sge, wqe->length,
356 wqe->wr.wr.rdma.remote_addr,
357 wqe->wr.wr.rdma.rkey,
365 if (unlikely(!ipath_rkey_ok(qp, &sqp->s_sge, wqe->length,
366 wqe->wr.wr.rdma.remote_addr,
367 wqe->wr.wr.rdma.rkey,
370 qp->r_sge.sge = wqe->sg_list[0];
371 qp->r_sge.sg_list = wqe->sg_list + 1;
372 qp->r_sge.num_sge = wqe->wr.num_sge;
380 wqe->wr.wr.atomic.remote_addr,
381 wqe->wr.wr.atomic.rkey,
386 sdata = wqe->wr.wr.atomic.compare_add;
388 (wqe->wr.opcode == IB_WR_ATOMIC_FETCH_AND_ADD) ?
391 sdata, wqe->wr.wr.atomic.swap);
432 if (wqe->wr.opcode == IB_WR_RDMA_WRITE_WITH_IMM)
438 wc.byte_len = wqe->length;
446 wqe->wr.send_flags & IB_SEND_SOLICITED);
452 ipath_send_complete(sqp, wqe, send_status);
492 ipath_send_complete(sqp, wqe, send_status);
699 void ipath_send_complete(struct ipath_qp *qp, struct ipath_swqe *wqe,
709 (wqe->wr.send_flags & IB_SEND_SIGNALED) ||
714 wc.wr_id = wqe->wr.wr_id;
716 wc.opcode = ib_ipath_wc_opcode[wqe->wr.opcode];
719 wc.byte_len = wqe->length;