alex/bcachefs-tools
1
0
Fork 0
mirror of https://github.com/koverstreet/bcachefs-tools.git synced 2025-02-09 00:00:04 +03:00
Code Issues Actions 2 Packages Projects Releases Wiki Activity

Stop the timer task at process exit time, to make valgrind happy.

Browse Source 
Signed-off-by: Justin Husted <sigstop@gmail.com>
This commit is contained in:
Justin Husted 2019-11-02 23:45:34 -07:00 committed by Kent Overstreet
parent 36e4b3147e
commit b20e160735
1 changed files with 21 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
linux/timer.c
View File

@ -244,6 +244,8 @@ out:
return idx >= 0; return idx >= 0;
} }
static bool timer_thread_stop = false;
static int timer_thread(void *arg) static int timer_thread(void *arg)
{ {
struct pending_timer *p; struct pending_timer *p;
@ -253,7 +255,7 @@ static int timer_thread(void *arg)
pthread_mutex_lock(&timer_lock); pthread_mutex_lock(&timer_lock);
while (1) { while (!timer_thread_stop) {
now = jiffies; now = jiffies;
p = heap_peek(&pending_timers); p = heap_peek(&pending_timers);
@ -295,14 +297,28 @@ static int timer_thread(void *arg)
return 0; return 0;
} }
struct task_struct *timer_task;
__attribute__((constructor(103))) __attribute__((constructor(103)))
static void timers_init(void) static void timers_init(void)
{ {
struct task_struct *p;
heap_init(&pending_timers, 64); heap_init(&pending_timers, 64);
BUG_ON(!pending_timers.data); BUG_ON(!pending_timers.data);
p = kthread_run(timer_thread, NULL, "timers"); timer_task = kthread_run(timer_thread, NULL, "timers");
BUG_ON(IS_ERR(p)); BUG_ON(IS_ERR(timer_task));
}
__attribute__((destructor(103)))
static void timers_cleanup(void)
{
pthread_mutex_lock(&timer_lock);
timer_thread_stop = true;
pthread_cond_signal(&timer_cond);
pthread_mutex_unlock(&timer_lock);
int ret = kthread_stop(timer_task);
BUG_ON(ret);
timer_task = NULL;
} }