[<prev] [next>] [<thread-prev] [day] [month] [year] [list]
Date: Fri, 9 Sep 2022 10:22:53 -0300
From: Arnaldo Carvalho de Melo <acme@...nel.org>
To: Namhyung Kim <namhyung@...nel.org>
Cc: Jiri Olsa <jolsa@...nel.org>, Ingo Molnar <mingo@...nel.org>,
Peter Zijlstra <peterz@...radead.org>,
LKML <linux-kernel@...r.kernel.org>,
Ian Rogers <irogers@...gle.com>,
Adrian Hunter <adrian.hunter@...el.com>,
linux-perf-users@...r.kernel.org
Subject: Re: [PATCH] perf sched: Factor out destroy_tasks()
Em Thu, Sep 08, 2022 at 03:54:48PM -0700, Namhyung Kim escreveu:
> Add destroy_tasks() as a counterpart of create_tasks() and put the
> thread safety notations there. After join, it destroys semaphores too.
Thanks, applied.
- Arnaldo
> Signed-off-by: Namhyung Kim <namhyung@...nel.org>
> ---
> tools/perf/builtin-sched.c | 24 ++++++++++++++++++++++--
> 1 file changed, 22 insertions(+), 2 deletions(-)
>
> diff --git a/tools/perf/builtin-sched.c b/tools/perf/builtin-sched.c
> index a92610eac4bf..f93737eef07b 100644
> --- a/tools/perf/builtin-sched.c
> +++ b/tools/perf/builtin-sched.c
> @@ -690,6 +690,27 @@ static void create_tasks(struct perf_sched *sched)
> }
> }
>
> +static void destroy_tasks(struct perf_sched *sched)
> + UNLOCK_FUNCTION(sched->start_work_mutex)
> + UNLOCK_FUNCTION(sched->work_done_wait_mutex)
> +{
> + struct task_desc *task;
> + unsigned long i;
> + int err;
> +
> + mutex_unlock(&sched->start_work_mutex);
> + mutex_unlock(&sched->work_done_wait_mutex);
> + /* Get rid of threads so they won't be upset by mutex destrunction */
> + for (i = 0; i < sched->nr_tasks; i++) {
> + task = sched->tasks[i];
> + err = pthread_join(task->thread, NULL);
> + BUG_ON(err);
> + sem_destroy(&task->sleep_sem);
> + sem_destroy(&task->ready_for_work);
> + sem_destroy(&task->work_done_sem);
> + }
> +}
> +
> static void wait_for_tasks(struct perf_sched *sched)
> EXCLUSIVE_LOCKS_REQUIRED(sched->work_done_wait_mutex)
> EXCLUSIVE_LOCKS_REQUIRED(sched->start_work_mutex)
> @@ -3324,8 +3345,7 @@ static int perf_sched__replay(struct perf_sched *sched)
> run_one_test(sched);
>
> sched->thread_funcs_exit = true;
> - mutex_unlock(&sched->start_work_mutex);
> - mutex_unlock(&sched->work_done_wait_mutex);
> + destroy_tasks(sched);
> return 0;
> }
>
> --
> 2.37.2.789.g6183377224-goog
--
- Arnaldo
Powered by blists - more mailing lists