X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=ltt%2Fbranches%2Fpoly%2Flttv%2Fmodules%2Ftext%2FtextDump.c;h=4fcd5b5c49abd779a51c962b19cddf55c705541a;hb=cbf66716da4528ad072b93c6666c4ed312a0e696;hp=96773a6c08bbff6d333736a97c3852fc0ee696f7;hpb=0bc23ba9a5357242cf0a72b12a3a3a393d248e94;p=lttv.git diff --git a/ltt/branches/poly/lttv/modules/text/textDump.c b/ltt/branches/poly/lttv/modules/text/textDump.c index 96773a6c..4fcd5b5c 100644 --- a/ltt/branches/poly/lttv/modules/text/textDump.c +++ b/ltt/branches/poly/lttv/modules/text/textDump.c @@ -1,5 +1,6 @@ /* This file is part of the Linux Trace Toolkit viewer * Copyright (C) 2003-2004 Michel Dagenais + * 2005 Mathieu Desnoyers * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License Version 2 as @@ -32,18 +33,18 @@ #include #include #include +#include #include #include -#include #include -#include #include static gboolean - a_field_names, + a_no_field_names, a_state, a_cpu_stats, - a_process_stats; + a_process_stats, + a_path_output; static char *a_file_name = NULL; @@ -54,130 +55,76 @@ static LttvHooks *before_trace, *event_hook; -void print_field(LttEvent *e, LttField *f, GString *s, gboolean field_names) { - - LttType *type; - - LttField *element; - - GQuark name; - - int nb, i; - - type = ltt_field_type(f); - switch(ltt_type_class(type)) { - case LTT_INT: - case LTT_LONG: - case LTT_SSIZE_T: - g_string_append_printf(s, " %lld", ltt_event_get_long_int(e,f)); - break; - - case LTT_UINT: - case LTT_ULONG: - case LTT_SIZE_T: - case LTT_OFF_T: - g_string_append_printf(s, " %llu", ltt_event_get_long_unsigned(e,f)); - break; - - case LTT_FLOAT: - g_string_append_printf(s, " %g", ltt_event_get_double(e,f)); - break; - - case LTT_POINTER: - g_string_append_printf(s, " 0x%llx", ltt_event_get_long_unsigned(e,f)); - break; - - case LTT_STRING: - g_string_append_printf(s, " \"%s\"", ltt_event_get_string(e,f)); - break; - - case LTT_ENUM: - g_string_append_printf(s, " %s", ltt_enum_string_get(type, - ltt_event_get_unsigned(e,f)-1)); - break; - - case LTT_ARRAY: - case LTT_SEQUENCE: - g_string_append_printf(s, " {"); - nb = ltt_event_field_element_number(e,f); - element = ltt_field_element(f); - for(i = 0 ; i < nb ; i++) { - ltt_event_field_element_select(e,f,i); - print_field(e, element, s, field_names); - } - g_string_append_printf(s, " }"); - break; - - case LTT_STRUCT: - g_string_append_printf(s, " {"); - nb = ltt_type_member_number(type); - for(i = 0 ; i < nb ; i++) { - element = ltt_field_member(f,i); - if(field_names) { - ltt_type_member_type(type, i, &name); - g_string_append_printf(s, " %s = ", g_quark_to_string(name)); - } - print_field(e, element, s, field_names); - } - g_string_append_printf(s, " }"); - break; - - case LTT_UNION: - g_string_append_printf(s, " {"); - nb = ltt_type_member_number(type); - for(i = 0 ; i < nb ; i++) { - element = ltt_field_member(f,i); - if(field_names) { - ltt_type_member_type(type, i, &name); - g_string_append_printf(s, " %s = ", g_quark_to_string(name)); - } - print_field(e, element, s, field_names); - } - g_string_append_printf(s, " }"); - break; - - } -} - -void lttv_event_to_string(LttEvent *e, GString *s, - gboolean mandatory_fields, gboolean field_names, LttvTracefileState *tfs) -{ - LttFacility *facility; +static void +print_path_tree(FILE *fp, GString *indent, LttvAttribute *tree) +{ + int i, nb, saved_length; - LttEventType *event_type; + LttvAttribute *subtree; - LttType *type; + LttvAttributeName name; - LttField *field; + LttvAttributeValue value; - LttTime time; + LttvAttributeType type; - g_string_set_size(s,0); + gboolean is_named; - facility = ltt_event_facility(e); - event_type = ltt_event_eventtype(e); - field = ltt_event_field(e); + saved_length = indent->len; + nb = lttv_attribute_get_number(tree); + for(i = 0 ; i < nb ; i++) { + type = lttv_attribute_get(tree, i, &name, &value, &is_named); + if(is_named) { + g_string_sprintfa(indent, "/%s", g_quark_to_string(name)); + } else { + g_string_sprintfa(indent, "/%s", name); + } - if(mandatory_fields) { - time = ltt_event_time(e); - g_string_append_printf(s,"%s.%s: %ld.%09ld (%s)", - g_quark_to_string(ltt_facility_name(facility)), - g_quark_to_string(ltt_eventtype_name(event_type)), - (long)time.tv_sec, time.tv_nsec, - g_quark_to_string(tfs->cpu_name)); - /* Print the process id and the state/interrupt type of the process */ - g_string_append_printf(s,", %u, %u, %s", tfs->process->pid, - tfs->process->ppid, - g_quark_to_string(tfs->process->state->t)); + switch(type) { + case LTTV_INT: + fprintf(fp, "%s: %d\n", indent->str, *value.v_int); + break; + case LTTV_UINT: + fprintf(fp, "%s: %d\n", indent->str, *value.v_int); + break; + case LTTV_LONG: + fprintf(fp, "%s: %ld\n", indent->str, *value.v_ulong); + break; + case LTTV_ULONG: + fprintf(fp, "%s: %lu\n", indent->str, *value.v_ulong); + break; + case LTTV_FLOAT: + fprintf(fp, "%s: %f\n", indent->str, (double) *value.v_float); + break; + case LTTV_DOUBLE: + fprintf(fp, "%s: %f\n", indent->str, *value.v_double); + break; + case LTTV_TIME: + fprintf(fp, "%s: %lu.%09lu\n", indent->str, value.v_time->tv_sec, value.v_time->tv_nsec); + break; + case LTTV_POINTER: + fprintf(fp, "%s: POINTER\n", indent->str); + break; + case LTTV_STRING: + fprintf(fp, "%s: %s\n", indent->str, *value.v_string); + break; + case LTTV_GOBJECT: + if(LTTV_IS_ATTRIBUTE(*(value.v_gobject))) { + subtree = (LttvAttribute*) *(value.v_gobject); + print_path_tree(fp, indent, subtree); + } else { + fprintf(fp, "%s: GOBJECT\n", indent->str); + } + break; + case LTTV_NONE: + break; + } + g_string_truncate(indent, saved_length); } +} - if(field) - print_field(e, field, s, field_names); -} - - -static void +static void print_tree(FILE *fp, GString *indent, LttvAttribute *tree) { int i, nb, saved_length; @@ -190,10 +137,15 @@ print_tree(FILE *fp, GString *indent, LttvAttribute *tree) LttvAttributeType type; + gboolean is_named; + nb = lttv_attribute_get_number(tree); for(i = 0 ; i < nb ; i++) { - type = lttv_attribute_get(tree, i, &name, &value); - fprintf(fp, "%s%s: ", indent->str, g_quark_to_string(name)); + type = lttv_attribute_get(tree, i, &name, &value, &is_named); + if(is_named) + fprintf(fp, "%s%s: ", indent->str, g_quark_to_string(name)); + else + fprintf(fp, "%s%lu: ", indent->str, name); switch(type) { case LTTV_INT: @@ -229,7 +181,7 @@ print_tree(FILE *fp, GString *indent, LttvAttribute *tree) fprintf(fp, "\n"); subtree = (LttvAttribute *)*(value.v_gobject); saved_length = indent->len; - g_string_append(indent, " "); + indent = g_string_append(indent, " "); print_tree(fp, indent, subtree); g_string_truncate(indent, saved_length); } @@ -241,7 +193,6 @@ print_tree(FILE *fp, GString *indent, LttvAttribute *tree) } } - static void print_stats(FILE *fp, LttvTracesetStats *tscs) { @@ -258,7 +209,11 @@ print_stats(FILE *fp, LttvTracesetStats *tscs) if(tscs->stats == NULL) return; indent = g_string_new(""); fprintf(fp, "Traceset statistics:\n\n"); - print_tree(fp, indent, tscs->stats); + if(a_path_output) { + print_path_tree(fp, indent, tscs->stats); + } else { + print_tree(fp, indent, tscs->stats); + } ts = tscs->parent.parent.ts; nb = lttv_traceset_number(ts); @@ -274,14 +229,18 @@ print_stats(FILE *fp, LttvTracesetStats *tscs) start_time.tv_nsec); #endif //FIXME saved_length = indent->len; - g_string_append(indent, " "); - print_tree(fp, indent, tcs->stats); + if(a_path_output) { + g_string_sprintfa(indent, "/trace%i", i); + print_path_tree(fp, indent, tcs->stats); + } else { + g_string_append(indent, " "); + print_tree(fp, indent, tcs->stats); + } g_string_truncate(indent, saved_length); } g_string_free(indent, TRUE); } - /* Insert the hooks before and after each trace and tracefile, and for each event. Print a global header. */ @@ -317,7 +276,7 @@ static gboolean write_traceset_footer(void *hook_data, void *call_data) fprintf(a_file,"End trace set\n\n"); if(LTTV_IS_TRACESET_STATS(tc)) { - lttv_stats_sum_traceset((LttvTracesetStats *)tc); + lttv_stats_sum_traceset((LttvTracesetStats *)tc, ltt_time_infinite); print_stats(a_file, (LttvTracesetStats *)tc); } @@ -344,6 +303,8 @@ static gboolean write_trace_header(void *hook_data, void *call_data) static int write_event_content(void *hook_data, void *call_data) { + gboolean result; + LttvIAttribute *attributes = LTTV_IATTRIBUTE(lttv_global_attributes()); LttvTracefileContext *tfc = (LttvTracefileContext *)call_data; @@ -356,28 +317,34 @@ static int write_event_content(void *hook_data, void *call_data) LttvFilter *filter; - e = ltt_tracefile_get_event(tfc->tf); + guint cpu = tfs->cpu; + LttvTraceState *ts = (LttvTraceState*)tfc->t_context; + LttvProcessState *process = ts->running_process[cpu]; + e = ltt_tracefile_get_event(tfc->tf); - g_assert(lttv_iattribute_find_by_path(attributes, "filter/lttv_filter", - LTTV_POINTER, &value_filter)); + result = lttv_iattribute_find_by_path(attributes, "filter/lttv_filter", + LTTV_POINTER, &value_filter); + g_assert(result); filter = (LttvFilter*)*(value_filter.v_pointer); /* * call to the filter if available */ if(filter->head != NULL) - if(!lttv_filter_tree_parse(filter->head,e,tfc->tf,tfc->t_context->t,tfs->process,tfc)) + if(!lttv_filter_tree_parse(filter->head,e,tfc->tf, + tfc->t_context->t,tfc,NULL,NULL)) return FALSE; - lttv_event_to_string(e, a_string, TRUE, a_field_names, tfs); - g_string_append_printf(a_string,"\n"); + lttv_event_to_string(e, a_string, TRUE, !a_no_field_names, tfs); if(a_state) { g_string_append_printf(a_string, " %s ", - g_quark_to_string(tfs->process->state->s)); + g_quark_to_string(process->state->s)); } + g_string_append_printf(a_string,"\n"); + fputs(a_string->str, a_file); return FALSE; } @@ -385,6 +352,8 @@ static int write_event_content(void *hook_data, void *call_data) static void init() { + gboolean result; + LttvAttributeValue value; LttvIAttribute *attributes = LTTV_IATTRIBUTE(lttv_global_attributes()); @@ -399,14 +368,14 @@ static void init() "file name", LTTV_OPT_STRING, &a_file_name, NULL, NULL); - a_field_names = FALSE; - lttv_option_add("field_names", 'l', - "write the field names for each event", + a_no_field_names = FALSE; + lttv_option_add("field_names", 's', + "do not write the field names for each event", "", - LTTV_OPT_NONE, &a_field_names, NULL, NULL); + LTTV_OPT_NONE, &a_no_field_names, NULL, NULL); a_state = FALSE; - lttv_option_add("process_state", 's', + lttv_option_add("process_state", 'r', "write the pid and state for each event", "", LTTV_OPT_NONE, &a_state, NULL, NULL); @@ -423,30 +392,43 @@ static void init() "", LTTV_OPT_NONE, &a_process_stats, NULL, NULL); - g_assert(lttv_iattribute_find_by_path(attributes, "hooks/event", - LTTV_POINTER, &value)); - g_assert((event_hook = *(value.v_pointer)) != NULL); + a_path_output = FALSE; + lttv_option_add("path_output", 'a', + "print the process stats in path format, for easy grepping", + "", + LTTV_OPT_NONE, &a_path_output, NULL, NULL); + + result = lttv_iattribute_find_by_path(attributes, "hooks/event", + LTTV_POINTER, &value); + g_assert(result); + event_hook = *(value.v_pointer); + g_assert(event_hook); lttv_hooks_add(event_hook, write_event_content, NULL, LTTV_PRIO_DEFAULT); - g_assert(lttv_iattribute_find_by_path(attributes, "hooks/trace/before", - LTTV_POINTER, &value)); - g_assert((before_trace = *(value.v_pointer)) != NULL); + result = lttv_iattribute_find_by_path(attributes, "hooks/trace/before", + LTTV_POINTER, &value); + g_assert(result); + before_trace = *(value.v_pointer); + g_assert(before_trace); lttv_hooks_add(before_trace, write_trace_header, NULL, LTTV_PRIO_DEFAULT); - g_assert(lttv_iattribute_find_by_path(attributes, "hooks/traceset/before", - LTTV_POINTER, &value)); - g_assert((before_traceset = *(value.v_pointer)) != NULL); + result = lttv_iattribute_find_by_path(attributes, "hooks/traceset/before", + LTTV_POINTER, &value); + g_assert(result); + before_traceset = *(value.v_pointer); + g_assert(before_traceset); lttv_hooks_add(before_traceset, write_traceset_header, NULL, LTTV_PRIO_DEFAULT); - g_assert(lttv_iattribute_find_by_path(attributes, "hooks/traceset/after", - LTTV_POINTER, &value)); - g_assert((after_traceset = *(value.v_pointer)) != NULL); + result = lttv_iattribute_find_by_path(attributes, "hooks/traceset/after", + LTTV_POINTER, &value); + g_assert(result); + after_traceset = *(value.v_pointer); + g_assert(after_traceset); lttv_hooks_add(after_traceset, write_traceset_footer, NULL, LTTV_PRIO_DEFAULT); } - static void destroy() { g_info("Destroy textDump"); @@ -461,19 +443,21 @@ static void destroy() lttv_option_remove("process_stats"); + lttv_option_remove("path_output"); + g_string_free(a_string, TRUE); lttv_hooks_remove_data(event_hook, write_event_content, NULL); lttv_hooks_remove_data(before_trace, write_trace_header, NULL); - lttv_hooks_remove_data(before_trace, write_traceset_header, NULL); + lttv_hooks_remove_data(before_traceset, write_traceset_header, NULL); - lttv_hooks_remove_data(before_trace, write_traceset_footer, NULL); + lttv_hooks_remove_data(after_traceset, write_traceset_footer, NULL); } LTTV_MODULE("textDump", "Print events in a file", \ "Produce a detailed text printout of a trace", \ - init, destroy, "stats", "batchAnalysis", "option") + init, destroy, "stats", "batchAnalysis", "option", "print")