X-Git-Url: https://git.liburcu.org/?a=blobdiff_plain;f=ltt%2Fbranches%2Fpoly%2Flttv%2FtextDump.c;h=797e7a12429e8d602257b3eeefffe80a1de8af43;hb=1e7cfdabf66cd03c0d3030a2a2ac23fc192dcdfa;hp=3fb0b6f7e461bce80830803daba11de631b27288;hpb=996acd9220aa2a8e2bb502cc95d140eb44c322de;p=lttv.git diff --git a/ltt/branches/poly/lttv/textDump.c b/ltt/branches/poly/lttv/textDump.c index 3fb0b6f7..797e7a12 100644 --- a/ltt/branches/poly/lttv/textDump.c +++ b/ltt/branches/poly/lttv/textDump.c @@ -9,6 +9,11 @@ #include #include #include +#include +#include +#include +#include +#include static gboolean a_field_names, @@ -24,68 +29,100 @@ static LttvHooks *before_event; -void init(int argc, char **argv) -{ - LttvAttributeValue *value; +void print_field(LttEvent *e, LttField *f, GString *s, gboolean field_names) { - LttvIAttribute *attributes = LTTV_IATTRIBUTE(lttv_global_attributes()); + LttType *type; - a_file_name = NULL; - lttv_option_add("output", 'o', - "output file where the text is written", - "file name", - LTTV_OPT_STRING, &a_file_name, NULL, NULL); + LttField *element; - a_field_names = FALSE; - lttv_option_add("field_names", 'l', - "write the field names for each event", - "", - LTTV_OPT_NONE, &a_field_names, NULL, NULL); + char *name; - a_state = FALSE; - lttv_option_add("process_state", 's', - "write the pid and state for each event", - "", - LTTV_OPT_NONE, &a_state, NULL, NULL); + int nb, i; - g_assert(lttv_iattribute_find_by_path(attributes, "hooks/event/before", - LTTV_POINTER, &value)); - g_assert((before_event = *(value->v_pointer)) != NULL); - lttv_hooks_add(before_event, write_event_content, NULL); + type = ltt_field_type(f); + switch(ltt_type_class(type)) { + case LTT_INT: + g_string_append_printf(s, " %ld", ltt_event_get_long_int(e,f)); + break; - g_assert(lttv_iattribute_find_by_path(attributes, "hooks/trace/before", - LTTV_POINTER, &value)); - g_assert((before_trace = *(value->v_pointer)) != NULL); - lttv_hooks_add(before_trace, write_trace_header, NULL); + case LTT_UINT: + g_string_append_printf(s, " %lu", ltt_event_get_long_unsigned(e,f)); + break; - g_assert(lttv_iattribute_find_by_path(attributes, "hooks/traceset/before", - LTTV_POINTER, &value)); - g_assert((before_traceset = *(value->v_pointer)) != NULL); - lttv_hooks_add(before_traceset, write_traceset_header, NULL); + case LTT_FLOAT: + g_string_append_printf(s, " %g", ltt_event_get_double(e,f)); + break; - g_assert(lttv_iattribute_find_by_path(attributes, "hooks/traceset/after", - LTTV_POINTER, &value)); - g_assert((after_traceset = *(value->v_pointer)) != NULL); - lttv_hooks_add(after_traceset, write_traceset_footer, NULL); + 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; + } } -void destroy() -{ - lttv_option_remove("output"); +void lttv_event_to_string(LttEvent *e, LttTracefile *tf, GString *s, + gboolean mandatory_fields, gboolean field_names, LttvTracefileState *tfs) +{ + LttFacility *facility; - lttv_option_remove("field_names"); + LttEventType *event_type; - lttv_option_remove("process_state"); + LttType *type; - lttv_hooks_remove(before_event, write_event, NULL); + LttField *field; - lttv_hooks_remove(before_trace, write_trace_header, NULL); + LttTime time; - lttv_hooks_remove(before_trace, write_traceset_header, NULL); + g_string_set_size(s,0); - lttv_hooks_remove(before_trace, write_traceset_footer, NULL); -} + facility = ltt_event_facility(e); + event_type = ltt_event_eventtype(e); + field = ltt_event_field(e); + + if(mandatory_fields) { + time = ltt_event_time(e); + g_string_append_printf(s,"%s.%s: %ld.%ld (%s)",ltt_facility_name(facility), + ltt_eventtype_name(event_type), (long)time.tv_sec, time.tv_nsec, + ltt_tracefile_name(tf)); + /* Print the process id and the state/interrupt type of the process */ + g_string_append_printf(s,", %d, %s", tfs->process->pid, + g_quark_to_string(tfs->process->state->t)); + } + + if(field) + print_field(e, field, s, field_names); +} /* Insert the hooks before and after each trace and tracefile, and for each @@ -95,7 +132,7 @@ static FILE *a_file; static GString *a_string; -static static gboolean write_traceset_header(void *hook_data, void *call_data) +static gboolean write_traceset_header(void *hook_data, void *call_data) { LttvTracesetContext *tc = (LttvTracesetContext *)call_data; @@ -106,20 +143,20 @@ static static gboolean write_traceset_header(void *hook_data, void *call_data) /* Print the trace set header */ fprintf(a_file,"Trace set contains %d traces\n\n", - lttv_traceset_number(tc->ta); + lttv_traceset_number(tc->ts)); return FALSE; } -static static gboolean write_traceset_footer(void *hook_data, void *call_data) +static gboolean write_traceset_footer(void *hook_data, void *call_data) { LttvTracesetContext *tc = (LttvTracesetContext *)call_data; - if(a_file_name != NULL) a_file = fclose(a_file); - fprintf(a_file,"End trace set\n\n"); + if(a_file_name != NULL) fclose(a_file); + return FALSE; } @@ -146,107 +183,85 @@ static int write_event_content(void *hook_data, void *call_data) e = tfc->e; - lttv_event_to_string(e, tfc->tf, a_string, TRUE, a_field_names); + lttv_event_to_string(e, tfc->tf, 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(tfs->process->state->s)); } - fputs(s, c->fd); + fputs(a_string->str, a_file); return FALSE; } -void lttv_event_to_string(LttEvent *e, LttTracefile *tf, g_string *s, - gboolean mandatory_fields, gboolean field_names) +//void init(int argc, char **argv) +G_MODULE_EXPORT void init(LttvModule *self, int argc, char **argv) { - LttFacility *facility; - - LttEventType *event_type; - - LttType *type; - - LttField *field; + LttvAttributeValue value; - LttTime time; + LttvIAttribute *attributes = LTTV_IATTRIBUTE(lttv_global_attributes()); - g_string_set_size(s,0); + a_string = g_string_new(""); - facility = lttv_event_facility(e); - eventtype = ltt_event_eventtype(e); - field = ltt_event_field(e); + a_file_name = NULL; + lttv_option_add("output", 'o', + "output file where the text is written", + "file name", + LTTV_OPT_STRING, &a_file_name, NULL, NULL); - if(mandatory_fields) { - time = ltt_event_time(e); - g_string_append_printf(s,"%s.%s: %ld.%ld (%s)",ltt_facility_name(facility), - ltt_eventtype_name(eventtype), (long)time.tv_sec, time.tv_nsec, - ltt_tracefile_name(tf)); - } + a_field_names = FALSE; + lttv_option_add("field_names", 'l', + "write the field names for each event", + "", + LTTV_OPT_NONE, &a_field_names, NULL, NULL); - print_field(e,f,s, field_names); -} + a_state = FALSE; + lttv_option_add("process_state", 's', + "write the pid and state for each event", + "", + LTTV_OPT_NONE, &a_state, NULL, NULL); + g_assert(lttv_iattribute_find_by_path(attributes, "hooks/event/before", + LTTV_POINTER, &value)); + g_assert((before_event = *(value.v_pointer)) != NULL); + lttv_hooks_add(before_event, write_event_content, NULL); -void print_field(LttEvent *e, LttField *f, g_string *s, gboolean field_names) { + g_assert(lttv_iattribute_find_by_path(attributes, "hooks/trace/before", + LTTV_POINTER, &value)); + g_assert((before_trace = *(value.v_pointer)) != NULL); + lttv_hooks_add(before_trace, write_trace_header, NULL); - LttType *type; + g_assert(lttv_iattribute_find_by_path(attributes, "hooks/traceset/before", + LTTV_POINTER, &value)); + g_assert((before_traceset = *(value.v_pointer)) != NULL); + lttv_hooks_add(before_traceset, write_traceset_header, NULL); - LttField *element; + g_assert(lttv_iattribute_find_by_path(attributes, "hooks/traceset/after", + LTTV_POINTER, &value)); + g_assert((after_traceset = *(value.v_pointer)) != NULL); + lttv_hooks_add(after_traceset, write_traceset_footer, NULL); +} - char *name; - int nb, i; +G_MODULE_EXPORT void destroy() +{ + lttv_option_remove("output"); - type = ltt_field_type(f); - switch(ltt_type_class(type)) { - case LTT_INT: - g_string_append_printf(s, " %ld", ltt_event_get_long_int(e,f)); - break; + lttv_option_remove("field_names"); - case LTT_UINT: - g_string_append_printf(s, " %lu", ltt_event_get_long_unsigned(e,f)); - break; + lttv_option_remove("process_state"); - case LTT_FLOAT: - g_string_append_printf(s, " %g", ltt_event_get_double(e,f)); - break; + g_string_free(a_string, TRUE); - case LTT_STRING: - g_string_append_printf(s, " \"%s\"", ltt_event_get_string(e,f)); - break; + lttv_hooks_remove_data(before_event, write_event_content, NULL); - case LTT_ENUM: - g_string_append_printf(s, " %s", ltt_enum_string_get(type, - event_get_unsigned(e,f)); - break; + lttv_hooks_remove_data(before_trace, write_trace_header, NULL); - 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); - } - g_string_append_printf(s, " }"); - break; + lttv_hooks_remove_data(before_trace, write_traceset_header, NULL); - 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(name) { - ltt_type_member_type(type, &name); - g_string_append_printf(s, " %s = ", field_names); - } - print_field(e,element,s); - } - g_string_append_printf(s, " }"); - break; - } + lttv_hooks_remove_data(before_trace, write_traceset_footer, NULL); }