X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=formats%2Fctf-text%2Fctf-text.c;h=7211c97f955889a4d6c15e409f2df0a87b4ae275;hp=5879cf4f8dfbb2a1f02216332e3dc817217a88c0;hb=c3815874ce57c8b9dbceda4e5b7db5fdf869559c;hpb=cba1661ca1dbb97c676e5318106ae23052be947c diff --git a/formats/ctf-text/ctf-text.c b/formats/ctf-text/ctf-text.c index 5879cf4f..7211c97f 100644 --- a/formats/ctf-text/ctf-text.c +++ b/formats/ctf-text/ctf-text.c @@ -22,8 +22,8 @@ #include #include #include +#include #include -#include #include #include #include @@ -34,11 +34,22 @@ #include #include +#define NSEC_PER_SEC 1000000000ULL + int opt_all_field_names, opt_scope_field_names, opt_header_field_names, opt_context_field_names, - opt_payload_field_names; + opt_payload_field_names, + opt_all_fields, + opt_trace_field, + 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_delta_field = 1; enum field_item { ITEM_SCOPE, @@ -47,8 +58,27 @@ enum field_item { ITEM_PAYLOAD, }; +enum bt_loglevel { + BT_LOGLEVEL_EMERG = 0, + BT_LOGLEVEL_ALERT = 1, + BT_LOGLEVEL_CRIT = 2, + BT_LOGLEVEL_ERR = 3, + BT_LOGLEVEL_WARNING = 4, + BT_LOGLEVEL_NOTICE = 5, + BT_LOGLEVEL_INFO = 6, + BT_LOGLEVEL_DEBUG_SYSTEM = 7, + BT_LOGLEVEL_DEBUG_PROGRAM = 8, + BT_LOGLEVEL_DEBUG_PROCESS = 9, + BT_LOGLEVEL_DEBUG_MODULE = 10, + BT_LOGLEVEL_DEBUG_UNIT = 11, + BT_LOGLEVEL_DEBUG_FUNCTION = 12, + BT_LOGLEVEL_DEBUG_LINE = 13, + BT_LOGLEVEL_DEBUG = 14, +}; + + struct trace_descriptor *ctf_text_open_trace(const char *path, int flags, - void (*move_pos_slow)(struct ctf_stream_pos *pos, size_t offset, + void (*packet_seek)(struct stream_pos *pos, size_t index, int whence), FILE *metadata_fp); void ctf_text_close_trace(struct trace_descriptor *descriptor); @@ -142,42 +172,111 @@ void set_field_names_print(struct ctf_text_stream_pos *pos, enum field_item item } static -int ctf_text_write_event(struct stream_pos *ppos, - struct ctf_stream *stream) +const char *print_loglevel(int value) +{ + switch (value) { + case -1: + return ""; + case BT_LOGLEVEL_EMERG: + return "TRACE_EMERG"; + case BT_LOGLEVEL_ALERT: + return "TRACE_ALERT"; + case BT_LOGLEVEL_CRIT: + return "TRACE_CRIT"; + case BT_LOGLEVEL_ERR: + return "TRACE_ERR"; + case BT_LOGLEVEL_WARNING: + return "TRACE_WARNING"; + case BT_LOGLEVEL_NOTICE: + return "TRACE_NOTICE"; + case BT_LOGLEVEL_INFO: + return "TRACE_INFO"; + case BT_LOGLEVEL_DEBUG_SYSTEM: + return "TRACE_DEBUG_SYSTEM"; + case BT_LOGLEVEL_DEBUG_PROGRAM: + return "TRACE_DEBUG_PROGRAM"; + case BT_LOGLEVEL_DEBUG_PROCESS: + return "TRACE_DEBUG_PROCESS"; + case BT_LOGLEVEL_DEBUG_MODULE: + return "TRACE_DEBUG_MODULE"; + case BT_LOGLEVEL_DEBUG_UNIT: + return "TRACE_DEBUG_UNIT"; + case BT_LOGLEVEL_DEBUG_FUNCTION: + return "TRACE_DEBUG_FUNCTION"; + case BT_LOGLEVEL_DEBUG_LINE: + return "TRACE_DEBUG_LINE"; + case BT_LOGLEVEL_DEBUG: + return "TRACE_DEBUG"; + default: + return "<>"; + } +} + +static +int ctf_text_write_event(struct stream_pos *ppos, struct ctf_stream_definition *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; + struct ctf_stream_declaration *stream_class = stream->stream_class; int field_nr_saved; - struct ctf_event *event_class; - struct ctf_stream_event *event; + struct ctf_event_declaration *event_class; + struct ctf_event_definition *event; uint64_t id; int ret; + int dom_print = 0; id = stream->event_id; if (id >= stream_class->events_by_id->len) { - fprintf(stdout, "[error] Event id %" PRIu64 " is outside range.\n", id); + fprintf(stderr, "[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); + fprintf(stderr, "[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); + if (!event_class) { + fprintf(stderr, "[error] Event class id %" PRIu64 " is unknown.\n", id); return -EINVAL; } + /* 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); + stream->events_discarded = 0; + } + if (stream->has_timestamp) { set_field_names_print(pos, ITEM_HEADER); if (pos->print_names) fprintf(pos->fp, "timestamp = "); else fprintf(pos->fp, "["); - fprintf(pos->fp, "%12" PRIu64, 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, "]"); @@ -186,6 +285,108 @@ int ctf_text_write_event(struct stream_pos *ppos, else fprintf(pos->fp, " "); } + if ((opt_delta_field || opt_all_fields) && stream->has_timestamp) { + uint64_t delta, delta_sec, delta_nsec; + + set_field_names_print(pos, ITEM_HEADER); + if (pos->print_names) + fprintf(pos->fp, "delta = "); + else + fprintf(pos->fp, "("); + 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, + delta_sec, delta_nsec); + } else { + fprintf(pos->fp, "+?.?????????"); + } + if (!pos->print_names) + fprintf(pos->fp, ")"); + + if (pos->print_names) + fprintf(pos->fp, ", "); + else + fprintf(pos->fp, " "); + 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') { + set_field_names_print(pos, ITEM_HEADER); + if (pos->print_names) { + fprintf(pos->fp, "trace = "); + } + fprintf(pos->fp, "%s", stream_class->trace->path); + if (pos->print_names) + fprintf(pos->fp, ", "); + else + fprintf(pos->fp, " "); + } + 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 = "); + } + fprintf(pos->fp, "%s", stream_class->trace->env.domain); + if (pos->print_names) + fprintf(pos->fp, ", "); + dom_print = 1; + } + 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 = "); + } else if (dom_print) { + fprintf(pos->fp, ":"); + } + fprintf(pos->fp, "%s", stream_class->trace->env.procname); + if (pos->print_names) + fprintf(pos->fp, ", "); + dom_print = 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 = "); + } else if (dom_print) { + fprintf(pos->fp, ":"); + } + fprintf(pos->fp, "%d", stream_class->trace->env.vpid); + if (pos->print_names) + fprintf(pos->fp, ", "); + dom_print = 1; + } + if ((opt_loglevel_field || opt_all_fields) && event_class->loglevel != -1) { + set_field_names_print(pos, ITEM_HEADER); + if (pos->print_names) { + fprintf(pos->fp, "loglevel = "); + } else if (dom_print) { + fprintf(pos->fp, ":"); + } + fprintf(pos->fp, "%s (%d)", + print_loglevel(event_class->loglevel), + event_class->loglevel); + 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); if (pos->print_names) fprintf(pos->fp, "name = "); @@ -281,13 +482,13 @@ int ctf_text_write_event(struct stream_pos *ppos, 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"); + fprintf(stderr, "[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, + void (*packet_seek)(struct stream_pos *pos, size_t index, int whence), FILE *metadata_fp) { struct ctf_text_stream_pos *pos; @@ -295,6 +496,8 @@ struct trace_descriptor *ctf_text_open_trace(const char *path, int flags, pos = g_new0(struct ctf_text_stream_pos, 1); + pos->last_real_timestamp = -1ULL; + pos->last_cycles_timestamp = -1ULL; switch (flags & O_ACCMODE) { case O_RDWR: if (!path) @@ -310,7 +513,7 @@ struct trace_descriptor *ctf_text_open_trace(const char *path, int flags, break; case O_RDONLY: default: - fprintf(stdout, "[error] Incorrect open flags.\n"); + fprintf(stderr, "[error] Incorrect open flags.\n"); goto error; }