Initial addition of trace-cmd files.

Signed-off-by: Steven Rostedt <rostedt@goodmis.org>

5 files changed, 4429 insertions, 0 deletions

diff --git a/Makefile b/Makefile
new file mode 100644
index 0000000..538406c
--- /dev/null
+++ b/Makefile
@@ -0,0 +1,20 @@
+CC = gcc
+CFLAGS = -g -Wall # -O2
+INCLUDES = -I. -I/usr/local/include
+
+%.o: %.c
+        $(CC) -c $(CFLAGS) $(INCLUDES) $< -o $@
+
+TARGETS = trace-cmd
+
+all: $(TARGETS)
+
+parse-events.o::        parse-events.h
+trace-read.o::          parse-events.h
+trace-cmd.o::           parse-events.h
+
+trace-cmd: trace-cmd.o trace-read.o parse-events.o
+        $(CC) $^ -o $@
+
+clean:
+        $(RM) *.o *~ $(TARGETS)
diff --git a/parse-events.c b/parse-events.c
new file mode 100644
index 0000000..c5d8fe1
--- /dev/null
+++ b/parse-events.c
@@ -0,0 +1,2491 @@
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <ctype.h>
+#include <errno.h>
+
+#include "parse-events.h"
+
+static char *input_buf;
+static unsigned long long input_buf_ptr;
+static unsigned long long input_buf_siz;
+
+static int cpus;
+static int long_size;
+
+static void init_input_buf(char *buf, unsigned long long size)
+{
+        input_buf = buf;
+        input_buf_siz = size;
+        input_buf_ptr = 0;
+}
+
+void breakpoint(void)
+{
+        static int x;
+        x++;
+}
+
+struct cmdline {
+        char *comm;
+        int pid;
+};
+
+static struct cmdline *cmdlines;
+static int cmdline_count;
+
+static int cmdline_cmp(const void *a, const void *b)
+{
+        const struct cmdline *ca = a;
+        const struct cmdline *cb = b;
+
+        if (ca->pid < cb->pid)
+                return -1;
+        if (ca->pid > cb->pid)
+                return 1;
+
+        return 0;
+}
+
+void parse_cmdlines(char *file, int size)
+{
+        struct cmdline_list {
+                struct cmdline_list     *next;
+                char                    *comm;
+                int                     pid;
+        } *list = NULL, *item;
+        char *line;
+        char *next;
+        int i;
+
+        line = strtok_r(file, "\n", &next);
+        while (line) {
+                item = malloc_or_die(sizeof(*item));
+                sscanf(line, "%d %as", &item->pid,
+                       &item->comm);
+                item->next = list;
+                list = item;
+                line = strtok_r(NULL, "\n", &next);
+                cmdline_count++;
+        }
+
+        cmdlines = malloc_or_die(sizeof(*cmdlines) * cmdline_count);
+
+        i = 0;
+        while (list) {
+                cmdlines[i].pid = list->pid;
+                cmdlines[i].comm = list->comm;
+                i++;
+                item = list;
+                list = list->next;
+                free(item);
+        }
+
+        qsort(cmdlines, cmdline_count, sizeof(*cmdlines), cmdline_cmp);
+}
+
+static char *find_cmdline(int pid)
+{
+        const struct cmdline *comm;
+        struct cmdline key;
+
+        if (!pid)
+                return "<idle>";
+
+        key.pid = pid;
+
+        comm = bsearch(&key, cmdlines, cmdline_count, sizeof(*cmdlines),
+                       cmdline_cmp);
+
+        if (comm)
+                return comm->comm;
+        return "<...>";
+}
+
+static struct func_map {
+        unsigned long long              addr;
+        char                            *func;
+        char                            *mod;
+} *func_list;
+static unsigned int func_count;
+
+static int func_cmp(const void *a, const void *b)
+{
+        const struct func_map *fa = a;
+        const struct func_map *fb = b;
+
+        if (fa->addr < fb->addr)
+                return -1;
+        if (fa->addr > fb->addr)
+                return 1;
+
+        return 0;
+}
+
+void parse_proc_kallsyms(char *file, unsigned int size)
+{
+        struct func_list {
+                struct func_list        *next;
+                unsigned long long      addr;
+                char                    *func;
+                char                    *mod;
+        } *list = NULL, *item;
+        char *line;
+        char *next;
+        char *addr_str;
+        char ch;
+        int ret;
+        int i;
+
+        line = strtok_r(file, "\n", &next);
+        while (line) {
+                item = malloc_or_die(sizeof(*item));
+                item->mod = NULL;
+                ret = sscanf(line, "%as %c %as\t[%as",
+                             &addr_str,
+                             &ch,
+                             &item->func,
+                             &item->mod);
+                item->addr = strtoull(addr_str, NULL, 16);
+                free(addr_str);
+
+                /* truncate the extra ']' */
+                if (item->mod)
+                        item->mod[strlen(item->mod) - 1] = 0;
+                        
+
+                item->next = list;
+                list = item;
+                line = strtok_r(NULL, "\n", &next);
+                func_count++;
+        }
+
+        func_list = malloc_or_die(sizeof(*func_list) * func_count + 1);
+
+        i = 0;
+        while (list) {
+                func_list[i].func = list->func;
+                func_list[i].addr = list->addr;
+                func_list[i].mod = list->mod;
+                i++;
+                item = list;
+                list = list->next;
+                free(item);
+        }
+
+        qsort(func_list, func_count, sizeof(*func_list), func_cmp);
+
+        /*
+         * Add a special record at the end.
+         */
+        func_list[func_count].func = NULL;
+        func_list[func_count].addr = 0;
+        func_list[func_count].mod = NULL;
+}
+
+/*
+ * We are searching for a record in between, not an exact
+ * match.
+ */
+static int func_bcmp(const void *a, const void *b)
+{
+        const struct func_map *fa = a;
+        const struct func_map *fb = b;
+
+        if ((fa->addr == fb->addr) ||
+
+            (fa->addr > fb->addr &&
+             fa->addr < (fb+1)->addr))
+                return 0;
+
+        if (fa->addr < fb->addr)
+                return -1;
+
+        return 1;
+}
+
+static struct func_map *find_func(unsigned long long addr)
+{
+        struct func_map *func;
+        struct func_map key;
+
+        key.addr = addr;
+
+        func = bsearch(&key, func_list, func_count, sizeof(*func_list),
+                       func_bcmp);
+
+        return func;
+}
+
+void print_funcs(void)
+{
+        int i;
+
+        for (i = 0; i < func_count; i++) {
+                printf("%016llx %s",
+                       func_list[i].addr,
+                       func_list[i].func);
+                if (func_list[i].mod)
+                        printf(" [%s]\n", func_list[i].mod);
+                else
+                        printf("\n");
+        }
+}
+
+struct event *alloc_event(void)
+{
+        struct event *event;
+
+        event = malloc_or_die(sizeof(*event));
+        memset(event, 0, sizeof(*event));
+
+        return event;
+}
+
+enum event_type {
+        EVENT_ERROR,
+        EVENT_NONE,
+        EVENT_SPACE,
+        EVENT_NEWLINE,
+        EVENT_ITEM,
+        EVENT_OP,
+        EVENT_DELIM,
+        EVENT_DQUOTE,
+        EVENT_SQUOTE,
+};
+
+static struct event *event_list;
+
+static void add_event(struct event *event)
+{
+        event->next = event_list;
+        event_list = event;
+}
+
+static int event_item_type(enum event_type type)
+{
+        switch (type) {
+        case EVENT_ITEM:
+        case EVENT_DQUOTE:
+        case EVENT_SQUOTE:
+                return 1;
+        default:
+                return 0;
+        }
+}
+
+void free_arg(struct print_arg *arg)
+{
+        if (!arg)
+                return;
+
+        switch (arg->type) {
+        case PRINT_ATOM:
+                if (arg->atom.atom)
+                        free(arg->atom.atom);
+                break;
+        default:
+                /* todo */
+                break;
+        }
+
+        free(arg);
+}
+
+enum event_type get_type(int ch)
+{
+        if (ch == '\n')
+                return EVENT_NEWLINE;
+        if (isspace(ch))
+                return EVENT_SPACE;
+        if (isalnum(ch) || ch == '_')
+                return EVENT_ITEM;
+        if (ch == '\'')
+                return EVENT_SQUOTE;
+        if (ch == '"')
+                return EVENT_DQUOTE;
+        if (!isprint(ch))
+                return EVENT_NONE;
+        if (ch == '(' || ch == ')' || ch == ',')
+                return EVENT_DELIM;
+
+        return EVENT_OP;
+}
+
+static int __read_char(void)
+{
+        if (input_buf_ptr >= input_buf_siz)
+                return -1;
+
+        return input_buf[input_buf_ptr++];
+}
+
+static int __peak_char(void)
+{
+        if (input_buf_ptr >= input_buf_siz)
+                return -1;
+
+        return input_buf[input_buf_ptr];
+}
+
+enum event_type __read_token(char **tok)
+{
+        char buf[BUFSIZ];
+        int ch, last_ch, quote_ch, next_ch;
+        int i = 0;
+        int tok_size = 0;
+        enum event_type type;
+
+        *tok = NULL;
+
+
+        ch = __read_char();
+        if (ch < 0)
+                return EVENT_NONE;
+
+        type = get_type(ch);
+        if (type == EVENT_NONE)
+                return type;
+
+        buf[i++] = ch;
+
+        switch (type) {
+        case EVENT_NEWLINE:
+        case EVENT_DELIM:
+                *tok = malloc_or_die(2);
+                (*tok)[0] = ch;
+                (*tok)[1] = 0;
+                return type;
+
+        case EVENT_OP:
+                switch (ch) {
+                case '-':
+                        next_ch = __peak_char();
+                        if (next_ch == '>') {
+                                buf[i++] = __read_char();
+                                break;
+                        }
+                        /* fall through */
+                case '+':
+                case '|':
+                case '&':
+                case '>':
+                case '<':
+                case '!':
+                        last_ch = ch;
+                        ch = __peak_char();
+                        if (ch != last_ch)
+                                goto test_equal;
+                        buf[i++] = __read_char();
+                        switch (last_ch) {
+                        case '>':
+                        case '<':
+                                goto test_equal;
+                        }
+                        break;
+                }
+                buf[i] = 0;
+                *tok = strdup(buf);
+                return type;
+
+ test_equal:
+                ch = __peak_char();
+                if (ch == '=')
+                        buf[i++] = __read_char();
+                break;
+
+        case EVENT_DQUOTE:
+        case EVENT_SQUOTE:
+                /* don't keep quotes */
+                i--;
+                quote_ch = ch;
+                last_ch = 0;
+                do {
+                        if (i == (BUFSIZ - 1)) {
+                                buf[i] = 0;
+                                if (*tok) {
+                                        *tok = realloc(*tok, tok_size + BUFSIZ);
+                                        if (!*tok)
+                                                return EVENT_NONE;
+                                        strcat(*tok, buf);
+                                } else
+                                        *tok = strdup(buf);
+
+                                if (!*tok)
+                                        return EVENT_NONE;
+                                tok_size += BUFSIZ;
+                                i = 0;
+                        }
+                        last_ch = ch;
+                        ch = __read_char();
+                        buf[i++] = ch;
+                } while (ch != quote_ch && last_ch != '\\');
+                /* remove the last quote */
+                i--;
+                goto out;
+        default:
+                break;
+        }
+                
+        while (get_type(__peak_char()) == type) {
+                if (i == (BUFSIZ - 1)) {
+                        buf[i] = 0;
+                        if (*tok) {
+                                *tok = realloc(*tok, tok_size + BUFSIZ);
+                                if (!*tok)
+                                        return EVENT_NONE;
+                                strcat(*tok, buf);
+                        } else
+                                *tok = strdup(buf);
+
+                        if (!*tok)
+                                return EVENT_NONE;
+                        tok_size += BUFSIZ;
+                        i = 0;
+                }
+                ch = __read_char();
+                buf[i++] = ch;
+        }
+
+ out:
+        buf[i] = 0;
+        if (*tok) {
+                *tok = realloc(*tok, tok_size + i);
+                if (!*tok)
+                        return EVENT_NONE;
+                strcat(*tok, buf);
+        } else
+                *tok = strdup(buf);
+        if (!*tok)
+                return EVENT_NONE;
+
+        return type;
+}
+
+void free_token(char *tok)
+{
+        if (tok)
+                free(tok);
+}
+
+enum event_type read_token(char **tok)
+{
+        enum event_type type;
+
+        for (;;) {
+                type = __read_token(tok);
+                if (type != EVENT_SPACE)
+                        return type;
+
+                free_token(*tok);
+        }
+
+        /* not reached */
+        return EVENT_NONE;
+}
+
+/* no newline */
+enum event_type read_token_item(char **tok)
+{
+        enum event_type type;
+
+        for (;;) {
+                type = __read_token(tok);
+                if (type != EVENT_SPACE && type != EVENT_NEWLINE)
+                        return type;
+
+                free_token(*tok);
+        }
+
+        /* not reached */
+        return EVENT_NONE;
+}
+
+int test_type(enum event_type type, enum event_type expect)
+{
+        if (type != expect) {
+                die("Error: expected type %d but read %d",
+                    expect, type);
+                return -1;
+        }
+        return 0;
+}
+
+int test_type_token(enum event_type type, char *token,
+                    enum event_type expect, char *expect_tok)
+{
+        if (type != expect) {
+                die("Error: expected type %d but read %d",
+                    expect, type);
+                return -1;
+        }
+
+        if (strcmp(token, expect_tok) != 0) {
+                die("Error: expected '%s' but read '%s'",
+                    expect_tok, token);
+                return -1;
+        }
+        return 0;
+}
+
+int __read_expect_type(enum event_type expect, char **tok, int newline_ok)
+{
+        enum event_type type;
+
+        if (newline_ok)
+                type = read_token(tok);
+        else
+                type = read_token_item(tok);
+        return test_type(type, expect);
+}
+
+int read_expect_type(enum event_type expect, char **tok)
+{
+        return __read_expect_type(expect, tok, 1);
+}
+
+int read_expect_type_item(enum event_type expect, char **tok)
+{
+        return __read_expect_type(expect, tok, 0);
+}
+
+int __read_expected(enum event_type expect, char *str, int newline_ok)
+{
+        enum event_type type;
+        char *token;
+        int ret;
+
+        if (newline_ok)
+                type = read_token(&token);
+        else
+                type = read_token_item(&token);
+
+        ret = test_type_token(type, token, expect, str);
+
+        free_token(token);
+
+        return 0;
+}
+
+int read_expected(enum event_type expect, char *str)
+{
+        return __read_expected(expect, str, 1);
+}
+
+int read_expected_item(enum event_type expect, char *str)
+{
+        return __read_expected(expect, str, 0);
+}
+
+char *event_read_name(void)
+{
+        char *token;
+
+        if (read_expected(EVENT_ITEM, "name") < 0)
+                return NULL;
+
+        if (read_expected(EVENT_OP, ":") < 0)
+                return NULL;
+
+        if (read_expect_type(EVENT_ITEM, &token) < 0)
+                goto fail;
+
+        return token;
+
+ fail:
+        free_token(token);
+        return NULL;
+}
+
+int event_read_id(void)
+{
+        char *token;
+        int id;
+
+        if (read_expected_item(EVENT_ITEM, "ID") < 0)
+                return -1;
+
+        if (read_expected(EVENT_OP, ":") < 0)
+                return -1;
+
+        if (read_expect_type(EVENT_ITEM, &token) < 0)
+                goto fail;
+
+        id = strtoul(token, NULL, 0);
+        free_token(token);
+        return id;
+
+ fail:
+        free_token(token);
+        return -1;
+}
+
+int event_read_fields(struct event *event, struct format_field **fields)
+{
+        struct format_field *field = NULL;
+        enum event_type type;
+        char *token;
+        char *last_token;
+        int count = 0;
+
+        do {
+                type = read_token(&token);
+                if (type == EVENT_NEWLINE) {
+                        free_token(token);
+                        return count;
+                }
+
+                count++;
+
+                if (test_type_token(type, token, EVENT_ITEM, "field"))
+                        goto fail;
+                free_token(token);
+
+                type = read_token(&token);
+                /*
+                 * The ftrace fields may still use the "special" name.
+                 * Just ignore it.
+                 */
+                if (event->flags & EVENT_FL_ISFTRACE &&
+                    type == EVENT_ITEM && strcmp(token, "special") == 0) {
+                        free_token(token);
+                        type = read_token(&token);
+                }
+
+                if (test_type_token(type, token, EVENT_OP, ":") < 0)
+                        return -1;
+
+                if (read_expect_type(EVENT_ITEM, &token) < 0)
+                        goto fail;
+
+                last_token = token;
+
+                field = malloc_or_die(sizeof(*field));
+                memset(field, 0, sizeof(*field));
+
+                /* read the rest of the type */
+                for (;;) {
+                        type = read_token(&token);
+                        if (type == EVENT_ITEM ||
+                            (type == EVENT_OP && strcmp(token, "*") == 0) ||
+                            /*
+                             * Some of the ftrace fields are broken and have
+                             * an illegal "." in them.
+                             */
+                            (event->flags & EVENT_FL_ISFTRACE &&
+                             type == EVENT_OP && strcmp(token, ".") == 0)) {
+
+                                if (strcmp(token, "*") == 0)
+                                        field->flags |= FIELD_IS_POINTER;
+
+                                if (field->type) {
+                                        field->type = realloc(field->type,
+                                                              strlen(field->type) +
+                                                              strlen(last_token) + 2);
+                                        strcat(field->type, " ");
+                                        strcat(field->type, last_token);
+                                } else
+                                        field->type = last_token;
+                                last_token = token;
+                                continue;
+                        }
+                                
+                        break;
+                }
+
+                if (!field->type) {
+                        die("no type found");
+                        goto fail;
+                }
+                field->name = last_token;
+
+                if (test_type(type, EVENT_OP))
+                        goto fail;
+
+                if (strcmp(token, "[") == 0) {
+                        field->flags |= FIELD_IS_ARRAY;
+                        /* add brackets to type */
+                        do {
+                                field->type = realloc(field->type,
+                                                      strlen(field->type) +
+                                                      strlen(token) + 1);
+                                strcat(field->type, token);
+                                free_token(token);
+                                type = read_token(&token);
+                                if (type == EVENT_NONE) {
+                                        die("failed to find token");
+                                        goto fail;
+                                }
+                        } while (type != EVENT_OP || strcmp(token, "]") != 0);
+                        field->type = realloc(field->type,
+                                              strlen(field->type) + 2);
+                        strcat(field->type, "]");
+                        free_token(token);
+                        type = read_token(&token);
+                }
+
+                if (test_type_token(type, token,  EVENT_OP, ";"))
+                        goto fail;
+                free_token(token);
+
+                if (read_expected(EVENT_ITEM, "offset") < 0)
+                        goto fail_expect;
+
+                if (read_expected(EVENT_OP, ":") < 0)
+                        goto fail_expect;
+
+                if (read_expect_type(EVENT_ITEM, &token))
+                        goto fail;
+                field->offset = strtoul(token, NULL, 0);
+                free_token(token);
+
+                if (read_expected(EVENT_OP, ";") < 0)
+                        goto fail_expect;
+
+                if (read_expected(EVENT_ITEM, "size") < 0)
+                        goto fail_expect;
+
+                if (read_expected(EVENT_OP, ":") < 0)
+                        goto fail_expect;
+
+                if (read_expect_type(EVENT_ITEM, &token))
+                        goto fail;
+                field->size = strtoul(token, NULL, 0);
+                free_token(token);
+
+                if (read_expected(EVENT_OP, ";") < 0)
+                        goto fail_expect;
+
+                if (read_expect_type(EVENT_NEWLINE, &token) < 0)
+                        goto fail;
+                free_token(token);
+
+                *fields = field;
+                fields = &field->next;
+
+        } while (1);
+
+        return 0;
+
+fail:
+        free_token(token);
+fail_expect:
+        if (field)
+                free(field);
+        return -1;
+}
+
+int event_read_format(struct event *event)
+{
+        char *token;
+        int ret;
+
+        if (read_expected_item(EVENT_ITEM, "format") < 0)
+                return -1;
+
+        if (read_expected(EVENT_OP, ":") < 0)
+                return -1;
+
+        if (read_expect_type(EVENT_NEWLINE, &token))
+                goto fail;
+        free_token(token);
+
+        ret = event_read_fields(event, &event->format.common_fields);
+        if (ret < 0)
+                return ret;
+        event->format.nr_common = ret;
+
+        ret = event_read_fields(event, &event->format.fields);
+        if (ret < 0)
+                return ret;
+        event->format.nr_fields = ret;
+
+        return 0;
+
+ fail:
+        free_token(token);
+        return -1;
+}
+
+enum event_type
+process_arg_token(struct event *event, struct print_arg *arg,
+                  char **tok, enum event_type type);
+        
+enum event_type
+process_arg(struct event *event, struct print_arg *arg, char **tok)
+{
+        enum event_type type;
+        char *token;
+
+        type = read_token(&token);
+        *tok = token;
+
+        return process_arg_token(event, arg, tok, type);
+}
+
+enum event_type
+process_cond(struct event *event, struct print_arg *top, char **tok)
+{
+        struct print_arg *arg, *left, *right;
+        enum event_type type;
+        char *token = NULL;
+
+        arg = malloc_or_die(sizeof(*arg));
+        memset(arg, 0, sizeof(*arg));
+
+        left = malloc_or_die(sizeof(*left));
+
+        right = malloc_or_die(sizeof(*right));
+
+        arg->type = PRINT_OP;
+        arg->op.left = left;
+        arg->op.right = right;
+
+        *tok = NULL;
+        type = process_arg(event, left, &token);
+        if (test_type_token(type, token, EVENT_OP, ":"))
+                goto out_free;
+
+        arg->op.op = token;
+
+        type = process_arg(event, right, &token);
+
+        top->op.right = arg;
+
+        *tok = token;
+        return type;
+
+out_free:
+        free_token(*tok);
+        free(right);
+        free(left);
+        free_arg(arg);
+        return EVENT_ERROR;
+}
+
+static int get_op_prio(char *op)
+{
+        if (!op[1]) {
+                switch (op[0]) {
+                case '*':
+                case '/':
+                case '%':
+                        return 6;
+                case '+':
+                case '-':
+                        return 7;
+                        /* '>>' and '<<' are 8 */
+                case '<':
+                case '>':
+                        return 9;
+                        /* '==' and '!=' are 10 */
+                case '&':
+                        return 11;
+                case '^':
+                        return 12;
+                case '|':
+                        return 13;
+                case '?':
+                        return 16;
+                default:
+                        die("unknown op '%c'", op[0]);
+                        return -1;
+                }
+        } else {
+                if (strcmp(op, "++") == 0 ||
+                    strcmp(op, "--") == 0) {
+                        return 3;
+                } else if (strcmp(op, ">>") == 0 ||
+                           strcmp(op, "<<") == 0) {
+                        return 8;
+                } else if (strcmp(op, ">=") == 0 ||
+                           strcmp(op, "<=") == 0) {
+                        return 9;
+                } else if (strcmp(op, "==") == 0 ||
+                           strcmp(op, "!=") == 0) {
+                        return 10;
+                } else if (strcmp(op, "&&") == 0) {
+                        return 14;
+                } else if (strcmp(op, "||") == 0) {
+                        return 15;
+                } else {
+                        die("unknown op '%s'", op);
+                        return -1;
+                }
+        }
+}
+
+static void set_op_prio(struct print_arg *arg)
+{
+
+        /* single ops are the greatest */
+        if (!arg->op.left || arg->op.left->type == PRINT_NULL) {
+                arg->op.prio = 0;
+                return;
+        }
+
+        arg->op.prio = get_op_prio(arg->op.op);
+}
+
+enum event_type
+process_op(struct event *event, struct print_arg *arg, char **tok)
+{
+        struct print_arg *left, *right;
+        enum event_type type;
+        char *token;
+
+        /* the op is passed in via tok */
+        token = *tok;
+
+        if (arg->type == PRINT_OP && !arg->op.left) {
+                /* handle single op */
+                if (token[1]) {
+                        die("bad op token %s", token);
+                        return EVENT_ERROR;
+                }
+                switch (token[0]) {
+                case '!':
+                case '+':
+                case '-':
+                        break;
+                default:
+                        die("bad op token %s", token);
+                        return EVENT_ERROR;
+                }
+
+                /* make an empty left */
+                left = malloc_or_die(sizeof(*left));
+                left->type = PRINT_NULL;
+                arg->op.left = left;
+
+                right = malloc_or_die(sizeof(*right));
+                arg->op.right = right;
+
+                type = process_arg(event, right, tok);
+
+        } else if (strcmp(token, "?") == 0) {
+
+                left = malloc_or_die(sizeof(*left));
+                /* copy the top arg to the left */
+                *left = *arg;
+
+                arg->type = PRINT_OP;
+                arg->op.op = token;
+                arg->op.left = left;
+                arg->op.prio = 0;
+
+                type = process_cond(event, arg, tok);
+
+        } else if (strcmp(token, ">>") == 0 ||
+                   strcmp(token, "<<") == 0 ||
+                   strcmp(token, "&") == 0 ||
+                   strcmp(token, "|") == 0 ||
+                   strcmp(token, "&&") == 0 ||
+                   strcmp(token, "||") == 0 ||
+                   strcmp(token, "-") == 0 ||
+                   strcmp(token, "+") == 0 ||
+                   strcmp(token, "*") == 0 ||
+                   strcmp(token, "^") == 0 ||
+                   strcmp(token, "/") == 0) {
+
+                left = malloc_or_die(sizeof(*left));
+
+                /* copy the top arg to the left */
+                *left = *arg;
+
+                arg->type = PRINT_OP;
+                arg->op.op = token;
+                arg->op.left = left;
+
+                set_op_prio(arg);
+
+                right = malloc_or_die(sizeof(*right));
+
+                type = process_arg(event, right, tok);
+                
+                arg->op.right = right;
+
+        } else {
+                die("unknown op '%s'", token);
+                /* the arg is now the left side */
+                return EVENT_NONE;
+        }
+
+
+        if (type == EVENT_OP) {
+                int prio;
+
+                /* higher prios need to be closer to the root */
+                prio = get_op_prio(*tok);
+
+                if (prio > arg->op.prio)
+                        return process_op(event, arg, tok);
+
+                return process_op(event, right, tok);
+        }
+
+        return type;
+}
+
+enum event_type
+process_entry(struct event *event, struct print_arg *arg,
+              char **tok)
+{
+        enum event_type type;
+        char *field;
+        char *token;
+
+        if (read_expected(EVENT_OP, "->") < 0)
+                return EVENT_ERROR;
+
+        if (read_expect_type(EVENT_ITEM, &token) < 0)
+                goto fail;
+        field = token;
+
+        arg->type = PRINT_FIELD;
+        arg->field.name = field;
+
+        type = read_token(&token);
+        *tok = token;
+
+        return type;
+
+fail:
+        free_token(token);
+        return EVENT_ERROR;
+}
+
+static char *arg_eval (struct print_arg *arg);
+
+static long long arg_num_eval(struct print_arg *arg)
+{
+        long long left, right;
+        long long val;
+
+        switch (arg->type) {
+        case PRINT_ATOM:
+                val = strtoll(arg->atom.atom, NULL, 0);
+                break;
+        case PRINT_TYPE:
+                val = arg_num_eval(arg->typecast.item);
+                break;
+        case PRINT_OP:
+                switch (arg->op.op[0]) {
+                case '|':
+                        left = arg_num_eval(arg->op.left);
+                        right = arg_num_eval(arg->op.right);
+                        if (arg->op.op[1])
+                                val = left || right;
+                        else
+                                val = left | right;
+                        break;
+                case '&':
+                        left = arg_num_eval(arg->op.left);
+                        right = arg_num_eval(arg->op.right);
+                        if (arg->op.op[1])
+                                val = left && right;
+                        else
+                                val = left & right;
+                        break;
+                case '<':
+                        left = arg_num_eval(arg->op.left);
+                        right = arg_num_eval(arg->op.right);
+                        switch (arg->op.op[1]) {
+                        case 0:
+                                val = left < right;
+                                break;
+                        case '<':
+                                val = left << right;
+                                break;
+                        case '=':
+                                val = left <= right;
+                                break;
+                        default:
+                                die("unknown op '%s'", arg->op.op);
+                        }
+                        break;
+                case '>':
+                        left = arg_num_eval(arg->op.left);
+                        right = arg_num_eval(arg->op.right);
+                        switch (arg->op.op[1]) {
+                        case 0:
+                                val = left > right;
+                                break;
+                        case '>':
+                                val = left >> right;
+                                break;
+                        case '=':
+                                val = left >= right;
+                                break;
+                        default:
+                                die("unknown op '%s'", arg->op.op);
+                        }
+                        break;
+                case '=':
+                        if (arg->op.op[1] != '=')
+                                die("unknown op '%s'", arg->op.op);
+
+                        val = left == right;
+                        break;
+                default:
+                        die("unknown op '%s'", arg->op.op);
+                }
+                break;
+        default:
+                die("invalid eval type %d", arg->type);
+
+        }
+        return val;
+}
+
+static char *arg_eval (struct print_arg *arg)
+{
+        long long val;
+        static char buf[20];
+
+        switch (arg->type) {
+        case PRINT_ATOM:
+                return arg->atom.atom;
+        case PRINT_TYPE:
+                return arg_eval(arg->typecast.item);
+        case PRINT_OP:
+                val = arg_num_eval(arg);
+                sprintf(buf, "%lld", val);
+                return buf;
+                
+        default:
+                die("invalid eval type %d", arg->type);
+                break;
+        }
+
+        return NULL;
+}
+
+enum event_type
+process_fields(struct event *event, struct print_flag_sym **list, char **tok)
+{
+        enum event_type type;
+        struct print_arg *arg = NULL;
+        struct print_flag_sym *field;
+        char *token = NULL;
+        char *value;
+
+        do {
+                free_token(token);
+                type = read_token_item(&token);
+                if (test_type_token(type, token, EVENT_OP, "{"))
+                        break;
+
+                arg = malloc_or_die(sizeof(*arg));
+
+                free_token(token);
+                type = process_arg(event, arg, &token);
+                if (test_type_token(type, token, EVENT_DELIM, ","))
+                        goto out_free;
+
+                field = malloc_or_die(sizeof(*field));
+                memset(field, 0, sizeof(field));
+
+                value = arg_eval(arg);
+                field->value = strdup(value);
+
+                free_token(token);
+                type = process_arg(event, arg, &token);
+                if (test_type_token(type, token, EVENT_OP, "}"))
+                        goto out_free;
+
+                value = arg_eval(arg);
+                field->str = strdup(value);
+                free_arg(arg);
+                arg = NULL;
+
+                *list = field;
+                list = &field->next;
+
+                free_token(token);
+                type = read_token_item(&token);
+        } while (type == EVENT_DELIM && strcmp(token, ",") == 0);
+
+        *tok = token;
+        return type;
+
+out_free:
+        free_arg(arg);
+        free_token(token);
+
+        return EVENT_ERROR;
+}
+
+enum event_type
+process_flags(struct event *event, struct print_arg *arg, char **tok)
+{
+        struct print_arg *field;
+        enum event_type type;
+        char *token;
+
+        memset(arg, 0, sizeof(*arg));
+        arg->type = PRINT_FLAGS;
+
+        if (read_expected_item(EVENT_DELIM, "(") < 0)
+                return EVENT_ERROR;
+
+        field = malloc_or_die(sizeof(*field));
+
+        type = process_arg(event, field, &token);
+        if (test_type_token(type, token, EVENT_DELIM, ","))
+                goto out_free;
+
+        arg->flags.field = field;
+
+        type = read_token_item(&token);
+        if (event_item_type(type)) {
+                arg->flags.delim = token;
+                type = read_token_item(&token);
+        }
+
+        if (test_type_token(type, token, EVENT_DELIM, ","))
+                goto out_free;
+
+        type = process_fields(event, &arg->flags.flags, &token);
+        if (test_type_token(type, token, EVENT_DELIM, ")"))
+                goto out_free;
+
+        free_token(token);
+        type = read_token_item(tok);
+        return type;
+
+out_free:
+        free_token(token);
+        return EVENT_ERROR;
+}
+
+enum event_type
+process_symbols(struct event *event, struct print_arg *arg, char **tok)
+{
+        struct print_arg *field;
+        enum event_type type;
+        char *token;
+
+        memset(arg, 0, sizeof(*arg));
+        arg->type = PRINT_SYMBOL;
+
+        if (read_expected_item(EVENT_DELIM, "(") < 0)
+                return EVENT_ERROR;
+
+        field = malloc_or_die(sizeof(*field));
+
+        type = process_arg(event, field, &token);
+        if (test_type_token(type, token, EVENT_DELIM, ","))
+                goto out_free;
+
+        arg->symbol.field = field;
+
+        type = process_fields(event, &arg->symbol.symbols, &token);
+        if (test_type_token(type, token, EVENT_DELIM, ")"))
+                goto out_free;
+
+        free_token(token);
+        type = read_token_item(tok);
+        return type;
+
+out_free:
+        free_token(token);
+        return EVENT_ERROR;
+}
+
+enum event_type
+process_paren(struct event *event, struct print_arg *arg, char **tok)
+{
+        struct print_arg *item_arg;
+        enum event_type type;
+        char *token;
+
+        type = process_arg(event, arg, &token);
+
+        if (type == EVENT_ERROR)
+                return EVENT_ERROR;
+
+        if (type == EVENT_OP)
+                type = process_op(event, arg, &token);
+
+        if (type == EVENT_ERROR)
+                return EVENT_ERROR;
+
+        if (test_type_token(type, token, EVENT_DELIM, ")")) {
+                free_token(token);
+                return EVENT_ERROR;
+        }
+
+        free_token(token);
+        type = read_token_item(&token);
+        
+        /*
+         * If the next token is an item or another open paren, then
+         * this was a typecast.
+         */
+        if (event_item_type(type) ||
+            (type == EVENT_DELIM && strcmp(token, "(") == 0)) {
+
+                /* make this a typecast and contine */
+
+                /* prevous must be an atom */
+                if (arg->type != PRINT_ATOM)
+                        die("previous needed to be PRINT_ATOM");
+
+                item_arg = malloc_or_die(sizeof(*item_arg));
+
+                arg->type = PRINT_TYPE;
+                arg->typecast.type = arg->atom.atom;
+                arg->typecast.item = item_arg;
+                type = process_arg_token(event, item_arg, &token, type);
+
+        }
+
+        *tok = token;
+        return type;
+}
+
+
+enum event_type
+process_str(struct event *event, struct print_arg *arg, char **tok)
+{
+        enum event_type type;
+        char *token;
+
+        if (read_expected(EVENT_DELIM, "(") < 0)
+                return EVENT_ERROR;
+
+        if (read_expect_type(EVENT_ITEM, &token) < 0)
+                goto fail;
+
+        arg->type = PRINT_STRING;
+        arg->string.string = token;
+
+        if (read_expected(EVENT_DELIM, ")") < 0)
+                return EVENT_ERROR;
+        
+        type = read_token(&token);
+        *tok = token;
+
+        return type;
+fail:
+        free_token(token);
+        return EVENT_ERROR;
+}
+
+enum event_type
+process_arg_token(struct event *event, struct print_arg *arg,
+                  char **tok, enum event_type type)
+{
+        char *token;
+        char *atom;
+
+        token = *tok;
+
+        switch (type) {
+        case EVENT_ITEM:
+                if (strcmp(token, "REC") == 0) {
+                        free_token(token);
+                        type = process_entry(event, arg, &token);
+                } else if (strcmp(token, "__print_flags") == 0) {
+                        free_token(token);
+                        type = process_flags(event, arg, &token);
+                } else if (strcmp(token, "__print_symbolic") == 0) {
+                        free_token(token);
+                        type = process_symbols(event, arg, &token);
+                } else if (strcmp(token, "__get_str") == 0) {
+                        free_token(token);
+                        type = process_str(event, arg, &token);
+                } else {
+                        atom = token;
+                        /* test the next token */
+                        type = read_token_item(&token);
+
+                        /* atoms can be more than one token long */
+                        while (type == EVENT_ITEM) {
+                                atom = realloc(atom, strlen(atom) + strlen(token) + 2);
+                                strcat(atom, " ");
+                                strcat(atom, token);
+                                free_token(token);
+                                type = read_token_item(&token);
+                        }
+
+                        /* todo, test for function */
+
+                        arg->type = PRINT_ATOM;
+                        arg->atom.atom = atom;
+                }
+                break;
+        case EVENT_DQUOTE:
+        case EVENT_SQUOTE:
+                arg->type = PRINT_ATOM;
+                arg->atom.atom = token;
+                type = read_token_item(&token);
+                break;
+        case EVENT_DELIM:
+                if (strcmp(token, "(") == 0) {
+                        free_token(token);
+                        type = process_paren(event, arg, &token);
+                        break;
+                }
+        case EVENT_OP:
+                /* handle single ops */
+                arg->type = PRINT_OP;
+                arg->op.op = token;
+                arg->op.left = NULL;
+                type = process_op(event, arg, &token);
+
+                break;
+        default:
+                die("unexpected type %d", type);
+        }
+        *tok = token;
+
+        return type;
+}
+
+int event_read_print_args(struct event *event, struct print_arg **list)
+{
+        enum event_type type;
+        struct print_arg *arg;
+        char *token;
+        int args = 0;
+
+        do {
+                arg = malloc_or_die(sizeof(*arg));
+                memset(arg, 0, sizeof(*arg));
+
+                type = process_arg(event, arg, &token);
+
+                if (type == EVENT_ERROR) {
+                        free_arg(arg);
+                        return -1;
+                }
+
+                *list = arg;
+                args++;
+
+                if (type == EVENT_OP) {
+                        type = process_op(event, arg, &token);
+                        list = &arg->next;
+                        continue;
+                }
+
+                if (type == EVENT_DELIM && strcmp(token, ",") == 0) {
+                        free_token(token);
+                        *list = arg;
+                        list = &arg->next;
+                        continue;
+                }
+                break;
+        } while (type != EVENT_NONE);
+
+        if (type != EVENT_NONE)
+                free_token(token);
+
+        return args;
+}
+
+int event_read_print(struct event *event)
+{
+        enum event_type type;
+        char *token;
+        int ret;
+
+        if (read_expected_item(EVENT_ITEM, "print") < 0)
+                return -1;
+
+        if (read_expected(EVENT_ITEM, "fmt") < 0)
+                return -1;
+
+        if (read_expected(EVENT_OP, ":") < 0)
+                return -1;
+
+        if (read_expect_type(EVENT_DQUOTE, &token) < 0)
+                goto fail;
+
+        event->print_fmt.format = token;
+        event->print_fmt.args = NULL;
+
+        /* ok to have no arg */
+        type = read_token_item(&token);
+
+        if (type == EVENT_NONE)
+                return 0;
+
+        if (test_type_token(type, token, EVENT_DELIM, ","))
+                goto fail;
+
+        free_token(token);
+
+        ret = event_read_print_args(event, &event->print_fmt.args);
+        if (ret < 0)
+                return -1;
+
+        return 0;
+
+ fail:
+        free_token(token);
+        return -1;
+}
+
+static struct format_field *
+find_common_field(struct event *event, const char *name)
+{
+        struct format_field *format;
+
+        for (format = event->format.common_fields;
+             format; format = format->next) {
+                if (strcmp(format->name, name) == 0)
+                        break;
+        }
+
+        return format;
+}
+
+static struct format_field *
+find_field(struct event *event, const char *name)
+{
+        struct format_field *format;
+
+        for (format = event->format.fields;
+             format; format = format->next) {
+                if (strcmp(format->name, name) == 0)
+                        break;
+        }
+
+        return format;
+}
+
+static struct format_field *
+find_any_field(struct event *event, const char *name)
+{
+        struct format_field *format;
+
+        format = find_common_field(event, name);
+        if (format)
+                return format;
+        return find_field(event, name);
+}
+
+static unsigned long long read_size(void *ptr, int size)
+{
+        switch (size) {
+        case 1:
+                return *(unsigned char *)ptr;
+        case 2:
+                return *(unsigned short *)ptr;
+        case 4:
+                return *(unsigned int *)ptr;
+        case 8:
+                return *(unsigned long long *)ptr;
+        default:
+                /* BUG! */
+                return 0;
+        }
+}
+
+static int get_common_info(const char *type, int *offset, int *size)
+{
+        struct event *event;
+        struct format_field *field;
+
+        /*
+         * All events should have the same common elements.
+         * Pick any event to find where the type is;
+         */
+        if (!event_list)
+                die("no event_list!");
+
+        event = event_list;
+        field = find_common_field(event, type);
+        if (!field)
+                die("field '%s' not found", type);
+
+        *offset = field->offset;
+        *size = field->size;
+
+        return 0;
+}
+
+static int parse_common_type(void *data)
+{
+        static int type_offset;
+        static int type_size;
+        int ret;
+
+        if (!type_size) {
+                ret = get_common_info("common_type",
+                                      &type_offset,
+                                      &type_size);
+                if (ret < 0)
+                        return ret;
+        }
+        return read_size(data + type_offset, type_size);
+}
+
+static int parse_common_pid(void *data)
+{
+        static int pid_offset;
+        static int pid_size;
+        int ret;
+
+        if (!pid_size) {
+                ret = get_common_info("common_pid",
+                                      &pid_offset,
+                                      &pid_size);
+                if (ret < 0)
+                        return ret;
+        }
+
+        return read_size(data + pid_offset, pid_size);
+}
+
+static struct event *find_event(int id)
+{
+        struct event *event;
+
+        for (event = event_list; event; event = event->next) {
+                if (event->id == id)
+                        break;
+        }
+        return event;
+}
+
+static unsigned long long eval_num_arg(void *data, int size,
+                                   struct event *event, struct print_arg *arg)
+{
+        unsigned long long val = 0;
+        unsigned long long left, right;
+
+        switch (arg->type) {
+        case PRINT_NULL:
+                /* ?? */
+                return 0;
+        case PRINT_ATOM:
+                return strtoull(arg->atom.atom, NULL, 0);
+        case PRINT_FIELD:
+                if (!arg->field.field) {
+                        arg->field.field = find_any_field(event, arg->field.name);
+                        if (!arg->field.field)
+                                die("field %s not found", arg->field.name);
+                }
+                /* must be a number */
+                val = read_size(data + arg->field.field->offset,
+                                arg->field.field->size);
+                break;
+        case PRINT_FLAGS:
+        case PRINT_SYMBOL:
+                break;
+        case PRINT_TYPE:
+                return eval_num_arg(data, size, event, arg->typecast.item);
+        case PRINT_STRING:
+                return 0;
+                break;
+        case PRINT_OP:
+                left = eval_num_arg(data, size, event, arg->op.left);
+                right = eval_num_arg(data, size, event, arg->op.right);
+                switch (arg->op.op[0]) {
+                case '|':
+                        if (arg->op.op[1])
+                                val = left || right;
+                        else
+                                val = left | right;
+                        break;
+                case '&':
+                        if (arg->op.op[1])
+                                val = left && right;
+                        else
+                                val = left & right;
+                        break;
+                case '<':
+                        switch (arg->op.op[1]) {
+                        case 0:
+                                val = left < right;
+                                break;
+                        case '<':
+                                val = left << right;
+                                break;
+                        case '=':
+                                val = left <= right;
+                                break;
+                        default:
+                                die("unknown op '%s'", arg->op.op);
+                        }
+                        break;
+                case '>':
+                        switch (arg->op.op[1]) {
+                        case 0:
+                                val = left > right;
+                                break;
+                        case '>':
+                                val = left >> right;
+                                break;
+                        case '=':
+                                val = left >= right;
+                                break;
+                        default:
+                                die("unknown op '%s'", arg->op.op);
+                        }
+                        break;
+                case '=':
+                        if (arg->op.op[1] != '=')
+                                die("unknown op '%s'", arg->op.op);
+                        val = left == right;
+                        break;
+                }
+                break;
+        }
+        return val;
+}
+
+static unsigned long long eval_flag(const char *flag)
+{
+        /*
+         * Some flags in the format files do not get converted.
+         * If the flag is not numeric, see if it is something that
+         * we already know about.
+         */
+        if (isdigit(flag[0]))
+                return strtoull(flag, NULL, 0);
+
+        if (strcmp("HI_SOFTIRQ", flag) == 0)
+                return 0;
+        if (strcmp("TIMER_SOFTIRQ", flag) == 0)
+                return 1;
+        if (strcmp("NET_TX_SOFTIRQ", flag) == 0)
+                return 2;
+        if (strcmp("NET_RX_SOFTIRQ", flag) == 0)
+                return 3;
+        if (strcmp("BLOCK_SOFTIRQ", flag) == 0)
+                return 4;
+        if (strcmp("TASKLET_SOFTIRQ", flag) == 0)
+                return 5;
+        if (strcmp("SCHED_SOFTIRQ", flag) == 0)
+                return 6;
+        if (strcmp("HRTIMER_SOFTIRQ", flag) == 0)
+                return 7;
+        if (strcmp("RCU_SOFTIRQ", flag) == 0)
+                return 8;
+        return 0;
+}
+
+static void print_str_arg(void *data, int size,
+                          struct event *event, struct print_arg *arg)
+{
+        struct print_flag_sym *flag;
+        unsigned long long val, fval;
+        char *str;
+        int print;
+
+        switch (arg->type) {
+        case PRINT_NULL:
+                /* ?? */
+                return;
+        case PRINT_ATOM:
+                return;
+        case PRINT_FIELD:
+                if (!arg->field.field) {
+                        arg->field.field = find_any_field(event, arg->field.name);
+                        if (!arg->field.field)
+                                die("field %s not found", arg->field.name);
+                }
+                str = malloc_or_die(arg->field.field->size + 1);
+                memcpy(str, data + arg->field.field->offset,
+                       arg->field.field->size);
+                str[arg->field.field->size] = 0;
+                free(str);
+                break;
+        case PRINT_FLAGS:
+                val = eval_num_arg(data, size, event, arg->flags.field);
+                print = 0;
+                for (flag = arg->flags.flags; flag; flag = flag->next) {
+                        fval = eval_flag(flag->value);
+                        if (!val && !fval) {
+                                printf("%s", flag->str);
+                                break;
+                        }
+                        if (fval && (val & fval) == fval) {
+                                if (print && arg->flags.delim)
+                                        printf("%s", arg->flags.delim);
+                                printf("%s", flag->str);
+                                print = 1;
+                                val &= ~fval;
+                        }
+                }
+                break;
+        case PRINT_SYMBOL:
+                val = eval_num_arg(data, size, event, arg->symbol.field);
+                for (flag = arg->symbol.symbols; flag; flag = flag->next) {
+                        fval = eval_flag(flag->value);
+                        if (val == fval) {
+                                printf("%s", flag->str);
+                                break;
+                        }
+                }
+                break;
+
+        case PRINT_TYPE:
+                break;
+        case PRINT_STRING:
+                printf("%s", arg->string.string);
+                break;
+        case PRINT_OP:
+                /*
+                 * The only op for string should be ? :
+                 */
+                if (arg->op.op[0] != '?')
+                        return;
+                val = eval_num_arg(data, size, event, arg->op.left);
+                if (val)
+                        print_str_arg(data, size, event, arg->op.right->op.left);
+                else
+                        print_str_arg(data, size, event, arg->op.right->op.right);
+                break;
+        }
+}
+
+static void pretty_print(void *data, int size, struct event *event)
+{
+        struct print_fmt *print_fmt = &event->print_fmt;
+        struct print_arg *arg = print_fmt->args;
+        const char *ptr = print_fmt->format;
+        unsigned long long val;
+        struct func_map *func;
+        const char *saveptr;
+        char format[32];
+        int show_func;
+        int len;
+        int ls;
+
+        if (event->flags & EVENT_FL_ISFUNC)
+                ptr = " %pF <-- %pF";
+
+        for (; *ptr; ptr++) {
+                ls = 0;
+                if (*ptr == '%') {
+                        saveptr = ptr;
+                        show_func = 0;
+ cont_process:
+                        ptr++;
+                        switch (*ptr) {
+                        case '%':
+                                printf("%%");
+                                break;
+                        case 'l':
+                                ls++;
+                                goto cont_process;
+                        case 'L':
+                                ls = 2;
+                                goto cont_process;
+                        case 'z':
+                        case 'Z':
+                        case '0' ... '9':
+                                goto cont_process;
+                        case 'p':
+                                if (long_size == 4)
+                                        ls = 1;
+                                else
+                                        ls = 2;
+
+                                if (*(ptr+1) == 'F' ||
+                                    *(ptr+1) == 'f') {
+                                        ptr++;
+                                        show_func = 1;
+                                }
+
+                                /* fall through */
+                        case 'd':
+                        case 'i':
+                        case 'x':
+                        case 'X':
+                        case 'u':
+                                if (!arg)
+                                        die("no argument match");
+
+                                len = ((unsigned long)ptr + 1) -
+                                        (unsigned long)saveptr;
+
+                                /* should never happen */
+                                if (len > 32)
+                                        die("bad format!");
+
+                                memcpy(format, saveptr, len);
+                                format[len] = 0;
+
+                                val = eval_num_arg(data, size, event, arg);
+                                arg = arg->next;
+
+                                if (show_func) {
+                                        func = find_func(val);
+                                        if (func) {
+                                                printf("%s+0x%llx",
+                                                       func->func,
+                                                       val - func->addr);
+                                                break;
+                                        }
+                                }
+                                switch (ls) {
+                                case 0:
+                                        printf(format, (int)val);
+                                        break;
+                                case 1:
+                                        printf(format, (long)val);
+                                        break;
+                                case 2:
+                                        printf(format, (long long)val);
+                                        break;
+                                default:
+                                        die("bad count (%d)", ls);
+                                }
+                                break;
+                        case 's':
+                                if (!arg)
+                                        die("no matching argument");
+
+                                print_str_arg(data, size, event, arg);
+                                arg = arg->next;
+                                break;
+                        default:
+                                printf(">%c<", *ptr);
+                                
+                        }
+                } else
+                        printf("%c", *ptr);
+        }
+}
+
+static inline int log10_cpu(int nb)
+{
+        if (nb / 100)
+                return 3;
+        if (nb / 10)
+                return 2;
+        return 1;
+}
+
+/* taken from Linux, written by Frederic Weisbecker */
+static void print_graph_cpu(int cpu)
+{
+        int i;
+        int log10_this = log10_cpu(cpu);
+        int log10_all = log10_cpu(cpus);
+
+
+        /*
+         * Start with a space character - to make it stand out
+         * to the right a bit when trace output is pasted into
+         * email:
+         */
+        printf(" ");
+
+        /*
+         * Tricky - we space the CPU field according to the max
+         * number of online CPUs. On a 2-cpu system it would take
+         * a maximum of 1 digit - on a 128 cpu system it would
+         * take up to 3 digits:
+         */
+        for (i = 0; i < log10_all - log10_this; i++)
+                printf(" ");
+
+        printf("%d) ", cpu);
+}
+
+#define TRACE_GRAPH_PROCINFO_LENGTH     14
+#define TRACE_GRAPH_INDENT      2
+
+static void print_graph_proc(int pid, const char *comm)
+{
+        /* sign + log10(MAX_INT) + '\0' */
+        char pid_str[11];
+        int spaces = 0;
+        int len;
+        int i;
+
+        sprintf(pid_str, "%d", pid);
+
+        /* 1 stands for the "-" character */
+        len = strlen(comm) + strlen(pid_str) + 1;
+
+        if (len < TRACE_GRAPH_PROCINFO_LENGTH)
+                spaces = TRACE_GRAPH_PROCINFO_LENGTH - len;
+
+        /* First spaces to align center */
+        for (i = 0; i < spaces / 2; i++)
+                printf(" ");
+
+        printf("%s-%s", comm, pid_str);
+
+        /* Last spaces to align center */
+        for (i = 0; i < spaces - (spaces / 2); i++)
+                printf(" ");
+}
+
+static struct record *
+get_return_for_leaf(int cpu, int cur_pid, unsigned long long cur_func,
+                    struct record *next)
+{
+        struct format_field *field;
+        struct event *event;
+        unsigned long val;
+        int type;
+        int pid;
+
+        type = parse_common_type(next->data);
+        event = find_event(type);
+        if (!event)
+                return NULL;
+
+        if (!(event->flags & EVENT_FL_ISFUNCRET))
+                return NULL;
+
+        pid = parse_common_pid(next->data);
+        field = find_field(event, "func");
+        if (!field)
+                die("function return does not have field func");
+
+        val = read_size(next->data + field->offset, field->size);
+
+        if (cur_pid != pid || cur_func != val)
+                return NULL;
+
+        /* this is a leaf, now advance the iterator */
+        return read_data(cpu);
+}
+
+/* Signal a overhead of time execution to the output */
+static void print_graph_overhead(unsigned long long duration)
+{
+        /* Non nested entry or return */
+        if (duration == -1)
+                return (void)printf("  ");
+
+        /* Duration exceeded 100 msecs */
+        if (duration > 100000ULL)
+                return (void)printf("! ");
+
+        /* Duration exceeded 10 msecs */
+        if (duration > 10000ULL)
+                return (void)printf("+ ");
+
+        printf("  ");
+}
+
+static void print_graph_duration(unsigned long long duration)
+{
+        unsigned long usecs = duration / 1000;
+        unsigned long nsecs_rem = duration % 1000;
+        /* log10(ULONG_MAX) + '\0' */
+        char msecs_str[21];
+        char nsecs_str[5];
+        int len;
+        int i;
+
+        sprintf(msecs_str, "%lu", usecs);
+
+        /* Print msecs */
+        len = printf("%lu", usecs);
+
+        /* Print nsecs (we don't want to exceed 7 numbers) */
+        if (len < 7) {
+                snprintf(nsecs_str, 8 - len, "%03lu", nsecs_rem);
+                len += printf(".%s", nsecs_str);
+        }
+
+        printf(" us ");
+
+        /* Print remaining spaces to fit the row's width */
+        for (i = len; i < 7; i++)
+                printf(" ");
+
+        printf("|  ");
+}
+
+static void
+print_graph_entry_leaf(struct event *event, void *data, struct record *ret_rec)
+{
+        unsigned long long rettime, calltime;
+        unsigned long long duration, depth;
+        unsigned long long val;
+        struct format_field *field;
+        struct func_map *func;
+        struct event *ret_event;
+        int type;
+        int i;
+
+        type = parse_common_type(ret_rec->data);
+        ret_event = find_event(type);
+
+        field = find_field(ret_event, "rettime");
+        if (!field)
+                die("can't find rettime in return graph");
+        rettime = read_size(ret_rec->data + field->offset, field->size);
+
+        field = find_field(ret_event, "calltime");
+        if (!field)
+                die("can't find rettime in return graph");
+        calltime = read_size(ret_rec->data + field->offset, field->size);
+
+        duration = rettime - calltime;
+
+        /* Overhead */
+        print_graph_overhead(duration);
+
+        /* Duration */
+        print_graph_duration(duration);
+
+        field = find_field(event, "depth");
+        if (!field)
+                die("can't find depth in entry graph");
+        depth = read_size(data + field->offset, field->size);
+
+        /* Function */
+        for (i = 0; i < depth * TRACE_GRAPH_INDENT; i++)
+                printf(" ");
+
+        field = find_field(event, "func");
+        if (!field)
+                die("can't find func in entry graph");
+        val = read_size(data + field->offset, field->size);
+        func = find_func(val);
+
+        if (func)
+                printf("%s();", func->func);
+        else
+                printf("%llx();", val);
+}
+
+static void print_graph_nested(struct event *event, void *data)
+{
+        struct format_field *field;
+        unsigned long long depth;
+        unsigned long long val;
+        struct func_map *func;
+        int i;
+
+        /* No overhead */
+        print_graph_overhead(-1);
+
+        /* No time */
+        printf("           |  ");
+
+        field = find_field(event, "depth");
+        if (!field)
+                die("can't find depth in entry graph");
+        depth = read_size(data + field->offset, field->size);
+
+        /* Function */
+        for (i = 0; i < depth * TRACE_GRAPH_INDENT; i++)
+                printf(" ");
+
+        field = find_field(event, "func");
+        if (!field)
+                die("can't find func in entry graph");
+        val = read_size(data + field->offset, field->size);
+        func = find_func(val);
+
+        if (func)
+                printf("%s() {", func->func);
+        else
+                printf("%llx() {", val);
+}
+
+static void
+pretty_print_func_ent(void *data, int size, struct event *event,
+                      int cpu, int pid, const char *comm,
+                      unsigned long secs, unsigned long usecs)
+{
+        struct format_field *field;
+        struct record *rec;
+        void *copy_data;
+        unsigned long val;
+
+        printf("%5lu.%06lu |  ", secs, usecs);
+
+        print_graph_cpu(cpu);
+        print_graph_proc(pid, comm);
+
+        printf(" | ");
+
+        field = find_field(event, "func");
+        if (!field)
+                die("function entry does not have func field");
+
+        val = read_size(data + field->offset, field->size);
+
+        /*
+         * peak_data may unmap the data pointer. Copy it first.
+         */
+        copy_data = malloc_or_die(size);
+        memcpy(copy_data, data, size);
+        data = copy_data;
+
+        rec = peak_data(cpu);
+        if (rec) {
+                rec = get_return_for_leaf(cpu, pid, val, rec);
+                if (rec) {
+                        print_graph_entry_leaf(event, data, rec);
+                        goto out_free;
+                }
+        }
+        print_graph_nested(event, data);
+out_free:
+        free(data);
+}
+
+static void
+pretty_print_func_ret(void *data, int size, struct event *event,
+                      int cpu, int pid, const char *comm,
+                      unsigned long secs, unsigned long usecs)
+{
+        unsigned long long rettime, calltime;
+        unsigned long long duration, depth;
+        struct format_field *field;
+        int i;
+
+        printf("%5lu.%06lu |  ", secs, usecs);
+
+        print_graph_cpu(cpu);
+        print_graph_proc(pid, comm);
+
+        printf(" | ");
+
+        field = find_field(event, "rettime");
+        if (!field)
+                die("can't find rettime in return graph");
+        rettime = read_size(data + field->offset, field->size);
+
+        field = find_field(event, "calltime");
+        if (!field)
+                die("can't find calltime in return graph");
+        calltime = read_size(data + field->offset, field->size);
+
+        duration = rettime - calltime;
+
+        /* Overhead */
+        print_graph_overhead(duration);
+
+        /* Duration */
+        print_graph_duration(duration);
+
+        field = find_field(event, "depth");
+        if (!field)
+                die("can't find depth in entry graph");
+        depth = read_size(data + field->offset, field->size);
+
+        /* Function */
+        for (i = 0; i < depth * TRACE_GRAPH_INDENT; i++)
+                printf(" ");
+
+        printf("}");
+}
+
+static void
+pretty_print_func_graph(void *data, int size, struct event *event,
+                        int cpu, int pid, const char *comm,
+                        unsigned long secs, unsigned long usecs)
+{
+        if (event->flags & EVENT_FL_ISFUNCENT)
+                pretty_print_func_ent(data, size, event,
+                                      cpu, pid, comm, secs, usecs);
+        else if (event->flags & EVENT_FL_ISFUNCRET)
+                pretty_print_func_ret(data, size, event,
+                                      cpu, pid, comm, secs, usecs);
+        printf("\n");
+}
+
+void print_event(int cpu, void *data, int size, unsigned long long nsecs)
+{
+        struct event *event;
+        unsigned long secs;
+        unsigned long usecs;
+        const char *comm;
+        int type;
+        int pid;
+
+        secs = nsecs / NSECS_PER_SEC;
+        nsecs -= secs * NSECS_PER_SEC;
+        usecs = nsecs / NSECS_PER_USEC;
+
+        type = parse_common_type(data);
+
+        event = find_event(type);
+        if (!event)
+                die("ug! no event found");
+
+        pid = parse_common_pid(data);
+        comm = find_cmdline(pid);
+
+        if (event->flags & (EVENT_FL_ISFUNCENT | EVENT_FL_ISFUNCRET))
+                return pretty_print_func_graph(data, size, event, cpu,
+                                               pid, comm, secs, usecs);
+
+        printf("%16s-%-5d [%03d] %5lu.%06lu: %s: ",
+               comm, pid,  cpu,
+               secs, usecs, event->name);
+
+        pretty_print(data, size, event);
+        printf("\n");
+}
+
+void print_fields(struct print_flag_sym *field)
+{
+        printf("{ %s, %s }", field->value, field->str);
+        if (field->next) {
+                printf(", ");
+                print_fields(field->next);
+        }
+}
+
+void print_args(struct print_arg *args)
+{
+        int print_paren = 1;
+
+        switch (args->type) {
+        case PRINT_NULL:
+                printf("null");
+                break;
+        case PRINT_ATOM:
+                printf("%s", args->atom.atom);
+                break;
+        case PRINT_FIELD:
+                printf("REC->%s", args->field.name);
+                break;
+        case PRINT_FLAGS:
+                printf("__print_flags(");
+                print_args(args->flags.field);
+                printf(", %s, ", args->flags.delim);
+                print_fields(args->flags.flags);
+                printf(")");
+                break;
+        case PRINT_SYMBOL:
+                printf("__print_symbolic(");
+                print_args(args->symbol.field);
+                printf(", ");
+                print_fields(args->symbol.symbols);
+                printf(")");
+                break;
+        case PRINT_STRING:
+                printf("__get_str(%s)", args->string.string);
+                break;
+        case PRINT_TYPE:
+                printf("(%s)", args->typecast.type);
+                print_args(args->typecast.item);
+                break;
+        case PRINT_OP:
+                if (strcmp(args->op.op, ":") == 0)
+                        print_paren = 0;
+                if (print_paren)
+                        printf("(");
+                print_args(args->op.left);
+                printf(" %s ", args->op.op);
+                print_args(args->op.right);
+                if (print_paren)
+                        printf(")");
+                break;
+        }
+        if (args->next) {
+                printf("\n");
+                print_args(args->next);
+        }
+}
+
+int parse_ftrace_file(char *buf, unsigned long size)
+{
+        struct format_field *field;
+        struct print_arg *arg, **list;
+        struct event *event;
+        int ret;
+
+        init_input_buf(buf, size);
+
+        event = alloc_event();
+        if (!event)
+                return -ENOMEM;
+
+        event->flags |= EVENT_FL_ISFTRACE;
+
+        event->name = event_read_name();
+        if (!event->name)
+                die("failed to read ftrace event name");
+
+        if (strcmp(event->name, "function") == 0)
+                event->flags |= EVENT_FL_ISFUNC;
+
+        else if (strcmp(event->name, "funcgraph_entry") == 0)
+                event->flags |= EVENT_FL_ISFUNCENT;
+
+        else if (strcmp(event->name, "funcgraph_exit") == 0)
+                event->flags |= EVENT_FL_ISFUNCRET;
+
+        event->id = event_read_id();
+        if (event->id < 0)
+                die("failed to read ftrace event id");
+
+        add_event(event);
+
+        ret = event_read_format(event);
+        if (ret < 0)
+                die("failed to read ftrace event format");
+
+        ret = event_read_print(event);
+        if (ret < 0)
+                die("failed to read ftrace event print fmt");
+
+        /*
+         * The arguments for ftrace files are parsed by the fields.
+         * Set up the fields as their arguments.
+         */
+        list = &event->print_fmt.args;
+        for (field = event->format.fields; field; field = field->next) {
+                arg = malloc_or_die(sizeof(*arg));
+                memset(arg, 0, sizeof(*arg));
+                *list = arg;
+                list = &arg->next;
+                arg->type = PRINT_FIELD;
+                arg->field.name = field->name;
+                arg->field.field = field;
+        }
+        return 0;
+}
+
+int parse_event_file(char *buf, unsigned long size, char *system)
+{
+        struct event *event;
+        int ret;
+
+        init_input_buf(buf, size);
+
+        event = alloc_event();
+        if (!event)
+                return -ENOMEM;
+
+        event->name = event_read_name();
+        if (!event->name)
+                die("failed to read event name");
+
+        event->id = event_read_id();
+        if (event->id < 0)
+                die("failed to read event id");
+
+        ret = event_read_format(event);
+        if (ret < 0)
+                die("failed to read event format");
+
+        ret = event_read_print(event);
+        if (ret < 0)
+                die("failed to read event print fmt");
+
+#define PRINT_ARGS 0
+        if (PRINT_ARGS && event->print_fmt.args)
+                print_args(event->print_fmt.args);
+
+        add_event(event);
+        return 0;
+}
+
+void parse_set_info(int nr_cpus, int long_sz)
+{
+        cpus = nr_cpus;
+        long_size = long_sz;
+}
diff --git a/parse-events.h b/parse-events.h
new file mode 100644
index 0000000..e77af1f
--- /dev/null
+++ b/parse-events.h
@@ -0,0 +1,171 @@
+#ifndef _PARSE_EVENTS_H
+#define _PARSE_EVENTS_H
+
+#ifndef PAGE_SIZE
+#define PAGE_SIZE               4096ULL
+#endif
+
+#ifndef PAGE_MASK
+#define PAGE_MASK (PAGE_SIZE - 1)
+#endif
+
+enum {
+        RINGBUF_TYPE_PADDING            = 29,
+        RINGBUF_TYPE_TIME_EXTEND        = 30,
+        RINGBUF_TYPE_TIME_STAMP         = 31,
+};
+
+#ifndef TS_SHIFT
+#define TS_SHIFT                27
+#endif
+
+#define NSECS_PER_SEC           1000000000ULL
+#define NSECS_PER_USEC          1000ULL
+
+enum format_flags {
+        FIELD_IS_ARRAY          = 1,
+        FIELD_IS_POINTER        = 2,
+};
+
+struct format_field {
+        struct format_field     *next;
+        char                    *type;
+        char                    *name;
+        int                     offset;
+        int                     size;
+        unsigned long           flags;
+};
+
+struct format {
+        int                     nr_common;
+        int                     nr_fields;
+        struct format_field     *common_fields;
+        struct format_field     *fields;
+};
+
+struct print_arg_atom {
+        char                    *atom;
+};
+
+struct print_arg_string {
+        char                    *string;
+};
+
+struct print_arg_field {
+        char                    *name;
+        struct format_field     *field;
+};
+
+struct print_flag_sym {
+        struct print_flag_sym   *next;
+        char                    *value;
+        char                    *str;
+};
+
+struct print_arg_typecast {
+        char                    *type;
+        struct print_arg        *item;
+};
+
+struct print_arg_flags {
+        struct print_arg        *field;
+        char                    *delim;
+        struct print_flag_sym   *flags;
+};
+
+struct print_arg_symbol {
+        struct print_arg        *field;
+        struct print_flag_sym   *symbols;
+};
+
+struct print_arg;
+
+struct print_arg_op {
+        char                    *op;
+        int                     prio;
+        struct print_arg        *left;
+        struct print_arg        *right;
+};
+
+struct print_arg_func {
+        char                    *name;
+        struct print_arg        *args;
+};
+
+enum print_arg_type {
+        PRINT_NULL,
+        PRINT_ATOM,
+        PRINT_FIELD,
+        PRINT_FLAGS,
+        PRINT_SYMBOL,
+        PRINT_TYPE,
+        PRINT_STRING,
+        PRINT_OP,
+};
+
+struct print_arg {
+        struct print_arg                *next;
+        enum print_arg_type             type;
+        union {
+                struct print_arg_atom           atom;
+                struct print_arg_field          field;
+                struct print_arg_typecast       typecast;
+                struct print_arg_flags          flags;
+                struct print_arg_symbol         symbol;
+                struct print_arg_func           func;
+                struct print_arg_string         string;
+                struct print_arg_op             op;
+        };
+};
+
+struct print_fmt {
+        char                    *format;
+        struct print_arg        *args;
+};
+
+struct event {
+        struct event            *next;
+        char                    *name;
+        int                     id;
+        int                     flags;
+        struct format           format;
+        struct print_fmt        print_fmt;
+};
+
+enum {
+        EVENT_FL_ISFTRACE       = 1,
+        EVENT_FL_ISPRINT        = 2,
+        EVENT_FL_ISBPRINT       = 4,
+        EVENT_FL_ISFUNC         = 8,
+        EVENT_FL_ISFUNCENT      = 16,
+        EVENT_FL_ISFUNCRET      = 32,
+};
+
+struct record {
+        unsigned long long ts;
+        int size;
+        void *data;
+};
+
+void usage(char **argv);
+
+struct record *peak_data(int cpu);
+struct record *read_data(int cpu);
+
+void parse_set_info(int nr_cpus, int long_sz);
+
+void trace_report(int argc, char **argv);
+
+void die(char *fmt, ...);
+void *malloc_or_die(unsigned int size);
+
+void parse_cmdlines(char *file, int size);
+void parse_proc_kallsyms(char *file, unsigned int size);
+
+void print_funcs(void);
+
+int parse_ftrace_file(char *buf, unsigned long size);
+int parse_event_file(char *buf, unsigned long size, char *system);
+void print_event(int cpu, void *data, int size, unsigned long long nsecs);
+
+#endif /* _PARSE_EVENTS_H */
diff --git a/trace-cmd.c b/trace-cmd.c
new file mode 100644
index 0000000..72f070b
--- /dev/null
+++ b/trace-cmd.c
@@ -0,0 +1,1143 @@
+/*
+ * Copyright (C) 2008,2009, Steven Rostedt <srostedt@redhat.com>
+ *
+ * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+ *
+ * This program is free software; you can redistribute it and/or modify
+ * it under the terms of the GNU General Public License as published by
+ * the Free Software Foundation; version 2 of the License (not later!)
+ *
+ * This program is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
+ * GNU General Public License for more details.
+ *
+ * You should have received a copy of the GNU General Public License
+ * along with this program; if not, write to the Free Software
+ * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
+ *
+ * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
+ */
+#define _GNU_SOURCE
+#include <dirent.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <stdarg.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <sys/wait.h>
+#include <pthread.h>
+#include <fcntl.h>
+#include <unistd.h>
+#include <ctype.h>
+#include <errno.h>
+
+#include "parse-events.h"
+
+
+#define VERSION "0.5"
+
+#define _STR(x) #x
+#define STR(x) _STR(x)
+#define MAX_PATH 256
+
+#define TRACE_CTRL      "tracing_on"
+#define TRACE           "trace"
+#define AVAILABLE       "available_tracers"
+#define CURRENT         "current_tracer"
+#define ITER_CTRL       "trace_options"
+#define MAX_LATENCY     "tracing_max_latency"
+
+static const char *output_file = "trace.dat";
+static int output_fd;
+
+static int latency;
+
+static int old_ftrace_name;
+
+static int cpu_count;
+static int *pids;
+
+struct event_list {
+        struct event_list *next;
+        const char *event;
+};
+
+static struct event_list *event_selection;
+
+struct events {
+        struct events *sibling;
+        struct events *children;
+        struct events *next;
+        char *name;
+};
+
+static void delete_temp_file(int cpu)
+{
+        char file[MAX_PATH];
+
+        snprintf(file, MAX_PATH, "%s.cpu%d", output_file, cpu);
+        unlink(file);
+}
+
+static void kill_threads(void)
+{
+        int i;
+
+        if (!cpu_count)
+                return;
+
+        for (i = 0; i < cpu_count; i++) {
+                if (pids[i]) {
+                        kill(pids[i], SIGKILL);
+                        delete_temp_file(i);
+                }
+        }
+}
+
+static void delete_thread_data(void)
+{
+        int i;
+
+        if (!cpu_count)
+                return;
+
+        for (i = 0; i < cpu_count; i++) {
+                if (pids[i])
+                        delete_temp_file(i);
+        }
+}
+
+static void stop_threads(void)
+{
+        int i;
+
+        if (!cpu_count)
+                return;
+
+        for (i = 0; i < cpu_count; i++) {
+                if (pids[i]) {
+                        kill(pids[i], SIGINT);
+                        waitpid(pids[i], NULL, 0);
+                        pids[i] = 0;
+                }
+        }
+}
+
+void die(char *fmt, ...)
+{
+        va_list ap;
+        int ret = errno;
+
+        if (errno)
+                perror("trace-cmd");
+        else
+                ret = -1;
+
+        kill_threads();
+        va_start(ap, fmt);
+        fprintf(stderr, "  ");
+        vfprintf(stderr, fmt, ap);
+        va_end(ap);
+
+        fprintf(stderr, "\n");
+        exit(ret);
+}
+
+void *malloc_or_die(unsigned int size)
+{
+        void *data;
+
+        data = malloc(size);
+        if (!data)
+                die("malloc");
+        return data;
+}
+
+static const char *find_debugfs(void)
+{
+        static char debugfs[MAX_PATH+1];
+        static int debugfs_found;
+        char type[100];
+        FILE *fp;
+
+        if (debugfs_found)
+                return debugfs;
+
+        if ((fp = fopen("/proc/mounts","r")) == NULL)
+                die("Can't open /proc/mounts for read");
+
+        while (fscanf(fp, "%*s %"
+                      STR(MAX_PATH)
+                      "s %99s %*s %*d %*d\n",
+                      debugfs, type) == 2) {
+                if (strcmp(type, "debugfs") == 0)
+                        break;
+        }
+        fclose(fp);
+
+        if (strcmp(type, "debugfs") != 0)
+                die("debugfs not mounted, please mount");
+
+        debugfs_found = 1;
+
+        return debugfs;
+}
+
+/*
+ * Finds the path to the debugfs/tracing
+ * Allocates the string and stores it.
+ */
+static const char *find_tracing_dir(void)
+{
+        static char *tracing;
+        static int tracing_found;
+        const char *debugfs;
+
+        if (tracing_found)
+                return tracing;
+
+        debugfs = find_debugfs();
+
+        tracing = malloc_or_die(strlen(debugfs) + 9);
+
+        sprintf(tracing, "%s/tracing", debugfs);
+
+        tracing_found = 1;
+        return tracing;
+}
+
+static char *get_tracing_file(const char *name)
+{
+        const char *tracing;
+        char *file;
+
+        tracing = find_tracing_dir();
+        if (!tracing)
+                return NULL;
+
+        file = malloc_or_die(strlen(tracing) + strlen(name) + 2);
+
+        sprintf(file, "%s/%s", tracing, name);
+        return file;
+}
+
+static void put_tracing_file(char *file)
+{
+        if (file)
+                free(file);
+}
+
+static void write_trace(const char *file, const char *val)
+{
+        char *path;
+        int fd;
+
+        path = get_tracing_file(file);
+        fd = open(path, O_WRONLY);
+        if (fd < 0)
+                die("writing %s", path);
+        put_tracing_file(path);
+        write(fd, val, strlen(val));
+        close(fd);
+
+}
+
+static int find_trace_type(const char *type)
+{
+        char scan[100];
+        char *path;
+        FILE *fp;
+        int ret;
+
+        path = get_tracing_file(path);
+        fp = fopen(path, "r");
+        if (!fp)
+                die("reading %s", path);
+        put_tracing_file(path);
+        do {
+                ret = fscanf(fp, "%99s", scan);
+                if (ret > 0 && strcmp(scan, "ftrace"))
+                        old_ftrace_name = 1;
+                if (ret > 0 && strcmp(scan, type) == 0)
+                        break;
+        } while (ret > 0);
+        fclose(fp);
+
+        return ret > 0;
+}
+
+static void set_ftrace(int set)
+{
+        int fd;
+        char *val = set ? "1" : "0";
+
+        fd = open("/proc/sys/kernel/ftrace_enabled", O_WRONLY);
+        if (fd < 0)
+                die ("Can't %s ftrace", set ? "enable" : "disable");
+
+        write(fd, val, 1);
+        close(fd);
+}
+
+void run_cmd(int argc, char **argv)
+{
+        int status;
+        int pid;
+
+        if ((pid = fork()) < 0)
+                die("failed to fork");
+        if (!pid) {
+                /* child */
+                if (execvp(argv[0], argv))
+                        exit(-1);
+        }
+        waitpid(pid, &status, 0);
+}
+
+static void show_events(void)
+{
+        char buf[BUFSIZ];
+        char *path;
+        FILE *fp;
+        size_t n;
+
+        path = get_tracing_file("available_events");
+        fp = fopen(path, "r");
+        if (!fp)
+                die("reading %s", path);
+        put_tracing_file(path);
+
+        do {
+                n = fread(buf, 1, BUFSIZ, fp);
+                if (n > 0)
+                        fwrite(buf, 1, n, stdout);
+        } while (n > 0);
+        fclose(fp);
+}
+
+static void show_plugins(void)
+{
+        char buf[BUFSIZ];
+        char *path;
+        FILE *fp;
+        size_t n;
+
+        path = get_tracing_file("available_tracers");
+        fp = fopen(path, "r");
+        if (!fp)
+                die("reading %s", path);
+        put_tracing_file(path);
+
+        do {
+                n = fread(buf, 1, BUFSIZ, fp);
+                if (n > 0)
+                        fwrite(buf, 1, n, stdout);
+        } while (n > 0);
+        fclose(fp);
+}
+
+static void set_plugin(const char *name)
+{
+        FILE *fp;
+        char *path;
+
+        path = get_tracing_file("current_tracer");
+        fp = fopen(path, "w");
+        if (!fp)
+                die("writing to '%s'", path);
+        put_tracing_file(path);
+
+        fwrite(name, 1, strlen(name), fp);
+        fclose(fp);
+}
+
+static void enable_event(const char *name)
+{
+        FILE *fp;
+        char *path;
+        int ret;
+
+        printf("enable %s\n", name);
+        if (strcmp(name, "all") == 0) {
+                path = get_tracing_file("events/enable");
+                fp = fopen(path, "w");
+                if (!fp)
+                        die("writing to '%s'", path);
+                put_tracing_file(path);
+                ret = fwrite("1", 1, 1, fp);
+                fclose(fp);
+                if (ret < 0)
+                        die("writing to '%s'", path);
+                return;
+        }
+
+        path = get_tracing_file("set_event");
+        fp = fopen(path, "w");
+        if (!fp)
+                die("writing to '%s'", path);
+        put_tracing_file(path);
+        ret = fwrite(name, 1, strlen(name), fp);
+        if (ret < 0)
+                die("bad event '%s'", name);
+        ret = fwrite("\n", 1, 1, fp);
+        if (ret < 0)
+                die("bad event '%s'", name);
+        fclose(fp);
+}
+
+static void disable_event(const char *name)
+{
+        FILE *fp;
+        char *path;
+
+        if (strcmp(name, "all") == 0) {
+                path = get_tracing_file("events/enable");
+                fp = fopen(path, "w");
+                if (!fp)
+                        die("writing to '%s'", path);
+                put_tracing_file(path);
+                fwrite("0", 1, 1, fp);
+                fclose(fp);
+        }
+}
+
+static void enable_tracing(void)
+{
+        FILE *fp;
+        char *path;
+
+        /* reset the trace */
+        path = get_tracing_file("tracing_on");
+        fp = fopen(path, "w");
+        if (!fp)
+                die("writing to '%s'", path);
+        put_tracing_file(path);
+        fwrite("1", 1, 1, fp);
+        fclose(fp);
+}
+
+static void disable_tracing(void)
+{
+        FILE *fp;
+        char *path;
+
+        /* reset the trace */
+        path = get_tracing_file("tracing_on");
+        fp = fopen(path, "w");
+        if (!fp)
+                die("writing to '%s'", path);
+        put_tracing_file(path);
+        fwrite("0", 1, 1, fp);
+        fclose(fp);
+}
+
+static void disable_all(void)
+{
+        FILE *fp;
+        char *path;
+
+        disable_tracing();
+
+        set_plugin("nop");
+        disable_event("all");
+
+        /* reset the trace */
+        path = get_tracing_file("trace");
+        fp = fopen(path, "w");
+        if (!fp)
+                die("writing to '%s'", path);
+        put_tracing_file(path);
+        fwrite("0", 1, 1, fp);
+        fclose(fp);
+}
+
+static void enable_events(void)
+{
+        struct event_list *event;
+
+        for (event = event_selection; event; event = event->next) {
+                enable_event(event->event);
+        }
+}
+
+static int count_cpus(void)
+{
+        FILE *fp;
+        char buf[1024];
+        int cpus = 0;
+        char *pbuf;
+        size_t *pn;
+        size_t n;
+        int r;
+
+        n = 1024;
+        pn = &n;
+        pbuf = buf;
+
+        fp = fopen("/proc/cpuinfo", "r");
+        if (!fp)
+                die("Can not read cpuinfo");
+
+        while ((r = getline(&pbuf, pn, fp)) >= 0) {
+                char *p;
+
+                if (strncmp(buf, "processor", 9) != 0)
+                        continue;
+                for (p = buf+9; isspace(*p); p++)
+                        ;
+                if (*p == ':')
+                        cpus++;
+        }
+        fclose(fp);
+
+        return cpus;
+}
+
+static int finished;
+
+static void finish(int sig)
+{
+        /* all done */
+        finished = 1;
+}
+
+static int create_recorder(int cpu)
+{
+        char file[MAX_PATH];
+        const char *tracing;
+        char *path;
+        int out_fd;
+        int in_fd;
+        int brass[2];
+        int pid;
+        int ret;
+        char buf[PAGE_SIZE];
+
+        pid = fork();
+        if (pid < 0)
+                die("fork");
+
+        if (pid)
+                return pid;
+
+        signal(SIGINT, finish);
+
+        /* do not kill tasks on error */
+        cpu_count = 0;
+
+        snprintf(file, MAX_PATH, "%s.cpu%d", output_file, cpu);
+
+        out_fd = open(file, O_WRONLY | O_CREAT | O_TRUNC | O_LARGEFILE, 0644);
+        if (out_fd < 0)
+                die("can't create file '%s'", file);
+
+        tracing = find_tracing_dir();
+
+        path = malloc_or_die(strlen(tracing) + 40);
+
+        sprintf(path, "%s/per_cpu/cpu%d/trace_pipe_raw", tracing, cpu);
+        in_fd = open(path, O_RDONLY);
+        if (in_fd < 0)
+                die("can not read '%s'", path);
+
+        ret = pipe(brass);
+        if (ret < 0)
+                die("can not create pipe");
+
+        do {
+                ret = splice(in_fd, NULL, brass[1], NULL, PAGE_SIZE, 1 /* SPLICE_F_MOVE */);
+                if (ret < 0) {
+                        perror("in");
+                        printf("errno=%d\n", errno);
+                        die("splice in");
+                }
+                ret = splice(brass[0], NULL, out_fd, NULL, PAGE_SIZE, 3 /* and NON_BLOCK */);
+                if (ret < 0 && errno != EAGAIN) {
+                        perror("in");
+                        printf("errno=%d\n", errno);
+                        die("splice out");
+                }
+        } while (!finished);
+
+        /* splice only reads full pages */
+        do {
+                ret = read(in_fd, buf, PAGE_SIZE);
+                if (ret > 0)
+                        write(out_fd, buf, ret);
+        } while (ret > 0);
+
+        exit(0);
+}
+
+static void start_threads(void)
+{
+        int cpus;
+        int i;
+
+        cpus = count_cpus();
+
+        /* make a thread for every CPU we have */
+        pids = malloc_or_die(sizeof(*pids) * cpu_count);
+
+        memset(pids, 0, sizeof(*pids) * cpu_count);
+
+        cpu_count = cpus;
+
+        for (i = 0; i < cpus; i++) {
+                pids[i] = create_recorder(i);
+        }
+}
+
+static ssize_t write_or_die(const void *buf, size_t len)
+{
+        int ret;
+
+        ret = write(output_fd, buf, len);
+        if (ret < 0)
+                die("writing to '%s'", output_file);
+
+        return ret;
+}
+
+static int bigendian(void)
+{
+        unsigned char str[] = { 0x1, 0x2, 0x3, 0x4 };
+        unsigned int *ptr;
+
+        ptr = (unsigned int *)str;
+        return *ptr == 0x1234;
+}
+
+static unsigned long long copy_file_fd(int fd)
+{
+        unsigned long long size = 0;
+        char buf[BUFSIZ];
+        int r;
+
+        do {
+                r = read(fd, buf, BUFSIZ);
+                if (r > 0) {
+                        size += r;
+                        write_or_die(buf, r);
+                }
+        } while (r > 0);
+
+        return size;
+}
+
+static unsigned long long copy_file(const char *file)
+{
+        unsigned long long size = 0;
+        int fd;
+
+        fd = open(file, O_RDONLY);
+        if (fd < 0)
+                die("Can't read '%s'", file);
+        size = copy_file_fd(fd);
+        close(fd);
+
+        return size;
+}
+
+static unsigned long get_size_fd(int fd)
+{
+        unsigned long long size = 0;
+        char buf[BUFSIZ];
+        int r;
+
+        do {
+                r = read(fd, buf, BUFSIZ);
+                if (r > 0)
+                        size += r;
+        } while (r > 0);
+
+        lseek(fd, 0, SEEK_SET);
+
+        return size;
+}
+
+static unsigned long get_size(const char *file)
+{
+        unsigned long long size = 0;
+        int fd;
+
+        fd = open(file, O_RDONLY);
+        if (fd < 0)
+                die("Can't read '%s'", file);
+        size = get_size_fd(fd);
+        close(fd);
+
+        return size;
+}
+
+static void read_header_files(void)
+{
+        unsigned long long size, check_size;
+        char *path;
+        int fd;
+
+        path = get_tracing_file("events/header_page");
+        fd = open(path, O_RDONLY);
+        if (fd < 0)
+                die("can't read '%s'", path);
+
+        /* unfortunately, you can not stat debugfs files for size */
+        size = get_size_fd(fd);
+
+        write_or_die("header_page", 12);
+        write_or_die(&size, 8);
+        check_size = copy_file_fd(fd);
+        if (size != check_size)
+                die("wrong size for '%s' size=%lld read=%lld",
+                    path, size, check_size);
+        put_tracing_file(path);
+
+        path = get_tracing_file("events/header_event");
+        fd = open(path, O_RDONLY);
+        if (fd < 0)
+                die("can't read '%s'", path);
+
+        size = get_size_fd(fd);
+
+        write_or_die("header_event", 13);
+        write_or_die(&size, 8);
+        check_size = copy_file_fd(fd);
+        if (size != check_size)
+                die("wrong size for '%s'", path);
+        put_tracing_file(path);
+}
+
+static void copy_event_system(const char *sys)
+{
+        unsigned long long size, check_size;
+        struct dirent *dent;
+        struct stat st;
+        char *format;
+        DIR *dir;
+        int count = 0;
+        int ret;
+
+        dir = opendir(sys);
+        if (!dir)
+                die("can't read directory '%s'", sys);
+
+        while ((dent = readdir(dir))) {
+                if (strcmp(dent->d_name, ".") == 0 ||
+                    strcmp(dent->d_name, "..") == 0)
+                        continue;
+                format = malloc_or_die(strlen(sys) + strlen(dent->d_name) + 10);
+                sprintf(format, "%s/%s/format", sys, dent->d_name);
+                ret = stat(format, &st);
+                free(format);
+                if (ret < 0)
+                        continue;
+                count++;
+        }
+
+        write_or_die(&count, 4);
+        
+        rewinddir(dir);
+        while ((dent = readdir(dir))) {
+                if (strcmp(dent->d_name, ".") == 0 ||
+                    strcmp(dent->d_name, "..") == 0)
+                        continue;
+                format = malloc_or_die(strlen(sys) + strlen(dent->d_name) + 10);
+                sprintf(format, "%s/%s/format", sys, dent->d_name);
+                ret = stat(format, &st);
+
+                if (ret >= 0) {
+                        /* unfortunately, you can not stat debugfs files for size */
+                        size = get_size(format);
+                        write_or_die(&size, 8);
+                        check_size = copy_file(format);
+                        if (size != check_size)
+                                die("error in size of file '%s'", format);
+                }
+
+                free(format);
+        }
+}
+
+static void read_ftrace_files(void)
+{
+        char *path;
+
+        path = get_tracing_file("events/ftrace");
+
+        copy_event_system(path);
+
+        put_tracing_file(path);
+}
+
+static void read_event_files(void)
+{
+        struct dirent *dent;
+        struct stat st;
+        char *path;
+        char *sys;
+        DIR *dir;
+        int count = 0;
+        int ret;
+
+        path = get_tracing_file("events");
+
+        dir = opendir(path);
+        if (!dir)
+                die("can't read directory '%s'", path);
+
+        while ((dent = readdir(dir))) {
+                if (strcmp(dent->d_name, ".") == 0 ||
+                    strcmp(dent->d_name, "..") == 0 ||
+                    strcmp(dent->d_name, "ftrace") == 0)
+                        continue;
+                sys = malloc_or_die(strlen(path) + strlen(dent->d_name) + 2);
+                sprintf(sys, "%s/%s", path, dent->d_name);
+                ret = stat(sys, &st);
+                free(sys);
+                if (ret < 0)
+                        continue;
+                if (S_ISDIR(st.st_mode))
+                        count++;
+        }
+
+        write_or_die(&count, 4);
+
+        rewinddir(dir);
+        while ((dent = readdir(dir))) {
+                if (strcmp(dent->d_name, ".") == 0 ||
+                    strcmp(dent->d_name, "..") == 0 ||
+                    strcmp(dent->d_name, "ftrace") == 0)
+                        continue;
+                sys = malloc_or_die(strlen(path) + strlen(dent->d_name) + 2);
+                sprintf(sys, "%s/%s", path, dent->d_name);
+                ret = stat(sys, &st);
+                if (ret >= 0) {
+                        if (S_ISDIR(st.st_mode)) {
+                                write_or_die(dent->d_name, strlen(dent->d_name) + 1);
+                                copy_event_system(sys);
+                        }
+                }
+                free(sys);
+        }
+
+        put_tracing_file(path);
+}
+
+static void read_proc_kallsyms(void)
+{
+        unsigned int size, check_size;
+        const char *path = "/proc/kallsyms";
+        struct stat st;
+        int ret;
+
+        ret = stat(path, &st);
+        if (ret < 0) {
+                /* not found */
+                size = 0;
+                write_or_die(&size, 4);
+                return;
+        }
+        size = get_size(path);
+        write_or_die(&size, 4);
+        check_size = copy_file(path);
+        if (size != check_size)
+                die("error in size of file '%s'", path);
+
+}
+
+static void read_tracing_data(void)
+{
+        char buf[BUFSIZ];
+
+        output_fd = open(output_file, O_WRONLY | O_CREAT | O_TRUNC | O_LARGEFILE, 0644);
+        if (output_fd < 0)
+                die("creating file '%s'", output_file);
+
+        buf[0] = 23;
+        buf[1] = 8;
+        buf[2] = 68;
+        memcpy(buf + 3, "tracing", 7);
+
+        write_or_die(buf, 10);
+
+        write_or_die(VERSION, strlen(VERSION) + 1);
+
+        if (bigendian())
+                buf[0] = 1;
+        else
+                buf[0] = 0;
+
+        write_or_die(buf, 1);
+
+        buf[0] = sizeof(long);
+        write_or_die(buf, 1);
+
+        read_header_files();
+        read_ftrace_files();
+        read_event_files();
+        read_proc_kallsyms();
+}
+
+static unsigned long long read_thread_file(int cpu)
+{
+        unsigned long long size;
+        char *file;
+
+        file = malloc_or_die(strlen(output_file) + 20);
+        snprintf(file, MAX_PATH, "%s.cpu%d", output_file, cpu);
+
+        size = copy_file(file);
+        free(file);
+        return size;
+}
+
+static void read_trace_data(void)
+{
+        char *path;
+
+        write_or_die("latency  ", 10);
+
+        path = get_tracing_file("trace");
+
+        copy_file(path);
+
+        put_tracing_file(path);
+}
+
+static void read_thread_data(void)
+{
+        unsigned long long offset, check_size;
+        unsigned long long *offsets;
+        unsigned long long *sizes;
+        unsigned long long size;
+        long long ret;
+        struct stat st;
+        char *file;
+        int i;
+                
+        if (!cpu_count)
+                return;
+
+        /*
+         * Save the command lines;
+         */
+        file = get_tracing_file("saved_cmdlines");
+        size = get_size(file);
+        write_or_die(&size, 8);
+        check_size = copy_file(file);
+        if (size != check_size)
+                die("error in size of file '%s'", file);
+        put_tracing_file(file);
+
+        write_or_die(&cpu_count, 4);
+
+        if (latency) {
+                read_trace_data();
+                return;
+        }
+
+        write_or_die("flyrecord", 10);
+
+        offsets = malloc_or_die(sizeof(*offsets) * cpu_count);
+        sizes = malloc_or_die(sizeof(*sizes) * cpu_count);
+
+        offset = lseek(output_fd, 0, SEEK_CUR);
+
+        /* hold any extra data for data */
+        offset += cpu_count * (16);
+        offset = (offset + (PAGE_SIZE - 1)) & ~(PAGE_MASK);
+
+        for (i = 0; i < cpu_count; i++) {
+                file = malloc_or_die(strlen(output_file) + 20);
+                sprintf(file, "%s.cpu%d", output_file, i);
+                ret = stat(file, &st);
+                if (ret < 0)
+                        die("can not stat '%s'", file);
+                free(file);
+                offsets[i] = offset;
+                sizes[i] = st.st_size;
+                offset += st.st_size;
+                offset = (offset + (PAGE_SIZE - 1)) & ~(PAGE_MASK);
+
+                write_or_die(&offsets[i], 8);
+                write_or_die(&sizes[i], 8);
+        }
+
+        for (i = 0; i < cpu_count; i++) {
+                printf("offset=%llx\n", offsets[i]);
+                ret = lseek64(output_fd, offsets[i], SEEK_SET);
+                if (ret < 0)
+                        die("could not seek to %lld\n", offsets[i]);
+                check_size = read_thread_file(i);
+                if (check_size != sizes[i])
+                        die("did not match size of %lld to %lld",
+                            check_size, sizes[i]);
+        }
+}
+
+void usage(char **argv)
+{
+        char *arg = argv[0];
+        char *p = arg+strlen(arg);
+
+        while (p >= arg && *p != '/')
+                p--;
+        p++;
+
+        printf("\n"
+               "%s version %s\n\n"
+               "usage: %s record [-e event][-p plugin] [-d] [-o file] command ...\n"
+               "          -e run command with event enabled\n"
+               "          -p run command with plugin enabled\n"
+               "          -d disable function tracer when running\n"
+               "          -o data output file [default trace.dat]\n"
+               "\n"
+               " %s report [-i file] [--cpu cpu] [-e][-f]\n"
+               "          -i input file [default trace.dat]\n"
+               "          -e show file endianess\n"
+               "          -f show function list\n"
+               "\n"
+               " %s list [-e][-p]\n"
+               "          -e list available events\n"
+               "          -p list available plugins\n"
+               "\n", p, VERSION, p, p, p);
+        exit(-1);
+}
+
+int main (int argc, char **argv)
+{
+        const char *plugin = NULL;
+        const char *output = NULL;
+        struct event_list *event;
+        int disable = 0;
+        int plug = 0;
+        int events = 0;
+
+        int c;
+
+        if (argc < 2)
+                usage(argv);
+
+        if (strcmp(argv[1], "report") == 0) {
+                trace_report(argc, argv);
+                exit(0);
+        } else if (strcmp(argv[1], "record") == 0) {
+
+                while ((c = getopt(argc-1, argv+1, "+he:p:do:")) >= 0) {
+                        switch (c) {
+                        case 'h':
+                                usage(argv);
+                                break;
+                        case 'e':
+                                events = 1;
+                                event = malloc_or_die(sizeof(*event));
+                                event->event = optarg;
+                                event->next = event_selection;
+                                event_selection = event;
+                                break;
+                        case 'p':
+                                if (plugin)
+                                        die("only one plugin allowed");
+                                plugin = optarg;
+                                printf("  plugin %s\n", plugin);
+                                break;
+                        case 'd':
+                                disable = 1;
+                                break;
+                        case 'o':
+                                if (output)
+                                        die("only one output file allowed");
+                                output = optarg;
+                        }
+                }
+
+        } else if (strcmp(argv[1], "list") == 0) {
+
+                while ((c = getopt(argc-1, argv+1, "+hep")) >= 0) {
+                        switch (c) {
+                        case 'h':
+                                usage(argv);
+                                break;
+                        case 'e':
+                                events = 1;
+                                break;
+                        case 'p':
+                                plug = 1;
+                                break;
+                        default:
+                                usage(argv);
+                        }
+                }
+
+                if (events)
+                        show_events();
+
+                if (plug)
+                        show_plugins();
+
+                if (!events && !plug) {
+                        printf("events:\n");
+                        show_events();
+                        printf("\nplugins:\n");
+                        show_plugins();
+                }
+
+                exit(0);
+
+        } else {
+                fprintf(stderr, "unkown command: %s\n", argv[1]);
+                usage(argv);
+        }
+
+        if ((argc - optind) < 2)
+                usage(argv);
+
+        if (output)
+                output_file = output;
+
+        read_tracing_data();
+
+        set_ftrace(!disable);
+
+        disable_all();
+
+        start_threads();
+
+        signal(SIGINT, finish);
+
+        if (events)
+                enable_events();
+        if (plugin) {
+                /*
+                 * Latency tracers just save the trace and kill
+                 * the threads.
+                 */
+                if (strcmp(plugin, "irqsoff") == 0 ||
+                    strcmp(plugin, "preemptoff") == 0 ||
+                    strcmp(plugin, "preemptirqsoff") == 0 ||
+                    strcmp(plugin, "wakeup") == 0 ||
+                    strcmp(plugin, "wakeup_rt") == 0) {
+                        latency = 1;
+                        stop_threads();
+                }
+                set_plugin(plugin);
+        }
+
+        enable_tracing();
+
+        run_cmd((argc - optind) - 1, &argv[optind + 1]);
+
+        disable_tracing();
+
+        stop_threads();
+
+        read_thread_data();
+        delete_thread_data();
+
+        exit(0);
+
+        return 0;
+}
+
diff --git a/trace-read.c b/trace-read.c
new file mode 100644
index 0000000..6b6a93b
--- /dev/null
+++ b/trace-read.c
@@ -0,0 +1,604 @@
+#define _GNU_SOURCE
+#include <dirent.h>
+#include <stdio.h>
+#include <stdlib.h>
+#include <string.h>
+#include <getopt.h>
+#include <stdarg.h>
+#include <sys/types.h>
+#include <sys/stat.h>
+#include <sys/wait.h>
+#include <sys/mman.h>
+#include <pthread.h>
+#include <fcntl.h>
+#include <unistd.h>
+#include <ctype.h>
+#include <errno.h>
+
+#include "parse-events.h"
+
+static int input_fd;
+
+static int file_bigendian;
+static int host_bigendian;
+static int long_size;
+
+static int filter_cpu = -1;
+
+static int bigendian(void)
+{
+        unsigned char str[] = { 0x1, 0x2, 0x3, 0x4 };
+        unsigned int *ptr;
+
+        ptr = (unsigned int *)str;
+        return *ptr == 0x01020304;
+}
+
+static int read_or_die(void *data, int size)
+{
+        int r;
+
+        r = read(input_fd, data, size);
+        if (r != size)
+                die("reading input file (size expected=%d received=%d)",
+                    size, r);
+        return r;
+}
+
+static unsigned int __data2host4(unsigned int data)
+{
+        unsigned long long swap;
+
+        if (host_bigendian == file_bigendian)
+                return data;
+
+        swap = ((data & 0xffULL) << 24) |
+                ((data & (0xffULL << 8)) << 8) |
+                ((data & (0xffULL << 16)) >> 8) |
+                ((data & (0xffULL << 24)) >> 24);
+
+        return swap;
+}
+
+static unsigned long long __data2host8(unsigned long long data)
+{
+        unsigned long long swap;
+
+        if (host_bigendian == file_bigendian)
+                return data;
+
+        swap = ((data & 0xffULL) << 56) |
+                ((data & (0xffULL << 8)) << 40) |
+                ((data & (0xffULL << 16)) << 24) |
+                ((data & (0xffULL << 24)) << 8) |
+                ((data & (0xffULL << 32)) >> 8) |
+                ((data & (0xffULL << 40)) >> 24) |
+                ((data & (0xffULL << 48)) >> 40) |
+                ((data & (0xffULL << 56)) >> 56);
+
+        return swap;
+}
+
+#define data2host4(ptr)         __data2host4(*(unsigned int *)ptr)
+#define data2host8(ptr)         __data2host8(*(unsigned long long *)ptr)
+
+static unsigned int read4(void)
+{
+        unsigned int data;
+
+        read_or_die(&data, 4);
+        return __data2host4(data);
+}
+
+static unsigned long long read8(void)
+{
+        unsigned long long data;
+
+        read_or_die(&data, 8);
+        return __data2host8(data);
+}
+
+static char *read_string(void)
+{
+        char buf[BUFSIZ];
+        char *str = NULL;
+        int size = 0;
+        int i;
+        int r;
+
+        for (;;) {
+                r = read(input_fd, buf, BUFSIZ);
+                if (r < 0)
+                        die("reading input file");
+
+                if (!r)
+                        die("no data");
+
+                for (i = 0; i < r; i++) {
+                        if (!buf[i])
+                                break;
+                }
+                if (i < r)
+                        break;
+                        
+                if (str) {
+                        size += BUFSIZ;
+                        str = realloc(str, size);
+                        if (!str)
+                                die("malloc of size %d", size);
+                        memcpy(str + (size - BUFSIZ), buf, BUFSIZ);
+                } else {
+                        size = BUFSIZ;
+                        str = malloc_or_die(size);
+                        memcpy(str, buf, size); 
+                }
+        }
+
+        /* move the file descriptor to the end of the string */
+        r = lseek(input_fd, -(r - (i+1)), SEEK_CUR);
+        if (r < 0)
+                die("lseek");
+
+        if (str) {
+                size += i;
+                str = realloc(str, size);
+                if (!str)
+                        die("malloc of size %d", size);
+                memcpy(str + (size - i), buf, i);
+        } else {
+                size = i;
+                str = malloc_or_die(i);
+                memcpy(str, buf, i);
+        }
+
+        return str;
+}
+
+static void read_proc_kallsyms(void)
+{
+        unsigned int size;
+        char *buf;
+
+        size = read4();
+        if (!size)
+                return;
+
+        buf = malloc_or_die(size);
+        read_or_die(buf, size);
+
+        parse_proc_kallsyms(buf, size);
+
+        free(buf);
+}
+
+static void read_header_files(void)
+{
+        unsigned long long size;
+        char *header_page;
+        char *header_event;
+        char buf[BUFSIZ];
+
+        read_or_die(buf, 12);
+        if (memcmp(buf, "header_page", 12) != 0)
+                die("did not read header page");
+
+        size = read8();
+        header_page = malloc_or_die(size);
+        read_or_die(header_page, size);
+        free(header_page);
+
+        read_or_die(buf, 13);
+        if (memcmp(buf, "header_event", 13) != 0)
+                die("did not read header event");
+
+        size = read8();
+        header_event = malloc_or_die(size);
+        read_or_die(header_event, size);
+        free(header_event);
+}
+
+static void read_ftrace_file(unsigned long long size)
+{
+        char *buf;
+
+        buf = malloc_or_die(size);
+        read_or_die(buf, size);
+        parse_ftrace_file(buf, size);
+        free(buf);
+}
+
+static void read_event_file(char *system, unsigned long long size)
+{
+        char *buf;
+
+        buf = malloc_or_die(size);
+        read_or_die(buf, size);
+        parse_event_file(buf, size, system);
+        free(buf);
+}
+
+static void read_ftrace_files(void)
+{
+        unsigned long long size;
+        int count;
+        int i;
+
+        count = read4();
+
+        for (i = 0; i < count; i++) {
+                size = read8();
+                read_ftrace_file(size);
+        }
+}
+
+static void read_event_files(void)
+{
+        unsigned long long size;
+        char *system;
+        int systems;
+        int count;
+        int i,x;
+
+        systems = read4();
+
+        for (i = 0; i < systems; i++) {
+                system = read_string();
+
+                count = read4();
+                for (x=0; x < count; x++) {
+                        size = read8();
+                        read_event_file(system, size);
+                }
+        }
+}
+
+struct cpu_data {
+        unsigned long long      offset;
+        unsigned long long      size;
+        unsigned long long      timestamp;
+        struct record           *next;
+        char                    *page;
+        int                     cpu;
+        int                     index;
+        int                     page_size;
+};
+
+static int cpus;
+static struct cpu_data *cpu_data;
+
+static void init_cpu(int cpu)
+{
+        if (!cpu_data[cpu].size) {
+                printf("CPU %d is empty\n", cpu);
+                return;
+        }
+
+        cpu_data[cpu].page = mmap(NULL, PAGE_SIZE, PROT_READ, MAP_PRIVATE,
+                                  input_fd, cpu_data[cpu].offset);
+        if (cpu_data[cpu].page == MAP_FAILED)
+                die("failed to mmap cpu %d at offset 0x%llx",
+                    cpu, cpu_data[cpu].offset);
+}
+
+static void get_next_page(int cpu)
+{
+        if (!cpu_data[cpu].page)
+                return;
+
+        munmap(cpu_data[cpu].page, PAGE_SIZE);
+        cpu_data[cpu].page = NULL;
+
+        if (cpu_data[cpu].size <= PAGE_SIZE)
+                return;
+
+        cpu_data[cpu].offset += PAGE_SIZE;
+        cpu_data[cpu].size -= PAGE_SIZE;
+        cpu_data[cpu].index = 0;
+        
+        cpu_data[cpu].page = mmap(NULL, PAGE_SIZE, PROT_READ, MAP_PRIVATE,
+                                  input_fd, cpu_data[cpu].offset);
+        if (cpu_data[cpu].page == MAP_FAILED)
+                die("failed to mmap cpu %d at offset 0x%llx",
+                    cpu, cpu_data[cpu].offset);
+}
+
+static unsigned int type_len4host(unsigned int type_len_ts)
+{
+        return type_len_ts & ((1 << 5) - 1);
+}
+
+static unsigned int ts4host(unsigned int type_len_ts)
+{
+        return type_len_ts >> 5;
+}
+
+static int calc_index(void *ptr, int cpu)
+{
+        return (unsigned long)ptr - (unsigned long)cpu_data[cpu].page;
+}
+
+struct record *peak_data(int cpu)
+{
+        struct record *data;
+        void *page = cpu_data[cpu].page;
+        int index = cpu_data[cpu].index;
+        void *ptr = page + index;
+        unsigned long long extend;
+        unsigned int type_len_ts;
+        unsigned int type_len;
+        unsigned int delta;
+        unsigned int length;
+
+        if (cpu_data[cpu].next)
+                return cpu_data[cpu].next;
+
+        if (!page)
+                return NULL;
+
+        if (!index) {
+                /* FIXME: handle header page */
+                cpu_data[cpu].timestamp = data2host8(ptr);
+                ptr += 8;
+                cpu_data[cpu].page_size = data2host8(ptr);
+                ptr += 8;
+        }
+
+read_again:
+        index = calc_index(ptr, cpu);
+
+        if (index >= cpu_data[cpu].page_size) {
+                get_next_page(cpu);
+                return peak_data(cpu);
+        }
+
+        type_len_ts = data2host4(ptr);
+        ptr += 4;
+
+        type_len = type_len4host(type_len_ts);
+        delta = ts4host(type_len_ts);
+
+        switch (type_len) {
+        case RINGBUF_TYPE_PADDING:
+                if (!delta)
+                        die("error, hit unexpected end of page");
+                length = data2host4(ptr);
+                ptr += 4;
+                length *= 4;
+                ptr += length;
+                goto read_again;
+
+        case RINGBUF_TYPE_TIME_EXTEND:
+                extend = data2host4(ptr);
+                ptr += 4;
+                extend <<= TS_SHIFT;
+                extend += delta;
+                cpu_data[cpu].timestamp += extend;
+                goto read_again;
+
+        case RINGBUF_TYPE_TIME_STAMP:
+                ptr += 12;
+                break;
+        case 0:
+                length = data2host4(ptr);
+                ptr += 4;
+                die("here! length=%d", length);
+                break;
+        default:
+                length = type_len * 4;
+                break;
+        }
+
+        cpu_data[cpu].timestamp += delta;
+
+        data = malloc_or_die(sizeof(*data));
+        memset(data, 0, sizeof(*data));
+
+        data->ts = cpu_data[cpu].timestamp;
+        data->size = length;
+        data->data = ptr;
+        ptr += length;
+
+        cpu_data[cpu].index = calc_index(ptr, cpu);
+        cpu_data[cpu].next = data;
+
+        return data;
+}
+
+struct record *read_data(int cpu)
+{
+        struct record *data;
+
+        data = peak_data(cpu);
+        cpu_data[cpu].next = NULL;
+
+        return data;
+}
+
+static void show_data(int cpu)
+{
+        struct record *record;
+
+        record = read_data(cpu);
+
+        print_event(cpu, record->data, record->size, record->ts);
+
+        free(record);
+}
+
+static void read_rest(void)
+{
+        char buf[BUFSIZ + 1];
+        int r;
+
+        do {
+                r = read(input_fd, buf, BUFSIZ);
+                if (r > 0) {
+                        buf[r] = 0;
+                        printf(buf);
+                }
+        } while (r > 0);
+}
+
+static void read_data_info(void)
+{
+        unsigned long long ts;
+        unsigned long long size;
+        char *cmdlines;
+        struct record *data;
+        char buf[10];
+        int cpu;
+        int next;
+
+        size = read8();
+        cmdlines = malloc_or_die(size);
+        read_or_die(cmdlines, size);
+        parse_cmdlines(cmdlines, size);
+        free(cmdlines);
+
+        cpus = read4();
+        printf("cpus=%d\n", cpus);
+
+        parse_set_info(cpus, long_size);
+
+        /*
+         * Check if this is a latency report or not.
+         */
+        read_or_die(buf, 10);
+        if (strncmp(buf, "latency", 7) == 0) {
+                read_rest();
+                return;
+        }
+
+        cpu_data = malloc_or_die(sizeof(*cpu_data) * cpus);
+        memset(cpu_data, 0, sizeof(*cpu_data) * cpus);
+
+        for (cpu = 0; cpu < cpus; cpu++) {
+                cpu_data[cpu].cpu = cpu;
+                cpu_data[cpu].offset = read8();
+                cpu_data[cpu].size = read8();
+
+                init_cpu(cpu);
+        }
+
+        do {
+                next = -1;
+                ts = 0;
+                if (filter_cpu >= 0) {
+                        cpu = filter_cpu;
+                        data = peak_data(cpu);
+                        if (data)
+                                next = cpu;
+                } else {
+                        for (cpu = 0; cpu < cpus; cpu++) {
+                                data = peak_data(cpu);
+                                if (data && (!ts || data->ts < ts)) {
+                                        ts = data->ts;
+                                        next = cpu;
+                                }
+                        }
+                }
+                if (next >= 0)
+                        show_data(next);
+
+        } while (next >= 0);
+}
+
+
+void trace_report (int argc, char **argv)
+{
+        const char *input_file = "trace.dat";
+        char buf[BUFSIZ];
+        char test[] = { 23, 8, 68 };
+        char *version;
+        int show_funcs = 0;
+        int show_endian = 0;
+        int c;
+
+        if (argc < 2)
+                usage(argv);
+
+        if (strcmp(argv[1], "report") != 0)
+                usage(argv);
+
+        for (;;) {
+                int option_index = 0;
+                static struct option long_options[] = {
+                        {"cpu", required_argument, NULL, 0},
+                        {"help", no_argument, NULL, '?'},
+                        {NULL, 0, NULL, 0}
+                };
+
+                c = getopt_long (argc-1, argv+1, "+hi:fe",
+                        long_options, &option_index);
+                if (c == -1)
+                        break;
+                switch (c) {
+                case 'h':
+                        usage(argv);
+                        break;
+                case 'i':
+                        input_file = optarg;
+                        break;
+                case 'f':
+                        show_funcs = 1;
+                        break;
+                case 'e':
+                        show_endian = 1;
+                        break;
+                case 0:
+                        switch(option_index) {
+                        case 0:
+                                filter_cpu = atoi(optarg);
+                                break;
+                        default:
+                                usage(argv);
+                        }
+                        break;
+                default:
+                        usage(argv);
+                }
+        }
+
+        input_fd = open(input_file, O_RDONLY);
+        if (input_fd < 0)
+                die("opening '%s'\n", input_file);
+
+        read_or_die(buf, 3);
+        if (memcmp(buf, test, 3) != 0)
+                die("not an trace data file");
+
+        read_or_die(buf, 7);
+        if (memcmp(buf, "tracing", 7) != 0)
+                die("not a trace file (missing tracing)");
+
+        version = read_string();
+        printf("version = %s\n", version);
+        free(version);
+
+        read_or_die(buf, 1);
+        file_bigendian = buf[0];
+        host_bigendian = bigendian();
+
+        read_or_die(buf, 1);
+        long_size = buf[0];
+
+        if (show_endian) {
+                printf("file is %s endian and host is %s endian\n",
+                       file_bigendian ? "big" : "little",
+                       host_bigendian ? "big" : "little");
+                return;
+        }
+
+        read_header_files();
+        read_ftrace_files();
+        read_event_files();
+        read_proc_kallsyms();
+
+        if (show_funcs) {
+                print_funcs();
+                return;
+        }
+        read_data_info();
+
+        return;
+}