Lines Matching refs:rm

572 int rds_cmsg_rdma_args(struct rds_sock *rs, struct rds_message *rm,  in rds_cmsg_rdma_args()  argument
577 struct rm_rdma_op *op = &rm->rdma; in rds_cmsg_rdma_args()
586 || rm->rdma.op_active) in rds_cmsg_rdma_args()
627 op->op_sg = rds_message_alloc_sgs(rm, nr_pages, &ret); in rds_cmsg_rdma_args()
728 int rds_cmsg_rdma_dest(struct rds_sock *rs, struct rds_message *rm, in rds_cmsg_rdma_dest() argument
737 rm->m_rdma_cookie != 0) in rds_cmsg_rdma_dest()
740 memcpy(&rm->m_rdma_cookie, CMSG_DATA(cmsg), sizeof(rm->m_rdma_cookie)); in rds_cmsg_rdma_dest()
747 r_key = rds_rdma_cookie_key(rm->m_rdma_cookie); in rds_cmsg_rdma_dest()
759 rm->rdma.op_rdma_mr = mr; in rds_cmsg_rdma_dest()
770 int rds_cmsg_rdma_map(struct rds_sock *rs, struct rds_message *rm, in rds_cmsg_rdma_map() argument
774 rm->m_rdma_cookie != 0) in rds_cmsg_rdma_map()
777 return __rds_rdma_map(rs, CMSG_DATA(cmsg), &rm->m_rdma_cookie, in rds_cmsg_rdma_map()
778 &rm->rdma.op_rdma_mr, rm->m_conn_path); in rds_cmsg_rdma_map()
784 int rds_cmsg_atomic(struct rds_sock *rs, struct rds_message *rm, in rds_cmsg_atomic() argument
792 || rm->atomic.op_active) in rds_cmsg_atomic()
800 rm->atomic.op_type = RDS_ATOMIC_TYPE_FADD; in rds_cmsg_atomic()
801 rm->atomic.op_m_fadd.add = args->fadd.add; in rds_cmsg_atomic()
802 rm->atomic.op_m_fadd.nocarry_mask = 0; in rds_cmsg_atomic()
805 rm->atomic.op_type = RDS_ATOMIC_TYPE_FADD; in rds_cmsg_atomic()
806 rm->atomic.op_m_fadd.add = args->m_fadd.add; in rds_cmsg_atomic()
807 rm->atomic.op_m_fadd.nocarry_mask = args->m_fadd.nocarry_mask; in rds_cmsg_atomic()
810 rm->atomic.op_type = RDS_ATOMIC_TYPE_CSWP; in rds_cmsg_atomic()
811 rm->atomic.op_m_cswp.compare = args->cswp.compare; in rds_cmsg_atomic()
812 rm->atomic.op_m_cswp.swap = args->cswp.swap; in rds_cmsg_atomic()
813 rm->atomic.op_m_cswp.compare_mask = ~0; in rds_cmsg_atomic()
814 rm->atomic.op_m_cswp.swap_mask = ~0; in rds_cmsg_atomic()
817 rm->atomic.op_type = RDS_ATOMIC_TYPE_CSWP; in rds_cmsg_atomic()
818 rm->atomic.op_m_cswp.compare = args->m_cswp.compare; in rds_cmsg_atomic()
819 rm->atomic.op_m_cswp.swap = args->m_cswp.swap; in rds_cmsg_atomic()
820 rm->atomic.op_m_cswp.compare_mask = args->m_cswp.compare_mask; in rds_cmsg_atomic()
821 rm->atomic.op_m_cswp.swap_mask = args->m_cswp.swap_mask; in rds_cmsg_atomic()
827 rm->atomic.op_notify = !!(args->flags & RDS_RDMA_NOTIFY_ME); in rds_cmsg_atomic()
828 rm->atomic.op_silent = !!(args->flags & RDS_RDMA_SILENT); in rds_cmsg_atomic()
829 rm->atomic.op_active = 1; in rds_cmsg_atomic()
830 rm->atomic.op_recverr = rs->rs_recverr; in rds_cmsg_atomic()
831 rm->atomic.op_sg = rds_message_alloc_sgs(rm, 1, &ret); in rds_cmsg_atomic()
832 if (!rm->atomic.op_sg) in rds_cmsg_atomic()
846 sg_set_page(rm->atomic.op_sg, page, 8, offset_in_page(args->local_addr)); in rds_cmsg_atomic()
848 if (rm->atomic.op_notify || rm->atomic.op_recverr) { in rds_cmsg_atomic()
854 rm->atomic.op_notifier = kmalloc(sizeof(*rm->atomic.op_notifier), GFP_KERNEL); in rds_cmsg_atomic()
855 if (!rm->atomic.op_notifier) { in rds_cmsg_atomic()
860 rm->atomic.op_notifier->n_user_token = args->user_token; in rds_cmsg_atomic()
861 rm->atomic.op_notifier->n_status = RDS_RDMA_SUCCESS; in rds_cmsg_atomic()
864 rm->atomic.op_rkey = rds_rdma_cookie_key(args->cookie); in rds_cmsg_atomic()
865 rm->atomic.op_remote_addr = args->remote_addr + rds_rdma_cookie_offset(args->cookie); in rds_cmsg_atomic()
871 rm->atomic.op_active = 0; in rds_cmsg_atomic()
872 kfree(rm->atomic.op_notifier); in rds_cmsg_atomic()