X-Git-Url: https://git.lttng.org/?a=blobdiff_plain;f=lttv%2Flttv%2Fprint.c;h=aa21f77bf3c18531515539bdf37d9cfb0e318087;hb=6db3427f29cace9a1addac5a6277bbc1ce666002;hp=d54f5f0dd65d4240cd045f69388e3780a585b66d;hpb=90e19f82bca635a1ba52b8a50b64e484bd19c14f;p=lttv.git diff --git a/lttv/lttv/print.c b/lttv/lttv/print.c index d54f5f0d..aa21f77b 100644 --- a/lttv/lttv/print.c +++ b/lttv/lttv/print.c @@ -32,8 +32,10 @@ #include #include #include +#ifdef BABEL_CLEANUP #include #include +#endif #include #include #include @@ -41,14 +43,15 @@ #include #include #include +#include #include #include - +#include +#include +#ifdef BABEL_CLEANUP static inline void print_enum_events(LttEvent *e, struct marker_field *f, guint64 value, GString *s, LttvTracefileState *tfs) { - LttTracefile *tf = tfs->parent.tf; - struct marker_info *info = marker_get_info_from_id(tf->mdata, e->event_id); LttvTraceState *ts = (LttvTraceState*)(tfs->parent.t_context); LttvNameTables *nt = ts->name_tables; @@ -257,7 +260,212 @@ void lttv_print_field(LttEvent *e, struct marker_field *f, GString *s, break; } } +#endif +int getProcessInfosFromEvent(LttvEvent *event, GString* processInfos) +{ + int pid=0, tid=0, ppid=0; + char *procname; + struct definition *scope; + unsigned long timestamp; + + int ret = 0; + + gboolean noError = TRUE; + + guint cpu; + LttvTraceState *state = event->state; + LttvProcessState *process; + struct bt_ctf_event *ctf_event = event->bt_event; + + cpu = lttv_traceset_get_cpuid_from_event(event); + + process = state->running_process[cpu]; + + timestamp = bt_ctf_get_timestamp(ctf_event); + + pid = process->pid; + tid = process->tgid; + ppid = process->ppid; + procname = g_quark_to_string(process->name); + if (timestamp == -1ULL) { + noError = FALSE; + } +#if 0 + if (noError) { + scope = bt_ctf_get_top_level_scope(ctf_event, BT_STREAM_EVENT_CONTEXT); + if (bt_ctf_field_get_error()) { + noError = FALSE; + } + } + if (noError) { + pid = bt_ctf_get_int64(bt_ctf_get_field(ctf_event, scope, "_pid")); + if (bt_ctf_field_get_error()) { + noError = FALSE; + } + } + if (noError) { + tid = bt_ctf_get_int64(bt_ctf_get_field(ctf_event, scope, "_tid")); + if (bt_ctf_field_get_error()) { + noError = FALSE; + } + } + if (noError) { + ppid = bt_ctf_get_int64(bt_ctf_get_field(ctf_event, scope, "_ppid")); + if (bt_ctf_field_get_error()) { + noError = FALSE; + } + } + if (noError) { + procname = bt_ctf_get_char_array(bt_ctf_get_field(ctf_event, scope, "_procname")); + if (bt_ctf_field_get_error()) { + noError = FALSE; + } + } +#endif + if (noError||1) { + g_string_append_printf(processInfos, "%u, %u, %s, %u", pid, tid, procname, ppid); + } + else { + ret = -1; + } + + return ret; +} + +static +int getCPUIdFromEvent(LttvEvent *event, GString* cpuId_str) +{ + gint cpuid; + + cpuid = lttv_traceset_get_cpuid_from_event(event); + if (cpuid < 0) { + return -1; + } + g_string_append_printf(cpuId_str, "%u", cpuid); + return 0; +} + +int getFields(struct bt_ctf_event *ctf_event, struct definition const *fields, GString* fieldsStr) +{ + enum ctf_type_id fieldType = bt_ctf_field_type(fields); + int ret = 0, isSigned = -1, len = 0, i = 0; + struct definition *index_def; + switch (fieldType) { + case CTF_TYPE_INTEGER: + isSigned = bt_ctf_get_int_signedness(fields); + if (isSigned == 1) { + g_string_append_printf(fieldsStr, "%lu", bt_ctf_get_int64(fields)); + } + else if (isSigned == 0) { + g_string_append_printf(fieldsStr, "%llu", bt_ctf_get_uint64(fields)); + } + break; + case CTF_TYPE_STRING: + g_string_append_printf(fieldsStr, "%s", bt_ctf_get_string(fields)); + break; + + case CTF_TYPE_ARRAY: + g_string_append_printf(fieldsStr, "[ "); + len = bt_ctf_get_array_len(fields); + if (index_def = bt_ctf_get_index(ctf_event, fields, i)) { + for (i = 0; i < len; i++) { + if (i > 0) { + g_string_append_printf(fieldsStr, ", "); + } + bt_ctf_field_type(bt_ctf_get_index(ctf_event, fields, i)); + g_string_append_printf(fieldsStr, " "); + g_string_append_printf(fieldsStr, "[%d] = "); + getFields(ctf_event, bt_ctf_get_index(ctf_event, fields, i), fieldsStr); + } + } + else { + g_string_append_printf(fieldsStr, "%s", bt_ctf_get_char_array(fields)); + } + g_string_append_printf(fieldsStr, " ]"); + + break; + case CTF_TYPE_UNKNOWN: + default: + break; + } + return ret; +} + +int getFieldsFromEvent(struct bt_ctf_event *ctf_event, GString* fields, gboolean field_names) +{ + struct definition const * const *list = NULL; + unsigned int count; + int i = 0, j = 0, ret = 0; + gboolean noError = TRUE; + struct definition *scope; + scope = bt_ctf_get_top_level_scope(ctf_event, BT_EVENT_FIELDS); + + if (!scope) { + noError = FALSE; + } + if (noError) { + ret = bt_ctf_get_field_list(ctf_event, scope, &list, &count); + if (ret < 0) { + noError = TRUE; + } + else { + for (i = 0; i < count; i++) { + if (i > 0) { + g_string_append_printf(fields, ", "); + } + const char *name = bt_ctf_field_name(list[i]); + if (field_names) { + g_string_append_printf(fields, "%s = ", name); + } + getFields(ctf_event, list[i] ,fields); + if (bt_ctf_field_get_error()) { + continue; + } + } + } + } + if (!noError) { + ret = -1; + } + return ret; +} + +void lttv_event_to_string(LttvEvent *event, GString *a_string, + gboolean field_names, gboolean long_version) +{ + GString* processInfos = g_string_new(""); + GString* fields = g_string_new(""); + GString* cpuId_str = g_string_new(""); + getProcessInfosFromEvent(event, processInfos); + getFieldsFromEvent(event->bt_event, fields, field_names); + getCPUIdFromEvent(event, cpuId_str); + + g_string_set_size(a_string,0); + if(long_version){ + g_string_append_printf(a_string, "%llu %s: ", + bt_ctf_get_timestamp(event->bt_event), + bt_ctf_event_name(event->bt_event)); + } + g_string_append_printf(a_string, "{ %s }", cpuId_str->str); + + if (strcmp("", processInfos->str) < 0) { + g_string_append_printf(a_string, ", { %s }", processInfos->str); + } + if (strcmp("", fields->str) < 0) { + g_string_append_printf(a_string, ", { %s }", fields->str); + } + + g_string_free(fields, TRUE); + g_string_free(processInfos, TRUE); + g_string_free(cpuId_str, TRUE); +} +void lttv_event_get_name(LttvEvent *event,GString *a_string) +{ + g_string_set_size(a_string,0); + g_string_append_printf(a_string, " %s", bt_ctf_event_name(event->bt_event)); +} +#ifdef BABEL_CLEANUP void lttv_event_to_string(LttEvent *e, GString *s, gboolean mandatory_fields, gboolean field_names, LttvTracefileState *tfs) { @@ -305,6 +513,7 @@ void lttv_event_to_string(LttEvent *e, GString *s, gboolean mandatory_fields, } g_string_append_printf(s, " }"); } +#endif /* BABEL_CLEANUP */ static void init() {