Sharing map groups within all process threads. This way
there's only one copy of mmap info and it's reachable
from any thread within the process.

Original-patch-by: Arnaldo Carvalho de Melo <a...@redhat.com>
Cc: Adrian Hunter <adrian.hun...@intel.com>
Cc: David Ahern <dsah...@gmail.com>
Cc: Don Zickus <dzic...@redhat.com>
Cc: Frederic Weisbecker <fweis...@gmail.com>
Cc: Mike Galbraith <efa...@gmx.de>
Cc: Namhyung Kim <namhy...@kernel.org>
Cc: Paul Mackerras <pau...@samba.org>
Cc: Peter Zijlstra <pet...@infradead.org>
Cc: Stephane Eranian <eran...@google.com>
Signed-off-by: Jiri Olsa <jo...@redhat.com>
---
 tools/perf/util/machine.c | 11 +++++++++++
 tools/perf/util/thread.c  | 48 ++++++++++++++++++++++++++++++++++-------------
 tools/perf/util/thread.h  |  1 +
 3 files changed, 47 insertions(+), 13 deletions(-)

diff --git a/tools/perf/util/machine.c b/tools/perf/util/machine.c
index 116842e..e86545a 100644
--- a/tools/perf/util/machine.c
+++ b/tools/perf/util/machine.c
@@ -316,6 +316,17 @@ static struct thread *__machine__findnew_thread(struct 
machine *machine,
                rb_link_node(&th->rb_node, parent, p);
                rb_insert_color(&th->rb_node, &machine->threads);
                machine->last_match = th;
+
+               /*
+                * We have to initialize map_groups separately
+                * after rb tree is updated.
+                *
+                * The reason is that we call machine__findnew_thread
+                * within thread__init_map_groups to find the thread
+                * leader and that would screwed the rb tree.
+                */
+               if (thread__init_map_groups(th, machine))
+                       return NULL;
        }
 
        return th;
diff --git a/tools/perf/util/thread.c b/tools/perf/util/thread.c
index b501848..2fde0d5 100644
--- a/tools/perf/util/thread.c
+++ b/tools/perf/util/thread.c
@@ -8,6 +8,22 @@
 #include "debug.h"
 #include "comm.h"
 
+int thread__init_map_groups(struct thread *thread, struct machine *machine)
+{
+       struct thread *leader;
+       pid_t pid = thread->pid_;
+
+       if (pid == thread->tid) {
+               thread->mg = map_groups__new();
+       } else {
+               leader = machine__findnew_thread(machine, pid, pid);
+               if (leader)
+                       thread->mg = map_groups__get(leader->mg);
+       }
+
+       return thread->mg ? 0 : -1;
+}
+
 struct thread *thread__new(pid_t pid, pid_t tid)
 {
        char *comm_str;
@@ -15,10 +31,6 @@ struct thread *thread__new(pid_t pid, pid_t tid)
        struct thread *thread = zalloc(sizeof(*thread));
 
        if (thread != NULL) {
-               thread->mg = map_groups__new();
-               if (thread->mg == NULL)
-                       goto out_free;
-
                thread->pid_ = pid;
                thread->tid = tid;
                thread->ppid = -1;
@@ -40,8 +52,6 @@ struct thread *thread__new(pid_t pid, pid_t tid)
        return thread;
 
 err_thread:
-       map_groups__delete(thread->mg);
-out_free:
        free(thread);
        return NULL;
 }
@@ -126,9 +136,26 @@ void thread__insert_map(struct thread *thread, struct map 
*map)
        map_groups__insert(thread->mg, map);
 }
 
+static int thread__clone_map_groups(struct thread *thread,
+                                   struct thread *parent)
+{
+       int i;
+
+       /* This is new thread, we share map groups for process. */
+       if (thread->pid_ == parent->pid_)
+               return 0;
+
+       /* But this one is new process, copy maps. */
+       for (i = 0; i < MAP__NR_TYPES; ++i)
+               if (map_groups__clone(thread->mg, parent->mg, i) < 0)
+                       return -ENOMEM;
+
+       return 0;
+}
+
 int thread__fork(struct thread *thread, struct thread *parent, u64 timestamp)
 {
-       int i, err;
+       int err;
 
        if (parent->comm_set) {
                const char *comm = thread__comm_str(parent);
@@ -140,13 +167,8 @@ int thread__fork(struct thread *thread, struct thread 
*parent, u64 timestamp)
                thread->comm_set = true;
        }
 
-       for (i = 0; i < MAP__NR_TYPES; ++i)
-               if (map_groups__clone(thread->mg, parent->mg, i) < 0)
-                       return -ENOMEM;
-
        thread->ppid = parent->tid;
-
-       return 0;
+       return thread__clone_map_groups(thread, parent);
 }
 
 void thread__find_cpumode_addr_location(struct thread *thread,
diff --git a/tools/perf/util/thread.h b/tools/perf/util/thread.h
index bee1eb0..3c0c272 100644
--- a/tools/perf/util/thread.h
+++ b/tools/perf/util/thread.h
@@ -30,6 +30,7 @@ struct machine;
 struct comm;
 
 struct thread *thread__new(pid_t pid, pid_t tid);
+int thread__init_map_groups(struct thread *thread, struct machine *machine);
 void thread__delete(struct thread *thread);
 static inline void thread__exited(struct thread *thread)
 {
-- 
1.8.3.1

--
To unsubscribe from this list: send the line "unsubscribe linux-kernel" in
the body of a message to majord...@vger.kernel.org
More majordomo info at  http://vger.kernel.org/majordomo-info.html
Please read the FAQ at  http://www.tux.org/lkml/

Reply via email to