Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 8b5f7e63 authored by AnilKumar Chimata's avatar AnilKumar Chimata
Browse files

qseecom: use wait_event_interruptible 



Kernel threads are not freezable by default, change to use
wait_event_interruptible to prevent a frozen qseecom thread
being blocked until another frozen thread is thawed.

Change-Id: I09d374c763a316201e790d9003b0b9785debd44a
Signed-off-by: default avatarZhen Kong <zkong@codeaurora.org>
Signed-off-by: default avatarAnilKumar Chimata <anilc@codeaurora.org>
parent 5084762c

drivers/misc/qseecom.c

+13 −11
Original line number Diff line number Diff line
@@ -1233,7 +1233,7 @@ static int qseecom_register_listener(struct qseecom_dev_handle *data, 
			pr_debug("register %d has to wait\n",

				rcvd_lstnr.listener_id);

			mutex_unlock(&listener_access_lock);

			ret = wait_event_freezable(

			ret = wait_event_interruptible(

				qseecom.register_lsnr_pending_wq,

				list_empty(

				&qseecom.unregister_lsnr_pending_list_head));
@@ -1308,7 +1308,7 @@ static int __qseecom_unregister_listener(struct qseecom_dev_handle *data, 
	}



	while (atomic_read(&data->ioctl_count) > 1) {

		if (wait_event_freezable(data->abort_wq,

		if (wait_event_interruptible(data->abort_wq,

				atomic_read(&data->ioctl_count) <= 1)) {

			pr_err("Interrupted from abort\n");

			ret = -ERESTARTSYS;
@@ -1416,7 +1416,7 @@ static void __wakeup_unregister_listener_kthread(void) 
static int __qseecom_unregister_listener_kthread_func(void *data)

{

	while (!kthread_should_stop()) {

		wait_event_freezable(

		wait_event_interruptible(

			qseecom.unregister_lsnr_kthread_wq,

			atomic_read(&qseecom.unregister_lsnr_kthread_state)

				== LSNR_UNREG_KT_WAKEUP);
@@ -1844,14 +1844,14 @@ static int __qseecom_process_incomplete_cmd(struct qseecom_dev_handle *data, 
			 * send_resp_flag.

			 */

			if (!qseecom.qsee_reentrancy_support &&

				!wait_event_freezable(qseecom.send_resp_wq,

				!wait_event_interruptible(qseecom.send_resp_wq,

				__qseecom_listener_has_sent_rsp(

						data, ptr_svc))) {

				break;

			}



			if (qseecom.qsee_reentrancy_support &&

				!wait_event_freezable(qseecom.send_resp_wq,

				!wait_event_interruptible(qseecom.send_resp_wq,

				__qseecom_reentrancy_listener_has_sent_rsp(

						data, ptr_svc))) {

				break;
@@ -2027,7 +2027,7 @@ static int __qseecom_process_reentrancy_blocked_on_listener( 
			ptr_app->app_blocked = true;

			mutex_unlock(&listener_access_lock);

			mutex_unlock(&app_access_lock);

			wait_event_freezable(

			wait_event_interruptible(

				list_ptr->listener_block_app_wq,

				!list_ptr->listener_in_use);

			mutex_lock(&app_access_lock);
@@ -2160,7 +2160,7 @@ static int __qseecom_reentrancy_process_incomplete_cmd( 
		mutex_unlock(&listener_access_lock);

		mutex_unlock(&app_access_lock);

		do {

			if (!wait_event_freezable(qseecom.send_resp_wq,

			if (!wait_event_interruptible(qseecom.send_resp_wq,

				__qseecom_reentrancy_listener_has_sent_rsp(

						data, ptr_svc))) {

				break;
@@ -2307,7 +2307,8 @@ static void __qseecom_reentrancy_check_if_no_app_blocked(uint32_t smc_id) 
			sigprocmask(SIG_SETMASK, &new_sigset, &old_sigset);

			mutex_unlock(&app_access_lock);

			do {

				if (!wait_event_freezable(qseecom.app_block_wq,

				if (!wait_event_interruptible(

					qseecom.app_block_wq,

					(qseecom.app_block_ref_cnt == 0)))

					break;

			} while (1);
@@ -2335,7 +2336,8 @@ static void __qseecom_reentrancy_check_if_this_app_blocked( 
			sigprocmask(SIG_SETMASK, &new_sigset, &old_sigset);

			mutex_unlock(&app_access_lock);

			do {

				if (!wait_event_freezable(qseecom.app_block_wq,

				if (!wait_event_interruptible(

					qseecom.app_block_wq,

					(!ptr_app->app_blocked &&

					qseecom.app_block_ref_cnt <= 1)))

					break;
@@ -2666,7 +2668,7 @@ static int __qseecom_cleanup_app(struct qseecom_dev_handle *data) 
	if (qseecom.qsee_reentrancy_support)

		mutex_unlock(&app_access_lock);

	while (atomic_read(&data->ioctl_count) > 1) {

		if (wait_event_freezable(data->abort_wq,

		if (wait_event_interruptible(data->abort_wq,

					atomic_read(&data->ioctl_count) <= 1)) {

			pr_err("Interrupted from abort\n");

			ret = -ERESTARTSYS;
@@ -4005,7 +4007,7 @@ static int qseecom_receive_req(struct qseecom_dev_handle *data) 
	mutex_unlock(&listener_access_lock);



	while (1) {

		if (wait_event_freezable(this_lstnr->rcv_req_wq,

		if (wait_event_interruptible(this_lstnr->rcv_req_wq,

				__qseecom_listener_has_rcvd_req(data,

				this_lstnr))) {

			pr_warn("Interrupted: exiting Listener Service = %d\n",