Lines Matching refs:msg

561 	struct rpmsg_hdr *msg;  in rpmsg_send_offchannel_raw()  local
585 msg = get_a_tx_buf(vrp); in rpmsg_send_offchannel_raw()
586 if (!msg && !wait) in rpmsg_send_offchannel_raw()
590 while (!msg) { in rpmsg_send_offchannel_raw()
601 (msg = get_a_tx_buf(vrp)), in rpmsg_send_offchannel_raw()
614 msg->len = cpu_to_rpmsg16(rpdev, len); in rpmsg_send_offchannel_raw()
615 msg->flags = 0; in rpmsg_send_offchannel_raw()
616 msg->src = cpu_to_rpmsg32(rpdev, src); in rpmsg_send_offchannel_raw()
617 msg->dst = cpu_to_rpmsg32(rpdev, dst); in rpmsg_send_offchannel_raw()
618 msg->reserved = 0; in rpmsg_send_offchannel_raw()
619 memcpy(msg->data, data, len); in rpmsg_send_offchannel_raw()
622 src, dst, len, msg->flags, msg->reserved); in rpmsg_send_offchannel_raw()
625 msg, sizeof(*msg) + len, true); in rpmsg_send_offchannel_raw()
628 rpmsg_sg_init(&sg, msg, sizeof(*msg) + len); in rpmsg_send_offchannel_raw()
633 err = virtqueue_add_outbuf(vrp->svq, &sg, 1, msg, GFP_KERNEL); in rpmsg_send_offchannel_raw()
710 struct rpmsg_hdr *msg, unsigned int len) in rpmsg_recv_single() argument
715 unsigned int msg_len = __rpmsg16_to_cpu(little_endian, msg->len); in rpmsg_recv_single()
719 __rpmsg32_to_cpu(little_endian, msg->src), in rpmsg_recv_single()
720 __rpmsg32_to_cpu(little_endian, msg->dst), msg_len, in rpmsg_recv_single()
721 __rpmsg16_to_cpu(little_endian, msg->flags), in rpmsg_recv_single()
722 __rpmsg32_to_cpu(little_endian, msg->reserved)); in rpmsg_recv_single()
725 msg, sizeof(*msg) + msg_len, true); in rpmsg_recv_single()
741 ept = idr_find(&vrp->endpoints, __rpmsg32_to_cpu(little_endian, msg->dst)); in rpmsg_recv_single()
754 ept->cb(ept->rpdev, msg->data, msg_len, ept->priv, in rpmsg_recv_single()
755 __rpmsg32_to_cpu(little_endian, msg->src)); in rpmsg_recv_single()
765 rpmsg_sg_init(&sg, msg, vrp->buf_size); in rpmsg_recv_single()
768 err = virtqueue_add_inbuf(vrp->rvq, &sg, 1, msg, GFP_KERNEL); in rpmsg_recv_single()
782 struct rpmsg_hdr *msg; in rpmsg_recv_done() local
786 msg = virtqueue_get_buf(rvq, &len); in rpmsg_recv_done()
787 if (!msg) { in rpmsg_recv_done()
792 while (msg) { in rpmsg_recv_done()
793 err = rpmsg_recv_single(vrp, dev, msg, len); in rpmsg_recv_done()
799 msg = virtqueue_get_buf(rvq, &len); in rpmsg_recv_done()