On Wed, Sep 10, 2014 at 03:57:09PM +0200, Peter Zijlstra wrote:
> On Mon, Sep 08, 2014 at 06:45:24PM +0200, Jiri Olsa wrote:
> > 
> > now I need to recall what I used to test this ;-)
> > 
> 
> Hint, if you'd mentioned that in the changelog.... :-)

will try much better this time.. perf test attached ;-)
seems like the child state fix is a good one

jirka


---
>From dc1068c627b332b2a5feb4deedfd96db8e056b5f Mon Sep 17 00:00:00 2001
From: Jiri Olsa <[email protected]>
Date: Wed, 10 Sep 2014 16:23:51 +0200
Subject: [PATCH] perf tests: Add test for optimized sched switch bug

---
 tools/perf/Makefile.perf            |    1 +
 tools/perf/tests/builtin-test.c     |    4 +
 tools/perf/tests/optimized_switch.c |  169 +++++++++++++++++++++++++++++++++++
 tools/perf/tests/tests.h            |    1 +
 4 files changed, 175 insertions(+), 0 deletions(-)
 create mode 100644 tools/perf/tests/optimized_switch.c

diff --git a/tools/perf/Makefile.perf b/tools/perf/Makefile.perf
index da8fc07..75603ac 100644
--- a/tools/perf/Makefile.perf
+++ b/tools/perf/Makefile.perf
@@ -427,6 +427,7 @@ LIB_OBJS += $(OUTPUT)tests/mmap-thread-lookup.o
 LIB_OBJS += $(OUTPUT)tests/thread-mg-share.o
 LIB_OBJS += $(OUTPUT)tests/switch-tracking.o
 LIB_OBJS += $(OUTPUT)tests/xyarray.o
+LIB_OBJS += $(OUTPUT)tests/optimized_switch.o
 
 BUILTIN_OBJS += $(OUTPUT)builtin-annotate.o
 BUILTIN_OBJS += $(OUTPUT)builtin-bench.o
diff --git a/tools/perf/tests/builtin-test.c b/tools/perf/tests/builtin-test.c
index 5c90326..e092d17 100644
--- a/tools/perf/tests/builtin-test.c
+++ b/tools/perf/tests/builtin-test.c
@@ -162,6 +162,10 @@ static struct test {
                .func = test__xyarray,
        },
        {
+               .desc = "Test optimized switch",
+               .func = test__optimized_switch,
+       },
+       {
                .func = NULL,
        },
 };
diff --git a/tools/perf/tests/optimized_switch.c 
b/tools/perf/tests/optimized_switch.c
new file mode 100644
index 0000000..68f8705
--- /dev/null
+++ b/tools/perf/tests/optimized_switch.c
@@ -0,0 +1,169 @@
+#include <unistd.h>
+#include <stdlib.h>
+#include <sys/prctl.h>
+#include <linux/compiler.h>
+#include "tests.h"
+#include "debug.h"
+#include "evsel.h"
+#include "evlist.h"
+#include "thread_map.h"
+
+#define GROUPS 10
+#define WORKERS        10
+#define BYTES  100
+
+struct worker {
+       union {
+               int pipefd[2];
+               struct {
+                       int read;
+                       int write;
+               } fd;
+       };
+};
+
+#define pr_errsys(s) \
+       pr_err(s " failed: %s\n", strerror(errno))
+
+static void worker(int fd)
+{
+       unsigned char c = 0;
+       int cnt = BYTES;
+       ssize_t r;
+
+       while (cnt--) {
+               r = read(fd, &c, sizeof(c));
+               if (r != 1) {
+                       pr_errsys("read");
+                       exit(-1);
+               }
+       }
+
+       prctl(0, 0, 0, 0, 0);
+       exit(0);
+}
+
+static void write_round(struct worker *workers)
+{
+       unsigned char c = 0;
+       ssize_t r;
+       int i, j;
+
+       for (j = 0; j < BYTES; j++) {
+               for (i = 0; i < WORKERS; i++) {
+                       struct worker *w = &workers[i];
+
+                       r = write(w->fd.write, &c, sizeof(c));
+                       if (r != 1) {
+                               pr_errsys("write");
+                               exit(-1);
+                       }
+               }
+       }
+}
+
+static int group(void)
+{
+       struct worker workers[WORKERS];
+       int i;
+
+       for (i = 0; i < WORKERS; i++) {
+               struct worker *w = &workers[i];
+               int pid;
+
+               if (pipe(w->pipefd)) {
+                       pr_errsys("pipe");
+                       return -1;
+               }
+
+               pid = fork();
+               if (pid == -1) {
+                       pr_errsys("fork");
+                       return -1;
+               } else if (!pid) {
+                       worker(w->fd.read);
+               }
+       }
+
+       write_round(workers);
+
+       for (i = 0; i < WORKERS; i++)
+               wait(NULL);
+
+       return 0;
+}
+
+static int child(void)
+{
+       int i;
+
+       for (i = 0; i < GROUPS; i++)
+               TEST_ASSERT_VAL("group failed", !group());
+
+       return 0;
+}
+
+int test__optimized_switch(void)
+{
+       ssize_t r __maybe_unused;
+       unsigned char c = 0;
+       int ready[2], pid;
+       struct thread_map *threads;
+       struct perf_evsel *evsel;
+       u64 total;
+
+       if (pipe(ready)) {
+               pr_errsys("pipe");
+               return -1;
+       }
+
+       pid = fork();
+       if (pid == -1) {
+               pr_errsys("fork");
+               return -1;
+       }
+
+       if (!pid) {
+               r = read(ready[0], &c, sizeof(c));
+               if (r != 1) {
+                       pr_errsys("read");
+                       exit(-1);
+               }
+
+               exit(child());
+       }
+
+       threads = thread_map__new(-1, pid, UINT_MAX);
+
+       evsel = perf_evsel__newtp("syscalls", "sys_enter_prctl");
+       if (evsel == NULL) {
+               pr_debug("perf_evsel__open_per_thread failed\n");
+               return -1;
+       }
+
+       evsel->attr.inherit = 1;
+
+       if (perf_evsel__open_per_thread(evsel, threads) < 0) {
+               pr_err("perf_evsel__newtp failed\n");
+               return -1;
+       }
+
+       r = write(ready[1], &c, sizeof(c));
+       if (r != 1) {
+               pr_errsys("write");
+               return -1;
+       }
+
+       wait(NULL);
+
+       if (perf_evsel__read_on_cpu(evsel, 0, 0) < 0) {
+               pr_err("perf_evsel__read_on_cpu failed\n");
+               return -1;
+       }
+
+       total = evsel->counts->cpu[0].val;
+
+       pr_debug("total count %lu, expected count %d\n", total, GROUPS * 
WORKERS);
+       TEST_ASSERT_VAL("wrong count", total == GROUPS * WORKERS);
+       return 0;
+}
diff --git a/tools/perf/tests/tests.h b/tools/perf/tests/tests.h
index 8c3e7d1..466184b 100644
--- a/tools/perf/tests/tests.h
+++ b/tools/perf/tests/tests.h
@@ -50,6 +50,7 @@ int test__hists_output(void);
 int test__hists_cumulate(void);
 int test__switch_tracking(void);
 int test__xyarray(void);
+int test__optimized_switch(void);
 
 #if defined(__x86_64__) || defined(__i386__) || defined(__arm__)
 #ifdef HAVE_DWARF_UNWIND_SUPPORT
-- 
1.7.7.6

--
To unsubscribe from this list: send the line "unsubscribe linux-kernel" in
the body of a message to [email protected]
More majordomo info at  http://vger.kernel.org/majordomo-info.html
Please read the FAQ at  http://www.tux.org/lkml/

Reply via email to