140 static __maybe_unused int value_set_##_name(struct ctf_writer *cw,	\
145 	struct bt_ctf_field_type *type = cw->data._name;		\
159 value_set_string(struct ctf_writer *cw, struct bt_ctf_event *event,  in value_set_string()  argument
162 	struct bt_ctf_field_type *type = cw->data.string;  in value_set_string()
188 get_tracepoint_field_type(struct ctf_writer *cw, struct tep_format_field *field)  in get_tracepoint_field_type()  argument
193 		return cw->data.string;  in get_tracepoint_field_type()
198 			return cw->data.u64_hex;  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()
209 		return cw->data.u64;  in get_tracepoint_field_type()
211 		return cw->data.u32;  in get_tracepoint_field_type()
289 static int add_tracepoint_field_value(struct ctf_writer *cw,  in add_tracepoint_field_value()  argument
343 	type = get_tracepoint_field_type(cw, fmtf);  in add_tracepoint_field_value()
401 static int add_tracepoint_fields_values(struct ctf_writer *cw,  in add_tracepoint_fields_values()  argument
411 		ret = add_tracepoint_field_value(cw, event_class, event, sample,  in add_tracepoint_fields_values()
419 static int add_tracepoint_values(struct ctf_writer *cw,  in add_tracepoint_values()  argument
429 	ret = add_tracepoint_fields_values(cw, event_class, event,  in add_tracepoint_values()
432 		ret = add_tracepoint_fields_values(cw, event_class, event,  in add_tracepoint_values()
591 static int add_generic_values(struct ctf_writer *cw,  in add_generic_values()  argument
611 		ret = value_set_u64_hex(cw, event, "perf_ip", sample->ip);  in add_generic_values()
617 		ret = value_set_s32(cw, event, "perf_tid", sample->tid);  in add_generic_values()
621 		ret = value_set_s32(cw, event, "perf_pid", sample->pid);  in add_generic_values()
628 		ret = value_set_u64(cw, event, "perf_id", sample->id);  in add_generic_values()
634 		ret = value_set_u64(cw, event, "perf_stream_id", sample->stream_id);  in add_generic_values()
640 		ret = value_set_u64(cw, event, "perf_period", sample->period);  in add_generic_values()
646 		ret = value_set_u64(cw, event, "perf_weight", sample->weight);  in add_generic_values()
652 		ret = value_set_u64(cw, event, "perf_data_src",  in add_generic_values()
659 		ret = value_set_u64(cw, event, "perf_transaction",  in add_generic_values()
686 static struct ctf_stream *ctf_stream__create(struct ctf_writer *cw, int cpu)  in ctf_stream__create()  argument
700 	stream = bt_ctf_writer_create_stream(cw->writer, cw->stream_class);  in ctf_stream__create()
749 static struct ctf_stream *ctf_stream(struct ctf_writer *cw, int cpu)  in ctf_stream()  argument
751 	struct ctf_stream *cs = cw->stream[cpu];  in ctf_stream()
754 		cs = ctf_stream__create(cw, cpu);  in ctf_stream()
755 		cw->stream[cpu] = cs;  in ctf_stream()
761 static int get_sample_cpu(struct ctf_writer *cw, struct perf_sample *sample,  in get_sample_cpu()  argument
769 	if (cpu > cw->stream_cnt) {  in get_sample_cpu()
771 			cpu, cw->stream_cnt);  in get_sample_cpu()
799 	struct ctf_writer *cw = &c->writer;  in process_sample_event()  local
823 	bt_ctf_clock_set_time(cw->clock, sample->time);  in process_sample_event()
825 	ret = add_generic_values(cw, event, evsel, sample);  in process_sample_event()
830 		ret = add_tracepoint_values(cw, event_class, event,  in process_sample_event()
849 	cs = ctf_stream(cw, get_sample_cpu(cw, sample, evsel));  in process_sample_event()
864 	ret = value_set_##_type(cw, event, #_field, _event->_name._field);\
876 	struct ctf_writer *cw = &c->writer;			\
877 	struct bt_ctf_event_class *event_class = cw->_name##_class;\
890 	bt_ctf_clock_set_time(cw->clock, sample->time);		\
892 	cs = ctf_stream(cw, 0);					\
1016 static int add_tracepoint_fields_types(struct ctf_writer *cw,  in add_tracepoint_fields_types()  argument
1029 		type = get_tracepoint_field_type(cw, field);  in add_tracepoint_fields_types()
1059 static int add_tracepoint_types(struct ctf_writer *cw,  in add_tracepoint_types()  argument
1067 	ret = add_tracepoint_fields_types(cw, common_fields, class);  in add_tracepoint_types()
1069 		ret = add_tracepoint_fields_types(cw, fields, class);  in add_tracepoint_types()
1074 static int add_bpf_output_types(struct ctf_writer *cw,  in add_bpf_output_types()  argument
1077 	struct bt_ctf_field_type *len_type = cw->data.u32;  in add_bpf_output_types()
1078 	struct bt_ctf_field_type *seq_base_type = cw->data.u32_hex;  in add_bpf_output_types()
1093 static int add_generic_types(struct ctf_writer *cw, struct evsel *evsel,  in add_generic_types()  argument
1121 		ADD_FIELD(event_class, cw->data.u64_hex, "perf_ip");  in add_generic_types()
1124 		ADD_FIELD(event_class, cw->data.s32, "perf_tid");  in add_generic_types()
1125 		ADD_FIELD(event_class, cw->data.s32, "perf_pid");  in add_generic_types()
1130 		ADD_FIELD(event_class, cw->data.u64, "perf_id");  in add_generic_types()
1133 		ADD_FIELD(event_class, cw->data.u64, "perf_stream_id");  in add_generic_types()
1136 		ADD_FIELD(event_class, cw->data.u64, "perf_period");  in add_generic_types()
1139 		ADD_FIELD(event_class, cw->data.u64, "perf_weight");  in add_generic_types()
1142 		ADD_FIELD(event_class, cw->data.u64, "perf_data_src");  in add_generic_types()
1145 		ADD_FIELD(event_class, cw->data.u64, "perf_transaction");  in add_generic_types()
1148 		ADD_FIELD(event_class, cw->data.u32, "perf_callchain_size");  in add_generic_types()
1151 				cw->data.u64_hex, "perf_callchain_size"),  in add_generic_types()
1159 static int add_event(struct ctf_writer *cw, struct evsel *evsel)  in add_event()  argument
1172 	ret = add_generic_types(cw, evsel, event_class);  in add_event()
1177 		ret = add_tracepoint_types(cw, evsel, event_class);  in add_event()
1183 		ret = add_bpf_output_types(cw, event_class);  in add_event()
1188 	ret = bt_ctf_stream_class_add_event_class(cw->stream_class, event_class);  in add_event()
1208 static int setup_events(struct ctf_writer *cw, struct perf_session *session)  in setup_events()  argument
1215 		ret = add_event(cw, evsel);  in setup_events()
1225 		if (bt_ctf_event_class_add_field(event_class, cw->data.t, #n)) {\
1232 static int add_##_name##_event(struct ctf_writer *cw)		\
1243 	ret = bt_ctf_stream_class_add_event_class(cw->stream_class, event_class);\
1249 	cw->_name##_class = event_class;			\
1292 static int setup_non_sample_events(struct ctf_writer *cw,
1297 	ret = add_comm_event(cw);
1300 	ret = add_exit_event(cw);
1303 	ret = add_fork_event(cw);
1306 	ret = add_mmap_event(cw);
1309 	ret = add_mmap2_event(cw);
1332 static int setup_streams(struct ctf_writer *cw, struct perf_session *session)  in setup_streams()  argument
1350 	cw->stream     = stream;  in setup_streams()
1351 	cw->stream_cnt = ncpus;  in setup_streams()
1355 static void free_streams(struct ctf_writer *cw)  in free_streams()  argument
1359 	for (cpu = 0; cpu < cw->stream_cnt; cpu++)  in free_streams()
1360 		ctf_stream__delete(cw->stream[cpu]);  in free_streams()
1362 	zfree(&cw->stream);  in free_streams()
1365 static int ctf_writer__setup_env(struct ctf_writer *cw,  in ctf_writer__setup_env()  argument
1369 	struct bt_ctf_writer *writer = cw->writer;  in ctf_writer__setup_env()
1389 static int ctf_writer__setup_clock(struct ctf_writer *cw,  in ctf_writer__setup_clock()  argument
1393 	struct bt_ctf_clock *clock = cw->clock;  in ctf_writer__setup_clock()
1457 static void ctf_writer__cleanup_data(struct ctf_writer *cw)  in ctf_writer__cleanup_data()  argument
1461 	for (i = 0; i < ARRAY_SIZE(cw->data.array); i++)  in ctf_writer__cleanup_data()
1462 		bt_ctf_field_type_put(cw->data.array[i]);  in ctf_writer__cleanup_data()
1465 static int ctf_writer__init_data(struct ctf_writer *cw)  in ctf_writer__init_data()  argument
1474 	CREATE_INT_TYPE(cw->data.s64, 64, true,  false);  in ctf_writer__init_data()
1475 	CREATE_INT_TYPE(cw->data.u64, 64, false, false);  in ctf_writer__init_data()
1476 	CREATE_INT_TYPE(cw->data.s32, 32, true,  false);  in ctf_writer__init_data()
1477 	CREATE_INT_TYPE(cw->data.u32, 32, false, false);  in ctf_writer__init_data()
1478 	CREATE_INT_TYPE(cw->data.u32_hex, 32, false, true);  in ctf_writer__init_data()
1479 	CREATE_INT_TYPE(cw->data.u64_hex, 64, false, true);  in ctf_writer__init_data()
1481 	cw->data.string  = bt_ctf_field_type_string_create();  in ctf_writer__init_data()
1482 	if (cw->data.string)  in ctf_writer__init_data()
1486 	ctf_writer__cleanup_data(cw);  in ctf_writer__init_data()
1491 static void ctf_writer__cleanup(struct ctf_writer *cw)  in ctf_writer__cleanup()  argument
1493 	ctf_writer__cleanup_data(cw);  in ctf_writer__cleanup()
1495 	bt_ctf_clock_put(cw->clock);  in ctf_writer__cleanup()
1496 	free_streams(cw);  in ctf_writer__cleanup()
1497 	bt_ctf_stream_class_put(cw->stream_class);  in ctf_writer__cleanup()
1498 	bt_ctf_writer_put(cw->writer);  in ctf_writer__cleanup()
1501 	memset(cw, 0, sizeof(*cw));  in ctf_writer__cleanup()
1504 static int ctf_writer__init(struct ctf_writer *cw, const char *path,  in ctf_writer__init()  argument
1518 	cw->writer = writer;  in ctf_writer__init()
1527 	cw->clock = clock;  in ctf_writer__init()
1529 	if (ctf_writer__setup_clock(cw, session, tod)) {  in ctf_writer__init()
1541 	cw->stream_class = stream_class;  in ctf_writer__init()
1549 	if (ctf_writer__init_data(cw))  in ctf_writer__init()
1557 	ret = bt_ctf_field_type_structure_add_field(pkt_ctx_type, cw->data.u32, "cpu_id");  in ctf_writer__init()
1571 	ctf_writer__cleanup(cw);  in ctf_writer__init()
1577 static int ctf_writer__flush_streams(struct ctf_writer *cw)  in ctf_writer__flush_streams()  argument
1581 	for (cpu = 0; cpu < cw->stream_cnt && !ret; cpu++)  in ctf_writer__flush_streams()
1582 		ret = ctf_stream__flush(cw->stream[cpu]);  in ctf_writer__flush_streams()
1622 	struct ctf_writer *cw = &c.writer;  in bt_convert__perf2ctf()  local
1644 	if (ctf_writer__init(cw, path, session, opts->tod))  in bt_convert__perf2ctf()
1653 	if (ctf_writer__setup_env(cw, session))  in bt_convert__perf2ctf()
1657 	if (setup_events(cw, session))  in bt_convert__perf2ctf()
1660 	if (opts->all && setup_non_sample_events(cw, session))  in bt_convert__perf2ctf()
1663 	if (setup_streams(cw, session))  in bt_convert__perf2ctf()
1668 		err = ctf_writer__flush_streams(cw);  in bt_convert__perf2ctf()
1688 	ctf_writer__cleanup(cw);  in bt_convert__perf2ctf()
1693 	ctf_writer__cleanup(cw);  in bt_convert__perf2ctf()