Lines Matching full:wr

488 static int rxe_post_srq_recv(struct ib_srq *ibsrq, const struct ib_recv_wr *wr,  in rxe_post_srq_recv()  argument
497 while (wr) { in rxe_post_srq_recv()
498 err = post_one_recv(&srq->rq, wr); in rxe_post_srq_recv()
501 wr = wr->next; in rxe_post_srq_recv()
507 *bad_wr = wr; in rxe_post_srq_recv()
662 /* send wr */
678 rxe_err_qp(qp, "bad wr opcode for qp type\n"); in validate_send_wr()
726 static int init_send_wr(struct rxe_qp *qp, struct rxe_send_wr *wr, in init_send_wr() argument
729 wr->wr_id = ibwr->wr_id; in init_send_wr()
730 wr->opcode = ibwr->opcode; in init_send_wr()
731 wr->send_flags = ibwr->send_flags; in init_send_wr()
737 wr->wr.ud.remote_qpn = ud_wr(ibwr)->remote_qpn; in init_send_wr()
738 wr->wr.ud.remote_qkey = ud_wr(ibwr)->remote_qkey; in init_send_wr()
739 wr->wr.ud.ah_num = to_rah(ibah)->ah_num; in init_send_wr()
741 wr->wr.ud.pkey_index = ud_wr(ibwr)->pkey_index; in init_send_wr()
743 switch (wr->opcode) { in init_send_wr()
745 wr->ex.imm_data = ibwr->ex.imm_data; in init_send_wr()
750 rxe_err_qp(qp, "bad wr opcode %d for UD/GSI QP\n", in init_send_wr()
751 wr->opcode); in init_send_wr()
755 switch (wr->opcode) { in init_send_wr()
757 wr->ex.imm_data = ibwr->ex.imm_data; in init_send_wr()
761 wr->wr.rdma.remote_addr = rdma_wr(ibwr)->remote_addr; in init_send_wr()
762 wr->wr.rdma.rkey = rdma_wr(ibwr)->rkey; in init_send_wr()
765 wr->ex.imm_data = ibwr->ex.imm_data; in init_send_wr()
768 wr->ex.invalidate_rkey = ibwr->ex.invalidate_rkey; in init_send_wr()
771 wr->ex.invalidate_rkey = ibwr->ex.invalidate_rkey; in init_send_wr()
772 wr->wr.rdma.remote_addr = rdma_wr(ibwr)->remote_addr; in init_send_wr()
773 wr->wr.rdma.rkey = rdma_wr(ibwr)->rkey; in init_send_wr()
777 wr->wr.atomic.remote_addr = in init_send_wr()
779 wr->wr.atomic.compare_add = in init_send_wr()
781 wr->wr.atomic.swap = atomic_wr(ibwr)->swap; in init_send_wr()
782 wr->wr.atomic.rkey = atomic_wr(ibwr)->rkey; in init_send_wr()
785 wr->ex.invalidate_rkey = ibwr->ex.invalidate_rkey; in init_send_wr()
788 wr->wr.reg.mr = reg_wr(ibwr)->mr; in init_send_wr()
789 wr->wr.reg.key = reg_wr(ibwr)->key; in init_send_wr()
790 wr->wr.reg.access = reg_wr(ibwr)->access; in init_send_wr()
798 rxe_err_qp(qp, "unsupported wr opcode %d\n", in init_send_wr()
799 wr->opcode); in init_send_wr()
827 err = init_send_wr(qp, &wqe->wr, ibwr); in init_send_wqe()
913 static int rxe_post_send(struct ib_qp *ibqp, const struct ib_send_wr *wr, in rxe_post_send() argument
930 *bad_wr = wr; in rxe_post_send()
940 err = rxe_post_send_kernel(qp, wr, bad_wr); in rxe_post_send()
948 /* recv wr */
1002 static int rxe_post_recv(struct ib_qp *ibqp, const struct ib_recv_wr *wr, in rxe_post_recv() argument
1021 *bad_wr = wr; in rxe_post_recv()
1028 *bad_wr = wr; in rxe_post_recv()
1035 while (wr) { in rxe_post_recv()
1036 err = post_one_recv(rq, wr); in rxe_post_recv()
1038 *bad_wr = wr; in rxe_post_recv()
1041 wr = wr->next; in rxe_post_recv()