|
@@ -46,6 +46,15 @@
|
|
|
#include <asm/bug.h>
|
|
|
#include <linux/time64.h>
|
|
|
|
|
|
+struct switch_output {
|
|
|
+ bool enabled;
|
|
|
+ bool signal;
|
|
|
+ unsigned long size;
|
|
|
+ unsigned long time;
|
|
|
+ const char *str;
|
|
|
+ bool set;
|
|
|
+};
|
|
|
+
|
|
|
struct record {
|
|
|
struct perf_tool tool;
|
|
|
struct record_opts opts;
|
|
@@ -62,10 +71,33 @@ struct record {
|
|
|
bool no_buildid_cache_set;
|
|
|
bool buildid_all;
|
|
|
bool timestamp_filename;
|
|
|
- bool switch_output;
|
|
|
+ struct switch_output switch_output;
|
|
|
unsigned long long samples;
|
|
|
};
|
|
|
|
|
|
+static volatile int auxtrace_record__snapshot_started;
|
|
|
+static DEFINE_TRIGGER(auxtrace_snapshot_trigger);
|
|
|
+static DEFINE_TRIGGER(switch_output_trigger);
|
|
|
+
|
|
|
+static bool switch_output_signal(struct record *rec)
|
|
|
+{
|
|
|
+ return rec->switch_output.signal &&
|
|
|
+ trigger_is_ready(&switch_output_trigger);
|
|
|
+}
|
|
|
+
|
|
|
+static bool switch_output_size(struct record *rec)
|
|
|
+{
|
|
|
+ return rec->switch_output.size &&
|
|
|
+ trigger_is_ready(&switch_output_trigger) &&
|
|
|
+ (rec->bytes_written >= rec->switch_output.size);
|
|
|
+}
|
|
|
+
|
|
|
+static bool switch_output_time(struct record *rec)
|
|
|
+{
|
|
|
+ return rec->switch_output.time &&
|
|
|
+ trigger_is_ready(&switch_output_trigger);
|
|
|
+}
|
|
|
+
|
|
|
static int record__write(struct record *rec, void *bf, size_t size)
|
|
|
{
|
|
|
if (perf_data_file__write(rec->session->file, bf, size) < 0) {
|
|
@@ -74,6 +106,10 @@ static int record__write(struct record *rec, void *bf, size_t size)
|
|
|
}
|
|
|
|
|
|
rec->bytes_written += size;
|
|
|
+
|
|
|
+ if (switch_output_size(rec))
|
|
|
+ trigger_hit(&switch_output_trigger);
|
|
|
+
|
|
|
return 0;
|
|
|
}
|
|
|
|
|
@@ -193,10 +229,6 @@ static volatile int done;
|
|
|
static volatile int signr = -1;
|
|
|
static volatile int child_finished;
|
|
|
|
|
|
-static volatile int auxtrace_record__snapshot_started;
|
|
|
-static DEFINE_TRIGGER(auxtrace_snapshot_trigger);
|
|
|
-static DEFINE_TRIGGER(switch_output_trigger);
|
|
|
-
|
|
|
static void sig_handler(int sig)
|
|
|
{
|
|
|
if (sig == SIGCHLD)
|
|
@@ -712,6 +744,7 @@ static void workload_exec_failed_signal(int signo __maybe_unused,
|
|
|
}
|
|
|
|
|
|
static void snapshot_sig_handler(int sig);
|
|
|
+static void alarm_sig_handler(int sig);
|
|
|
|
|
|
int __weak
|
|
|
perf_event__synth_time_conv(const struct perf_event_mmap_page *pc __maybe_unused,
|
|
@@ -842,11 +875,11 @@ static int __cmd_record(struct record *rec, int argc, const char **argv)
|
|
|
signal(SIGTERM, sig_handler);
|
|
|
signal(SIGSEGV, sigsegv_handler);
|
|
|
|
|
|
- if (rec->opts.auxtrace_snapshot_mode || rec->switch_output) {
|
|
|
+ if (rec->opts.auxtrace_snapshot_mode || rec->switch_output.enabled) {
|
|
|
signal(SIGUSR2, snapshot_sig_handler);
|
|
|
if (rec->opts.auxtrace_snapshot_mode)
|
|
|
trigger_on(&auxtrace_snapshot_trigger);
|
|
|
- if (rec->switch_output)
|
|
|
+ if (rec->switch_output.enabled)
|
|
|
trigger_on(&switch_output_trigger);
|
|
|
} else {
|
|
|
signal(SIGUSR2, SIG_IGN);
|
|
@@ -1043,6 +1076,10 @@ static int __cmd_record(struct record *rec, int argc, const char **argv)
|
|
|
err = fd;
|
|
|
goto out_child;
|
|
|
}
|
|
|
+
|
|
|
+ /* re-arm the alarm */
|
|
|
+ if (rec->switch_output.time)
|
|
|
+ alarm(rec->switch_output.time);
|
|
|
}
|
|
|
|
|
|
if (hits == rec->samples) {
|
|
@@ -1352,6 +1389,78 @@ out_free:
|
|
|
return ret;
|
|
|
}
|
|
|
|
|
|
+static void switch_output_size_warn(struct record *rec)
|
|
|
+{
|
|
|
+ u64 wakeup_size = perf_evlist__mmap_size(rec->opts.mmap_pages);
|
|
|
+ struct switch_output *s = &rec->switch_output;
|
|
|
+
|
|
|
+ wakeup_size /= 2;
|
|
|
+
|
|
|
+ if (s->size < wakeup_size) {
|
|
|
+ char buf[100];
|
|
|
+
|
|
|
+ unit_number__scnprintf(buf, sizeof(buf), wakeup_size);
|
|
|
+ pr_warning("WARNING: switch-output data size lower than "
|
|
|
+ "wakeup kernel buffer size (%s) "
|
|
|
+ "expect bigger perf.data sizes\n", buf);
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+static int switch_output_setup(struct record *rec)
|
|
|
+{
|
|
|
+ struct switch_output *s = &rec->switch_output;
|
|
|
+ static struct parse_tag tags_size[] = {
|
|
|
+ { .tag = 'B', .mult = 1 },
|
|
|
+ { .tag = 'K', .mult = 1 << 10 },
|
|
|
+ { .tag = 'M', .mult = 1 << 20 },
|
|
|
+ { .tag = 'G', .mult = 1 << 30 },
|
|
|
+ { .tag = 0 },
|
|
|
+ };
|
|
|
+ static struct parse_tag tags_time[] = {
|
|
|
+ { .tag = 's', .mult = 1 },
|
|
|
+ { .tag = 'm', .mult = 60 },
|
|
|
+ { .tag = 'h', .mult = 60*60 },
|
|
|
+ { .tag = 'd', .mult = 60*60*24 },
|
|
|
+ { .tag = 0 },
|
|
|
+ };
|
|
|
+ unsigned long val;
|
|
|
+
|
|
|
+ if (!s->set)
|
|
|
+ return 0;
|
|
|
+
|
|
|
+ if (!strcmp(s->str, "signal")) {
|
|
|
+ s->signal = true;
|
|
|
+ pr_debug("switch-output with SIGUSR2 signal\n");
|
|
|
+ goto enabled;
|
|
|
+ }
|
|
|
+
|
|
|
+ val = parse_tag_value(s->str, tags_size);
|
|
|
+ if (val != (unsigned long) -1) {
|
|
|
+ s->size = val;
|
|
|
+ pr_debug("switch-output with %s size threshold\n", s->str);
|
|
|
+ goto enabled;
|
|
|
+ }
|
|
|
+
|
|
|
+ val = parse_tag_value(s->str, tags_time);
|
|
|
+ if (val != (unsigned long) -1) {
|
|
|
+ s->time = val;
|
|
|
+ pr_debug("switch-output with %s time threshold (%lu seconds)\n",
|
|
|
+ s->str, s->time);
|
|
|
+ goto enabled;
|
|
|
+ }
|
|
|
+
|
|
|
+ return -1;
|
|
|
+
|
|
|
+enabled:
|
|
|
+ rec->timestamp_filename = true;
|
|
|
+ s->enabled = true;
|
|
|
+
|
|
|
+ if (s->size && !rec->opts.no_buffering)
|
|
|
+ switch_output_size_warn(rec);
|
|
|
+
|
|
|
+ return 0;
|
|
|
+}
|
|
|
+
|
|
|
static const char * const __record_usage[] = {
|
|
|
"perf record [<options>] [<command>]",
|
|
|
"perf record [<options>] -- <command> [<options>]",
|
|
@@ -1519,8 +1628,10 @@ static struct option __record_options[] = {
|
|
|
"Record build-id of all DSOs regardless of hits"),
|
|
|
OPT_BOOLEAN(0, "timestamp-filename", &record.timestamp_filename,
|
|
|
"append timestamp to output filename"),
|
|
|
- OPT_BOOLEAN(0, "switch-output", &record.switch_output,
|
|
|
- "Switch output when receive SIGUSR2"),
|
|
|
+ OPT_STRING_OPTARG_SET(0, "switch-output", &record.switch_output.str,
|
|
|
+ &record.switch_output.set, "signal,size,time",
|
|
|
+ "Switch output when receive SIGUSR2 or cross size,time threshold",
|
|
|
+ "signal"),
|
|
|
OPT_BOOLEAN(0, "dry-run", &dry_run,
|
|
|
"Parse options then exit"),
|
|
|
OPT_END()
|
|
@@ -1578,8 +1689,15 @@ int cmd_record(int argc, const char **argv, const char *prefix __maybe_unused)
|
|
|
return -EINVAL;
|
|
|
}
|
|
|
|
|
|
- if (rec->switch_output)
|
|
|
- rec->timestamp_filename = true;
|
|
|
+ if (switch_output_setup(rec)) {
|
|
|
+ parse_options_usage(record_usage, record_options, "switch-output", 0);
|
|
|
+ return -EINVAL;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (rec->switch_output.time) {
|
|
|
+ signal(SIGALRM, alarm_sig_handler);
|
|
|
+ alarm(rec->switch_output.time);
|
|
|
+ }
|
|
|
|
|
|
if (!rec->itr) {
|
|
|
rec->itr = auxtrace_record__init(rec->evlist, &err);
|
|
@@ -1629,7 +1747,7 @@ int cmd_record(int argc, const char **argv, const char *prefix __maybe_unused)
|
|
|
|
|
|
if (rec->no_buildid_cache || rec->no_buildid) {
|
|
|
disable_buildid_cache();
|
|
|
- } else if (rec->switch_output) {
|
|
|
+ } else if (rec->switch_output.enabled) {
|
|
|
/*
|
|
|
* In 'perf record --switch-output', disable buildid
|
|
|
* generation by default to reduce data file switching
|
|
@@ -1721,6 +1839,8 @@ out:
|
|
|
|
|
|
static void snapshot_sig_handler(int sig __maybe_unused)
|
|
|
{
|
|
|
+ struct record *rec = &record;
|
|
|
+
|
|
|
if (trigger_is_ready(&auxtrace_snapshot_trigger)) {
|
|
|
trigger_hit(&auxtrace_snapshot_trigger);
|
|
|
auxtrace_record__snapshot_started = 1;
|
|
@@ -1728,6 +1848,14 @@ static void snapshot_sig_handler(int sig __maybe_unused)
|
|
|
trigger_error(&auxtrace_snapshot_trigger);
|
|
|
}
|
|
|
|
|
|
- if (trigger_is_ready(&switch_output_trigger))
|
|
|
+ if (switch_output_signal(rec))
|
|
|
+ trigger_hit(&switch_output_trigger);
|
|
|
+}
|
|
|
+
|
|
|
+static void alarm_sig_handler(int sig __maybe_unused)
|
|
|
+{
|
|
|
+ struct record *rec = &record;
|
|
|
+
|
|
|
+ if (switch_output_time(rec))
|
|
|
trigger_hit(&switch_output_trigger);
|
|
|
}
|