probe-event.c 40.0 KB
Newer Older
1
/*
2
 * probe-event.c : perf-probe definition to probe_events format converter
3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31
 *
 * Written by Masami Hiramatsu <mhiramat@redhat.com>
 *
 * This program is free software; you can redistribute it and/or modify
 * it under the terms of the GNU General Public License as published by
 * the Free Software Foundation; either version 2 of the License, or
 * (at your option) any later version.
 *
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU General Public License for more details.
 *
 * You should have received a copy of the GNU General Public License
 * along with this program; if not, write to the Free Software
 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA 02111-1307, USA.
 *
 */

#define _GNU_SOURCE
#include <sys/utsname.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <errno.h>
#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
32 33
#include <stdarg.h>
#include <limits.h>
34 35

#undef _GNU_SOURCE
36
#include "util.h"
37
#include "event.h"
38
#include "string.h"
39
#include "strlist.h"
40
#include "debug.h"
41
#include "cache.h"
42
#include "color.h"
43 44
#include "symbol.h"
#include "thread.h"
45
#include "debugfs.h"
46
#include "trace-event.h"	/* For __unused */
47
#include "probe-event.h"
48
#include "probe-finder.h"
49 50 51 52 53

#define MAX_CMDLEN 256
#define MAX_PROBE_ARGS 128
#define PERFPROBE_GROUP "probe"

54 55
bool probe_event_dry_run;	/* Dry run flag */

56
#define semantic_error(msg ...) pr_err("Semantic error :" msg)
57

58
/* If there is no space to write, returns -E2BIG. */
59 60 61
static int e_snprintf(char *str, size_t size, const char *format, ...)
	__attribute__((format(printf, 3, 4)));

62 63 64 65 66 67 68 69 70 71 72 73
static int e_snprintf(char *str, size_t size, const char *format, ...)
{
	int ret;
	va_list ap;
	va_start(ap, format);
	ret = vsnprintf(str, size, format, ap);
	va_end(ap);
	if (ret >= (int)size)
		ret = -E2BIG;
	return ret;
}

74
static char *synthesize_perf_probe_point(struct perf_probe_point *pp);
75
static struct machine machine;
76

77
/* Initialize symbol maps and path of vmlinux */
78
static int init_vmlinux(void)
79
{
80
	struct dso *kernel;
81 82
	int ret;

83 84 85 86 87
	symbol_conf.sort_by_name = true;
	if (symbol_conf.vmlinux_name == NULL)
		symbol_conf.try_vmlinux_path = true;
	else
		pr_debug("Use vmlinux: %s\n", symbol_conf.vmlinux_name);
88 89 90 91 92
	ret = symbol__init();
	if (ret < 0) {
		pr_debug("Failed to init symbol map.\n");
		goto out;
	}
93

94 95 96 97
	ret = machine__init(&machine, "/", 0);
	if (ret < 0)
		goto out;

98 99 100 101
	kernel = dso__new_kernel(symbol_conf.vmlinux_name);
	if (kernel == NULL)
		die("Failed to create kernel dso.");

102
	ret = __machine__create_kernel_maps(&machine, kernel);
103 104 105 106 107 108 109
	if (ret < 0)
		pr_debug("Failed to create kernel maps.\n");

out:
	if (ret < 0)
		pr_warning("Failed to init vmlinux path.\n");
	return ret;
110 111
}

112
#ifdef DWARF_SUPPORT
113 114
static int open_vmlinux(void)
{
115
	if (map__load(machine.vmlinux_maps[MAP__FUNCTION], NULL) < 0) {
116 117 118
		pr_debug("Failed to load kernel map.\n");
		return -EINVAL;
	}
119 120
	pr_debug("Try to open %s\n", machine.vmlinux_maps[MAP__FUNCTION]->dso->long_name);
	return open(machine.vmlinux_maps[MAP__FUNCTION]->dso->long_name, O_RDONLY);
121
}
122

123 124 125 126 127
/*
 * Convert trace point to probe point with debuginfo
 * Currently only handles kprobes.
 */
static int kprobe_convert_to_perf_probe(struct probe_trace_point *tp,
128
				       struct perf_probe_point *pp)
129 130
{
	struct symbol *sym;
131
	int fd, ret = -ENOENT;
132

133
	sym = map__find_symbol_by_name(machine.vmlinux_maps[MAP__FUNCTION],
134 135 136
				       tp->symbol, NULL);
	if (sym) {
		fd = open_vmlinux();
137 138 139 140 141
		if (fd >= 0) {
			ret = find_perf_probe_point(fd,
						 sym->start + tp->offset, pp);
			close(fd);
		}
142 143
	}
	if (ret <= 0) {
144 145
		pr_debug("Failed to find corresponding probes from "
			 "debuginfo. Use kprobe event information.\n");
146 147 148
		pp->function = strdup(tp->symbol);
		if (pp->function == NULL)
			return -ENOMEM;
149 150 151
		pp->offset = tp->offset;
	}
	pp->retprobe = tp->retprobe;
152 153

	return 0;
154 155 156
}

/* Try to find perf_probe_event with debuginfo */
157 158
static int try_to_find_probe_trace_events(struct perf_probe_event *pev,
					   struct probe_trace_event **tevs,
159
					   int max_tevs)
160 161 162 163 164 165
{
	bool need_dwarf = perf_probe_event_need_dwarf(pev);
	int fd, ntevs;

	fd = open_vmlinux();
	if (fd < 0) {
166 167 168 169
		if (need_dwarf) {
			pr_warning("Failed to open debuginfo file.\n");
			return fd;
		}
170 171 172 173 174
		pr_debug("Could not open vmlinux. Try to use symbols.\n");
		return 0;
	}

	/* Searching trace events corresponding to probe event */
175
	ntevs = find_probe_trace_events(fd, pev, tevs, max_tevs);
176 177
	close(fd);

178
	if (ntevs > 0) {	/* Succeeded to find trace events */
179
		pr_debug("find %d probe_trace_events.\n", ntevs);
180
		return ntevs;
181
	}
182

183 184 185 186 187 188
	if (ntevs == 0)	{	/* No error but failed to find probe point. */
		pr_warning("Probe point '%s' not found.\n",
			   synthesize_perf_probe_point(&pev->point));
		return -ENOENT;
	}
	/* Error path : ntevs < 0 */
189 190 191 192 193 194 195 196
	pr_debug("An error occurred in debuginfo analysis (%d).\n", ntevs);
	if (ntevs == -EBADF) {
		pr_warning("Warning: No dwarf info found in the vmlinux - "
			"please rebuild kernel with CONFIG_DEBUG_INFO=y.\n");
		if (!need_dwarf) {
			pr_debug("Trying to use symbols.\nn");
			return 0;
		}
197
	}
198
	return ntevs;
199 200
}

201 202 203 204 205 206
/*
 * Find a src file from a DWARF tag path. Prepend optional source path prefix
 * and chop off leading directories that do not exist. Result is passed back as
 * a newly allocated path on success.
 * Return 0 if file was found and readable, -errno otherwise.
 */
207 208
static int get_real_path(const char *raw_path, const char *comp_dir,
			 char **new_path)
209
{
210 211 212 213 214 215 216 217 218 219 220 221 222
	const char *prefix = symbol_conf.source_prefix;

	if (!prefix) {
		if (raw_path[0] != '/' && comp_dir)
			/* If not an absolute path, try to use comp_dir */
			prefix = comp_dir;
		else {
			if (access(raw_path, R_OK) == 0) {
				*new_path = strdup(raw_path);
				return 0;
			} else
				return -errno;
		}
223 224
	}

225
	*new_path = malloc((strlen(prefix) + strlen(raw_path) + 2));
226 227 228 229
	if (!*new_path)
		return -ENOMEM;

	for (;;) {
230
		sprintf(*new_path, "%s/%s", prefix, raw_path);
231 232 233 234

		if (access(*new_path, R_OK) == 0)
			return 0;

235 236 237 238
		if (!symbol_conf.source_prefix)
			/* In case of searching comp_dir, don't retry */
			return -errno;

239 240 241 242 243 244 245 246 247 248 249 250 251 252 253 254 255 256 257 258 259
		switch (errno) {
		case ENAMETOOLONG:
		case ENOENT:
		case EROFS:
		case EFAULT:
			raw_path = strchr(++raw_path, '/');
			if (!raw_path) {
				free(*new_path);
				*new_path = NULL;
				return -ENOENT;
			}
			continue;

		default:
			free(*new_path);
			*new_path = NULL;
			return -errno;
		}
	}
}

260 261 262
#define LINEBUF_SIZE 256
#define NR_ADDITIONAL_LINES 2

263
static int show_one_line(FILE *fp, int l, bool skip, bool show_num)
264 265 266 267 268 269 270 271
{
	char buf[LINEBUF_SIZE];
	const char *color = PERF_COLOR_BLUE;

	if (fgets(buf, LINEBUF_SIZE, fp) == NULL)
		goto error;
	if (!skip) {
		if (show_num)
272
			fprintf(stdout, "%7d  %s", l, buf);
273 274 275 276 277 278 279 280 281 282 283 284 285 286 287
		else
			color_fprintf(stdout, color, "         %s", buf);
	}

	while (strlen(buf) == LINEBUF_SIZE - 1 &&
	       buf[LINEBUF_SIZE - 2] != '\n') {
		if (fgets(buf, LINEBUF_SIZE, fp) == NULL)
			goto error;
		if (!skip) {
			if (show_num)
				fprintf(stdout, "%s", buf);
			else
				color_fprintf(stdout, color, "%s", buf);
		}
	}
288 289

	return 0;
290 291
error:
	if (feof(fp))
292
		pr_warning("Source file is shorter than expected.\n");
293
	else
294 295 296
		pr_warning("File read error: %s\n", strerror(errno));

	return -1;
297 298 299 300 301 302
}

/*
 * Show line-range always requires debuginfo to find source file and
 * line number.
 */
303
int show_line_range(struct line_range *lr)
304
{
305
	int l = 1;
306 307 308
	struct line_node *ln;
	FILE *fp;
	int fd, ret;
309
	char *tmp;
310 311

	/* Search a line range */
312 313 314 315
	ret = init_vmlinux();
	if (ret < 0)
		return ret;

316
	fd = open_vmlinux();
317 318 319 320 321
	if (fd < 0) {
		pr_warning("Failed to open debuginfo file.\n");
		return fd;
	}

322 323
	ret = find_line_range(fd, lr);
	close(fd);
324 325 326 327 328 329 330
	if (ret == 0) {
		pr_warning("Specified source line is not found.\n");
		return -ENOENT;
	} else if (ret < 0) {
		pr_warning("Debuginfo analysis failed. (%d)\n", ret);
		return ret;
	}
331

332 333
	/* Convert source file path */
	tmp = lr->path;
334
	ret = get_real_path(tmp, lr->comp_dir, &lr->path);
335 336 337 338 339 340
	free(tmp);	/* Free old path */
	if (ret < 0) {
		pr_warning("Failed to find source file. (%d)\n", ret);
		return ret;
	}

341 342 343 344 345 346 347 348 349
	setup_pager();

	if (lr->function)
		fprintf(stdout, "<%s:%d>\n", lr->function,
			lr->start - lr->offset);
	else
		fprintf(stdout, "<%s:%d>\n", lr->file, lr->start);

	fp = fopen(lr->path, "r");
350 351 352 353 354
	if (fp == NULL) {
		pr_warning("Failed to open %s: %s\n", lr->path,
			   strerror(errno));
		return -errno;
	}
355
	/* Skip to starting line number */
356 357 358 359
	while (l < lr->start && ret >= 0)
		ret = show_one_line(fp, l++, true, false);
	if (ret < 0)
		goto end;
360 361

	list_for_each_entry(ln, &lr->line_list, list) {
362 363 364 365 366 367 368 369
		while (ln->line > l && ret >= 0)
			ret = show_one_line(fp, (l++) - lr->offset,
					    false, false);
		if (ret >= 0)
			ret = show_one_line(fp, (l++) - lr->offset,
					    false, true);
		if (ret < 0)
			goto end;
370 371 372 373
	}

	if (lr->end == INT_MAX)
		lr->end = l + NR_ADDITIONAL_LINES;
374
	while (l <= lr->end && !feof(fp) && ret >= 0)
375 376
		ret = show_one_line(fp, (l++) - lr->offset, false, false);
end:
377
	fclose(fp);
378
	return ret;
379 380
}

381
static int show_available_vars_at(int fd, struct perf_probe_event *pev,
382
				  int max_vls, bool externs)
383 384 385 386 387 388 389 390 391 392 393
{
	char *buf;
	int ret, i;
	struct str_node *node;
	struct variable_list *vls = NULL, *vl;

	buf = synthesize_perf_probe_point(&pev->point);
	if (!buf)
		return -EINVAL;
	pr_debug("Searching variables at %s\n", buf);

394
	ret = find_available_vars_at(fd, pev, &vls, max_vls, externs);
395 396 397 398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423
	if (ret > 0) {
		/* Some variables were found */
		fprintf(stdout, "Available variables at %s\n", buf);
		for (i = 0; i < ret; i++) {
			vl = &vls[i];
			/*
			 * A probe point might be converted to
			 * several trace points.
			 */
			fprintf(stdout, "\t@<%s+%lu>\n", vl->point.symbol,
				vl->point.offset);
			free(vl->point.symbol);
			if (vl->vars) {
				strlist__for_each(node, vl->vars)
					fprintf(stdout, "\t\t%s\n", node->s);
				strlist__delete(vl->vars);
			} else
				fprintf(stdout, "(No variables)\n");
		}
		free(vls);
	} else
		pr_err("Failed to find variables at %s (%d)\n", buf, ret);

	free(buf);
	return ret;
}

/* Show available variables on given probe point */
int show_available_vars(struct perf_probe_event *pevs, int npevs,
424
			int max_vls, bool externs)
425 426 427 428 429 430 431 432 433 434 435 436 437 438 439 440
{
	int i, fd, ret = 0;

	ret = init_vmlinux();
	if (ret < 0)
		return ret;

	fd = open_vmlinux();
	if (fd < 0) {
		pr_warning("Failed to open debuginfo file.\n");
		return fd;
	}

	setup_pager();

	for (i = 0; i < npevs && ret >= 0; i++)
441
		ret = show_available_vars_at(fd, &pevs[i], max_vls, externs);
442 443 444 445 446

	close(fd);
	return ret;
}

447 448
#else	/* !DWARF_SUPPORT */

449 450
static int kprobe_convert_to_perf_probe(struct probe_trace_point *tp,
				       struct perf_probe_point *pp)
451
{
452 453 454
	pp->function = strdup(tp->symbol);
	if (pp->function == NULL)
		return -ENOMEM;
455 456
	pp->offset = tp->offset;
	pp->retprobe = tp->retprobe;
457 458

	return 0;
459 460
}

461 462
static int try_to_find_probe_trace_events(struct perf_probe_event *pev,
				struct probe_trace_event **tevs __unused,
463
				int max_tevs __unused)
464
{
465 466 467 468
	if (perf_probe_event_need_dwarf(pev)) {
		pr_warning("Debuginfo-analysis is not supported.\n");
		return -ENOSYS;
	}
469 470 471
	return 0;
}

472
int show_line_range(struct line_range *lr __unused)
473
{
474 475
	pr_warning("Debuginfo-analysis is not supported.\n");
	return -ENOSYS;
476 477
}

478 479 480 481 482 483
int show_available_vars(struct perf_probe_event *pevs __unused,
			int npevs __unused, int max_probe_points __unused)
{
	pr_warning("Debuginfo-analysis is not supported.\n");
	return -ENOSYS;
}
484 485
#endif

486
int parse_line_range_desc(const char *arg, struct line_range *lr)
487 488 489 490 491 492 493 494 495 496
{
	const char *ptr;
	char *tmp;
	/*
	 * <Syntax>
	 * SRC:SLN[+NUM|-ELN]
	 * FUNC[:SLN[+NUM|-ELN]]
	 */
	ptr = strchr(arg, ':');
	if (ptr) {
497
		lr->start = (int)strtoul(ptr + 1, &tmp, 0);
498
		if (*tmp == '+') {
499
			lr->end = lr->start + (int)strtoul(tmp + 1, &tmp, 0);
500 501 502 503 504 505 506
			lr->end--;	/*
					 * Adjust the number of lines here.
					 * If the number of lines == 1, the
					 * the end of line should be equal to
					 * the start of line.
					 */
		} else if (*tmp == '-')
507
			lr->end = (int)strtoul(tmp + 1, &tmp, 0);
508
		else
509 510 511
			lr->end = INT_MAX;
		pr_debug("Line range is %d to %d\n", lr->start, lr->end);
		if (lr->start > lr->end) {
512
			semantic_error("Start line must be smaller"
513 514 515 516 517
				       " than end line.\n");
			return -EINVAL;
		}
		if (*tmp != '\0') {
			semantic_error("Tailing with invalid character '%d'.\n",
518
				       *tmp);
519 520
			return -EINVAL;
		}
521
		tmp = strndup(arg, (ptr - arg));
522
	} else {
523
		tmp = strdup(arg);
524 525
		lr->end = INT_MAX;
	}
526 527 528

	if (tmp == NULL)
		return -ENOMEM;
529 530 531 532 533

	if (strchr(tmp, '.'))
		lr->file = tmp;
	else
		lr->function = tmp;
534 535

	return 0;
536 537
}

538 539 540 541 542 543 544 545 546 547 548 549
/* Check the name is good for event/group */
static bool check_event_name(const char *name)
{
	if (!isalpha(*name) && *name != '_')
		return false;
	while (*++name != '\0') {
		if (!isalpha(*name) && !isdigit(*name) && *name != '_')
			return false;
	}
	return true;
}

550
/* Parse probepoint definition. */
551
static int parse_perf_probe_point(char *arg, struct perf_probe_event *pev)
552
{
553
	struct perf_probe_point *pp = &pev->point;
554 555 556 557
	char *ptr, *tmp;
	char c, nc = 0;
	/*
	 * <Syntax>
558 559
	 * perf probe [EVENT=]SRC[:LN|;PTN]
	 * perf probe [EVENT=]FUNC[@SRC][+OFFS|%return|:LN|;PAT]
560 561
	 *
	 * TODO:Group name support
562 563
	 */

564 565
	ptr = strpbrk(arg, ";=@+%");
	if (ptr && *ptr == '=') {	/* Event name */
566 567
		*ptr = '\0';
		tmp = ptr + 1;
568 569 570 571 572
		if (strchr(arg, ':')) {
			semantic_error("Group name is not supported yet.\n");
			return -ENOTSUP;
		}
		if (!check_event_name(arg)) {
573
			semantic_error("%s is bad for event name -it must "
574 575 576
				       "follow C symbol-naming rule.\n", arg);
			return -EINVAL;
		}
577 578 579
		pev->event = strdup(arg);
		if (pev->event == NULL)
			return -ENOMEM;
580
		pev->group = NULL;
581 582 583
		arg = tmp;
	}

584
	ptr = strpbrk(arg, ";:+@%");
585 586 587 588 589
	if (ptr) {
		nc = *ptr;
		*ptr++ = '\0';
	}

590 591 592 593
	tmp = strdup(arg);
	if (tmp == NULL)
		return -ENOMEM;

594
	/* Check arg is function or file and copy it */
595 596
	if (strchr(tmp, '.'))	/* File */
		pp->file = tmp;
597
	else			/* Function */
598
		pp->function = tmp;
599 600 601 602 603

	/* Parse other options */
	while (ptr) {
		arg = ptr;
		c = nc;
604
		if (c == ';') {	/* Lazy pattern must be the last part */
605 606 607
			pp->lazy_line = strdup(arg);
			if (pp->lazy_line == NULL)
				return -ENOMEM;
608 609 610
			break;
		}
		ptr = strpbrk(arg, ";:+@%");
611 612 613 614 615 616 617
		if (ptr) {
			nc = *ptr;
			*ptr++ = '\0';
		}
		switch (c) {
		case ':':	/* Line number */
			pp->line = strtoul(arg, &tmp, 0);
618
			if (*tmp != '\0') {
619
				semantic_error("There is non-digit char"
620 621 622
					       " in line number.\n");
				return -EINVAL;
			}
623 624 625
			break;
		case '+':	/* Byte offset from a symbol */
			pp->offset = strtoul(arg, &tmp, 0);
626
			if (*tmp != '\0') {
627
				semantic_error("There is non-digit character"
628 629 630
						" in offset.\n");
				return -EINVAL;
			}
631 632
			break;
		case '@':	/* File name */
633 634 635 636
			if (pp->file) {
				semantic_error("SRC@SRC is not allowed.\n");
				return -EINVAL;
			}
637 638 639
			pp->file = strdup(arg);
			if (pp->file == NULL)
				return -ENOMEM;
640 641 642 643
			break;
		case '%':	/* Probe places */
			if (strcmp(arg, "return") == 0) {
				pp->retprobe = 1;
644 645 646 647
			} else {	/* Others not supported yet */
				semantic_error("%%%s is not supported.\n", arg);
				return -ENOTSUP;
			}
648
			break;
649 650 651 652
		default:	/* Buggy case */
			pr_err("This program has a bug at %s:%d.\n",
				__FILE__, __LINE__);
			return -ENOTSUP;
653 654 655 656 657
			break;
		}
	}

	/* Exclusion check */
658
	if (pp->lazy_line && pp->line) {
659
		semantic_error("Lazy pattern can't be used with line number.");
660 661
		return -EINVAL;
	}
662

663
	if (pp->lazy_line && pp->offset) {
664
		semantic_error("Lazy pattern can't be used with offset.");
665 666
		return -EINVAL;
	}
667

668
	if (pp->line && pp->offset) {
669
		semantic_error("Offset can't be used with line number.");
670 671
		return -EINVAL;
	}
672

673
	if (!pp->line && !pp->lazy_line && pp->file && !pp->function) {
674 675
		semantic_error("File always requires line number or "
			       "lazy pattern.");
676 677
		return -EINVAL;
	}
678

679
	if (pp->offset && !pp->function) {
680
		semantic_error("Offset requires an entry function.");
681 682
		return -EINVAL;
	}
683

684
	if (pp->retprobe && !pp->function) {
685
		semantic_error("Return probe requires an entry function.");
686 687
		return -EINVAL;
	}
688

689
	if ((pp->offset || pp->line || pp->lazy_line) && pp->retprobe) {
690 691
		semantic_error("Offset/Line/Lazy pattern can't be used with "
			       "return probe.");
692 693
		return -EINVAL;
	}
694

695
	pr_debug("symbol:%s file:%s line:%d offset:%lu return:%d lazy:%s\n",
696 697
		 pp->function, pp->file, pp->line, pp->offset, pp->retprobe,
		 pp->lazy_line);
698
	return 0;
699 700
}

701
/* Parse perf-probe event argument */
702
static int parse_perf_probe_arg(char *str, struct perf_probe_arg *arg)
703
{
704
	char *tmp, *goodname;
705 706 707 708
	struct perf_probe_arg_field **fieldp;

	pr_debug("parsing arg: %s into ", str);

709 710
	tmp = strchr(str, '=');
	if (tmp) {
711 712 713
		arg->name = strndup(str, tmp - str);
		if (arg->name == NULL)
			return -ENOMEM;
714
		pr_debug("name:%s ", arg->name);
715 716 717
		str = tmp + 1;
	}

718 719 720
	tmp = strchr(str, ':');
	if (tmp) {	/* Type setting */
		*tmp = '\0';
721 722 723
		arg->type = strdup(tmp + 1);
		if (arg->type == NULL)
			return -ENOMEM;
724 725 726
		pr_debug("type:%s ", arg->type);
	}

727
	tmp = strpbrk(str, "-.[");
728 729
	if (!is_c_varname(str) || !tmp) {
		/* A variable, register, symbol or special value */
730 731 732
		arg->var = strdup(str);
		if (arg->var == NULL)
			return -ENOMEM;
733
		pr_debug("%s\n", arg->var);
734
		return 0;
735 736
	}

737
	/* Structure fields or array element */
738 739 740
	arg->var = strndup(str, tmp - str);
	if (arg->var == NULL)
		return -ENOMEM;
741
	goodname = arg->var;
742
	pr_debug("%s, ", arg->var);
743 744 745
	fieldp = &arg->field;

	do {
746 747 748
		*fieldp = zalloc(sizeof(struct perf_probe_arg_field));
		if (*fieldp == NULL)
			return -ENOMEM;
749 750 751
		if (*tmp == '[') {	/* Array */
			str = tmp;
			(*fieldp)->index = strtol(str + 1, &tmp, 0);
752
			(*fieldp)->ref = true;
753 754 755 756 757 758 759 760 761 762 763 764 765 766 767 768 769 770 771 772 773
			if (*tmp != ']' || tmp == str + 1) {
				semantic_error("Array index must be a"
						" number.\n");
				return -EINVAL;
			}
			tmp++;
			if (*tmp == '\0')
				tmp = NULL;
		} else {		/* Structure */
			if (*tmp == '.') {
				str = tmp + 1;
				(*fieldp)->ref = false;
			} else if (tmp[1] == '>') {
				str = tmp + 2;
				(*fieldp)->ref = true;
			} else {
				semantic_error("Argument parse error: %s\n",
					       str);
				return -EINVAL;
			}
			tmp = strpbrk(str, "-.[");
774
		}
775
		if (tmp) {
776 777 778
			(*fieldp)->name = strndup(str, tmp - str);
			if ((*fieldp)->name == NULL)
				return -ENOMEM;
779 780
			if (*str != '[')
				goodname = (*fieldp)->name;
781 782 783 784
			pr_debug("%s(%d), ", (*fieldp)->name, (*fieldp)->ref);
			fieldp = &(*fieldp)->next;
		}
	} while (tmp);
785 786 787
	(*fieldp)->name = strdup(str);
	if ((*fieldp)->name == NULL)
		return -ENOMEM;
788 789
	if (*str != '[')
		goodname = (*fieldp)->name;
790
	pr_debug("%s(%d)\n", (*fieldp)->name, (*fieldp)->ref);
791

792
	/* If no name is specified, set the last field name (not array index)*/
793
	if (!arg->name) {
794
		arg->name = strdup(goodname);
795 796 797
		if (arg->name == NULL)
			return -ENOMEM;
	}
798
	return 0;
799 800
}

801
/* Parse perf-probe event command */
802
int parse_perf_probe_command(const char *cmd, struct perf_probe_event *pev)
803
{
804
	char **argv;
805
	int argc, i, ret = 0;
806

807
	argv = argv_split(cmd, &argc);
808 809 810 811 812 813 814 815 816
	if (!argv) {
		pr_debug("Failed to split arguments.\n");
		return -ENOMEM;
	}
	if (argc - 1 > MAX_PROBE_ARGS) {
		semantic_error("Too many probe arguments (%d).\n", argc - 1);
		ret = -ERANGE;
		goto out;
	}
817
	/* Parse probe point */
818 819 820
	ret = parse_perf_probe_point(argv[0], pev);
	if (ret < 0)
		goto out;
821

822
	/* Copy arguments and ensure return probe has no C argument */
823
	pev->nargs = argc - 1;
824 825 826 827 828
	pev->args = zalloc(sizeof(struct perf_probe_arg) * pev->nargs);
	if (pev->args == NULL) {
		ret = -ENOMEM;
		goto out;
	}
829 830 831 832
	for (i = 0; i < pev->nargs && ret >= 0; i++) {
		ret = parse_perf_probe_arg(argv[i + 1], &pev->args[i]);
		if (ret >= 0 &&
		    is_c_varname(pev->args[i].var) && pev->point.retprobe) {
833
			semantic_error("You can't specify local variable for"
834 835 836
				       " kretprobe.\n");
			ret = -EINVAL;
		}
837
	}
838
out:
839
	argv_free(argv);
840 841

	return ret;
842 843
}

844 845 846 847 848 849 850 851 852
/* Return true if this perf_probe_event requires debuginfo */
bool perf_probe_event_need_dwarf(struct perf_probe_event *pev)
{
	int i;

	if (pev->point.file || pev->point.line || pev->point.lazy_line)
		return true;

	for (i = 0; i < pev->nargs; i++)
853
		if (is_c_varname(pev->args[i].var))
854 855 856 857 858
			return true;

	return false;
}

859 860 861
/* Parse probe_events event into struct probe_point */
static int parse_probe_trace_command(const char *cmd,
					struct probe_trace_event *tev)
862
{
863
	struct probe_trace_point *tp = &tev->point;
864 865 866 867 868
	char pr;
	char *p;
	int ret, i, argc;
	char **argv;

869
	pr_debug("Parsing probe_events: %s\n", cmd);
870
	argv = argv_split(cmd, &argc);
871 872 873 874 875 876 877 878 879
	if (!argv) {
		pr_debug("Failed to split arguments.\n");
		return -ENOMEM;
	}
	if (argc < 2) {
		semantic_error("Too few probe arguments.\n");
		ret = -ERANGE;
		goto out;
	}
880 881

	/* Scan event and group name. */
882
	ret = sscanf(argv[0], "%c:%a[^/ \t]/%a[^ \t]",
883 884
		     &pr, (float *)(void *)&tev->group,
		     (float *)(void *)&tev->event);
885 886 887 888 889
	if (ret != 3) {
		semantic_error("Failed to parse event name: %s\n", argv[0]);
		ret = -EINVAL;
		goto out;
	}
890
	pr_debug("Group:%s Event:%s probe:%c\n", tev->group, tev->event, pr);
891

892
	tp->retprobe = (pr == 'r');
893 894

	/* Scan function name and offset */
895 896
	ret = sscanf(argv[1], "%a[^+]+%lu", (float *)(void *)&tp->symbol,
		     &tp->offset);
897
	if (ret == 1)
898
		tp->offset = 0;
899

900
	tev->nargs = argc - 2;
901
	tev->args = zalloc(sizeof(struct probe_trace_arg) * tev->nargs);
902 903 904 905
	if (tev->args == NULL) {
		ret = -ENOMEM;
		goto out;
	}
906
	for (i = 0; i < tev->nargs; i++) {
907 908
		p = strchr(argv[i + 2], '=');
		if (p)	/* We don't need which register is assigned. */
909 910 911
			*p++ = '\0';
		else
			p = argv[i + 2];
912
		tev->args[i].name = strdup(argv[i + 2]);
913
		/* TODO: parse regs and offset */
914 915 916 917 918
		tev->args[i].value = strdup(p);
		if (tev->args[i].name == NULL || tev->args[i].value == NULL) {
			ret = -ENOMEM;
			goto out;
		}
919
	}
920 921
	ret = 0;
out:
922
	argv_free(argv);
923
	return ret;
924 925
}

926 927 928 929 930 931 932
/* Compose only probe arg */
int synthesize_perf_probe_arg(struct perf_probe_arg *pa, char *buf, size_t len)
{
	struct perf_probe_arg_field *field = pa->field;
	int ret;
	char *tmp = buf;

933 934 935 936
	if (pa->name && pa->var)
		ret = e_snprintf(tmp, len, "%s=%s", pa->name, pa->var);
	else
		ret = e_snprintf(tmp, len, "%s", pa->name ? pa->name : pa->var);
937 938 939 940 941 942
	if (ret <= 0)
		goto error;
	tmp += ret;
	len -= ret;

	while (field) {
943 944 945 946 947
		if (field->name[0] == '[')
			ret = e_snprintf(tmp, len, "%s", field->name);
		else
			ret = e_snprintf(tmp, len, "%s%s",
					 field->ref ? "->" : ".", field->name);
948 949 950 951 952 953
		if (ret <= 0)
			goto error;
		tmp += ret;
		len -= ret;
		field = field->next;
	}
954 955 956 957 958 959 960 961 962

	if (pa->type) {
		ret = e_snprintf(tmp, len, ":%s", pa->type);
		if (ret <= 0)
			goto error;
		tmp += ret;
		len -= ret;
	}

963 964
	return tmp - buf;
error:
965 966 967
	pr_debug("Failed to synthesize perf probe argument: %s",
		 strerror(-ret));
	return ret;
968 969
}

970 971
/* Compose only probe point (not argument) */
static char *synthesize_perf_probe_point(struct perf_probe_point *pp)
972
{
973 974 975
	char *buf, *tmp;
	char offs[32] = "", line[32] = "", file[32] = "";
	int ret, len;
976

977 978 979 980 981
	buf = zalloc(MAX_CMDLEN);
	if (buf == NULL) {
		ret = -ENOMEM;
		goto error;
	}
982
	if (pp->offset) {
983
		ret = e_snprintf(offs, 32, "+%lu", pp->offset);
984 985 986 987
		if (ret <= 0)
			goto error;
	}
	if (pp->line) {
988 989 990 991 992
		ret = e_snprintf(line, 32, ":%d", pp->line);
		if (ret <= 0)
			goto error;
	}
	if (pp->file) {
993
		len = strlen(pp->file) - 31;
994 995 996 997
		if (len < 0)
			len = 0;
		tmp = strchr(pp->file + len, '/');
		if (!tmp)
998
			tmp = pp->file + len;
999
		ret = e_snprintf(file, 32, "@%s", tmp + 1);
1000 1001 1002 1003 1004
		if (ret <= 0)
			goto error;
	}

	if (pp->function)
1005 1006 1007
		ret = e_snprintf(buf, MAX_CMDLEN, "%s%s%s%s%s", pp->function,
				 offs, pp->retprobe ? "%return" : "", line,
				 file);
1008
	else
1009
		ret = e_snprintf(buf, MAX_CMDLEN, "%s%s", file, line);
1010 1011 1012 1013
	if (ret <= 0)
		goto error;

	return buf;
1014
error:
1015 1016
	pr_debug("Failed to synthesize perf probe point: %s",
		 strerror(-ret));
1017 1018
	if (buf)
		free(buf);
1019
	return NULL;
1020 1021
}

1022 1023
#if 0
char *synthesize_perf_probe_command(struct perf_probe_event *pev)
1024 1025 1026 1027
{
	char *buf;
	int i, len, ret;

1028 1029 1030
	buf = synthesize_perf_probe_point(&pev->point);
	if (!buf)
		return NULL;
1031

1032 1033
	len = strlen(buf);
	for (i = 0; i < pev->nargs; i++) {
1034
		ret = e_snprintf(&buf[len], MAX_CMDLEN - len, " %s",
1035 1036 1037 1038 1039
				 pev->args[i].name);
		if (ret <= 0) {
			free(buf);
			return NULL;
		}
1040 1041 1042
		len += ret;
	}

1043 1044 1045 1046
	return buf;
}
#endif

1047
static int __synthesize_probe_trace_arg_ref(struct probe_trace_arg_ref *ref,
1048 1049 1050 1051 1052
					     char **buf, size_t *buflen,
					     int depth)
{
	int ret;
	if (ref->next) {
1053
		depth = __synthesize_probe_trace_arg_ref(ref->next, buf,
1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064 1065 1066 1067
							 buflen, depth + 1);
		if (depth < 0)
			goto out;
	}

	ret = e_snprintf(*buf, *buflen, "%+ld(", ref->offset);
	if (ret < 0)
		depth = ret;
	else {
		*buf += ret;
		*buflen -= ret;
	}
out:
	return depth;
1068 1069 1070

}

1071
static int synthesize_probe_trace_arg(struct probe_trace_arg *arg,
1072
				       char *buf, size_t buflen)
1073
{
1074
	struct probe_trace_arg_ref *ref = arg->ref;
1075 1076 1077 1078 1079 1080 1081 1082 1083 1084 1085 1086 1087
	int ret, depth = 0;
	char *tmp = buf;

	/* Argument name or separator */
	if (arg->name)
		ret = e_snprintf(buf, buflen, " %s=", arg->name);
	else
		ret = e_snprintf(buf, buflen, " ");
	if (ret < 0)
		return ret;
	buf += ret;
	buflen -= ret;

1088 1089 1090 1091
	/* Special case: @XXX */
	if (arg->value[0] == '@' && arg->ref)
			ref = ref->next;

1092
	/* Dereferencing arguments */
1093
	if (ref) {
1094
		depth = __synthesize_probe_trace_arg_ref(ref, &buf,
1095 1096 1097 1098 1099 1100
							  &buflen, 1);
		if (depth < 0)
			return depth;
	}

	/* Print argument value */
1101 1102 1103 1104 1105
	if (arg->value[0] == '@' && arg->ref)
		ret = e_snprintf(buf, buflen, "%s%+ld", arg->value,
				 arg->ref->offset);
	else
		ret = e_snprintf(buf, buflen, "%s", arg->value);
1106 1107 1108 1109 1110 1111 1112 1113 1114 1115 1116 1117 1118
	if (ret < 0)
		return ret;
	buf += ret;
	buflen -= ret;

	/* Closing */
	while (depth--) {
		ret = e_snprintf(buf, buflen, ")");
		if (ret < 0)
			return ret;
		buf += ret;
		buflen -= ret;
	}
1119 1120 1121 1122 1123 1124 1125
	/* Print argument type */
	if (arg->type) {
		ret = e_snprintf(buf, buflen, ":%s", arg->type);
		if (ret <= 0)
			return ret;
		buf += ret;
	}
1126 1127 1128 1129

	return buf - tmp;
}

1130
char *synthesize_probe_trace_command(struct probe_trace_event *tev)
1131
{
1132
	struct probe_trace_point *tp = &tev->point;
1133 1134 1135
	char *buf;
	int i, len, ret;

1136 1137 1138 1139
	buf = zalloc(MAX_CMDLEN);
	if (buf == NULL)
		return NULL;

1140 1141 1142 1143 1144
	len = e_snprintf(buf, MAX_CMDLEN, "%c:%s/%s %s+%lu",
			 tp->retprobe ? 'r' : 'p',
			 tev->group, tev->event,
			 tp->symbol, tp->offset);
	if (len <= 0)
1145 1146
		goto error;

1147
	for (i = 0; i < tev->nargs; i++) {
1148
		ret = synthesize_probe_trace_arg(&tev->args[i], buf + len,
1149
						  MAX_CMDLEN - len);
1150
		if (ret <= 0)
1151 1152 1153 1154
			goto error;
		len += ret;
	}

1155
	return buf;
1156
error:
1157 1158 1159
	free(buf);
	return NULL;
}
1160

1161
static int convert_to_perf_probe_event(struct probe_trace_event *tev,
1162
				struct perf_probe_event *pev)
1163
{
1164
	char buf[64] = "";
1165
	int i, ret;
1166

1167
	/* Convert event/group name */
1168 1169 1170 1171
	pev->event = strdup(tev->event);
	pev->group = strdup(tev->group);
	if (pev->event == NULL || pev->group == NULL)
		return -ENOMEM;
1172

1173
	/* Convert trace_point to probe_point */
1174
	ret = kprobe_convert_to_perf_probe(&tev->point, &pev->point);
1175 1176
	if (ret < 0)
		return ret;
1177

1178 1179
	/* Convert trace_arg to probe_arg */
	pev->nargs = tev->nargs;
1180 1181 1182
	pev->args = zalloc(sizeof(struct perf_probe_arg) * pev->nargs);
	if (pev->args == NULL)
		return -ENOMEM;
1183
	for (i = 0; i < tev->nargs && ret >= 0; i++) {
1184
		if (tev->args[i].name)
1185
			pev->args[i].name = strdup(tev->args[i].name);
1186
		else {
1187
			ret = synthesize_probe_trace_arg(&tev->args[i],
1188
							  buf, 64);
1189
			pev->args[i].name = strdup(buf);
1190
		}
1191 1192 1193
		if (pev->args[i].name == NULL && ret >= 0)
			ret = -ENOMEM;
	}
1194 1195 1196 1197 1198

	if (ret < 0)
		clear_perf_probe_event(pev);

	return ret;
1199 1200 1201 1202 1203
}

void clear_perf_probe_event(struct perf_probe_event *pev)
{
	struct perf_probe_point *pp = &pev->point;
1204
	struct perf_probe_arg_field *field, *next;
1205 1206 1207 1208 1209 1210 1211 1212 1213 1214 1215 1216
	int i;

	if (pev->event)
		free(pev->event);
	if (pev->group)
		free(pev->group);
	if (pp->file)
		free(pp->file);
	if (pp->function)
		free(pp->function);
	if (pp->lazy_line)
		free(pp->lazy_line);
1217
	for (i = 0; i < pev->nargs; i++) {
1218 1219
		if (pev->args[i].name)
			free(pev->args[i].name);
1220 1221
		if (pev->args[i].var)
			free(pev->args[i].var);
1222 1223
		if (pev->args[i].type)
			free(pev->args[i].type);
1224 1225 1226 1227 1228 1229 1230 1231 1232
		field = pev->args[i].field;
		while (field) {
			next = field->next;
			if (field->name)
				free(field->name);
			free(field);
			field = next;
		}
	}
1233 1234 1235 1236 1237
	if (pev->args)
		free(pev->args);
	memset(pev, 0, sizeof(*pev));
}

1238
static void clear_probe_trace_event(struct probe_trace_event *tev)
1239
{
1240
	struct probe_trace_arg_ref *ref, *next;
1241 1242 1243 1244 1245 1246 1247 1248 1249 1250 1251 1252 1253
	int i;

	if (tev->event)
		free(tev->event);
	if (tev->group)
		free(tev->group);
	if (tev->point.symbol)
		free(tev->point.symbol);
	for (i = 0; i < tev->nargs; i++) {
		if (tev->args[i].name)
			free(tev->args[i].name);
		if (tev->args[i].value)
			free(tev->args[i].value);
1254 1255
		if (tev->args[i].type)
			free(tev->args[i].type);
1256 1257 1258 1259 1260 1261 1262 1263 1264 1265
		ref = tev->args[i].ref;
		while (ref) {
			next = ref->next;
			free(ref);
			ref = next;
		}
	}
	if (tev->args)
		free(tev->args);
	memset(tev, 0, sizeof(*tev));
1266 1267
}

1268
static int open_kprobe_events(bool readwrite)
1269 1270
{
	char buf[PATH_MAX];
1271
	const char *__debugfs;
1272 1273
	int ret;

1274 1275 1276 1277 1278 1279 1280
	__debugfs = debugfs_find_mountpoint();
	if (__debugfs == NULL) {
		pr_warning("Debugfs is not mounted.\n");
		return -ENOENT;
	}

	ret = e_snprintf(buf, PATH_MAX, "%stracing/kprobe_events", __debugfs);
1281
	if (ret >= 0) {
1282
		pr_debug("Opening %s write=%d\n", buf, readwrite);
1283 1284 1285 1286 1287
		if (readwrite && !probe_event_dry_run)
			ret = open(buf, O_RDWR, O_APPEND);
		else
			ret = open(buf, O_RDONLY, 0);
	}
1288

1289 1290
	if (ret < 0) {
		if (errno == ENOENT)
1291 1292
			pr_warning("kprobe_events file does not exist - please"
				 " rebuild kernel with CONFIG_KPROBE_EVENT.\n");
1293
		else
1294 1295
			pr_warning("Failed to open kprobe_events file: %s\n",
				   strerror(errno));
1296 1297 1298 1299 1300
	}
	return ret;
}

/* Get raw string list of current kprobe_events */
1301
static struct strlist *get_probe_trace_command_rawlist(int fd)
1302 1303 1304 1305 1306 1307 1308 1309 1310 1311 1312 1313 1314 1315 1316 1317 1318 1319 1320
{
	int ret, idx;
	FILE *fp;
	char buf[MAX_CMDLEN];
	char *p;
	struct strlist *sl;

	sl = strlist__new(true, NULL);

	fp = fdopen(dup(fd), "r");
	while (!feof(fp)) {
		p = fgets(buf, MAX_CMDLEN, fp);
		if (!p)
			break;

		idx = strlen(p) - 1;
		if (p[idx] == '\n')
			p[idx] = '\0';
		ret = strlist__add(sl, buf);
1321 1322 1323 1324 1325
		if (ret < 0) {
			pr_debug("strlist__add failed: %s\n", strerror(-ret));
			strlist__delete(sl);
			return NULL;
		}
1326 1327 1328 1329 1330 1331
	}
	fclose(fp);

	return sl;
}

1332
/* Show an event */
1333
static int show_perf_probe_event(struct perf_probe_event *pev)
1334
{
1335
	int i, ret;
1336
	char buf[128];
1337
	char *place;
1338

1339 1340
	/* Synthesize only event probe point */
	place = synthesize_perf_probe_point(&pev->point);
1341 1342
	if (!place)
		return -EINVAL;
1343 1344

	ret = e_snprintf(buf, 128, "%s:%s", pev->group, pev->event);
1345
	if (ret < 0)
1346 1347
		return ret;

1348
	printf("  %-20s (on %s", buf, place);
1349

1350
	if (pev->nargs > 0) {
1351
		printf(" with");
1352
		for (i = 0; i < pev->nargs; i++) {
1353 1354 1355 1356
			ret = synthesize_perf_probe_arg(&pev->args[i],
							buf, 128);
			if (ret < 0)
				break;
1357 1358
			printf(" %s", buf);
		}
1359 1360
	}
	printf(")\n");
1361
	free(place);
1362
	return ret;
1363 1364
}

1365
/* List up current perf-probe events */
1366
int show_perf_probe_events(void)
1367
{
1368
	int fd, ret;
1369
	struct probe_trace_event tev;
1370
	struct perf_probe_event pev;
1371 1372 1373
	struct strlist *rawlist;
	struct str_node *ent;

1374
	setup_pager();
1375 1376 1377
	ret = init_vmlinux();
	if (ret < 0)
		return ret;
1378 1379 1380

	memset(&tev, 0, sizeof(tev));
	memset(&pev, 0, sizeof(pev));
1381

1382
	fd = open_kprobe_events(false);
1383 1384 1385
	if (fd < 0)
		return fd;

1386
	rawlist = get_probe_trace_command_rawlist(fd);
1387
	close(fd);
1388 1389
	if (!rawlist)
		return -ENOENT;
1390

1391
	strlist__for_each(ent, rawlist) {
1392
		ret = parse_probe_trace_command(ent->s, &tev);
1393 1394 1395 1396 1397
		if (ret >= 0) {
			ret = convert_to_perf_probe_event(&tev, &pev);
			if (ret >= 0)
				ret = show_perf_probe_event(&pev);
		}
1398
		clear_perf_probe_event(&pev);
1399
		clear_probe_trace_event(&tev);
1400 1401
		if (ret < 0)
			break;
1402 1403
	}
	strlist__delete(rawlist);
1404 1405

	return ret;
1406 1407
}

1408
/* Get current perf-probe event names */
1409
static struct strlist *get_probe_trace_event_names(int fd, bool include_group)
1410
{
1411
	char buf[128];
1412 1413
	struct strlist *sl, *rawlist;
	struct str_node *ent;
1414
	struct probe_trace_event tev;
1415
	int ret = 0;
1416

1417
	memset(&tev, 0, sizeof(tev));
1418
	rawlist = get_probe_trace_command_rawlist(fd);
1419
	sl = strlist__new(true, NULL);
1420
	strlist__for_each(ent, rawlist) {
1421
		ret = parse_probe_trace_command(ent->s, &tev);
1422 1423
		if (ret < 0)
			break;
1424
		if (include_group) {
1425 1426 1427 1428
			ret = e_snprintf(buf, 128, "%s:%s", tev.group,
					tev.event);
			if (ret >= 0)
				ret = strlist__add(sl, buf);
1429
		} else
1430
			ret = strlist__add(sl, tev.event);
1431
		clear_probe_trace_event(&tev);
1432 1433
		if (ret < 0)
			break;
1434 1435 1436
	}
	strlist__delete(rawlist);

1437 1438 1439 1440
	if (ret < 0) {
		strlist__delete(sl);
		return NULL;
	}
1441 1442 1443
	return sl;
}

1444
static int write_probe_trace_event(int fd, struct probe_trace_event *tev)
1445
{
1446
	int ret = 0;
1447
	char *buf = synthesize_probe_trace_command(tev);
1448

1449
	if (!buf) {
1450
		pr_debug("Failed to synthesize probe trace event.\n");
1451 1452 1453
		return -EINVAL;
	}

1454
	pr_debug("Writing event: %s\n", buf);
1455 1456 1457
	if (!probe_event_dry_run) {
		ret = write(fd, buf, strlen(buf));
		if (ret <= 0)
1458 1459
			pr_warning("Failed to write event: %s\n",
				   strerror(errno));
1460
	}
1461
	free(buf);
1462
	return ret;
1463 1464
}

1465 1466
static int get_new_event_name(char *buf, size_t len, const char *base,
			      struct strlist *namelist, bool allow_suffix)
1467 1468
{
	int i, ret;
1469 1470 1471

	/* Try no suffix */
	ret = e_snprintf(buf, len, "%s", base);
1472 1473 1474 1475
	if (ret < 0) {
		pr_debug("snprintf() failed: %s\n", strerror(-ret));
		return ret;
	}
1476
	if (!strlist__has_entry(namelist, buf))
1477
		return 0;
1478

1479 1480 1481
	if (!allow_suffix) {
		pr_warning("Error: event \"%s\" already exists. "
			   "(Use -f to force duplicates.)\n", base);
1482
		return -EEXIST;
1483 1484
	}

1485 1486
	/* Try to add suffix */
	for (i = 1; i < MAX_EVENT_INDEX; i++) {
1487
		ret = e_snprintf(buf, len, "%s_%d", base, i);
1488 1489 1490 1491
		if (ret < 0) {
			pr_debug("snprintf() failed: %s\n", strerror(-ret));
			return ret;
		}
1492 1493 1494
		if (!strlist__has_entry(namelist, buf))
			break;
	}
1495 1496 1497 1498 1499 1500
	if (i == MAX_EVENT_INDEX) {
		pr_warning("Too many events are on the same function.\n");
		ret = -ERANGE;
	}

	return ret;
1501 1502
}

1503 1504
static int __add_probe_trace_events(struct perf_probe_event *pev,
				     struct probe_trace_event *tevs,
1505
				     int ntevs, bool allow_suffix)
1506
{
1507
	int i, fd, ret;
1508
	struct probe_trace_event *tev = NULL;
1509 1510
	char buf[64];
	const char *event, *group;
1511
	struct strlist *namelist;
1512

1513
	fd = open_kprobe_events(true);
1514 1515
	if (fd < 0)
		return fd;
1516
	/* Get current event names */
1517
	namelist = get_probe_trace_event_names(fd, false);
1518 1519 1520 1521
	if (!namelist) {
		pr_debug("Failed to get current event list.\n");
		return -EIO;
	}
1522

1523
	ret = 0;
1524
	printf("Add new event%s\n", (ntevs > 1) ? "s:" : ":");
1525
	for (i = 0; i < ntevs; i++) {
1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537 1538 1539
		tev = &tevs[i];
		if (pev->event)
			event = pev->event;
		else
			if (pev->point.function)
				event = pev->point.function;
			else
				event = tev->point.symbol;
		if (pev->group)
			group = pev->group;
		else
			group = PERFPROBE_GROUP;

		/* Get an unused new event name */
1540 1541 1542 1543
		ret = get_new_event_name(buf, 64, event,
					 namelist, allow_suffix);
		if (ret < 0)
			break;
1544 1545
		event = buf;

1546 1547 1548 1549 1550 1551
		tev->event = strdup(event);
		tev->group = strdup(group);
		if (tev->event == NULL || tev->group == NULL) {
			ret = -ENOMEM;
			break;
		}
1552
		ret = write_probe_trace_event(fd, tev);
1553 1554
		if (ret < 0)
			break;
1555 1556 1557 1558 1559 1560 1561 1562 1563 1564 1565 1566 1567 1568 1569 1570 1571 1572 1573 1574
		/* Add added event name to namelist */
		strlist__add(namelist, event);

		/* Trick here - save current event/group */
		event = pev->event;
		group = pev->group;
		pev->event = tev->event;
		pev->group = tev->group;
		show_perf_probe_event(pev);
		/* Trick here - restore current event/group */
		pev->event = (char *)event;
		pev->group = (char *)group;

		/*
		 * Probes after the first probe which comes from same
		 * user input are always allowed to add suffix, because
		 * there might be several addresses corresponding to
		 * one code line.
		 */
		allow_suffix = true;
1575
	}
1576 1577 1578 1579 1580 1581 1582

	if (ret >= 0) {
		/* Show how to use the event. */
		printf("\nYou can now use it on all perf tools, such as:\n\n");
		printf("\tperf record -e %s:%s -aR sleep 1\n\n", tev->group,
			 tev->event);
	}
1583

1584
	strlist__delete(namelist);
1585
	close(fd);
1586
	return ret;
1587
}
1588

1589 1590
static int convert_to_probe_trace_events(struct perf_probe_event *pev,
					  struct probe_trace_event **tevs,
1591
					  int max_tevs)
1592 1593
{
	struct symbol *sym;
1594
	int ret = 0, i;
1595
	struct probe_trace_event *tev;
1596

1597
	/* Convert perf_probe_event with debuginfo */
1598
	ret = try_to_find_probe_trace_events(pev, tevs, max_tevs);
1599 1600
	if (ret != 0)
		return ret;
1601

1602
	/* Allocate trace event buffer */
1603
	tev = *tevs = zalloc(sizeof(struct probe_trace_event));
1604 1605
	if (tev == NULL)
		return -ENOMEM;
1606 1607

	/* Copy parameters */
1608 1609 1610 1611 1612
	tev->point.symbol = strdup(pev->point.function);
	if (tev->point.symbol == NULL) {
		ret = -ENOMEM;
		goto error;
	}
1613
	tev->point.offset = pev->point.offset;
1614
	tev->point.retprobe = pev->point.retprobe;
1615 1616
	tev->nargs = pev->nargs;
	if (tev->nargs) {
1617
		tev->args = zalloc(sizeof(struct probe_trace_arg)
1618 1619
				   * tev->nargs);
		if (tev->args == NULL) {
1620 1621
			ret = -ENOMEM;
			goto error;
1622
		}
1623
		for (i = 0; i < tev->nargs; i++) {
1624 1625 1626 1627 1628 1629 1630 1631 1632 1633 1634 1635 1636 1637 1638 1639 1640 1641 1642
			if (pev->args[i].name) {
				tev->args[i].name = strdup(pev->args[i].name);
				if (tev->args[i].name == NULL) {
					ret = -ENOMEM;
					goto error;
				}
			}
			tev->args[i].value = strdup(pev->args[i].var);
			if (tev->args[i].value == NULL) {
				ret = -ENOMEM;
				goto error;
			}
			if (pev->args[i].type) {
				tev->args[i].type = strdup(pev->args[i].type);
				if (tev->args[i].type == NULL) {
					ret = -ENOMEM;
					goto error;
				}
			}
1643
		}
1644 1645 1646
	}

	/* Currently just checking function name from symbol map */
1647
	sym = map__find_symbol_by_name(machine.vmlinux_maps[MAP__FUNCTION],
1648
				       tev->point.symbol, NULL);
1649 1650 1651
	if (!sym) {
		pr_warning("Kernel symbol \'%s\' not found.\n",
			   tev->point.symbol);
1652 1653 1654
		ret = -ENOENT;
		goto error;
	}
1655

1656 1657
	return 1;
error:
1658
	clear_probe_trace_event(tev);
1659 1660
	free(tev);
	*tevs = NULL;
1661
	return ret;
1662 1663 1664 1665
}

struct __event_package {
	struct perf_probe_event		*pev;
1666
	struct probe_trace_event	*tevs;
1667 1668 1669
	int				ntevs;
};

1670
int add_perf_probe_events(struct perf_probe_event *pevs, int npevs,
M
Masami Hiramatsu 已提交
1671
			  int max_tevs, bool force_add)
1672
{
1673
	int i, j, ret;
1674 1675
	struct __event_package *pkgs;

1676 1677 1678
	pkgs = zalloc(sizeof(struct __event_package) * npevs);
	if (pkgs == NULL)
		return -ENOMEM;
1679 1680

	/* Init vmlinux path */
1681
	ret = init_vmlinux();
1682 1683
	if (ret < 0) {
		free(pkgs);
1684
		return ret;
1685
	}
1686 1687 1688 1689 1690

	/* Loop 1: convert all events */
	for (i = 0; i < npevs; i++) {
		pkgs[i].pev = &pevs[i];
		/* Convert with or without debuginfo */
1691
		ret  = convert_to_probe_trace_events(pkgs[i].pev,
1692
						      &pkgs[i].tevs, max_tevs);
1693 1694 1695
		if (ret < 0)
			goto end;
		pkgs[i].ntevs = ret;
1696 1697
	}

1698
	/* Loop 2: add all events */
1699
	for (i = 0; i < npevs && ret >= 0; i++)
1700
		ret = __add_probe_trace_events(pkgs[i].pev, pkgs[i].tevs,
1701 1702
						pkgs[i].ntevs, force_add);
end:
1703 1704
	/* Loop 3: cleanup and free trace events  */
	for (i = 0; i < npevs; i++) {
1705
		for (j = 0; j < pkgs[i].ntevs; j++)
1706
			clear_probe_trace_event(&pkgs[i].tevs[j]);
1707 1708 1709
		free(pkgs[i].tevs);
	}
	free(pkgs);
1710 1711

	return ret;
1712 1713
}

1714
static int __del_trace_probe_event(int fd, struct str_node *ent)
1715 1716 1717
{
	char *p;
	char buf[128];
1718
	int ret;
1719

1720
	/* Convert from perf-probe event to trace-probe event */
1721 1722 1723 1724
	ret = e_snprintf(buf, 128, "-:%s", ent->s);
	if (ret < 0)
		goto error;

1725
	p = strchr(buf + 2, ':');
1726 1727 1728 1729 1730 1731
	if (!p) {
		pr_debug("Internal error: %s should have ':' but not.\n",
			 ent->s);
		ret = -ENOTSUP;
		goto error;
	}
1732 1733
	*p = '/';

1734 1735
	pr_debug("Writing event: %s\n", buf);
	ret = write(fd, buf, strlen(buf));
1736 1737 1738
	if (ret < 0)
		goto error;

1739
	printf("Remove event: %s\n", ent->s);
1740 1741 1742 1743
	return 0;
error:
	pr_warning("Failed to delete event: %s\n", strerror(-ret));
	return ret;
1744 1745
}

1746
static int del_trace_probe_event(int fd, const char *group,
1747
				  const char *event, struct strlist *namelist)
1748 1749
{
	char buf[128];
1750
	struct str_node *ent, *n;
1751
	int found = 0, ret = 0;
1752

1753 1754 1755 1756 1757
	ret = e_snprintf(buf, 128, "%s:%s", group, event);
	if (ret < 0) {
		pr_err("Failed to copy event.");
		return ret;
	}
1758

1759 1760 1761 1762
	if (strpbrk(buf, "*?")) { /* Glob-exp */
		strlist__for_each_safe(ent, n, namelist)
			if (strglobmatch(ent->s, buf)) {
				found++;
1763
				ret = __del_trace_probe_event(fd, ent);
1764 1765
				if (ret < 0)
					break;
1766 1767 1768 1769 1770 1771
				strlist__remove(namelist, ent);
			}
	} else {
		ent = strlist__find(namelist, buf);
		if (ent) {
			found++;
1772
			ret = __del_trace_probe_event(fd, ent);
1773 1774
			if (ret >= 0)
				strlist__remove(namelist, ent);
1775 1776
		}
	}
1777 1778 1779 1780
	if (found == 0 && ret >= 0)
		pr_info("Info: Event \"%s\" does not exist.\n", buf);

	return ret;
1781 1782
}

1783
int del_perf_probe_events(struct strlist *dellist)
1784
{
1785
	int fd, ret = 0;
1786 1787 1788 1789 1790
	const char *group, *event;
	char *p, *str;
	struct str_node *ent;
	struct strlist *namelist;

1791
	fd = open_kprobe_events(true);
1792 1793 1794
	if (fd < 0)
		return fd;

1795
	/* Get current event names */
1796
	namelist = get_probe_trace_event_names(fd, true);
1797 1798
	if (namelist == NULL)
		return -EINVAL;
1799

1800
	strlist__for_each(ent, dellist) {
1801 1802 1803 1804 1805
		str = strdup(ent->s);
		if (str == NULL) {
			ret = -ENOMEM;
			break;
		}
1806
		pr_debug("Parsing: %s\n", str);
1807 1808 1809 1810 1811 1812
		p = strchr(str, ':');
		if (p) {
			group = str;
			*p = '\0';
			event = p + 1;
		} else {
1813
			group = "*";
1814 1815
			event = str;
		}
1816
		pr_debug("Group: %s, Event: %s\n", group, event);
1817
		ret = del_trace_probe_event(fd, group, event, namelist);
1818
		free(str);
1819 1820
		if (ret < 0)
			break;
1821 1822 1823
	}
	strlist__delete(namelist);
	close(fd);
1824 1825

	return ret;
1826 1827
}