Commit 93d5731d authored by Arnaldo Carvalho de Melo's avatar Arnaldo Carvalho de Melo Committed by Jiri Olsa

perf tools: Allocate thread map_groups's dynamically

Moving towards sharing map groups within a process threads.

Because of this we need the map groups to be dynamically allocated. No
other functional change is intended in here.

Based on a patch by Jiri Olsa, but this time _just_ making the
conversion from statically allocating thread->mg to turning it into a
pointer and instead of initializing it at thread's constructor,
introduce a constructor/destructor for the map_groups class and
call at thread creation time.

Later we will introduce the get/put methods when we move to sharing
those map_groups, when the get/put refcounting semantics will be needed.
Signed-off-by: default avatarArnaldo Carvalho de Melo <acme@kernel.org>
Acked-by: default avatarNamhyung Kim <namhyung@kernel.org>
Cc: Adrian Hunter <adrian.hunter@intel.com>
Cc: Corey Ashford <cjashfor@linux.vnet.ibm.com>
Cc: David Ahern <dsahern@gmail.com>
Cc: Don Zickus <dzickus@redhat.com>
Cc: Frederic Weisbecker <fweisbec@gmail.com>
Cc: Ingo Molnar <mingo@kernel.org>
Cc: Mike Galbraith <efault@gmx.de>
Cc: Namhyung Kim <namhyung@kernel.org>
Cc: Paul Mackerras <paulus@samba.org>
Cc: Peter Zijlstra <a.p.zijlstra@chello.nl>
Cc: Stephane Eranian <eranian@google.com>
Link: http://lkml.kernel.org/r/1397490723-1992-3-git-send-email-jolsa@redhat.comSigned-off-by: default avatarJiri Olsa <jolsa@kernel.org>
parent 4e85edfc
...@@ -23,7 +23,7 @@ static int sample_ustack(struct perf_sample *sample, ...@@ -23,7 +23,7 @@ static int sample_ustack(struct perf_sample *sample,
sp = (unsigned long) regs[PERF_REG_X86_SP]; sp = (unsigned long) regs[PERF_REG_X86_SP];
map = map_groups__find(&thread->mg, MAP__FUNCTION, (u64) sp); map = map_groups__find(thread->mg, MAP__FUNCTION, (u64) sp);
if (!map) { if (!map) {
pr_debug("failed to get stack map\n"); pr_debug("failed to get stack map\n");
free(buf); free(buf);
......
...@@ -495,7 +495,7 @@ size_t hists__fprintf(struct hists *hists, bool show_header, int max_rows, ...@@ -495,7 +495,7 @@ size_t hists__fprintf(struct hists *hists, bool show_header, int max_rows,
break; break;
if (h->ms.map == NULL && verbose > 1) { if (h->ms.map == NULL && verbose > 1) {
__map_groups__fprintf_maps(&h->thread->mg, __map_groups__fprintf_maps(h->thread->mg,
MAP__FUNCTION, verbose, fp); MAP__FUNCTION, verbose, fp);
fprintf(fp, "%.10s end\n", graph_dotted_line); fprintf(fp, "%.10s end\n", graph_dotted_line);
} }
......
...@@ -699,7 +699,7 @@ void thread__find_addr_map(struct thread *thread, ...@@ -699,7 +699,7 @@ void thread__find_addr_map(struct thread *thread,
enum map_type type, u64 addr, enum map_type type, u64 addr,
struct addr_location *al) struct addr_location *al)
{ {
struct map_groups *mg = &thread->mg; struct map_groups *mg = thread->mg;
bool load_map = false; bool load_map = false;
al->machine = machine; al->machine = machine;
......
...@@ -358,6 +358,22 @@ void map_groups__exit(struct map_groups *mg) ...@@ -358,6 +358,22 @@ void map_groups__exit(struct map_groups *mg)
} }
} }
struct map_groups *map_groups__new(void)
{
struct map_groups *mg = malloc(sizeof(*mg));
if (mg != NULL)
map_groups__init(mg);
return mg;
}
void map_groups__delete(struct map_groups *mg)
{
map_groups__exit(mg);
free(mg);
}
void map_groups__flush(struct map_groups *mg) void map_groups__flush(struct map_groups *mg)
{ {
int type; int type;
......
...@@ -61,6 +61,9 @@ struct map_groups { ...@@ -61,6 +61,9 @@ struct map_groups {
struct machine *machine; struct machine *machine;
}; };
struct map_groups *map_groups__new(void);
void map_groups__delete(struct map_groups *mg);
static inline struct kmap *map__kmap(struct map *map) static inline struct kmap *map__kmap(struct map *map)
{ {
return (struct kmap *)(map + 1); return (struct kmap *)(map + 1);
......
...@@ -15,7 +15,10 @@ struct thread *thread__new(pid_t pid, pid_t tid) ...@@ -15,7 +15,10 @@ struct thread *thread__new(pid_t pid, pid_t tid)
struct thread *thread = zalloc(sizeof(*thread)); struct thread *thread = zalloc(sizeof(*thread));
if (thread != NULL) { if (thread != NULL) {
map_groups__init(&thread->mg); thread->mg = map_groups__new();
if (thread->mg == NULL)
goto out_free;
thread->pid_ = pid; thread->pid_ = pid;
thread->tid = tid; thread->tid = tid;
thread->ppid = -1; thread->ppid = -1;
...@@ -37,6 +40,8 @@ struct thread *thread__new(pid_t pid, pid_t tid) ...@@ -37,6 +40,8 @@ struct thread *thread__new(pid_t pid, pid_t tid)
return thread; return thread;
err_thread: err_thread:
map_groups__delete(thread->mg);
out_free:
free(thread); free(thread);
return NULL; return NULL;
} }
...@@ -45,7 +50,8 @@ void thread__delete(struct thread *thread) ...@@ -45,7 +50,8 @@ void thread__delete(struct thread *thread)
{ {
struct comm *comm, *tmp; struct comm *comm, *tmp;
map_groups__exit(&thread->mg); map_groups__delete(thread->mg);
thread->mg = NULL;
list_for_each_entry_safe(comm, tmp, &thread->comm_list, list) { list_for_each_entry_safe(comm, tmp, &thread->comm_list, list) {
list_del(&comm->list); list_del(&comm->list);
comm__free(comm); comm__free(comm);
...@@ -111,13 +117,13 @@ int thread__comm_len(struct thread *thread) ...@@ -111,13 +117,13 @@ int thread__comm_len(struct thread *thread)
size_t thread__fprintf(struct thread *thread, FILE *fp) size_t thread__fprintf(struct thread *thread, FILE *fp)
{ {
return fprintf(fp, "Thread %d %s\n", thread->tid, thread__comm_str(thread)) + return fprintf(fp, "Thread %d %s\n", thread->tid, thread__comm_str(thread)) +
map_groups__fprintf(&thread->mg, verbose, fp); map_groups__fprintf(thread->mg, verbose, fp);
} }
void thread__insert_map(struct thread *thread, struct map *map) void thread__insert_map(struct thread *thread, struct map *map)
{ {
map_groups__fixup_overlappings(&thread->mg, map, verbose, stderr); map_groups__fixup_overlappings(thread->mg, map, verbose, stderr);
map_groups__insert(&thread->mg, map); map_groups__insert(thread->mg, map);
} }
int thread__fork(struct thread *thread, struct thread *parent, u64 timestamp) int thread__fork(struct thread *thread, struct thread *parent, u64 timestamp)
...@@ -135,7 +141,7 @@ int thread__fork(struct thread *thread, struct thread *parent, u64 timestamp) ...@@ -135,7 +141,7 @@ int thread__fork(struct thread *thread, struct thread *parent, u64 timestamp)
} }
for (i = 0; i < MAP__NR_TYPES; ++i) for (i = 0; i < MAP__NR_TYPES; ++i)
if (map_groups__clone(&thread->mg, &parent->mg, i) < 0) if (map_groups__clone(thread->mg, parent->mg, i) < 0)
return -ENOMEM; return -ENOMEM;
thread->ppid = parent->tid; thread->ppid = parent->tid;
......
...@@ -13,7 +13,7 @@ struct thread { ...@@ -13,7 +13,7 @@ struct thread {
struct rb_node rb_node; struct rb_node rb_node;
struct list_head node; struct list_head node;
}; };
struct map_groups mg; struct map_groups *mg;
pid_t pid_; /* Not all tools update this */ pid_t pid_; /* Not all tools update this */
pid_t tid; pid_t tid;
pid_t ppid; pid_t ppid;
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment