Lines Matching refs:cw
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,
162 struct bt_ctf_field_type *type = cw->data.string;
188 get_tracepoint_field_type(struct ctf_writer *cw, struct tep_format_field *field)
193 return cw->data.string;
198 return cw->data.u64_hex;
203 return cw->data.s64;
205 return cw->data.s32;
209 return cw->data.u64;
211 return cw->data.u32;
289 static int add_tracepoint_field_value(struct ctf_writer *cw,
341 type = get_tracepoint_field_type(cw, fmtf);
399 static int add_tracepoint_fields_values(struct ctf_writer *cw,
409 ret = add_tracepoint_field_value(cw, event_class, event, sample,
417 static int add_tracepoint_values(struct ctf_writer *cw,
427 ret = add_tracepoint_fields_values(cw, event_class, event,
430 ret = add_tracepoint_fields_values(cw, event_class, event,
589 static int add_generic_values(struct ctf_writer *cw,
609 ret = value_set_u64_hex(cw, event, "perf_ip", sample->ip);
615 ret = value_set_s32(cw, event, "perf_tid", sample->tid);
619 ret = value_set_s32(cw, event, "perf_pid", sample->pid);
626 ret = value_set_u64(cw, event, "perf_id", sample->id);
632 ret = value_set_u64(cw, event, "perf_stream_id", sample->stream_id);
638 ret = value_set_u64(cw, event, "perf_period", sample->period);
644 ret = value_set_u64(cw, event, "perf_weight", sample->weight);
650 ret = value_set_u64(cw, event, "perf_data_src",
657 ret = value_set_u64(cw, event, "perf_transaction",
684 static struct ctf_stream *ctf_stream__create(struct ctf_writer *cw, int cpu)
698 stream = bt_ctf_writer_create_stream(cw->writer, cw->stream_class);
747 static struct ctf_stream *ctf_stream(struct ctf_writer *cw, int cpu)
749 struct ctf_stream *cs = cw->stream[cpu];
752 cs = ctf_stream__create(cw, cpu);
753 cw->stream[cpu] = cs;
759 static int get_sample_cpu(struct ctf_writer *cw, struct perf_sample *sample,
767 if (cpu > cw->stream_cnt) {
769 cpu, cw->stream_cnt);
797 struct ctf_writer *cw = &c->writer;
821 bt_ctf_clock_set_time(cw->clock, sample->time);
823 ret = add_generic_values(cw, event, evsel, sample);
828 ret = add_tracepoint_values(cw, event_class, event,
847 cs = ctf_stream(cw, get_sample_cpu(cw, sample, evsel));
862 ret = value_set_##_type(cw, event, #_field, _event->_name._field);\
874 struct ctf_writer *cw = &c->writer; \
875 struct bt_ctf_event_class *event_class = cw->_name##_class;\
888 bt_ctf_clock_set_time(cw->clock, sample->time); \
890 cs = ctf_stream(cw, 0); \
1014 static int add_tracepoint_fields_types(struct ctf_writer *cw,
1027 type = get_tracepoint_field_type(cw, field);
1057 static int add_tracepoint_types(struct ctf_writer *cw,
1065 ret = add_tracepoint_fields_types(cw, common_fields, class);
1067 ret = add_tracepoint_fields_types(cw, fields, class);
1072 static int add_bpf_output_types(struct ctf_writer *cw,
1075 struct bt_ctf_field_type *len_type = cw->data.u32;
1076 struct bt_ctf_field_type *seq_base_type = cw->data.u32_hex;
1091 static int add_generic_types(struct ctf_writer *cw, struct evsel *evsel,
1119 ADD_FIELD(event_class, cw->data.u64_hex, "perf_ip");
1122 ADD_FIELD(event_class, cw->data.s32, "perf_tid");
1123 ADD_FIELD(event_class, cw->data.s32, "perf_pid");
1128 ADD_FIELD(event_class, cw->data.u64, "perf_id");
1131 ADD_FIELD(event_class, cw->data.u64, "perf_stream_id");
1134 ADD_FIELD(event_class, cw->data.u64, "perf_period");
1137 ADD_FIELD(event_class, cw->data.u64, "perf_weight");
1140 ADD_FIELD(event_class, cw->data.u64, "perf_data_src");
1143 ADD_FIELD(event_class, cw->data.u64, "perf_transaction");
1146 ADD_FIELD(event_class, cw->data.u32, "perf_callchain_size");
1149 cw->data.u64_hex, "perf_callchain_size"),
1157 static int add_event(struct ctf_writer *cw, struct evsel *evsel)
1170 ret = add_generic_types(cw, evsel, event_class);
1175 ret = add_tracepoint_types(cw, evsel, event_class);
1181 ret = add_bpf_output_types(cw, event_class);
1186 ret = bt_ctf_stream_class_add_event_class(cw->stream_class, event_class);
1206 static int setup_events(struct ctf_writer *cw, struct perf_session *session)
1213 ret = add_event(cw, evsel);
1223 if (bt_ctf_event_class_add_field(event_class, cw->data.t, #n)) {\
1230 static int add_##_name##_event(struct ctf_writer *cw) \
1241 ret = bt_ctf_stream_class_add_event_class(cw->stream_class, event_class);\
1247 cw->_name##_class = event_class; \
1290 static int setup_non_sample_events(struct ctf_writer *cw,
1295 ret = add_comm_event(cw);
1298 ret = add_exit_event(cw);
1301 ret = add_fork_event(cw);
1304 ret = add_mmap_event(cw);
1307 ret = add_mmap2_event(cw);
1330 static int setup_streams(struct ctf_writer *cw, struct perf_session *session)
1348 cw->stream = stream;
1349 cw->stream_cnt = ncpus;
1353 static void free_streams(struct ctf_writer *cw)
1357 for (cpu = 0; cpu < cw->stream_cnt; cpu++)
1358 ctf_stream__delete(cw->stream[cpu]);
1360 zfree(&cw->stream);
1363 static int ctf_writer__setup_env(struct ctf_writer *cw,
1367 struct bt_ctf_writer *writer = cw->writer;
1387 static int ctf_writer__setup_clock(struct ctf_writer *cw,
1391 struct bt_ctf_clock *clock = cw->clock;
1455 static void ctf_writer__cleanup_data(struct ctf_writer *cw)
1459 for (i = 0; i < ARRAY_SIZE(cw->data.array); i++)
1460 bt_ctf_field_type_put(cw->data.array[i]);
1463 static int ctf_writer__init_data(struct ctf_writer *cw)
1472 CREATE_INT_TYPE(cw->data.s64, 64, true, false);
1473 CREATE_INT_TYPE(cw->data.u64, 64, false, false);
1474 CREATE_INT_TYPE(cw->data.s32, 32, true, false);
1475 CREATE_INT_TYPE(cw->data.u32, 32, false, false);
1476 CREATE_INT_TYPE(cw->data.u32_hex, 32, false, true);
1477 CREATE_INT_TYPE(cw->data.u64_hex, 64, false, true);
1479 cw->data.string = bt_ctf_field_type_string_create();
1480 if (cw->data.string)
1484 ctf_writer__cleanup_data(cw);
1489 static void ctf_writer__cleanup(struct ctf_writer *cw)
1491 ctf_writer__cleanup_data(cw);
1493 bt_ctf_clock_put(cw->clock);
1494 free_streams(cw);
1495 bt_ctf_stream_class_put(cw->stream_class);
1496 bt_ctf_writer_put(cw->writer);
1499 memset(cw, 0, sizeof(*cw));
1502 static int ctf_writer__init(struct ctf_writer *cw, const char *path,
1516 cw->writer = writer;
1525 cw->clock = clock;
1527 if (ctf_writer__setup_clock(cw, session, tod)) {
1539 cw->stream_class = stream_class;
1547 if (ctf_writer__init_data(cw))
1555 ret = bt_ctf_field_type_structure_add_field(pkt_ctx_type, cw->data.u32, "cpu_id");
1569 ctf_writer__cleanup(cw);
1575 static int ctf_writer__flush_streams(struct ctf_writer *cw)
1579 for (cpu = 0; cpu < cw->stream_cnt && !ret; cpu++)
1580 ret = ctf_stream__flush(cw->stream[cpu]);
1620 struct ctf_writer *cw = &c.writer;
1642 if (ctf_writer__init(cw, path, session, opts->tod))
1651 if (ctf_writer__setup_env(cw, session))
1655 if (setup_events(cw, session))
1658 if (opts->all && setup_non_sample_events(cw, session))
1661 if (setup_streams(cw, session))
1666 err = ctf_writer__flush_streams(cw);
1686 ctf_writer__cleanup(cw);
1691 ctf_writer__cleanup(cw);