fix control flow with filter by cpu
[lttv.git] / ltt / branches / poly / lttv / modules / text / textDump.c
index 11afbed4ccf2aecc711f819aa9e2c029d0c6fb46..421ff6f3a2ab9be72a277048041775a9f5b974f5 100644 (file)
@@ -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
    before each trace, to print each event, and to print statistics
    after each trace. */
 
+#ifdef HAVE_CONFIG_H
+#include <config.h>
+#endif
+
 #include <lttv/lttv.h>
 #include <lttv/option.h>
 #include <lttv/module.h>
@@ -28,6 +33,7 @@
 #include <lttv/iattribute.h>
 #include <lttv/stats.h>
 #include <lttv/filter.h>
+#include <lttv/print.h>
 #include <ltt/ltt.h>
 #include <ltt/event.h>
 #include <ltt/type.h>
@@ -39,7 +45,8 @@ static gboolean
   a_field_names,
   a_state,
   a_cpu_stats,
-  a_process_stats;
+  a_process_stats,
+  a_path_output;
 
 static char
   *a_file_name = NULL;
@@ -50,120 +57,76 @@ static LttvHooks
   *before_trace,
   *event_hook;
 
-void print_field(LttEvent *e, LttField *f, GString *s, gboolean field_names) {
-
-  LttType *type;
-
-  LttField *element;
-
-  char *name;
-
-  int nb, i;
-
-  type = ltt_field_type(f);
-  switch(ltt_type_class(type)) {
-    case LTT_INT:
-      g_string_append_printf(s, " %lld", ltt_event_get_long_int(e,f));
-      break;
-
-    case LTT_UINT:
-      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_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 = ", 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 = ", name);
-        }
-        print_field(e, element, s, field_names);
-      }
-      g_string_append_printf(s, " }");
-      break;
-
-  }
-}
 
+static void 
+print_path_tree(FILE *fp, GString *indent, LttvAttribute *tree)
+{
+  int i, nb, saved_length;
 
-void lttv_event_to_string(LttEvent *e, GString *s,
-    gboolean mandatory_fields, gboolean field_names, LttvTracefileState *tfs)
-{ 
-  LttFacility *facility;
-
-  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)",
-        ltt_facility_name(facility),
-        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;
@@ -176,10 +139,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:
@@ -215,7 +183,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);
         }
@@ -227,7 +195,6 @@ print_tree(FILE *fp, GString *indent, LttvAttribute *tree)
   }
 }
 
-
 static void
 print_stats(FILE *fp, LttvTracesetStats *tscs)
 {
@@ -244,28 +211,38 @@ 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);
 
   for(i = 0 ; i < nb ; i++) {
     tcs = (LttvTraceStats *)(LTTV_TRACESET_CONTEXT(tscs)->traces[i]);
+#if 0 //FIXME
     desc = ltt_trace_system_description(tcs->parent.parent.t);
     LttTime start_time = ltt_trace_system_description_trace_start_time(desc);
     fprintf(fp, "Trace on system %s at time %lu.%09lu :\n", 
            ltt_trace_system_description_node_name(desc), 
            start_time.tv_sec,
       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. */
 
@@ -314,13 +291,14 @@ static gboolean write_traceset_footer(void *hook_data, void *call_data)
 static gboolean write_trace_header(void *hook_data, void *call_data)
 {
   LttvTraceContext *tc = (LttvTraceContext *)call_data;
-
+#if 0 //FIXME
   LttSystemDescription *system = ltt_trace_system_description(tc->t);
 
   fprintf(a_file,"  Trace from %s in %s\n%s\n\n", 
          ltt_trace_system_description_node_name(system), 
          ltt_trace_system_description_domain_name(system), 
          ltt_trace_system_description_description(system));
+#endif //0
   return FALSE;
 }
 
@@ -339,8 +317,11 @@ static int write_event_content(void *hook_data, void *call_data)
 
   LttvFilter *filter;
 
-  e = tfc->e;
+  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));
@@ -349,16 +330,17 @@ static int write_event_content(void *hook_data, void *call_data)
   /*
    * call to the filter if available
    */
-  if(!lttv_filter_tree_parse(filter->head,e,tfc->tf,tfc->t_context->t,tfs->process,tfc)) {
+  if(filter->head != NULL)
+    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");  
 
   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));
   }
 
   fputs(a_string->str, a_file);
@@ -406,6 +388,12 @@ static void init()
       "", 
       LTTV_OPT_NONE, &a_process_stats, NULL, 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);
+
   g_assert(lttv_iattribute_find_by_path(attributes, "hooks/event",
       LTTV_POINTER, &value));
   g_assert((event_hook = *(value.v_pointer)) != NULL);
@@ -429,7 +417,6 @@ static void init()
       LTTV_PRIO_DEFAULT);
 }
 
-
 static void destroy()
 {
   g_info("Destroy textDump");
@@ -444,6 +431,8 @@ 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);
@@ -458,5 +447,5 @@ static void destroy()
 
 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")
 
This page took 0.026911 seconds and 4 git commands to generate.