Lines Matching refs:wqe
114 int ipath_init_sge(struct ipath_qp *qp, struct ipath_rwqe *wqe,
121 for (i = j = 0; i < wqe->num_sge; i++) {
122 if (wqe->sg_list[i].length == 0)
126 &wqe->sg_list[i], IB_ACCESS_LOCAL_WRITE))
128 *lengthp += wqe->sg_list[i].length;
137 wc.wr_id = wqe->wr_id;
163 struct ipath_rwqe *wqe;
196 wqe = get_rwqe_ptr(rq, tail);
202 } while (!ipath_init_sge(qp, wqe, &qp->r_len, &qp->r_sge));
203 qp->r_wr_id = wqe->wr_id;
255 struct ipath_swqe *wqe;
281 wqe = get_swqe_ptr(sqp, sqp->s_last);
319 sqp->s_sge.sge = wqe->sg_list[0];
320 sqp->s_sge.sg_list = wqe->sg_list + 1;
321 sqp->s_sge.num_sge = wqe->wr.num_sge;
322 sqp->s_len = wqe->length;
323 switch (wqe->wr.opcode) {
326 wc.ex.imm_data = wqe->wr.ex.imm_data;
337 wc.ex.imm_data = wqe->wr.ex.imm_data;
344 if (wqe->length == 0)
346 if (unlikely(!ipath_rkey_ok(qp, &qp->r_sge, wqe->length,
347 wqe->wr.wr.rdma.remote_addr,
348 wqe->wr.wr.rdma.rkey,
356 if (unlikely(!ipath_rkey_ok(qp, &sqp->s_sge, wqe->length,
357 wqe->wr.wr.rdma.remote_addr,
358 wqe->wr.wr.rdma.rkey,
361 qp->r_sge.sge = wqe->sg_list[0];
362 qp->r_sge.sg_list = wqe->sg_list + 1;
363 qp->r_sge.num_sge = wqe->wr.num_sge;
371 wqe->wr.wr.atomic.remote_addr,
372 wqe->wr.wr.atomic.rkey,
377 sdata = wqe->wr.wr.atomic.compare_add;
379 (wqe->wr.opcode == IB_WR_ATOMIC_FETCH_AND_ADD) ?
382 sdata, wqe->wr.wr.atomic.swap);
423 if (wqe->wr.opcode == IB_WR_RDMA_WRITE_WITH_IMM)
429 wc.byte_len = wqe->length;
437 wqe->wr.send_flags & IB_SEND_SOLICITED);
443 ipath_send_complete(sqp, wqe, send_status);
483 ipath_send_complete(sqp, wqe, send_status);
690 void ipath_send_complete(struct ipath_qp *qp, struct ipath_swqe *wqe,
700 (wqe->wr.send_flags & IB_SEND_SIGNALED) ||
705 wc.wr_id = wqe->wr.wr_id;
707 wc.opcode = ib_ipath_wc_opcode[wqe->wr.opcode];
710 wc.byte_len = wqe->length;