mirror of
https://github.com/torvalds/linux.git
synced 2024-12-15 07:33:56 +00:00
fba7c86601
Move evsel::leader to perf_evsel::leader, so we can move the group interface to libperf. Also add several evsel helpers to ease up the transition: struct evsel *evsel__leader(struct evsel *evsel); - get leader evsel bool evsel__has_leader(struct evsel *evsel, struct evsel *leader); - true if evsel has leader as leader bool evsel__is_leader(struct evsel *evsel); - true if evsel is itw own leader void evsel__set_leader(struct evsel *evsel, struct evsel *leader); - set leader for evsel Committer notes: Fix this when building with 'make BUILD_BPF_SKEL=1' tools/perf/util/bpf_counter.c - if (evsel->leader->core.nr_members > 1) { + if (evsel->core.leader->nr_members > 1) { Signed-off-by: Jiri Olsa <jolsa@kernel.org> Requested-by: Shunsuke Nakamura <nakamura.shun@fujitsu.com> Cc: Alexander Shishkin <alexander.shishkin@linux.intel.com> Cc: Ian Rogers <irogers@google.com> Cc: Mark Rutland <mark.rutland@arm.com> Cc: Michael Petlan <mpetlan@redhat.com> Cc: Namhyung Kim <namhyung@kernel.org> Cc: Peter Zijlstra <peterz@infradead.org> Link: http://lore.kernel.org/lkml/20210706151704.73662-4-jolsa@kernel.org Signed-off-by: Arnaldo Carvalho de Melo <acme@redhat.com>
578 lines
12 KiB
C
578 lines
12 KiB
C
// SPDX-License-Identifier: GPL-2.0
|
|
#include <subcmd/parse-options.h>
|
|
#include "evsel.h"
|
|
#include "cgroup.h"
|
|
#include "evlist.h"
|
|
#include "rblist.h"
|
|
#include "metricgroup.h"
|
|
#include "stat.h"
|
|
#include <linux/zalloc.h>
|
|
#include <sys/types.h>
|
|
#include <sys/stat.h>
|
|
#include <sys/statfs.h>
|
|
#include <fcntl.h>
|
|
#include <stdlib.h>
|
|
#include <string.h>
|
|
#include <api/fs/fs.h>
|
|
#include <ftw.h>
|
|
#include <regex.h>
|
|
|
|
int nr_cgroups;
|
|
bool cgrp_event_expanded;
|
|
|
|
/* used to match cgroup name with patterns */
|
|
struct cgroup_name {
|
|
struct list_head list;
|
|
bool used;
|
|
char name[];
|
|
};
|
|
static LIST_HEAD(cgroup_list);
|
|
|
|
static int open_cgroup(const char *name)
|
|
{
|
|
char path[PATH_MAX + 1];
|
|
char mnt[PATH_MAX + 1];
|
|
int fd;
|
|
|
|
|
|
if (cgroupfs_find_mountpoint(mnt, PATH_MAX + 1, "perf_event"))
|
|
return -1;
|
|
|
|
scnprintf(path, PATH_MAX, "%s/%s", mnt, name);
|
|
|
|
fd = open(path, O_RDONLY);
|
|
if (fd == -1)
|
|
fprintf(stderr, "no access to cgroup %s\n", path);
|
|
|
|
return fd;
|
|
}
|
|
|
|
#ifdef HAVE_FILE_HANDLE
|
|
int read_cgroup_id(struct cgroup *cgrp)
|
|
{
|
|
char path[PATH_MAX + 1];
|
|
char mnt[PATH_MAX + 1];
|
|
struct {
|
|
struct file_handle fh;
|
|
uint64_t cgroup_id;
|
|
} handle;
|
|
int mount_id;
|
|
|
|
if (cgroupfs_find_mountpoint(mnt, PATH_MAX + 1, "perf_event"))
|
|
return -1;
|
|
|
|
scnprintf(path, PATH_MAX, "%s/%s", mnt, cgrp->name);
|
|
|
|
handle.fh.handle_bytes = sizeof(handle.cgroup_id);
|
|
if (name_to_handle_at(AT_FDCWD, path, &handle.fh, &mount_id, 0) < 0)
|
|
return -1;
|
|
|
|
cgrp->id = handle.cgroup_id;
|
|
return 0;
|
|
}
|
|
#endif /* HAVE_FILE_HANDLE */
|
|
|
|
#ifndef CGROUP2_SUPER_MAGIC
|
|
#define CGROUP2_SUPER_MAGIC 0x63677270
|
|
#endif
|
|
|
|
int cgroup_is_v2(const char *subsys)
|
|
{
|
|
char mnt[PATH_MAX + 1];
|
|
struct statfs stbuf;
|
|
|
|
if (cgroupfs_find_mountpoint(mnt, PATH_MAX + 1, subsys))
|
|
return -1;
|
|
|
|
if (statfs(mnt, &stbuf) < 0)
|
|
return -1;
|
|
|
|
return (stbuf.f_type == CGROUP2_SUPER_MAGIC);
|
|
}
|
|
|
|
static struct cgroup *evlist__find_cgroup(struct evlist *evlist, const char *str)
|
|
{
|
|
struct evsel *counter;
|
|
/*
|
|
* check if cgrp is already defined, if so we reuse it
|
|
*/
|
|
evlist__for_each_entry(evlist, counter) {
|
|
if (!counter->cgrp)
|
|
continue;
|
|
if (!strcmp(counter->cgrp->name, str))
|
|
return cgroup__get(counter->cgrp);
|
|
}
|
|
|
|
return NULL;
|
|
}
|
|
|
|
static struct cgroup *cgroup__new(const char *name, bool do_open)
|
|
{
|
|
struct cgroup *cgroup = zalloc(sizeof(*cgroup));
|
|
|
|
if (cgroup != NULL) {
|
|
refcount_set(&cgroup->refcnt, 1);
|
|
|
|
cgroup->name = strdup(name);
|
|
if (!cgroup->name)
|
|
goto out_err;
|
|
|
|
if (do_open) {
|
|
cgroup->fd = open_cgroup(name);
|
|
if (cgroup->fd == -1)
|
|
goto out_free_name;
|
|
} else {
|
|
cgroup->fd = -1;
|
|
}
|
|
}
|
|
|
|
return cgroup;
|
|
|
|
out_free_name:
|
|
zfree(&cgroup->name);
|
|
out_err:
|
|
free(cgroup);
|
|
return NULL;
|
|
}
|
|
|
|
struct cgroup *evlist__findnew_cgroup(struct evlist *evlist, const char *name)
|
|
{
|
|
struct cgroup *cgroup = evlist__find_cgroup(evlist, name);
|
|
|
|
return cgroup ?: cgroup__new(name, true);
|
|
}
|
|
|
|
static int add_cgroup(struct evlist *evlist, const char *str)
|
|
{
|
|
struct evsel *counter;
|
|
struct cgroup *cgrp = evlist__findnew_cgroup(evlist, str);
|
|
int n;
|
|
|
|
if (!cgrp)
|
|
return -1;
|
|
/*
|
|
* find corresponding event
|
|
* if add cgroup N, then need to find event N
|
|
*/
|
|
n = 0;
|
|
evlist__for_each_entry(evlist, counter) {
|
|
if (n == nr_cgroups)
|
|
goto found;
|
|
n++;
|
|
}
|
|
|
|
cgroup__put(cgrp);
|
|
return -1;
|
|
found:
|
|
counter->cgrp = cgrp;
|
|
return 0;
|
|
}
|
|
|
|
static void cgroup__delete(struct cgroup *cgroup)
|
|
{
|
|
if (cgroup->fd >= 0)
|
|
close(cgroup->fd);
|
|
zfree(&cgroup->name);
|
|
free(cgroup);
|
|
}
|
|
|
|
void cgroup__put(struct cgroup *cgrp)
|
|
{
|
|
if (cgrp && refcount_dec_and_test(&cgrp->refcnt)) {
|
|
cgroup__delete(cgrp);
|
|
}
|
|
}
|
|
|
|
struct cgroup *cgroup__get(struct cgroup *cgroup)
|
|
{
|
|
if (cgroup)
|
|
refcount_inc(&cgroup->refcnt);
|
|
return cgroup;
|
|
}
|
|
|
|
static void evsel__set_default_cgroup(struct evsel *evsel, struct cgroup *cgroup)
|
|
{
|
|
if (evsel->cgrp == NULL)
|
|
evsel->cgrp = cgroup__get(cgroup);
|
|
}
|
|
|
|
void evlist__set_default_cgroup(struct evlist *evlist, struct cgroup *cgroup)
|
|
{
|
|
struct evsel *evsel;
|
|
|
|
evlist__for_each_entry(evlist, evsel)
|
|
evsel__set_default_cgroup(evsel, cgroup);
|
|
}
|
|
|
|
/* helper function for ftw() in match_cgroups and list_cgroups */
|
|
static int add_cgroup_name(const char *fpath, const struct stat *sb __maybe_unused,
|
|
int typeflag, struct FTW *ftwbuf __maybe_unused)
|
|
{
|
|
struct cgroup_name *cn;
|
|
|
|
if (typeflag != FTW_D)
|
|
return 0;
|
|
|
|
cn = malloc(sizeof(*cn) + strlen(fpath) + 1);
|
|
if (cn == NULL)
|
|
return -1;
|
|
|
|
cn->used = false;
|
|
strcpy(cn->name, fpath);
|
|
|
|
list_add_tail(&cn->list, &cgroup_list);
|
|
return 0;
|
|
}
|
|
|
|
static void release_cgroup_list(void)
|
|
{
|
|
struct cgroup_name *cn;
|
|
|
|
while (!list_empty(&cgroup_list)) {
|
|
cn = list_first_entry(&cgroup_list, struct cgroup_name, list);
|
|
list_del(&cn->list);
|
|
free(cn);
|
|
}
|
|
}
|
|
|
|
/* collect given cgroups only */
|
|
static int list_cgroups(const char *str)
|
|
{
|
|
const char *p, *e, *eos = str + strlen(str);
|
|
struct cgroup_name *cn;
|
|
char *s;
|
|
|
|
/* use given name as is - for testing purpose */
|
|
for (;;) {
|
|
p = strchr(str, ',');
|
|
e = p ? p : eos;
|
|
|
|
if (e - str) {
|
|
int ret;
|
|
|
|
s = strndup(str, e - str);
|
|
if (!s)
|
|
return -1;
|
|
/* pretend if it's added by ftw() */
|
|
ret = add_cgroup_name(s, NULL, FTW_D, NULL);
|
|
free(s);
|
|
if (ret)
|
|
return -1;
|
|
} else {
|
|
if (add_cgroup_name("", NULL, FTW_D, NULL) < 0)
|
|
return -1;
|
|
}
|
|
|
|
if (!p)
|
|
break;
|
|
str = p+1;
|
|
}
|
|
|
|
/* these groups will be used */
|
|
list_for_each_entry(cn, &cgroup_list, list)
|
|
cn->used = true;
|
|
|
|
return 0;
|
|
}
|
|
|
|
/* collect all cgroups first and then match with the pattern */
|
|
static int match_cgroups(const char *str)
|
|
{
|
|
char mnt[PATH_MAX];
|
|
const char *p, *e, *eos = str + strlen(str);
|
|
struct cgroup_name *cn;
|
|
regex_t reg;
|
|
int prefix_len;
|
|
char *s;
|
|
|
|
if (cgroupfs_find_mountpoint(mnt, sizeof(mnt), "perf_event"))
|
|
return -1;
|
|
|
|
/* cgroup_name will have a full path, skip the root directory */
|
|
prefix_len = strlen(mnt);
|
|
|
|
/* collect all cgroups in the cgroup_list */
|
|
if (nftw(mnt, add_cgroup_name, 20, 0) < 0)
|
|
return -1;
|
|
|
|
for (;;) {
|
|
p = strchr(str, ',');
|
|
e = p ? p : eos;
|
|
|
|
/* allow empty cgroups, i.e., skip */
|
|
if (e - str) {
|
|
/* termination added */
|
|
s = strndup(str, e - str);
|
|
if (!s)
|
|
return -1;
|
|
if (regcomp(®, s, REG_NOSUB)) {
|
|
free(s);
|
|
return -1;
|
|
}
|
|
|
|
/* check cgroup name with the pattern */
|
|
list_for_each_entry(cn, &cgroup_list, list) {
|
|
char *name = cn->name + prefix_len;
|
|
|
|
if (name[0] == '/' && name[1])
|
|
name++;
|
|
if (!regexec(®, name, 0, NULL, 0))
|
|
cn->used = true;
|
|
}
|
|
regfree(®);
|
|
free(s);
|
|
} else {
|
|
/* first entry to root cgroup */
|
|
cn = list_first_entry(&cgroup_list, struct cgroup_name,
|
|
list);
|
|
cn->used = true;
|
|
}
|
|
|
|
if (!p)
|
|
break;
|
|
str = p+1;
|
|
}
|
|
return prefix_len;
|
|
}
|
|
|
|
int parse_cgroups(const struct option *opt, const char *str,
|
|
int unset __maybe_unused)
|
|
{
|
|
struct evlist *evlist = *(struct evlist **)opt->value;
|
|
struct evsel *counter;
|
|
struct cgroup *cgrp = NULL;
|
|
const char *p, *e, *eos = str + strlen(str);
|
|
char *s;
|
|
int ret, i;
|
|
|
|
if (list_empty(&evlist->core.entries)) {
|
|
fprintf(stderr, "must define events before cgroups\n");
|
|
return -1;
|
|
}
|
|
|
|
for (;;) {
|
|
p = strchr(str, ',');
|
|
e = p ? p : eos;
|
|
|
|
/* allow empty cgroups, i.e., skip */
|
|
if (e - str) {
|
|
/* termination added */
|
|
s = strndup(str, e - str);
|
|
if (!s)
|
|
return -1;
|
|
ret = add_cgroup(evlist, s);
|
|
free(s);
|
|
if (ret)
|
|
return -1;
|
|
}
|
|
/* nr_cgroups is increased een for empty cgroups */
|
|
nr_cgroups++;
|
|
if (!p)
|
|
break;
|
|
str = p+1;
|
|
}
|
|
/* for the case one cgroup combine to multiple events */
|
|
i = 0;
|
|
if (nr_cgroups == 1) {
|
|
evlist__for_each_entry(evlist, counter) {
|
|
if (i == 0)
|
|
cgrp = counter->cgrp;
|
|
else {
|
|
counter->cgrp = cgrp;
|
|
refcount_inc(&cgrp->refcnt);
|
|
}
|
|
i++;
|
|
}
|
|
}
|
|
return 0;
|
|
}
|
|
|
|
static bool has_pattern_string(const char *str)
|
|
{
|
|
return !!strpbrk(str, "{}[]()|*+?^$");
|
|
}
|
|
|
|
int evlist__expand_cgroup(struct evlist *evlist, const char *str,
|
|
struct rblist *metric_events, bool open_cgroup)
|
|
{
|
|
struct evlist *orig_list, *tmp_list;
|
|
struct evsel *pos, *evsel, *leader;
|
|
struct rblist orig_metric_events;
|
|
struct cgroup *cgrp = NULL;
|
|
struct cgroup_name *cn;
|
|
int ret = -1;
|
|
int prefix_len;
|
|
|
|
if (evlist->core.nr_entries == 0) {
|
|
fprintf(stderr, "must define events before cgroups\n");
|
|
return -EINVAL;
|
|
}
|
|
|
|
orig_list = evlist__new();
|
|
tmp_list = evlist__new();
|
|
if (orig_list == NULL || tmp_list == NULL) {
|
|
fprintf(stderr, "memory allocation failed\n");
|
|
return -ENOMEM;
|
|
}
|
|
|
|
/* save original events and init evlist */
|
|
evlist__splice_list_tail(orig_list, &evlist->core.entries);
|
|
evlist->core.nr_entries = 0;
|
|
|
|
if (metric_events) {
|
|
orig_metric_events = *metric_events;
|
|
rblist__init(metric_events);
|
|
} else {
|
|
rblist__init(&orig_metric_events);
|
|
}
|
|
|
|
if (has_pattern_string(str))
|
|
prefix_len = match_cgroups(str);
|
|
else
|
|
prefix_len = list_cgroups(str);
|
|
|
|
if (prefix_len < 0)
|
|
goto out_err;
|
|
|
|
list_for_each_entry(cn, &cgroup_list, list) {
|
|
char *name;
|
|
|
|
if (!cn->used)
|
|
continue;
|
|
|
|
/* cgroup_name might have a full path, skip the prefix */
|
|
name = cn->name + prefix_len;
|
|
if (name[0] == '/' && name[1])
|
|
name++;
|
|
cgrp = cgroup__new(name, open_cgroup);
|
|
if (cgrp == NULL)
|
|
goto out_err;
|
|
|
|
leader = NULL;
|
|
evlist__for_each_entry(orig_list, pos) {
|
|
evsel = evsel__clone(pos);
|
|
if (evsel == NULL)
|
|
goto out_err;
|
|
|
|
cgroup__put(evsel->cgrp);
|
|
evsel->cgrp = cgroup__get(cgrp);
|
|
|
|
if (evsel__is_group_leader(pos))
|
|
leader = evsel;
|
|
evsel__set_leader(evsel, leader);
|
|
|
|
evlist__add(tmp_list, evsel);
|
|
}
|
|
/* cgroup__new() has a refcount, release it here */
|
|
cgroup__put(cgrp);
|
|
nr_cgroups++;
|
|
|
|
if (metric_events) {
|
|
perf_stat__collect_metric_expr(tmp_list);
|
|
if (metricgroup__copy_metric_events(tmp_list, cgrp,
|
|
metric_events,
|
|
&orig_metric_events) < 0)
|
|
goto out_err;
|
|
}
|
|
|
|
evlist__splice_list_tail(evlist, &tmp_list->core.entries);
|
|
tmp_list->core.nr_entries = 0;
|
|
}
|
|
|
|
if (list_empty(&evlist->core.entries)) {
|
|
fprintf(stderr, "no cgroup matched: %s\n", str);
|
|
goto out_err;
|
|
}
|
|
|
|
ret = 0;
|
|
cgrp_event_expanded = true;
|
|
|
|
out_err:
|
|
evlist__delete(orig_list);
|
|
evlist__delete(tmp_list);
|
|
rblist__exit(&orig_metric_events);
|
|
release_cgroup_list();
|
|
|
|
return ret;
|
|
}
|
|
|
|
static struct cgroup *__cgroup__findnew(struct rb_root *root, uint64_t id,
|
|
bool create, const char *path)
|
|
{
|
|
struct rb_node **p = &root->rb_node;
|
|
struct rb_node *parent = NULL;
|
|
struct cgroup *cgrp;
|
|
|
|
while (*p != NULL) {
|
|
parent = *p;
|
|
cgrp = rb_entry(parent, struct cgroup, node);
|
|
|
|
if (cgrp->id == id)
|
|
return cgrp;
|
|
|
|
if (cgrp->id < id)
|
|
p = &(*p)->rb_left;
|
|
else
|
|
p = &(*p)->rb_right;
|
|
}
|
|
|
|
if (!create)
|
|
return NULL;
|
|
|
|
cgrp = malloc(sizeof(*cgrp));
|
|
if (cgrp == NULL)
|
|
return NULL;
|
|
|
|
cgrp->name = strdup(path);
|
|
if (cgrp->name == NULL) {
|
|
free(cgrp);
|
|
return NULL;
|
|
}
|
|
|
|
cgrp->fd = -1;
|
|
cgrp->id = id;
|
|
refcount_set(&cgrp->refcnt, 1);
|
|
|
|
rb_link_node(&cgrp->node, parent, p);
|
|
rb_insert_color(&cgrp->node, root);
|
|
|
|
return cgrp;
|
|
}
|
|
|
|
struct cgroup *cgroup__findnew(struct perf_env *env, uint64_t id,
|
|
const char *path)
|
|
{
|
|
struct cgroup *cgrp;
|
|
|
|
down_write(&env->cgroups.lock);
|
|
cgrp = __cgroup__findnew(&env->cgroups.tree, id, true, path);
|
|
up_write(&env->cgroups.lock);
|
|
return cgrp;
|
|
}
|
|
|
|
struct cgroup *cgroup__find(struct perf_env *env, uint64_t id)
|
|
{
|
|
struct cgroup *cgrp;
|
|
|
|
down_read(&env->cgroups.lock);
|
|
cgrp = __cgroup__findnew(&env->cgroups.tree, id, false, NULL);
|
|
up_read(&env->cgroups.lock);
|
|
return cgrp;
|
|
}
|
|
|
|
void perf_env__purge_cgroups(struct perf_env *env)
|
|
{
|
|
struct rb_node *node;
|
|
struct cgroup *cgrp;
|
|
|
|
down_write(&env->cgroups.lock);
|
|
while (!RB_EMPTY_ROOT(&env->cgroups.tree)) {
|
|
node = rb_first(&env->cgroups.tree);
|
|
cgrp = rb_entry(node, struct cgroup, node);
|
|
|
|
rb_erase(node, &env->cgroups.tree);
|
|
cgroup__put(cgrp);
|
|
}
|
|
up_write(&env->cgroups.lock);
|
|
}
|