From 1b3424a485e3a98c12ad081e48752f2417730979 Mon Sep 17 00:00:00 2001 From: Michal Mielewczyk Date: Tue, 31 Mar 2020 06:46:27 -0400 Subject: [PATCH] Revert "Free memory of all allocated threads." This reverts commit 4ec277433d86b73d6739c98ffb24b5535ad83bc0. --- modules/cas_cache/threads.c | 12 ++---------- 1 file changed, 2 insertions(+), 10 deletions(-) diff --git a/modules/cas_cache/threads.c b/modules/cas_cache/threads.c index f83f37f..4bae862 100644 --- a/modules/cas_cache/threads.c +++ b/modules/cas_cache/threads.c @@ -51,10 +51,8 @@ static int _cas_io_queue_thread(void *data) /* If we get here, then thread was signalled to terminate. * So, let's free memory and exit. */ - wait_for_completion(&info->compl); printk(KERN_DEBUG "Thread %s stopped\n", info->name); kfree(info); - do_exit(0); return 0; } @@ -113,9 +111,7 @@ static int _cas_cleaner_thread(void *data) } } while (true); - wait_for_completion(&info->compl); - kfree(info); - do_exit(0); + complete_and_exit(&info->compl, 0); return 0; } @@ -147,9 +143,7 @@ static int _cas_metadata_updater_thread(void *data) atomic_read(&info->kicked)); } while (true); - wait_for_completion(&info->compl); - kfree(info); - do_exit(0); + complete_and_exit(&info->compl, 0); return 0; } @@ -205,10 +199,8 @@ static void _cas_start_thread(struct cas_thread_info *info) static void _cas_stop_thread(struct cas_thread_info *info) { if (info && info->thread) { - reinit_completion(&info->compl); atomic_set(&info->stop, 1); wake_up(&info->wq); - complete(&info->compl); } }