Commit | Line | Data |
---|---|---|
92f6c72e MH |
1 | /* |
2 | * probe-file.c : operate ftrace k/uprobe events files | |
3 | * | |
4 | * Written by Masami Hiramatsu <masami.hiramatsu.pt@hitachi.com> | |
5 | * | |
6 | * This program is free software; you can redistribute it and/or modify | |
7 | * it under the terms of the GNU General Public License as published by | |
8 | * the Free Software Foundation; either version 2 of the License, or | |
9 | * (at your option) any later version. | |
10 | * | |
11 | * This program is distributed in the hope that it will be useful, | |
12 | * but WITHOUT ANY WARRANTY; without even the implied warranty of | |
13 | * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the | |
14 | * GNU General Public License for more details. | |
15 | * | |
16 | */ | |
dd975497 | 17 | #include <sys/uio.h> |
92f6c72e MH |
18 | #include "util.h" |
19 | #include "event.h" | |
20 | #include "strlist.h" | |
21 | #include "debug.h" | |
22 | #include "cache.h" | |
23 | #include "color.h" | |
24 | #include "symbol.h" | |
25 | #include "thread.h" | |
fbf99625 | 26 | #include <api/fs/tracing_path.h> |
92f6c72e MH |
27 | #include "probe-event.h" |
28 | #include "probe-file.h" | |
29 | #include "session.h" | |
30 | ||
31 | #define MAX_CMDLEN 256 | |
32 | ||
33 | static void print_open_warning(int err, bool uprobe) | |
34 | { | |
35 | char sbuf[STRERR_BUFSIZE]; | |
36 | ||
37 | if (err == -ENOENT) { | |
38 | const char *config; | |
39 | ||
40 | if (uprobe) | |
41 | config = "CONFIG_UPROBE_EVENTS"; | |
42 | else | |
43 | config = "CONFIG_KPROBE_EVENTS"; | |
44 | ||
45 | pr_warning("%cprobe_events file does not exist" | |
46 | " - please rebuild kernel with %s.\n", | |
47 | uprobe ? 'u' : 'k', config); | |
48 | } else if (err == -ENOTSUP) | |
49 | pr_warning("Tracefs or debugfs is not mounted.\n"); | |
50 | else | |
51 | pr_warning("Failed to open %cprobe_events: %s\n", | |
52 | uprobe ? 'u' : 'k', | |
c8b5f2c9 | 53 | str_error_r(-err, sbuf, sizeof(sbuf))); |
92f6c72e MH |
54 | } |
55 | ||
56 | static void print_both_open_warning(int kerr, int uerr) | |
57 | { | |
58 | /* Both kprobes and uprobes are disabled, warn it. */ | |
59 | if (kerr == -ENOTSUP && uerr == -ENOTSUP) | |
60 | pr_warning("Tracefs or debugfs is not mounted.\n"); | |
61 | else if (kerr == -ENOENT && uerr == -ENOENT) | |
62 | pr_warning("Please rebuild kernel with CONFIG_KPROBE_EVENTS " | |
63 | "or/and CONFIG_UPROBE_EVENTS.\n"); | |
64 | else { | |
65 | char sbuf[STRERR_BUFSIZE]; | |
66 | pr_warning("Failed to open kprobe events: %s.\n", | |
c8b5f2c9 | 67 | str_error_r(-kerr, sbuf, sizeof(sbuf))); |
92f6c72e | 68 | pr_warning("Failed to open uprobe events: %s.\n", |
c8b5f2c9 | 69 | str_error_r(-uerr, sbuf, sizeof(sbuf))); |
92f6c72e MH |
70 | } |
71 | } | |
72 | ||
73 | static int open_probe_events(const char *trace_file, bool readwrite) | |
74 | { | |
75 | char buf[PATH_MAX]; | |
92f6c72e MH |
76 | int ret; |
77 | ||
04e11960 MH |
78 | ret = e_snprintf(buf, PATH_MAX, "%s/%s", |
79 | tracing_path, trace_file); | |
92f6c72e MH |
80 | if (ret >= 0) { |
81 | pr_debug("Opening %s write=%d\n", buf, readwrite); | |
82 | if (readwrite && !probe_event_dry_run) | |
83 | ret = open(buf, O_RDWR | O_APPEND, 0); | |
84 | else | |
85 | ret = open(buf, O_RDONLY, 0); | |
86 | ||
87 | if (ret < 0) | |
88 | ret = -errno; | |
89 | } | |
90 | return ret; | |
91 | } | |
92 | ||
93 | static int open_kprobe_events(bool readwrite) | |
94 | { | |
95 | return open_probe_events("kprobe_events", readwrite); | |
96 | } | |
97 | ||
98 | static int open_uprobe_events(bool readwrite) | |
99 | { | |
100 | return open_probe_events("uprobe_events", readwrite); | |
101 | } | |
102 | ||
103 | int probe_file__open(int flag) | |
104 | { | |
105 | int fd; | |
106 | ||
107 | if (flag & PF_FL_UPROBE) | |
108 | fd = open_uprobe_events(flag & PF_FL_RW); | |
109 | else | |
110 | fd = open_kprobe_events(flag & PF_FL_RW); | |
111 | if (fd < 0) | |
112 | print_open_warning(fd, flag & PF_FL_UPROBE); | |
113 | ||
114 | return fd; | |
115 | } | |
116 | ||
117 | int probe_file__open_both(int *kfd, int *ufd, int flag) | |
118 | { | |
119 | if (!kfd || !ufd) | |
120 | return -EINVAL; | |
121 | ||
122 | *kfd = open_kprobe_events(flag & PF_FL_RW); | |
123 | *ufd = open_uprobe_events(flag & PF_FL_RW); | |
124 | if (*kfd < 0 && *ufd < 0) { | |
125 | print_both_open_warning(*kfd, *ufd); | |
126 | return *kfd; | |
127 | } | |
128 | ||
129 | return 0; | |
130 | } | |
131 | ||
132 | /* Get raw string list of current kprobe_events or uprobe_events */ | |
133 | struct strlist *probe_file__get_rawlist(int fd) | |
134 | { | |
0325862d | 135 | int ret, idx, fddup; |
92f6c72e MH |
136 | FILE *fp; |
137 | char buf[MAX_CMDLEN]; | |
138 | char *p; | |
139 | struct strlist *sl; | |
140 | ||
421fd084 WN |
141 | if (fd < 0) |
142 | return NULL; | |
143 | ||
92f6c72e | 144 | sl = strlist__new(NULL, NULL); |
60ebc159 ACM |
145 | if (sl == NULL) |
146 | return NULL; | |
92f6c72e | 147 | |
0325862d CIK |
148 | fddup = dup(fd); |
149 | if (fddup < 0) | |
150 | goto out_free_sl; | |
151 | ||
152 | fp = fdopen(fddup, "r"); | |
153 | if (!fp) | |
154 | goto out_close_fddup; | |
155 | ||
92f6c72e MH |
156 | while (!feof(fp)) { |
157 | p = fgets(buf, MAX_CMDLEN, fp); | |
158 | if (!p) | |
159 | break; | |
160 | ||
161 | idx = strlen(p) - 1; | |
162 | if (p[idx] == '\n') | |
163 | p[idx] = '\0'; | |
164 | ret = strlist__add(sl, buf); | |
165 | if (ret < 0) { | |
166 | pr_debug("strlist__add failed (%d)\n", ret); | |
60ebc159 | 167 | goto out_close_fp; |
92f6c72e MH |
168 | } |
169 | } | |
170 | fclose(fp); | |
171 | ||
172 | return sl; | |
0325862d | 173 | |
60ebc159 ACM |
174 | out_close_fp: |
175 | fclose(fp); | |
176 | goto out_free_sl; | |
0325862d CIK |
177 | out_close_fddup: |
178 | close(fddup); | |
179 | out_free_sl: | |
180 | strlist__delete(sl); | |
181 | return NULL; | |
92f6c72e MH |
182 | } |
183 | ||
184 | static struct strlist *__probe_file__get_namelist(int fd, bool include_group) | |
185 | { | |
186 | char buf[128]; | |
187 | struct strlist *sl, *rawlist; | |
188 | struct str_node *ent; | |
189 | struct probe_trace_event tev; | |
190 | int ret = 0; | |
191 | ||
192 | memset(&tev, 0, sizeof(tev)); | |
193 | rawlist = probe_file__get_rawlist(fd); | |
194 | if (!rawlist) | |
195 | return NULL; | |
196 | sl = strlist__new(NULL, NULL); | |
602a1f4d | 197 | strlist__for_each_entry(ent, rawlist) { |
92f6c72e MH |
198 | ret = parse_probe_trace_command(ent->s, &tev); |
199 | if (ret < 0) | |
200 | break; | |
201 | if (include_group) { | |
202 | ret = e_snprintf(buf, 128, "%s:%s", tev.group, | |
203 | tev.event); | |
204 | if (ret >= 0) | |
205 | ret = strlist__add(sl, buf); | |
206 | } else | |
207 | ret = strlist__add(sl, tev.event); | |
208 | clear_probe_trace_event(&tev); | |
209 | if (ret < 0) | |
210 | break; | |
211 | } | |
212 | strlist__delete(rawlist); | |
213 | ||
214 | if (ret < 0) { | |
215 | strlist__delete(sl); | |
216 | return NULL; | |
217 | } | |
218 | return sl; | |
219 | } | |
220 | ||
221 | /* Get current perf-probe event names */ | |
222 | struct strlist *probe_file__get_namelist(int fd) | |
223 | { | |
224 | return __probe_file__get_namelist(fd, false); | |
225 | } | |
226 | ||
227 | int probe_file__add_event(int fd, struct probe_trace_event *tev) | |
228 | { | |
229 | int ret = 0; | |
230 | char *buf = synthesize_probe_trace_command(tev); | |
231 | char sbuf[STRERR_BUFSIZE]; | |
232 | ||
233 | if (!buf) { | |
234 | pr_debug("Failed to synthesize probe trace event.\n"); | |
235 | return -EINVAL; | |
236 | } | |
237 | ||
238 | pr_debug("Writing event: %s\n", buf); | |
239 | if (!probe_event_dry_run) { | |
6ed0720a | 240 | if (write(fd, buf, strlen(buf)) < (int)strlen(buf)) { |
92f6c72e MH |
241 | ret = -errno; |
242 | pr_warning("Failed to write event: %s\n", | |
c8b5f2c9 | 243 | str_error_r(errno, sbuf, sizeof(sbuf))); |
92f6c72e MH |
244 | } |
245 | } | |
246 | free(buf); | |
247 | ||
248 | return ret; | |
249 | } | |
250 | ||
251 | static int __del_trace_probe_event(int fd, struct str_node *ent) | |
252 | { | |
253 | char *p; | |
254 | char buf[128]; | |
255 | int ret; | |
256 | ||
257 | /* Convert from perf-probe event to trace-probe event */ | |
258 | ret = e_snprintf(buf, 128, "-:%s", ent->s); | |
259 | if (ret < 0) | |
260 | goto error; | |
261 | ||
262 | p = strchr(buf + 2, ':'); | |
263 | if (!p) { | |
264 | pr_debug("Internal error: %s should have ':' but not.\n", | |
265 | ent->s); | |
266 | ret = -ENOTSUP; | |
267 | goto error; | |
268 | } | |
269 | *p = '/'; | |
270 | ||
271 | pr_debug("Writing event: %s\n", buf); | |
272 | ret = write(fd, buf, strlen(buf)); | |
273 | if (ret < 0) { | |
274 | ret = -errno; | |
275 | goto error; | |
276 | } | |
277 | ||
92f6c72e MH |
278 | return 0; |
279 | error: | |
280 | pr_warning("Failed to delete event: %s\n", | |
c8b5f2c9 | 281 | str_error_r(-ret, buf, sizeof(buf))); |
92f6c72e MH |
282 | return ret; |
283 | } | |
284 | ||
e607f142 NK |
285 | int probe_file__get_events(int fd, struct strfilter *filter, |
286 | struct strlist *plist) | |
92f6c72e MH |
287 | { |
288 | struct strlist *namelist; | |
289 | struct str_node *ent; | |
290 | const char *p; | |
291 | int ret = -ENOENT; | |
292 | ||
421fd084 WN |
293 | if (!plist) |
294 | return -EINVAL; | |
295 | ||
92f6c72e MH |
296 | namelist = __probe_file__get_namelist(fd, true); |
297 | if (!namelist) | |
298 | return -ENOENT; | |
299 | ||
602a1f4d | 300 | strlist__for_each_entry(ent, namelist) { |
92f6c72e MH |
301 | p = strchr(ent->s, ':'); |
302 | if ((p && strfilter__compare(filter, p + 1)) || | |
303 | strfilter__compare(filter, ent->s)) { | |
e7895e42 NK |
304 | strlist__add(plist, ent->s); |
305 | ret = 0; | |
92f6c72e MH |
306 | } |
307 | } | |
308 | strlist__delete(namelist); | |
309 | ||
310 | return ret; | |
311 | } | |
e7895e42 | 312 | |
e607f142 | 313 | int probe_file__del_strlist(int fd, struct strlist *namelist) |
e7895e42 NK |
314 | { |
315 | int ret = 0; | |
316 | struct str_node *ent; | |
317 | ||
602a1f4d | 318 | strlist__for_each_entry(ent, namelist) { |
e7895e42 NK |
319 | ret = __del_trace_probe_event(fd, ent); |
320 | if (ret < 0) | |
321 | break; | |
322 | } | |
323 | return ret; | |
324 | } | |
325 | ||
326 | int probe_file__del_events(int fd, struct strfilter *filter) | |
327 | { | |
328 | struct strlist *namelist; | |
329 | int ret; | |
330 | ||
331 | namelist = strlist__new(NULL, NULL); | |
332 | if (!namelist) | |
333 | return -ENOMEM; | |
334 | ||
335 | ret = probe_file__get_events(fd, filter, namelist); | |
336 | if (ret < 0) | |
337 | return ret; | |
338 | ||
339 | ret = probe_file__del_strlist(fd, namelist); | |
340 | strlist__delete(namelist); | |
341 | ||
342 | return ret; | |
343 | } | |
dd975497 MH |
344 | |
345 | /* Caller must ensure to remove this entry from list */ | |
346 | static void probe_cache_entry__delete(struct probe_cache_entry *entry) | |
347 | { | |
348 | if (entry) { | |
349 | BUG_ON(!list_empty(&entry->node)); | |
350 | ||
351 | strlist__delete(entry->tevlist); | |
352 | clear_perf_probe_event(&entry->pev); | |
353 | zfree(&entry->spev); | |
354 | free(entry); | |
355 | } | |
356 | } | |
357 | ||
358 | static struct probe_cache_entry * | |
359 | probe_cache_entry__new(struct perf_probe_event *pev) | |
360 | { | |
361 | struct probe_cache_entry *entry = zalloc(sizeof(*entry)); | |
362 | ||
363 | if (entry) { | |
364 | INIT_LIST_HEAD(&entry->node); | |
365 | entry->tevlist = strlist__new(NULL, NULL); | |
366 | if (!entry->tevlist) | |
367 | zfree(&entry); | |
368 | else if (pev) { | |
369 | entry->spev = synthesize_perf_probe_command(pev); | |
370 | if (!entry->spev || | |
371 | perf_probe_event__copy(&entry->pev, pev) < 0) { | |
372 | probe_cache_entry__delete(entry); | |
373 | return NULL; | |
374 | } | |
375 | } | |
376 | } | |
377 | ||
378 | return entry; | |
379 | } | |
380 | ||
42bba263 MH |
381 | int probe_cache_entry__get_event(struct probe_cache_entry *entry, |
382 | struct probe_trace_event **tevs) | |
383 | { | |
384 | struct probe_trace_event *tev; | |
385 | struct str_node *node; | |
386 | int ret, i; | |
387 | ||
388 | ret = strlist__nr_entries(entry->tevlist); | |
389 | if (ret > probe_conf.max_probes) | |
390 | return -E2BIG; | |
391 | ||
392 | *tevs = zalloc(ret * sizeof(*tev)); | |
393 | if (!*tevs) | |
394 | return -ENOMEM; | |
395 | ||
396 | i = 0; | |
397 | strlist__for_each_entry(node, entry->tevlist) { | |
398 | tev = &(*tevs)[i++]; | |
399 | ret = parse_probe_trace_command(node->s, tev); | |
400 | if (ret < 0) | |
401 | break; | |
402 | } | |
403 | return i; | |
404 | } | |
405 | ||
406 | /* For the kernel probe caches, pass target = NULL or DSO__NAME_KALLSYMS */ | |
dd975497 MH |
407 | static int probe_cache__open(struct probe_cache *pcache, const char *target) |
408 | { | |
409 | char cpath[PATH_MAX]; | |
410 | char sbuildid[SBUILD_ID_SIZE]; | |
1f3736c9 | 411 | char *dir_name = NULL; |
42bba263 | 412 | bool is_kallsyms = false; |
dd975497 MH |
413 | int ret, fd; |
414 | ||
1f3736c9 MH |
415 | if (target && build_id_cache__cached(target)) { |
416 | /* This is a cached buildid */ | |
417 | strncpy(sbuildid, target, SBUILD_ID_SIZE); | |
418 | dir_name = build_id_cache__linkname(sbuildid, NULL, 0); | |
419 | goto found; | |
420 | } | |
421 | ||
42bba263 | 422 | if (!target || !strcmp(target, DSO__NAME_KALLSYMS)) { |
dd975497 | 423 | target = DSO__NAME_KALLSYMS; |
42bba263 | 424 | is_kallsyms = true; |
dd975497 | 425 | ret = sysfs__sprintf_build_id("/", sbuildid); |
42bba263 MH |
426 | } else |
427 | ret = filename__sprintf_build_id(target, sbuildid); | |
428 | ||
dd975497 MH |
429 | if (ret < 0) { |
430 | pr_debug("Failed to get build-id from %s.\n", target); | |
431 | return ret; | |
432 | } | |
433 | ||
434 | /* If we have no buildid cache, make it */ | |
435 | if (!build_id_cache__cached(sbuildid)) { | |
436 | ret = build_id_cache__add_s(sbuildid, target, | |
437 | is_kallsyms, NULL); | |
438 | if (ret < 0) { | |
439 | pr_debug("Failed to add build-id cache: %s\n", target); | |
440 | return ret; | |
441 | } | |
442 | } | |
443 | ||
444 | dir_name = build_id_cache__cachedir(sbuildid, target, is_kallsyms, | |
445 | false); | |
1f3736c9 MH |
446 | found: |
447 | if (!dir_name) { | |
448 | pr_debug("Failed to get cache from %s\n", target); | |
dd975497 | 449 | return -ENOMEM; |
1f3736c9 | 450 | } |
dd975497 MH |
451 | |
452 | snprintf(cpath, PATH_MAX, "%s/probes", dir_name); | |
453 | fd = open(cpath, O_CREAT | O_RDWR, 0644); | |
454 | if (fd < 0) | |
455 | pr_debug("Failed to open cache(%d): %s\n", fd, cpath); | |
456 | free(dir_name); | |
457 | pcache->fd = fd; | |
458 | ||
459 | return fd; | |
460 | } | |
461 | ||
462 | static int probe_cache__load(struct probe_cache *pcache) | |
463 | { | |
464 | struct probe_cache_entry *entry = NULL; | |
465 | char buf[MAX_CMDLEN], *p; | |
0325862d | 466 | int ret = 0, fddup; |
dd975497 MH |
467 | FILE *fp; |
468 | ||
0325862d CIK |
469 | fddup = dup(pcache->fd); |
470 | if (fddup < 0) | |
471 | return -errno; | |
472 | fp = fdopen(fddup, "r"); | |
60ebc159 ACM |
473 | if (!fp) { |
474 | close(fddup); | |
dd975497 | 475 | return -EINVAL; |
60ebc159 | 476 | } |
dd975497 MH |
477 | |
478 | while (!feof(fp)) { | |
479 | if (!fgets(buf, MAX_CMDLEN, fp)) | |
480 | break; | |
481 | p = strchr(buf, '\n'); | |
482 | if (p) | |
483 | *p = '\0'; | |
6430a94e MH |
484 | /* #perf_probe_event or %sdt_event */ |
485 | if (buf[0] == '#' || buf[0] == '%') { | |
dd975497 MH |
486 | entry = probe_cache_entry__new(NULL); |
487 | if (!entry) { | |
488 | ret = -ENOMEM; | |
489 | goto out; | |
490 | } | |
6430a94e MH |
491 | if (buf[0] == '%') |
492 | entry->sdt = true; | |
dd975497 MH |
493 | entry->spev = strdup(buf + 1); |
494 | if (entry->spev) | |
495 | ret = parse_perf_probe_command(buf + 1, | |
496 | &entry->pev); | |
497 | else | |
498 | ret = -ENOMEM; | |
499 | if (ret < 0) { | |
500 | probe_cache_entry__delete(entry); | |
501 | goto out; | |
502 | } | |
503 | list_add_tail(&entry->node, &pcache->entries); | |
504 | } else { /* trace_probe_event */ | |
505 | if (!entry) { | |
506 | ret = -EINVAL; | |
507 | goto out; | |
508 | } | |
509 | strlist__add(entry->tevlist, buf); | |
510 | } | |
511 | } | |
512 | out: | |
513 | fclose(fp); | |
514 | return ret; | |
515 | } | |
516 | ||
517 | static struct probe_cache *probe_cache__alloc(void) | |
518 | { | |
519 | struct probe_cache *pcache = zalloc(sizeof(*pcache)); | |
520 | ||
521 | if (pcache) { | |
522 | INIT_LIST_HEAD(&pcache->entries); | |
523 | pcache->fd = -EINVAL; | |
524 | } | |
525 | return pcache; | |
526 | } | |
527 | ||
528 | void probe_cache__purge(struct probe_cache *pcache) | |
529 | { | |
530 | struct probe_cache_entry *entry, *n; | |
531 | ||
532 | list_for_each_entry_safe(entry, n, &pcache->entries, node) { | |
533 | list_del_init(&entry->node); | |
534 | probe_cache_entry__delete(entry); | |
535 | } | |
536 | } | |
537 | ||
538 | void probe_cache__delete(struct probe_cache *pcache) | |
539 | { | |
540 | if (!pcache) | |
541 | return; | |
542 | ||
543 | probe_cache__purge(pcache); | |
544 | if (pcache->fd > 0) | |
545 | close(pcache->fd); | |
546 | free(pcache); | |
547 | } | |
548 | ||
549 | struct probe_cache *probe_cache__new(const char *target) | |
550 | { | |
551 | struct probe_cache *pcache = probe_cache__alloc(); | |
552 | int ret; | |
553 | ||
554 | if (!pcache) | |
555 | return NULL; | |
556 | ||
557 | ret = probe_cache__open(pcache, target); | |
558 | if (ret < 0) { | |
559 | pr_debug("Cache open error: %d\n", ret); | |
560 | goto out_err; | |
561 | } | |
562 | ||
563 | ret = probe_cache__load(pcache); | |
564 | if (ret < 0) { | |
565 | pr_debug("Cache read error: %d\n", ret); | |
566 | goto out_err; | |
567 | } | |
568 | ||
569 | return pcache; | |
570 | ||
571 | out_err: | |
572 | probe_cache__delete(pcache); | |
573 | return NULL; | |
574 | } | |
575 | ||
576 | static bool streql(const char *a, const char *b) | |
577 | { | |
578 | if (a == b) | |
579 | return true; | |
580 | ||
581 | if (!a || !b) | |
582 | return false; | |
583 | ||
584 | return !strcmp(a, b); | |
585 | } | |
586 | ||
bc062230 | 587 | struct probe_cache_entry * |
dd975497 MH |
588 | probe_cache__find(struct probe_cache *pcache, struct perf_probe_event *pev) |
589 | { | |
590 | struct probe_cache_entry *entry = NULL; | |
591 | char *cmd = synthesize_perf_probe_command(pev); | |
592 | ||
593 | if (!cmd) | |
594 | return NULL; | |
595 | ||
05bf2c8a | 596 | for_each_probe_cache_entry(entry, pcache) { |
36a009fe MH |
597 | if (pev->sdt) { |
598 | if (entry->pev.event && | |
599 | streql(entry->pev.event, pev->event) && | |
600 | (!pev->group || | |
601 | streql(entry->pev.group, pev->group))) | |
602 | goto found; | |
603 | ||
604 | continue; | |
605 | } | |
dd975497 MH |
606 | /* Hit if same event name or same command-string */ |
607 | if ((pev->event && | |
608 | (streql(entry->pev.group, pev->group) && | |
609 | streql(entry->pev.event, pev->event))) || | |
610 | (!strcmp(entry->spev, cmd))) | |
611 | goto found; | |
612 | } | |
613 | entry = NULL; | |
614 | ||
615 | found: | |
616 | free(cmd); | |
617 | return entry; | |
618 | } | |
619 | ||
bc062230 MH |
620 | struct probe_cache_entry * |
621 | probe_cache__find_by_name(struct probe_cache *pcache, | |
622 | const char *group, const char *event) | |
623 | { | |
624 | struct probe_cache_entry *entry = NULL; | |
625 | ||
05bf2c8a | 626 | for_each_probe_cache_entry(entry, pcache) { |
bc062230 MH |
627 | /* Hit if same event name or same command-string */ |
628 | if (streql(entry->pev.group, group) && | |
629 | streql(entry->pev.event, event)) | |
630 | goto found; | |
631 | } | |
632 | entry = NULL; | |
633 | ||
634 | found: | |
635 | return entry; | |
636 | } | |
637 | ||
dd975497 MH |
638 | int probe_cache__add_entry(struct probe_cache *pcache, |
639 | struct perf_probe_event *pev, | |
640 | struct probe_trace_event *tevs, int ntevs) | |
641 | { | |
642 | struct probe_cache_entry *entry = NULL; | |
643 | char *command; | |
644 | int i, ret = 0; | |
645 | ||
646 | if (!pcache || !pev || !tevs || ntevs <= 0) { | |
647 | ret = -EINVAL; | |
648 | goto out_err; | |
649 | } | |
650 | ||
651 | /* Remove old cache entry */ | |
652 | entry = probe_cache__find(pcache, pev); | |
653 | if (entry) { | |
654 | list_del_init(&entry->node); | |
655 | probe_cache_entry__delete(entry); | |
656 | } | |
657 | ||
658 | ret = -ENOMEM; | |
659 | entry = probe_cache_entry__new(pev); | |
660 | if (!entry) | |
661 | goto out_err; | |
662 | ||
663 | for (i = 0; i < ntevs; i++) { | |
664 | if (!tevs[i].point.symbol) | |
665 | continue; | |
666 | ||
667 | command = synthesize_probe_trace_command(&tevs[i]); | |
668 | if (!command) | |
669 | goto out_err; | |
670 | strlist__add(entry->tevlist, command); | |
671 | free(command); | |
672 | } | |
673 | list_add_tail(&entry->node, &pcache->entries); | |
674 | pr_debug("Added probe cache: %d\n", ntevs); | |
675 | return 0; | |
676 | ||
677 | out_err: | |
678 | pr_debug("Failed to add probe caches\n"); | |
679 | probe_cache_entry__delete(entry); | |
680 | return ret; | |
681 | } | |
682 | ||
1c1a3a47 | 683 | #ifdef HAVE_GELF_GETNOTE_SUPPORT |
6430a94e MH |
684 | static unsigned long long sdt_note__get_addr(struct sdt_note *note) |
685 | { | |
686 | return note->bit32 ? (unsigned long long)note->addr.a32[0] | |
687 | : (unsigned long long)note->addr.a64[0]; | |
688 | } | |
689 | ||
690 | int probe_cache__scan_sdt(struct probe_cache *pcache, const char *pathname) | |
691 | { | |
692 | struct probe_cache_entry *entry = NULL; | |
693 | struct list_head sdtlist; | |
694 | struct sdt_note *note; | |
695 | char *buf; | |
696 | char sdtgrp[64]; | |
697 | int ret; | |
698 | ||
699 | INIT_LIST_HEAD(&sdtlist); | |
700 | ret = get_sdt_note_list(&sdtlist, pathname); | |
701 | if (ret < 0) { | |
f9655200 | 702 | pr_debug4("Failed to get sdt note: %d\n", ret); |
6430a94e MH |
703 | return ret; |
704 | } | |
705 | list_for_each_entry(note, &sdtlist, note_list) { | |
706 | ret = snprintf(sdtgrp, 64, "sdt_%s", note->provider); | |
707 | if (ret < 0) | |
708 | break; | |
709 | /* Try to find same-name entry */ | |
710 | entry = probe_cache__find_by_name(pcache, sdtgrp, note->name); | |
711 | if (!entry) { | |
712 | entry = probe_cache_entry__new(NULL); | |
713 | if (!entry) { | |
714 | ret = -ENOMEM; | |
715 | break; | |
716 | } | |
717 | entry->sdt = true; | |
718 | ret = asprintf(&entry->spev, "%s:%s=%s", sdtgrp, | |
719 | note->name, note->name); | |
720 | if (ret < 0) | |
721 | break; | |
722 | entry->pev.event = strdup(note->name); | |
723 | entry->pev.group = strdup(sdtgrp); | |
724 | list_add_tail(&entry->node, &pcache->entries); | |
725 | } | |
726 | ret = asprintf(&buf, "p:%s/%s %s:0x%llx", | |
727 | sdtgrp, note->name, pathname, | |
728 | sdt_note__get_addr(note)); | |
729 | if (ret < 0) | |
730 | break; | |
731 | strlist__add(entry->tevlist, buf); | |
732 | free(buf); | |
733 | entry = NULL; | |
734 | } | |
735 | if (entry) { | |
736 | list_del_init(&entry->node); | |
737 | probe_cache_entry__delete(entry); | |
738 | } | |
739 | cleanup_sdt_note_list(&sdtlist); | |
740 | return ret; | |
741 | } | |
1c1a3a47 | 742 | #endif |
6430a94e | 743 | |
dd975497 MH |
744 | static int probe_cache_entry__write(struct probe_cache_entry *entry, int fd) |
745 | { | |
746 | struct str_node *snode; | |
747 | struct stat st; | |
748 | struct iovec iov[3]; | |
6430a94e | 749 | const char *prefix = entry->sdt ? "%" : "#"; |
dd975497 MH |
750 | int ret; |
751 | /* Save stat for rollback */ | |
752 | ret = fstat(fd, &st); | |
753 | if (ret < 0) | |
754 | return ret; | |
755 | ||
6430a94e MH |
756 | pr_debug("Writing cache: %s%s\n", prefix, entry->spev); |
757 | iov[0].iov_base = (void *)prefix; iov[0].iov_len = 1; | |
dd975497 MH |
758 | iov[1].iov_base = entry->spev; iov[1].iov_len = strlen(entry->spev); |
759 | iov[2].iov_base = (void *)"\n"; iov[2].iov_len = 1; | |
760 | ret = writev(fd, iov, 3); | |
761 | if (ret < (int)iov[1].iov_len + 2) | |
762 | goto rollback; | |
763 | ||
602a1f4d | 764 | strlist__for_each_entry(snode, entry->tevlist) { |
dd975497 MH |
765 | iov[0].iov_base = (void *)snode->s; |
766 | iov[0].iov_len = strlen(snode->s); | |
767 | iov[1].iov_base = (void *)"\n"; iov[1].iov_len = 1; | |
768 | ret = writev(fd, iov, 2); | |
769 | if (ret < (int)iov[0].iov_len + 1) | |
770 | goto rollback; | |
771 | } | |
772 | return 0; | |
773 | ||
774 | rollback: | |
775 | /* Rollback to avoid cache file corruption */ | |
776 | if (ret > 0) | |
777 | ret = -1; | |
778 | if (ftruncate(fd, st.st_size) < 0) | |
779 | ret = -2; | |
780 | ||
781 | return ret; | |
782 | } | |
783 | ||
784 | int probe_cache__commit(struct probe_cache *pcache) | |
785 | { | |
786 | struct probe_cache_entry *entry; | |
787 | int ret = 0; | |
788 | ||
789 | /* TBD: if we do not update existing entries, skip it */ | |
790 | ret = lseek(pcache->fd, 0, SEEK_SET); | |
791 | if (ret < 0) | |
792 | goto out; | |
793 | ||
794 | ret = ftruncate(pcache->fd, 0); | |
795 | if (ret < 0) | |
796 | goto out; | |
797 | ||
05bf2c8a | 798 | for_each_probe_cache_entry(entry, pcache) { |
dd975497 MH |
799 | ret = probe_cache_entry__write(entry, pcache->fd); |
800 | pr_debug("Cache committed: %d\n", ret); | |
801 | if (ret < 0) | |
802 | break; | |
803 | } | |
804 | out: | |
805 | return ret; | |
806 | } | |
1f3736c9 | 807 | |
4a0f65c1 MH |
808 | static bool probe_cache_entry__compare(struct probe_cache_entry *entry, |
809 | struct strfilter *filter) | |
810 | { | |
811 | char buf[128], *ptr = entry->spev; | |
812 | ||
813 | if (entry->pev.event) { | |
814 | snprintf(buf, 128, "%s:%s", entry->pev.group, entry->pev.event); | |
815 | ptr = buf; | |
816 | } | |
817 | return strfilter__compare(filter, ptr); | |
818 | } | |
819 | ||
820 | int probe_cache__filter_purge(struct probe_cache *pcache, | |
821 | struct strfilter *filter) | |
822 | { | |
823 | struct probe_cache_entry *entry, *tmp; | |
824 | ||
825 | list_for_each_entry_safe(entry, tmp, &pcache->entries, node) { | |
826 | if (probe_cache_entry__compare(entry, filter)) { | |
827 | pr_info("Removed cached event: %s\n", entry->spev); | |
828 | list_del_init(&entry->node); | |
829 | probe_cache_entry__delete(entry); | |
830 | } | |
831 | } | |
832 | return 0; | |
833 | } | |
834 | ||
1f3736c9 MH |
835 | static int probe_cache__show_entries(struct probe_cache *pcache, |
836 | struct strfilter *filter) | |
837 | { | |
838 | struct probe_cache_entry *entry; | |
1f3736c9 | 839 | |
05bf2c8a | 840 | for_each_probe_cache_entry(entry, pcache) { |
4a0f65c1 | 841 | if (probe_cache_entry__compare(entry, filter)) |
1f3736c9 MH |
842 | printf("%s\n", entry->spev); |
843 | } | |
844 | return 0; | |
845 | } | |
846 | ||
847 | /* Show all cached probes */ | |
848 | int probe_cache__show_all_caches(struct strfilter *filter) | |
849 | { | |
850 | struct probe_cache *pcache; | |
851 | struct strlist *bidlist; | |
852 | struct str_node *nd; | |
853 | char *buf = strfilter__string(filter); | |
854 | ||
855 | pr_debug("list cache with filter: %s\n", buf); | |
856 | free(buf); | |
857 | ||
c3492a3a | 858 | bidlist = build_id_cache__list_all(true); |
1f3736c9 MH |
859 | if (!bidlist) { |
860 | pr_debug("Failed to get buildids: %d\n", errno); | |
861 | return -EINVAL; | |
862 | } | |
863 | strlist__for_each_entry(nd, bidlist) { | |
864 | pcache = probe_cache__new(nd->s); | |
865 | if (!pcache) | |
866 | continue; | |
867 | if (!list_empty(&pcache->entries)) { | |
868 | buf = build_id_cache__origname(nd->s); | |
869 | printf("%s (%s):\n", buf, nd->s); | |
870 | free(buf); | |
871 | probe_cache__show_entries(pcache, filter); | |
872 | } | |
873 | probe_cache__delete(pcache); | |
874 | } | |
875 | strlist__delete(bidlist); | |
876 | ||
877 | return 0; | |
878 | } | |
180b2061 MH |
879 | |
880 | static struct { | |
881 | const char *pattern; | |
882 | bool avail; | |
883 | bool checked; | |
884 | } probe_type_table[] = { | |
885 | #define DEFINE_TYPE(idx, pat, def_avail) \ | |
886 | [idx] = {.pattern = pat, .avail = (def_avail)} | |
887 | DEFINE_TYPE(PROBE_TYPE_U, "* u8/16/32/64,*", true), | |
888 | DEFINE_TYPE(PROBE_TYPE_S, "* s8/16/32/64,*", true), | |
889 | DEFINE_TYPE(PROBE_TYPE_X, "* x8/16/32/64,*", false), | |
890 | DEFINE_TYPE(PROBE_TYPE_STRING, "* string,*", true), | |
891 | DEFINE_TYPE(PROBE_TYPE_BITFIELD, | |
892 | "* b<bit-width>@<bit-offset>/<container-size>", true), | |
893 | }; | |
894 | ||
895 | bool probe_type_is_available(enum probe_type type) | |
896 | { | |
897 | FILE *fp; | |
898 | char *buf = NULL; | |
899 | size_t len = 0; | |
900 | bool target_line = false; | |
901 | bool ret = probe_type_table[type].avail; | |
902 | ||
903 | if (type >= PROBE_TYPE_END) | |
904 | return false; | |
905 | /* We don't have to check the type which supported by default */ | |
906 | if (ret || probe_type_table[type].checked) | |
907 | return ret; | |
908 | ||
909 | if (asprintf(&buf, "%s/README", tracing_path) < 0) | |
910 | return ret; | |
911 | ||
912 | fp = fopen(buf, "r"); | |
913 | if (!fp) | |
914 | goto end; | |
915 | ||
916 | zfree(&buf); | |
917 | while (getline(&buf, &len, fp) > 0 && !ret) { | |
918 | if (!target_line) { | |
919 | target_line = !!strstr(buf, " type: "); | |
920 | if (!target_line) | |
921 | continue; | |
922 | } else if (strstr(buf, "\t ") != buf) | |
923 | break; | |
924 | ret = strglobmatch(buf, probe_type_table[type].pattern); | |
925 | } | |
926 | /* Cache the result */ | |
927 | probe_type_table[type].checked = true; | |
928 | probe_type_table[type].avail = ret; | |
929 | ||
930 | fclose(fp); | |
931 | end: | |
932 | free(buf); | |
933 | ||
934 | return ret; | |
935 | } |