X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=formats%2Fctf-text%2Fctf-text.c;h=fa46a9262a184293aa396c37f3b094aef565e95d;hp=2e9509e71cf281672f11c1a2afcbbbbfd001d8f7;hb=b086c01a10fc706dacf1a5a8ea2c4a8acfa0ee24;hpb=642ec66de5bdf7e5e8edfca5d3aacf809955e33e diff --git a/formats/ctf-text/ctf-text.c b/formats/ctf-text/ctf-text.c index 2e9509e7..fa46a926 100644 --- a/formats/ctf-text/ctf-text.c +++ b/formats/ctf-text/ctf-text.c @@ -3,7 +3,9 @@ * * CTF Text Format registration. * - * Copyright 2010, 2011 - Mathieu Desnoyers + * Copyright 2010-2011 EfficiOS Inc. and Linux Foundation + * + * Author: Mathieu Desnoyers * * Permission is hereby granted, free of charge, to any person obtaining a copy * of this software and associated documentation files (the "Software"), to deal @@ -18,7 +20,8 @@ #include #include -#include +#include +#include #include #include #include @@ -31,14 +34,11 @@ #include #include -struct trace_descriptor *ctf_text_open_trace(const char *path, int flags); +struct trace_descriptor *ctf_text_open_trace(const char *path, int flags, + void (*move_pos_slow)(struct ctf_stream_pos *pos, size_t offset, + int whence)); void ctf_text_close_trace(struct trace_descriptor *descriptor); -static -rw_dispatch read_dispatch_table[] = { - /* All unimplemented */ -}; - static rw_dispatch write_dispatch_table[] = { [ CTF_TYPE_INTEGER ] = ctf_text_integer_write, @@ -57,7 +57,179 @@ struct format ctf_text_format = { .close_trace = ctf_text_close_trace, }; -struct trace_descriptor *ctf_text_open_trace(const char *path, int flags) +static GQuark Q_STREAM_PACKET_CONTEXT_TIMESTAMP_BEGIN, + Q_STREAM_PACKET_CONTEXT_TIMESTAMP_END, + Q_STREAM_PACKET_CONTEXT_EVENTS_DISCARDED, + Q_STREAM_PACKET_CONTEXT_CONTENT_SIZE, + Q_STREAM_PACKET_CONTEXT_PACKET_SIZE; + +static +void __attribute__((constructor)) init_quarks(void) +{ + Q_STREAM_PACKET_CONTEXT_TIMESTAMP_BEGIN = g_quark_from_static_string("stream.packet.context.timestamp_begin"); + Q_STREAM_PACKET_CONTEXT_TIMESTAMP_END = g_quark_from_static_string("stream.packet.context.timestamp_end"); + Q_STREAM_PACKET_CONTEXT_EVENTS_DISCARDED = g_quark_from_static_string("stream.packet.context.events_discarded"); + Q_STREAM_PACKET_CONTEXT_CONTENT_SIZE = g_quark_from_static_string("stream.packet.context.content_size"); + Q_STREAM_PACKET_CONTEXT_PACKET_SIZE = g_quark_from_static_string("stream.packet.context.packet_size"); +} + +int print_field(struct definition *definition) +{ + /* Print all fields in verbose mode */ + if (babeltrace_verbose) + return 1; + + /* Filter out part of the packet context */ + if (definition->path == Q_STREAM_PACKET_CONTEXT_TIMESTAMP_BEGIN) + return 0; + if (definition->path == Q_STREAM_PACKET_CONTEXT_TIMESTAMP_END) + return 0; + if (definition->path == Q_STREAM_PACKET_CONTEXT_EVENTS_DISCARDED) + return 0; + if (definition->path == Q_STREAM_PACKET_CONTEXT_CONTENT_SIZE) + return 0; + if (definition->path == Q_STREAM_PACKET_CONTEXT_PACKET_SIZE) + return 0; + + return 1; +} + +static +int ctf_text_write_event(struct stream_pos *ppos, + struct ctf_stream *stream) +{ + struct ctf_text_stream_pos *pos = + container_of(ppos, struct ctf_text_stream_pos, parent); + struct ctf_stream_class *stream_class = stream->stream_class; + int field_nr_saved; + struct ctf_event *event_class; + struct ctf_stream_event *event; + uint64_t id; + int ret; + + id = stream->event_id; + + if (id >= stream_class->events_by_id->len) { + fprintf(stdout, "[error] Event id %" PRIu64 " is outside range.\n", id); + return -EINVAL; + } + event = g_ptr_array_index(stream->events_by_id, id); + if (!event) { + fprintf(stdout, "[error] Event id %" PRIu64 " is unknown.\n", id); + return -EINVAL; + } + event_class = g_ptr_array_index(stream_class->events_by_id, id); + if (!event) { + fprintf(stdout, "[error] Event id %" PRIu64 " is unknown.\n", id); + return -EINVAL; + } + + if (stream->has_timestamp) { + if (pos->print_names) + fprintf(pos->fp, "timestamp = "); + else + fprintf(pos->fp, "["); + fprintf(pos->fp, "%12" PRIu64, stream->timestamp); + if (!pos->print_names) + fprintf(pos->fp, "]"); + + if (pos->print_names) + fprintf(pos->fp, ", "); + else + fprintf(pos->fp, " "); + } + if (pos->print_names) + fprintf(pos->fp, "name = "); + fprintf(pos->fp, "%s", g_quark_to_string(event_class->name)); + if (pos->print_names) + pos->field_nr++; + else + fprintf(pos->fp, ":"); + + /* print cpuid field from packet context */ + if (stream->stream_packet_context) { + if (pos->field_nr++ != 0) + fprintf(pos->fp, ","); + if (pos->print_names) + fprintf(pos->fp, " stream.packet.context ="); + field_nr_saved = pos->field_nr; + pos->field_nr = 0; + ret = generic_rw(ppos, &stream->stream_packet_context->p); + if (ret) + goto error; + pos->field_nr = field_nr_saved; + } + + /* Only show the event header in verbose mode */ + if (babeltrace_verbose && stream->stream_event_header) { + if (pos->field_nr++ != 0) + fprintf(pos->fp, ","); + if (pos->print_names) + fprintf(pos->fp, " stream.event.header ="); + field_nr_saved = pos->field_nr; + pos->field_nr = 0; + ret = generic_rw(ppos, &stream->stream_event_header->p); + if (ret) + goto error; + pos->field_nr = field_nr_saved; + } + + /* print stream-declared event context */ + if (stream->stream_event_context) { + if (pos->field_nr++ != 0) + fprintf(pos->fp, ","); + if (pos->print_names) + fprintf(pos->fp, " stream.event.context ="); + field_nr_saved = pos->field_nr; + pos->field_nr = 0; + ret = generic_rw(ppos, &stream->stream_event_context->p); + if (ret) + goto error; + pos->field_nr = field_nr_saved; + } + + /* print event-declared event context */ + if (event->event_context) { + if (pos->field_nr++ != 0) + fprintf(pos->fp, ","); + if (pos->print_names) + fprintf(pos->fp, " event.context ="); + field_nr_saved = pos->field_nr; + pos->field_nr = 0; + ret = generic_rw(ppos, &event->event_context->p); + if (ret) + goto error; + pos->field_nr = field_nr_saved; + } + + /* Read and print event payload */ + if (event->event_fields) { + if (pos->field_nr++ != 0) + fprintf(pos->fp, ","); + if (pos->print_names) + fprintf(pos->fp, " event.fields ="); + field_nr_saved = pos->field_nr; + pos->field_nr = 0; + ret = generic_rw(ppos, &event->event_fields->p); + if (ret) + goto error; + pos->field_nr = field_nr_saved; + } + /* newline */ + fprintf(pos->fp, "\n"); + pos->field_nr = 0; + + return 0; + +error: + fprintf(stdout, "[error] Unexpected end of stream. Either the trace data stream is corrupted or metadata description does not match data layout.\n"); + return ret; +} + + +struct trace_descriptor *ctf_text_open_trace(const char *path, int flags, + void (*move_pos_slow)(struct ctf_stream_pos *pos, size_t offset, + int whence)) { struct ctf_text_stream_pos *pos; FILE *fp; @@ -65,12 +237,17 @@ struct trace_descriptor *ctf_text_open_trace(const char *path, int flags) pos = g_new0(struct ctf_text_stream_pos, 1); switch (flags & O_ACCMODE) { - case O_WRONLY: - fp = fopen(path, "w"); + case O_RDWR: + if (!path) + fp = stdout; + else + fp = fopen(path, "w"); if (!fp) goto error; pos->fp = fp; pos->parent.rw_table = write_dispatch_table; + pos->parent.event_cb = ctf_text_write_event; + pos->print_names = opt_field_names; break; case O_RDONLY: default: