builtin-trace.c 85.7 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18
/*
 * builtin-trace.c
 *
 * Builtin 'trace' command:
 *
 * Display a continuously updated trace of any workload, CPU, specific PID,
 * system wide, etc.  Default format is loosely strace like, but any other
 * event may be specified using --event.
 *
 * Copyright (C) 2012, 2013, 2014, 2015 Red Hat Inc, Arnaldo Carvalho de Melo <acme@redhat.com>
 *
 * Initially based on the 'trace' prototype by Thomas Gleixner:
 *
 * http://lwn.net/Articles/415728/ ("Announcing a new utility: 'trace'")
 *
 * Released under the GPL v2. (and only v2, not any later version)
 */

19
#include <traceevent/event-parse.h>
20
#include <api/fs/tracing_path.h>
A
Arnaldo Carvalho de Melo 已提交
21
#include "builtin.h"
22
#include "util/color.h"
23
#include "util/debug.h"
A
Arnaldo Carvalho de Melo 已提交
24
#include "util/evlist.h"
25
#include <subcmd/exec-cmd.h>
26
#include "util/machine.h"
27
#include "util/path.h"
28
#include "util/session.h"
29
#include "util/thread.h"
30
#include <subcmd/parse-options.h>
31
#include "util/strlist.h"
32
#include "util/intlist.h"
A
Arnaldo Carvalho de Melo 已提交
33
#include "util/thread_map.h"
34
#include "util/stat.h"
35
#include "trace/beauty/beauty.h"
36
#include "trace-event.h"
37
#include "util/parse-events.h"
38
#include "util/bpf-loader.h"
39
#include "callchain.h"
40
#include "print_binary.h"
41
#include "string2.h"
42
#include "syscalltbl.h"
43
#include "rb_resort.h"
A
Arnaldo Carvalho de Melo 已提交
44

45
#include <errno.h>
46
#include <inttypes.h>
47
#include <libaudit.h> /* FIXME: Still needed for audit_errno_to_name */
A
Arnaldo Carvalho de Melo 已提交
48
#include <stdlib.h>
49
#include <string.h>
50
#include <linux/err.h>
51 52
#include <linux/filter.h>
#include <linux/audit.h>
53
#include <linux/kernel.h>
54
#include <linux/random.h>
55
#include <linux/stringify.h>
56
#include <linux/time64.h>
A
Arnaldo Carvalho de Melo 已提交
57

58 59
#include "sane_ctype.h"

60 61 62 63
#ifndef O_CLOEXEC
# define O_CLOEXEC		02000000
#endif

64 65
struct trace {
	struct perf_tool	tool;
66
	struct syscalltbl	*sctbl;
67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96
	struct {
		int		max;
		struct syscall  *table;
		struct {
			struct perf_evsel *sys_enter,
					  *sys_exit;
		}		events;
	} syscalls;
	struct record_opts	opts;
	struct perf_evlist	*evlist;
	struct machine		*host;
	struct thread		*current;
	u64			base_time;
	FILE			*output;
	unsigned long		nr_events;
	struct strlist		*ev_qualifier;
	struct {
		size_t		nr;
		int		*entries;
	}			ev_qualifier_ids;
	struct {
		size_t		nr;
		pid_t		*entries;
	}			filter_pids;
	double			duration_filter;
	double			runtime_ms;
	struct {
		u64		vfs_getname,
				proc_getname;
	} stats;
97
	unsigned int		max_stack;
98
	unsigned int		min_stack;
99 100 101 102 103 104 105 106 107 108
	bool			not_ev_qualifier;
	bool			live;
	bool			full_time;
	bool			sched;
	bool			multiple_threads;
	bool			summary;
	bool			summary_only;
	bool			show_comm;
	bool			show_tool_stats;
	bool			trace_syscalls;
109
	bool			kernel_syscallchains;
110 111 112
	bool			force;
	bool			vfs_getname;
	int			trace_pgfaults;
113
	int			open_id;
114
};
115

116 117 118 119 120 121 122 123 124 125 126
struct tp_field {
	int offset;
	union {
		u64 (*integer)(struct tp_field *field, struct perf_sample *sample);
		void *(*pointer)(struct tp_field *field, struct perf_sample *sample);
	};
};

#define TP_UINT_FIELD(bits) \
static u64 tp_field__u##bits(struct tp_field *field, struct perf_sample *sample) \
{ \
127 128 129
	u##bits value; \
	memcpy(&value, sample->raw_data + field->offset, sizeof(value)); \
	return value;  \
130 131 132 133 134 135 136 137 138 139
}

TP_UINT_FIELD(8);
TP_UINT_FIELD(16);
TP_UINT_FIELD(32);
TP_UINT_FIELD(64);

#define TP_UINT_FIELD__SWAPPED(bits) \
static u64 tp_field__swapped_u##bits(struct tp_field *field, struct perf_sample *sample) \
{ \
140 141
	u##bits value; \
	memcpy(&value, sample->raw_data + field->offset, sizeof(value)); \
142 143 144 145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160 161 162 163 164 165 166 167 168 169 170 171 172 173 174 175 176 177 178 179 180 181 182 183 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 200 201 202 203 204 205 206 207 208 209 210 211 212 213 214 215 216 217 218 219 220 221 222 223 224 225 226 227
	return bswap_##bits(value);\
}

TP_UINT_FIELD__SWAPPED(16);
TP_UINT_FIELD__SWAPPED(32);
TP_UINT_FIELD__SWAPPED(64);

static int tp_field__init_uint(struct tp_field *field,
			       struct format_field *format_field,
			       bool needs_swap)
{
	field->offset = format_field->offset;

	switch (format_field->size) {
	case 1:
		field->integer = tp_field__u8;
		break;
	case 2:
		field->integer = needs_swap ? tp_field__swapped_u16 : tp_field__u16;
		break;
	case 4:
		field->integer = needs_swap ? tp_field__swapped_u32 : tp_field__u32;
		break;
	case 8:
		field->integer = needs_swap ? tp_field__swapped_u64 : tp_field__u64;
		break;
	default:
		return -1;
	}

	return 0;
}

static void *tp_field__ptr(struct tp_field *field, struct perf_sample *sample)
{
	return sample->raw_data + field->offset;
}

static int tp_field__init_ptr(struct tp_field *field, struct format_field *format_field)
{
	field->offset = format_field->offset;
	field->pointer = tp_field__ptr;
	return 0;
}

struct syscall_tp {
	struct tp_field id;
	union {
		struct tp_field args, ret;
	};
};

static int perf_evsel__init_tp_uint_field(struct perf_evsel *evsel,
					  struct tp_field *field,
					  const char *name)
{
	struct format_field *format_field = perf_evsel__field(evsel, name);

	if (format_field == NULL)
		return -1;

	return tp_field__init_uint(field, format_field, evsel->needs_swap);
}

#define perf_evsel__init_sc_tp_uint_field(evsel, name) \
	({ struct syscall_tp *sc = evsel->priv;\
	   perf_evsel__init_tp_uint_field(evsel, &sc->name, #name); })

static int perf_evsel__init_tp_ptr_field(struct perf_evsel *evsel,
					 struct tp_field *field,
					 const char *name)
{
	struct format_field *format_field = perf_evsel__field(evsel, name);

	if (format_field == NULL)
		return -1;

	return tp_field__init_ptr(field, format_field);
}

#define perf_evsel__init_sc_tp_ptr_field(evsel, name) \
	({ struct syscall_tp *sc = evsel->priv;\
	   perf_evsel__init_tp_ptr_field(evsel, &sc->name, #name); })

static void perf_evsel__delete_priv(struct perf_evsel *evsel)
{
228
	zfree(&evsel->priv);
229 230 231
	perf_evsel__delete(evsel);
}

232 233 234 235 236 237 238 239 240 241 242 243 244 245
static int perf_evsel__init_syscall_tp(struct perf_evsel *evsel, void *handler)
{
	evsel->priv = malloc(sizeof(struct syscall_tp));
	if (evsel->priv != NULL) {
		if (perf_evsel__init_sc_tp_uint_field(evsel, id))
			goto out_delete;

		evsel->handler = handler;
		return 0;
	}

	return -ENOMEM;

out_delete:
246
	zfree(&evsel->priv);
247 248 249
	return -ENOENT;
}

250
static struct perf_evsel *perf_evsel__syscall_newtp(const char *direction, void *handler)
251
{
252
	struct perf_evsel *evsel = perf_evsel__newtp("raw_syscalls", direction);
253

254
	/* older kernel (e.g., RHEL6) use syscalls:{enter,exit} */
255
	if (IS_ERR(evsel))
256 257
		evsel = perf_evsel__newtp("syscalls", direction);

258 259 260 261 262
	if (IS_ERR(evsel))
		return NULL;

	if (perf_evsel__init_syscall_tp(evsel, handler))
		goto out_delete;
263 264 265 266 267 268 269 270 271 272 273 274 275 276 277 278

	return evsel;

out_delete:
	perf_evsel__delete_priv(evsel);
	return NULL;
}

#define perf_evsel__sc_tp_uint(evsel, name, sample) \
	({ struct syscall_tp *fields = evsel->priv; \
	   fields->name.integer(&fields->name, sample); })

#define perf_evsel__sc_tp_ptr(evsel, name, sample) \
	({ struct syscall_tp *fields = evsel->priv; \
	   fields->name.pointer(&fields->name, sample); })

279
struct strarray {
280
	int	    offset;
281 282 283 284 285 286 287 288 289
	int	    nr_entries;
	const char **entries;
};

#define DEFINE_STRARRAY(array) struct strarray strarray__##array = { \
	.nr_entries = ARRAY_SIZE(array), \
	.entries = array, \
}

290 291 292 293 294 295
#define DEFINE_STRARRAY_OFFSET(array, off) struct strarray strarray__##array = { \
	.offset	    = off, \
	.nr_entries = ARRAY_SIZE(array), \
	.entries = array, \
}

296 297 298
static size_t __syscall_arg__scnprintf_strarray(char *bf, size_t size,
						const char *intfmt,
					        struct syscall_arg *arg)
299 300
{
	struct strarray *sa = arg->parm;
301
	int idx = arg->val - sa->offset;
302 303

	if (idx < 0 || idx >= sa->nr_entries)
304
		return scnprintf(bf, size, intfmt, arg->val);
305 306 307 308

	return scnprintf(bf, size, "%s", sa->entries[idx]);
}

309 310 311 312 313 314
static size_t syscall_arg__scnprintf_strarray(char *bf, size_t size,
					      struct syscall_arg *arg)
{
	return __syscall_arg__scnprintf_strarray(bf, size, "%d", arg);
}

315 316
#define SCA_STRARRAY syscall_arg__scnprintf_strarray

317 318 319 320 321
#if defined(__i386__) || defined(__x86_64__)
/*
 * FIXME: Make this available to all arches as soon as the ioctl beautifier
 * 	  gets rewritten to support all arches.
 */
322 323 324 325 326 327 328
static size_t syscall_arg__scnprintf_strhexarray(char *bf, size_t size,
						 struct syscall_arg *arg)
{
	return __syscall_arg__scnprintf_strarray(bf, size, "%#x", arg);
}

#define SCA_STRHEXARRAY syscall_arg__scnprintf_strhexarray
329
#endif /* defined(__i386__) || defined(__x86_64__) */
330

331 332 333 334 335
static size_t syscall_arg__scnprintf_fd(char *bf, size_t size,
					struct syscall_arg *arg);

#define SCA_FD syscall_arg__scnprintf_fd

336 337 338 339
#ifndef AT_FDCWD
#define AT_FDCWD	-100
#endif

340 341 342 343 344 345 346 347 348 349 350 351 352 353 354 355 356 357
static size_t syscall_arg__scnprintf_fd_at(char *bf, size_t size,
					   struct syscall_arg *arg)
{
	int fd = arg->val;

	if (fd == AT_FDCWD)
		return scnprintf(bf, size, "CWD");

	return syscall_arg__scnprintf_fd(bf, size, arg);
}

#define SCA_FDAT syscall_arg__scnprintf_fd_at

static size_t syscall_arg__scnprintf_close_fd(char *bf, size_t size,
					      struct syscall_arg *arg);

#define SCA_CLOSE_FD syscall_arg__scnprintf_close_fd

358
static size_t syscall_arg__scnprintf_hex(char *bf, size_t size,
359
					 struct syscall_arg *arg)
360
{
361
	return scnprintf(bf, size, "%#lx", arg->val);
362 363
}

364 365
#define SCA_HEX syscall_arg__scnprintf_hex

366 367 368 369 370 371 372 373
static size_t syscall_arg__scnprintf_int(char *bf, size_t size,
					 struct syscall_arg *arg)
{
	return scnprintf(bf, size, "%d", arg->val);
}

#define SCA_INT syscall_arg__scnprintf_int

374 375 376 377 378 379
static const char *bpf_cmd[] = {
	"MAP_CREATE", "MAP_LOOKUP_ELEM", "MAP_UPDATE_ELEM", "MAP_DELETE_ELEM",
	"MAP_GET_NEXT_KEY", "PROG_LOAD",
};
static DEFINE_STRARRAY(bpf_cmd);

380 381
static const char *epoll_ctl_ops[] = { "ADD", "DEL", "MOD", };
static DEFINE_STRARRAY_OFFSET(epoll_ctl_ops, 1);
382

383 384 385
static const char *itimers[] = { "REAL", "VIRTUAL", "PROF", };
static DEFINE_STRARRAY(itimers);

386 387 388 389 390 391 392 393 394
static const char *keyctl_options[] = {
	"GET_KEYRING_ID", "JOIN_SESSION_KEYRING", "UPDATE", "REVOKE", "CHOWN",
	"SETPERM", "DESCRIBE", "CLEAR", "LINK", "UNLINK", "SEARCH", "READ",
	"INSTANTIATE", "NEGATE", "SET_REQKEY_KEYRING", "SET_TIMEOUT",
	"ASSUME_AUTHORITY", "GET_SECURITY", "SESSION_TO_PARENT", "REJECT",
	"INSTANTIATE_IOV", "INVALIDATE", "GET_PERSISTENT",
};
static DEFINE_STRARRAY(keyctl_options);

395 396 397 398 399 400 401 402 403
static const char *whences[] = { "SET", "CUR", "END",
#ifdef SEEK_DATA
"DATA",
#endif
#ifdef SEEK_HOLE
"HOLE",
#endif
};
static DEFINE_STRARRAY(whences);
404

405 406 407 408 409 410 411 412
static const char *fcntl_cmds[] = {
	"DUPFD", "GETFD", "SETFD", "GETFL", "SETFL", "GETLK", "SETLK",
	"SETLKW", "SETOWN", "GETOWN", "SETSIG", "GETSIG", "F_GETLK64",
	"F_SETLK64", "F_SETLKW64", "F_SETOWN_EX", "F_GETOWN_EX",
	"F_GETOWNER_UIDS",
};
static DEFINE_STRARRAY(fcntl_cmds);

413 414 415 416 417 418 419
static const char *rlimit_resources[] = {
	"CPU", "FSIZE", "DATA", "STACK", "CORE", "RSS", "NPROC", "NOFILE",
	"MEMLOCK", "AS", "LOCKS", "SIGPENDING", "MSGQUEUE", "NICE", "RTPRIO",
	"RTTIME",
};
static DEFINE_STRARRAY(rlimit_resources);

420 421 422
static const char *sighow[] = { "BLOCK", "UNBLOCK", "SETMASK", };
static DEFINE_STRARRAY(sighow);

423 424
static const char *clockid[] = {
	"REALTIME", "MONOTONIC", "PROCESS_CPUTIME_ID", "THREAD_CPUTIME_ID",
425 426
	"MONOTONIC_RAW", "REALTIME_COARSE", "MONOTONIC_COARSE", "BOOTTIME",
	"REALTIME_ALARM", "BOOTTIME_ALARM", "SGI_CYCLE", "TAI"
427 428 429
};
static DEFINE_STRARRAY(clockid);

430 431 432 433 434 435 436 437 438 439
static const char *socket_families[] = {
	"UNSPEC", "LOCAL", "INET", "AX25", "IPX", "APPLETALK", "NETROM",
	"BRIDGE", "ATMPVC", "X25", "INET6", "ROSE", "DECnet", "NETBEUI",
	"SECURITY", "KEY", "NETLINK", "PACKET", "ASH", "ECONET", "ATMSVC",
	"RDS", "SNA", "IRDA", "PPPOX", "WANPIPE", "LLC", "IB", "CAN", "TIPC",
	"BLUETOOTH", "IUCV", "RXRPC", "ISDN", "PHONET", "IEEE802154", "CAIF",
	"ALG", "NFC", "VSOCK",
};
static DEFINE_STRARRAY(socket_families);

440 441 442 443 444 445 446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466
static size_t syscall_arg__scnprintf_access_mode(char *bf, size_t size,
						 struct syscall_arg *arg)
{
	size_t printed = 0;
	int mode = arg->val;

	if (mode == F_OK) /* 0 */
		return scnprintf(bf, size, "F");
#define	P_MODE(n) \
	if (mode & n##_OK) { \
		printed += scnprintf(bf + printed, size - printed, "%s", #n); \
		mode &= ~n##_OK; \
	}

	P_MODE(R);
	P_MODE(W);
	P_MODE(X);
#undef P_MODE

	if (mode)
		printed += scnprintf(bf + printed, size - printed, "|%#x", mode);

	return printed;
}

#define SCA_ACCMODE syscall_arg__scnprintf_access_mode

467 468 469 470 471
static size_t syscall_arg__scnprintf_filename(char *bf, size_t size,
					      struct syscall_arg *arg);

#define SCA_FILENAME syscall_arg__scnprintf_filename

472 473 474 475 476 477 478 479 480 481 482 483 484 485 486 487 488 489 490 491 492 493 494
static size_t syscall_arg__scnprintf_pipe_flags(char *bf, size_t size,
						struct syscall_arg *arg)
{
	int printed = 0, flags = arg->val;

#define	P_FLAG(n) \
	if (flags & O_##n) { \
		printed += scnprintf(bf + printed, size - printed, "%s%s", printed ? "|" : "", #n); \
		flags &= ~O_##n; \
	}

	P_FLAG(CLOEXEC);
	P_FLAG(NONBLOCK);
#undef P_FLAG

	if (flags)
		printed += scnprintf(bf + printed, size - printed, "%s%#x", printed ? "|" : "", flags);

	return printed;
}

#define SCA_PIPE_FLAGS syscall_arg__scnprintf_pipe_flags

495 496 497 498
#if defined(__i386__) || defined(__x86_64__)
/*
 * FIXME: Make this available to all arches.
 */
499 500 501 502 503 504 505 506 507 508 509 510 511 512 513 514 515 516 517 518 519
#define TCGETS		0x5401

static const char *tioctls[] = {
	"TCGETS", "TCSETS", "TCSETSW", "TCSETSF", "TCGETA", "TCSETA", "TCSETAW",
	"TCSETAF", "TCSBRK", "TCXONC", "TCFLSH", "TIOCEXCL", "TIOCNXCL",
	"TIOCSCTTY", "TIOCGPGRP", "TIOCSPGRP", "TIOCOUTQ", "TIOCSTI",
	"TIOCGWINSZ", "TIOCSWINSZ", "TIOCMGET", "TIOCMBIS", "TIOCMBIC",
	"TIOCMSET", "TIOCGSOFTCAR", "TIOCSSOFTCAR", "FIONREAD", "TIOCLINUX",
	"TIOCCONS", "TIOCGSERIAL", "TIOCSSERIAL", "TIOCPKT", "FIONBIO",
	"TIOCNOTTY", "TIOCSETD", "TIOCGETD", "TCSBRKP", [0x27] = "TIOCSBRK",
	"TIOCCBRK", "TIOCGSID", "TCGETS2", "TCSETS2", "TCSETSW2", "TCSETSF2",
	"TIOCGRS485", "TIOCSRS485", "TIOCGPTN", "TIOCSPTLCK",
	"TIOCGDEV||TCGETX", "TCSETX", "TCSETXF", "TCSETXW", "TIOCSIG",
	"TIOCVHANGUP", "TIOCGPKT", "TIOCGPTLCK", "TIOCGEXCL",
	[0x50] = "FIONCLEX", "FIOCLEX", "FIOASYNC", "TIOCSERCONFIG",
	"TIOCSERGWILD", "TIOCSERSWILD", "TIOCGLCKTRMIOS", "TIOCSLCKTRMIOS",
	"TIOCSERGSTRUCT", "TIOCSERGETLSR", "TIOCSERGETMULTI", "TIOCSERSETMULTI",
	"TIOCMIWAIT", "TIOCGICOUNT", [0x60] = "FIOQSIZE",
};

static DEFINE_STRARRAY_OFFSET(tioctls, 0x5401);
520
#endif /* defined(__i386__) || defined(__x86_64__) */
521

522 523 524 525 526 527 528
#ifndef GRND_NONBLOCK
#define GRND_NONBLOCK	0x0001
#endif
#ifndef GRND_RANDOM
#define GRND_RANDOM	0x0002
#endif

529 530 531 532 533 534 535 536 537 538 539 540 541 542 543 544 545 546 547 548 549 550 551
static size_t syscall_arg__scnprintf_getrandom_flags(char *bf, size_t size,
						   struct syscall_arg *arg)
{
	int printed = 0, flags = arg->val;

#define	P_FLAG(n) \
	if (flags & GRND_##n) { \
		printed += scnprintf(bf + printed, size - printed, "%s%s", printed ? "|" : "", #n); \
		flags &= ~GRND_##n; \
	}

	P_FLAG(RANDOM);
	P_FLAG(NONBLOCK);
#undef P_FLAG

	if (flags)
		printed += scnprintf(bf + printed, size - printed, "%s%#x", printed ? "|" : "", flags);

	return printed;
}

#define SCA_GETRANDOM_FLAGS syscall_arg__scnprintf_getrandom_flags

552 553 554 555
#define STRARRAY(arg, name, array) \
	  .arg_scnprintf = { [arg] = SCA_STRARRAY, }, \
	  .arg_parm	 = { [arg] = &strarray__##array, }

556
#include "trace/beauty/eventfd.c"
557
#include "trace/beauty/flock.c"
558
#include "trace/beauty/futex_op.c"
559
#include "trace/beauty/mmap.c"
560
#include "trace/beauty/mode_t.c"
561
#include "trace/beauty/msg_flags.c"
562
#include "trace/beauty/open_flags.c"
563
#include "trace/beauty/perf_event_open.c"
564
#include "trace/beauty/pid.c"
565
#include "trace/beauty/sched_policy.c"
566
#include "trace/beauty/seccomp.c"
567
#include "trace/beauty/signum.c"
568
#include "trace/beauty/socket_type.c"
569
#include "trace/beauty/waitid_options.c"
570

A
Arnaldo Carvalho de Melo 已提交
571 572
static struct syscall_fmt {
	const char *name;
573
	const char *alias;
574
	size_t	   (*arg_scnprintf[6])(char *bf, size_t size, struct syscall_arg *arg);
575
	void	   *arg_parm[6];
A
Arnaldo Carvalho de Melo 已提交
576
	bool	   errmsg;
577
	bool	   errpid;
A
Arnaldo Carvalho de Melo 已提交
578
	bool	   timeout;
579
	bool	   hexret;
A
Arnaldo Carvalho de Melo 已提交
580
} syscall_fmts[] = {
581
	{ .name	    = "access",	    .errmsg = true,
582
	  .arg_scnprintf = { [1] = SCA_ACCMODE,  /* mode */ }, },
583
	{ .name	    = "arch_prctl", .errmsg = true, .alias = "prctl", },
584
	{ .name	    = "bpf",	    .errmsg = true, STRARRAY(0, cmd, bpf_cmd), },
585 586
	{ .name	    = "brk",	    .hexret = true,
	  .arg_scnprintf = { [0] = SCA_HEX, /* brk */ }, },
587 588 589
	{ .name	    = "chdir",	    .errmsg = true, },
	{ .name	    = "chmod",	    .errmsg = true, },
	{ .name	    = "chroot",	    .errmsg = true, },
590
	{ .name     = "clock_gettime",  .errmsg = true, STRARRAY(0, clk_id, clockid), },
591
	{ .name	    = "clone",	    .errpid = true, },
592
	{ .name	    = "close",	    .errmsg = true,
593
	  .arg_scnprintf = { [0] = SCA_CLOSE_FD, /* fd */ }, },
594
	{ .name	    = "connect",    .errmsg = true, },
595
	{ .name	    = "creat",	    .errmsg = true, },
596 597 598
	{ .name	    = "dup",	    .errmsg = true, },
	{ .name	    = "dup2",	    .errmsg = true, },
	{ .name	    = "dup3",	    .errmsg = true, },
599
	{ .name	    = "epoll_ctl",  .errmsg = true, STRARRAY(1, op, epoll_ctl_ops), },
600 601
	{ .name	    = "eventfd2",   .errmsg = true,
	  .arg_scnprintf = { [1] = SCA_EFD_FLAGS, /* flags */ }, },
602
	{ .name	    = "faccessat",  .errmsg = true, },
603 604 605 606
	{ .name	    = "fadvise64",  .errmsg = true, },
	{ .name	    = "fallocate",  .errmsg = true, },
	{ .name	    = "fchdir",	    .errmsg = true, },
	{ .name	    = "fchmod",	    .errmsg = true, },
607
	{ .name	    = "fchmodat",   .errmsg = true,
608
	  .arg_scnprintf = { [0] = SCA_FDAT, /* fd */ }, },
609
	{ .name	    = "fchown",	    .errmsg = true, },
610
	{ .name	    = "fchownat",   .errmsg = true,
611
	  .arg_scnprintf = { [0] = SCA_FDAT, /* fd */ }, },
612
	{ .name	    = "fcntl",	    .errmsg = true,
613
	  .arg_scnprintf = { [1] = SCA_STRARRAY, /* cmd */ },
614
	  .arg_parm	 = { [1] = &strarray__fcntl_cmds, /* cmd */ }, },
615
	{ .name	    = "fdatasync",  .errmsg = true, },
616
	{ .name	    = "flock",	    .errmsg = true,
617 618 619
	  .arg_scnprintf = { [1] = SCA_FLOCK, /* cmd */ }, },
	{ .name	    = "fsetxattr",  .errmsg = true, },
	{ .name	    = "fstat",	    .errmsg = true, .alias = "newfstat", },
620
	{ .name	    = "fstatat",    .errmsg = true, .alias = "newfstatat", },
621 622 623
	{ .name	    = "fstatfs",    .errmsg = true, },
	{ .name	    = "fsync",    .errmsg = true, },
	{ .name	    = "ftruncate", .errmsg = true, },
624 625
	{ .name	    = "futex",	    .errmsg = true,
	  .arg_scnprintf = { [1] = SCA_FUTEX_OP, /* op */ }, },
626
	{ .name	    = "futimesat", .errmsg = true,
627
	  .arg_scnprintf = { [0] = SCA_FDAT, /* fd */ }, },
628 629
	{ .name	    = "getdents",   .errmsg = true, },
	{ .name	    = "getdents64", .errmsg = true, },
630
	{ .name	    = "getitimer",  .errmsg = true, STRARRAY(0, which, itimers), },
631
	{ .name	    = "getpid",	    .errpid = true, },
632
	{ .name	    = "getpgid",    .errpid = true, },
633
	{ .name	    = "getppid",    .errpid = true, },
634 635
	{ .name	    = "getrandom",  .errmsg = true,
	  .arg_scnprintf = { [2] = SCA_GETRANDOM_FLAGS, /* flags */ }, },
636
	{ .name	    = "getrlimit",  .errmsg = true, STRARRAY(0, resource, rlimit_resources), },
637 638
	{ .name	    = "getxattr",   .errmsg = true, },
	{ .name	    = "inotify_add_watch",	    .errmsg = true, },
639
	{ .name	    = "ioctl",	    .errmsg = true,
640
	  .arg_scnprintf = {
641 642 643 644
#if defined(__i386__) || defined(__x86_64__)
/*
 * FIXME: Make this available to all arches.
 */
645 646 647
			     [1] = SCA_STRHEXARRAY, /* cmd */
			     [2] = SCA_HEX, /* arg */ },
	  .arg_parm	 = { [1] = &strarray__tioctls, /* cmd */ }, },
648 649 650
#else
			     [2] = SCA_HEX, /* arg */ }, },
#endif
651
	{ .name	    = "keyctl",	    .errmsg = true, STRARRAY(0, option, keyctl_options), },
652 653
	{ .name	    = "kill",	    .errmsg = true,
	  .arg_scnprintf = { [1] = SCA_SIGNUM, /* sig */ }, },
654 655
	{ .name	    = "lchown",    .errmsg = true, },
	{ .name	    = "lgetxattr",  .errmsg = true, },
656
	{ .name	    = "linkat",	    .errmsg = true,
657
	  .arg_scnprintf = { [0] = SCA_FDAT, /* fd */ }, },
658 659 660
	{ .name	    = "listxattr",  .errmsg = true, },
	{ .name	    = "llistxattr", .errmsg = true, },
	{ .name	    = "lremovexattr",  .errmsg = true, },
661
	{ .name	    = "lseek",	    .errmsg = true,
662
	  .arg_scnprintf = { [2] = SCA_STRARRAY, /* whence */ },
663
	  .arg_parm	 = { [2] = &strarray__whences, /* whence */ }, },
664 665 666
	{ .name	    = "lsetxattr",  .errmsg = true, },
	{ .name	    = "lstat",	    .errmsg = true, .alias = "newlstat", },
	{ .name	    = "lsxattr",    .errmsg = true, },
667 668 669
	{ .name     = "madvise",    .errmsg = true,
	  .arg_scnprintf = { [0] = SCA_HEX,	 /* start */
			     [2] = SCA_MADV_BHV, /* behavior */ }, },
670
	{ .name	    = "mkdir",    .errmsg = true, },
671
	{ .name	    = "mkdirat",    .errmsg = true,
672 673
	  .arg_scnprintf = { [0] = SCA_FDAT, /* fd */ }, },
	{ .name	    = "mknod",      .errmsg = true, },
674
	{ .name	    = "mknodat",    .errmsg = true,
675
	  .arg_scnprintf = { [0] = SCA_FDAT, /* fd */ }, },
676 677 678 679
	{ .name	    = "mlock",	    .errmsg = true,
	  .arg_scnprintf = { [0] = SCA_HEX, /* addr */ }, },
	{ .name	    = "mlockall",   .errmsg = true,
	  .arg_scnprintf = { [0] = SCA_HEX, /* addr */ }, },
680
	{ .name	    = "mmap",	    .hexret = true,
681
	  .arg_scnprintf = { [0] = SCA_HEX,	  /* addr */
682
			     [2] = SCA_MMAP_PROT, /* prot */
683
			     [3] = SCA_MMAP_FLAGS, /* flags */ }, },
684
	{ .name	    = "mprotect",   .errmsg = true,
685 686
	  .arg_scnprintf = { [0] = SCA_HEX, /* start */
			     [2] = SCA_MMAP_PROT, /* prot */ }, },
687 688
	{ .name	    = "mq_unlink", .errmsg = true,
	  .arg_scnprintf = { [0] = SCA_FILENAME, /* u_name */ }, },
689 690
	{ .name	    = "mremap",	    .hexret = true,
	  .arg_scnprintf = { [0] = SCA_HEX, /* addr */
691
			     [3] = SCA_MREMAP_FLAGS, /* flags */
692
			     [4] = SCA_HEX, /* new_addr */ }, },
693 694
	{ .name	    = "munlock",    .errmsg = true,
	  .arg_scnprintf = { [0] = SCA_HEX, /* addr */ }, },
695 696
	{ .name	    = "munmap",	    .errmsg = true,
	  .arg_scnprintf = { [0] = SCA_HEX, /* addr */ }, },
697
	{ .name	    = "name_to_handle_at", .errmsg = true,
698
	  .arg_scnprintf = { [0] = SCA_FDAT, /* dfd */ }, },
699
	{ .name	    = "newfstatat", .errmsg = true,
700
	  .arg_scnprintf = { [0] = SCA_FDAT, /* dfd */ }, },
701
	{ .name	    = "open",	    .errmsg = true,
702
	  .arg_scnprintf = { [1] = SCA_OPEN_FLAGS, /* flags */ }, },
703
	{ .name	    = "open_by_handle_at", .errmsg = true,
704 705
	  .arg_scnprintf = { [0] = SCA_FDAT, /* dfd */
			     [2] = SCA_OPEN_FLAGS, /* flags */ }, },
706
	{ .name	    = "openat",	    .errmsg = true,
707 708
	  .arg_scnprintf = { [0] = SCA_FDAT, /* dfd */
			     [2] = SCA_OPEN_FLAGS, /* flags */ }, },
709
	{ .name	    = "perf_event_open", .errmsg = true,
710
	  .arg_scnprintf = { [2] = SCA_INT, /* cpu */
711 712
			     [3] = SCA_FD,  /* group_fd */
			     [4] = SCA_PERF_FLAGS,  /* flags */ }, },
713 714
	{ .name	    = "pipe2",	    .errmsg = true,
	  .arg_scnprintf = { [1] = SCA_PIPE_FLAGS, /* flags */ }, },
715 716
	{ .name	    = "poll",	    .errmsg = true, .timeout = true, },
	{ .name	    = "ppoll",	    .errmsg = true, .timeout = true, },
717 718
	{ .name	    = "pread",	    .errmsg = true, .alias = "pread64", },
	{ .name	    = "preadv",	    .errmsg = true, .alias = "pread", },
719
	{ .name	    = "prlimit64",  .errmsg = true, STRARRAY(1, resource, rlimit_resources), },
720 721 722
	{ .name	    = "pwrite",	    .errmsg = true, .alias = "pwrite64", },
	{ .name	    = "pwritev",    .errmsg = true, },
	{ .name	    = "read",	    .errmsg = true, },
723
	{ .name	    = "readlink",   .errmsg = true, },
724
	{ .name	    = "readlinkat", .errmsg = true,
725
	  .arg_scnprintf = { [0] = SCA_FDAT, /* dfd */ }, },
726
	{ .name	    = "readv",	    .errmsg = true, },
727
	{ .name	    = "recvfrom",   .errmsg = true,
728
	  .arg_scnprintf = { [3] = SCA_MSG_FLAGS, /* flags */ }, },
729
	{ .name	    = "recvmmsg",   .errmsg = true,
730
	  .arg_scnprintf = { [3] = SCA_MSG_FLAGS, /* flags */ }, },
731
	{ .name	    = "recvmsg",    .errmsg = true,
732
	  .arg_scnprintf = { [2] = SCA_MSG_FLAGS, /* flags */ }, },
733
	{ .name	    = "removexattr", .errmsg = true, },
734
	{ .name	    = "renameat",   .errmsg = true,
735
	  .arg_scnprintf = { [0] = SCA_FDAT, /* dfd */ }, },
736
	{ .name	    = "rmdir",    .errmsg = true, },
737 738
	{ .name	    = "rt_sigaction", .errmsg = true,
	  .arg_scnprintf = { [0] = SCA_SIGNUM, /* sig */ }, },
739
	{ .name	    = "rt_sigprocmask",  .errmsg = true, STRARRAY(0, how, sighow), },
740 741 742 743
	{ .name	    = "rt_sigqueueinfo", .errmsg = true,
	  .arg_scnprintf = { [1] = SCA_SIGNUM, /* sig */ }, },
	{ .name	    = "rt_tgsigqueueinfo", .errmsg = true,
	  .arg_scnprintf = { [2] = SCA_SIGNUM, /* sig */ }, },
744 745
	{ .name	    = "sched_getattr",	      .errmsg = true, },
	{ .name	    = "sched_setattr",	      .errmsg = true, },
746 747
	{ .name	    = "sched_setscheduler",   .errmsg = true,
	  .arg_scnprintf = { [1] = SCA_SCHED_POLICY, /* policy */ }, },
748 749 750
	{ .name	    = "seccomp", .errmsg = true,
	  .arg_scnprintf = { [0] = SCA_SECCOMP_OP, /* op */
			     [1] = SCA_SECCOMP_FLAGS, /* flags */ }, },
751
	{ .name	    = "select",	    .errmsg = true, .timeout = true, },
752
	{ .name	    = "sendmmsg",    .errmsg = true,
753
	  .arg_scnprintf = { [3] = SCA_MSG_FLAGS, /* flags */ }, },
754
	{ .name	    = "sendmsg",    .errmsg = true,
755
	  .arg_scnprintf = { [2] = SCA_MSG_FLAGS, /* flags */ }, },
756
	{ .name	    = "sendto",	    .errmsg = true,
757
	  .arg_scnprintf = { [3] = SCA_MSG_FLAGS, /* flags */ }, },
758
	{ .name	    = "set_tid_address", .errpid = true, },
759
	{ .name	    = "setitimer",  .errmsg = true, STRARRAY(0, which, itimers), },
760
	{ .name	    = "setpgid",    .errmsg = true, },
761
	{ .name	    = "setrlimit",  .errmsg = true, STRARRAY(0, resource, rlimit_resources), },
762
	{ .name	    = "setxattr",   .errmsg = true, },
763
	{ .name	    = "shutdown",   .errmsg = true, },
764
	{ .name	    = "socket",	    .errmsg = true,
765 766
	  .arg_scnprintf = { [0] = SCA_STRARRAY, /* family */
			     [1] = SCA_SK_TYPE, /* type */ },
767 768 769 770
	  .arg_parm	 = { [0] = &strarray__socket_families, /* family */ }, },
	{ .name	    = "socketpair", .errmsg = true,
	  .arg_scnprintf = { [0] = SCA_STRARRAY, /* family */
			     [1] = SCA_SK_TYPE, /* type */ },
771
	  .arg_parm	 = { [0] = &strarray__socket_families, /* family */ }, },
772 773
	{ .name	    = "stat",	    .errmsg = true, .alias = "newstat", },
	{ .name	    = "statfs",	    .errmsg = true, },
774 775 776 777
	{ .name	    = "statx",	    .errmsg = true,
	  .arg_scnprintf = { [0] = SCA_FDAT, /* flags */
			     [2] = SCA_STATX_FLAGS, /* flags */
			     [3] = SCA_STATX_MASK, /* mask */ }, },
778 779 780 781
	{ .name	    = "swapoff",    .errmsg = true,
	  .arg_scnprintf = { [0] = SCA_FILENAME, /* specialfile */ }, },
	{ .name	    = "swapon",	    .errmsg = true,
	  .arg_scnprintf = { [0] = SCA_FILENAME, /* specialfile */ }, },
782
	{ .name	    = "symlinkat",  .errmsg = true,
783
	  .arg_scnprintf = { [0] = SCA_FDAT, /* dfd */ }, },
784 785 786 787
	{ .name	    = "tgkill",	    .errmsg = true,
	  .arg_scnprintf = { [2] = SCA_SIGNUM, /* sig */ }, },
	{ .name	    = "tkill",	    .errmsg = true,
	  .arg_scnprintf = { [1] = SCA_SIGNUM, /* sig */ }, },
788
	{ .name	    = "truncate",   .errmsg = true, },
789
	{ .name	    = "uname",	    .errmsg = true, .alias = "newuname", },
790
	{ .name	    = "unlinkat",   .errmsg = true,
791 792
	  .arg_scnprintf = { [0] = SCA_FDAT, /* dfd */ }, },
	{ .name	    = "utime",  .errmsg = true, },
793
	{ .name	    = "utimensat",  .errmsg = true,
794 795
	  .arg_scnprintf = { [0] = SCA_FDAT, /* dirfd */ }, },
	{ .name	    = "utimes",  .errmsg = true, },
796
	{ .name	    = "vmsplice",  .errmsg = true, },
797
	{ .name	    = "wait4",	    .errpid = true,
798
	  .arg_scnprintf = { [2] = SCA_WAITID_OPTIONS, /* options */ }, },
799
	{ .name	    = "waitid",	    .errpid = true,
800
	  .arg_scnprintf = { [3] = SCA_WAITID_OPTIONS, /* options */ }, },
801 802
	{ .name	    = "write",	    .errmsg = true, },
	{ .name	    = "writev",	    .errmsg = true, },
A
Arnaldo Carvalho de Melo 已提交
803 804 805 806 807 808 809 810 811 812 813 814 815 816 817 818
};

static int syscall_fmt__cmp(const void *name, const void *fmtp)
{
	const struct syscall_fmt *fmt = fmtp;
	return strcmp(name, fmt->name);
}

static struct syscall_fmt *syscall_fmt__find(const char *name)
{
	const int nmemb = ARRAY_SIZE(syscall_fmts);
	return bsearch(name, syscall_fmts, nmemb, sizeof(struct syscall_fmt), syscall_fmt__cmp);
}

struct syscall {
	struct event_format *tp_format;
819 820
	int		    nr_args;
	struct format_field *args;
A
Arnaldo Carvalho de Melo 已提交
821
	const char	    *name;
822
	bool		    is_exit;
A
Arnaldo Carvalho de Melo 已提交
823
	struct syscall_fmt  *fmt;
824
	size_t		    (**arg_scnprintf)(char *bf, size_t size, struct syscall_arg *arg);
825
	void		    **arg_parm;
A
Arnaldo Carvalho de Melo 已提交
826 827
};

828 829 830 831 832 833 834 835
/*
 * We need to have this 'calculated' boolean because in some cases we really
 * don't know what is the duration of a syscall, for instance, when we start
 * a session and some threads are waiting for a syscall to finish, say 'poll',
 * in which case all we can do is to print "( ? ) for duration and for the
 * start timestamp.
 */
static size_t fprintf_duration(unsigned long t, bool calculated, FILE *fp)
836 837 838 839
{
	double duration = (double)t / NSEC_PER_MSEC;
	size_t printed = fprintf(fp, "(");

840 841 842
	if (!calculated)
		printed += fprintf(fp, "     ?   ");
	else if (duration >= 1.0)
843 844 845 846 847
		printed += color_fprintf(fp, PERF_COLOR_RED, "%6.3f ms", duration);
	else if (duration >= 0.01)
		printed += color_fprintf(fp, PERF_COLOR_YELLOW, "%6.3f ms", duration);
	else
		printed += color_fprintf(fp, PERF_COLOR_NORMAL, "%6.3f ms", duration);
848
	return printed + fprintf(fp, "): ");
849 850
}

851 852 853 854 855
/**
 * filename.ptr: The filename char pointer that will be vfs_getname'd
 * filename.entry_str_pos: Where to insert the string translated from
 *                         filename.ptr by the vfs_getname tracepoint/kprobe.
 */
856 857 858
struct thread_trace {
	u64		  entry_time;
	bool		  entry_pending;
859
	unsigned long	  nr_events;
860
	unsigned long	  pfmaj, pfmin;
861
	char		  *entry_str;
862
	double		  runtime_ms;
863 864
        struct {
		unsigned long ptr;
865 866 867 868
		short int     entry_str_pos;
		bool	      pending_open;
		unsigned int  namelen;
		char	      *name;
869
	} filename;
870 871 872 873
	struct {
		int	  max;
		char	  **table;
	} paths;
874 875

	struct intlist *syscall_stats;
876 877 878 879
};

static struct thread_trace *thread_trace__new(void)
{
880 881 882 883 884
	struct thread_trace *ttrace =  zalloc(sizeof(struct thread_trace));

	if (ttrace)
		ttrace->paths.max = -1;

885 886
	ttrace->syscall_stats = intlist__new(NULL);

887
	return ttrace;
888 889
}

890
static struct thread_trace *thread__trace(struct thread *thread, FILE *fp)
891
{
892 893
	struct thread_trace *ttrace;

894 895 896
	if (thread == NULL)
		goto fail;

897 898
	if (thread__priv(thread) == NULL)
		thread__set_priv(thread, thread_trace__new());
899

900
	if (thread__priv(thread) == NULL)
901 902
		goto fail;

903
	ttrace = thread__priv(thread);
904 905 906
	++ttrace->nr_events;

	return ttrace;
907
fail:
908
	color_fprintf(fp, PERF_COLOR_RED,
909 910 911 912
		      "WARNING: not enough memory, dropping samples!\n");
	return NULL;
}

913 914 915
#define TRACE_PFMAJ		(1 << 0)
#define TRACE_PFMIN		(1 << 1)

916 917
static const size_t trace__entry_str_size = 2048;

918
static int trace__set_fd_pathname(struct thread *thread, int fd, const char *pathname)
919
{
920
	struct thread_trace *ttrace = thread__priv(thread);
921 922 923 924 925 926 927 928 929 930 931 932 933 934 935 936 937 938 939 940 941 942 943

	if (fd > ttrace->paths.max) {
		char **npath = realloc(ttrace->paths.table, (fd + 1) * sizeof(char *));

		if (npath == NULL)
			return -1;

		if (ttrace->paths.max != -1) {
			memset(npath + ttrace->paths.max + 1, 0,
			       (fd - ttrace->paths.max) * sizeof(char *));
		} else {
			memset(npath, 0, (fd + 1) * sizeof(char *));
		}

		ttrace->paths.table = npath;
		ttrace->paths.max   = fd;
	}

	ttrace->paths.table[fd] = strdup(pathname);

	return ttrace->paths.table[fd] != NULL ? 0 : -1;
}

944 945 946 947 948 949 950 951 952 953 954 955 956 957 958 959 960 961 962 963 964 965 966 967 968 969
static int thread__read_fd_path(struct thread *thread, int fd)
{
	char linkname[PATH_MAX], pathname[PATH_MAX];
	struct stat st;
	int ret;

	if (thread->pid_ == thread->tid) {
		scnprintf(linkname, sizeof(linkname),
			  "/proc/%d/fd/%d", thread->pid_, fd);
	} else {
		scnprintf(linkname, sizeof(linkname),
			  "/proc/%d/task/%d/fd/%d", thread->pid_, thread->tid, fd);
	}

	if (lstat(linkname, &st) < 0 || st.st_size + 1 > (off_t)sizeof(pathname))
		return -1;

	ret = readlink(linkname, pathname, sizeof(pathname));

	if (ret < 0 || ret > st.st_size)
		return -1;

	pathname[ret] = '\0';
	return trace__set_fd_pathname(thread, fd, pathname);
}

970 971
static const char *thread__fd_path(struct thread *thread, int fd,
				   struct trace *trace)
972
{
973
	struct thread_trace *ttrace = thread__priv(thread);
974 975 976 977 978 979 980

	if (ttrace == NULL)
		return NULL;

	if (fd < 0)
		return NULL;

981
	if ((fd > ttrace->paths.max || ttrace->paths.table[fd] == NULL)) {
982 983 984
		if (!trace->live)
			return NULL;
		++trace->stats.proc_getname;
985
		if (thread__read_fd_path(thread, fd))
986 987
			return NULL;
	}
988 989 990 991 992 993 994 995 996

	return ttrace->paths.table[fd];
}

static size_t syscall_arg__scnprintf_fd(char *bf, size_t size,
					struct syscall_arg *arg)
{
	int fd = arg->val;
	size_t printed = scnprintf(bf, size, "%d", fd);
997
	const char *path = thread__fd_path(arg->thread, fd, arg->trace);
998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009

	if (path)
		printed += scnprintf(bf + printed, size - printed, "<%s>", path);

	return printed;
}

static size_t syscall_arg__scnprintf_close_fd(char *bf, size_t size,
					      struct syscall_arg *arg)
{
	int fd = arg->val;
	size_t printed = syscall_arg__scnprintf_fd(bf, size, arg);
1010
	struct thread_trace *ttrace = thread__priv(arg->thread);
1011

1012 1013
	if (ttrace && fd >= 0 && fd <= ttrace->paths.max)
		zfree(&ttrace->paths.table[fd]);
1014 1015 1016 1017

	return printed;
}

1018 1019 1020 1021 1022 1023 1024 1025 1026 1027 1028 1029 1030 1031 1032 1033 1034 1035 1036 1037 1038
static void thread__set_filename_pos(struct thread *thread, const char *bf,
				     unsigned long ptr)
{
	struct thread_trace *ttrace = thread__priv(thread);

	ttrace->filename.ptr = ptr;
	ttrace->filename.entry_str_pos = bf - ttrace->entry_str;
}

static size_t syscall_arg__scnprintf_filename(char *bf, size_t size,
					      struct syscall_arg *arg)
{
	unsigned long ptr = arg->val;

	if (!arg->trace->vfs_getname)
		return scnprintf(bf, size, "%#x", ptr);

	thread__set_filename_pos(arg->thread, bf, ptr);
	return 0;
}

1039 1040 1041 1042 1043
static bool trace__filter_duration(struct trace *trace, double t)
{
	return t < (trace->duration_filter * NSEC_PER_MSEC);
}

1044
static size_t __trace__fprintf_tstamp(struct trace *trace, u64 tstamp, FILE *fp)
1045 1046 1047
{
	double ts = (double)(tstamp - trace->base_time) / NSEC_PER_MSEC;

1048
	return fprintf(fp, "%10.3f ", ts);
1049 1050
}

1051 1052 1053 1054 1055 1056 1057 1058 1059 1060 1061 1062 1063 1064
/*
 * We're handling tstamp=0 as an undefined tstamp, i.e. like when we are
 * using ttrace->entry_time for a thread that receives a sys_exit without
 * first having received a sys_enter ("poll" issued before tracing session
 * starts, lost sys_enter exit due to ring buffer overflow).
 */
static size_t trace__fprintf_tstamp(struct trace *trace, u64 tstamp, FILE *fp)
{
	if (tstamp > 0)
		return __trace__fprintf_tstamp(trace, tstamp, fp);

	return fprintf(fp, "         ? ");
}

1065
static bool done = false;
1066
static bool interrupted = false;
1067

1068
static void sig_handler(int sig)
1069 1070
{
	done = true;
1071
	interrupted = sig == SIGINT;
1072 1073
}

1074
static size_t trace__fprintf_entry_head(struct trace *trace, struct thread *thread,
1075
					u64 duration, bool duration_calculated, u64 tstamp, FILE *fp)
1076 1077
{
	size_t printed = trace__fprintf_tstamp(trace, tstamp, fp);
1078
	printed += fprintf_duration(duration, duration_calculated, fp);
1079

1080 1081
	if (trace->multiple_threads) {
		if (trace->show_comm)
1082
			printed += fprintf(fp, "%.14s/", thread__comm_str(thread));
1083
		printed += fprintf(fp, "%d ", thread->tid);
1084
	}
1085 1086 1087 1088

	return printed;
}

1089
static int trace__process_event(struct trace *trace, struct machine *machine,
1090
				union perf_event *event, struct perf_sample *sample)
1091 1092 1093 1094 1095
{
	int ret = 0;

	switch (event->header.type) {
	case PERF_RECORD_LOST:
1096
		color_fprintf(trace->output, PERF_COLOR_RED,
1097
			      "LOST %" PRIu64 " events!\n", event->lost.lost);
1098
		ret = machine__process_lost_event(machine, event, sample);
1099
		break;
1100
	default:
1101
		ret = machine__process_event(machine, event, sample);
1102 1103 1104 1105 1106 1107
		break;
	}

	return ret;
}

1108
static int trace__tool_process(struct perf_tool *tool,
1109
			       union perf_event *event,
1110
			       struct perf_sample *sample,
1111 1112
			       struct machine *machine)
{
1113
	struct trace *trace = container_of(tool, struct trace, tool);
1114
	return trace__process_event(trace, machine, event, sample);
1115 1116
}

1117 1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134
static char *trace__machine__resolve_kernel_addr(void *vmachine, unsigned long long *addrp, char **modp)
{
	struct machine *machine = vmachine;

	if (machine->kptr_restrict_warned)
		return NULL;

	if (symbol_conf.kptr_restrict) {
		pr_warning("Kernel address maps (/proc/{kallsyms,modules}) are restricted.\n\n"
			   "Check /proc/sys/kernel/kptr_restrict.\n\n"
			   "Kernel samples will not be resolved.\n");
		machine->kptr_restrict_warned = true;
		return NULL;
	}

	return machine__resolve_kernel_addr(vmachine, addrp, modp);
}

1135 1136
static int trace__symbols_init(struct trace *trace, struct perf_evlist *evlist)
{
1137
	int err = symbol__init(NULL);
1138 1139 1140 1141

	if (err)
		return err;

1142 1143 1144
	trace->host = machine__new_host();
	if (trace->host == NULL)
		return -ENOMEM;
1145

1146
	if (trace_event__register_resolver(trace->host, trace__machine__resolve_kernel_addr) < 0)
1147 1148
		return -errno;

1149
	err = __machine__synthesize_threads(trace->host, &trace->tool, &trace->opts.target,
1150 1151
					    evlist->threads, trace__tool_process, false,
					    trace->opts.proc_map_timeout);
1152 1153 1154 1155 1156 1157
	if (err)
		symbol__exit();

	return err;
}

1158 1159 1160
static int syscall__set_arg_fmts(struct syscall *sc)
{
	struct format_field *field;
1161
	int idx = 0, len;
1162

1163
	sc->arg_scnprintf = calloc(sc->nr_args, sizeof(void *));
1164 1165 1166
	if (sc->arg_scnprintf == NULL)
		return -1;

1167 1168 1169
	if (sc->fmt)
		sc->arg_parm = sc->fmt->arg_parm;

1170
	for (field = sc->args; field; field = field->next) {
1171 1172
		if (sc->fmt && sc->fmt->arg_scnprintf[idx])
			sc->arg_scnprintf[idx] = sc->fmt->arg_scnprintf[idx];
1173 1174 1175 1176 1177
		else if (strcmp(field->type, "const char *") == 0 &&
			 (strcmp(field->name, "filename") == 0 ||
			  strcmp(field->name, "path") == 0 ||
			  strcmp(field->name, "pathname") == 0))
			sc->arg_scnprintf[idx] = SCA_FILENAME;
1178
		else if (field->flags & FIELD_IS_POINTER)
1179
			sc->arg_scnprintf[idx] = syscall_arg__scnprintf_hex;
1180 1181
		else if (strcmp(field->type, "pid_t") == 0)
			sc->arg_scnprintf[idx] = SCA_PID;
1182 1183
		else if (strcmp(field->type, "umode_t") == 0)
			sc->arg_scnprintf[idx] = SCA_MODE_T;
1184 1185 1186 1187 1188 1189 1190 1191 1192 1193 1194 1195 1196 1197
		else if ((strcmp(field->type, "int") == 0 ||
			  strcmp(field->type, "unsigned int") == 0 ||
			  strcmp(field->type, "long") == 0) &&
			 (len = strlen(field->name)) >= 2 &&
			 strcmp(field->name + len - 2, "fd") == 0) {
			/*
			 * /sys/kernel/tracing/events/syscalls/sys_enter*
			 * egrep 'field:.*fd;' .../format|sed -r 's/.*field:([a-z ]+) [a-z_]*fd.+/\1/g'|sort|uniq -c
			 * 65 int
			 * 23 unsigned int
			 * 7 unsigned long
			 */
			sc->arg_scnprintf[idx] = SCA_FD;
		}
1198 1199 1200 1201 1202 1203
		++idx;
	}

	return 0;
}

A
Arnaldo Carvalho de Melo 已提交
1204 1205 1206 1207
static int trace__read_syscall_info(struct trace *trace, int id)
{
	char tp_name[128];
	struct syscall *sc;
1208
	const char *name = syscalltbl__name(trace->sctbl, id);
1209 1210 1211

	if (name == NULL)
		return -1;
A
Arnaldo Carvalho de Melo 已提交
1212 1213 1214 1215 1216 1217 1218 1219 1220 1221 1222 1223 1224 1225 1226 1227 1228 1229 1230

	if (id > trace->syscalls.max) {
		struct syscall *nsyscalls = realloc(trace->syscalls.table, (id + 1) * sizeof(*sc));

		if (nsyscalls == NULL)
			return -1;

		if (trace->syscalls.max != -1) {
			memset(nsyscalls + trace->syscalls.max + 1, 0,
			       (id - trace->syscalls.max) * sizeof(*sc));
		} else {
			memset(nsyscalls, 0, (id + 1) * sizeof(*sc));
		}

		trace->syscalls.table = nsyscalls;
		trace->syscalls.max   = id;
	}

	sc = trace->syscalls.table + id;
1231
	sc->name = name;
1232

1233
	sc->fmt  = syscall_fmt__find(sc->name);
A
Arnaldo Carvalho de Melo 已提交
1234

1235
	snprintf(tp_name, sizeof(tp_name), "sys_enter_%s", sc->name);
1236
	sc->tp_format = trace_event__tp_format("syscalls", tp_name);
1237

1238
	if (IS_ERR(sc->tp_format) && sc->fmt && sc->fmt->alias) {
1239
		snprintf(tp_name, sizeof(tp_name), "sys_enter_%s", sc->fmt->alias);
1240
		sc->tp_format = trace_event__tp_format("syscalls", tp_name);
1241
	}
A
Arnaldo Carvalho de Melo 已提交
1242

1243
	if (IS_ERR(sc->tp_format))
1244 1245
		return -1;

1246 1247
	sc->args = sc->tp_format->format.fields;
	sc->nr_args = sc->tp_format->format.nr_fields;
1248 1249 1250 1251 1252 1253
	/*
	 * We need to check and discard the first variable '__syscall_nr'
	 * or 'nr' that mean the syscall number. It is needless here.
	 * So drop '__syscall_nr' or 'nr' field but does not exist on older kernels.
	 */
	if (sc->args && (!strcmp(sc->args->name, "__syscall_nr") || !strcmp(sc->args->name, "nr"))) {
1254 1255 1256 1257
		sc->args = sc->args->next;
		--sc->nr_args;
	}

1258 1259
	sc->is_exit = !strcmp(name, "exit_group") || !strcmp(name, "exit");

1260
	return syscall__set_arg_fmts(sc);
A
Arnaldo Carvalho de Melo 已提交
1261 1262
}

1263 1264
static int trace__validate_ev_qualifier(struct trace *trace)
{
1265
	int err = 0, i;
1266 1267
	struct str_node *pos;

1268 1269 1270 1271 1272 1273 1274 1275 1276 1277 1278 1279 1280
	trace->ev_qualifier_ids.nr = strlist__nr_entries(trace->ev_qualifier);
	trace->ev_qualifier_ids.entries = malloc(trace->ev_qualifier_ids.nr *
						 sizeof(trace->ev_qualifier_ids.entries[0]));

	if (trace->ev_qualifier_ids.entries == NULL) {
		fputs("Error:\tNot enough memory for allocating events qualifier ids\n",
		       trace->output);
		err = -EINVAL;
		goto out;
	}

	i = 0;

1281
	strlist__for_each_entry(pos, trace->ev_qualifier) {
1282
		const char *sc = pos->s;
1283
		int id = syscalltbl__id(trace->sctbl, sc);
1284

1285
		if (id < 0) {
1286 1287 1288 1289 1290 1291 1292 1293 1294
			if (err == 0) {
				fputs("Error:\tInvalid syscall ", trace->output);
				err = -EINVAL;
			} else {
				fputs(", ", trace->output);
			}

			fputs(sc, trace->output);
		}
1295 1296

		trace->ev_qualifier_ids.entries[i++] = id;
1297 1298 1299 1300 1301
	}

	if (err < 0) {
		fputs("\nHint:\ttry 'perf list syscalls:sys_enter_*'"
		      "\nHint:\tand: 'man syscalls'\n", trace->output);
1302 1303
		zfree(&trace->ev_qualifier_ids.entries);
		trace->ev_qualifier_ids.nr = 0;
1304
	}
1305
out:
1306 1307 1308
	return err;
}

1309 1310 1311 1312 1313 1314 1315 1316 1317
/*
 * args is to be interpreted as a series of longs but we need to handle
 * 8-byte unaligned accesses. args points to raw_data within the event
 * and raw_data is guaranteed to be 8-byte unaligned because it is
 * preceded by raw_size which is a u32. So we need to copy args to a temp
 * variable to read it. Most notably this avoids extended load instructions
 * on unaligned addresses
 */

1318
static size_t syscall__scnprintf_args(struct syscall *sc, char *bf, size_t size,
1319
				      unsigned char *args, struct trace *trace,
1320
				      struct thread *thread)
A
Arnaldo Carvalho de Melo 已提交
1321 1322
{
	size_t printed = 0;
1323 1324
	unsigned char *p;
	unsigned long val;
A
Arnaldo Carvalho de Melo 已提交
1325

1326
	if (sc->args != NULL) {
A
Arnaldo Carvalho de Melo 已提交
1327
		struct format_field *field;
1328 1329
		u8 bit = 1;
		struct syscall_arg arg = {
1330 1331 1332 1333
			.idx	= 0,
			.mask	= 0,
			.trace  = trace,
			.thread = thread,
1334
		};
1335

1336
		for (field = sc->args; field;
1337 1338
		     field = field->next, ++arg.idx, bit <<= 1) {
			if (arg.mask & bit)
1339
				continue;
1340 1341 1342 1343 1344

			/* special care for unaligned accesses */
			p = args + sizeof(unsigned long) * arg.idx;
			memcpy(&val, p, sizeof(val));

1345 1346 1347 1348 1349
			/*
 			 * Suppress this argument if its value is zero and
 			 * and we don't have a string associated in an
 			 * strarray for it.
 			 */
1350
			if (val == 0 &&
1351 1352 1353
			    !(sc->arg_scnprintf &&
			      sc->arg_scnprintf[arg.idx] == SCA_STRARRAY &&
			      sc->arg_parm[arg.idx]))
1354 1355
				continue;

1356
			printed += scnprintf(bf + printed, size - printed,
1357
					     "%s%s: ", printed ? ", " : "", field->name);
1358
			if (sc->arg_scnprintf && sc->arg_scnprintf[arg.idx]) {
1359
				arg.val = val;
1360 1361
				if (sc->arg_parm)
					arg.parm = sc->arg_parm[arg.idx];
1362 1363
				printed += sc->arg_scnprintf[arg.idx](bf + printed,
								      size - printed, &arg);
1364
			} else {
1365
				printed += scnprintf(bf + printed, size - printed,
1366
						     "%ld", val);
1367
			}
A
Arnaldo Carvalho de Melo 已提交
1368
		}
1369 1370 1371 1372 1373 1374
	} else if (IS_ERR(sc->tp_format)) {
		/*
		 * If we managed to read the tracepoint /format file, then we
		 * may end up not having any args, like with gettid(), so only
		 * print the raw args when we didn't manage to read it.
		 */
1375 1376
		int i = 0;

A
Arnaldo Carvalho de Melo 已提交
1377
		while (i < 6) {
1378 1379 1380
			/* special care for unaligned accesses */
			p = args + sizeof(unsigned long) * i;
			memcpy(&val, p, sizeof(val));
1381 1382
			printed += scnprintf(bf + printed, size - printed,
					     "%sarg%d: %ld",
1383
					     printed ? ", " : "", i, val);
A
Arnaldo Carvalho de Melo 已提交
1384 1385 1386 1387 1388 1389 1390
			++i;
		}
	}

	return printed;
}

1391
typedef int (*tracepoint_handler)(struct trace *trace, struct perf_evsel *evsel,
1392
				  union perf_event *event,
1393 1394 1395
				  struct perf_sample *sample);

static struct syscall *trace__syscall_info(struct trace *trace,
1396
					   struct perf_evsel *evsel, int id)
1397 1398 1399
{

	if (id < 0) {
1400 1401 1402 1403 1404 1405 1406 1407 1408 1409 1410 1411 1412 1413 1414 1415

		/*
		 * XXX: Noticed on x86_64, reproduced as far back as 3.0.36, haven't tried
		 * before that, leaving at a higher verbosity level till that is
		 * explained. Reproduced with plain ftrace with:
		 *
		 * echo 1 > /t/events/raw_syscalls/sys_exit/enable
		 * grep "NR -1 " /t/trace_pipe
		 *
		 * After generating some load on the machine.
 		 */
		if (verbose > 1) {
			static u64 n;
			fprintf(trace->output, "Invalid syscall %d id, skipping (%s, %" PRIu64 ") ...\n",
				id, perf_evsel__name(evsel), ++n);
		}
1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 1427 1428
		return NULL;
	}

	if ((id > trace->syscalls.max || trace->syscalls.table[id].name == NULL) &&
	    trace__read_syscall_info(trace, id))
		goto out_cant_read;

	if ((id > trace->syscalls.max || trace->syscalls.table[id].name == NULL))
		goto out_cant_read;

	return &trace->syscalls.table[id];

out_cant_read:
1429
	if (verbose > 0) {
1430 1431 1432 1433 1434
		fprintf(trace->output, "Problems reading syscall %d", id);
		if (id <= trace->syscalls.max && trace->syscalls.table[id].name != NULL)
			fprintf(trace->output, "(%s)", trace->syscalls.table[id].name);
		fputs(" information\n", trace->output);
	}
1435 1436 1437
	return NULL;
}

1438 1439 1440 1441 1442 1443 1444 1445 1446 1447 1448 1449 1450 1451 1452 1453 1454 1455 1456 1457 1458 1459 1460 1461 1462 1463
static void thread__update_stats(struct thread_trace *ttrace,
				 int id, struct perf_sample *sample)
{
	struct int_node *inode;
	struct stats *stats;
	u64 duration = 0;

	inode = intlist__findnew(ttrace->syscall_stats, id);
	if (inode == NULL)
		return;

	stats = inode->priv;
	if (stats == NULL) {
		stats = malloc(sizeof(struct stats));
		if (stats == NULL)
			return;
		init_stats(stats);
		inode->priv = stats;
	}

	if (ttrace->entry_time && sample->time > ttrace->entry_time)
		duration = sample->time - ttrace->entry_time;

	update_stats(stats, duration);
}

1464 1465 1466 1467 1468 1469 1470 1471 1472 1473 1474 1475 1476 1477 1478 1479
static int trace__printf_interrupted_entry(struct trace *trace, struct perf_sample *sample)
{
	struct thread_trace *ttrace;
	u64 duration;
	size_t printed;

	if (trace->current == NULL)
		return 0;

	ttrace = thread__priv(trace->current);

	if (!ttrace->entry_pending)
		return 0;

	duration = sample->time - ttrace->entry_time;

1480
	printed  = trace__fprintf_entry_head(trace, trace->current, duration, true, ttrace->entry_time, trace->output);
1481 1482 1483 1484 1485 1486
	printed += fprintf(trace->output, "%-70s) ...\n", ttrace->entry_str);
	ttrace->entry_pending = false;

	return printed;
}

1487
static int trace__sys_enter(struct trace *trace, struct perf_evsel *evsel,
1488
			    union perf_event *event __maybe_unused,
1489 1490
			    struct perf_sample *sample)
{
1491
	char *msg;
1492
	void *args;
1493
	size_t printed = 0;
1494
	struct thread *thread;
1495
	int id = perf_evsel__sc_tp_uint(evsel, id, sample), err = -1;
1496
	struct syscall *sc = trace__syscall_info(trace, evsel, id);
1497 1498 1499 1500
	struct thread_trace *ttrace;

	if (sc == NULL)
		return -1;
1501

1502
	thread = machine__findnew_thread(trace->host, sample->pid, sample->tid);
1503
	ttrace = thread__trace(thread, trace->output);
1504
	if (ttrace == NULL)
1505
		goto out_put;
1506

1507
	args = perf_evsel__sc_tp_ptr(evsel, args, sample);
1508 1509

	if (ttrace->entry_str == NULL) {
1510
		ttrace->entry_str = malloc(trace__entry_str_size);
1511
		if (!ttrace->entry_str)
1512
			goto out_put;
1513 1514
	}

1515
	if (!(trace->duration_filter || trace->summary_only || trace->min_stack))
1516
		trace__printf_interrupted_entry(trace, sample);
1517

1518 1519
	ttrace->entry_time = sample->time;
	msg = ttrace->entry_str;
1520
	printed += scnprintf(msg + printed, trace__entry_str_size - printed, "%s(", sc->name);
1521

1522
	printed += syscall__scnprintf_args(sc, msg + printed, trace__entry_str_size - printed,
1523
					   args, trace, thread);
1524

1525
	if (sc->is_exit) {
1526
		if (!(trace->duration_filter || trace->summary_only || trace->min_stack)) {
1527
			trace__fprintf_entry_head(trace, thread, 0, false, ttrace->entry_time, trace->output);
1528
			fprintf(trace->output, "%-70s)\n", ttrace->entry_str);
1529
		}
1530
	} else {
1531
		ttrace->entry_pending = true;
1532 1533 1534
		/* See trace__vfs_getname & trace__sys_exit */
		ttrace->filename.pending_open = false;
	}
1535

1536 1537 1538 1539
	if (trace->current != thread) {
		thread__put(trace->current);
		trace->current = thread__get(thread);
	}
1540 1541 1542 1543
	err = 0;
out_put:
	thread__put(thread);
	return err;
1544 1545
}

1546 1547 1548
static int trace__resolve_callchain(struct trace *trace, struct perf_evsel *evsel,
				    struct perf_sample *sample,
				    struct callchain_cursor *cursor)
1549 1550
{
	struct addr_location al;
1551 1552 1553 1554 1555 1556 1557 1558 1559 1560

	if (machine__resolve(trace->host, &al, sample) < 0 ||
	    thread__resolve_callchain(al.thread, cursor, evsel, sample, NULL, NULL, trace->max_stack))
		return -1;

	return 0;
}

static int trace__fprintf_callchain(struct trace *trace, struct perf_sample *sample)
{
1561
	/* TODO: user-configurable print_opts */
1562 1563 1564
	const unsigned int print_opts = EVSEL__PRINT_SYM |
				        EVSEL__PRINT_DSO |
				        EVSEL__PRINT_UNKNOWN_AS_ADDR;
1565

1566
	return sample__fprintf_callchain(sample, 38, print_opts, &callchain_cursor, trace->output);
1567 1568
}

1569
static int trace__sys_exit(struct trace *trace, struct perf_evsel *evsel,
1570
			   union perf_event *event __maybe_unused,
1571 1572
			   struct perf_sample *sample)
{
1573
	long ret;
1574
	u64 duration = 0;
1575
	bool duration_calculated = false;
1576
	struct thread *thread;
1577
	int id = perf_evsel__sc_tp_uint(evsel, id, sample), err = -1, callchain_ret = 0;
1578
	struct syscall *sc = trace__syscall_info(trace, evsel, id);
1579 1580 1581 1582
	struct thread_trace *ttrace;

	if (sc == NULL)
		return -1;
1583

1584
	thread = machine__findnew_thread(trace->host, sample->pid, sample->tid);
1585
	ttrace = thread__trace(thread, trace->output);
1586
	if (ttrace == NULL)
1587
		goto out_put;
1588

1589 1590 1591
	if (trace->summary)
		thread__update_stats(ttrace, id, sample);

1592
	ret = perf_evsel__sc_tp_uint(evsel, ret, sample);
1593

1594
	if (id == trace->open_id && ret >= 0 && ttrace->filename.pending_open) {
1595 1596
		trace__set_fd_pathname(thread, ret, ttrace->filename.name);
		ttrace->filename.pending_open = false;
1597 1598 1599
		++trace->stats.vfs_getname;
	}

1600
	if (ttrace->entry_time) {
1601
		duration = sample->time - ttrace->entry_time;
1602 1603
		if (trace__filter_duration(trace, duration))
			goto out;
1604
		duration_calculated = true;
1605 1606
	} else if (trace->duration_filter)
		goto out;
1607

1608 1609 1610 1611 1612 1613 1614 1615 1616
	if (sample->callchain) {
		callchain_ret = trace__resolve_callchain(trace, evsel, sample, &callchain_cursor);
		if (callchain_ret == 0) {
			if (callchain_cursor.nr < trace->min_stack)
				goto out;
			callchain_ret = 1;
		}
	}

D
David Ahern 已提交
1617 1618 1619
	if (trace->summary_only)
		goto out;

1620
	trace__fprintf_entry_head(trace, thread, duration, duration_calculated, ttrace->entry_time, trace->output);
1621 1622

	if (ttrace->entry_pending) {
1623
		fprintf(trace->output, "%-70s", ttrace->entry_str);
1624
	} else {
1625 1626 1627
		fprintf(trace->output, " ... [");
		color_fprintf(trace->output, PERF_COLOR_YELLOW, "continued");
		fprintf(trace->output, "]: %s()", sc->name);
1628 1629
	}

1630 1631
	if (sc->fmt == NULL) {
signed_print:
1632
		fprintf(trace->output, ") = %ld", ret);
1633
	} else if (ret < 0 && (sc->fmt->errmsg || sc->fmt->errpid)) {
1634
		char bf[STRERR_BUFSIZE];
1635
		const char *emsg = str_error_r(-ret, bf, sizeof(bf)),
1636 1637
			   *e = audit_errno_to_name(-ret);

1638
		fprintf(trace->output, ") = -1 %s %s", e, emsg);
1639
	} else if (ret == 0 && sc->fmt->timeout)
1640
		fprintf(trace->output, ") = 0 Timeout");
1641
	else if (sc->fmt->hexret)
1642
		fprintf(trace->output, ") = %#lx", ret);
1643 1644 1645 1646 1647 1648 1649 1650 1651 1652
	else if (sc->fmt->errpid) {
		struct thread *child = machine__find_thread(trace->host, ret, ret);

		if (child != NULL) {
			fprintf(trace->output, ") = %ld", ret);
			if (child->comm_set)
				fprintf(trace->output, " (%s)", thread__comm_str(child));
			thread__put(child);
		}
	} else
1653
		goto signed_print;
1654

1655
	fputc('\n', trace->output);
1656

1657 1658 1659 1660
	if (callchain_ret > 0)
		trace__fprintf_callchain(trace, sample);
	else if (callchain_ret < 0)
		pr_err("Problem processing %s callchain, skipping...\n", perf_evsel__name(evsel));
1661
out:
1662
	ttrace->entry_pending = false;
1663 1664 1665 1666
	err = 0;
out_put:
	thread__put(thread);
	return err;
1667 1668
}

1669
static int trace__vfs_getname(struct trace *trace, struct perf_evsel *evsel,
1670
			      union perf_event *event __maybe_unused,
1671 1672
			      struct perf_sample *sample)
{
1673 1674 1675 1676 1677
	struct thread *thread = machine__findnew_thread(trace->host, sample->pid, sample->tid);
	struct thread_trace *ttrace;
	size_t filename_len, entry_str_len, to_move;
	ssize_t remaining_space;
	char *pos;
1678
	const char *filename = perf_evsel__rawptr(evsel, sample, "pathname");
1679 1680 1681 1682 1683 1684

	if (!thread)
		goto out;

	ttrace = thread__priv(thread);
	if (!ttrace)
1685
		goto out_put;
1686

1687
	filename_len = strlen(filename);
1688
	if (filename_len == 0)
1689
		goto out_put;
1690 1691 1692 1693 1694

	if (ttrace->filename.namelen < filename_len) {
		char *f = realloc(ttrace->filename.name, filename_len + 1);

		if (f == NULL)
1695
			goto out_put;
1696 1697 1698 1699 1700 1701 1702 1703

		ttrace->filename.namelen = filename_len;
		ttrace->filename.name = f;
	}

	strcpy(ttrace->filename.name, filename);
	ttrace->filename.pending_open = true;

1704
	if (!ttrace->filename.ptr)
1705
		goto out_put;
1706 1707 1708 1709

	entry_str_len = strlen(ttrace->entry_str);
	remaining_space = trace__entry_str_size - entry_str_len - 1; /* \0 */
	if (remaining_space <= 0)
1710
		goto out_put;
1711 1712 1713 1714 1715 1716 1717 1718 1719 1720 1721 1722 1723

	if (filename_len > (size_t)remaining_space) {
		filename += filename_len - remaining_space;
		filename_len = remaining_space;
	}

	to_move = entry_str_len - ttrace->filename.entry_str_pos + 1; /* \0 */
	pos = ttrace->entry_str + ttrace->filename.entry_str_pos;
	memmove(pos + filename_len, pos, to_move);
	memcpy(pos, filename, filename_len);

	ttrace->filename.ptr = 0;
	ttrace->filename.entry_str_pos = 0;
1724 1725
out_put:
	thread__put(thread);
1726
out:
1727 1728 1729
	return 0;
}

1730
static int trace__sched_stat_runtime(struct trace *trace, struct perf_evsel *evsel,
1731
				     union perf_event *event __maybe_unused,
1732 1733 1734 1735
				     struct perf_sample *sample)
{
        u64 runtime = perf_evsel__intval(evsel, sample, "runtime");
	double runtime_ms = (double)runtime / NSEC_PER_MSEC;
1736
	struct thread *thread = machine__findnew_thread(trace->host,
1737 1738
							sample->pid,
							sample->tid);
1739
	struct thread_trace *ttrace = thread__trace(thread, trace->output);
1740 1741 1742 1743 1744 1745

	if (ttrace == NULL)
		goto out_dump;

	ttrace->runtime_ms += runtime_ms;
	trace->runtime_ms += runtime_ms;
1746
out_put:
1747
	thread__put(thread);
1748 1749 1750
	return 0;

out_dump:
1751
	fprintf(trace->output, "%s: comm=%s,pid=%u,runtime=%" PRIu64 ",vruntime=%" PRIu64 ")\n",
1752 1753 1754 1755 1756
	       evsel->name,
	       perf_evsel__strval(evsel, sample, "comm"),
	       (pid_t)perf_evsel__intval(evsel, sample, "pid"),
	       runtime,
	       perf_evsel__intval(evsel, sample, "vruntime"));
1757
	goto out_put;
1758 1759
}

1760 1761 1762 1763 1764 1765 1766 1767 1768 1769 1770 1771 1772 1773 1774 1775 1776 1777 1778 1779 1780 1781 1782 1783 1784 1785 1786 1787 1788 1789 1790
static void bpf_output__printer(enum binary_printer_ops op,
				unsigned int val, void *extra)
{
	FILE *output = extra;
	unsigned char ch = (unsigned char)val;

	switch (op) {
	case BINARY_PRINT_CHAR_DATA:
		fprintf(output, "%c", isprint(ch) ? ch : '.');
		break;
	case BINARY_PRINT_DATA_BEGIN:
	case BINARY_PRINT_LINE_BEGIN:
	case BINARY_PRINT_ADDR:
	case BINARY_PRINT_NUM_DATA:
	case BINARY_PRINT_NUM_PAD:
	case BINARY_PRINT_SEP:
	case BINARY_PRINT_CHAR_PAD:
	case BINARY_PRINT_LINE_END:
	case BINARY_PRINT_DATA_END:
	default:
		break;
	}
}

static void bpf_output__fprintf(struct trace *trace,
				struct perf_sample *sample)
{
	print_binary(sample->raw_data, sample->raw_size, 8,
		     bpf_output__printer, trace->output);
}

1791 1792 1793 1794
static int trace__event_handler(struct trace *trace, struct perf_evsel *evsel,
				union perf_event *event __maybe_unused,
				struct perf_sample *sample)
{
1795 1796 1797 1798 1799 1800 1801 1802 1803 1804 1805
	int callchain_ret = 0;

	if (sample->callchain) {
		callchain_ret = trace__resolve_callchain(trace, evsel, sample, &callchain_cursor);
		if (callchain_ret == 0) {
			if (callchain_cursor.nr < trace->min_stack)
				goto out;
			callchain_ret = 1;
		}
	}

1806 1807
	trace__printf_interrupted_entry(trace, sample);
	trace__fprintf_tstamp(trace, sample->time, trace->output);
1808 1809 1810 1811 1812

	if (trace->trace_syscalls)
		fprintf(trace->output, "(         ): ");

	fprintf(trace->output, "%s:", evsel->name);
1813

1814 1815 1816
	if (perf_evsel__is_bpf_output(evsel)) {
		bpf_output__fprintf(trace, sample);
	} else if (evsel->tp_format) {
1817 1818 1819 1820 1821 1822
		event_format__fprintf(evsel->tp_format, sample->cpu,
				      sample->raw_data, sample->raw_size,
				      trace->output);
	}

	fprintf(trace->output, ")\n");
1823

1824 1825 1826 1827 1828
	if (callchain_ret > 0)
		trace__fprintf_callchain(trace, sample);
	else if (callchain_ret < 0)
		pr_err("Problem processing %s callchain, skipping...\n", perf_evsel__name(evsel));
out:
1829 1830 1831
	return 0;
}

1832 1833 1834 1835 1836
static void print_location(FILE *f, struct perf_sample *sample,
			   struct addr_location *al,
			   bool print_dso, bool print_sym)
{

1837
	if ((verbose > 0 || print_dso) && al->map)
1838 1839
		fprintf(f, "%s@", al->map->dso->long_name);

1840
	if ((verbose > 0 || print_sym) && al->sym)
1841
		fprintf(f, "%s+0x%" PRIx64, al->sym->name,
1842 1843
			al->addr - al->sym->start);
	else if (al->map)
1844
		fprintf(f, "0x%" PRIx64, al->addr);
1845
	else
1846
		fprintf(f, "0x%" PRIx64, sample->addr);
1847 1848 1849 1850
}

static int trace__pgfault(struct trace *trace,
			  struct perf_evsel *evsel,
1851
			  union perf_event *event __maybe_unused,
1852 1853 1854 1855 1856
			  struct perf_sample *sample)
{
	struct thread *thread;
	struct addr_location al;
	char map_type = 'd';
1857
	struct thread_trace *ttrace;
1858
	int err = -1;
1859
	int callchain_ret = 0;
1860 1861

	thread = machine__findnew_thread(trace->host, sample->pid, sample->tid);
1862 1863 1864 1865 1866 1867 1868 1869 1870 1871

	if (sample->callchain) {
		callchain_ret = trace__resolve_callchain(trace, evsel, sample, &callchain_cursor);
		if (callchain_ret == 0) {
			if (callchain_cursor.nr < trace->min_stack)
				goto out_put;
			callchain_ret = 1;
		}
	}

1872 1873
	ttrace = thread__trace(thread, trace->output);
	if (ttrace == NULL)
1874
		goto out_put;
1875 1876 1877 1878 1879 1880 1881

	if (evsel->attr.config == PERF_COUNT_SW_PAGE_FAULTS_MAJ)
		ttrace->pfmaj++;
	else
		ttrace->pfmin++;

	if (trace->summary_only)
1882
		goto out;
1883

1884
	thread__find_addr_location(thread, sample->cpumode, MAP__FUNCTION,
1885 1886
			      sample->ip, &al);

1887
	trace__fprintf_entry_head(trace, thread, 0, true, sample->time, trace->output);
1888 1889 1890 1891 1892 1893 1894 1895 1896

	fprintf(trace->output, "%sfault [",
		evsel->attr.config == PERF_COUNT_SW_PAGE_FAULTS_MAJ ?
		"maj" : "min");

	print_location(trace->output, sample, &al, false, true);

	fprintf(trace->output, "] => ");

1897
	thread__find_addr_location(thread, sample->cpumode, MAP__VARIABLE,
1898 1899 1900
				   sample->addr, &al);

	if (!al.map) {
1901
		thread__find_addr_location(thread, sample->cpumode,
1902 1903 1904 1905 1906 1907 1908 1909 1910 1911 1912
					   MAP__FUNCTION, sample->addr, &al);

		if (al.map)
			map_type = 'x';
		else
			map_type = '?';
	}

	print_location(trace->output, sample, &al, true, false);

	fprintf(trace->output, " (%c%c)\n", map_type, al.level);
1913

1914 1915 1916 1917
	if (callchain_ret > 0)
		trace__fprintf_callchain(trace, sample);
	else if (callchain_ret < 0)
		pr_err("Problem processing %s callchain, skipping...\n", perf_evsel__name(evsel));
1918 1919 1920 1921 1922
out:
	err = 0;
out_put:
	thread__put(thread);
	return err;
1923 1924
}

1925
static void trace__set_base_time(struct trace *trace,
1926
				 struct perf_evsel *evsel,
1927 1928
				 struct perf_sample *sample)
{
1929 1930 1931 1932 1933 1934 1935 1936 1937 1938
	/*
	 * BPF events were not setting PERF_SAMPLE_TIME, so be more robust
	 * and don't use sample->time unconditionally, we may end up having
	 * some other event in the future without PERF_SAMPLE_TIME for good
	 * reason, i.e. we may not be interested in its timestamps, just in
	 * it taking place, picking some piece of information when it
	 * appears in our event stream (vfs_getname comes to mind).
	 */
	if (trace->base_time == 0 && !trace->full_time &&
	    (evsel->attr.sample_type & PERF_SAMPLE_TIME))
1939 1940 1941
		trace->base_time = sample->time;
}

1942
static int trace__process_sample(struct perf_tool *tool,
1943
				 union perf_event *event,
1944 1945 1946 1947 1948
				 struct perf_sample *sample,
				 struct perf_evsel *evsel,
				 struct machine *machine __maybe_unused)
{
	struct trace *trace = container_of(tool, struct trace, tool);
1949
	struct thread *thread;
1950 1951
	int err = 0;

1952
	tracepoint_handler handler = evsel->handler;
1953

1954 1955
	thread = machine__findnew_thread(trace->host, sample->pid, sample->tid);
	if (thread && thread__is_filtered(thread))
1956
		goto out;
1957

1958
	trace__set_base_time(trace, evsel, sample);
1959

1960 1961
	if (handler) {
		++trace->nr_events;
1962
		handler(trace, evsel, event, sample);
1963
	}
1964 1965
out:
	thread__put(thread);
1966 1967 1968
	return err;
}

1969
static int trace__record(struct trace *trace, int argc, const char **argv)
D
David Ahern 已提交
1970 1971 1972 1973 1974 1975 1976 1977 1978 1979
{
	unsigned int rec_argc, i, j;
	const char **rec_argv;
	const char * const record_args[] = {
		"record",
		"-R",
		"-m", "1024",
		"-c", "1",
	};

1980 1981 1982 1983 1984 1985 1986
	const char * const sc_args[] = { "-e", };
	unsigned int sc_args_nr = ARRAY_SIZE(sc_args);
	const char * const majpf_args[] = { "-e", "major-faults" };
	unsigned int majpf_args_nr = ARRAY_SIZE(majpf_args);
	const char * const minpf_args[] = { "-e", "minor-faults" };
	unsigned int minpf_args_nr = ARRAY_SIZE(minpf_args);

1987
	/* +1 is for the event string below */
1988 1989
	rec_argc = ARRAY_SIZE(record_args) + sc_args_nr + 1 +
		majpf_args_nr + minpf_args_nr + argc;
D
David Ahern 已提交
1990 1991 1992 1993 1994
	rec_argv = calloc(rec_argc + 1, sizeof(char *));

	if (rec_argv == NULL)
		return -ENOMEM;

1995
	j = 0;
D
David Ahern 已提交
1996
	for (i = 0; i < ARRAY_SIZE(record_args); i++)
1997 1998
		rec_argv[j++] = record_args[i];

1999 2000 2001 2002 2003 2004 2005 2006 2007 2008 2009 2010 2011
	if (trace->trace_syscalls) {
		for (i = 0; i < sc_args_nr; i++)
			rec_argv[j++] = sc_args[i];

		/* event string may be different for older kernels - e.g., RHEL6 */
		if (is_valid_tracepoint("raw_syscalls:sys_enter"))
			rec_argv[j++] = "raw_syscalls:sys_enter,raw_syscalls:sys_exit";
		else if (is_valid_tracepoint("syscalls:sys_enter"))
			rec_argv[j++] = "syscalls:sys_enter,syscalls:sys_exit";
		else {
			pr_err("Neither raw_syscalls nor syscalls events exist.\n");
			return -1;
		}
2012 2013
	}

2014 2015 2016 2017 2018 2019 2020 2021 2022 2023
	if (trace->trace_pgfaults & TRACE_PFMAJ)
		for (i = 0; i < majpf_args_nr; i++)
			rec_argv[j++] = majpf_args[i];

	if (trace->trace_pgfaults & TRACE_PFMIN)
		for (i = 0; i < minpf_args_nr; i++)
			rec_argv[j++] = minpf_args[i];

	for (i = 0; i < (unsigned int)argc; i++)
		rec_argv[j++] = argv[i];
D
David Ahern 已提交
2024

2025
	return cmd_record(j, rec_argv);
D
David Ahern 已提交
2026 2027
}

2028 2029
static size_t trace__fprintf_thread_summary(struct trace *trace, FILE *fp);

2030
static bool perf_evlist__add_vfs_getname(struct perf_evlist *evlist)
2031
{
2032
	struct perf_evsel *evsel = perf_evsel__newtp("probe", "vfs_getname");
2033 2034

	if (IS_ERR(evsel))
2035
		return false;
2036 2037 2038

	if (perf_evsel__field(evsel, "pathname") == NULL) {
		perf_evsel__delete(evsel);
2039
		return false;
2040 2041
	}

2042
	evsel->handler = trace__vfs_getname;
2043
	perf_evlist__add(evlist, evsel);
2044
	return true;
2045 2046
}

2047
static struct perf_evsel *perf_evsel__new_pgfault(u64 config)
2048 2049 2050 2051 2052 2053 2054 2055
{
	struct perf_evsel *evsel;
	struct perf_event_attr attr = {
		.type = PERF_TYPE_SOFTWARE,
		.mmap_data = 1,
	};

	attr.config = config;
2056
	attr.sample_period = 1;
2057 2058 2059 2060

	event_attr_init(&attr);

	evsel = perf_evsel__new(&attr);
2061 2062
	if (evsel)
		evsel->handler = trace__pgfault;
2063

2064
	return evsel;
2065 2066
}

2067 2068 2069 2070 2071 2072 2073 2074 2075 2076 2077 2078 2079 2080 2081 2082
static void trace__handle_event(struct trace *trace, union perf_event *event, struct perf_sample *sample)
{
	const u32 type = event->header.type;
	struct perf_evsel *evsel;

	if (type != PERF_RECORD_SAMPLE) {
		trace__process_event(trace, trace->host, event, sample);
		return;
	}

	evsel = perf_evlist__id2evsel(trace->evlist, sample->id);
	if (evsel == NULL) {
		fprintf(trace->output, "Unknown tp ID %" PRIu64 ", skipping...\n", sample->id);
		return;
	}

2083 2084
	trace__set_base_time(trace, evsel, sample);

2085 2086 2087 2088 2089 2090 2091 2092 2093 2094 2095
	if (evsel->attr.type == PERF_TYPE_TRACEPOINT &&
	    sample->raw_data == NULL) {
		fprintf(trace->output, "%s sample with no payload for tid: %d, cpu %d, raw_size=%d, skipping...\n",
		       perf_evsel__name(evsel), sample->tid,
		       sample->cpu, sample->raw_size);
	} else {
		tracepoint_handler handler = evsel->handler;
		handler(trace, evsel, event, sample);
	}
}

2096 2097 2098 2099 2100 2101 2102 2103 2104 2105 2106 2107 2108 2109 2110 2111 2112 2113 2114 2115 2116 2117 2118
static int trace__add_syscall_newtp(struct trace *trace)
{
	int ret = -1;
	struct perf_evlist *evlist = trace->evlist;
	struct perf_evsel *sys_enter, *sys_exit;

	sys_enter = perf_evsel__syscall_newtp("sys_enter", trace__sys_enter);
	if (sys_enter == NULL)
		goto out;

	if (perf_evsel__init_sc_tp_ptr_field(sys_enter, args))
		goto out_delete_sys_enter;

	sys_exit = perf_evsel__syscall_newtp("sys_exit", trace__sys_exit);
	if (sys_exit == NULL)
		goto out_delete_sys_enter;

	if (perf_evsel__init_sc_tp_uint_field(sys_exit, ret))
		goto out_delete_sys_exit;

	perf_evlist__add(evlist, sys_enter);
	perf_evlist__add(evlist, sys_exit);

2119
	if (callchain_param.enabled && !trace->kernel_syscallchains) {
2120 2121 2122 2123 2124 2125 2126 2127
		/*
		 * We're interested only in the user space callchain
		 * leading to the syscall, allow overriding that for
		 * debugging reasons using --kernel_syscall_callchains
		 */
		sys_exit->attr.exclude_callchain_kernel = 1;
	}

2128 2129
	trace->syscalls.events.sys_enter = sys_enter;
	trace->syscalls.events.sys_exit  = sys_exit;
2130 2131 2132 2133 2134 2135 2136 2137 2138 2139 2140 2141

	ret = 0;
out:
	return ret;

out_delete_sys_exit:
	perf_evsel__delete_priv(sys_exit);
out_delete_sys_enter:
	perf_evsel__delete_priv(sys_enter);
	goto out;
}

2142 2143 2144
static int trace__set_ev_qualifier_filter(struct trace *trace)
{
	int err = -1;
2145
	struct perf_evsel *sys_exit;
2146 2147 2148 2149 2150 2151 2152
	char *filter = asprintf_expr_inout_ints("id", !trace->not_ev_qualifier,
						trace->ev_qualifier_ids.nr,
						trace->ev_qualifier_ids.entries);

	if (filter == NULL)
		goto out_enomem;

2153 2154
	if (!perf_evsel__append_tp_filter(trace->syscalls.events.sys_enter,
					  filter)) {
2155
		sys_exit = trace->syscalls.events.sys_exit;
2156
		err = perf_evsel__append_tp_filter(sys_exit, filter);
2157
	}
2158 2159 2160 2161 2162 2163 2164 2165

	free(filter);
out:
	return err;
out_enomem:
	errno = ENOMEM;
	goto out;
}
2166

2167
static int trace__run(struct trace *trace, int argc, const char **argv)
A
Arnaldo Carvalho de Melo 已提交
2168
{
2169
	struct perf_evlist *evlist = trace->evlist;
2170
	struct perf_evsel *evsel, *pgfault_maj = NULL, *pgfault_min = NULL;
2171 2172
	int err = -1, i;
	unsigned long before;
2173
	const bool forks = argc > 0;
2174
	bool draining = false;
A
Arnaldo Carvalho de Melo 已提交
2175

2176 2177
	trace->live = true;

2178
	if (trace->trace_syscalls && trace__add_syscall_newtp(trace))
2179
		goto out_error_raw_syscalls;
A
Arnaldo Carvalho de Melo 已提交
2180

2181
	if (trace->trace_syscalls)
2182
		trace->vfs_getname = perf_evlist__add_vfs_getname(evlist);
2183

2184 2185 2186 2187 2188
	if ((trace->trace_pgfaults & TRACE_PFMAJ)) {
		pgfault_maj = perf_evsel__new_pgfault(PERF_COUNT_SW_PAGE_FAULTS_MAJ);
		if (pgfault_maj == NULL)
			goto out_error_mem;
		perf_evlist__add(evlist, pgfault_maj);
2189
	}
2190

2191 2192 2193 2194 2195 2196
	if ((trace->trace_pgfaults & TRACE_PFMIN)) {
		pgfault_min = perf_evsel__new_pgfault(PERF_COUNT_SW_PAGE_FAULTS_MIN);
		if (pgfault_min == NULL)
			goto out_error_mem;
		perf_evlist__add(evlist, pgfault_min);
	}
2197

2198
	if (trace->sched &&
2199 2200 2201
	    perf_evlist__add_newtp(evlist, "sched", "sched_stat_runtime",
				   trace__sched_stat_runtime))
		goto out_error_sched_stat_runtime;
2202

A
Arnaldo Carvalho de Melo 已提交
2203 2204
	err = perf_evlist__create_maps(evlist, &trace->opts.target);
	if (err < 0) {
2205
		fprintf(trace->output, "Problems parsing the target to trace, check your options!\n");
A
Arnaldo Carvalho de Melo 已提交
2206 2207 2208
		goto out_delete_evlist;
	}

2209 2210
	err = trace__symbols_init(trace, evlist);
	if (err < 0) {
2211
		fprintf(trace->output, "Problems initializing symbol libraries!\n");
2212
		goto out_delete_evlist;
2213 2214
	}

2215 2216
	perf_evlist__config(evlist, &trace->opts, NULL);

2217 2218 2219 2220 2221 2222 2223 2224 2225 2226 2227 2228 2229 2230 2231 2232 2233 2234 2235 2236 2237 2238 2239 2240 2241 2242 2243 2244 2245 2246 2247 2248 2249 2250 2251 2252
	if (callchain_param.enabled) {
		bool use_identifier = false;

		if (trace->syscalls.events.sys_exit) {
			perf_evsel__config_callchain(trace->syscalls.events.sys_exit,
						     &trace->opts, &callchain_param);
			use_identifier = true;
		}

		if (pgfault_maj) {
			perf_evsel__config_callchain(pgfault_maj, &trace->opts, &callchain_param);
			use_identifier = true;
		}

		if (pgfault_min) {
			perf_evsel__config_callchain(pgfault_min, &trace->opts, &callchain_param);
			use_identifier = true;
		}

		if (use_identifier) {
		       /*
			* Now we have evsels with different sample_ids, use
			* PERF_SAMPLE_IDENTIFIER to map from sample to evsel
			* from a fixed position in each ring buffer record.
			*
			* As of this the changeset introducing this comment, this
			* isn't strictly needed, as the fields that can come before
			* PERF_SAMPLE_ID are all used, but we'll probably disable
			* some of those for things like copying the payload of
			* pointer syscall arguments, and for vfs_getname we don't
			* need PERF_SAMPLE_ADDR and PERF_SAMPLE_IP, so do this
			* here as a warning we need to use PERF_SAMPLE_IDENTIFIER.
			*/
			perf_evlist__set_sample_bit(evlist, IDENTIFIER);
			perf_evlist__reset_sample_bit(evlist, ID);
		}
2253
	}
A
Arnaldo Carvalho de Melo 已提交
2254

2255 2256 2257 2258
	signal(SIGCHLD, sig_handler);
	signal(SIGINT, sig_handler);

	if (forks) {
2259
		err = perf_evlist__prepare_workload(evlist, &trace->opts.target,
2260
						    argv, false, NULL);
2261
		if (err < 0) {
2262
			fprintf(trace->output, "Couldn't run the workload!\n");
2263
			goto out_delete_evlist;
2264 2265 2266
		}
	}

A
Arnaldo Carvalho de Melo 已提交
2267
	err = perf_evlist__open(evlist);
2268 2269
	if (err < 0)
		goto out_error_open;
A
Arnaldo Carvalho de Melo 已提交
2270

2271 2272 2273 2274 2275 2276 2277 2278 2279 2280
	err = bpf__apply_obj_config();
	if (err) {
		char errbuf[BUFSIZ];

		bpf__strerror_apply_obj_config(err, errbuf, sizeof(errbuf));
		pr_err("ERROR: Apply config to BPF failed: %s\n",
			 errbuf);
		goto out_error_open;
	}

2281 2282 2283 2284 2285 2286
	/*
	 * Better not use !target__has_task() here because we need to cover the
	 * case where no threads were specified in the command line, but a
	 * workload was, and in that case we will fill in the thread_map when
	 * we fork the workload in perf_evlist__prepare_workload.
	 */
2287 2288
	if (trace->filter_pids.nr > 0)
		err = perf_evlist__set_filter_pids(evlist, trace->filter_pids.nr, trace->filter_pids.entries);
2289
	else if (thread_map__pid(evlist->threads, 0) == -1)
2290 2291
		err = perf_evlist__set_filter_pid(evlist, getpid());

2292 2293 2294
	if (err < 0)
		goto out_error_mem;

2295 2296 2297 2298 2299
	if (trace->ev_qualifier_ids.nr > 0) {
		err = trace__set_ev_qualifier_filter(trace);
		if (err < 0)
			goto out_errno;

2300 2301 2302
		pr_debug("event qualifier tracepoint filter: %s\n",
			 trace->syscalls.events.sys_exit->filter);
	}
2303

2304 2305 2306
	err = perf_evlist__apply_filters(evlist, &evsel);
	if (err < 0)
		goto out_error_apply_filters;
2307

J
Jiri Olsa 已提交
2308
	err = perf_evlist__mmap(evlist, trace->opts.mmap_pages, false);
2309 2310
	if (err < 0)
		goto out_error_mmap;
A
Arnaldo Carvalho de Melo 已提交
2311

A
Alexis Berlemont 已提交
2312
	if (!target__none(&trace->opts.target) && !trace->opts.initial_delay)
2313 2314
		perf_evlist__enable(evlist);

2315 2316 2317
	if (forks)
		perf_evlist__start_workload(evlist);

A
Alexis Berlemont 已提交
2318 2319 2320 2321 2322
	if (trace->opts.initial_delay) {
		usleep(trace->opts.initial_delay * 1000);
		perf_evlist__enable(evlist);
	}

2323
	trace->multiple_threads = thread_map__pid(evlist->threads, 0) == -1 ||
2324 2325
				  evlist->threads->nr > 1 ||
				  perf_evlist__first(evlist)->attr.inherit;
A
Arnaldo Carvalho de Melo 已提交
2326
again:
2327
	before = trace->nr_events;
A
Arnaldo Carvalho de Melo 已提交
2328 2329 2330 2331 2332 2333 2334

	for (i = 0; i < evlist->nr_mmaps; i++) {
		union perf_event *event;

		while ((event = perf_evlist__mmap_read(evlist, i)) != NULL) {
			struct perf_sample sample;

2335
			++trace->nr_events;
A
Arnaldo Carvalho de Melo 已提交
2336 2337 2338

			err = perf_evlist__parse_sample(evlist, event, &sample);
			if (err) {
2339
				fprintf(trace->output, "Can't parse sample, err = %d, skipping...\n", err);
2340
				goto next_event;
A
Arnaldo Carvalho de Melo 已提交
2341 2342
			}

2343
			trace__handle_event(trace, event, &sample);
2344 2345
next_event:
			perf_evlist__mmap_consume(evlist, i);
2346

2347 2348
			if (interrupted)
				goto out_disable;
2349 2350 2351 2352 2353

			if (done && !draining) {
				perf_evlist__disable(evlist);
				draining = true;
			}
A
Arnaldo Carvalho de Melo 已提交
2354 2355 2356
		}
	}

2357
	if (trace->nr_events == before) {
2358
		int timeout = done ? 100 : -1;
2359

2360 2361 2362 2363
		if (!draining && perf_evlist__poll(evlist, timeout) > 0) {
			if (perf_evlist__filter_pollfd(evlist, POLLERR | POLLHUP) == 0)
				draining = true;

2364
			goto again;
2365
		}
2366 2367
	} else {
		goto again;
2368 2369
	}

2370
out_disable:
2371 2372
	thread__zput(trace->current);

2373
	perf_evlist__disable(evlist);
A
Arnaldo Carvalho de Melo 已提交
2374

2375 2376 2377 2378 2379 2380 2381 2382 2383 2384 2385 2386
	if (!err) {
		if (trace->summary)
			trace__fprintf_thread_summary(trace, trace->output);

		if (trace->show_tool_stats) {
			fprintf(trace->output, "Stats:\n "
					       " vfs_getname : %" PRIu64 "\n"
					       " proc_getname: %" PRIu64 "\n",
				trace->stats.vfs_getname,
				trace->stats.proc_getname);
		}
	}
2387

A
Arnaldo Carvalho de Melo 已提交
2388 2389
out_delete_evlist:
	perf_evlist__delete(evlist);
2390
	trace->evlist = NULL;
2391
	trace->live = false;
A
Arnaldo Carvalho de Melo 已提交
2392
	return err;
2393 2394
{
	char errbuf[BUFSIZ];
2395

2396
out_error_sched_stat_runtime:
2397
	tracing_path__strerror_open_tp(errno, errbuf, sizeof(errbuf), "sched", "sched_stat_runtime");
2398 2399
	goto out_error;

2400
out_error_raw_syscalls:
2401
	tracing_path__strerror_open_tp(errno, errbuf, sizeof(errbuf), "raw_syscalls", "sys_(enter|exit)");
2402 2403
	goto out_error;

2404 2405 2406 2407
out_error_mmap:
	perf_evlist__strerror_mmap(evlist, errno, errbuf, sizeof(errbuf));
	goto out_error;

2408 2409 2410 2411
out_error_open:
	perf_evlist__strerror_open(evlist, errno, errbuf, sizeof(errbuf));

out_error:
2412
	fprintf(trace->output, "%s\n", errbuf);
2413
	goto out_delete_evlist;
2414 2415 2416 2417 2418

out_error_apply_filters:
	fprintf(trace->output,
		"Failed to set filter \"%s\" on event %s with %d (%s)\n",
		evsel->filter, perf_evsel__name(evsel), errno,
2419
		str_error_r(errno, errbuf, sizeof(errbuf)));
2420
	goto out_delete_evlist;
A
Arnaldo Carvalho de Melo 已提交
2421
}
2422 2423 2424
out_error_mem:
	fprintf(trace->output, "Not enough memory to run!\n");
	goto out_delete_evlist;
2425 2426 2427 2428

out_errno:
	fprintf(trace->output, "errno=%d,%s\n", errno, strerror(errno));
	goto out_delete_evlist;
2429
}
A
Arnaldo Carvalho de Melo 已提交
2430

2431 2432 2433
static int trace__replay(struct trace *trace)
{
	const struct perf_evsel_str_handler handlers[] = {
2434
		{ "probe:vfs_getname",	     trace__vfs_getname, },
2435
	};
2436 2437 2438
	struct perf_data_file file = {
		.path  = input_name,
		.mode  = PERF_DATA_MODE_READ,
2439
		.force = trace->force,
2440
	};
2441
	struct perf_session *session;
2442
	struct perf_evsel *evsel;
2443 2444 2445 2446
	int err = -1;

	trace->tool.sample	  = trace__process_sample;
	trace->tool.mmap	  = perf_event__process_mmap;
D
David Ahern 已提交
2447
	trace->tool.mmap2	  = perf_event__process_mmap2;
2448 2449 2450 2451
	trace->tool.comm	  = perf_event__process_comm;
	trace->tool.exit	  = perf_event__process_exit;
	trace->tool.fork	  = perf_event__process_fork;
	trace->tool.attr	  = perf_event__process_attr;
2452
	trace->tool.tracing_data  = perf_event__process_tracing_data;
2453
	trace->tool.build_id	  = perf_event__process_build_id;
2454
	trace->tool.namespaces	  = perf_event__process_namespaces;
2455

2456
	trace->tool.ordered_events = true;
2457 2458 2459 2460 2461
	trace->tool.ordering_requires_timestamps = true;

	/* add tid to output */
	trace->multiple_threads = true;

2462
	session = perf_session__new(&file, false, &trace->tool);
2463
	if (session == NULL)
2464
		return -1;
2465

2466 2467 2468 2469 2470 2471
	if (trace->opts.target.pid)
		symbol_conf.pid_list_str = strdup(trace->opts.target.pid);

	if (trace->opts.target.tid)
		symbol_conf.tid_list_str = strdup(trace->opts.target.tid);

2472
	if (symbol__init(&session->header.env) < 0)
2473 2474
		goto out;

2475 2476
	trace->host = &session->machines.host;

2477 2478 2479 2480
	err = perf_session__set_tracepoints_handlers(session, handlers);
	if (err)
		goto out;

2481 2482
	evsel = perf_evlist__find_tracepoint_by_name(session->evlist,
						     "raw_syscalls:sys_enter");
2483 2484 2485 2486
	/* older kernels have syscalls tp versus raw_syscalls */
	if (evsel == NULL)
		evsel = perf_evlist__find_tracepoint_by_name(session->evlist,
							     "syscalls:sys_enter");
2487

2488 2489 2490
	if (evsel &&
	    (perf_evsel__init_syscall_tp(evsel, trace__sys_enter) < 0 ||
	    perf_evsel__init_sc_tp_ptr_field(evsel, args))) {
2491 2492 2493 2494 2495 2496
		pr_err("Error during initialize raw_syscalls:sys_enter event\n");
		goto out;
	}

	evsel = perf_evlist__find_tracepoint_by_name(session->evlist,
						     "raw_syscalls:sys_exit");
2497 2498 2499
	if (evsel == NULL)
		evsel = perf_evlist__find_tracepoint_by_name(session->evlist,
							     "syscalls:sys_exit");
2500 2501 2502
	if (evsel &&
	    (perf_evsel__init_syscall_tp(evsel, trace__sys_exit) < 0 ||
	    perf_evsel__init_sc_tp_uint_field(evsel, ret))) {
2503
		pr_err("Error during initialize raw_syscalls:sys_exit event\n");
2504 2505 2506
		goto out;
	}

2507
	evlist__for_each_entry(session->evlist, evsel) {
2508 2509 2510 2511 2512 2513 2514
		if (evsel->attr.type == PERF_TYPE_SOFTWARE &&
		    (evsel->attr.config == PERF_COUNT_SW_PAGE_FAULTS_MAJ ||
		     evsel->attr.config == PERF_COUNT_SW_PAGE_FAULTS_MIN ||
		     evsel->attr.config == PERF_COUNT_SW_PAGE_FAULTS))
			evsel->handler = trace__pgfault;
	}

2515 2516
	setup_pager();

2517
	err = perf_session__process_events(session);
2518 2519 2520
	if (err)
		pr_err("Failed to process events, error %d", err);

2521 2522 2523
	else if (trace->summary)
		trace__fprintf_thread_summary(trace, trace->output);

2524 2525 2526 2527 2528 2529
out:
	perf_session__delete(session);

	return err;
}

2530 2531 2532 2533
static size_t trace__fprintf_threads_header(FILE *fp)
{
	size_t printed;

2534
	printed  = fprintf(fp, "\n Summary of events:\n\n");
2535 2536 2537 2538

	return printed;
}

2539 2540 2541 2542 2543 2544 2545 2546 2547 2548 2549 2550 2551 2552
DEFINE_RESORT_RB(syscall_stats, a->msecs > b->msecs,
	struct stats 	*stats;
	double		msecs;
	int		syscall;
)
{
	struct int_node *source = rb_entry(nd, struct int_node, rb_node);
	struct stats *stats = source->priv;

	entry->syscall = source->i;
	entry->stats   = stats;
	entry->msecs   = stats ? (u64)stats->n * (avg_stats(stats) / NSEC_PER_MSEC) : 0;
}

2553 2554 2555 2556 2557
static size_t thread__dump_stats(struct thread_trace *ttrace,
				 struct trace *trace, FILE *fp)
{
	size_t printed = 0;
	struct syscall *sc;
2558 2559
	struct rb_node *nd;
	DECLARE_RESORT_RB_INTLIST(syscall_stats, ttrace->syscall_stats);
2560

2561
	if (syscall_stats == NULL)
2562 2563 2564 2565
		return 0;

	printed += fprintf(fp, "\n");

2566 2567 2568
	printed += fprintf(fp, "   syscall            calls    total       min       avg       max      stddev\n");
	printed += fprintf(fp, "                               (msec)    (msec)    (msec)    (msec)        (%%)\n");
	printed += fprintf(fp, "   --------------- -------- --------- --------- --------- ---------     ------\n");
2569

2570
	resort_rb__for_each_entry(nd, syscall_stats) {
2571
		struct stats *stats = syscall_stats_entry->stats;
2572 2573 2574 2575 2576 2577 2578 2579 2580 2581
		if (stats) {
			double min = (double)(stats->min) / NSEC_PER_MSEC;
			double max = (double)(stats->max) / NSEC_PER_MSEC;
			double avg = avg_stats(stats);
			double pct;
			u64 n = (u64) stats->n;

			pct = avg ? 100.0 * stddev_stats(stats)/avg : 0.0;
			avg /= NSEC_PER_MSEC;

2582
			sc = &trace->syscalls.table[syscall_stats_entry->syscall];
2583
			printed += fprintf(fp, "   %-15s", sc->name);
2584
			printed += fprintf(fp, " %8" PRIu64 " %9.3f %9.3f %9.3f",
2585
					   n, syscall_stats_entry->msecs, min, avg);
P
Pekka Enberg 已提交
2586
			printed += fprintf(fp, " %9.3f %9.2f%%\n", max, pct);
2587 2588 2589
		}
	}

2590
	resort_rb__delete(syscall_stats);
2591
	printed += fprintf(fp, "\n\n");
2592 2593 2594 2595

	return printed;
}

2596
static size_t trace__fprintf_thread(FILE *fp, struct thread *thread, struct trace *trace)
2597
{
2598
	size_t printed = 0;
2599
	struct thread_trace *ttrace = thread__priv(thread);
2600 2601 2602 2603 2604 2605 2606
	double ratio;

	if (ttrace == NULL)
		return 0;

	ratio = (double)ttrace->nr_events / trace->nr_events * 100.0;

2607
	printed += fprintf(fp, " %s (%d), ", thread__comm_str(thread), thread->tid);
2608
	printed += fprintf(fp, "%lu events, ", ttrace->nr_events);
2609
	printed += fprintf(fp, "%.1f%%", ratio);
2610 2611 2612 2613
	if (ttrace->pfmaj)
		printed += fprintf(fp, ", %lu majfaults", ttrace->pfmaj);
	if (ttrace->pfmin)
		printed += fprintf(fp, ", %lu minfaults", ttrace->pfmin);
2614 2615 2616 2617 2618
	if (trace->sched)
		printed += fprintf(fp, ", %.3f msec\n", ttrace->runtime_ms);
	else if (fputc('\n', fp) != EOF)
		++printed;

2619
	printed += thread__dump_stats(ttrace, trace, fp);
2620

2621 2622
	return printed;
}
2623

2624 2625 2626 2627 2628 2629 2630 2631 2632 2633
static unsigned long thread__nr_events(struct thread_trace *ttrace)
{
	return ttrace ? ttrace->nr_events : 0;
}

DEFINE_RESORT_RB(threads, (thread__nr_events(a->thread->priv) < thread__nr_events(b->thread->priv)),
	struct thread *thread;
)
{
	entry->thread = rb_entry(nd, struct thread, rb_node);
2634 2635
}

2636 2637
static size_t trace__fprintf_thread_summary(struct trace *trace, FILE *fp)
{
2638 2639 2640
	DECLARE_RESORT_RB_MACHINE_THREADS(threads, trace->host);
	size_t printed = trace__fprintf_threads_header(fp);
	struct rb_node *nd;
2641

2642 2643 2644 2645 2646
	if (threads == NULL) {
		fprintf(fp, "%s", "Error sorting output by nr_events!\n");
		return 0;
	}

2647
	resort_rb__for_each_entry(nd, threads)
2648
		printed += trace__fprintf_thread(fp, threads_entry->thread, trace);
2649

2650 2651 2652
	resort_rb__delete(threads);

	return printed;
2653 2654
}

2655 2656 2657 2658 2659 2660 2661 2662 2663
static int trace__set_duration(const struct option *opt, const char *str,
			       int unset __maybe_unused)
{
	struct trace *trace = opt->value;

	trace->duration_filter = atof(str);
	return 0;
}

2664 2665 2666 2667 2668 2669 2670 2671 2672 2673 2674 2675 2676 2677 2678 2679 2680 2681 2682 2683 2684 2685 2686 2687 2688 2689 2690 2691 2692 2693 2694 2695
static int trace__set_filter_pids(const struct option *opt, const char *str,
				  int unset __maybe_unused)
{
	int ret = -1;
	size_t i;
	struct trace *trace = opt->value;
	/*
	 * FIXME: introduce a intarray class, plain parse csv and create a
	 * { int nr, int entries[] } struct...
	 */
	struct intlist *list = intlist__new(str);

	if (list == NULL)
		return -1;

	i = trace->filter_pids.nr = intlist__nr_entries(list) + 1;
	trace->filter_pids.entries = calloc(i, sizeof(pid_t));

	if (trace->filter_pids.entries == NULL)
		goto out;

	trace->filter_pids.entries[0] = getpid();

	for (i = 1; i < trace->filter_pids.nr; ++i)
		trace->filter_pids.entries[i] = intlist__entry(list, i - 1)->i;

	intlist__delete(list);
	ret = 0;
out:
	return ret;
}

2696 2697 2698 2699 2700 2701 2702 2703 2704 2705 2706 2707 2708 2709 2710 2711 2712
static int trace__open_output(struct trace *trace, const char *filename)
{
	struct stat st;

	if (!stat(filename, &st) && st.st_size) {
		char oldname[PATH_MAX];

		scnprintf(oldname, sizeof(oldname), "%s.old", filename);
		unlink(oldname);
		rename(filename, oldname);
	}

	trace->output = fopen(filename, "w");

	return trace->output == NULL ? -errno : 0;
}

2713 2714 2715 2716 2717 2718 2719 2720 2721 2722 2723 2724 2725 2726 2727 2728 2729
static int parse_pagefaults(const struct option *opt, const char *str,
			    int unset __maybe_unused)
{
	int *trace_pgfaults = opt->value;

	if (strcmp(str, "all") == 0)
		*trace_pgfaults |= TRACE_PFMAJ | TRACE_PFMIN;
	else if (strcmp(str, "maj") == 0)
		*trace_pgfaults |= TRACE_PFMAJ;
	else if (strcmp(str, "min") == 0)
		*trace_pgfaults |= TRACE_PFMIN;
	else
		return -1;

	return 0;
}

2730 2731 2732 2733
static void evlist__set_evsel_handler(struct perf_evlist *evlist, void *handler)
{
	struct perf_evsel *evsel;

2734
	evlist__for_each_entry(evlist, evsel)
2735 2736 2737
		evsel->handler = handler;
}

2738 2739 2740 2741 2742 2743 2744 2745 2746 2747 2748 2749 2750 2751 2752 2753 2754 2755 2756 2757 2758 2759 2760 2761 2762 2763 2764 2765 2766 2767 2768 2769 2770 2771 2772 2773 2774 2775 2776 2777 2778 2779 2780 2781 2782 2783 2784 2785 2786 2787 2788 2789 2790 2791 2792 2793 2794 2795 2796 2797 2798 2799 2800 2801 2802 2803 2804 2805 2806 2807 2808 2809 2810 2811 2812 2813 2814 2815 2816 2817 2818 2819 2820 2821 2822
/*
 * XXX: Hackish, just splitting the combined -e+--event (syscalls
 * (raw_syscalls:{sys_{enter,exit}} + events (tracepoints, HW, SW, etc) to use
 * existing facilities unchanged (trace->ev_qualifier + parse_options()).
 *
 * It'd be better to introduce a parse_options() variant that would return a
 * list with the terms it didn't match to an event...
 */
static int trace__parse_events_option(const struct option *opt, const char *str,
				      int unset __maybe_unused)
{
	struct trace *trace = (struct trace *)opt->value;
	const char *s = str;
	char *sep = NULL, *lists[2] = { NULL, NULL, };
	int len = strlen(str), err = -1, list;
	char *strace_groups_dir = system_path(STRACE_GROUPS_DIR);
	char group_name[PATH_MAX];

	if (strace_groups_dir == NULL)
		return -1;

	if (*s == '!') {
		++s;
		trace->not_ev_qualifier = true;
	}

	while (1) {
		if ((sep = strchr(s, ',')) != NULL)
			*sep = '\0';

		list = 0;
		if (syscalltbl__id(trace->sctbl, s) >= 0) {
			list = 1;
		} else {
			path__join(group_name, sizeof(group_name), strace_groups_dir, s);
			if (access(group_name, R_OK) == 0)
				list = 1;
		}

		if (lists[list]) {
			sprintf(lists[list] + strlen(lists[list]), ",%s", s);
		} else {
			lists[list] = malloc(len);
			if (lists[list] == NULL)
				goto out;
			strcpy(lists[list], s);
		}

		if (!sep)
			break;

		*sep = ',';
		s = sep + 1;
	}

	if (lists[1] != NULL) {
		struct strlist_config slist_config = {
			.dirname = strace_groups_dir,
		};

		trace->ev_qualifier = strlist__new(lists[1], &slist_config);
		if (trace->ev_qualifier == NULL) {
			fputs("Not enough memory to parse event qualifier", trace->output);
			goto out;
		}

		if (trace__validate_ev_qualifier(trace))
			goto out;
	}

	err = 0;

	if (lists[0]) {
		struct option o = OPT_CALLBACK('e', "event", &trace->evlist, "event",
					       "event selector. use 'perf list' to list available events",
					       parse_events_option);
		err = parse_events_option(&o, lists[0], 0);
	}
out:
	if (sep)
		*sep = ',';

	return err;
}

2823
int cmd_trace(int argc, const char **argv)
A
Arnaldo Carvalho de Melo 已提交
2824
{
2825
	const char *trace_usage[] = {
2826 2827
		"perf trace [<options>] [<command>]",
		"perf trace [<options>] -- <command> [<options>]",
D
David Ahern 已提交
2828 2829
		"perf trace record [<options>] [<command>]",
		"perf trace record [<options>] -- <command> [<options>]",
A
Arnaldo Carvalho de Melo 已提交
2830 2831 2832 2833 2834 2835 2836 2837 2838 2839 2840 2841 2842
		NULL
	};
	struct trace trace = {
		.syscalls = {
			. max = -1,
		},
		.opts = {
			.target = {
				.uid	   = UINT_MAX,
				.uses_mmap = true,
			},
			.user_freq     = UINT_MAX,
			.user_interval = ULLONG_MAX,
2843
			.no_buffering  = true,
2844
			.mmap_pages    = UINT_MAX,
2845
			.proc_map_timeout  = 500,
A
Arnaldo Carvalho de Melo 已提交
2846
		},
2847
		.output = stderr,
2848
		.show_comm = true,
2849
		.trace_syscalls = true,
2850
		.kernel_syscallchains = false,
2851
		.max_stack = UINT_MAX,
A
Arnaldo Carvalho de Melo 已提交
2852
	};
2853
	const char *output_name = NULL;
A
Arnaldo Carvalho de Melo 已提交
2854
	const struct option trace_options[] = {
2855 2856 2857
	OPT_CALLBACK('e', "event", &trace, "event",
		     "event/syscall selector. use 'perf list' to list available events",
		     trace__parse_events_option),
2858 2859
	OPT_BOOLEAN(0, "comm", &trace.show_comm,
		    "show the thread COMM next to its id"),
2860
	OPT_BOOLEAN(0, "tool_stats", &trace.show_tool_stats, "show tool stats"),
2861 2862
	OPT_CALLBACK(0, "expr", &trace, "expr", "list of syscalls/events to trace",
		     trace__parse_events_option),
2863
	OPT_STRING('o', "output", &output_name, "file", "output file name"),
2864
	OPT_STRING('i', "input", &input_name, "file", "Analyze events in file"),
A
Arnaldo Carvalho de Melo 已提交
2865 2866
	OPT_STRING('p', "pid", &trace.opts.target.pid, "pid",
		    "trace events on existing process id"),
2867
	OPT_STRING('t', "tid", &trace.opts.target.tid, "tid",
A
Arnaldo Carvalho de Melo 已提交
2868
		    "trace events on existing thread id"),
2869 2870
	OPT_CALLBACK(0, "filter-pids", &trace, "CSV list of pids",
		     "pids to filter (by the kernel)", trace__set_filter_pids),
2871
	OPT_BOOLEAN('a', "all-cpus", &trace.opts.target.system_wide,
A
Arnaldo Carvalho de Melo 已提交
2872
		    "system-wide collection from all CPUs"),
2873
	OPT_STRING('C', "cpu", &trace.opts.target.cpu_list, "cpu",
A
Arnaldo Carvalho de Melo 已提交
2874
		    "list of cpus to monitor"),
2875
	OPT_BOOLEAN(0, "no-inherit", &trace.opts.no_inherit,
A
Arnaldo Carvalho de Melo 已提交
2876
		    "child tasks do not inherit counters"),
2877 2878 2879
	OPT_CALLBACK('m', "mmap-pages", &trace.opts.mmap_pages, "pages",
		     "number of mmap data pages",
		     perf_evlist__parse_mmap_pages),
2880
	OPT_STRING('u', "uid", &trace.opts.target.uid_str, "user",
A
Arnaldo Carvalho de Melo 已提交
2881
		   "user to profile"),
2882 2883 2884
	OPT_CALLBACK(0, "duration", &trace, "float",
		     "show only events with duration > N.M ms",
		     trace__set_duration),
2885
	OPT_BOOLEAN(0, "sched", &trace.sched, "show blocking scheduler events"),
2886
	OPT_INCR('v', "verbose", &verbose, "be more verbose"),
2887 2888
	OPT_BOOLEAN('T', "time", &trace.full_time,
		    "Show full timestamp, not time relative to first start"),
D
David Ahern 已提交
2889 2890 2891 2892
	OPT_BOOLEAN('s', "summary", &trace.summary_only,
		    "Show only syscall summary with statistics"),
	OPT_BOOLEAN('S', "with-summary", &trace.summary,
		    "Show all syscalls and summary with statistics"),
2893 2894
	OPT_CALLBACK_DEFAULT('F', "pf", &trace.trace_pgfaults, "all|maj|min",
		     "Trace pagefaults", parse_pagefaults, "maj"),
2895
	OPT_BOOLEAN(0, "syscalls", &trace.trace_syscalls, "Trace syscalls"),
2896
	OPT_BOOLEAN('f', "force", &trace.force, "don't complain, do it"),
2897 2898 2899
	OPT_CALLBACK(0, "call-graph", &trace.opts,
		     "record_mode[,record_size]", record_callchain_help,
		     &record_parse_callchain_opt),
2900 2901
	OPT_BOOLEAN(0, "kernel-syscall-graph", &trace.kernel_syscallchains,
		    "Show the kernel callchains on the syscall exit path"),
2902 2903 2904
	OPT_UINTEGER(0, "min-stack", &trace.min_stack,
		     "Set the minimum stack depth when parsing the callchain, "
		     "anything below the specified depth will be ignored."),
2905 2906 2907
	OPT_UINTEGER(0, "max-stack", &trace.max_stack,
		     "Set the maximum stack depth when parsing the callchain, "
		     "anything beyond the specified depth will be ignored. "
2908
		     "Default: kernel.perf_event_max_stack or " __stringify(PERF_MAX_STACK_DEPTH)),
2909 2910
	OPT_UINTEGER(0, "proc-map-timeout", &trace.opts.proc_map_timeout,
			"per thread proc mmap processing timeout in ms"),
A
Alexis Berlemont 已提交
2911 2912 2913
	OPT_UINTEGER('D', "delay", &trace.opts.initial_delay,
		     "ms to wait before starting measurement after program "
		     "start"),
A
Arnaldo Carvalho de Melo 已提交
2914 2915
	OPT_END()
	};
2916
	bool __maybe_unused max_stack_user_set = true;
2917
	bool mmap_pages_user_set = true;
2918
	const char * const trace_subcommands[] = { "record", NULL };
A
Arnaldo Carvalho de Melo 已提交
2919
	int err;
2920
	char bf[BUFSIZ];
A
Arnaldo Carvalho de Melo 已提交
2921

2922 2923 2924
	signal(SIGSEGV, sighandler_dump_stack);
	signal(SIGFPE, sighandler_dump_stack);

2925
	trace.evlist = perf_evlist__new();
2926
	trace.sctbl = syscalltbl__new();
2927

2928
	if (trace.evlist == NULL || trace.sctbl == NULL) {
2929
		pr_err("Not enough memory to run!\n");
2930
		err = -ENOMEM;
2931 2932 2933
		goto out;
	}

2934 2935
	argc = parse_options_subcommand(argc, argv, trace_options, trace_subcommands,
				 trace_usage, PARSE_OPT_STOP_AT_NON_OPTION);
D
David Ahern 已提交
2936

2937 2938 2939 2940 2941 2942 2943
	err = bpf__setup_stdout(trace.evlist);
	if (err) {
		bpf__strerror_setup_stdout(trace.evlist, err, bf, sizeof(bf));
		pr_err("ERROR: Setup BPF stdout failed: %s\n", bf);
		goto out;
	}

2944 2945
	err = -1;

2946 2947 2948 2949 2950
	if (trace.trace_pgfaults) {
		trace.opts.sample_address = true;
		trace.opts.sample_time = true;
	}

2951 2952 2953
	if (trace.opts.mmap_pages == UINT_MAX)
		mmap_pages_user_set = false;

2954
	if (trace.max_stack == UINT_MAX) {
2955
		trace.max_stack = input_name ? PERF_MAX_STACK_DEPTH : sysctl_perf_event_max_stack;
2956 2957 2958 2959
		max_stack_user_set = false;
	}

#ifdef HAVE_DWARF_UNWIND_SUPPORT
2960
	if ((trace.min_stack || max_stack_user_set) && !callchain_param.enabled && trace.trace_syscalls)
2961 2962 2963
		record_opts__parse_callchain(&trace.opts, &callchain_param, "dwarf", false);
#endif

2964
	if (callchain_param.enabled) {
2965 2966 2967
		if (!mmap_pages_user_set && geteuid() == 0)
			trace.opts.mmap_pages = perf_event_mlock_kb_in_pages() * 4;

2968
		symbol_conf.use_callchain = true;
2969
	}
2970

2971 2972 2973
	if (trace.evlist->nr_entries > 0)
		evlist__set_evsel_handler(trace.evlist, trace__event_handler);

2974 2975 2976 2977 2978 2979 2980
	if ((argc >= 1) && (strcmp(argv[0], "record") == 0))
		return trace__record(&trace, argc-1, &argv[1]);

	/* summary_only implies summary option, but don't overwrite summary if set */
	if (trace.summary_only)
		trace.summary = trace.summary_only;

2981 2982
	if (!trace.trace_syscalls && !trace.trace_pgfaults &&
	    trace.evlist->nr_entries == 0 /* Was --events used? */) {
2983 2984 2985 2986
		pr_err("Please specify something to trace.\n");
		return -1;
	}

2987
	if (!trace.trace_syscalls && trace.ev_qualifier) {
2988 2989 2990 2991
		pr_err("The -e option can't be used with --no-syscalls.\n");
		goto out;
	}

2992 2993 2994 2995 2996 2997 2998 2999
	if (output_name != NULL) {
		err = trace__open_output(&trace, output_name);
		if (err < 0) {
			perror("failed to create output file");
			goto out;
		}
	}

3000 3001
	trace.open_id = syscalltbl__id(trace.sctbl, "open");

3002
	err = target__validate(&trace.opts.target);
3003
	if (err) {
3004
		target__strerror(&trace.opts.target, err, bf, sizeof(bf));
3005 3006
		fprintf(trace.output, "%s", bf);
		goto out_close;
3007 3008
	}

3009
	err = target__parse_uid(&trace.opts.target);
A
Arnaldo Carvalho de Melo 已提交
3010
	if (err) {
3011
		target__strerror(&trace.opts.target, err, bf, sizeof(bf));
3012 3013
		fprintf(trace.output, "%s", bf);
		goto out_close;
A
Arnaldo Carvalho de Melo 已提交
3014 3015
	}

3016
	if (!argc && target__none(&trace.opts.target))
3017 3018
		trace.opts.target.system_wide = true;

3019 3020 3021 3022
	if (input_name)
		err = trace__replay(&trace);
	else
		err = trace__run(&trace, argc, argv);
3023

3024 3025 3026 3027
out_close:
	if (output_name != NULL)
		fclose(trace.output);
out:
3028
	return err;
A
Arnaldo Carvalho de Melo 已提交
3029
}