perf tools: Derive trigger class from auxtrace_snapshot

auxtrace_snapshot_state matches the trigger model. Use trigger to
implement it. auxtrace_snapshot_state and auxtrace_snapshot_err are
absorbed.

Signed-off-by: Wang Nan <wangnan0@huawei.com>
Acked-by: Adrian Hunter <adrian.hunter@intel.com>
Cc: He Kuang <hekuang@huawei.com>
Cc: Jiri Olsa <jolsa@redhat.com>
Cc: Masami Hiramatsu <mhiramat@kernel.org>
Cc: Namhyung Kim <namhyung@kernel.org>
Cc: Zefan Li <lizefan@huawei.com>
Cc: pi3orama@163.com
Link: http://lkml.kernel.org/r/1461178794-40467-3-git-send-email-wangnan0@huawei.com
Signed-off-by: Arnaldo Carvalho de Melo <acme@redhat.com>

1 files changed, 20 insertions, 53 deletions

diff --git a/tools/perf/builtin-record.c b/tools/perf/builtin-record.c
index bd9593346bb2..f4710c82980f 100644
--- a/tools/perf/builtin-record.c
+++ b/tools/perf/builtin-record.c
@@ -34,6 +34,7 @@
 #include "util/parse-regs-options.h"
 #include "util/llvm-utils.h"
 #include "util/bpf-loader.h"
+#include "util/trigger.h"
 #include "asm/bug.h"
 
 #include <unistd.h>
@@ -127,44 +128,8 @@ static volatile int done;
 static volatile int signr = -1;
 static volatile int child_finished;
 
-static volatile enum {
-        AUXTRACE_SNAPSHOT_OFF = -1,
-        AUXTRACE_SNAPSHOT_DISABLED = 0,
-        AUXTRACE_SNAPSHOT_ENABLED = 1,
-} auxtrace_snapshot_state = AUXTRACE_SNAPSHOT_OFF;
-
-static inline void
-auxtrace_snapshot_on(void)
-{
-        auxtrace_snapshot_state = AUXTRACE_SNAPSHOT_DISABLED;
-}
-
-static inline void
-auxtrace_snapshot_enable(void)
-{
-        if (auxtrace_snapshot_state == AUXTRACE_SNAPSHOT_OFF)
-                return;
-        auxtrace_snapshot_state = AUXTRACE_SNAPSHOT_ENABLED;
-}
-
-static inline void
-auxtrace_snapshot_disable(void)
-{
-        if (auxtrace_snapshot_state == AUXTRACE_SNAPSHOT_OFF)
-                return;
-        auxtrace_snapshot_state = AUXTRACE_SNAPSHOT_DISABLED;
-}
-
-static inline bool
-auxtrace_snapshot_is_enabled(void)
-{
-        if (auxtrace_snapshot_state == AUXTRACE_SNAPSHOT_OFF)
-                return false;
-        return auxtrace_snapshot_state == AUXTRACE_SNAPSHOT_ENABLED;
-}
-
-static volatile int auxtrace_snapshot_err;
 static volatile int auxtrace_record__snapshot_started;
+static DEFINE_TRIGGER(auxtrace_snapshot_trigger);
 
 static void sig_handler(int sig)
 {
@@ -282,11 +247,12 @@ static void record__read_auxtrace_snapshot(struct record *rec)
 {
         pr_debug("Recording AUX area tracing snapshot\n");
         if (record__auxtrace_read_snapshot_all(rec) < 0) {
-                auxtrace_snapshot_err = -1;
+                trigger_error(&auxtrace_snapshot_trigger);
         } else {
-                auxtrace_snapshot_err = auxtrace_record__snapshot_finish(rec->itr);
-                if (!auxtrace_snapshot_err)
-                        auxtrace_snapshot_enable();
+                if (auxtrace_record__snapshot_finish(rec->itr))
+                        trigger_error(&auxtrace_snapshot_trigger);
+                else
+                        trigger_ready(&auxtrace_snapshot_trigger);
         }
 }
 
@@ -686,7 +652,7 @@ static int __cmd_record(struct record *rec, int argc, const char **argv)
 
         if (rec->opts.auxtrace_snapshot_mode) {
                 signal(SIGUSR2, snapshot_sig_handler);
-                auxtrace_snapshot_on();
+                trigger_on(&auxtrace_snapshot_trigger);
         } else {
                 signal(SIGUSR2, SIG_IGN);
         }
@@ -815,21 +781,21 @@ static int __cmd_record(struct record *rec, int argc, const char **argv)
                 perf_evlist__enable(rec->evlist);
         }
 
-        auxtrace_snapshot_enable();
+        trigger_ready(&auxtrace_snapshot_trigger);
         for (;;) {
                 unsigned long long hits = rec->samples;
 
                 if (record__mmap_read_all(rec) < 0) {
-                        auxtrace_snapshot_disable();
+                        trigger_error(&auxtrace_snapshot_trigger);
                         err = -1;
                         goto out_child;
                 }
 
                 if (auxtrace_record__snapshot_started) {
                         auxtrace_record__snapshot_started = 0;
-                        if (!auxtrace_snapshot_err)
+                        if (!trigger_is_error(&auxtrace_snapshot_trigger))
                                 record__read_auxtrace_snapshot(rec);
-                        if (auxtrace_snapshot_err) {
+                        if (trigger_is_error(&auxtrace_snapshot_trigger)) {
                                 pr_err("AUX area tracing snapshot failed\n");
                                 err = -1;
                                 goto out_child;
@@ -858,12 +824,12 @@ static int __cmd_record(struct record *rec, int argc, const char **argv)
                  * disable events in this case.
                  */
                 if (done && !disabled && !target__none(&opts->target)) {
-                        auxtrace_snapshot_disable();
+                        trigger_off(&auxtrace_snapshot_trigger);
                         perf_evlist__disable(rec->evlist);
                         disabled = true;
                 }
         }
-        auxtrace_snapshot_disable();
+        trigger_off(&auxtrace_snapshot_trigger);
 
         if (forks && workload_exec_errno) {
                 char msg[STRERR_BUFSIZE];
@@ -1445,9 +1411,10 @@ out_symbol_exit:
 
 static void snapshot_sig_handler(int sig __maybe_unused)
 {
-        if (!auxtrace_snapshot_is_enabled())
-                return;
-        auxtrace_snapshot_disable();
-        auxtrace_snapshot_err = auxtrace_record__snapshot_start(record.itr);
-        auxtrace_record__snapshot_started = 1;
+        if (trigger_is_ready(&auxtrace_snapshot_trigger)) {
+                trigger_hit(&auxtrace_snapshot_trigger);
+                auxtrace_record__snapshot_started = 1;
+                if (auxtrace_record__snapshot_start(record.itr))
+                        trigger_error(&auxtrace_snapshot_trigger);
+        }
 }