Commit 27451700 authored by Ingo Molnar's avatar Ingo Molnar

Merge tag 'perf-core-for-mingo' of...

Merge tag 'perf-core-for-mingo' of git://git.kernel.org/pub/scm/linux/kernel/git/acme/linux into perf/core

Pull perf/core improvements and fixes from Arnaldo Carvalho de Melo:

User visible changes:

  - Move toggling event logic from 'perf top' and into hists browser, allowing
    freeze/unfreeze with event lists with more than one entry (Namhyung Kim)

  - Add missing newlines when dumping PERF_RECORD_FINISHED_ROUND and
    showing the Aggregated stats in 'perf report -D' (Adrian Hunter)

Infrastructure changes:

  - Allow auxtrace data alignment (Adrian Hunter)

  - Allow events with dot (Andi Kleen)

  - Fix failure to 'perf probe' events on arm (He Kuang)

  - Add testing for Makefile.perf (Jiri Olsa)

  - Add test for make install with prefix (Jiri Olsa)

  - Fix single target build dependency check (Jiri Olsa)

  - Access thread_map entries via accessors, prep patch to hold more info per
    entry, for ongoing 'perf stat --per-thread' work (Jiri Olsa)

  - Use __weak definition from compiler.h (Sukadev Bhattiprolu)

  - Split perf_pmu__new_alias() (Sukadev Bhattiprolu)
Signed-off-by: default avatarArnaldo Carvalho de Melo <acme@redhat.com>
Signed-off-by: default avatarIngo Molnar <mingo@kernel.org>
parents 407a2c72 83b2ea25
...@@ -83,8 +83,8 @@ build-test: ...@@ -83,8 +83,8 @@ build-test:
# #
# All other targets get passed through: # All other targets get passed through:
# #
%: %: FORCE
$(print_msg) $(print_msg)
$(make) $(make)
.PHONY: tags TAGS .PHONY: tags TAGS FORCE Makefile
...@@ -586,27 +586,9 @@ static void *display_thread_tui(void *arg) ...@@ -586,27 +586,9 @@ static void *display_thread_tui(void *arg)
hists->uid_filter_str = top->record_opts.target.uid_str; hists->uid_filter_str = top->record_opts.target.uid_str;
} }
while (true) { perf_evlist__tui_browse_hists(top->evlist, help, &hbt,
int key = perf_evlist__tui_browse_hists(top->evlist, help, &hbt, top->min_percent,
top->min_percent, &top->session->header.env);
&top->session->header.env);
if (key != 'f')
break;
perf_evlist__toggle_enable(top->evlist);
/*
* No need to refresh, resort/decay histogram entries
* if we are not collecting samples:
*/
if (top->evlist->enabled) {
hbt.refresh = top->delay_secs;
help = "Press 'f' to disable the events or 'h' to see other hotkeys";
} else {
help = "Press 'f' again to re-enable the events";
hbt.refresh = 0;
}
}
done = 1; done = 1;
return NULL; return NULL;
......
...@@ -2325,7 +2325,7 @@ static int trace__run(struct trace *trace, int argc, const char **argv) ...@@ -2325,7 +2325,7 @@ static int trace__run(struct trace *trace, int argc, const char **argv)
*/ */
if (trace->filter_pids.nr > 0) if (trace->filter_pids.nr > 0)
err = perf_evlist__set_filter_pids(evlist, trace->filter_pids.nr, trace->filter_pids.entries); err = perf_evlist__set_filter_pids(evlist, trace->filter_pids.nr, trace->filter_pids.entries);
else if (evlist->threads->map[0] == -1) else if (thread_map__pid(evlist->threads, 0) == -1)
err = perf_evlist__set_filter_pid(evlist, getpid()); err = perf_evlist__set_filter_pid(evlist, getpid());
if (err < 0) { if (err < 0) {
...@@ -2343,7 +2343,7 @@ static int trace__run(struct trace *trace, int argc, const char **argv) ...@@ -2343,7 +2343,7 @@ static int trace__run(struct trace *trace, int argc, const char **argv)
if (forks) if (forks)
perf_evlist__start_workload(evlist); perf_evlist__start_workload(evlist);
trace->multiple_threads = evlist->threads->map[0] == -1 || trace->multiple_threads = thread_map__pid(evlist->threads, 0) == -1 ||
evlist->threads->nr > 1 || evlist->threads->nr > 1 ||
perf_evlist__first(evlist)->attr.inherit; perf_evlist__first(evlist)->attr.inherit;
again: again:
......
ifndef MK
ifeq ($(MAKECMDGOALS),)
# no target specified, trigger the whole suite
all:
@echo "Testing Makefile"; $(MAKE) -sf tests/make MK=Makefile
@echo "Testing Makefile.perf"; $(MAKE) -sf tests/make MK=Makefile.perf
else
# run only specific test over 'Makefile'
%:
@echo "Testing Makefile"; $(MAKE) -sf tests/make MK=Makefile $@
endif
else
PERF := . PERF := .
MK := Makefile
include config/Makefile.arch include config/Makefile.arch
...@@ -47,6 +58,7 @@ make_install_man := install-man ...@@ -47,6 +58,7 @@ make_install_man := install-man
make_install_html := install-html make_install_html := install-html
make_install_info := install-info make_install_info := install-info
make_install_pdf := install-pdf make_install_pdf := install-pdf
make_install_prefix := install prefix=/tmp/krava
make_static := LDFLAGS=-static make_static := LDFLAGS=-static
# all the NO_* variable combined # all the NO_* variable combined
...@@ -57,7 +69,12 @@ make_minimal += NO_LIBDW_DWARF_UNWIND=1 NO_AUXTRACE=1 ...@@ -57,7 +69,12 @@ make_minimal += NO_LIBDW_DWARF_UNWIND=1 NO_AUXTRACE=1
# $(run) contains all available tests # $(run) contains all available tests
run := make_pure run := make_pure
# Targets 'clean all' can be run together only through top level
# Makefile because we detect clean target in Makefile.perf and
# disable features detection
ifeq ($(MK),Makefile)
run += make_clean_all run += make_clean_all
endif
run += make_python_perf_so run += make_python_perf_so
run += make_debug run += make_debug
run += make_no_libperl run += make_no_libperl
...@@ -83,6 +100,7 @@ run += make_util_map_o ...@@ -83,6 +100,7 @@ run += make_util_map_o
run += make_util_pmu_bison_o run += make_util_pmu_bison_o
run += make_install run += make_install
run += make_install_bin run += make_install_bin
run += make_install_prefix
# FIXME 'install-*' commented out till they're fixed # FIXME 'install-*' commented out till they're fixed
# run += make_install_doc # run += make_install_doc
# run += make_install_man # run += make_install_man
...@@ -157,6 +175,12 @@ test_make_install_O := $(call test_dest_files,$(installed_files_all)) ...@@ -157,6 +175,12 @@ test_make_install_O := $(call test_dest_files,$(installed_files_all))
test_make_install_bin := $(call test_dest_files,$(installed_files_bin)) test_make_install_bin := $(call test_dest_files,$(installed_files_bin))
test_make_install_bin_O := $(call test_dest_files,$(installed_files_bin)) test_make_install_bin_O := $(call test_dest_files,$(installed_files_bin))
# We prefix all installed files for make_install_prefix
# with '/tmp/krava' to match installed/prefix-ed files.
installed_files_all_prefix := $(addprefix /tmp/krava/,$(installed_files_all))
test_make_install_prefix := $(call test_dest_files,$(installed_files_all_prefix))
test_make_install_prefix_O := $(call test_dest_files,$(installed_files_all_prefix))
# FIXME nothing gets installed # FIXME nothing gets installed
test_make_install_man := test -f $$TMP_DEST/share/man/man1/perf.1 test_make_install_man := test -f $$TMP_DEST/share/man/man1/perf.1
test_make_install_man_O := $(test_make_install_man) test_make_install_man_O := $(test_make_install_man)
...@@ -226,13 +250,13 @@ tarpkg: ...@@ -226,13 +250,13 @@ tarpkg:
( eval $$cmd ) >> $@ 2>&1 ( eval $$cmd ) >> $@ 2>&1
make_kernelsrc: make_kernelsrc:
@echo " - make -C <kernelsrc> tools/perf" @echo "- make -C <kernelsrc> tools/perf"
$(call clean); \ $(call clean); \
(make -C ../.. tools/perf) > $@ 2>&1 && \ (make -C ../.. tools/perf) > $@ 2>&1 && \
test -x perf && rm -f $@ || (cat $@ ; false) test -x perf && rm -f $@ || (cat $@ ; false)
make_kernelsrc_tools: make_kernelsrc_tools:
@echo " - make -C <kernelsrc>/tools perf" @echo "- make -C <kernelsrc>/tools perf"
$(call clean); \ $(call clean); \
(make -C ../../tools perf) > $@ 2>&1 && \ (make -C ../../tools perf) > $@ 2>&1 && \
test -x perf && rm -f $@ || (cat $@ ; false) test -x perf && rm -f $@ || (cat $@ ; false)
...@@ -244,3 +268,4 @@ out: $(run_O) ...@@ -244,3 +268,4 @@ out: $(run_O)
@echo OK @echo OK
.PHONY: all $(run) $(run_O) tarpkg clean .PHONY: all $(run) $(run_O) tarpkg clean
endif # ifndef MK
...@@ -45,7 +45,7 @@ int test__syscall_openat_tp_fields(void) ...@@ -45,7 +45,7 @@ int test__syscall_openat_tp_fields(void)
perf_evsel__config(evsel, &opts); perf_evsel__config(evsel, &opts);
evlist->threads->map[0] = getpid(); thread_map__set_pid(evlist->threads, 0, getpid());
err = perf_evlist__open(evlist); err = perf_evlist__open(evlist);
if (err < 0) { if (err < 0) {
......
...@@ -1902,8 +1902,23 @@ static int perf_evsel__hists_browse(struct perf_evsel *evsel, int nr_events, ...@@ -1902,8 +1902,23 @@ static int perf_evsel__hists_browse(struct perf_evsel *evsel, int nr_events,
case CTRL('c'): case CTRL('c'):
goto out_free_stack; goto out_free_stack;
case 'f': case 'f':
if (!is_report_browser(hbt)) if (!is_report_browser(hbt)) {
goto out_free_stack; struct perf_top *top = hbt->arg;
perf_evlist__toggle_enable(top->evlist);
/*
* No need to refresh, resort/decay histogram
* entries if we are not collecting samples:
*/
if (top->evlist->enabled) {
helpline = "Press 'f' to disable the events or 'h' to see other hotkeys";
hbt->refresh = delay_secs;
} else {
helpline = "Press 'f' again to re-enable the events";
hbt->refresh = 0;
}
continue;
}
/* Fall thru */ /* Fall thru */
default: default:
helpline = "Press '?' for help on key bindings"; helpline = "Press '?' for help on key bindings";
......
...@@ -119,12 +119,12 @@ void auxtrace_mmap_params__set_idx(struct auxtrace_mmap_params *mp, ...@@ -119,12 +119,12 @@ void auxtrace_mmap_params__set_idx(struct auxtrace_mmap_params *mp,
if (per_cpu) { if (per_cpu) {
mp->cpu = evlist->cpus->map[idx]; mp->cpu = evlist->cpus->map[idx];
if (evlist->threads) if (evlist->threads)
mp->tid = evlist->threads->map[0]; mp->tid = thread_map__pid(evlist->threads, 0);
else else
mp->tid = -1; mp->tid = -1;
} else { } else {
mp->cpu = -1; mp->cpu = -1;
mp->tid = evlist->threads->map[idx]; mp->tid = thread_map__pid(evlist->threads, idx);
} }
} }
...@@ -1182,6 +1182,13 @@ static int __auxtrace_mmap__read(struct auxtrace_mmap *mm, ...@@ -1182,6 +1182,13 @@ static int __auxtrace_mmap__read(struct auxtrace_mmap *mm,
data2 = NULL; data2 = NULL;
} }
if (itr->alignment) {
unsigned int unwanted = len1 % itr->alignment;
len1 -= unwanted;
size -= unwanted;
}
/* padding must be written by fn() e.g. record__process_auxtrace() */ /* padding must be written by fn() e.g. record__process_auxtrace() */
padding = size & 7; padding = size & 7;
if (padding) if (padding)
......
...@@ -303,6 +303,7 @@ struct auxtrace_record { ...@@ -303,6 +303,7 @@ struct auxtrace_record {
const char *str); const char *str);
u64 (*reference)(struct auxtrace_record *itr); u64 (*reference)(struct auxtrace_record *itr);
int (*read_finish)(struct auxtrace_record *itr, int idx); int (*read_finish)(struct auxtrace_record *itr, int idx);
unsigned int alignment;
}; };
#ifdef HAVE_AUXTRACE_SUPPORT #ifdef HAVE_AUXTRACE_SUPPORT
......
...@@ -504,7 +504,7 @@ int perf_event__synthesize_thread_map(struct perf_tool *tool, ...@@ -504,7 +504,7 @@ int perf_event__synthesize_thread_map(struct perf_tool *tool,
for (thread = 0; thread < threads->nr; ++thread) { for (thread = 0; thread < threads->nr; ++thread) {
if (__event__synthesize_thread(comm_event, mmap_event, if (__event__synthesize_thread(comm_event, mmap_event,
fork_event, fork_event,
threads->map[thread], 0, thread_map__pid(threads, thread), 0,
process, tool, machine, process, tool, machine,
mmap_data, proc_map_timeout)) { mmap_data, proc_map_timeout)) {
err = -1; err = -1;
...@@ -515,12 +515,12 @@ int perf_event__synthesize_thread_map(struct perf_tool *tool, ...@@ -515,12 +515,12 @@ int perf_event__synthesize_thread_map(struct perf_tool *tool,
* comm.pid is set to thread group id by * comm.pid is set to thread group id by
* perf_event__synthesize_comm * perf_event__synthesize_comm
*/ */
if ((int) comm_event->comm.pid != threads->map[thread]) { if ((int) comm_event->comm.pid != thread_map__pid(threads, thread)) {
bool need_leader = true; bool need_leader = true;
/* is thread group leader in thread_map? */ /* is thread group leader in thread_map? */
for (j = 0; j < threads->nr; ++j) { for (j = 0; j < threads->nr; ++j) {
if ((int) comm_event->comm.pid == threads->map[j]) { if ((int) comm_event->comm.pid == thread_map__pid(threads, j)) {
need_leader = false; need_leader = false;
break; break;
} }
......
...@@ -548,7 +548,7 @@ static void perf_evlist__set_sid_idx(struct perf_evlist *evlist, ...@@ -548,7 +548,7 @@ static void perf_evlist__set_sid_idx(struct perf_evlist *evlist,
else else
sid->cpu = -1; sid->cpu = -1;
if (!evsel->system_wide && evlist->threads && thread >= 0) if (!evsel->system_wide && evlist->threads && thread >= 0)
sid->tid = evlist->threads->map[thread]; sid->tid = thread_map__pid(evlist->threads, thread);
else else
sid->tid = -1; sid->tid = -1;
} }
...@@ -1475,7 +1475,7 @@ int perf_evlist__prepare_workload(struct perf_evlist *evlist, struct target *tar ...@@ -1475,7 +1475,7 @@ int perf_evlist__prepare_workload(struct perf_evlist *evlist, struct target *tar
__func__, __LINE__); __func__, __LINE__);
goto out_close_pipes; goto out_close_pipes;
} }
evlist->threads->map[0] = evlist->workload.pid; thread_map__set_pid(evlist->threads, 0, evlist->workload.pid);
} }
close(child_ready_pipe[1]); close(child_ready_pipe[1]);
......
...@@ -1167,7 +1167,7 @@ static int __perf_evsel__open(struct perf_evsel *evsel, struct cpu_map *cpus, ...@@ -1167,7 +1167,7 @@ static int __perf_evsel__open(struct perf_evsel *evsel, struct cpu_map *cpus,
int group_fd; int group_fd;
if (!evsel->cgrp && !evsel->system_wide) if (!evsel->cgrp && !evsel->system_wide)
pid = threads->map[thread]; pid = thread_map__pid(threads, thread);
group_fd = get_group_fd(evsel, cpu, thread); group_fd = get_group_fd(evsel, cpu, thread);
retry_open: retry_open:
......
...@@ -119,8 +119,8 @@ event [^,{}/]+ ...@@ -119,8 +119,8 @@ event [^,{}/]+
num_dec [0-9]+ num_dec [0-9]+
num_hex 0x[a-fA-F0-9]+ num_hex 0x[a-fA-F0-9]+
num_raw_hex [a-fA-F0-9]+ num_raw_hex [a-fA-F0-9]+
name [a-zA-Z_*?][a-zA-Z0-9_*?]* name [a-zA-Z_*?][a-zA-Z0-9_*?.]*
name_minus [a-zA-Z_*?][a-zA-Z0-9\-_*?]* name_minus [a-zA-Z_*?][a-zA-Z0-9\-_*?.]*
/* If you add a modifier you need to update check_modifier() */ /* If you add a modifier you need to update check_modifier() */
modifier_event [ukhpGHSDI]+ modifier_event [ukhpGHSDI]+
modifier_bp [rwx]{1,3} modifier_bp [rwx]{1,3}
...@@ -165,7 +165,6 @@ modifier_bp [rwx]{1,3} ...@@ -165,7 +165,6 @@ modifier_bp [rwx]{1,3}
return PE_EVENT_NAME; return PE_EVENT_NAME;
} }
. |
<<EOF>> { <<EOF>> {
BEGIN(INITIAL); BEGIN(INITIAL);
REWIND(0); REWIND(0);
......
#include <linux/list.h> #include <linux/list.h>
#include <linux/compiler.h>
#include <sys/types.h> #include <sys/types.h>
#include <unistd.h> #include <unistd.h>
#include <stdio.h> #include <stdio.h>
...@@ -205,17 +206,12 @@ static int perf_pmu__parse_snapshot(struct perf_pmu_alias *alias, ...@@ -205,17 +206,12 @@ static int perf_pmu__parse_snapshot(struct perf_pmu_alias *alias,
return 0; return 0;
} }
static int perf_pmu__new_alias(struct list_head *list, char *dir, char *name, FILE *file) static int __perf_pmu__new_alias(struct list_head *list, char *dir, char *name,
char *desc __maybe_unused, char *val)
{ {
struct perf_pmu_alias *alias; struct perf_pmu_alias *alias;
char buf[256];
int ret; int ret;
ret = fread(buf, 1, sizeof(buf), file);
if (ret == 0)
return -EINVAL;
buf[ret] = 0;
alias = malloc(sizeof(*alias)); alias = malloc(sizeof(*alias));
if (!alias) if (!alias)
return -ENOMEM; return -ENOMEM;
...@@ -225,26 +221,43 @@ static int perf_pmu__new_alias(struct list_head *list, char *dir, char *name, FI ...@@ -225,26 +221,43 @@ static int perf_pmu__new_alias(struct list_head *list, char *dir, char *name, FI
alias->unit[0] = '\0'; alias->unit[0] = '\0';
alias->per_pkg = false; alias->per_pkg = false;
ret = parse_events_terms(&alias->terms, buf); ret = parse_events_terms(&alias->terms, val);
if (ret) { if (ret) {
pr_err("Cannot parse alias %s: %d\n", val, ret);
free(alias); free(alias);
return ret; return ret;
} }
alias->name = strdup(name); alias->name = strdup(name);
/* if (dir) {
* load unit name and scale if available /*
*/ * load unit name and scale if available
perf_pmu__parse_unit(alias, dir, name); */
perf_pmu__parse_scale(alias, dir, name); perf_pmu__parse_unit(alias, dir, name);
perf_pmu__parse_per_pkg(alias, dir, name); perf_pmu__parse_scale(alias, dir, name);
perf_pmu__parse_snapshot(alias, dir, name); perf_pmu__parse_per_pkg(alias, dir, name);
perf_pmu__parse_snapshot(alias, dir, name);
}
list_add_tail(&alias->list, list); list_add_tail(&alias->list, list);
return 0; return 0;
} }
static int perf_pmu__new_alias(struct list_head *list, char *dir, char *name, FILE *file)
{
char buf[256];
int ret;
ret = fread(buf, 1, sizeof(buf), file);
if (ret == 0)
return -EINVAL;
buf[ret] = 0;
return __perf_pmu__new_alias(list, dir, name, NULL, buf);
}
static inline bool pmu_alias_info_file(char *name) static inline bool pmu_alias_info_file(char *name)
{ {
size_t len; size_t len;
...@@ -436,7 +449,7 @@ static struct cpu_map *pmu_cpumask(const char *name) ...@@ -436,7 +449,7 @@ static struct cpu_map *pmu_cpumask(const char *name)
return cpus; return cpus;
} }
struct perf_event_attr *__attribute__((weak)) struct perf_event_attr * __weak
perf_pmu__get_default_config(struct perf_pmu *pmu __maybe_unused) perf_pmu__get_default_config(struct perf_pmu *pmu __maybe_unused)
{ {
return NULL; return NULL;
......
...@@ -249,8 +249,12 @@ static void clear_probe_trace_events(struct probe_trace_event *tevs, int ntevs) ...@@ -249,8 +249,12 @@ static void clear_probe_trace_events(struct probe_trace_event *tevs, int ntevs)
static bool kprobe_blacklist__listed(unsigned long address); static bool kprobe_blacklist__listed(unsigned long address);
static bool kprobe_warn_out_range(const char *symbol, unsigned long address) static bool kprobe_warn_out_range(const char *symbol, unsigned long address)
{ {
u64 etext_addr;
/* Get the address of _etext for checking non-probable text symbol */ /* Get the address of _etext for checking non-probable text symbol */
if (kernel_get_symbol_address_by_name("_etext", false) < address) etext_addr = kernel_get_symbol_address_by_name("_etext", false);
if (etext_addr != 0 && etext_addr < address)
pr_warning("%s is out of .text, skip it.\n", symbol); pr_warning("%s is out of .text, skip it.\n", symbol);
else if (kprobe_blacklist__listed(address)) else if (kprobe_blacklist__listed(address))
pr_warning("%s is blacklisted function, skip it.\n", symbol); pr_warning("%s is blacklisted function, skip it.\n", symbol);
......
...@@ -686,6 +686,8 @@ static int process_finished_round(struct perf_tool *tool __maybe_unused, ...@@ -686,6 +686,8 @@ static int process_finished_round(struct perf_tool *tool __maybe_unused,
union perf_event *event __maybe_unused, union perf_event *event __maybe_unused,
struct ordered_events *oe) struct ordered_events *oe)
{ {
if (dump_trace)
fprintf(stdout, "\n");
return ordered_events__flush(oe, OE_FLUSH__ROUND); return ordered_events__flush(oe, OE_FLUSH__ROUND);
} }
...@@ -1726,7 +1728,7 @@ size_t perf_session__fprintf_nr_events(struct perf_session *session, FILE *fp) ...@@ -1726,7 +1728,7 @@ size_t perf_session__fprintf_nr_events(struct perf_session *session, FILE *fp)
if (perf_header__has_feat(&session->header, HEADER_AUXTRACE)) if (perf_header__has_feat(&session->header, HEADER_AUXTRACE))
msg = " (excludes AUX area (e.g. instruction trace) decoded / synthesized events)"; msg = " (excludes AUX area (e.g. instruction trace) decoded / synthesized events)";
ret = fprintf(fp, "Aggregated stats:%s\n", msg); ret = fprintf(fp, "\nAggregated stats:%s\n", msg);
ret += events_stats__fprintf(&session->evlist->stats, fp); ret += events_stats__fprintf(&session->evlist->stats, fp);
return ret; return ret;
......
...@@ -45,7 +45,7 @@ struct thread_map *thread_map__new_by_pid(pid_t pid) ...@@ -45,7 +45,7 @@ struct thread_map *thread_map__new_by_pid(pid_t pid)
threads = thread_map__alloc(items); threads = thread_map__alloc(items);
if (threads != NULL) { if (threads != NULL) {
for (i = 0; i < items; i++) for (i = 0; i < items; i++)
threads->map[i] = atoi(namelist[i]->d_name); thread_map__set_pid(threads, i, atoi(namelist[i]->d_name));
threads->nr = items; threads->nr = items;
} }
...@@ -61,8 +61,8 @@ struct thread_map *thread_map__new_by_tid(pid_t tid) ...@@ -61,8 +61,8 @@ struct thread_map *thread_map__new_by_tid(pid_t tid)
struct thread_map *threads = thread_map__alloc(1); struct thread_map *threads = thread_map__alloc(1);
if (threads != NULL) { if (threads != NULL) {
threads->map[0] = tid; thread_map__set_pid(threads, 0, tid);
threads->nr = 1; threads->nr = 1;
} }
return threads; return threads;
...@@ -123,8 +123,10 @@ struct thread_map *thread_map__new_by_uid(uid_t uid) ...@@ -123,8 +123,10 @@ struct thread_map *thread_map__new_by_uid(uid_t uid)
threads = tmp; threads = tmp;
} }
for (i = 0; i < items; i++) for (i = 0; i < items; i++) {
threads->map[threads->nr + i] = atoi(namelist[i]->d_name); thread_map__set_pid(threads, threads->nr + i,
atoi(namelist[i]->d_name));
}
for (i = 0; i < items; i++) for (i = 0; i < items; i++)
zfree(&namelist[i]); zfree(&namelist[i]);
...@@ -201,7 +203,7 @@ static struct thread_map *thread_map__new_by_pid_str(const char *pid_str) ...@@ -201,7 +203,7 @@ static struct thread_map *thread_map__new_by_pid_str(const char *pid_str)
threads = nt; threads = nt;
for (i = 0; i < items; i++) { for (i = 0; i < items; i++) {
threads->map[j++] = atoi(namelist[i]->d_name); thread_map__set_pid(threads, j++, atoi(namelist[i]->d_name));
zfree(&namelist[i]); zfree(&namelist[i]);
} }
threads->nr = total_tasks; threads->nr = total_tasks;
...@@ -227,8 +229,8 @@ struct thread_map *thread_map__new_dummy(void) ...@@ -227,8 +229,8 @@ struct thread_map *thread_map__new_dummy(void)
struct thread_map *threads = thread_map__alloc(1); struct thread_map *threads = thread_map__alloc(1);
if (threads != NULL) { if (threads != NULL) {
threads->map[0] = -1; thread_map__set_pid(threads, 0, -1);
threads->nr = 1; threads->nr = 1;
} }
return threads; return threads;
} }
...@@ -267,8 +269,8 @@ static struct thread_map *thread_map__new_by_tid_str(const char *tid_str) ...@@ -267,8 +269,8 @@ static struct thread_map *thread_map__new_by_tid_str(const char *tid_str)
goto out_free_threads; goto out_free_threads;
threads = nt; threads = nt;
threads->map[ntasks - 1] = tid; thread_map__set_pid(threads, ntasks - 1, tid);
threads->nr = ntasks; threads->nr = ntasks;
} }
out: out:
return threads; return threads;
...@@ -301,7 +303,7 @@ size_t thread_map__fprintf(struct thread_map *threads, FILE *fp) ...@@ -301,7 +303,7 @@ size_t thread_map__fprintf(struct thread_map *threads, FILE *fp)
size_t printed = fprintf(fp, "%d thread%s: ", size_t printed = fprintf(fp, "%d thread%s: ",
threads->nr, threads->nr > 1 ? "s" : ""); threads->nr, threads->nr > 1 ? "s" : "");
for (i = 0; i < threads->nr; ++i) for (i = 0; i < threads->nr; ++i)
printed += fprintf(fp, "%s%d", i ? ", " : "", threads->map[i]); printed += fprintf(fp, "%s%d", i ? ", " : "", thread_map__pid(threads, i));
return printed + fprintf(fp, "\n"); return printed + fprintf(fp, "\n");
} }
...@@ -4,9 +4,13 @@ ...@@ -4,9 +4,13 @@
#include <sys/types.h> #include <sys/types.h>
#include <stdio.h> #include <stdio.h>
struct thread_map_data {
pid_t pid;
};
struct thread_map { struct thread_map {
int nr; int nr;
pid_t map[]; struct thread_map_data map[];
}; };
struct thread_map *thread_map__new_dummy(void); struct thread_map *thread_map__new_dummy(void);
...@@ -27,4 +31,14 @@ static inline int thread_map__nr(struct thread_map *threads) ...@@ -27,4 +31,14 @@ static inline int thread_map__nr(struct thread_map *threads)
return threads ? threads->nr : 1; return threads ? threads->nr : 1;
} }
static inline pid_t thread_map__pid(struct thread_map *map, int thread)
{
return map->map[thread].pid;
}
static inline void
thread_map__set_pid(struct thread_map *map, int thread, pid_t pid)
{
map->map[thread].pid = pid;
}
#endif /* __PERF_THREAD_MAP_H */ #endif /* __PERF_THREAD_MAP_H */
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