github/open-cas-linux
2
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Revert "Free thread memory after it is stopped."

Browse Source 
This reverts commit d483951ebe.
This commit is contained in:
Michal Mielewczyk 2020-03-31 06:47:37 -04:00
parent 1b3424a485
commit 664c974e03
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
modules/cas_cache/threads.c
View File

@ -49,10 +49,9 @@ static int _cas_io_queue_thread(void *data)
WARN(ocf_queue_pending_io(q), "Still pending IO requests\n"); WARN(ocf_queue_pending_io(q), "Still pending IO requests\n");
/* If we get here, then thread was signalled to terminate. /* If we get here, then thread was signalled to terminate.
* So, let's free memory and exit. * So, let's complete and exit.
*/ */
printk(KERN_DEBUG "Thread %s stopped\n", info->name); complete_and_exit(&info->compl, 0);
kfree(info);
return 0; return 0;
} }
@ -199,9 +198,13 @@ static void _cas_start_thread(struct cas_thread_info *info)
static void _cas_stop_thread(struct cas_thread_info *info) static void _cas_stop_thread(struct cas_thread_info *info)
{ {
if (info && info->thread) { if (info && info->thread) {
reinit_completion(&info->compl);
atomic_set(&info->stop, 1); atomic_set(&info->stop, 1);
wake_up(&info->wq); wake_up(&info->wq);
wait_for_completion(&info->compl);
printk(KERN_DEBUG "Thread %s stopped\n", info->name);
} }
kfree(info);
} }
int cas_create_queue_thread(ocf_queue_t q, int cpu) int cas_create_queue_thread(ocf_queue_t q, int cpu)