Lines Matching +full:cs +full:- +full:out
1 // SPDX-License-Identifier: GPL-2.0-only
14 #include <babeltrace/ctf-writer/writer.h>
15 #include <babeltrace/ctf-writer/clock.h>
16 #include <babeltrace/ctf-writer/stream.h>
17 #include <babeltrace/ctf-writer/event.h>
18 #include <babeltrace/ctf-writer/event-types.h>
19 #include <babeltrace/ctf-writer/event-fields.h>
20 #include <babeltrace/ctf-ir/utils.h>
22 #include <traceevent/event-parse.h>
24 #include "data-convert-bt.h"
109 return -1; in value_set()
145 struct bt_ctf_field_type *type = cw->data._name; \
162 struct bt_ctf_field_type *type = cw->data.string; in value_set_string()
169 return -1; in value_set_string()
190 unsigned long flags = field->flags; in get_tracepoint_field_type()
193 return cw->data.string; in get_tracepoint_field_type()
198 return cw->data.u64_hex; in get_tracepoint_field_type()
202 if (field->size == 8) in get_tracepoint_field_type()
203 return cw->data.s64; in get_tracepoint_field_type()
205 return cw->data.s32; in get_tracepoint_field_type()
208 if (field->size == 8) in get_tracepoint_field_type()
209 return cw->data.u64; in get_tracepoint_field_type()
211 return cw->data.u32; in get_tracepoint_field_type()
219 * value_mask = (1 << (size * 8 - 1)) - 1. in adjust_signedness()
244 if ((value_int & (~0ULL - value_mask)) == 0) in adjust_signedness()
269 buffer = zalloc(i + (len - i) * 4 + 2); in string_set_value()
272 return bt_ctf_field_string_set_value(field, "UNPRINTABLE-STRING"); in string_set_value()
298 const char *name = fmtf->name; in add_tracepoint_field_value()
299 void *data = sample->raw_data; in add_tracepoint_field_value()
300 unsigned long flags = fmtf->flags; in add_tracepoint_field_value()
307 name = fmtf->alias; in add_tracepoint_field_value()
308 offset = fmtf->offset; in add_tracepoint_field_value()
309 len = fmtf->size; in add_tracepoint_field_value()
316 tmp_val = tep_read_number(fmtf->event->tep, in add_tracepoint_field_value()
331 return -1; in add_tracepoint_field_value()
334 len = fmtf->size / fmtf->arraylen; in add_tracepoint_field_value()
335 n_items = fmtf->arraylen; in add_tracepoint_field_value()
351 return -1; in add_tracepoint_field_value()
360 fmtf->event->tep, in add_tracepoint_field_value()
388 return -1; in add_tracepoint_field_value()
396 return -1; in add_tracepoint_field_value()
408 for (field = fields; field; field = field->next) { in add_tracepoint_fields_values()
412 return -1; in add_tracepoint_fields_values()
423 struct tep_format_field *common_fields = evsel->tp_format->format.common_fields; in add_tracepoint_values()
424 struct tep_format_field *fields = evsel->tp_format->format.fields; in add_tracepoint_values()
443 unsigned int raw_size = sample->raw_size; in add_bpf_output_values()
450 raw_size, nr_elements * sizeof(u32) - raw_size); in add_bpf_output_values()
456 ret = -1; in add_bpf_output_values()
475 ret = -1; in add_bpf_output_values()
490 ((u32 *)(sample->raw_data))[i]); in add_bpf_output_values()
521 unsigned int nr_elements = callchain->nr; in add_callchain_output_values()
530 ret = -1; in add_callchain_output_values()
550 ret = -1; in add_callchain_output_values()
565 ((u64 *)(callchain->ips))[i]); in add_callchain_output_values()
594 u64 type = evsel->core.attr.sample_type; in add_generic_values()
599 * PERF_SAMPLE_TIME - not needed as we have it in in add_generic_values()
601 * PERF_SAMPLE_READ - TODO in add_generic_values()
602 * PERF_SAMPLE_RAW - tracepoint fields are handled separately in add_generic_values()
603 * PERF_SAMPLE_BRANCH_STACK - TODO in add_generic_values()
604 * PERF_SAMPLE_REGS_USER - TODO in add_generic_values()
605 * PERF_SAMPLE_STACK_USER - TODO in add_generic_values()
609 ret = value_set_u64_hex(cw, event, "perf_ip", sample->ip); in add_generic_values()
611 return -1; in add_generic_values()
615 ret = value_set_s32(cw, event, "perf_tid", sample->tid); in add_generic_values()
617 return -1; in add_generic_values()
619 ret = value_set_s32(cw, event, "perf_pid", sample->pid); in add_generic_values()
621 return -1; in add_generic_values()
626 ret = value_set_u64(cw, event, "perf_id", sample->id); in add_generic_values()
628 return -1; in add_generic_values()
632 ret = value_set_u64(cw, event, "perf_stream_id", sample->stream_id); in add_generic_values()
634 return -1; in add_generic_values()
638 ret = value_set_u64(cw, event, "perf_period", sample->period); in add_generic_values()
640 return -1; in add_generic_values()
644 ret = value_set_u64(cw, event, "perf_weight", sample->weight); in add_generic_values()
646 return -1; in add_generic_values()
651 sample->data_src); in add_generic_values()
653 return -1; in add_generic_values()
658 sample->transaction); in add_generic_values()
660 return -1; in add_generic_values()
666 static int ctf_stream__flush(struct ctf_stream *cs) in ctf_stream__flush() argument
670 if (cs) { in ctf_stream__flush()
671 err = bt_ctf_stream_flush(cs->stream); in ctf_stream__flush()
673 pr_err("CTF stream %d flush failed\n", cs->cpu); in ctf_stream__flush()
676 cs->cpu, cs->count); in ctf_stream__flush()
678 cs->count = 0; in ctf_stream__flush()
686 struct ctf_stream *cs; in ctf_stream__create() local
692 cs = zalloc(sizeof(*cs)); in ctf_stream__create()
693 if (!cs) { in ctf_stream__create()
698 stream = bt_ctf_writer_create_stream(cw->writer, cw->stream_class); in ctf_stream__create()
701 goto out; in ctf_stream__create()
707 goto out; in ctf_stream__create()
714 goto out; in ctf_stream__create()
720 goto out; in ctf_stream__create()
725 cs->cpu = cpu; in ctf_stream__create()
726 cs->stream = stream; in ctf_stream__create()
727 return cs; in ctf_stream__create()
729 out: in ctf_stream__create()
735 free(cs); in ctf_stream__create()
739 static void ctf_stream__delete(struct ctf_stream *cs) in ctf_stream__delete() argument
741 if (cs) { in ctf_stream__delete()
742 bt_ctf_stream_put(cs->stream); in ctf_stream__delete()
743 free(cs); in ctf_stream__delete()
749 struct ctf_stream *cs = cw->stream[cpu]; in ctf_stream() local
751 if (!cs) { in ctf_stream()
752 cs = ctf_stream__create(cw, cpu); in ctf_stream()
753 cw->stream[cpu] = cs; in ctf_stream()
756 return cs; in ctf_stream()
764 if (evsel->core.attr.sample_type & PERF_SAMPLE_CPU) in get_sample_cpu()
765 cpu = sample->cpu; in get_sample_cpu()
767 if (cpu > cw->stream_cnt) { in get_sample_cpu()
769 cpu, cw->stream_cnt); in get_sample_cpu()
784 static bool is_flush_needed(struct ctf_stream *cs) in is_flush_needed() argument
786 return cs->count >= STREAM_FLUSH_COUNT; in is_flush_needed()
796 struct evsel_priv *priv = evsel->priv; in process_sample_event()
797 struct ctf_writer *cw = &c->writer; in process_sample_event()
798 struct ctf_stream *cs; in process_sample_event() local
802 unsigned long type = evsel->core.attr.sample_type; in process_sample_event()
807 event_class = priv->event_class; in process_sample_event()
810 c->events_count++; in process_sample_event()
811 c->events_size += _event->header.size; in process_sample_event()
813 pr_time2(sample->time, "sample %" PRIu64 "\n", c->events_count); in process_sample_event()
818 return -1; in process_sample_event()
821 bt_ctf_clock_set_time(cw->clock, sample->time); in process_sample_event()
825 return -1; in process_sample_event()
827 if (evsel->core.attr.type == PERF_TYPE_TRACEPOINT) { in process_sample_event()
831 return -1; in process_sample_event()
836 event, sample->callchain); in process_sample_event()
838 return -1; in process_sample_event()
844 return -1; in process_sample_event()
847 cs = ctf_stream(cw, get_sample_cpu(cw, sample, evsel)); in process_sample_event()
848 if (cs) { in process_sample_event()
849 if (is_flush_needed(cs)) in process_sample_event()
850 ctf_stream__flush(cs); in process_sample_event()
852 cs->count++; in process_sample_event()
853 bt_ctf_stream_append_event(cs->stream, event); in process_sample_event()
857 return cs ? 0 : -1; in process_sample_event()
862 ret = value_set_##_type(cw, event, #_field, _event->_name._field);\
864 return -1; \
874 struct ctf_writer *cw = &c->writer; \
875 struct bt_ctf_event_class *event_class = cw->_name##_class;\
877 struct ctf_stream *cs; \
880 c->non_sample_count++; \
881 c->events_size += _event->header.size; \
885 return -1; \
888 bt_ctf_clock_set_time(cw->clock, sample->time); \
890 cs = ctf_stream(cw, 0); \
891 if (cs) { \
892 if (is_flush_needed(cs)) \
893 ctf_stream__flush(cs); \
895 cs->count++; \
896 bt_ctf_stream_append_event(cs->stream, event); \
948 goto out;
961 goto out;
968 out:
984 if (field->alias != field->name) in event_class_add_field()
986 (char *)field->alias); in event_class_add_field()
988 name = field->name; in event_class_add_field()
992 name = change_name(name, field->name, -1); in event_class_add_field()
996 return -1; in event_class_add_field()
1000 name = change_name(name, field->name, dup++); in event_class_add_field()
1002 pr_err("Failed to create dup name for '%s'\n", field->name); in event_class_add_field()
1003 return -1; in event_class_add_field()
1009 field->alias = name; in event_class_add_field()
1021 for (field = fields; field; field = field->next) { in add_tracepoint_fields_types()
1023 unsigned long flags = field->flags; in add_tracepoint_fields_types()
1025 pr2(" field '%s'\n", field->name); in add_tracepoint_fields_types()
1029 return -1; in add_tracepoint_fields_types()
1040 type = bt_ctf_field_type_array_create(type, field->arraylen); in add_tracepoint_fields_types()
1049 field->name, ret); in add_tracepoint_fields_types()
1050 return -1; in add_tracepoint_fields_types()
1061 struct tep_format_field *common_fields = evsel->tp_format->format.common_fields; in add_tracepoint_types()
1062 struct tep_format_field *fields = evsel->tp_format->format.fields; in add_tracepoint_types()
1075 struct bt_ctf_field_type *len_type = cw->data.u32; in add_bpf_output_types()
1076 struct bt_ctf_field_type *seq_base_type = cw->data.u32_hex; in add_bpf_output_types()
1086 return -1; in add_bpf_output_types()
1094 u64 type = evsel->core.attr.sample_type; in add_generic_types()
1098 * PERF_SAMPLE_TIME - not needed as we have it in in add_generic_types()
1100 * PERF_SAMPLE_READ - TODO in add_generic_types()
1101 * PERF_SAMPLE_CALLCHAIN - TODO in add_generic_types()
1102 * PERF_SAMPLE_RAW - tracepoint fields and BPF output in add_generic_types()
1104 * PERF_SAMPLE_BRANCH_STACK - TODO in add_generic_types()
1105 * PERF_SAMPLE_REGS_USER - TODO in add_generic_types()
1106 * PERF_SAMPLE_STACK_USER - TODO in add_generic_types()
1114 return -1; \ in add_generic_types()
1119 ADD_FIELD(event_class, cw->data.u64_hex, "perf_ip"); in add_generic_types()
1122 ADD_FIELD(event_class, cw->data.s32, "perf_tid"); in add_generic_types()
1123 ADD_FIELD(event_class, cw->data.s32, "perf_pid"); in add_generic_types()
1128 ADD_FIELD(event_class, cw->data.u64, "perf_id"); in add_generic_types()
1131 ADD_FIELD(event_class, cw->data.u64, "perf_stream_id"); in add_generic_types()
1134 ADD_FIELD(event_class, cw->data.u64, "perf_period"); in add_generic_types()
1137 ADD_FIELD(event_class, cw->data.u64, "perf_weight"); in add_generic_types()
1140 ADD_FIELD(event_class, cw->data.u64, "perf_data_src"); in add_generic_types()
1143 ADD_FIELD(event_class, cw->data.u64, "perf_transaction"); in add_generic_types()
1146 ADD_FIELD(event_class, cw->data.u32, "perf_callchain_size"); in add_generic_types()
1149 cw->data.u64_hex, "perf_callchain_size"), in add_generic_types()
1164 pr("Adding event '%s' (type %d)\n", name, evsel->core.attr.type); in add_event()
1168 return -1; in add_event()
1174 if (evsel->core.attr.type == PERF_TYPE_TRACEPOINT) { in add_event()
1186 ret = bt_ctf_stream_class_add_event_class(cw->stream_class, event_class); in add_event()
1196 priv->event_class = event_class; in add_event()
1197 evsel->priv = priv; in add_event()
1203 return -1; in add_event()
1208 struct evlist *evlist = session->evlist; in setup_events()
1223 if (bt_ctf_event_class_add_field(event_class, cw->data.t, #n)) {\
1225 return -1; \
1238 return -1; \
1241 ret = bt_ctf_stream_class_add_event_class(cw->stream_class, event_class);\
1247 cw->_name##_class = event_class; \
1315 struct evlist *evlist = session->evlist; in cleanup_events()
1321 priv = evsel->priv; in cleanup_events()
1322 bt_ctf_event_class_put(priv->event_class); in cleanup_events()
1323 zfree(&evsel->priv); in cleanup_events()
1327 session->evlist = NULL; in cleanup_events()
1333 struct perf_header *ph = &session->header; in setup_streams()
1340 ncpus = ph->env.nr_cpus_avail ?: MAX_CPUS; in setup_streams()
1345 return -ENOMEM; in setup_streams()
1348 cw->stream = stream; in setup_streams()
1349 cw->stream_cnt = ncpus; in setup_streams()
1357 for (cpu = 0; cpu < cw->stream_cnt; cpu++) in free_streams()
1358 ctf_stream__delete(cw->stream[cpu]); in free_streams()
1360 zfree(&cw->stream); in free_streams()
1366 struct perf_header *header = &session->header; in ctf_writer__setup_env()
1367 struct bt_ctf_writer *writer = cw->writer; in ctf_writer__setup_env()
1372 return -1; \ in ctf_writer__setup_env()
1375 ADD("host", header->env.hostname); in ctf_writer__setup_env()
1377 ADD("release", header->env.os_release); in ctf_writer__setup_env()
1378 ADD("version", header->env.version); in ctf_writer__setup_env()
1379 ADD("machine", header->env.arch); in ctf_writer__setup_env()
1391 struct bt_ctf_clock *clock = cw->clock; in ctf_writer__setup_clock()
1396 struct perf_env *env = &session->header.env; in ctf_writer__setup_clock()
1398 if (!env->clock.enabled) { in ctf_writer__setup_clock()
1399 pr_err("Can't provide --tod time, missing clock data. " in ctf_writer__setup_clock()
1400 "Please record with -k/--clockid option.\n"); in ctf_writer__setup_clock()
1401 return -1; in ctf_writer__setup_clock()
1404 desc = clockid_name(env->clock.clockid); in ctf_writer__setup_clock()
1405 offset = env->clock.tod_ns - env->clock.clockid_ns; in ctf_writer__setup_clock()
1411 return -1; \ in ctf_writer__setup_clock()
1446 pr2("Created type: INTEGER %d-bit %ssigned %s\n", in create_int_type()
1459 for (i = 0; i < ARRAY_SIZE(cw->data.array); i++) in ctf_writer__cleanup_data()
1460 bt_ctf_field_type_put(cw->data.array[i]); in ctf_writer__cleanup_data()
1472 CREATE_INT_TYPE(cw->data.s64, 64, true, false); in ctf_writer__init_data()
1473 CREATE_INT_TYPE(cw->data.u64, 64, false, false); in ctf_writer__init_data()
1474 CREATE_INT_TYPE(cw->data.s32, 32, true, false); in ctf_writer__init_data()
1475 CREATE_INT_TYPE(cw->data.u32, 32, false, false); in ctf_writer__init_data()
1476 CREATE_INT_TYPE(cw->data.u32_hex, 32, false, true); in ctf_writer__init_data()
1477 CREATE_INT_TYPE(cw->data.u64_hex, 64, false, true); in ctf_writer__init_data()
1479 cw->data.string = bt_ctf_field_type_string_create(); in ctf_writer__init_data()
1480 if (cw->data.string) in ctf_writer__init_data()
1486 return -1; in ctf_writer__init_data()
1493 bt_ctf_clock_put(cw->clock); in ctf_writer__cleanup()
1495 bt_ctf_stream_class_put(cw->stream_class); in ctf_writer__cleanup()
1496 bt_ctf_writer_put(cw->writer); in ctf_writer__cleanup()
1516 cw->writer = writer; in ctf_writer__init()
1525 cw->clock = clock; in ctf_writer__init()
1539 cw->stream_class = stream_class; in ctf_writer__init()
1555 ret = bt_ctf_field_type_structure_add_field(pkt_ctx_type, cw->data.u32, "cpu_id"); in ctf_writer__init()
1572 return -1; in ctf_writer__init()
1579 for (cpu = 0; cpu < cw->stream_cnt && !ret; cpu++) in ctf_writer__flush_streams()
1580 ret = ctf_stream__flush(cw->stream[cpu]); in ctf_writer__flush_streams()
1589 if (!strcmp(var, "convert.queue-size")) in convert__config()
1590 return perf_config_u64(&c->queue_size, var, value); in convert__config()
1602 .force = opts->force, in bt_convert__perf2ctf()
1623 if (opts->all) { in bt_convert__perf2ctf()
1635 err = -1; in bt_convert__perf2ctf()
1642 if (ctf_writer__init(cw, path, session, opts->tod)) in bt_convert__perf2ctf()
1646 ordered_events__set_alloc_size(&session->ordered_events, in bt_convert__perf2ctf()
1658 if (opts->all && setup_non_sample_events(cw, session)) in bt_convert__perf2ctf()
1682 fprintf(stderr, ", %" PRIu64 " non-samples) ]\n", c.non_sample_count); in bt_convert__perf2ctf()