perf/util/data-convert-bt.c

144 static __maybe_unused int value_set_##_name(struct ctf_writer *cw,	\
149 	struct bt_ctf_field_type *type = cw->data._name;		\
163 value_set_string(struct ctf_writer *cw, struct bt_ctf_event *event,
166 	struct bt_ctf_field_type *type = cw->data.string;
192 get_tracepoint_field_type(struct ctf_writer *cw, struct tep_format_field *field)
197 		return cw->data.string;
202 			return cw->data.u64_hex;
207 			return cw->data.s64;
209 			return cw->data.s32;
213 		return cw->data.u64;
215 		return cw->data.u32;
293 static int add_tracepoint_field_value(struct ctf_writer *cw,
347 	type = get_tracepoint_field_type(cw, fmtf);
405 static int add_tracepoint_fields_values(struct ctf_writer *cw,
415 		ret = add_tracepoint_field_value(cw, event_class, event, sample,
423 static int add_tracepoint_values(struct ctf_writer *cw,
433 	ret = add_tracepoint_fields_values(cw, event_class, event,
436 		ret = add_tracepoint_fields_values(cw, event_class, event,
595 static int add_generic_values(struct ctf_writer *cw,
615 		ret = value_set_u64_hex(cw, event, "perf_ip", sample->ip);
621 		ret = value_set_s32(cw, event, "perf_tid", sample->tid);
625 		ret = value_set_s32(cw, event, "perf_pid", sample->pid);
632 		ret = value_set_u64(cw, event, "perf_id", sample->id);
638 		ret = value_set_u64(cw, event, "perf_stream_id", sample->stream_id);
644 		ret = value_set_u64(cw, event, "perf_period", sample->period);
650 		ret = value_set_u64(cw, event, "perf_weight", sample->weight);
656 		ret = value_set_u64(cw, event, "perf_data_src",
663 		ret = value_set_u64(cw, event, "perf_transaction",
690 static struct ctf_stream *ctf_stream__create(struct ctf_writer *cw, int cpu)
704 	stream = bt_ctf_writer_create_stream(cw->writer, cw->stream_class);
753 static struct ctf_stream *ctf_stream(struct ctf_writer *cw, int cpu)
755 	struct ctf_stream *cs = cw->stream[cpu];
758 		cs = ctf_stream__create(cw, cpu);
759 		cw->stream[cpu] = cs;
765 static int get_sample_cpu(struct ctf_writer *cw, struct perf_sample *sample,
773 	if (cpu > cw->stream_cnt) {
775 			cpu, cw->stream_cnt);
803 	struct ctf_writer *cw = &c->writer;
827 	bt_ctf_clock_set_time(cw->clock, sample->time);
829 	ret = add_generic_values(cw, event, evsel, sample);
834 		ret = add_tracepoint_values(cw, event_class, event,
853 	cs = ctf_stream(cw, get_sample_cpu(cw, sample, evsel));
868 	ret = value_set_##_type(cw, event, #_field, _event->_name._field);\
880 	struct ctf_writer *cw = &c->writer;			\
881 	struct bt_ctf_event_class *event_class = cw->_name##_class;\
894 	bt_ctf_clock_set_time(cw->clock, sample->time);		\
896 	cs = ctf_stream(cw, 0);					\
1020 static int add_tracepoint_fields_types(struct ctf_writer *cw,
1033 		type = get_tracepoint_field_type(cw, field);
1063 static int add_tracepoint_types(struct ctf_writer *cw,
1071 	ret = add_tracepoint_fields_types(cw, common_fields, class);
1073 		ret = add_tracepoint_fields_types(cw, fields, class);
1078 static int add_bpf_output_types(struct ctf_writer *cw,
1081 	struct bt_ctf_field_type *len_type = cw->data.u32;
1082 	struct bt_ctf_field_type *seq_base_type = cw->data.u32_hex;
1097 static int add_generic_types(struct ctf_writer *cw, struct evsel *evsel,
1125 		ADD_FIELD(event_class, cw->data.u64_hex, "perf_ip");
1128 		ADD_FIELD(event_class, cw->data.s32, "perf_tid");
1129 		ADD_FIELD(event_class, cw->data.s32, "perf_pid");
1134 		ADD_FIELD(event_class, cw->data.u64, "perf_id");
1137 		ADD_FIELD(event_class, cw->data.u64, "perf_stream_id");
1140 		ADD_FIELD(event_class, cw->data.u64, "perf_period");
1143 		ADD_FIELD(event_class, cw->data.u64, "perf_weight");
1146 		ADD_FIELD(event_class, cw->data.u64, "perf_data_src");
1149 		ADD_FIELD(event_class, cw->data.u64, "perf_transaction");
1152 		ADD_FIELD(event_class, cw->data.u32, "perf_callchain_size");
1155 				cw->data.u64_hex, "perf_callchain_size"),
1163 static int add_event(struct ctf_writer *cw, struct evsel *evsel)
1176 	ret = add_generic_types(cw, evsel, event_class);
1181 		ret = add_tracepoint_types(cw, evsel, event_class);
1187 		ret = add_bpf_output_types(cw, event_class);
1192 	ret = bt_ctf_stream_class_add_event_class(cw->stream_class, event_class);
1212 static int setup_events(struct ctf_writer *cw, struct perf_session *session)
1219 		ret = add_event(cw, evsel);
1229 		if (bt_ctf_event_class_add_field(event_class, cw->data.t, #n)) {\
1236 static int add_##_name##_event(struct ctf_writer *cw)		\
1247 	ret = bt_ctf_stream_class_add_event_class(cw->stream_class, event_class);\
1253 	cw->_name##_class = event_class;			\
1296 static int setup_non_sample_events(struct ctf_writer *cw,
1301 	ret = add_comm_event(cw);
1304 	ret = add_exit_event(cw);
1307 	ret = add_fork_event(cw);
1310 	ret = add_mmap_event(cw);
1313 	ret = add_mmap2_event(cw);
1336 static int setup_streams(struct ctf_writer *cw, struct perf_session *session)
1354 	cw->stream     = stream;
1355 	cw->stream_cnt = ncpus;
1359 static void free_streams(struct ctf_writer *cw)
1363 	for (cpu = 0; cpu < cw->stream_cnt; cpu++)
1364 		ctf_stream__delete(cw->stream[cpu]);
1366 	zfree(&cw->stream);
1369 static int ctf_writer__setup_env(struct ctf_writer *cw,
1373 	struct bt_ctf_writer *writer = cw->writer;
1393 static int ctf_writer__setup_clock(struct ctf_writer *cw,
1397 	struct bt_ctf_clock *clock = cw->clock;
1461 static void ctf_writer__cleanup_data(struct ctf_writer *cw)
1465 	for (i = 0; i < ARRAY_SIZE(cw->data.array); i++)
1466 		bt_ctf_field_type_put(cw->data.array[i]);
1469 static int ctf_writer__init_data(struct ctf_writer *cw)
1478 	CREATE_INT_TYPE(cw->data.s64, 64, true,  false);
1479 	CREATE_INT_TYPE(cw->data.u64, 64, false, false);
1480 	CREATE_INT_TYPE(cw->data.s32, 32, true,  false);
1481 	CREATE_INT_TYPE(cw->data.u32, 32, false, false);
1482 	CREATE_INT_TYPE(cw->data.u32_hex, 32, false, true);
1483 	CREATE_INT_TYPE(cw->data.u64_hex, 64, false, true);
1485 	cw->data.string  = bt_ctf_field_type_string_create();
1486 	if (cw->data.string)
1490 	ctf_writer__cleanup_data(cw);
1495 static void ctf_writer__cleanup(struct ctf_writer *cw)
1497 	ctf_writer__cleanup_data(cw);
1499 	bt_ctf_clock_put(cw->clock);
1500 	free_streams(cw);
1501 	bt_ctf_stream_class_put(cw->stream_class);
1502 	bt_ctf_writer_put(cw->writer);
1505 	memset(cw, 0, sizeof(*cw));
1508 static int ctf_writer__init(struct ctf_writer *cw, const char *path,
1522 	cw->writer = writer;
1531 	cw->clock = clock;
1533 	if (ctf_writer__setup_clock(cw, session, tod)) {
1545 	cw->stream_class = stream_class;
1553 	if (ctf_writer__init_data(cw))
1561 	ret = bt_ctf_field_type_structure_add_field(pkt_ctx_type, cw->data.u32, "cpu_id");
1575 	ctf_writer__cleanup(cw);
1581 static int ctf_writer__flush_streams(struct ctf_writer *cw)
1585 	for (cpu = 0; cpu < cw->stream_cnt && !ret; cpu++)
1586 		ret = ctf_stream__flush(cw->stream[cpu]);
1626 	struct ctf_writer *cw = &c.writer;
1648 	if (ctf_writer__init(cw, path, session, opts->tod))
1657 	if (ctf_writer__setup_env(cw, session))
1661 	if (setup_events(cw, session))
1664 	if (opts->all && setup_non_sample_events(cw, session))
1667 	if (setup_streams(cw, session))
1672 		err = ctf_writer__flush_streams(cw);
1692 	ctf_writer__cleanup(cw);
1697 	ctf_writer__cleanup(cw);