123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540 |
- /*
- * 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 <stdbool.h>
- #include "../perf.h"
- #include "trace-event.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)
- {
- 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)
- {
- free(file);
- }
- 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;
- }
- 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);
- 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 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 (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 (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);
- }
- }
- 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 (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);
- 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 ||
- !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) {
- if (S_ISDIR(st.st_mode)) {
- write_or_die(dent->d_name, strlen(dent->d_name) + 1);
- copy_event_system(sys, tps);
- }
- }
- 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_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 perf_event_attr *pattrs, int nb_events)
- {
- struct tracepoint_path path, *ppath = &path;
- int i;
- for (i = 0; i < nb_events; i++) {
- if (pattrs[i].type != PERF_TYPE_TRACEPOINT)
- continue;
- ppath->next = tracepoint_id_to_path(pattrs[i].config);
- if (!ppath->next)
- die("%s\n", "No memory to alloc tracepoints list");
- ppath = ppath->next;
- }
- return path.next;
- }
- void read_tracing_data(struct perf_event_attr *pattrs, int nb_events)
- {
- char buf[BUFSIZ];
- struct tracepoint_path *tps;
- 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);
- /* 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 = getpagesize();
- write_or_die(&page_size, 4);
- tps = get_tracepoints_path(pattrs, nb_events);
- read_header_files();
- read_ftrace_files(tps);
- read_event_files(tps);
- read_proc_kallsyms();
- read_ftrace_printk();
- }
|