X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=formats%2Fctf-text%2Fctf-text.c;h=008762339fdef48d861aca994d5a1f6661fcae40;hp=4f5ba73e97b22cf045bbba3294ca43a5ce953bce;hb=b5a8598f01c8e40163449bff173909eff824647b;hpb=4c4ba0211b25f7a4ef4f3fbd7cda9ee5a4bc6330 diff --git a/formats/ctf-text/ctf-text.c b/formats/ctf-text/ctf-text.c index 4f5ba73e..00876233 100644 --- a/formats/ctf-text/ctf-text.c +++ b/formats/ctf-text/ctf-text.c @@ -16,6 +16,14 @@ * * The above copyright notice and this permission notice shall be included in * all copies or substantial portions of the Software. + * + * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR + * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, + * FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE + * AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER + * LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, + * OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE + * SOFTWARE. */ #include @@ -23,6 +31,7 @@ #include #include #include +#include #include #include #include @@ -46,7 +55,11 @@ int opt_all_field_names, opt_trace_domain_field, opt_trace_procname_field, opt_trace_vpid_field, + opt_trace_hostname_field, + opt_trace_default_fields = 1, opt_loglevel_field, + opt_emf_field, + opt_callsite_field, opt_delta_field = 1; enum field_item { @@ -74,11 +87,12 @@ enum bt_loglevel { BT_LOGLEVEL_DEBUG = 14, }; - -struct trace_descriptor *ctf_text_open_trace(const char *path, int flags, - void (*packet_seek)(struct stream_pos *pos, size_t index, +static +struct bt_trace_descriptor *ctf_text_open_trace(const char *path, int flags, + void (*packet_seek)(struct bt_stream_pos *pos, size_t index, int whence), FILE *metadata_fp); -void ctf_text_close_trace(struct trace_descriptor *descriptor); +static +int ctf_text_close_trace(struct bt_trace_descriptor *descriptor); static rw_dispatch write_dispatch_table[] = { @@ -93,7 +107,7 @@ rw_dispatch write_dispatch_table[] = { }; static -struct format ctf_text_format = { +struct bt_format ctf_text_format = { .open_trace = ctf_text_open_trace, .close_trace = ctf_text_close_trace, }; @@ -102,7 +116,8 @@ 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; + Q_STREAM_PACKET_CONTEXT_PACKET_SIZE, + Q_STREAM_PACKET_CONTEXT_PACKET_SEQ_NUM; static void __attribute__((constructor)) init_quarks(void) @@ -112,9 +127,18 @@ void __attribute__((constructor)) init_quarks(void) 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"); + Q_STREAM_PACKET_CONTEXT_PACKET_SEQ_NUM = g_quark_from_static_string("stream.packet.context.packet_seq_num"); } -int print_field(struct definition *definition) +static +struct ctf_callsite_dups *ctf_trace_callsite_lookup(struct ctf_trace *trace, + GQuark callsite_name) +{ + return g_hash_table_lookup(trace->callsites, + (gpointer) (unsigned long) callsite_name); +} + +int print_field(struct bt_definition *definition) { /* Print all fields in verbose mode */ if (babeltrace_verbose) @@ -131,6 +155,8 @@ int print_field(struct definition *definition) return 0; if (definition->path == Q_STREAM_PACKET_CONTEXT_PACKET_SIZE) return 0; + if (definition->path == Q_STREAM_PACKET_CONTEXT_PACKET_SEQ_NUM) + return 0; return 1; } @@ -211,8 +237,7 @@ const char *print_loglevel(int value) } static -int ctf_text_write_event(struct stream_pos *ppos, struct ctf_stream_definition *stream) - +int ctf_text_write_event(struct bt_stream_pos *ppos, struct ctf_stream_definition *stream) { struct ctf_text_stream_pos *pos = container_of(ppos, struct ctf_text_stream_pos, parent); @@ -241,18 +266,7 @@ int ctf_text_write_event(struct stream_pos *ppos, struct ctf_stream_definition * return -EINVAL; } - /* Print events discarded */ - if (stream->events_discarded) { - fflush(pos->fp); - fprintf(stderr, "[warning] Tracer discarded %" PRIu64 " events between [", - stream->events_discarded); - ctf_print_timestamp(stderr, stream, stream->prev_timestamp); - fprintf(stderr, "] and ["); - ctf_print_timestamp(stderr, stream, stream->prev_timestamp_end); - fprintf(stderr, "]. You should consider recording a new trace with larger buffers or with fewer events enabled.\n"); - fflush(stderr); - stream->events_discarded = 0; - } + handle_debug_info_event(stream_class, event); if (stream->has_timestamp) { set_field_names_print(pos, ITEM_HEADER); @@ -260,7 +274,11 @@ int ctf_text_write_event(struct stream_pos *ppos, struct ctf_stream_definition * fprintf(pos->fp, "timestamp = "); else fprintf(pos->fp, "["); - ctf_print_timestamp(pos->fp, stream, stream->timestamp); + if (opt_clock_cycles) { + ctf_print_timestamp(pos->fp, stream, stream->cycles_timestamp); + } else { + ctf_print_timestamp(pos->fp, stream, stream->real_timestamp); + } if (!pos->print_names) fprintf(pos->fp, "]"); @@ -269,7 +287,7 @@ int ctf_text_write_event(struct stream_pos *ppos, struct ctf_stream_definition * else fprintf(pos->fp, " "); } - if ((opt_delta_field || opt_all_fields) && stream->has_timestamp) { + if (opt_delta_field && stream->has_timestamp) { uint64_t delta, delta_sec, delta_nsec; set_field_names_print(pos, ITEM_HEADER); @@ -277,8 +295,8 @@ int ctf_text_write_event(struct stream_pos *ppos, struct ctf_stream_definition * fprintf(pos->fp, "delta = "); else fprintf(pos->fp, "("); - if (pos->last_timestamp != -1ULL) { - delta = stream->timestamp - pos->last_timestamp; + if (pos->last_real_timestamp != -1ULL) { + delta = stream->real_timestamp - pos->last_real_timestamp; delta_sec = delta / NSEC_PER_SEC; delta_nsec = delta % NSEC_PER_SEC; fprintf(pos->fp, "+%" PRIu64 ".%09" PRIu64, @@ -293,21 +311,33 @@ int ctf_text_write_event(struct stream_pos *ppos, struct ctf_stream_definition * fprintf(pos->fp, ", "); else fprintf(pos->fp, " "); - pos->last_timestamp = stream->timestamp; + pos->last_real_timestamp = stream->real_timestamp; + pos->last_cycles_timestamp = stream->cycles_timestamp; } - if ((opt_trace_field || opt_all_fields) && stream_class->trace->path[0] != '\0') { + if ((opt_trace_field || opt_all_fields) && stream_class->trace->parent.path[0] != '\0') { set_field_names_print(pos, ITEM_HEADER); if (pos->print_names) { fprintf(pos->fp, "trace = "); } - fprintf(pos->fp, "%s", stream_class->trace->path); + fprintf(pos->fp, "%s", stream_class->trace->parent.path); if (pos->print_names) fprintf(pos->fp, ", "); else fprintf(pos->fp, " "); } - if ((opt_trace_domain_field && !opt_all_fields) && stream_class->trace->env.domain[0] != '\0') { + if ((opt_trace_hostname_field || opt_all_fields || opt_trace_default_fields) + && stream_class->trace->env.hostname[0] != '\0') { + set_field_names_print(pos, ITEM_HEADER); + if (pos->print_names) { + fprintf(pos->fp, "trace:hostname = "); + } + fprintf(pos->fp, "%s", stream_class->trace->env.hostname); + if (pos->print_names) + fprintf(pos->fp, ", "); + dom_print = 1; + } + if ((opt_trace_domain_field || opt_all_fields) && stream_class->trace->env.domain[0] != '\0') { set_field_names_print(pos, ITEM_HEADER); if (pos->print_names) { fprintf(pos->fp, "trace:domain = "); @@ -317,7 +347,8 @@ int ctf_text_write_event(struct stream_pos *ppos, struct ctf_stream_definition * fprintf(pos->fp, ", "); dom_print = 1; } - if ((opt_trace_procname_field && !opt_all_fields) && stream_class->trace->env.procname[0] != '\0') { + if ((opt_trace_procname_field || opt_all_fields || opt_trace_default_fields) + && stream_class->trace->env.procname[0] != '\0') { set_field_names_print(pos, ITEM_HEADER); if (pos->print_names) { fprintf(pos->fp, "trace:procname = "); @@ -329,7 +360,8 @@ int ctf_text_write_event(struct stream_pos *ppos, struct ctf_stream_definition * fprintf(pos->fp, ", "); dom_print = 1; } - if ((opt_trace_vpid_field && !opt_all_fields) && stream_class->trace->env.vpid != -1) { + if ((opt_trace_vpid_field || opt_all_fields || opt_trace_default_fields) + && stream_class->trace->env.vpid != -1) { set_field_names_print(pos, ITEM_HEADER); if (pos->print_names) { fprintf(pos->fp, "trace:vpid = "); @@ -355,6 +387,55 @@ int ctf_text_write_event(struct stream_pos *ppos, struct ctf_stream_definition * fprintf(pos->fp, ", "); dom_print = 1; } + if ((opt_emf_field || opt_all_fields) && event_class->model_emf_uri) { + set_field_names_print(pos, ITEM_HEADER); + if (pos->print_names) { + fprintf(pos->fp, "model.emf.uri = "); + } else if (dom_print) { + fprintf(pos->fp, ":"); + } + fprintf(pos->fp, "\"%s\"", + g_quark_to_string(event_class->model_emf_uri)); + if (pos->print_names) + fprintf(pos->fp, ", "); + dom_print = 1; + } + if ((opt_callsite_field || opt_all_fields)) { + struct ctf_callsite_dups *cs_dups; + struct ctf_callsite *callsite; + + cs_dups = ctf_trace_callsite_lookup(stream_class->trace, + event_class->name); + if (cs_dups) { + int i = 0; + + set_field_names_print(pos, ITEM_HEADER); + if (pos->print_names) { + fprintf(pos->fp, "callsite = "); + } else if (dom_print) { + fprintf(pos->fp, ":"); + } + fprintf(pos->fp, "["); + bt_list_for_each_entry(callsite, &cs_dups->head, node) { + if (i != 0) + fprintf(pos->fp, ","); + if (CTF_CALLSITE_FIELD_IS_SET(callsite, ip)) { + fprintf(pos->fp, "%s@0x%" PRIx64 ":%s:%" PRIu64 "", + callsite->func, callsite->ip, callsite->file, + callsite->line); + } else { + fprintf(pos->fp, "%s:%s:%" PRIu64 "", + callsite->func, callsite->file, + callsite->line); + } + i++; + } + fprintf(pos->fp, "]"); + if (pos->print_names) + fprintf(pos->fp, ", "); + dom_print = 1; + } + } if (dom_print && !pos->print_names) fprintf(pos->fp, " "); set_field_names_print(pos, ITEM_HEADER); @@ -448,7 +529,6 @@ int ctf_text_write_event(struct stream_pos *ppos, struct ctf_stream_definition * /* newline */ fprintf(pos->fp, "\n"); pos->field_nr = 0; - stream->consumed = 1; return 0; @@ -457,9 +537,9 @@ error: return ret; } - -struct trace_descriptor *ctf_text_open_trace(const char *path, int flags, - void (*packet_seek)(struct stream_pos *pos, size_t index, +static +struct bt_trace_descriptor *ctf_text_open_trace(const char *path, int flags, + void (*packet_seek)(struct bt_stream_pos *pos, size_t index, int whence), FILE *metadata_fp) { struct ctf_text_stream_pos *pos; @@ -467,7 +547,8 @@ struct trace_descriptor *ctf_text_open_trace(const char *path, int flags, pos = g_new0(struct ctf_text_stream_pos, 1); - pos->last_timestamp = -1ULL; + pos->last_real_timestamp = -1ULL; + pos->last_cycles_timestamp = -1ULL; switch (flags & O_ACCMODE) { case O_RDWR: if (!path) @@ -479,7 +560,9 @@ struct trace_descriptor *ctf_text_open_trace(const char *path, int flags, pos->fp = fp; pos->parent.rw_table = write_dispatch_table; pos->parent.event_cb = ctf_text_write_event; + pos->parent.trace = &pos->trace_descriptor; pos->print_names = 0; + babeltrace_ctf_console_output++; break; case O_RDONLY: default: @@ -493,14 +576,26 @@ error: return NULL; } -void ctf_text_close_trace(struct trace_descriptor *td) +static +int ctf_text_close_trace(struct bt_trace_descriptor *td) { + int ret; struct ctf_text_stream_pos *pos = container_of(td, struct ctf_text_stream_pos, trace_descriptor); - fclose(pos->fp); + + babeltrace_ctf_console_output--; + if (pos->fp != stdout) { + ret = fclose(pos->fp); + if (ret) { + perror("Error on fclose"); + return -1; + } + } g_free(pos); + return 0; } +static void __attribute__((constructor)) ctf_text_init(void) { int ret; @@ -510,4 +605,8 @@ void __attribute__((constructor)) ctf_text_init(void) assert(!ret); } -/* TODO: finalize */ +static +void __attribute__((destructor)) ctf_text_exit(void) +{ + bt_unregister_format(&ctf_text_format); +}