X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=formats%2Fctf-text%2Fctf-text.c;h=f60fde62f5fa794b749f91e0201fc92672f0a389;hb=87148dc74de9861a656aa4f38f03b51743471049;hp=1f798b2bc372c522e369f9d2d86e0b66965bcc8b;hpb=1cf393f63db4dce618515749d5549564d1313ee4;p=babeltrace.git diff --git a/formats/ctf-text/ctf-text.c b/formats/ctf-text/ctf-text.c index 1f798b2b..f60fde62 100644 --- a/formats/ctf-text/ctf-text.c +++ b/formats/ctf-text/ctf-text.c @@ -87,11 +87,11 @@ enum bt_loglevel { }; static -struct trace_descriptor *ctf_text_open_trace(const char *path, int flags, +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); static -int ctf_text_close_trace(struct trace_descriptor *descriptor); +int ctf_text_close_trace(struct bt_trace_descriptor *descriptor); static rw_dispatch write_dispatch_table[] = { @@ -106,7 +106,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, }; @@ -135,7 +135,7 @@ struct ctf_callsite_dups *ctf_trace_callsite_lookup(struct ctf_trace *trace, (gpointer) (unsigned long) callsite_name); } -int print_field(struct definition *definition) +int print_field(struct bt_definition *definition) { /* Print all fields in verbose mode */ if (babeltrace_verbose) @@ -265,23 +265,7 @@ int ctf_text_write_event(struct bt_stream_pos *ppos, struct ctf_stream_definitio /* Print events discarded */ if (stream->events_discarded) { fflush(pos->fp); - fprintf(stderr, "[warning] Tracer discarded %" PRIu64 " events between [", - stream->events_discarded); - if (opt_clock_cycles) { - ctf_print_timestamp(stderr, stream, - stream->prev_cycles_timestamp); - fprintf(stderr, "] and ["); - ctf_print_timestamp(stderr, stream, - stream->prev_cycles_timestamp_end); - } else { - ctf_print_timestamp(stderr, stream, - stream->prev_real_timestamp); - fprintf(stderr, "] and ["); - ctf_print_timestamp(stderr, stream, - stream->prev_real_timestamp_end); - } - fprintf(stderr, "]. You should consider recording a new trace with larger buffers or with fewer events enabled.\n"); - fflush(stderr); + ctf_print_discarded(stderr, stream); stream->events_discarded = 0; } @@ -304,7 +288,7 @@ int ctf_text_write_event(struct bt_stream_pos *ppos, struct ctf_stream_definitio 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); @@ -555,7 +539,7 @@ error: } static -struct trace_descriptor *ctf_text_open_trace(const char *path, int flags, +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) { @@ -592,15 +576,17 @@ error: } static -int ctf_text_close_trace(struct trace_descriptor *td) +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); - ret = fclose(pos->fp); - if (ret) { - perror("Error on fclose"); - return -1; + if (pos->fp != stdout) { + ret = fclose(pos->fp); + if (ret) { + perror("Error on fclose"); + return -1; + } } g_free(pos); return 0;