Lines Matching full:wr
497 static int rxe_post_srq_recv(struct ib_srq *ibsrq, const struct ib_recv_wr *wr, in rxe_post_srq_recv() argument
506 while (wr) { in rxe_post_srq_recv()
507 err = post_one_recv(&srq->rq, wr); in rxe_post_srq_recv()
510 wr = wr->next; in rxe_post_srq_recv()
516 *bad_wr = wr; in rxe_post_srq_recv()
671 /* send wr */
687 rxe_err_qp(qp, "bad wr opcode for qp type\n"); in validate_send_wr()
735 static int init_send_wr(struct rxe_qp *qp, struct rxe_send_wr *wr, in init_send_wr() argument
738 wr->wr_id = ibwr->wr_id; in init_send_wr()
739 wr->opcode = ibwr->opcode; in init_send_wr()
740 wr->send_flags = ibwr->send_flags; in init_send_wr()
746 wr->wr.ud.remote_qpn = ud_wr(ibwr)->remote_qpn; in init_send_wr()
747 wr->wr.ud.remote_qkey = ud_wr(ibwr)->remote_qkey; in init_send_wr()
748 wr->wr.ud.ah_num = to_rah(ibah)->ah_num; in init_send_wr()
750 wr->wr.ud.pkey_index = ud_wr(ibwr)->pkey_index; in init_send_wr()
752 switch (wr->opcode) { in init_send_wr()
754 wr->ex.imm_data = ibwr->ex.imm_data; in init_send_wr()
759 rxe_err_qp(qp, "bad wr opcode %d for UD/GSI QP\n", in init_send_wr()
760 wr->opcode); in init_send_wr()
764 switch (wr->opcode) { in init_send_wr()
766 wr->ex.imm_data = ibwr->ex.imm_data; in init_send_wr()
770 wr->wr.rdma.remote_addr = rdma_wr(ibwr)->remote_addr; in init_send_wr()
771 wr->wr.rdma.rkey = rdma_wr(ibwr)->rkey; in init_send_wr()
774 wr->ex.imm_data = ibwr->ex.imm_data; in init_send_wr()
777 wr->ex.invalidate_rkey = ibwr->ex.invalidate_rkey; in init_send_wr()
780 wr->ex.invalidate_rkey = ibwr->ex.invalidate_rkey; in init_send_wr()
781 wr->wr.rdma.remote_addr = rdma_wr(ibwr)->remote_addr; in init_send_wr()
782 wr->wr.rdma.rkey = rdma_wr(ibwr)->rkey; in init_send_wr()
786 wr->wr.atomic.remote_addr = in init_send_wr()
788 wr->wr.atomic.compare_add = in init_send_wr()
790 wr->wr.atomic.swap = atomic_wr(ibwr)->swap; in init_send_wr()
791 wr->wr.atomic.rkey = atomic_wr(ibwr)->rkey; in init_send_wr()
794 wr->ex.invalidate_rkey = ibwr->ex.invalidate_rkey; in init_send_wr()
797 wr->wr.reg.mr = reg_wr(ibwr)->mr; in init_send_wr()
798 wr->wr.reg.key = reg_wr(ibwr)->key; in init_send_wr()
799 wr->wr.reg.access = reg_wr(ibwr)->access; in init_send_wr()
807 rxe_err_qp(qp, "unsupported wr opcode %d\n", in init_send_wr()
808 wr->opcode); in init_send_wr()
836 err = init_send_wr(qp, &wqe->wr, ibwr); in init_send_wqe()
922 static int rxe_post_send(struct ib_qp *ibqp, const struct ib_send_wr *wr, in rxe_post_send() argument
939 *bad_wr = wr; in rxe_post_send()
949 err = rxe_post_send_kernel(qp, wr, bad_wr); in rxe_post_send()
957 /* recv wr */
1010 static int rxe_post_recv(struct ib_qp *ibqp, const struct ib_recv_wr *wr, in rxe_post_recv() argument
1029 *bad_wr = wr; in rxe_post_recv()
1036 *bad_wr = wr; in rxe_post_recv()
1043 while (wr) { in rxe_post_recv()
1044 err = post_one_recv(rq, wr); in rxe_post_recv()
1046 *bad_wr = wr; in rxe_post_recv()
1049 wr = wr->next; in rxe_post_recv()