From mboxrd@z Thu Jan 1 00:00:00 1970 Return-Path: Subject: Re: [PATCH v2 01/20] rpmsg: glink: Rename glink_rpm_xx functions to qcom_glink_xx References: <1503559302-3744-1-git-send-email-sricharan@codeaurora.org> <1503559302-3744-2-git-send-email-sricharan@codeaurora.org> From: Arun Kumar Neelakantam Message-ID: Date: Mon, 28 Aug 2017 17:12:53 +0530 MIME-Version: 1.0 In-Reply-To: <1503559302-3744-2-git-send-email-sricharan@codeaurora.org> Content-Type: text/plain; charset=utf-8; format=flowed Content-Transfer-Encoding: 7bit Content-Language: en-US To: Sricharan R , ohad@wizery.com, bjorn.andersson@linaro.org, linux-remoteproc@vger.kernel.org, linux-kernel@vger.kernel.org, linux-arm-msm@vger.kernel.org, linux-arm-kernel@lists.infradead.org List-ID: On 8/24/2017 12:51 PM, Sricharan R wrote: > From: Bjorn Andersson > > Renaming the glink_rpm_xx functions and structs to qcom_glink_xx > equivalents helps to reuse the core glink protocol while adding > support for smem based glink transport in the later patches. > > Signed-off-by: Bjorn Andersson > Signed-off-by: Sricharan R Acked-by: Arun Kumar Neelakantam Reagrds Arun N > --- > drivers/rpmsg/qcom_glink_rpm.c | 248 +++++++++++++++++++++-------------------- > 1 file changed, 128 insertions(+), 120 deletions(-) > > diff --git a/drivers/rpmsg/qcom_glink_rpm.c b/drivers/rpmsg/qcom_glink_rpm.c > index 3559a3e..56a0a66 100644 > --- a/drivers/rpmsg/qcom_glink_rpm.c > +++ b/drivers/rpmsg/qcom_glink_rpm.c > @@ -101,7 +101,7 @@ struct glink_defer_cmd { > * @lcids: idr of all channels with a known local channel id > * @rcids: idr of all channels with a known remote channel id > */ > -struct glink_rpm { > +struct qcom_glink { > struct device *dev; > > struct mbox_client mbox_client; > @@ -134,7 +134,7 @@ enum { > * struct glink_channel - internal representation of a channel > * @rpdev: rpdev reference, only used for primary endpoints > * @ept: rpmsg endpoint this channel is associated with > - * @glink: glink_rpm context handle > + * @glink: qcom_glink context handle > * @refcount: refcount for the channel object > * @recv_lock: guard for @ept.cb > * @name: unique channel name/identifier > @@ -150,7 +150,7 @@ struct glink_channel { > struct rpmsg_endpoint ept; > > struct rpmsg_device *rpdev; > - struct glink_rpm *glink; > + struct qcom_glink *glink; > > struct kref refcount; > > @@ -184,8 +184,8 @@ struct glink_channel { > > #define GLINK_FEATURE_INTENTLESS BIT(1) > > -static struct glink_channel *glink_rpm_alloc_channel(struct glink_rpm *glink, > - const char *name) > +static struct glink_channel *qcom_glink_alloc_channel(struct qcom_glink *glink, > + const char *name) > { > struct glink_channel *channel; > > @@ -206,7 +206,7 @@ static struct glink_channel *glink_rpm_alloc_channel(struct glink_rpm *glink, > return channel; > } > > -static void glink_rpm_channel_release(struct kref *ref) > +static void qcom_glink_channel_release(struct kref *ref) > { > struct glink_channel *channel = container_of(ref, struct glink_channel, > refcount); > @@ -215,7 +215,7 @@ static void glink_rpm_channel_release(struct kref *ref) > kfree(channel); > } > > -static size_t glink_rpm_rx_avail(struct glink_rpm *glink) > +static size_t qcom_glink_rx_avail(struct qcom_glink *glink) > { > struct glink_rpm_pipe *pipe = &glink->rx_pipe; > unsigned int head; > @@ -230,8 +230,8 @@ static size_t glink_rpm_rx_avail(struct glink_rpm *glink) > return head - tail; > } > > -static void glink_rpm_rx_peak(struct glink_rpm *glink, > - void *data, size_t count) > +static void qcom_glink_rx_peak(struct qcom_glink *glink, > + void *data, size_t count) > { > struct glink_rpm_pipe *pipe = &glink->rx_pipe; > unsigned int tail; > @@ -251,8 +251,8 @@ static void glink_rpm_rx_peak(struct glink_rpm *glink, > } > } > > -static void glink_rpm_rx_advance(struct glink_rpm *glink, > - size_t count) > +static void qcom_glink_rx_advance(struct qcom_glink *glink, > + size_t count) > { > struct glink_rpm_pipe *pipe = &glink->rx_pipe; > unsigned int tail; > @@ -266,7 +266,7 @@ static void glink_rpm_rx_advance(struct glink_rpm *glink, > writel(tail, pipe->tail); > } > > -static size_t glink_rpm_tx_avail(struct glink_rpm *glink) > +static size_t qcom_glink_tx_avail(struct qcom_glink *glink) > { > struct glink_rpm_pipe *pipe = &glink->tx_pipe; > unsigned int head; > @@ -281,9 +281,9 @@ static size_t glink_rpm_tx_avail(struct glink_rpm *glink) > return tail - head; > } > > -static unsigned int glink_rpm_tx_write(struct glink_rpm *glink, > - unsigned int head, > - const void *data, size_t count) > +static unsigned int qcom_glink_tx_write(struct qcom_glink *glink, > + unsigned int head, > + const void *data, size_t count) > { > struct glink_rpm_pipe *pipe = &glink->tx_pipe; > size_t len; > @@ -306,8 +306,8 @@ static unsigned int glink_rpm_tx_write(struct glink_rpm *glink, > return head; > } > > -static int glink_rpm_tx(struct glink_rpm *glink, > - const void *hdr, size_t hlen, > +static int qcom_glink_tx(struct qcom_glink *glink, > + const void *hdr, size_t hlen, > const void *data, size_t dlen, bool wait) > { > struct glink_rpm_pipe *pipe = &glink->tx_pipe; > @@ -326,7 +326,7 @@ static int glink_rpm_tx(struct glink_rpm *glink, > if (ret) > return ret; > > - while (glink_rpm_tx_avail(glink) < tlen) { > + while (qcom_glink_tx_avail(glink) < tlen) { > if (!wait) { > ret = -ENOMEM; > goto out; > @@ -336,8 +336,8 @@ static int glink_rpm_tx(struct glink_rpm *glink, > } > > head = readl(pipe->head); > - head = glink_rpm_tx_write(glink, head, hdr, hlen); > - head = glink_rpm_tx_write(glink, head, data, dlen); > + head = qcom_glink_tx_write(glink, head, hdr, hlen); > + head = qcom_glink_tx_write(glink, head, data, dlen); > writel(head, pipe->head); > > mbox_send_message(glink->mbox_chan, NULL); > @@ -349,7 +349,7 @@ static int glink_rpm_tx(struct glink_rpm *glink, > return ret; > } > > -static int glink_rpm_send_version(struct glink_rpm *glink) > +static int qcom_glink_send_version(struct qcom_glink *glink) > { > struct glink_msg msg; > > @@ -357,10 +357,10 @@ static int glink_rpm_send_version(struct glink_rpm *glink) > msg.param1 = cpu_to_le16(1); > msg.param2 = cpu_to_le32(GLINK_FEATURE_INTENTLESS); > > - return glink_rpm_tx(glink, &msg, sizeof(msg), NULL, 0, true); > + return qcom_glink_tx(glink, &msg, sizeof(msg), NULL, 0, true); > } > > -static void glink_rpm_send_version_ack(struct glink_rpm *glink) > +static void qcom_glink_send_version_ack(struct qcom_glink *glink) > { > struct glink_msg msg; > > @@ -368,11 +368,11 @@ static void glink_rpm_send_version_ack(struct glink_rpm *glink) > msg.param1 = cpu_to_le16(1); > msg.param2 = cpu_to_le32(0); > > - glink_rpm_tx(glink, &msg, sizeof(msg), NULL, 0, true); > + qcom_glink_tx(glink, &msg, sizeof(msg), NULL, 0, true); > } > > -static void glink_rpm_send_open_ack(struct glink_rpm *glink, > - struct glink_channel *channel) > +static void qcom_glink_send_open_ack(struct qcom_glink *glink, > + struct glink_channel *channel) > { > struct glink_msg msg; > > @@ -380,11 +380,11 @@ static void glink_rpm_send_open_ack(struct glink_rpm *glink, > msg.param1 = cpu_to_le16(channel->rcid); > msg.param2 = cpu_to_le32(0); > > - glink_rpm_tx(glink, &msg, sizeof(msg), NULL, 0, true); > + qcom_glink_tx(glink, &msg, sizeof(msg), NULL, 0, true); > } > > /** > - * glink_rpm_send_open_req() - send a RPM_CMD_OPEN request to the remote > + * qcom_glink_send_open_req() - send a RPM_CMD_OPEN request to the remote > * @glink: > * @channel: > * > @@ -393,8 +393,8 @@ static void glink_rpm_send_open_ack(struct glink_rpm *glink, > * > * Returns 0 on success, negative errno otherwise. > */ > -static int glink_rpm_send_open_req(struct glink_rpm *glink, > - struct glink_channel *channel) > +static int qcom_glink_send_open_req(struct qcom_glink *glink, > + struct glink_channel *channel) > { > struct { > struct glink_msg msg; > @@ -420,7 +420,7 @@ static int glink_rpm_send_open_req(struct glink_rpm *glink, > req.msg.param2 = cpu_to_le32(name_len); > strcpy(req.name, channel->name); > > - ret = glink_rpm_tx(glink, &req, req_len, NULL, 0, true); > + ret = qcom_glink_tx(glink, &req, req_len, NULL, 0, true); > if (ret) > goto remove_idr; > > @@ -435,8 +435,8 @@ static int glink_rpm_send_open_req(struct glink_rpm *glink, > return ret; > } > > -static void glink_rpm_send_close_req(struct glink_rpm *glink, > - struct glink_channel *channel) > +static void qcom_glink_send_close_req(struct qcom_glink *glink, > + struct glink_channel *channel) > { > struct glink_msg req; > > @@ -444,10 +444,11 @@ static void glink_rpm_send_close_req(struct glink_rpm *glink, > req.param1 = cpu_to_le16(channel->lcid); > req.param2 = 0; > > - glink_rpm_tx(glink, &req, sizeof(req), NULL, 0, true); > + qcom_glink_tx(glink, &req, sizeof(req), NULL, 0, true); > } > > -static void glink_rpm_send_close_ack(struct glink_rpm *glink, unsigned int rcid) > +static void qcom_glink_send_close_ack(struct qcom_glink *glink, > + unsigned int rcid) > { > struct glink_msg req; > > @@ -455,16 +456,16 @@ static void glink_rpm_send_close_ack(struct glink_rpm *glink, unsigned int rcid) > req.param1 = cpu_to_le16(rcid); > req.param2 = 0; > > - glink_rpm_tx(glink, &req, sizeof(req), NULL, 0, true); > + qcom_glink_tx(glink, &req, sizeof(req), NULL, 0, true); > } > > -static int glink_rpm_rx_defer(struct glink_rpm *glink, size_t extra) > +static int qcom_glink_rx_defer(struct qcom_glink *glink, size_t extra) > { > struct glink_defer_cmd *dcmd; > > extra = ALIGN(extra, 8); > > - if (glink_rpm_rx_avail(glink) < sizeof(struct glink_msg) + extra) { > + if (qcom_glink_rx_avail(glink) < sizeof(struct glink_msg) + extra) { > dev_dbg(glink->dev, "Insufficient data in rx fifo"); > return -ENXIO; > } > @@ -475,19 +476,19 @@ static int glink_rpm_rx_defer(struct glink_rpm *glink, size_t extra) > > INIT_LIST_HEAD(&dcmd->node); > > - glink_rpm_rx_peak(glink, &dcmd->msg, sizeof(dcmd->msg) + extra); > + qcom_glink_rx_peak(glink, &dcmd->msg, sizeof(dcmd->msg) + extra); > > spin_lock(&glink->rx_lock); > list_add_tail(&dcmd->node, &glink->rx_queue); > spin_unlock(&glink->rx_lock); > > schedule_work(&glink->rx_work); > - glink_rpm_rx_advance(glink, sizeof(dcmd->msg) + extra); > + qcom_glink_rx_advance(glink, sizeof(dcmd->msg) + extra); > > return 0; > } > > -static int glink_rpm_rx_data(struct glink_rpm *glink, size_t avail) > +static int qcom_glink_rx_data(struct qcom_glink *glink, size_t avail) > { > struct glink_channel *channel; > struct { > @@ -504,7 +505,7 @@ static int glink_rpm_rx_data(struct glink_rpm *glink, size_t avail) > return -EAGAIN; > } > > - glink_rpm_rx_peak(glink, &hdr, sizeof(hdr)); > + qcom_glink_rx_peak(glink, &hdr, sizeof(hdr)); > chunk_size = le32_to_cpu(hdr.chunk_size); > left_size = le32_to_cpu(hdr.left_size); > > @@ -522,7 +523,8 @@ static int glink_rpm_rx_data(struct glink_rpm *glink, size_t avail) > dev_dbg(glink->dev, "Data on non-existing channel\n"); > > /* Drop the message */ > - glink_rpm_rx_advance(glink, ALIGN(sizeof(hdr) + chunk_size, 8)); > + qcom_glink_rx_advance(glink, > + ALIGN(sizeof(hdr) + chunk_size, 8)); > return 0; > } > > @@ -536,17 +538,18 @@ static int glink_rpm_rx_data(struct glink_rpm *glink, size_t avail) > channel->buf_offset = 0; > } > > - glink_rpm_rx_advance(glink, sizeof(hdr)); > + qcom_glink_rx_advance(glink, sizeof(hdr)); > > if (channel->buf_size - channel->buf_offset < chunk_size) { > dev_err(glink->dev, "Insufficient space in input buffer\n"); > > /* The packet header lied, drop payload */ > - glink_rpm_rx_advance(glink, chunk_size); > + qcom_glink_rx_advance(glink, chunk_size); > return -ENOMEM; > } > > - glink_rpm_rx_peak(glink, channel->buf + channel->buf_offset, chunk_size); > + qcom_glink_rx_peak(glink, channel->buf + channel->buf_offset, > + chunk_size); > channel->buf_offset += chunk_size; > > /* Handle message when no fragments remain to be received */ > @@ -567,12 +570,12 @@ static int glink_rpm_rx_data(struct glink_rpm *glink, size_t avail) > } > > /* Each message starts at 8 byte aligned address */ > - glink_rpm_rx_advance(glink, ALIGN(chunk_size, 8)); > + qcom_glink_rx_advance(glink, ALIGN(chunk_size, 8)); > > return 0; > } > > -static int glink_rpm_rx_open_ack(struct glink_rpm *glink, unsigned int lcid) > +static int qcom_glink_rx_open_ack(struct qcom_glink *glink, unsigned int lcid) > { > struct glink_channel *channel; > > @@ -587,9 +590,9 @@ static int glink_rpm_rx_open_ack(struct glink_rpm *glink, unsigned int lcid) > return 0; > } > > -static irqreturn_t glink_rpm_intr(int irq, void *data) > +static irqreturn_t qcom_glink_intr(int irq, void *data) > { > - struct glink_rpm *glink = data; > + struct qcom_glink *glink = data; > struct glink_msg msg; > unsigned int param1; > unsigned int param2; > @@ -598,11 +601,11 @@ static irqreturn_t glink_rpm_intr(int irq, void *data) > int ret; > > for (;;) { > - avail = glink_rpm_rx_avail(glink); > + avail = qcom_glink_rx_avail(glink); > if (avail < sizeof(msg)) > break; > > - glink_rpm_rx_peak(glink, &msg, sizeof(msg)); > + qcom_glink_rx_peak(glink, &msg, sizeof(msg)); > > cmd = le16_to_cpu(msg.cmd); > param1 = le16_to_cpu(msg.param1); > @@ -613,21 +616,21 @@ static irqreturn_t glink_rpm_intr(int irq, void *data) > case RPM_CMD_VERSION_ACK: > case RPM_CMD_CLOSE: > case RPM_CMD_CLOSE_ACK: > - ret = glink_rpm_rx_defer(glink, 0); > + ret = qcom_glink_rx_defer(glink, 0); > break; > case RPM_CMD_OPEN_ACK: > - ret = glink_rpm_rx_open_ack(glink, param1); > - glink_rpm_rx_advance(glink, ALIGN(sizeof(msg), 8)); > + ret = qcom_glink_rx_open_ack(glink, param1); > + qcom_glink_rx_advance(glink, ALIGN(sizeof(msg), 8)); > break; > case RPM_CMD_OPEN: > - ret = glink_rpm_rx_defer(glink, param2); > + ret = qcom_glink_rx_defer(glink, param2); > break; > case RPM_CMD_TX_DATA: > case RPM_CMD_TX_DATA_CONT: > - ret = glink_rpm_rx_data(glink, avail); > + ret = qcom_glink_rx_data(glink, avail); > break; > case RPM_CMD_READ_NOTIF: > - glink_rpm_rx_advance(glink, ALIGN(sizeof(msg), 8)); > + qcom_glink_rx_advance(glink, ALIGN(sizeof(msg), 8)); > > mbox_send_message(glink->mbox_chan, NULL); > mbox_client_txdone(glink->mbox_chan, 0); > @@ -648,17 +651,17 @@ static irqreturn_t glink_rpm_intr(int irq, void *data) > } > > /* Locally initiated rpmsg_create_ept */ > -static struct glink_channel *glink_rpm_create_local(struct glink_rpm *glink, > - const char *name) > +static struct glink_channel *qcom_glink_create_local(struct qcom_glink *glink, > + const char *name) > { > struct glink_channel *channel; > int ret; > > - channel = glink_rpm_alloc_channel(glink, name); > + channel = qcom_glink_alloc_channel(glink, name); > if (IS_ERR(channel)) > return ERR_CAST(channel); > > - ret = glink_rpm_send_open_req(glink, channel); > + ret = qcom_glink_send_open_req(glink, channel); > if (ret) > goto release_channel; > > @@ -670,34 +673,34 @@ static struct glink_channel *glink_rpm_create_local(struct glink_rpm *glink, > if (!ret) > goto err_timeout; > > - glink_rpm_send_open_ack(glink, channel); > + qcom_glink_send_open_ack(glink, channel); > > return channel; > > err_timeout: > - /* glink_rpm_send_open_req() did register the channel in lcids*/ > + /* qcom_glink_send_open_req() did register the channel in lcids*/ > mutex_lock(&glink->idr_lock); > idr_remove(&glink->lcids, channel->lcid); > mutex_unlock(&glink->idr_lock); > > release_channel: > - /* Release glink_rpm_send_open_req() reference */ > - kref_put(&channel->refcount, glink_rpm_channel_release); > - /* Release glink_rpm_alloc_channel() reference */ > - kref_put(&channel->refcount, glink_rpm_channel_release); > + /* Release qcom_glink_send_open_req() reference */ > + kref_put(&channel->refcount, qcom_glink_channel_release); > + /* Release qcom_glink_alloc_channel() reference */ > + kref_put(&channel->refcount, qcom_glink_channel_release); > > return ERR_PTR(-ETIMEDOUT); > } > > /* Remote initiated rpmsg_create_ept */ > -static int glink_rpm_create_remote(struct glink_rpm *glink, > - struct glink_channel *channel) > +static int qcom_glink_create_remote(struct qcom_glink *glink, > + struct glink_channel *channel) > { > int ret; > > - glink_rpm_send_open_ack(glink, channel); > + qcom_glink_send_open_ack(glink, channel); > > - ret = glink_rpm_send_open_req(glink, channel); > + ret = qcom_glink_send_open_req(glink, channel); > if (ret) > goto close_link; > > @@ -714,21 +717,23 @@ static int glink_rpm_create_remote(struct glink_rpm *glink, > * Send a close request to "undo" our open-ack. The close-ack will > * release the last reference. > */ > - glink_rpm_send_close_req(glink, channel); > + qcom_glink_send_close_req(glink, channel); > > - /* Release glink_rpm_send_open_req() reference */ > - kref_put(&channel->refcount, glink_rpm_channel_release); > + /* Release qcom_glink_send_open_req() reference */ > + kref_put(&channel->refcount, qcom_glink_channel_release); > > return ret; > } > > -static struct rpmsg_endpoint *glink_rpm_create_ept(struct rpmsg_device *rpdev, > - rpmsg_rx_cb_t cb, void *priv, > - struct rpmsg_channel_info chinfo) > +static struct rpmsg_endpoint *qcom_glink_create_ept(struct rpmsg_device *rpdev, > + rpmsg_rx_cb_t cb, > + void *priv, > + struct rpmsg_channel_info > + chinfo) > { > struct glink_channel *parent = to_glink_channel(rpdev->ept); > struct glink_channel *channel; > - struct glink_rpm *glink = parent->glink; > + struct qcom_glink *glink = parent->glink; > struct rpmsg_endpoint *ept; > const char *name = chinfo.name; > int cid; > @@ -740,11 +745,11 @@ static struct rpmsg_endpoint *glink_rpm_create_ept(struct rpmsg_device *rpdev, > } > > if (!channel) { > - channel = glink_rpm_create_local(glink, name); > + channel = qcom_glink_create_local(glink, name); > if (IS_ERR(channel)) > return NULL; > } else { > - ret = glink_rpm_create_remote(glink, channel); > + ret = qcom_glink_create_remote(glink, channel); > if (ret) > return NULL; > } > @@ -758,10 +763,10 @@ static struct rpmsg_endpoint *glink_rpm_create_ept(struct rpmsg_device *rpdev, > return ept; > } > > -static void glink_rpm_destroy_ept(struct rpmsg_endpoint *ept) > +static void qcom_glink_destroy_ept(struct rpmsg_endpoint *ept) > { > struct glink_channel *channel = to_glink_channel(ept); > - struct glink_rpm *glink = channel->glink; > + struct qcom_glink *glink = channel->glink; > unsigned long flags; > > spin_lock_irqsave(&channel->recv_lock, flags); > @@ -771,13 +776,13 @@ static void glink_rpm_destroy_ept(struct rpmsg_endpoint *ept) > /* Decouple the potential rpdev from the channel */ > channel->rpdev = NULL; > > - glink_rpm_send_close_req(glink, channel); > + qcom_glink_send_close_req(glink, channel); > } > > -static int __glink_rpm_send(struct glink_channel *channel, > +static int __qcom_glink_send(struct glink_channel *channel, > void *data, int len, bool wait) > { > - struct glink_rpm *glink = channel->glink; > + struct qcom_glink *glink = channel->glink; > struct { > struct glink_msg msg; > __le32 chunk_size; > @@ -793,27 +798,27 @@ static int __glink_rpm_send(struct glink_channel *channel, > req.chunk_size = cpu_to_le32(len); > req.left_size = cpu_to_le32(0); > > - return glink_rpm_tx(glink, &req, sizeof(req), data, len, wait); > + return qcom_glink_tx(glink, &req, sizeof(req), data, len, wait); > } > > -static int glink_rpm_send(struct rpmsg_endpoint *ept, void *data, int len) > +static int qcom_glink_send(struct rpmsg_endpoint *ept, void *data, int len) > { > struct glink_channel *channel = to_glink_channel(ept); > > - return __glink_rpm_send(channel, data, len, true); > + return __qcom_glink_send(channel, data, len, true); > } > > -static int glink_rpm_trysend(struct rpmsg_endpoint *ept, void *data, int len) > +static int qcom_glink_trysend(struct rpmsg_endpoint *ept, void *data, int len) > { > struct glink_channel *channel = to_glink_channel(ept); > > - return __glink_rpm_send(channel, data, len, false); > + return __qcom_glink_send(channel, data, len, false); > } > > /* > * Finds the device_node for the glink child interested in this channel. > */ > -static struct device_node *glink_rpm_match_channel(struct device_node *node, > +static struct device_node *qcom_glink_match_channel(struct device_node *node, > const char *channel) > { > struct device_node *child; > @@ -835,16 +840,16 @@ static struct device_node *glink_rpm_match_channel(struct device_node *node, > } > > static const struct rpmsg_device_ops glink_device_ops = { > - .create_ept = glink_rpm_create_ept, > + .create_ept = qcom_glink_create_ept, > }; > > static const struct rpmsg_endpoint_ops glink_endpoint_ops = { > - .destroy_ept = glink_rpm_destroy_ept, > - .send = glink_rpm_send, > - .trysend = glink_rpm_trysend, > + .destroy_ept = qcom_glink_destroy_ept, > + .send = qcom_glink_send, > + .trysend = qcom_glink_trysend, > }; > > -static void glink_rpm_rpdev_release(struct device *dev) > +static void qcom_glink_rpdev_release(struct device *dev) > { > struct rpmsg_device *rpdev = to_rpmsg_device(dev); > struct glink_channel *channel = to_glink_channel(rpdev->ept); > @@ -853,14 +858,15 @@ static void glink_rpm_rpdev_release(struct device *dev) > kfree(rpdev); > } > > -static int glink_rpm_rx_open(struct glink_rpm *glink, unsigned int rcid, > - char *name) > +static int qcom_glink_rx_open(struct qcom_glink *glink, unsigned int rcid, > + char *name) > { > struct glink_channel *channel; > struct rpmsg_device *rpdev; > bool create_device = false; > int lcid; > int ret; > + struct device_node *node; > > idr_for_each_entry(&glink->lcids, channel, lcid) { > if (!strcmp(channel->name, name)) > @@ -868,7 +874,7 @@ static int glink_rpm_rx_open(struct glink_rpm *glink, unsigned int rcid, > } > > if (!channel) { > - channel = glink_rpm_alloc_channel(glink, name); > + channel = qcom_glink_alloc_channel(glink, name); > if (IS_ERR(channel)) > return PTR_ERR(channel); > > @@ -901,9 +907,10 @@ static int glink_rpm_rx_open(struct glink_rpm *glink, unsigned int rcid, > rpdev->dst = RPMSG_ADDR_ANY; > rpdev->ops = &glink_device_ops; > > - rpdev->dev.of_node = glink_rpm_match_channel(glink->dev->of_node, name); > + node = qcom_glink_match_channel(glink->dev->of_node, name); > + rpdev->dev.of_node = node; > rpdev->dev.parent = glink->dev; > - rpdev->dev.release = glink_rpm_rpdev_release; > + rpdev->dev.release = qcom_glink_rpdev_release; > > ret = rpmsg_register_device(rpdev); > if (ret) > @@ -924,12 +931,12 @@ static int glink_rpm_rx_open(struct glink_rpm *glink, unsigned int rcid, > free_channel: > /* Release the reference, iff we took it */ > if (create_device) > - kref_put(&channel->refcount, glink_rpm_channel_release); > + kref_put(&channel->refcount, qcom_glink_channel_release); > > return ret; > } > > -static void glink_rpm_rx_close(struct glink_rpm *glink, unsigned int rcid) > +static void qcom_glink_rx_close(struct qcom_glink *glink, unsigned int rcid) > { > struct rpmsg_channel_info chinfo; > struct glink_channel *channel; > @@ -946,17 +953,17 @@ static void glink_rpm_rx_close(struct glink_rpm *glink, unsigned int rcid) > rpmsg_unregister_device(glink->dev, &chinfo); > } > > - glink_rpm_send_close_ack(glink, channel->rcid); > + qcom_glink_send_close_ack(glink, channel->rcid); > > mutex_lock(&glink->idr_lock); > idr_remove(&glink->rcids, channel->rcid); > channel->rcid = 0; > mutex_unlock(&glink->idr_lock); > > - kref_put(&channel->refcount, glink_rpm_channel_release); > + kref_put(&channel->refcount, qcom_glink_channel_release); > } > > -static void glink_rpm_rx_close_ack(struct glink_rpm *glink, unsigned int lcid) > +static void qcom_glink_rx_close_ack(struct qcom_glink *glink, unsigned int lcid) > { > struct glink_channel *channel; > > @@ -969,12 +976,13 @@ static void glink_rpm_rx_close_ack(struct glink_rpm *glink, unsigned int lcid) > channel->lcid = 0; > mutex_unlock(&glink->idr_lock); > > - kref_put(&channel->refcount, glink_rpm_channel_release); > + kref_put(&channel->refcount, qcom_glink_channel_release); > } > > -static void glink_rpm_work(struct work_struct *work) > +static void qcom_glink_work(struct work_struct *work) > { > - struct glink_rpm *glink = container_of(work, struct glink_rpm, rx_work); > + struct qcom_glink *glink = container_of(work, struct qcom_glink, > + rx_work); > struct glink_defer_cmd *dcmd; > struct glink_msg *msg; > unsigned long flags; > @@ -999,18 +1007,18 @@ static void glink_rpm_work(struct work_struct *work) > > switch (cmd) { > case RPM_CMD_VERSION: > - glink_rpm_send_version_ack(glink); > + qcom_glink_send_version_ack(glink); > break; > case RPM_CMD_VERSION_ACK: > break; > case RPM_CMD_OPEN: > - glink_rpm_rx_open(glink, param1, msg->data); > + qcom_glink_rx_open(glink, param1, msg->data); > break; > case RPM_CMD_CLOSE: > - glink_rpm_rx_close(glink, param1); > + qcom_glink_rx_close(glink, param1); > break; > case RPM_CMD_CLOSE_ACK: > - glink_rpm_rx_close_ack(glink, param1); > + qcom_glink_rx_close_ack(glink, param1); > break; > default: > WARN(1, "Unknown defer object %d\n", cmd); > @@ -1098,7 +1106,7 @@ static int glink_rpm_parse_toc(struct device *dev, > > static int glink_rpm_probe(struct platform_device *pdev) > { > - struct glink_rpm *glink; > + struct qcom_glink *glink; > struct device_node *np; > void __iomem *msg_ram; > size_t msg_ram_size; > @@ -1116,7 +1124,7 @@ static int glink_rpm_probe(struct platform_device *pdev) > mutex_init(&glink->tx_lock); > spin_lock_init(&glink->rx_lock); > INIT_LIST_HEAD(&glink->rx_queue); > - INIT_WORK(&glink->rx_work, glink_rpm_work); > + INIT_WORK(&glink->rx_work, qcom_glink_work); > > mutex_init(&glink->idr_lock); > idr_init(&glink->lcids); > @@ -1151,7 +1159,7 @@ static int glink_rpm_probe(struct platform_device *pdev) > > irq = platform_get_irq(pdev, 0); > ret = devm_request_irq(dev, irq, > - glink_rpm_intr, > + qcom_glink_intr, > IRQF_NO_SUSPEND | IRQF_SHARED, > "glink-rpm", glink); > if (ret) { > @@ -1161,7 +1169,7 @@ static int glink_rpm_probe(struct platform_device *pdev) > > glink->irq = irq; > > - ret = glink_rpm_send_version(glink); > + ret = qcom_glink_send_version(glink); > if (ret) > return ret; > > @@ -1179,7 +1187,7 @@ static int glink_rpm_remove_device(struct device *dev, void *data) > > static int glink_rpm_remove(struct platform_device *pdev) > { > - struct glink_rpm *glink = platform_get_drvdata(pdev); > + struct qcom_glink *glink = platform_get_drvdata(pdev); > struct glink_channel *channel; > int cid; > int ret; > @@ -1193,7 +1201,7 @@ static int glink_rpm_remove(struct platform_device *pdev) > > /* Release any defunct local channels, waiting for close-ack */ > idr_for_each_entry(&glink->lcids, channel, cid) > - kref_put(&channel->refcount, glink_rpm_channel_release); > + kref_put(&channel->refcount, qcom_glink_channel_release); > > idr_destroy(&glink->lcids); > idr_destroy(&glink->rcids); From mboxrd@z Thu Jan 1 00:00:00 1970 From: aneela@codeaurora.org (Arun Kumar Neelakantam) Date: Mon, 28 Aug 2017 17:12:53 +0530 Subject: [PATCH v2 01/20] rpmsg: glink: Rename glink_rpm_xx functions to qcom_glink_xx In-Reply-To: <1503559302-3744-2-git-send-email-sricharan@codeaurora.org> References: <1503559302-3744-1-git-send-email-sricharan@codeaurora.org> <1503559302-3744-2-git-send-email-sricharan@codeaurora.org> Message-ID: To: linux-arm-kernel@lists.infradead.org List-Id: linux-arm-kernel.lists.infradead.org On 8/24/2017 12:51 PM, Sricharan R wrote: > From: Bjorn Andersson > > Renaming the glink_rpm_xx functions and structs to qcom_glink_xx > equivalents helps to reuse the core glink protocol while adding > support for smem based glink transport in the later patches. > > Signed-off-by: Bjorn Andersson > Signed-off-by: Sricharan R Acked-by: Arun Kumar Neelakantam Reagrds Arun N > --- > drivers/rpmsg/qcom_glink_rpm.c | 248 +++++++++++++++++++++-------------------- > 1 file changed, 128 insertions(+), 120 deletions(-) > > diff --git a/drivers/rpmsg/qcom_glink_rpm.c b/drivers/rpmsg/qcom_glink_rpm.c > index 3559a3e..56a0a66 100644 > --- a/drivers/rpmsg/qcom_glink_rpm.c > +++ b/drivers/rpmsg/qcom_glink_rpm.c > @@ -101,7 +101,7 @@ struct glink_defer_cmd { > * @lcids: idr of all channels with a known local channel id > * @rcids: idr of all channels with a known remote channel id > */ > -struct glink_rpm { > +struct qcom_glink { > struct device *dev; > > struct mbox_client mbox_client; > @@ -134,7 +134,7 @@ enum { > * struct glink_channel - internal representation of a channel > * @rpdev: rpdev reference, only used for primary endpoints > * @ept: rpmsg endpoint this channel is associated with > - * @glink: glink_rpm context handle > + * @glink: qcom_glink context handle > * @refcount: refcount for the channel object > * @recv_lock: guard for @ept.cb > * @name: unique channel name/identifier > @@ -150,7 +150,7 @@ struct glink_channel { > struct rpmsg_endpoint ept; > > struct rpmsg_device *rpdev; > - struct glink_rpm *glink; > + struct qcom_glink *glink; > > struct kref refcount; > > @@ -184,8 +184,8 @@ struct glink_channel { > > #define GLINK_FEATURE_INTENTLESS BIT(1) > > -static struct glink_channel *glink_rpm_alloc_channel(struct glink_rpm *glink, > - const char *name) > +static struct glink_channel *qcom_glink_alloc_channel(struct qcom_glink *glink, > + const char *name) > { > struct glink_channel *channel; > > @@ -206,7 +206,7 @@ static struct glink_channel *glink_rpm_alloc_channel(struct glink_rpm *glink, > return channel; > } > > -static void glink_rpm_channel_release(struct kref *ref) > +static void qcom_glink_channel_release(struct kref *ref) > { > struct glink_channel *channel = container_of(ref, struct glink_channel, > refcount); > @@ -215,7 +215,7 @@ static void glink_rpm_channel_release(struct kref *ref) > kfree(channel); > } > > -static size_t glink_rpm_rx_avail(struct glink_rpm *glink) > +static size_t qcom_glink_rx_avail(struct qcom_glink *glink) > { > struct glink_rpm_pipe *pipe = &glink->rx_pipe; > unsigned int head; > @@ -230,8 +230,8 @@ static size_t glink_rpm_rx_avail(struct glink_rpm *glink) > return head - tail; > } > > -static void glink_rpm_rx_peak(struct glink_rpm *glink, > - void *data, size_t count) > +static void qcom_glink_rx_peak(struct qcom_glink *glink, > + void *data, size_t count) > { > struct glink_rpm_pipe *pipe = &glink->rx_pipe; > unsigned int tail; > @@ -251,8 +251,8 @@ static void glink_rpm_rx_peak(struct glink_rpm *glink, > } > } > > -static void glink_rpm_rx_advance(struct glink_rpm *glink, > - size_t count) > +static void qcom_glink_rx_advance(struct qcom_glink *glink, > + size_t count) > { > struct glink_rpm_pipe *pipe = &glink->rx_pipe; > unsigned int tail; > @@ -266,7 +266,7 @@ static void glink_rpm_rx_advance(struct glink_rpm *glink, > writel(tail, pipe->tail); > } > > -static size_t glink_rpm_tx_avail(struct glink_rpm *glink) > +static size_t qcom_glink_tx_avail(struct qcom_glink *glink) > { > struct glink_rpm_pipe *pipe = &glink->tx_pipe; > unsigned int head; > @@ -281,9 +281,9 @@ static size_t glink_rpm_tx_avail(struct glink_rpm *glink) > return tail - head; > } > > -static unsigned int glink_rpm_tx_write(struct glink_rpm *glink, > - unsigned int head, > - const void *data, size_t count) > +static unsigned int qcom_glink_tx_write(struct qcom_glink *glink, > + unsigned int head, > + const void *data, size_t count) > { > struct glink_rpm_pipe *pipe = &glink->tx_pipe; > size_t len; > @@ -306,8 +306,8 @@ static unsigned int glink_rpm_tx_write(struct glink_rpm *glink, > return head; > } > > -static int glink_rpm_tx(struct glink_rpm *glink, > - const void *hdr, size_t hlen, > +static int qcom_glink_tx(struct qcom_glink *glink, > + const void *hdr, size_t hlen, > const void *data, size_t dlen, bool wait) > { > struct glink_rpm_pipe *pipe = &glink->tx_pipe; > @@ -326,7 +326,7 @@ static int glink_rpm_tx(struct glink_rpm *glink, > if (ret) > return ret; > > - while (glink_rpm_tx_avail(glink) < tlen) { > + while (qcom_glink_tx_avail(glink) < tlen) { > if (!wait) { > ret = -ENOMEM; > goto out; > @@ -336,8 +336,8 @@ static int glink_rpm_tx(struct glink_rpm *glink, > } > > head = readl(pipe->head); > - head = glink_rpm_tx_write(glink, head, hdr, hlen); > - head = glink_rpm_tx_write(glink, head, data, dlen); > + head = qcom_glink_tx_write(glink, head, hdr, hlen); > + head = qcom_glink_tx_write(glink, head, data, dlen); > writel(head, pipe->head); > > mbox_send_message(glink->mbox_chan, NULL); > @@ -349,7 +349,7 @@ static int glink_rpm_tx(struct glink_rpm *glink, > return ret; > } > > -static int glink_rpm_send_version(struct glink_rpm *glink) > +static int qcom_glink_send_version(struct qcom_glink *glink) > { > struct glink_msg msg; > > @@ -357,10 +357,10 @@ static int glink_rpm_send_version(struct glink_rpm *glink) > msg.param1 = cpu_to_le16(1); > msg.param2 = cpu_to_le32(GLINK_FEATURE_INTENTLESS); > > - return glink_rpm_tx(glink, &msg, sizeof(msg), NULL, 0, true); > + return qcom_glink_tx(glink, &msg, sizeof(msg), NULL, 0, true); > } > > -static void glink_rpm_send_version_ack(struct glink_rpm *glink) > +static void qcom_glink_send_version_ack(struct qcom_glink *glink) > { > struct glink_msg msg; > > @@ -368,11 +368,11 @@ static void glink_rpm_send_version_ack(struct glink_rpm *glink) > msg.param1 = cpu_to_le16(1); > msg.param2 = cpu_to_le32(0); > > - glink_rpm_tx(glink, &msg, sizeof(msg), NULL, 0, true); > + qcom_glink_tx(glink, &msg, sizeof(msg), NULL, 0, true); > } > > -static void glink_rpm_send_open_ack(struct glink_rpm *glink, > - struct glink_channel *channel) > +static void qcom_glink_send_open_ack(struct qcom_glink *glink, > + struct glink_channel *channel) > { > struct glink_msg msg; > > @@ -380,11 +380,11 @@ static void glink_rpm_send_open_ack(struct glink_rpm *glink, > msg.param1 = cpu_to_le16(channel->rcid); > msg.param2 = cpu_to_le32(0); > > - glink_rpm_tx(glink, &msg, sizeof(msg), NULL, 0, true); > + qcom_glink_tx(glink, &msg, sizeof(msg), NULL, 0, true); > } > > /** > - * glink_rpm_send_open_req() - send a RPM_CMD_OPEN request to the remote > + * qcom_glink_send_open_req() - send a RPM_CMD_OPEN request to the remote > * @glink: > * @channel: > * > @@ -393,8 +393,8 @@ static void glink_rpm_send_open_ack(struct glink_rpm *glink, > * > * Returns 0 on success, negative errno otherwise. > */ > -static int glink_rpm_send_open_req(struct glink_rpm *glink, > - struct glink_channel *channel) > +static int qcom_glink_send_open_req(struct qcom_glink *glink, > + struct glink_channel *channel) > { > struct { > struct glink_msg msg; > @@ -420,7 +420,7 @@ static int glink_rpm_send_open_req(struct glink_rpm *glink, > req.msg.param2 = cpu_to_le32(name_len); > strcpy(req.name, channel->name); > > - ret = glink_rpm_tx(glink, &req, req_len, NULL, 0, true); > + ret = qcom_glink_tx(glink, &req, req_len, NULL, 0, true); > if (ret) > goto remove_idr; > > @@ -435,8 +435,8 @@ static int glink_rpm_send_open_req(struct glink_rpm *glink, > return ret; > } > > -static void glink_rpm_send_close_req(struct glink_rpm *glink, > - struct glink_channel *channel) > +static void qcom_glink_send_close_req(struct qcom_glink *glink, > + struct glink_channel *channel) > { > struct glink_msg req; > > @@ -444,10 +444,11 @@ static void glink_rpm_send_close_req(struct glink_rpm *glink, > req.param1 = cpu_to_le16(channel->lcid); > req.param2 = 0; > > - glink_rpm_tx(glink, &req, sizeof(req), NULL, 0, true); > + qcom_glink_tx(glink, &req, sizeof(req), NULL, 0, true); > } > > -static void glink_rpm_send_close_ack(struct glink_rpm *glink, unsigned int rcid) > +static void qcom_glink_send_close_ack(struct qcom_glink *glink, > + unsigned int rcid) > { > struct glink_msg req; > > @@ -455,16 +456,16 @@ static void glink_rpm_send_close_ack(struct glink_rpm *glink, unsigned int rcid) > req.param1 = cpu_to_le16(rcid); > req.param2 = 0; > > - glink_rpm_tx(glink, &req, sizeof(req), NULL, 0, true); > + qcom_glink_tx(glink, &req, sizeof(req), NULL, 0, true); > } > > -static int glink_rpm_rx_defer(struct glink_rpm *glink, size_t extra) > +static int qcom_glink_rx_defer(struct qcom_glink *glink, size_t extra) > { > struct glink_defer_cmd *dcmd; > > extra = ALIGN(extra, 8); > > - if (glink_rpm_rx_avail(glink) < sizeof(struct glink_msg) + extra) { > + if (qcom_glink_rx_avail(glink) < sizeof(struct glink_msg) + extra) { > dev_dbg(glink->dev, "Insufficient data in rx fifo"); > return -ENXIO; > } > @@ -475,19 +476,19 @@ static int glink_rpm_rx_defer(struct glink_rpm *glink, size_t extra) > > INIT_LIST_HEAD(&dcmd->node); > > - glink_rpm_rx_peak(glink, &dcmd->msg, sizeof(dcmd->msg) + extra); > + qcom_glink_rx_peak(glink, &dcmd->msg, sizeof(dcmd->msg) + extra); > > spin_lock(&glink->rx_lock); > list_add_tail(&dcmd->node, &glink->rx_queue); > spin_unlock(&glink->rx_lock); > > schedule_work(&glink->rx_work); > - glink_rpm_rx_advance(glink, sizeof(dcmd->msg) + extra); > + qcom_glink_rx_advance(glink, sizeof(dcmd->msg) + extra); > > return 0; > } > > -static int glink_rpm_rx_data(struct glink_rpm *glink, size_t avail) > +static int qcom_glink_rx_data(struct qcom_glink *glink, size_t avail) > { > struct glink_channel *channel; > struct { > @@ -504,7 +505,7 @@ static int glink_rpm_rx_data(struct glink_rpm *glink, size_t avail) > return -EAGAIN; > } > > - glink_rpm_rx_peak(glink, &hdr, sizeof(hdr)); > + qcom_glink_rx_peak(glink, &hdr, sizeof(hdr)); > chunk_size = le32_to_cpu(hdr.chunk_size); > left_size = le32_to_cpu(hdr.left_size); > > @@ -522,7 +523,8 @@ static int glink_rpm_rx_data(struct glink_rpm *glink, size_t avail) > dev_dbg(glink->dev, "Data on non-existing channel\n"); > > /* Drop the message */ > - glink_rpm_rx_advance(glink, ALIGN(sizeof(hdr) + chunk_size, 8)); > + qcom_glink_rx_advance(glink, > + ALIGN(sizeof(hdr) + chunk_size, 8)); > return 0; > } > > @@ -536,17 +538,18 @@ static int glink_rpm_rx_data(struct glink_rpm *glink, size_t avail) > channel->buf_offset = 0; > } > > - glink_rpm_rx_advance(glink, sizeof(hdr)); > + qcom_glink_rx_advance(glink, sizeof(hdr)); > > if (channel->buf_size - channel->buf_offset < chunk_size) { > dev_err(glink->dev, "Insufficient space in input buffer\n"); > > /* The packet header lied, drop payload */ > - glink_rpm_rx_advance(glink, chunk_size); > + qcom_glink_rx_advance(glink, chunk_size); > return -ENOMEM; > } > > - glink_rpm_rx_peak(glink, channel->buf + channel->buf_offset, chunk_size); > + qcom_glink_rx_peak(glink, channel->buf + channel->buf_offset, > + chunk_size); > channel->buf_offset += chunk_size; > > /* Handle message when no fragments remain to be received */ > @@ -567,12 +570,12 @@ static int glink_rpm_rx_data(struct glink_rpm *glink, size_t avail) > } > > /* Each message starts at 8 byte aligned address */ > - glink_rpm_rx_advance(glink, ALIGN(chunk_size, 8)); > + qcom_glink_rx_advance(glink, ALIGN(chunk_size, 8)); > > return 0; > } > > -static int glink_rpm_rx_open_ack(struct glink_rpm *glink, unsigned int lcid) > +static int qcom_glink_rx_open_ack(struct qcom_glink *glink, unsigned int lcid) > { > struct glink_channel *channel; > > @@ -587,9 +590,9 @@ static int glink_rpm_rx_open_ack(struct glink_rpm *glink, unsigned int lcid) > return 0; > } > > -static irqreturn_t glink_rpm_intr(int irq, void *data) > +static irqreturn_t qcom_glink_intr(int irq, void *data) > { > - struct glink_rpm *glink = data; > + struct qcom_glink *glink = data; > struct glink_msg msg; > unsigned int param1; > unsigned int param2; > @@ -598,11 +601,11 @@ static irqreturn_t glink_rpm_intr(int irq, void *data) > int ret; > > for (;;) { > - avail = glink_rpm_rx_avail(glink); > + avail = qcom_glink_rx_avail(glink); > if (avail < sizeof(msg)) > break; > > - glink_rpm_rx_peak(glink, &msg, sizeof(msg)); > + qcom_glink_rx_peak(glink, &msg, sizeof(msg)); > > cmd = le16_to_cpu(msg.cmd); > param1 = le16_to_cpu(msg.param1); > @@ -613,21 +616,21 @@ static irqreturn_t glink_rpm_intr(int irq, void *data) > case RPM_CMD_VERSION_ACK: > case RPM_CMD_CLOSE: > case RPM_CMD_CLOSE_ACK: > - ret = glink_rpm_rx_defer(glink, 0); > + ret = qcom_glink_rx_defer(glink, 0); > break; > case RPM_CMD_OPEN_ACK: > - ret = glink_rpm_rx_open_ack(glink, param1); > - glink_rpm_rx_advance(glink, ALIGN(sizeof(msg), 8)); > + ret = qcom_glink_rx_open_ack(glink, param1); > + qcom_glink_rx_advance(glink, ALIGN(sizeof(msg), 8)); > break; > case RPM_CMD_OPEN: > - ret = glink_rpm_rx_defer(glink, param2); > + ret = qcom_glink_rx_defer(glink, param2); > break; > case RPM_CMD_TX_DATA: > case RPM_CMD_TX_DATA_CONT: > - ret = glink_rpm_rx_data(glink, avail); > + ret = qcom_glink_rx_data(glink, avail); > break; > case RPM_CMD_READ_NOTIF: > - glink_rpm_rx_advance(glink, ALIGN(sizeof(msg), 8)); > + qcom_glink_rx_advance(glink, ALIGN(sizeof(msg), 8)); > > mbox_send_message(glink->mbox_chan, NULL); > mbox_client_txdone(glink->mbox_chan, 0); > @@ -648,17 +651,17 @@ static irqreturn_t glink_rpm_intr(int irq, void *data) > } > > /* Locally initiated rpmsg_create_ept */ > -static struct glink_channel *glink_rpm_create_local(struct glink_rpm *glink, > - const char *name) > +static struct glink_channel *qcom_glink_create_local(struct qcom_glink *glink, > + const char *name) > { > struct glink_channel *channel; > int ret; > > - channel = glink_rpm_alloc_channel(glink, name); > + channel = qcom_glink_alloc_channel(glink, name); > if (IS_ERR(channel)) > return ERR_CAST(channel); > > - ret = glink_rpm_send_open_req(glink, channel); > + ret = qcom_glink_send_open_req(glink, channel); > if (ret) > goto release_channel; > > @@ -670,34 +673,34 @@ static struct glink_channel *glink_rpm_create_local(struct glink_rpm *glink, > if (!ret) > goto err_timeout; > > - glink_rpm_send_open_ack(glink, channel); > + qcom_glink_send_open_ack(glink, channel); > > return channel; > > err_timeout: > - /* glink_rpm_send_open_req() did register the channel in lcids*/ > + /* qcom_glink_send_open_req() did register the channel in lcids*/ > mutex_lock(&glink->idr_lock); > idr_remove(&glink->lcids, channel->lcid); > mutex_unlock(&glink->idr_lock); > > release_channel: > - /* Release glink_rpm_send_open_req() reference */ > - kref_put(&channel->refcount, glink_rpm_channel_release); > - /* Release glink_rpm_alloc_channel() reference */ > - kref_put(&channel->refcount, glink_rpm_channel_release); > + /* Release qcom_glink_send_open_req() reference */ > + kref_put(&channel->refcount, qcom_glink_channel_release); > + /* Release qcom_glink_alloc_channel() reference */ > + kref_put(&channel->refcount, qcom_glink_channel_release); > > return ERR_PTR(-ETIMEDOUT); > } > > /* Remote initiated rpmsg_create_ept */ > -static int glink_rpm_create_remote(struct glink_rpm *glink, > - struct glink_channel *channel) > +static int qcom_glink_create_remote(struct qcom_glink *glink, > + struct glink_channel *channel) > { > int ret; > > - glink_rpm_send_open_ack(glink, channel); > + qcom_glink_send_open_ack(glink, channel); > > - ret = glink_rpm_send_open_req(glink, channel); > + ret = qcom_glink_send_open_req(glink, channel); > if (ret) > goto close_link; > > @@ -714,21 +717,23 @@ static int glink_rpm_create_remote(struct glink_rpm *glink, > * Send a close request to "undo" our open-ack. The close-ack will > * release the last reference. > */ > - glink_rpm_send_close_req(glink, channel); > + qcom_glink_send_close_req(glink, channel); > > - /* Release glink_rpm_send_open_req() reference */ > - kref_put(&channel->refcount, glink_rpm_channel_release); > + /* Release qcom_glink_send_open_req() reference */ > + kref_put(&channel->refcount, qcom_glink_channel_release); > > return ret; > } > > -static struct rpmsg_endpoint *glink_rpm_create_ept(struct rpmsg_device *rpdev, > - rpmsg_rx_cb_t cb, void *priv, > - struct rpmsg_channel_info chinfo) > +static struct rpmsg_endpoint *qcom_glink_create_ept(struct rpmsg_device *rpdev, > + rpmsg_rx_cb_t cb, > + void *priv, > + struct rpmsg_channel_info > + chinfo) > { > struct glink_channel *parent = to_glink_channel(rpdev->ept); > struct glink_channel *channel; > - struct glink_rpm *glink = parent->glink; > + struct qcom_glink *glink = parent->glink; > struct rpmsg_endpoint *ept; > const char *name = chinfo.name; > int cid; > @@ -740,11 +745,11 @@ static struct rpmsg_endpoint *glink_rpm_create_ept(struct rpmsg_device *rpdev, > } > > if (!channel) { > - channel = glink_rpm_create_local(glink, name); > + channel = qcom_glink_create_local(glink, name); > if (IS_ERR(channel)) > return NULL; > } else { > - ret = glink_rpm_create_remote(glink, channel); > + ret = qcom_glink_create_remote(glink, channel); > if (ret) > return NULL; > } > @@ -758,10 +763,10 @@ static struct rpmsg_endpoint *glink_rpm_create_ept(struct rpmsg_device *rpdev, > return ept; > } > > -static void glink_rpm_destroy_ept(struct rpmsg_endpoint *ept) > +static void qcom_glink_destroy_ept(struct rpmsg_endpoint *ept) > { > struct glink_channel *channel = to_glink_channel(ept); > - struct glink_rpm *glink = channel->glink; > + struct qcom_glink *glink = channel->glink; > unsigned long flags; > > spin_lock_irqsave(&channel->recv_lock, flags); > @@ -771,13 +776,13 @@ static void glink_rpm_destroy_ept(struct rpmsg_endpoint *ept) > /* Decouple the potential rpdev from the channel */ > channel->rpdev = NULL; > > - glink_rpm_send_close_req(glink, channel); > + qcom_glink_send_close_req(glink, channel); > } > > -static int __glink_rpm_send(struct glink_channel *channel, > +static int __qcom_glink_send(struct glink_channel *channel, > void *data, int len, bool wait) > { > - struct glink_rpm *glink = channel->glink; > + struct qcom_glink *glink = channel->glink; > struct { > struct glink_msg msg; > __le32 chunk_size; > @@ -793,27 +798,27 @@ static int __glink_rpm_send(struct glink_channel *channel, > req.chunk_size = cpu_to_le32(len); > req.left_size = cpu_to_le32(0); > > - return glink_rpm_tx(glink, &req, sizeof(req), data, len, wait); > + return qcom_glink_tx(glink, &req, sizeof(req), data, len, wait); > } > > -static int glink_rpm_send(struct rpmsg_endpoint *ept, void *data, int len) > +static int qcom_glink_send(struct rpmsg_endpoint *ept, void *data, int len) > { > struct glink_channel *channel = to_glink_channel(ept); > > - return __glink_rpm_send(channel, data, len, true); > + return __qcom_glink_send(channel, data, len, true); > } > > -static int glink_rpm_trysend(struct rpmsg_endpoint *ept, void *data, int len) > +static int qcom_glink_trysend(struct rpmsg_endpoint *ept, void *data, int len) > { > struct glink_channel *channel = to_glink_channel(ept); > > - return __glink_rpm_send(channel, data, len, false); > + return __qcom_glink_send(channel, data, len, false); > } > > /* > * Finds the device_node for the glink child interested in this channel. > */ > -static struct device_node *glink_rpm_match_channel(struct device_node *node, > +static struct device_node *qcom_glink_match_channel(struct device_node *node, > const char *channel) > { > struct device_node *child; > @@ -835,16 +840,16 @@ static struct device_node *glink_rpm_match_channel(struct device_node *node, > } > > static const struct rpmsg_device_ops glink_device_ops = { > - .create_ept = glink_rpm_create_ept, > + .create_ept = qcom_glink_create_ept, > }; > > static const struct rpmsg_endpoint_ops glink_endpoint_ops = { > - .destroy_ept = glink_rpm_destroy_ept, > - .send = glink_rpm_send, > - .trysend = glink_rpm_trysend, > + .destroy_ept = qcom_glink_destroy_ept, > + .send = qcom_glink_send, > + .trysend = qcom_glink_trysend, > }; > > -static void glink_rpm_rpdev_release(struct device *dev) > +static void qcom_glink_rpdev_release(struct device *dev) > { > struct rpmsg_device *rpdev = to_rpmsg_device(dev); > struct glink_channel *channel = to_glink_channel(rpdev->ept); > @@ -853,14 +858,15 @@ static void glink_rpm_rpdev_release(struct device *dev) > kfree(rpdev); > } > > -static int glink_rpm_rx_open(struct glink_rpm *glink, unsigned int rcid, > - char *name) > +static int qcom_glink_rx_open(struct qcom_glink *glink, unsigned int rcid, > + char *name) > { > struct glink_channel *channel; > struct rpmsg_device *rpdev; > bool create_device = false; > int lcid; > int ret; > + struct device_node *node; > > idr_for_each_entry(&glink->lcids, channel, lcid) { > if (!strcmp(channel->name, name)) > @@ -868,7 +874,7 @@ static int glink_rpm_rx_open(struct glink_rpm *glink, unsigned int rcid, > } > > if (!channel) { > - channel = glink_rpm_alloc_channel(glink, name); > + channel = qcom_glink_alloc_channel(glink, name); > if (IS_ERR(channel)) > return PTR_ERR(channel); > > @@ -901,9 +907,10 @@ static int glink_rpm_rx_open(struct glink_rpm *glink, unsigned int rcid, > rpdev->dst = RPMSG_ADDR_ANY; > rpdev->ops = &glink_device_ops; > > - rpdev->dev.of_node = glink_rpm_match_channel(glink->dev->of_node, name); > + node = qcom_glink_match_channel(glink->dev->of_node, name); > + rpdev->dev.of_node = node; > rpdev->dev.parent = glink->dev; > - rpdev->dev.release = glink_rpm_rpdev_release; > + rpdev->dev.release = qcom_glink_rpdev_release; > > ret = rpmsg_register_device(rpdev); > if (ret) > @@ -924,12 +931,12 @@ static int glink_rpm_rx_open(struct glink_rpm *glink, unsigned int rcid, > free_channel: > /* Release the reference, iff we took it */ > if (create_device) > - kref_put(&channel->refcount, glink_rpm_channel_release); > + kref_put(&channel->refcount, qcom_glink_channel_release); > > return ret; > } > > -static void glink_rpm_rx_close(struct glink_rpm *glink, unsigned int rcid) > +static void qcom_glink_rx_close(struct qcom_glink *glink, unsigned int rcid) > { > struct rpmsg_channel_info chinfo; > struct glink_channel *channel; > @@ -946,17 +953,17 @@ static void glink_rpm_rx_close(struct glink_rpm *glink, unsigned int rcid) > rpmsg_unregister_device(glink->dev, &chinfo); > } > > - glink_rpm_send_close_ack(glink, channel->rcid); > + qcom_glink_send_close_ack(glink, channel->rcid); > > mutex_lock(&glink->idr_lock); > idr_remove(&glink->rcids, channel->rcid); > channel->rcid = 0; > mutex_unlock(&glink->idr_lock); > > - kref_put(&channel->refcount, glink_rpm_channel_release); > + kref_put(&channel->refcount, qcom_glink_channel_release); > } > > -static void glink_rpm_rx_close_ack(struct glink_rpm *glink, unsigned int lcid) > +static void qcom_glink_rx_close_ack(struct qcom_glink *glink, unsigned int lcid) > { > struct glink_channel *channel; > > @@ -969,12 +976,13 @@ static void glink_rpm_rx_close_ack(struct glink_rpm *glink, unsigned int lcid) > channel->lcid = 0; > mutex_unlock(&glink->idr_lock); > > - kref_put(&channel->refcount, glink_rpm_channel_release); > + kref_put(&channel->refcount, qcom_glink_channel_release); > } > > -static void glink_rpm_work(struct work_struct *work) > +static void qcom_glink_work(struct work_struct *work) > { > - struct glink_rpm *glink = container_of(work, struct glink_rpm, rx_work); > + struct qcom_glink *glink = container_of(work, struct qcom_glink, > + rx_work); > struct glink_defer_cmd *dcmd; > struct glink_msg *msg; > unsigned long flags; > @@ -999,18 +1007,18 @@ static void glink_rpm_work(struct work_struct *work) > > switch (cmd) { > case RPM_CMD_VERSION: > - glink_rpm_send_version_ack(glink); > + qcom_glink_send_version_ack(glink); > break; > case RPM_CMD_VERSION_ACK: > break; > case RPM_CMD_OPEN: > - glink_rpm_rx_open(glink, param1, msg->data); > + qcom_glink_rx_open(glink, param1, msg->data); > break; > case RPM_CMD_CLOSE: > - glink_rpm_rx_close(glink, param1); > + qcom_glink_rx_close(glink, param1); > break; > case RPM_CMD_CLOSE_ACK: > - glink_rpm_rx_close_ack(glink, param1); > + qcom_glink_rx_close_ack(glink, param1); > break; > default: > WARN(1, "Unknown defer object %d\n", cmd); > @@ -1098,7 +1106,7 @@ static int glink_rpm_parse_toc(struct device *dev, > > static int glink_rpm_probe(struct platform_device *pdev) > { > - struct glink_rpm *glink; > + struct qcom_glink *glink; > struct device_node *np; > void __iomem *msg_ram; > size_t msg_ram_size; > @@ -1116,7 +1124,7 @@ static int glink_rpm_probe(struct platform_device *pdev) > mutex_init(&glink->tx_lock); > spin_lock_init(&glink->rx_lock); > INIT_LIST_HEAD(&glink->rx_queue); > - INIT_WORK(&glink->rx_work, glink_rpm_work); > + INIT_WORK(&glink->rx_work, qcom_glink_work); > > mutex_init(&glink->idr_lock); > idr_init(&glink->lcids); > @@ -1151,7 +1159,7 @@ static int glink_rpm_probe(struct platform_device *pdev) > > irq = platform_get_irq(pdev, 0); > ret = devm_request_irq(dev, irq, > - glink_rpm_intr, > + qcom_glink_intr, > IRQF_NO_SUSPEND | IRQF_SHARED, > "glink-rpm", glink); > if (ret) { > @@ -1161,7 +1169,7 @@ static int glink_rpm_probe(struct platform_device *pdev) > > glink->irq = irq; > > - ret = glink_rpm_send_version(glink); > + ret = qcom_glink_send_version(glink); > if (ret) > return ret; > > @@ -1179,7 +1187,7 @@ static int glink_rpm_remove_device(struct device *dev, void *data) > > static int glink_rpm_remove(struct platform_device *pdev) > { > - struct glink_rpm *glink = platform_get_drvdata(pdev); > + struct qcom_glink *glink = platform_get_drvdata(pdev); > struct glink_channel *channel; > int cid; > int ret; > @@ -1193,7 +1201,7 @@ static int glink_rpm_remove(struct platform_device *pdev) > > /* Release any defunct local channels, waiting for close-ack */ > idr_for_each_entry(&glink->lcids, channel, cid) > - kref_put(&channel->refcount, glink_rpm_channel_release); > + kref_put(&channel->refcount, qcom_glink_channel_release); > > idr_destroy(&glink->lcids); > idr_destroy(&glink->rcids);