.. | .. |
---|
| 1 | +// SPDX-License-Identifier: GPL-2.0-only |
---|
1 | 2 | /* |
---|
2 | 3 | * Copyright (c) 2017, Intel Corporation. |
---|
3 | | - * |
---|
4 | | - * This program is free software; you can redistribute it and/or modify it |
---|
5 | | - * under the terms and conditions of the GNU General Public License, |
---|
6 | | - * version 2, as published by the Free Software Foundation. |
---|
7 | | - * |
---|
8 | | - * This program is distributed in the hope it will be useful, but WITHOUT |
---|
9 | | - * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or |
---|
10 | | - * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License for |
---|
11 | | - * more details. |
---|
12 | | - * |
---|
13 | 4 | */ |
---|
14 | 5 | |
---|
15 | 6 | /* Manage metrics and groups of metrics from JSON files */ |
---|
16 | 7 | |
---|
17 | 8 | #include "metricgroup.h" |
---|
| 9 | +#include "debug.h" |
---|
18 | 10 | #include "evlist.h" |
---|
| 11 | +#include "evsel.h" |
---|
19 | 12 | #include "strbuf.h" |
---|
20 | 13 | #include "pmu.h" |
---|
21 | 14 | #include "expr.h" |
---|
22 | 15 | #include "rblist.h" |
---|
23 | 16 | #include <string.h> |
---|
24 | | -#include <stdbool.h> |
---|
25 | 17 | #include <errno.h> |
---|
26 | | -#include "pmu-events/pmu-events.h" |
---|
27 | 18 | #include "strlist.h" |
---|
28 | 19 | #include <assert.h> |
---|
29 | | -#include <ctype.h> |
---|
| 20 | +#include <linux/ctype.h> |
---|
| 21 | +#include <linux/string.h> |
---|
| 22 | +#include <linux/zalloc.h> |
---|
| 23 | +#include <subcmd/parse-options.h> |
---|
| 24 | +#include <api/fs/fs.h> |
---|
| 25 | +#include "util.h" |
---|
| 26 | +#include <asm/bug.h> |
---|
| 27 | +#include "cgroup.h" |
---|
30 | 28 | |
---|
31 | 29 | struct metric_event *metricgroup__lookup(struct rblist *metric_events, |
---|
32 | | - struct perf_evsel *evsel, |
---|
| 30 | + struct evsel *evsel, |
---|
33 | 31 | bool create) |
---|
34 | 32 | { |
---|
35 | 33 | struct rb_node *nd; |
---|
.. | .. |
---|
79 | 77 | return &me->nd; |
---|
80 | 78 | } |
---|
81 | 79 | |
---|
| 80 | +static void metric_event_delete(struct rblist *rblist __maybe_unused, |
---|
| 81 | + struct rb_node *rb_node) |
---|
| 82 | +{ |
---|
| 83 | + struct metric_event *me = container_of(rb_node, struct metric_event, nd); |
---|
| 84 | + struct metric_expr *expr, *tmp; |
---|
| 85 | + |
---|
| 86 | + list_for_each_entry_safe(expr, tmp, &me->head, nd) { |
---|
| 87 | + free(expr->metric_refs); |
---|
| 88 | + free(expr->metric_events); |
---|
| 89 | + free(expr); |
---|
| 90 | + } |
---|
| 91 | + |
---|
| 92 | + free(me); |
---|
| 93 | +} |
---|
| 94 | + |
---|
82 | 95 | static void metricgroup__rblist_init(struct rblist *metric_events) |
---|
83 | 96 | { |
---|
84 | 97 | rblist__init(metric_events); |
---|
85 | 98 | metric_events->node_cmp = metric_event_cmp; |
---|
86 | 99 | metric_events->node_new = metric_event_new; |
---|
| 100 | + metric_events->node_delete = metric_event_delete; |
---|
87 | 101 | } |
---|
88 | 102 | |
---|
89 | | -struct egroup { |
---|
90 | | - struct list_head nd; |
---|
91 | | - int idnum; |
---|
92 | | - const char **ids; |
---|
| 103 | +void metricgroup__rblist_exit(struct rblist *metric_events) |
---|
| 104 | +{ |
---|
| 105 | + rblist__exit(metric_events); |
---|
| 106 | +} |
---|
| 107 | + |
---|
| 108 | +/* |
---|
| 109 | + * A node in the list of referenced metrics. metric_expr |
---|
| 110 | + * is held as a convenience to avoid a search through the |
---|
| 111 | + * metric list. |
---|
| 112 | + */ |
---|
| 113 | +struct metric_ref_node { |
---|
93 | 114 | const char *metric_name; |
---|
94 | 115 | const char *metric_expr; |
---|
| 116 | + struct list_head list; |
---|
95 | 117 | }; |
---|
96 | 118 | |
---|
97 | | -static bool record_evsel(int *ind, struct perf_evsel **start, |
---|
98 | | - int idnum, |
---|
99 | | - struct perf_evsel **metric_events, |
---|
100 | | - struct perf_evsel *ev) |
---|
| 119 | +struct metric { |
---|
| 120 | + struct list_head nd; |
---|
| 121 | + struct expr_parse_ctx pctx; |
---|
| 122 | + const char *metric_name; |
---|
| 123 | + const char *metric_expr; |
---|
| 124 | + const char *metric_unit; |
---|
| 125 | + struct list_head metric_refs; |
---|
| 126 | + int metric_refs_cnt; |
---|
| 127 | + int runtime; |
---|
| 128 | + bool has_constraint; |
---|
| 129 | +}; |
---|
| 130 | + |
---|
| 131 | +#define RECURSION_ID_MAX 1000 |
---|
| 132 | + |
---|
| 133 | +struct expr_ids { |
---|
| 134 | + struct expr_id id[RECURSION_ID_MAX]; |
---|
| 135 | + int cnt; |
---|
| 136 | +}; |
---|
| 137 | + |
---|
| 138 | +static struct expr_id *expr_ids__alloc(struct expr_ids *ids) |
---|
101 | 139 | { |
---|
102 | | - metric_events[*ind] = ev; |
---|
103 | | - if (*ind == 0) |
---|
104 | | - *start = ev; |
---|
105 | | - if (++*ind == idnum) { |
---|
106 | | - metric_events[*ind] = NULL; |
---|
107 | | - return true; |
---|
| 140 | + if (ids->cnt >= RECURSION_ID_MAX) |
---|
| 141 | + return NULL; |
---|
| 142 | + return &ids->id[ids->cnt++]; |
---|
| 143 | +} |
---|
| 144 | + |
---|
| 145 | +static void expr_ids__exit(struct expr_ids *ids) |
---|
| 146 | +{ |
---|
| 147 | + int i; |
---|
| 148 | + |
---|
| 149 | + for (i = 0; i < ids->cnt; i++) |
---|
| 150 | + free(ids->id[i].id); |
---|
| 151 | +} |
---|
| 152 | + |
---|
| 153 | +static bool contains_event(struct evsel **metric_events, int num_events, |
---|
| 154 | + const char *event_name) |
---|
| 155 | +{ |
---|
| 156 | + int i; |
---|
| 157 | + |
---|
| 158 | + for (i = 0; i < num_events; i++) { |
---|
| 159 | + if (!strcmp(metric_events[i]->name, event_name)) |
---|
| 160 | + return true; |
---|
108 | 161 | } |
---|
109 | 162 | return false; |
---|
110 | 163 | } |
---|
111 | 164 | |
---|
112 | | -static struct perf_evsel *find_evsel_group(struct perf_evlist *perf_evlist, |
---|
113 | | - const char **ids, |
---|
114 | | - int idnum, |
---|
115 | | - struct perf_evsel **metric_events) |
---|
| 165 | +/** |
---|
| 166 | + * Find a group of events in perf_evlist that correspond to those from a parsed |
---|
| 167 | + * metric expression. Note, as find_evsel_group is called in the same order as |
---|
| 168 | + * perf_evlist was constructed, metric_no_merge doesn't need to test for |
---|
| 169 | + * underfilling a group. |
---|
| 170 | + * @perf_evlist: a list of events something like: {metric1 leader, metric1 |
---|
| 171 | + * sibling, metric1 sibling}:W,duration_time,{metric2 leader, metric2 sibling, |
---|
| 172 | + * metric2 sibling}:W,duration_time |
---|
| 173 | + * @pctx: the parse context for the metric expression. |
---|
| 174 | + * @metric_no_merge: don't attempt to share events for the metric with other |
---|
| 175 | + * metrics. |
---|
| 176 | + * @has_constraint: is there a contraint on the group of events? In which case |
---|
| 177 | + * the events won't be grouped. |
---|
| 178 | + * @metric_events: out argument, null terminated array of evsel's associated |
---|
| 179 | + * with the metric. |
---|
| 180 | + * @evlist_used: in/out argument, bitmap tracking which evlist events are used. |
---|
| 181 | + * @return the first metric event or NULL on failure. |
---|
| 182 | + */ |
---|
| 183 | +static struct evsel *find_evsel_group(struct evlist *perf_evlist, |
---|
| 184 | + struct expr_parse_ctx *pctx, |
---|
| 185 | + bool metric_no_merge, |
---|
| 186 | + bool has_constraint, |
---|
| 187 | + struct evsel **metric_events, |
---|
| 188 | + unsigned long *evlist_used) |
---|
116 | 189 | { |
---|
117 | | - struct perf_evsel *ev, *start = NULL; |
---|
118 | | - int ind = 0; |
---|
| 190 | + struct evsel *ev, *current_leader = NULL; |
---|
| 191 | + struct expr_id_data *val_ptr; |
---|
| 192 | + int i = 0, matched_events = 0, events_to_match; |
---|
| 193 | + const int idnum = (int)hashmap__size(&pctx->ids); |
---|
| 194 | + |
---|
| 195 | + /* |
---|
| 196 | + * duration_time is always grouped separately, when events are grouped |
---|
| 197 | + * (ie has_constraint is false) then ignore it in the matching loop and |
---|
| 198 | + * add it to metric_events at the end. |
---|
| 199 | + */ |
---|
| 200 | + if (!has_constraint && |
---|
| 201 | + hashmap__find(&pctx->ids, "duration_time", (void **)&val_ptr)) |
---|
| 202 | + events_to_match = idnum - 1; |
---|
| 203 | + else |
---|
| 204 | + events_to_match = idnum; |
---|
119 | 205 | |
---|
120 | 206 | evlist__for_each_entry (perf_evlist, ev) { |
---|
121 | | - if (ev->collect_stat) |
---|
| 207 | + /* |
---|
| 208 | + * Events with a constraint aren't grouped and match the first |
---|
| 209 | + * events available. |
---|
| 210 | + */ |
---|
| 211 | + if (has_constraint && ev->weak_group) |
---|
122 | 212 | continue; |
---|
123 | | - if (!strcmp(ev->name, ids[ind])) { |
---|
124 | | - if (record_evsel(&ind, &start, idnum, |
---|
125 | | - metric_events, ev)) |
---|
126 | | - return start; |
---|
127 | | - } else { |
---|
| 213 | + /* Ignore event if already used and merging is disabled. */ |
---|
| 214 | + if (metric_no_merge && test_bit(ev->idx, evlist_used)) |
---|
| 215 | + continue; |
---|
| 216 | + if (!has_constraint && ev->leader != current_leader) { |
---|
128 | 217 | /* |
---|
129 | | - * We saw some other event that is not |
---|
130 | | - * in our list of events. Discard |
---|
131 | | - * the whole match and start again. |
---|
| 218 | + * Start of a new group, discard the whole match and |
---|
| 219 | + * start again. |
---|
132 | 220 | */ |
---|
133 | | - ind = 0; |
---|
134 | | - start = NULL; |
---|
135 | | - if (!strcmp(ev->name, ids[ind])) { |
---|
136 | | - if (record_evsel(&ind, &start, idnum, |
---|
137 | | - metric_events, ev)) |
---|
138 | | - return start; |
---|
| 221 | + matched_events = 0; |
---|
| 222 | + memset(metric_events, 0, |
---|
| 223 | + sizeof(struct evsel *) * idnum); |
---|
| 224 | + current_leader = ev->leader; |
---|
| 225 | + } |
---|
| 226 | + /* |
---|
| 227 | + * Check for duplicate events with the same name. For example, |
---|
| 228 | + * uncore_imc/cas_count_read/ will turn into 6 events per socket |
---|
| 229 | + * on skylakex. Only the first such event is placed in |
---|
| 230 | + * metric_events. If events aren't grouped then this also |
---|
| 231 | + * ensures that the same event in different sibling groups |
---|
| 232 | + * aren't both added to metric_events. |
---|
| 233 | + */ |
---|
| 234 | + if (contains_event(metric_events, matched_events, ev->name)) |
---|
| 235 | + continue; |
---|
| 236 | + /* Does this event belong to the parse context? */ |
---|
| 237 | + if (hashmap__find(&pctx->ids, ev->name, (void **)&val_ptr)) |
---|
| 238 | + metric_events[matched_events++] = ev; |
---|
| 239 | + |
---|
| 240 | + if (matched_events == events_to_match) |
---|
| 241 | + break; |
---|
| 242 | + } |
---|
| 243 | + |
---|
| 244 | + if (events_to_match != idnum) { |
---|
| 245 | + /* Add the first duration_time. */ |
---|
| 246 | + evlist__for_each_entry(perf_evlist, ev) { |
---|
| 247 | + if (!strcmp(ev->name, "duration_time")) { |
---|
| 248 | + metric_events[matched_events++] = ev; |
---|
| 249 | + break; |
---|
139 | 250 | } |
---|
140 | 251 | } |
---|
141 | 252 | } |
---|
142 | | - /* |
---|
143 | | - * This can happen when an alias expands to multiple |
---|
144 | | - * events, like for uncore events. |
---|
145 | | - * We don't support this case for now. |
---|
146 | | - */ |
---|
147 | | - return NULL; |
---|
| 253 | + |
---|
| 254 | + if (matched_events != idnum) { |
---|
| 255 | + /* Not a whole match */ |
---|
| 256 | + return NULL; |
---|
| 257 | + } |
---|
| 258 | + |
---|
| 259 | + metric_events[idnum] = NULL; |
---|
| 260 | + |
---|
| 261 | + for (i = 0; i < idnum; i++) { |
---|
| 262 | + ev = metric_events[i]; |
---|
| 263 | + /* Don't free the used events. */ |
---|
| 264 | + set_bit(ev->idx, evlist_used); |
---|
| 265 | + /* |
---|
| 266 | + * The metric leader points to the identically named event in |
---|
| 267 | + * metric_events. |
---|
| 268 | + */ |
---|
| 269 | + ev->metric_leader = ev; |
---|
| 270 | + /* |
---|
| 271 | + * Mark two events with identical names in the same group (or |
---|
| 272 | + * globally) as being in use as uncore events may be duplicated |
---|
| 273 | + * for each pmu. Set the metric leader of such events to be the |
---|
| 274 | + * event that appears in metric_events. |
---|
| 275 | + */ |
---|
| 276 | + evlist__for_each_entry_continue(perf_evlist, ev) { |
---|
| 277 | + /* |
---|
| 278 | + * If events are grouped then the search can terminate |
---|
| 279 | + * when then group is left. |
---|
| 280 | + */ |
---|
| 281 | + if (!has_constraint && |
---|
| 282 | + ev->leader != metric_events[i]->leader) |
---|
| 283 | + break; |
---|
| 284 | + if (!strcmp(metric_events[i]->name, ev->name)) { |
---|
| 285 | + set_bit(ev->idx, evlist_used); |
---|
| 286 | + ev->metric_leader = metric_events[i]; |
---|
| 287 | + } |
---|
| 288 | + } |
---|
| 289 | + } |
---|
| 290 | + |
---|
| 291 | + return metric_events[0]; |
---|
148 | 292 | } |
---|
149 | 293 | |
---|
150 | 294 | static int metricgroup__setup_events(struct list_head *groups, |
---|
151 | | - struct perf_evlist *perf_evlist, |
---|
| 295 | + bool metric_no_merge, |
---|
| 296 | + struct evlist *perf_evlist, |
---|
152 | 297 | struct rblist *metric_events_list) |
---|
153 | 298 | { |
---|
154 | 299 | struct metric_event *me; |
---|
155 | 300 | struct metric_expr *expr; |
---|
156 | 301 | int i = 0; |
---|
157 | 302 | int ret = 0; |
---|
158 | | - struct egroup *eg; |
---|
159 | | - struct perf_evsel *evsel; |
---|
| 303 | + struct metric *m; |
---|
| 304 | + struct evsel *evsel, *tmp; |
---|
| 305 | + unsigned long *evlist_used; |
---|
160 | 306 | |
---|
161 | | - list_for_each_entry (eg, groups, nd) { |
---|
162 | | - struct perf_evsel **metric_events; |
---|
| 307 | + evlist_used = bitmap_alloc(perf_evlist->core.nr_entries); |
---|
| 308 | + if (!evlist_used) |
---|
| 309 | + return -ENOMEM; |
---|
163 | 310 | |
---|
164 | | - metric_events = calloc(sizeof(void *), eg->idnum + 1); |
---|
| 311 | + list_for_each_entry (m, groups, nd) { |
---|
| 312 | + struct evsel **metric_events; |
---|
| 313 | + struct metric_ref *metric_refs = NULL; |
---|
| 314 | + |
---|
| 315 | + metric_events = calloc(sizeof(void *), |
---|
| 316 | + hashmap__size(&m->pctx.ids) + 1); |
---|
165 | 317 | if (!metric_events) { |
---|
166 | 318 | ret = -ENOMEM; |
---|
167 | 319 | break; |
---|
168 | 320 | } |
---|
169 | | - evsel = find_evsel_group(perf_evlist, eg->ids, eg->idnum, |
---|
170 | | - metric_events); |
---|
| 321 | + evsel = find_evsel_group(perf_evlist, &m->pctx, |
---|
| 322 | + metric_no_merge, |
---|
| 323 | + m->has_constraint, metric_events, |
---|
| 324 | + evlist_used); |
---|
171 | 325 | if (!evsel) { |
---|
172 | 326 | pr_debug("Cannot resolve %s: %s\n", |
---|
173 | | - eg->metric_name, eg->metric_expr); |
---|
| 327 | + m->metric_name, m->metric_expr); |
---|
174 | 328 | free(metric_events); |
---|
175 | 329 | continue; |
---|
176 | 330 | } |
---|
177 | | - for (i = 0; i < eg->idnum; i++) |
---|
| 331 | + for (i = 0; metric_events[i]; i++) |
---|
178 | 332 | metric_events[i]->collect_stat = true; |
---|
179 | 333 | me = metricgroup__lookup(metric_events_list, evsel, true); |
---|
180 | 334 | if (!me) { |
---|
.. | .. |
---|
188 | 342 | free(metric_events); |
---|
189 | 343 | break; |
---|
190 | 344 | } |
---|
191 | | - expr->metric_expr = eg->metric_expr; |
---|
192 | | - expr->metric_name = eg->metric_name; |
---|
| 345 | + |
---|
| 346 | + /* |
---|
| 347 | + * Collect and store collected nested expressions |
---|
| 348 | + * for metric processing. |
---|
| 349 | + */ |
---|
| 350 | + if (m->metric_refs_cnt) { |
---|
| 351 | + struct metric_ref_node *ref; |
---|
| 352 | + |
---|
| 353 | + metric_refs = zalloc(sizeof(struct metric_ref) * (m->metric_refs_cnt + 1)); |
---|
| 354 | + if (!metric_refs) { |
---|
| 355 | + ret = -ENOMEM; |
---|
| 356 | + free(metric_events); |
---|
| 357 | + free(expr); |
---|
| 358 | + break; |
---|
| 359 | + } |
---|
| 360 | + |
---|
| 361 | + i = 0; |
---|
| 362 | + list_for_each_entry(ref, &m->metric_refs, list) { |
---|
| 363 | + /* |
---|
| 364 | + * Intentionally passing just const char pointers, |
---|
| 365 | + * originally from 'struct pmu_event' object. |
---|
| 366 | + * We don't need to change them, so there's no |
---|
| 367 | + * need to create our own copy. |
---|
| 368 | + */ |
---|
| 369 | + metric_refs[i].metric_name = ref->metric_name; |
---|
| 370 | + metric_refs[i].metric_expr = ref->metric_expr; |
---|
| 371 | + i++; |
---|
| 372 | + } |
---|
| 373 | + }; |
---|
| 374 | + |
---|
| 375 | + expr->metric_refs = metric_refs; |
---|
| 376 | + expr->metric_expr = m->metric_expr; |
---|
| 377 | + expr->metric_name = m->metric_name; |
---|
| 378 | + expr->metric_unit = m->metric_unit; |
---|
193 | 379 | expr->metric_events = metric_events; |
---|
| 380 | + expr->runtime = m->runtime; |
---|
194 | 381 | list_add(&expr->nd, &me->head); |
---|
195 | 382 | } |
---|
| 383 | + |
---|
| 384 | + evlist__for_each_entry_safe(perf_evlist, tmp, evsel) { |
---|
| 385 | + if (!test_bit(evsel->idx, evlist_used)) { |
---|
| 386 | + evlist__remove(perf_evlist, evsel); |
---|
| 387 | + evsel__delete(evsel); |
---|
| 388 | + } |
---|
| 389 | + } |
---|
| 390 | + bitmap_free(evlist_used); |
---|
| 391 | + |
---|
196 | 392 | return ret; |
---|
197 | 393 | } |
---|
198 | 394 | |
---|
.. | .. |
---|
247 | 443 | goto out_name; |
---|
248 | 444 | return &me->nd; |
---|
249 | 445 | out_name: |
---|
250 | | - free((char *)me->name); |
---|
| 446 | + zfree(&me->name); |
---|
251 | 447 | out_me: |
---|
252 | 448 | free(me); |
---|
253 | 449 | return NULL; |
---|
.. | .. |
---|
275 | 471 | struct mep *me = container_of(nd, struct mep, nd); |
---|
276 | 472 | |
---|
277 | 473 | strlist__delete(me->metrics); |
---|
278 | | - free((void *)me->name); |
---|
| 474 | + zfree(&me->name); |
---|
279 | 475 | free(me); |
---|
280 | 476 | } |
---|
281 | 477 | |
---|
.. | .. |
---|
296 | 492 | } |
---|
297 | 493 | |
---|
298 | 494 | void metricgroup__print(bool metrics, bool metricgroups, char *filter, |
---|
299 | | - bool raw) |
---|
| 495 | + bool raw, bool details) |
---|
300 | 496 | { |
---|
301 | 497 | struct pmu_events_map *map = perf_pmu__find_map(NULL); |
---|
302 | 498 | struct pmu_event *pe; |
---|
.. | .. |
---|
343 | 539 | struct mep *me; |
---|
344 | 540 | char *s; |
---|
345 | 541 | |
---|
| 542 | + g = skip_spaces(g); |
---|
346 | 543 | if (*g == 0) |
---|
347 | 544 | g = "No_group"; |
---|
348 | | - while (isspace(*g)) |
---|
349 | | - g++; |
---|
350 | 545 | if (filter && !strstr(g, filter)) |
---|
351 | 546 | continue; |
---|
352 | 547 | if (raw) |
---|
.. | .. |
---|
355 | 550 | if (asprintf(&s, "%s\n%*s%s]", |
---|
356 | 551 | pe->metric_name, 8, "[", pe->desc) < 0) |
---|
357 | 552 | return; |
---|
| 553 | + |
---|
| 554 | + if (details) { |
---|
| 555 | + if (asprintf(&s, "%s\n%*s%s]", |
---|
| 556 | + s, 8, "[", pe->metric_expr) < 0) |
---|
| 557 | + return; |
---|
| 558 | + } |
---|
358 | 559 | } |
---|
359 | 560 | |
---|
360 | 561 | if (!s) |
---|
.. | .. |
---|
368 | 569 | continue; |
---|
369 | 570 | strlist__add(me->metrics, s); |
---|
370 | 571 | } |
---|
| 572 | + |
---|
| 573 | + if (!raw) |
---|
| 574 | + free(s); |
---|
371 | 575 | } |
---|
372 | 576 | free(omg); |
---|
373 | 577 | } |
---|
374 | 578 | } |
---|
375 | 579 | |
---|
376 | | - if (metricgroups && !raw) |
---|
377 | | - printf("\nMetric Groups:\n\n"); |
---|
378 | | - else if (metrics && !raw) |
---|
379 | | - printf("\nMetrics:\n\n"); |
---|
| 580 | + if (!filter || !rblist__empty(&groups)) { |
---|
| 581 | + if (metricgroups && !raw) |
---|
| 582 | + printf("\nMetric Groups:\n\n"); |
---|
| 583 | + else if (metrics && !raw) |
---|
| 584 | + printf("\nMetrics:\n\n"); |
---|
| 585 | + } |
---|
380 | 586 | |
---|
381 | | - for (node = rb_first(&groups.entries); node; node = next) { |
---|
| 587 | + for (node = rb_first_cached(&groups.entries); node; node = next) { |
---|
382 | 588 | struct mep *me = container_of(node, struct mep, nd); |
---|
383 | 589 | |
---|
384 | 590 | if (metricgroups) |
---|
385 | | - printf("%s%s%s", me->name, metrics ? ":" : "", raw ? " " : "\n"); |
---|
| 591 | + printf("%s%s%s", me->name, metrics && !raw ? ":" : "", raw ? " " : "\n"); |
---|
386 | 592 | if (metrics) |
---|
387 | 593 | metricgroup__print_strlist(me->metrics, raw); |
---|
388 | 594 | next = rb_next(node); |
---|
.. | .. |
---|
393 | 599 | strlist__delete(metriclist); |
---|
394 | 600 | } |
---|
395 | 601 | |
---|
396 | | -static int metricgroup__add_metric(const char *metric, struct strbuf *events, |
---|
397 | | - struct list_head *group_list) |
---|
| 602 | +static void metricgroup__add_metric_weak_group(struct strbuf *events, |
---|
| 603 | + struct expr_parse_ctx *ctx) |
---|
398 | 604 | { |
---|
399 | | - struct pmu_events_map *map = perf_pmu__find_map(NULL); |
---|
400 | | - struct pmu_event *pe; |
---|
401 | | - int ret = -EINVAL; |
---|
402 | | - int i, j; |
---|
| 605 | + struct hashmap_entry *cur; |
---|
| 606 | + size_t bkt; |
---|
| 607 | + bool no_group = true, has_duration = false; |
---|
403 | 608 | |
---|
404 | | - if (!map) |
---|
| 609 | + hashmap__for_each_entry((&ctx->ids), cur, bkt) { |
---|
| 610 | + pr_debug("found event %s\n", (const char *)cur->key); |
---|
| 611 | + /* |
---|
| 612 | + * Duration time maps to a software event and can make |
---|
| 613 | + * groups not count. Always use it outside a |
---|
| 614 | + * group. |
---|
| 615 | + */ |
---|
| 616 | + if (!strcmp(cur->key, "duration_time")) { |
---|
| 617 | + has_duration = true; |
---|
| 618 | + continue; |
---|
| 619 | + } |
---|
| 620 | + strbuf_addf(events, "%s%s", |
---|
| 621 | + no_group ? "{" : ",", |
---|
| 622 | + (const char *)cur->key); |
---|
| 623 | + no_group = false; |
---|
| 624 | + } |
---|
| 625 | + if (!no_group) { |
---|
| 626 | + strbuf_addf(events, "}:W"); |
---|
| 627 | + if (has_duration) |
---|
| 628 | + strbuf_addf(events, ",duration_time"); |
---|
| 629 | + } else if (has_duration) |
---|
| 630 | + strbuf_addf(events, "duration_time"); |
---|
| 631 | +} |
---|
| 632 | + |
---|
| 633 | +static void metricgroup__add_metric_non_group(struct strbuf *events, |
---|
| 634 | + struct expr_parse_ctx *ctx) |
---|
| 635 | +{ |
---|
| 636 | + struct hashmap_entry *cur; |
---|
| 637 | + size_t bkt; |
---|
| 638 | + bool first = true; |
---|
| 639 | + |
---|
| 640 | + hashmap__for_each_entry((&ctx->ids), cur, bkt) { |
---|
| 641 | + if (!first) |
---|
| 642 | + strbuf_addf(events, ","); |
---|
| 643 | + strbuf_addf(events, "%s", (const char *)cur->key); |
---|
| 644 | + first = false; |
---|
| 645 | + } |
---|
| 646 | +} |
---|
| 647 | + |
---|
| 648 | +static void metricgroup___watchdog_constraint_hint(const char *name, bool foot) |
---|
| 649 | +{ |
---|
| 650 | + static bool violate_nmi_constraint; |
---|
| 651 | + |
---|
| 652 | + if (!foot) { |
---|
| 653 | + pr_warning("Splitting metric group %s into standalone metrics.\n", name); |
---|
| 654 | + violate_nmi_constraint = true; |
---|
| 655 | + return; |
---|
| 656 | + } |
---|
| 657 | + |
---|
| 658 | + if (!violate_nmi_constraint) |
---|
| 659 | + return; |
---|
| 660 | + |
---|
| 661 | + pr_warning("Try disabling the NMI watchdog to comply NO_NMI_WATCHDOG metric constraint:\n" |
---|
| 662 | + " echo 0 > /proc/sys/kernel/nmi_watchdog\n" |
---|
| 663 | + " perf stat ...\n" |
---|
| 664 | + " echo 1 > /proc/sys/kernel/nmi_watchdog\n"); |
---|
| 665 | +} |
---|
| 666 | + |
---|
| 667 | +static bool metricgroup__has_constraint(struct pmu_event *pe) |
---|
| 668 | +{ |
---|
| 669 | + if (!pe->metric_constraint) |
---|
| 670 | + return false; |
---|
| 671 | + |
---|
| 672 | + if (!strcmp(pe->metric_constraint, "NO_NMI_WATCHDOG") && |
---|
| 673 | + sysctl__nmi_watchdog_enabled()) { |
---|
| 674 | + metricgroup___watchdog_constraint_hint(pe->metric_name, false); |
---|
| 675 | + return true; |
---|
| 676 | + } |
---|
| 677 | + |
---|
| 678 | + return false; |
---|
| 679 | +} |
---|
| 680 | + |
---|
| 681 | +int __weak arch_get_runtimeparam(struct pmu_event *pe __maybe_unused) |
---|
| 682 | +{ |
---|
| 683 | + return 1; |
---|
| 684 | +} |
---|
| 685 | + |
---|
| 686 | +static int __add_metric(struct list_head *metric_list, |
---|
| 687 | + struct pmu_event *pe, |
---|
| 688 | + bool metric_no_group, |
---|
| 689 | + int runtime, |
---|
| 690 | + struct metric **mp, |
---|
| 691 | + struct expr_id *parent, |
---|
| 692 | + struct expr_ids *ids) |
---|
| 693 | +{ |
---|
| 694 | + struct metric_ref_node *ref; |
---|
| 695 | + struct metric *m; |
---|
| 696 | + |
---|
| 697 | + if (*mp == NULL) { |
---|
| 698 | + /* |
---|
| 699 | + * We got in here for the parent group, |
---|
| 700 | + * allocate it and put it on the list. |
---|
| 701 | + */ |
---|
| 702 | + m = zalloc(sizeof(*m)); |
---|
| 703 | + if (!m) |
---|
| 704 | + return -ENOMEM; |
---|
| 705 | + |
---|
| 706 | + expr__ctx_init(&m->pctx); |
---|
| 707 | + m->metric_name = pe->metric_name; |
---|
| 708 | + m->metric_expr = pe->metric_expr; |
---|
| 709 | + m->metric_unit = pe->unit; |
---|
| 710 | + m->runtime = runtime; |
---|
| 711 | + m->has_constraint = metric_no_group || metricgroup__has_constraint(pe); |
---|
| 712 | + INIT_LIST_HEAD(&m->metric_refs); |
---|
| 713 | + m->metric_refs_cnt = 0; |
---|
| 714 | + |
---|
| 715 | + parent = expr_ids__alloc(ids); |
---|
| 716 | + if (!parent) { |
---|
| 717 | + free(m); |
---|
| 718 | + return -EINVAL; |
---|
| 719 | + } |
---|
| 720 | + |
---|
| 721 | + parent->id = strdup(pe->metric_name); |
---|
| 722 | + if (!parent->id) { |
---|
| 723 | + free(m); |
---|
| 724 | + return -ENOMEM; |
---|
| 725 | + } |
---|
| 726 | + *mp = m; |
---|
| 727 | + } else { |
---|
| 728 | + /* |
---|
| 729 | + * We got here for the referenced metric, via the |
---|
| 730 | + * recursive metricgroup__add_metric call, add |
---|
| 731 | + * it to the parent group. |
---|
| 732 | + */ |
---|
| 733 | + m = *mp; |
---|
| 734 | + |
---|
| 735 | + ref = malloc(sizeof(*ref)); |
---|
| 736 | + if (!ref) |
---|
| 737 | + return -ENOMEM; |
---|
| 738 | + |
---|
| 739 | + /* |
---|
| 740 | + * Intentionally passing just const char pointers, |
---|
| 741 | + * from 'pe' object, so they never go away. We don't |
---|
| 742 | + * need to change them, so there's no need to create |
---|
| 743 | + * our own copy. |
---|
| 744 | + */ |
---|
| 745 | + ref->metric_name = pe->metric_name; |
---|
| 746 | + ref->metric_expr = pe->metric_expr; |
---|
| 747 | + |
---|
| 748 | + list_add(&ref->list, &m->metric_refs); |
---|
| 749 | + m->metric_refs_cnt++; |
---|
| 750 | + } |
---|
| 751 | + |
---|
| 752 | + /* Force all found IDs in metric to have us as parent ID. */ |
---|
| 753 | + WARN_ON_ONCE(!parent); |
---|
| 754 | + m->pctx.parent = parent; |
---|
| 755 | + |
---|
| 756 | + /* |
---|
| 757 | + * For both the parent and referenced metrics, we parse |
---|
| 758 | + * all the metric's IDs and add it to the parent context. |
---|
| 759 | + */ |
---|
| 760 | + if (expr__find_other(pe->metric_expr, NULL, &m->pctx, runtime) < 0) { |
---|
| 761 | + if (m->metric_refs_cnt == 0) { |
---|
| 762 | + expr__ctx_clear(&m->pctx); |
---|
| 763 | + free(m); |
---|
| 764 | + *mp = NULL; |
---|
| 765 | + } |
---|
| 766 | + return -EINVAL; |
---|
| 767 | + } |
---|
| 768 | + |
---|
| 769 | + /* |
---|
| 770 | + * We add new group only in the 'parent' call, |
---|
| 771 | + * so bail out for referenced metric case. |
---|
| 772 | + */ |
---|
| 773 | + if (m->metric_refs_cnt) |
---|
405 | 774 | return 0; |
---|
406 | 775 | |
---|
407 | | - for (i = 0; ; i++) { |
---|
408 | | - pe = &map->table[i]; |
---|
| 776 | + if (list_empty(metric_list)) |
---|
| 777 | + list_add(&m->nd, metric_list); |
---|
| 778 | + else { |
---|
| 779 | + struct list_head *pos; |
---|
409 | 780 | |
---|
410 | | - if (!pe->name && !pe->metric_group && !pe->metric_name) |
---|
411 | | - break; |
---|
412 | | - if (!pe->metric_expr) |
---|
413 | | - continue; |
---|
414 | | - if (match_metric(pe->metric_group, metric) || |
---|
415 | | - match_metric(pe->metric_name, metric)) { |
---|
416 | | - const char **ids; |
---|
417 | | - int idnum; |
---|
418 | | - struct egroup *eg; |
---|
| 781 | + /* Place the largest groups at the front. */ |
---|
| 782 | + list_for_each_prev(pos, metric_list) { |
---|
| 783 | + struct metric *old = list_entry(pos, struct metric, nd); |
---|
419 | 784 | |
---|
420 | | - pr_debug("metric expr %s for %s\n", pe->metric_expr, pe->metric_name); |
---|
421 | | - |
---|
422 | | - if (expr__find_other(pe->metric_expr, |
---|
423 | | - NULL, &ids, &idnum) < 0) |
---|
424 | | - continue; |
---|
425 | | - if (events->len > 0) |
---|
426 | | - strbuf_addf(events, ","); |
---|
427 | | - for (j = 0; j < idnum; j++) { |
---|
428 | | - pr_debug("found event %s\n", ids[j]); |
---|
429 | | - strbuf_addf(events, "%s%s", |
---|
430 | | - j == 0 ? "{" : ",", |
---|
431 | | - ids[j]); |
---|
432 | | - } |
---|
433 | | - strbuf_addf(events, "}:W"); |
---|
434 | | - |
---|
435 | | - eg = malloc(sizeof(struct egroup)); |
---|
436 | | - if (!eg) { |
---|
437 | | - ret = -ENOMEM; |
---|
| 785 | + if (hashmap__size(&m->pctx.ids) <= |
---|
| 786 | + hashmap__size(&old->pctx.ids)) |
---|
438 | 787 | break; |
---|
439 | | - } |
---|
440 | | - eg->ids = ids; |
---|
441 | | - eg->idnum = idnum; |
---|
442 | | - eg->metric_name = pe->metric_name; |
---|
443 | | - eg->metric_expr = pe->metric_expr; |
---|
444 | | - list_add_tail(&eg->nd, group_list); |
---|
445 | | - ret = 0; |
---|
446 | 788 | } |
---|
| 789 | + list_add(&m->nd, pos); |
---|
447 | 790 | } |
---|
| 791 | + |
---|
| 792 | + return 0; |
---|
| 793 | +} |
---|
| 794 | + |
---|
| 795 | +#define map_for_each_event(__pe, __idx, __map) \ |
---|
| 796 | + for (__idx = 0, __pe = &__map->table[__idx]; \ |
---|
| 797 | + __pe->name || __pe->metric_group || __pe->metric_name; \ |
---|
| 798 | + __pe = &__map->table[++__idx]) |
---|
| 799 | + |
---|
| 800 | +#define map_for_each_metric(__pe, __idx, __map, __metric) \ |
---|
| 801 | + map_for_each_event(__pe, __idx, __map) \ |
---|
| 802 | + if (__pe->metric_expr && \ |
---|
| 803 | + (match_metric(__pe->metric_group, __metric) || \ |
---|
| 804 | + match_metric(__pe->metric_name, __metric))) |
---|
| 805 | + |
---|
| 806 | +static struct pmu_event *find_metric(const char *metric, struct pmu_events_map *map) |
---|
| 807 | +{ |
---|
| 808 | + struct pmu_event *pe; |
---|
| 809 | + int i; |
---|
| 810 | + |
---|
| 811 | + map_for_each_event(pe, i, map) { |
---|
| 812 | + if (match_metric(pe->metric_name, metric)) |
---|
| 813 | + return pe; |
---|
| 814 | + } |
---|
| 815 | + |
---|
| 816 | + return NULL; |
---|
| 817 | +} |
---|
| 818 | + |
---|
| 819 | +static int recursion_check(struct metric *m, const char *id, struct expr_id **parent, |
---|
| 820 | + struct expr_ids *ids) |
---|
| 821 | +{ |
---|
| 822 | + struct expr_id_data *data; |
---|
| 823 | + struct expr_id *p; |
---|
| 824 | + int ret; |
---|
| 825 | + |
---|
| 826 | + /* |
---|
| 827 | + * We get the parent referenced by 'id' argument and |
---|
| 828 | + * traverse through all the parent object IDs to check |
---|
| 829 | + * if we already processed 'id', if we did, it's recursion |
---|
| 830 | + * and we fail. |
---|
| 831 | + */ |
---|
| 832 | + ret = expr__get_id(&m->pctx, id, &data); |
---|
| 833 | + if (ret) |
---|
| 834 | + return ret; |
---|
| 835 | + |
---|
| 836 | + p = data->parent; |
---|
| 837 | + |
---|
| 838 | + while (p->parent) { |
---|
| 839 | + if (!strcmp(p->id, id)) { |
---|
| 840 | + pr_err("failed: recursion detected for %s\n", id); |
---|
| 841 | + return -1; |
---|
| 842 | + } |
---|
| 843 | + p = p->parent; |
---|
| 844 | + } |
---|
| 845 | + |
---|
| 846 | + /* |
---|
| 847 | + * If we are over the limit of static entris, the metric |
---|
| 848 | + * is too difficult/nested to process, fail as well. |
---|
| 849 | + */ |
---|
| 850 | + p = expr_ids__alloc(ids); |
---|
| 851 | + if (!p) { |
---|
| 852 | + pr_err("failed: too many nested metrics\n"); |
---|
| 853 | + return -EINVAL; |
---|
| 854 | + } |
---|
| 855 | + |
---|
| 856 | + p->id = strdup(id); |
---|
| 857 | + p->parent = data->parent; |
---|
| 858 | + *parent = p; |
---|
| 859 | + |
---|
| 860 | + return p->id ? 0 : -ENOMEM; |
---|
| 861 | +} |
---|
| 862 | + |
---|
| 863 | +static int add_metric(struct list_head *metric_list, |
---|
| 864 | + struct pmu_event *pe, |
---|
| 865 | + bool metric_no_group, |
---|
| 866 | + struct metric **mp, |
---|
| 867 | + struct expr_id *parent, |
---|
| 868 | + struct expr_ids *ids); |
---|
| 869 | + |
---|
| 870 | +static int __resolve_metric(struct metric *m, |
---|
| 871 | + bool metric_no_group, |
---|
| 872 | + struct list_head *metric_list, |
---|
| 873 | + struct pmu_events_map *map, |
---|
| 874 | + struct expr_ids *ids) |
---|
| 875 | +{ |
---|
| 876 | + struct hashmap_entry *cur; |
---|
| 877 | + size_t bkt; |
---|
| 878 | + bool all; |
---|
| 879 | + int ret; |
---|
| 880 | + |
---|
| 881 | + /* |
---|
| 882 | + * Iterate all the parsed IDs and if there's metric, |
---|
| 883 | + * add it to the context. |
---|
| 884 | + */ |
---|
| 885 | + do { |
---|
| 886 | + all = true; |
---|
| 887 | + hashmap__for_each_entry((&m->pctx.ids), cur, bkt) { |
---|
| 888 | + struct expr_id *parent; |
---|
| 889 | + struct pmu_event *pe; |
---|
| 890 | + |
---|
| 891 | + pe = find_metric(cur->key, map); |
---|
| 892 | + if (!pe) |
---|
| 893 | + continue; |
---|
| 894 | + |
---|
| 895 | + ret = recursion_check(m, cur->key, &parent, ids); |
---|
| 896 | + if (ret) |
---|
| 897 | + return ret; |
---|
| 898 | + |
---|
| 899 | + all = false; |
---|
| 900 | + /* The metric key itself needs to go out.. */ |
---|
| 901 | + expr__del_id(&m->pctx, cur->key); |
---|
| 902 | + |
---|
| 903 | + /* ... and it gets resolved to the parent context. */ |
---|
| 904 | + ret = add_metric(metric_list, pe, metric_no_group, &m, parent, ids); |
---|
| 905 | + if (ret) |
---|
| 906 | + return ret; |
---|
| 907 | + |
---|
| 908 | + /* |
---|
| 909 | + * We added new metric to hashmap, so we need |
---|
| 910 | + * to break the iteration and start over. |
---|
| 911 | + */ |
---|
| 912 | + break; |
---|
| 913 | + } |
---|
| 914 | + } while (!all); |
---|
| 915 | + |
---|
| 916 | + return 0; |
---|
| 917 | +} |
---|
| 918 | + |
---|
| 919 | +static int resolve_metric(bool metric_no_group, |
---|
| 920 | + struct list_head *metric_list, |
---|
| 921 | + struct pmu_events_map *map, |
---|
| 922 | + struct expr_ids *ids) |
---|
| 923 | +{ |
---|
| 924 | + struct metric *m; |
---|
| 925 | + int err; |
---|
| 926 | + |
---|
| 927 | + list_for_each_entry(m, metric_list, nd) { |
---|
| 928 | + err = __resolve_metric(m, metric_no_group, metric_list, map, ids); |
---|
| 929 | + if (err) |
---|
| 930 | + return err; |
---|
| 931 | + } |
---|
| 932 | + return 0; |
---|
| 933 | +} |
---|
| 934 | + |
---|
| 935 | +static int add_metric(struct list_head *metric_list, |
---|
| 936 | + struct pmu_event *pe, |
---|
| 937 | + bool metric_no_group, |
---|
| 938 | + struct metric **m, |
---|
| 939 | + struct expr_id *parent, |
---|
| 940 | + struct expr_ids *ids) |
---|
| 941 | +{ |
---|
| 942 | + struct metric *orig = *m; |
---|
| 943 | + int ret = 0; |
---|
| 944 | + |
---|
| 945 | + pr_debug("metric expr %s for %s\n", pe->metric_expr, pe->metric_name); |
---|
| 946 | + |
---|
| 947 | + if (!strstr(pe->metric_expr, "?")) { |
---|
| 948 | + ret = __add_metric(metric_list, pe, metric_no_group, 1, m, parent, ids); |
---|
| 949 | + } else { |
---|
| 950 | + int j, count; |
---|
| 951 | + |
---|
| 952 | + count = arch_get_runtimeparam(pe); |
---|
| 953 | + |
---|
| 954 | + /* This loop is added to create multiple |
---|
| 955 | + * events depend on count value and add |
---|
| 956 | + * those events to metric_list. |
---|
| 957 | + */ |
---|
| 958 | + |
---|
| 959 | + for (j = 0; j < count && !ret; j++, *m = orig) |
---|
| 960 | + ret = __add_metric(metric_list, pe, metric_no_group, j, m, parent, ids); |
---|
| 961 | + } |
---|
| 962 | + |
---|
448 | 963 | return ret; |
---|
449 | 964 | } |
---|
450 | 965 | |
---|
451 | | -static int metricgroup__add_metric_list(const char *list, struct strbuf *events, |
---|
452 | | - struct list_head *group_list) |
---|
| 966 | +static int metricgroup__add_metric(const char *metric, bool metric_no_group, |
---|
| 967 | + struct strbuf *events, |
---|
| 968 | + struct list_head *metric_list, |
---|
| 969 | + struct pmu_events_map *map) |
---|
| 970 | +{ |
---|
| 971 | + struct expr_ids ids = { .cnt = 0, }; |
---|
| 972 | + struct pmu_event *pe; |
---|
| 973 | + struct metric *m; |
---|
| 974 | + LIST_HEAD(list); |
---|
| 975 | + int i, ret; |
---|
| 976 | + bool has_match = false; |
---|
| 977 | + |
---|
| 978 | + map_for_each_metric(pe, i, map, metric) { |
---|
| 979 | + has_match = true; |
---|
| 980 | + m = NULL; |
---|
| 981 | + |
---|
| 982 | + ret = add_metric(&list, pe, metric_no_group, &m, NULL, &ids); |
---|
| 983 | + if (ret) |
---|
| 984 | + goto out; |
---|
| 985 | + |
---|
| 986 | + /* |
---|
| 987 | + * Process any possible referenced metrics |
---|
| 988 | + * included in the expression. |
---|
| 989 | + */ |
---|
| 990 | + ret = resolve_metric(metric_no_group, |
---|
| 991 | + &list, map, &ids); |
---|
| 992 | + if (ret) |
---|
| 993 | + goto out; |
---|
| 994 | + } |
---|
| 995 | + |
---|
| 996 | + /* End of pmu events. */ |
---|
| 997 | + if (!has_match) { |
---|
| 998 | + ret = -EINVAL; |
---|
| 999 | + goto out; |
---|
| 1000 | + } |
---|
| 1001 | + |
---|
| 1002 | + list_for_each_entry(m, &list, nd) { |
---|
| 1003 | + if (events->len > 0) |
---|
| 1004 | + strbuf_addf(events, ","); |
---|
| 1005 | + |
---|
| 1006 | + if (m->has_constraint) { |
---|
| 1007 | + metricgroup__add_metric_non_group(events, |
---|
| 1008 | + &m->pctx); |
---|
| 1009 | + } else { |
---|
| 1010 | + metricgroup__add_metric_weak_group(events, |
---|
| 1011 | + &m->pctx); |
---|
| 1012 | + } |
---|
| 1013 | + } |
---|
| 1014 | + |
---|
| 1015 | +out: |
---|
| 1016 | + /* |
---|
| 1017 | + * add to metric_list so that they can be released |
---|
| 1018 | + * even if it's failed |
---|
| 1019 | + */ |
---|
| 1020 | + list_splice(&list, metric_list); |
---|
| 1021 | + expr_ids__exit(&ids); |
---|
| 1022 | + return ret; |
---|
| 1023 | +} |
---|
| 1024 | + |
---|
| 1025 | +static int metricgroup__add_metric_list(const char *list, bool metric_no_group, |
---|
| 1026 | + struct strbuf *events, |
---|
| 1027 | + struct list_head *metric_list, |
---|
| 1028 | + struct pmu_events_map *map) |
---|
453 | 1029 | { |
---|
454 | 1030 | char *llist, *nlist, *p; |
---|
455 | 1031 | int ret = -EINVAL; |
---|
.. | .. |
---|
463 | 1039 | strbuf_addf(events, "%s", ""); |
---|
464 | 1040 | |
---|
465 | 1041 | while ((p = strsep(&llist, ",")) != NULL) { |
---|
466 | | - ret = metricgroup__add_metric(p, events, group_list); |
---|
| 1042 | + ret = metricgroup__add_metric(p, metric_no_group, events, |
---|
| 1043 | + metric_list, map); |
---|
467 | 1044 | if (ret == -EINVAL) { |
---|
468 | 1045 | fprintf(stderr, "Cannot find metric or group `%s'\n", |
---|
469 | 1046 | p); |
---|
.. | .. |
---|
471 | 1048 | } |
---|
472 | 1049 | } |
---|
473 | 1050 | free(nlist); |
---|
| 1051 | + |
---|
| 1052 | + if (!ret) |
---|
| 1053 | + metricgroup___watchdog_constraint_hint(NULL, true); |
---|
| 1054 | + |
---|
474 | 1055 | return ret; |
---|
475 | 1056 | } |
---|
476 | 1057 | |
---|
477 | | -static void metricgroup__free_egroups(struct list_head *group_list) |
---|
| 1058 | +static void metric__free_refs(struct metric *metric) |
---|
478 | 1059 | { |
---|
479 | | - struct egroup *eg, *egtmp; |
---|
480 | | - int i; |
---|
| 1060 | + struct metric_ref_node *ref, *tmp; |
---|
481 | 1061 | |
---|
482 | | - list_for_each_entry_safe (eg, egtmp, group_list, nd) { |
---|
483 | | - for (i = 0; i < eg->idnum; i++) |
---|
484 | | - free((char *)eg->ids[i]); |
---|
485 | | - free(eg->ids); |
---|
486 | | - free(eg); |
---|
| 1062 | + list_for_each_entry_safe(ref, tmp, &metric->metric_refs, list) { |
---|
| 1063 | + list_del(&ref->list); |
---|
| 1064 | + free(ref); |
---|
487 | 1065 | } |
---|
488 | 1066 | } |
---|
489 | 1067 | |
---|
490 | | -int metricgroup__parse_groups(const struct option *opt, |
---|
491 | | - const char *str, |
---|
492 | | - struct rblist *metric_events) |
---|
| 1068 | +static void metricgroup__free_metrics(struct list_head *metric_list) |
---|
| 1069 | +{ |
---|
| 1070 | + struct metric *m, *tmp; |
---|
| 1071 | + |
---|
| 1072 | + list_for_each_entry_safe (m, tmp, metric_list, nd) { |
---|
| 1073 | + metric__free_refs(m); |
---|
| 1074 | + expr__ctx_clear(&m->pctx); |
---|
| 1075 | + list_del_init(&m->nd); |
---|
| 1076 | + free(m); |
---|
| 1077 | + } |
---|
| 1078 | +} |
---|
| 1079 | + |
---|
| 1080 | +static int parse_groups(struct evlist *perf_evlist, const char *str, |
---|
| 1081 | + bool metric_no_group, |
---|
| 1082 | + bool metric_no_merge, |
---|
| 1083 | + struct perf_pmu *fake_pmu, |
---|
| 1084 | + struct rblist *metric_events, |
---|
| 1085 | + struct pmu_events_map *map) |
---|
493 | 1086 | { |
---|
494 | 1087 | struct parse_events_error parse_error; |
---|
495 | | - struct perf_evlist *perf_evlist = *(struct perf_evlist **)opt->value; |
---|
496 | 1088 | struct strbuf extra_events; |
---|
497 | | - LIST_HEAD(group_list); |
---|
| 1089 | + LIST_HEAD(metric_list); |
---|
498 | 1090 | int ret; |
---|
499 | 1091 | |
---|
500 | 1092 | if (metric_events->nr_entries == 0) |
---|
501 | 1093 | metricgroup__rblist_init(metric_events); |
---|
502 | | - ret = metricgroup__add_metric_list(str, &extra_events, &group_list); |
---|
| 1094 | + ret = metricgroup__add_metric_list(str, metric_no_group, |
---|
| 1095 | + &extra_events, &metric_list, map); |
---|
503 | 1096 | if (ret) |
---|
504 | | - return ret; |
---|
| 1097 | + goto out; |
---|
505 | 1098 | pr_debug("adding %s\n", extra_events.buf); |
---|
506 | | - memset(&parse_error, 0, sizeof(struct parse_events_error)); |
---|
507 | | - ret = parse_events(perf_evlist, extra_events.buf, &parse_error); |
---|
| 1099 | + bzero(&parse_error, sizeof(parse_error)); |
---|
| 1100 | + ret = __parse_events(perf_evlist, extra_events.buf, &parse_error, fake_pmu); |
---|
508 | 1101 | if (ret) { |
---|
509 | 1102 | parse_events_print_error(&parse_error, extra_events.buf); |
---|
510 | 1103 | goto out; |
---|
511 | 1104 | } |
---|
512 | | - strbuf_release(&extra_events); |
---|
513 | | - ret = metricgroup__setup_events(&group_list, perf_evlist, |
---|
514 | | - metric_events); |
---|
| 1105 | + ret = metricgroup__setup_events(&metric_list, metric_no_merge, |
---|
| 1106 | + perf_evlist, metric_events); |
---|
515 | 1107 | out: |
---|
516 | | - metricgroup__free_egroups(&group_list); |
---|
| 1108 | + metricgroup__free_metrics(&metric_list); |
---|
| 1109 | + strbuf_release(&extra_events); |
---|
517 | 1110 | return ret; |
---|
| 1111 | +} |
---|
| 1112 | + |
---|
| 1113 | +int metricgroup__parse_groups(const struct option *opt, |
---|
| 1114 | + const char *str, |
---|
| 1115 | + bool metric_no_group, |
---|
| 1116 | + bool metric_no_merge, |
---|
| 1117 | + struct rblist *metric_events) |
---|
| 1118 | +{ |
---|
| 1119 | + struct evlist *perf_evlist = *(struct evlist **)opt->value; |
---|
| 1120 | + struct pmu_events_map *map = perf_pmu__find_map(NULL); |
---|
| 1121 | + |
---|
| 1122 | + if (!map) |
---|
| 1123 | + return 0; |
---|
| 1124 | + |
---|
| 1125 | + return parse_groups(perf_evlist, str, metric_no_group, |
---|
| 1126 | + metric_no_merge, NULL, metric_events, map); |
---|
| 1127 | +} |
---|
| 1128 | + |
---|
| 1129 | +int metricgroup__parse_groups_test(struct evlist *evlist, |
---|
| 1130 | + struct pmu_events_map *map, |
---|
| 1131 | + const char *str, |
---|
| 1132 | + bool metric_no_group, |
---|
| 1133 | + bool metric_no_merge, |
---|
| 1134 | + struct rblist *metric_events) |
---|
| 1135 | +{ |
---|
| 1136 | + return parse_groups(evlist, str, metric_no_group, |
---|
| 1137 | + metric_no_merge, &perf_pmu__fake, metric_events, map); |
---|
518 | 1138 | } |
---|
519 | 1139 | |
---|
520 | 1140 | bool metricgroup__has_metric(const char *metric) |
---|
.. | .. |
---|
538 | 1158 | } |
---|
539 | 1159 | return false; |
---|
540 | 1160 | } |
---|
| 1161 | + |
---|
| 1162 | +int metricgroup__copy_metric_events(struct evlist *evlist, struct cgroup *cgrp, |
---|
| 1163 | + struct rblist *new_metric_events, |
---|
| 1164 | + struct rblist *old_metric_events) |
---|
| 1165 | +{ |
---|
| 1166 | + unsigned i; |
---|
| 1167 | + |
---|
| 1168 | + for (i = 0; i < rblist__nr_entries(old_metric_events); i++) { |
---|
| 1169 | + struct rb_node *nd; |
---|
| 1170 | + struct metric_event *old_me, *new_me; |
---|
| 1171 | + struct metric_expr *old_expr, *new_expr; |
---|
| 1172 | + struct evsel *evsel; |
---|
| 1173 | + size_t alloc_size; |
---|
| 1174 | + int idx, nr; |
---|
| 1175 | + |
---|
| 1176 | + nd = rblist__entry(old_metric_events, i); |
---|
| 1177 | + old_me = container_of(nd, struct metric_event, nd); |
---|
| 1178 | + |
---|
| 1179 | + evsel = evlist__find_evsel(evlist, old_me->evsel->idx); |
---|
| 1180 | + if (!evsel) |
---|
| 1181 | + return -EINVAL; |
---|
| 1182 | + new_me = metricgroup__lookup(new_metric_events, evsel, true); |
---|
| 1183 | + if (!new_me) |
---|
| 1184 | + return -ENOMEM; |
---|
| 1185 | + |
---|
| 1186 | + pr_debug("copying metric event for cgroup '%s': %s (idx=%d)\n", |
---|
| 1187 | + cgrp ? cgrp->name : "root", evsel->name, evsel->idx); |
---|
| 1188 | + |
---|
| 1189 | + list_for_each_entry(old_expr, &old_me->head, nd) { |
---|
| 1190 | + new_expr = malloc(sizeof(*new_expr)); |
---|
| 1191 | + if (!new_expr) |
---|
| 1192 | + return -ENOMEM; |
---|
| 1193 | + |
---|
| 1194 | + new_expr->metric_expr = old_expr->metric_expr; |
---|
| 1195 | + new_expr->metric_name = old_expr->metric_name; |
---|
| 1196 | + new_expr->metric_unit = old_expr->metric_unit; |
---|
| 1197 | + new_expr->runtime = old_expr->runtime; |
---|
| 1198 | + |
---|
| 1199 | + if (old_expr->metric_refs) { |
---|
| 1200 | + /* calculate number of metric_events */ |
---|
| 1201 | + for (nr = 0; old_expr->metric_refs[nr].metric_name; nr++) |
---|
| 1202 | + continue; |
---|
| 1203 | + alloc_size = sizeof(*new_expr->metric_refs); |
---|
| 1204 | + new_expr->metric_refs = calloc(nr + 1, alloc_size); |
---|
| 1205 | + if (!new_expr->metric_refs) { |
---|
| 1206 | + free(new_expr); |
---|
| 1207 | + return -ENOMEM; |
---|
| 1208 | + } |
---|
| 1209 | + |
---|
| 1210 | + memcpy(new_expr->metric_refs, old_expr->metric_refs, |
---|
| 1211 | + nr * alloc_size); |
---|
| 1212 | + } else { |
---|
| 1213 | + new_expr->metric_refs = NULL; |
---|
| 1214 | + } |
---|
| 1215 | + |
---|
| 1216 | + /* calculate number of metric_events */ |
---|
| 1217 | + for (nr = 0; old_expr->metric_events[nr]; nr++) |
---|
| 1218 | + continue; |
---|
| 1219 | + alloc_size = sizeof(*new_expr->metric_events); |
---|
| 1220 | + new_expr->metric_events = calloc(nr + 1, alloc_size); |
---|
| 1221 | + if (!new_expr->metric_events) { |
---|
| 1222 | + free(new_expr->metric_refs); |
---|
| 1223 | + free(new_expr); |
---|
| 1224 | + return -ENOMEM; |
---|
| 1225 | + } |
---|
| 1226 | + |
---|
| 1227 | + /* copy evsel in the same position */ |
---|
| 1228 | + for (idx = 0; idx < nr; idx++) { |
---|
| 1229 | + evsel = old_expr->metric_events[idx]; |
---|
| 1230 | + evsel = evlist__find_evsel(evlist, evsel->idx); |
---|
| 1231 | + if (evsel == NULL) { |
---|
| 1232 | + free(new_expr->metric_events); |
---|
| 1233 | + free(new_expr->metric_refs); |
---|
| 1234 | + free(new_expr); |
---|
| 1235 | + return -EINVAL; |
---|
| 1236 | + } |
---|
| 1237 | + new_expr->metric_events[idx] = evsel; |
---|
| 1238 | + } |
---|
| 1239 | + |
---|
| 1240 | + list_add(&new_expr->nd, &new_me->head); |
---|
| 1241 | + } |
---|
| 1242 | + } |
---|
| 1243 | + return 0; |
---|
| 1244 | +} |
---|