evie/android_kernel_oneplus_msm8998
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

soc: qcom: glink_ssr: Add rx done for received packets

Browse source 
Glink ssr client does not send rx done even in success cases.
This leads to memory leak in transport layer.

Added worker for sending rx_done in deferred context.

CRs-Fixed: 1100789
Change-Id: I84a936f834101ba2ad9e354c4d8df6d3c051a2f7
Signed-off-by: Dhoat Harpal <hdhoat@codeaurora.org>
This commit is contained in:
Dhoat Harpal 2016-12-20 18:22:57 +05:30
parent 3162449f7d
commit 9d8ae4e698
1 changed files with 33 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

33
drivers/soc/qcom/glink_ssr.c
View file

@ -79,6 +79,19 @@ struct configure_and_open_ch_work {
struct work_struct work;
};
/**
* struct rx_done_ch_work - Work structure used for sending rx_done on
* glink_ssr channels
* handle: G-Link channel handle to be used for sending rx_done
* ptr: Intent pointer data provided in notify rx function
* work: Work structure
*/
struct rx_done_ch_work {
void *handle;
const void *ptr;
struct work_struct work;
};
/**
* struct close_ch_work - Work structure for used for closing glink_ssr channels
* edge: The G-Link edge name for the channel being closed
@ -102,6 +115,15 @@ static LIST_HEAD(subsystem_list);
static atomic_t responses_remaining = ATOMIC_INIT(0);
static wait_queue_head_t waitqueue;
static void rx_done_cb_worker(struct work_struct *work)
{
struct rx_done_ch_work *rx_done_work =
container_of(work, struct rx_done_ch_work, work);
glink_rx_done(rx_done_work->handle, rx_done_work->ptr, false);
kfree(rx_done_work);
}
static void link_state_cb_worker(struct work_struct *work)
{
unsigned long flags;
@ -196,7 +218,14 @@ void glink_ssr_notify_rx(void *handle, const void *priv, const void *pkt_priv,
{
struct ssr_notify_data *cb_data = (struct ssr_notify_data *)priv;
struct cleanup_done_msg *resp = (struct cleanup_done_msg *)ptr;
struct rx_done_ch_work *rx_done_work;
rx_done_work = kmalloc(sizeof(*rx_done_work), GFP_ATOMIC);
if (!rx_done_work) {
GLINK_SSR_ERR("<SSR> %s: Could not allocate rx_done_work\n",
__func__);
return;
}
if (unlikely(!cb_data))
goto missing_cb_data;
if (unlikely(!cb_data->do_cleanup_data))
@ -221,6 +250,10 @@ void glink_ssr_notify_rx(void *handle, const void *priv, const void *pkt_priv,
kfree(cb_data->do_cleanup_data);
cb_data->do_cleanup_data = NULL;
rx_done_work->ptr = ptr;
rx_done_work->handle = handle;
INIT_WORK(&rx_done_work->work, rx_done_cb_worker);
queue_work(glink_ssr_wq, &rx_done_work->work);
wake_up(&waitqueue);
return;