2 * Copyright (C) 2009, Steven Rostedt <srostedt@redhat.com>
4 * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
6 * This program is free software; you can redistribute it and/or modify
7 * it under the terms of the GNU General Public License as published by
8 * the Free Software Foundation; version 2 of the License (not later!)
10 * This program is distributed in the hope that it will be useful,
11 * but WITHOUT ANY WARRANTY; without even the implied warranty of
12 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
13 * GNU General Public License for more details.
15 * You should have received a copy of the GNU General Public License
16 * along with this program; if not, write to the Free Software
17 * Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
19 * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
26 #include <sys/types.h>
37 #include "trace-event.h"
42 static ssize_t trace_data_size;
45 static int __do_read(int fd, void *buf, int size)
50 int ret = read(fd, buf, size);
56 int retw = write(STDOUT_FILENO, buf, ret);
58 if (retw <= 0 || retw != ret) {
59 pr_debug("repiping input file");
71 static int do_read(void *data, int size)
75 r = __do_read(input_fd, data, size);
77 pr_debug("reading input file (size expected=%d received=%d)",
87 /* If it fails, the next read will report it */
88 static void skip(int size)
94 r = size > BUFSIZ ? BUFSIZ : size;
100 static unsigned int read4(struct pevent *pevent)
104 if (do_read(&data, 4) < 0)
106 return __data2host4(pevent, data);
109 static unsigned long long read8(struct pevent *pevent)
111 unsigned long long data;
113 if (do_read(&data, 8) < 0)
115 return __data2host8(pevent, data);
118 static char *read_string(void)
127 r = read(input_fd, &c, 1);
129 pr_debug("reading input file");
139 int retw = write(STDOUT_FILENO, &c, 1);
141 if (retw <= 0 || retw != r) {
142 pr_debug("repiping input file string");
153 trace_data_size += size;
157 memcpy(str, buf, size);
162 static int read_proc_kallsyms(struct pevent *pevent)
166 size = read4(pevent);
170 * Just skip it, now that we configure libtraceevent to use the
171 * tools/perf/ symbol resolver.
173 * We need to skip it so that we can continue parsing old perf.data
174 * files, that contains this /proc/kallsyms payload.
176 * Newer perf.data files will have just the 4-bytes zeros "kallsyms
177 * payload", so that older tools can continue reading it and interpret
178 * it as "no kallsyms payload is present".
180 lseek(input_fd, size, SEEK_CUR);
181 trace_data_size += size;
185 static int read_ftrace_printk(struct pevent *pevent)
190 /* it can have 0 size */
191 size = read4(pevent);
195 buf = malloc(size + 1);
199 if (do_read(buf, size) < 0) {
206 parse_ftrace_printk(pevent, buf, size);
212 static int read_header_files(struct pevent *pevent)
214 unsigned long long size;
219 if (do_read(buf, 12) < 0)
222 if (memcmp(buf, "header_page", 12) != 0) {
223 pr_debug("did not read header page");
227 size = read8(pevent);
229 header_page = malloc(size);
230 if (header_page == NULL)
233 if (do_read(header_page, size) < 0) {
234 pr_debug("did not read header page");
239 if (!pevent_parse_header_page(pevent, header_page, size,
240 pevent_get_long_size(pevent))) {
242 * The commit field in the page is of type long,
243 * use that instead, since it represents the kernel.
245 pevent_set_long_size(pevent, pevent->header_page_size_size);
249 if (do_read(buf, 13) < 0)
252 if (memcmp(buf, "header_event", 13) != 0) {
253 pr_debug("did not read header event");
257 size = read8(pevent);
263 static int read_ftrace_file(struct pevent *pevent, unsigned long long size)
270 pr_debug("memory allocation failure\n");
274 ret = do_read(buf, size);
276 pr_debug("error reading ftrace file.\n");
280 ret = parse_ftrace_file(pevent, buf, size);
282 pr_debug("error parsing ftrace file.\n");
288 static int read_event_file(struct pevent *pevent, char *sys,
289 unsigned long long size)
296 pr_debug("memory allocation failure\n");
300 ret = do_read(buf, size);
306 ret = parse_event_file(pevent, buf, size, sys);
308 pr_debug("error parsing event file.\n");
314 static int read_ftrace_files(struct pevent *pevent)
316 unsigned long long size;
321 count = read4(pevent);
323 for (i = 0; i < count; i++) {
324 size = read8(pevent);
325 ret = read_ftrace_file(pevent, size);
332 static int read_event_files(struct pevent *pevent)
334 unsigned long long size;
341 systems = read4(pevent);
343 for (i = 0; i < systems; i++) {
348 count = read4(pevent);
350 for (x=0; x < count; x++) {
351 size = read8(pevent);
352 ret = read_event_file(pevent, sys, size);
363 static int read_saved_cmdline(struct pevent *pevent)
365 unsigned long long size;
369 /* it can have 0 size */
370 size = read8(pevent);
374 buf = malloc(size + 1);
376 pr_debug("memory allocation failure\n");
380 ret = do_read(buf, size);
382 pr_debug("error reading saved cmdlines\n");
387 parse_saved_cmdline(pevent, buf, size);
394 ssize_t trace_report(int fd, struct trace_event *tevent, bool __repipe)
397 char test[] = { 23, 8, 68 };
399 int show_version = 0;
407 struct pevent *pevent = NULL;
413 if (do_read(buf, 3) < 0)
415 if (memcmp(buf, test, 3) != 0) {
416 pr_debug("no trace data in the file");
420 if (do_read(buf, 7) < 0)
422 if (memcmp(buf, "tracing", 7) != 0) {
423 pr_debug("not a trace file (missing 'tracing' tag)");
427 version = read_string();
431 printf("version = %s\n", version);
433 if (do_read(buf, 1) < 0) {
437 file_bigendian = buf[0];
438 host_bigendian = bigendian();
440 if (trace_event__init(tevent)) {
441 pr_debug("trace_event__init failed");
445 pevent = tevent->pevent;
447 pevent_set_flag(pevent, PEVENT_NSEC_OUTPUT);
448 pevent_set_file_bigendian(pevent, file_bigendian);
449 pevent_set_host_bigendian(pevent, host_bigendian);
451 if (do_read(buf, 1) < 0)
453 file_long_size = buf[0];
455 file_page_size = read4(pevent);
459 pevent_set_long_size(pevent, file_long_size);
460 pevent_set_page_size(pevent, file_page_size);
462 err = read_header_files(pevent);
465 err = read_ftrace_files(pevent);
468 err = read_event_files(pevent);
471 err = read_proc_kallsyms(pevent);
474 err = read_ftrace_printk(pevent);
477 if (atof(version) >= 0.6) {
478 err = read_saved_cmdline(pevent);
483 size = trace_data_size;
487 pevent_print_funcs(pevent);
488 } else if (show_printk) {
489 pevent_print_printk(pevent);
496 trace_event__cleanup(tevent);