Lines Matching refs:msg
691 struct rpmsg_hdr *msg; in rpmsg_send_offchannel_raw() local
715 msg = get_a_tx_buf(vrp); in rpmsg_send_offchannel_raw()
716 if (!msg && !wait) in rpmsg_send_offchannel_raw()
720 while (!msg) { in rpmsg_send_offchannel_raw()
731 (msg = get_a_tx_buf(vrp)), in rpmsg_send_offchannel_raw()
744 msg->len = len; in rpmsg_send_offchannel_raw()
745 msg->flags = 0; in rpmsg_send_offchannel_raw()
746 msg->src = src; in rpmsg_send_offchannel_raw()
747 msg->dst = dst; in rpmsg_send_offchannel_raw()
748 msg->reserved = 0; in rpmsg_send_offchannel_raw()
749 memcpy(msg->data, data, len); in rpmsg_send_offchannel_raw()
752 msg->src, msg->dst, msg->len, in rpmsg_send_offchannel_raw()
753 msg->flags, msg->reserved); in rpmsg_send_offchannel_raw()
755 msg, sizeof(*msg) + msg->len, true); in rpmsg_send_offchannel_raw()
757 sg_init_one(&sg, msg, sizeof(*msg) + len); in rpmsg_send_offchannel_raw()
762 err = virtqueue_add_outbuf(vrp->svq, &sg, 1, msg, GFP_KERNEL); in rpmsg_send_offchannel_raw()
782 struct rpmsg_hdr *msg, unsigned int len) in rpmsg_recv_single() argument
789 msg->src, msg->dst, msg->len, in rpmsg_recv_single()
790 msg->flags, msg->reserved); in rpmsg_recv_single()
792 msg, sizeof(*msg) + msg->len, true); in rpmsg_recv_single()
799 msg->len > (len - sizeof(struct rpmsg_hdr))) { in rpmsg_recv_single()
800 dev_warn(dev, "inbound msg too big: (%d, %d)\n", len, msg->len); in rpmsg_recv_single()
807 ept = idr_find(&vrp->endpoints, msg->dst); in rpmsg_recv_single()
820 ept->cb(ept->rpdev, msg->data, msg->len, ept->priv, in rpmsg_recv_single()
821 msg->src); in rpmsg_recv_single()
831 sg_init_one(&sg, msg, RPMSG_BUF_SIZE); in rpmsg_recv_single()
834 err = virtqueue_add_inbuf(vrp->rvq, &sg, 1, msg, GFP_KERNEL); in rpmsg_recv_single()
848 struct rpmsg_hdr *msg; in rpmsg_recv_done() local
852 msg = virtqueue_get_buf(rvq, &len); in rpmsg_recv_done()
853 if (!msg) { in rpmsg_recv_done()
858 while (msg) { in rpmsg_recv_done()
859 err = rpmsg_recv_single(vrp, dev, msg, len); in rpmsg_recv_done()
865 msg = virtqueue_get_buf(rvq, &len); in rpmsg_recv_done()
896 struct rpmsg_ns_msg *msg = data; in rpmsg_ns_cb() local
907 if (len != sizeof(*msg)) { in rpmsg_ns_cb()
924 msg->name[RPMSG_NAME_SIZE - 1] = '\0'; in rpmsg_ns_cb()
927 msg->flags & RPMSG_NS_DESTROY ? "destroy" : "creat", in rpmsg_ns_cb()
928 msg->name, msg->addr); in rpmsg_ns_cb()
930 strncpy(chinfo.name, msg->name, sizeof(chinfo.name)); in rpmsg_ns_cb()
932 chinfo.dst = msg->addr; in rpmsg_ns_cb()
934 if (msg->flags & RPMSG_NS_DESTROY) { in rpmsg_ns_cb()