123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566 |
- /*
- * 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 <mntent.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 <stdbool.h>
- #include <linux/list.h>
- #include <linux/kernel.h>
- #include "../perf.h"
- #include "trace-event.h"
- #include "debugfs.h"
- #include "evsel.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"
- unsigned int page_size;
- static const char *output_file = "trace.info";
- static int output_fd;
- struct event_list {
- struct event_list *next;
- const char *event;
- };
- struct events {
- struct events *sibling;
- struct events *children;
- struct events *next;
- char *name;
- };
- static void die(const char *fmt, ...)
- {
- va_list ap;
- int ret = errno;
- if (errno)
- perror("trace-cmd");
- else
- ret = -1;
- 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)
- {
- const char *path = debugfs_mount(NULL);
- if (!path)
- die("Your kernel not support debugfs filesystem");
- return path;
- }
- /*
- * 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)
- {
- free(file);
- }
- static ssize_t calc_data_size;
- static ssize_t write_or_die(const void *buf, size_t len)
- {
- int ret;
- if (calc_data_size) {
- calc_data_size += len;
- return len;
- }
- ret = write(output_fd, buf, len);
- if (ret < 0)
- die("writing to '%s'", output_file);
- return ret;
- }
- int bigendian(void)
- {
- unsigned char str[] = { 0x1, 0x2, 0x3, 0x4, 0x0, 0x0, 0x0, 0x0};
- unsigned int *ptr;
- ptr = (unsigned int *)(void *)str;
- return *ptr == 0x01020304;
- }
- 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);
- close(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);
- close(fd);
- }
- static bool name_in_tp_list(char *sys, struct tracepoint_path *tps)
- {
- while (tps) {
- if (!strcmp(sys, tps->name))
- return true;
- tps = tps->next;
- }
- return false;
- }
- static void copy_event_system(const char *sys, struct tracepoint_path *tps)
- {
- 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 (dent->d_type != DT_DIR ||
- strcmp(dent->d_name, ".") == 0 ||
- strcmp(dent->d_name, "..") == 0 ||
- !name_in_tp_list(dent->d_name, tps))
- 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 (dent->d_type != DT_DIR ||
- strcmp(dent->d_name, ".") == 0 ||
- strcmp(dent->d_name, "..") == 0 ||
- !name_in_tp_list(dent->d_name, tps))
- 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);
- }
- closedir(dir);
- }
- static void read_ftrace_files(struct tracepoint_path *tps)
- {
- char *path;
- path = get_tracing_file("events/ftrace");
- copy_event_system(path, tps);
- put_tracing_file(path);
- }
- static bool system_in_tp_list(char *sys, struct tracepoint_path *tps)
- {
- while (tps) {
- if (!strcmp(sys, tps->system))
- return true;
- tps = tps->next;
- }
- return false;
- }
- static void read_event_files(struct tracepoint_path *tps)
- {
- 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 (dent->d_type != DT_DIR ||
- strcmp(dent->d_name, ".") == 0 ||
- strcmp(dent->d_name, "..") == 0 ||
- strcmp(dent->d_name, "ftrace") == 0 ||
- !system_in_tp_list(dent->d_name, tps))
- continue;
- count++;
- }
- write_or_die(&count, 4);
- rewinddir(dir);
- while ((dent = readdir(dir))) {
- if (dent->d_type != DT_DIR ||
- strcmp(dent->d_name, ".") == 0 ||
- strcmp(dent->d_name, "..") == 0 ||
- strcmp(dent->d_name, "ftrace") == 0 ||
- !system_in_tp_list(dent->d_name, tps))
- 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) {
- write_or_die(dent->d_name, strlen(dent->d_name) + 1);
- copy_event_system(sys, tps);
- }
- free(sys);
- }
- closedir(dir);
- 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_ftrace_printk(void)
- {
- unsigned int size, check_size;
- char *path;
- struct stat st;
- int ret;
- path = get_tracing_file("printk_formats");
- ret = stat(path, &st);
- if (ret < 0) {
- /* not found */
- size = 0;
- write_or_die(&size, 4);
- goto out;
- }
- 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);
- out:
- put_tracing_file(path);
- }
- static struct tracepoint_path *
- get_tracepoints_path(struct list_head *pattrs)
- {
- struct tracepoint_path path, *ppath = &path;
- struct perf_evsel *pos;
- int nr_tracepoints = 0;
- list_for_each_entry(pos, pattrs, node) {
- if (pos->attr.type != PERF_TYPE_TRACEPOINT)
- continue;
- ++nr_tracepoints;
- ppath->next = tracepoint_id_to_path(pos->attr.config);
- if (!ppath->next)
- die("%s\n", "No memory to alloc tracepoints list");
- ppath = ppath->next;
- }
- return nr_tracepoints > 0 ? path.next : NULL;
- }
- bool have_tracepoints(struct list_head *pattrs)
- {
- struct perf_evsel *pos;
- list_for_each_entry(pos, pattrs, node)
- if (pos->attr.type == PERF_TYPE_TRACEPOINT)
- return true;
- return false;
- }
- int read_tracing_data(int fd, struct list_head *pattrs)
- {
- char buf[BUFSIZ];
- struct tracepoint_path *tps = get_tracepoints_path(pattrs);
- /*
- * What? No tracepoints? No sense writing anything here, bail out.
- */
- if (tps == NULL)
- return -1;
- output_fd = fd;
- 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);
- /* save endian */
- if (bigendian())
- buf[0] = 1;
- else
- buf[0] = 0;
- write_or_die(buf, 1);
- /* save size of long */
- buf[0] = sizeof(long);
- write_or_die(buf, 1);
- /* save page_size */
- page_size = sysconf(_SC_PAGESIZE);
- write_or_die(&page_size, 4);
- read_header_files();
- read_ftrace_files(tps);
- read_event_files(tps);
- read_proc_kallsyms();
- read_ftrace_printk();
- return 0;
- }
- ssize_t read_tracing_data_size(int fd, struct list_head *pattrs)
- {
- ssize_t size;
- int err = 0;
- calc_data_size = 1;
- err = read_tracing_data(fd, pattrs);
- size = calc_data_size - 1;
- calc_data_size = 0;
- if (err < 0)
- return err;
- return size;
- }
|