1 // SPDX-License-Identifier: GPL-2.0-only 2 /* 3 * CTF writing support via babeltrace. 4 * 5 * Copyright (C) 2014, Jiri Olsa <jolsa@redhat.com> 6 * Copyright (C) 2014, Sebastian Andrzej Siewior <bigeasy@linutronix.de> 7 */ 8 9 #include <errno.h> 10 #include <inttypes.h> 11 #include <linux/compiler.h> 12 #include <linux/kernel.h> 13 #include <linux/zalloc.h> 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> 21 #include <babeltrace/ctf/events.h> 22 #include <traceevent/event-parse.h> 23 #include "asm/bug.h" 24 #include "data-convert.h" 25 #include "session.h" 26 #include "debug.h" 27 #include "tool.h" 28 #include "evlist.h" 29 #include "evsel.h" 30 #include "machine.h" 31 #include "config.h" 32 #include <linux/ctype.h> 33 #include <linux/err.h> 34 #include <linux/time64.h> 35 #include "util.h" 36 #include "clockid.h" 37 38 #define pr_N(n, fmt, ...) \ 39 eprintf(n, debug_data_convert, fmt, ##__VA_ARGS__) 40 41 #define pr(fmt, ...) pr_N(1, pr_fmt(fmt), ##__VA_ARGS__) 42 #define pr2(fmt, ...) pr_N(2, pr_fmt(fmt), ##__VA_ARGS__) 43 44 #define pr_time2(t, fmt, ...) pr_time_N(2, debug_data_convert, t, pr_fmt(fmt), ##__VA_ARGS__) 45 46 struct evsel_priv { 47 struct bt_ctf_event_class *event_class; 48 }; 49 50 #define MAX_CPUS 4096 51 52 struct ctf_stream { 53 struct bt_ctf_stream *stream; 54 int cpu; 55 u32 count; 56 }; 57 58 struct ctf_writer { 59 /* writer primitives */ 60 struct bt_ctf_writer *writer; 61 struct ctf_stream **stream; 62 int stream_cnt; 63 struct bt_ctf_stream_class *stream_class; 64 struct bt_ctf_clock *clock; 65 66 /* data types */ 67 union { 68 struct { 69 struct bt_ctf_field_type *s64; 70 struct bt_ctf_field_type *u64; 71 struct bt_ctf_field_type *s32; 72 struct bt_ctf_field_type *u32; 73 struct bt_ctf_field_type *string; 74 struct bt_ctf_field_type *u32_hex; 75 struct bt_ctf_field_type *u64_hex; 76 }; 77 struct bt_ctf_field_type *array[6]; 78 } data; 79 struct bt_ctf_event_class *comm_class; 80 struct bt_ctf_event_class *exit_class; 81 struct bt_ctf_event_class *fork_class; 82 struct bt_ctf_event_class *mmap_class; 83 struct bt_ctf_event_class *mmap2_class; 84 }; 85 86 struct convert { 87 struct perf_tool tool; 88 struct ctf_writer writer; 89 90 u64 events_size; 91 u64 events_count; 92 u64 non_sample_count; 93 94 /* Ordered events configured queue size. */ 95 u64 queue_size; 96 }; 97 98 static int value_set(struct bt_ctf_field_type *type, 99 struct bt_ctf_event *event, 100 const char *name, u64 val) 101 { 102 struct bt_ctf_field *field; 103 bool sign = bt_ctf_field_type_integer_get_signed(type); 104 int ret; 105 106 field = bt_ctf_field_create(type); 107 if (!field) { 108 pr_err("failed to create a field %s\n", name); 109 return -1; 110 } 111 112 if (sign) { 113 ret = bt_ctf_field_signed_integer_set_value(field, val); 114 if (ret) { 115 pr_err("failed to set field value %s\n", name); 116 goto err; 117 } 118 } else { 119 ret = bt_ctf_field_unsigned_integer_set_value(field, val); 120 if (ret) { 121 pr_err("failed to set field value %s\n", name); 122 goto err; 123 } 124 } 125 126 ret = bt_ctf_event_set_payload(event, name, field); 127 if (ret) { 128 pr_err("failed to set payload %s\n", name); 129 goto err; 130 } 131 132 pr2(" SET [%s = %" PRIu64 "]\n", name, val); 133 134 err: 135 bt_ctf_field_put(field); 136 return ret; 137 } 138 139 #define __FUNC_VALUE_SET(_name, _val_type) \ 140 static __maybe_unused int value_set_##_name(struct ctf_writer *cw, \ 141 struct bt_ctf_event *event, \ 142 const char *name, \ 143 _val_type val) \ 144 { \ 145 struct bt_ctf_field_type *type = cw->data._name; \ 146 return value_set(type, event, name, (u64) val); \ 147 } 148 149 #define FUNC_VALUE_SET(_name) __FUNC_VALUE_SET(_name, _name) 150 151 FUNC_VALUE_SET(s32) 152 FUNC_VALUE_SET(u32) 153 FUNC_VALUE_SET(s64) 154 FUNC_VALUE_SET(u64) 155 __FUNC_VALUE_SET(u64_hex, u64) 156 157 static int string_set_value(struct bt_ctf_field *field, const char *string); 158 static __maybe_unused int 159 value_set_string(struct ctf_writer *cw, struct bt_ctf_event *event, 160 const char *name, const char *string) 161 { 162 struct bt_ctf_field_type *type = cw->data.string; 163 struct bt_ctf_field *field; 164 int ret = 0; 165 166 field = bt_ctf_field_create(type); 167 if (!field) { 168 pr_err("failed to create a field %s\n", name); 169 return -1; 170 } 171 172 ret = string_set_value(field, string); 173 if (ret) { 174 pr_err("failed to set value %s\n", name); 175 goto err_put_field; 176 } 177 178 ret = bt_ctf_event_set_payload(event, name, field); 179 if (ret) 180 pr_err("failed to set payload %s\n", name); 181 182 err_put_field: 183 bt_ctf_field_put(field); 184 return ret; 185 } 186 187 static struct bt_ctf_field_type* 188 get_tracepoint_field_type(struct ctf_writer *cw, struct tep_format_field *field) 189 { 190 unsigned long flags = field->flags; 191 192 if (flags & TEP_FIELD_IS_STRING) 193 return cw->data.string; 194 195 if (!(flags & TEP_FIELD_IS_SIGNED)) { 196 /* unsigned long are mostly pointers */ 197 if (flags & TEP_FIELD_IS_LONG || flags & TEP_FIELD_IS_POINTER) 198 return cw->data.u64_hex; 199 } 200 201 if (flags & TEP_FIELD_IS_SIGNED) { 202 if (field->size == 8) 203 return cw->data.s64; 204 else 205 return cw->data.s32; 206 } 207 208 if (field->size == 8) 209 return cw->data.u64; 210 else 211 return cw->data.u32; 212 } 213 214 static unsigned long long adjust_signedness(unsigned long long value_int, int size) 215 { 216 unsigned long long value_mask; 217 218 /* 219 * value_mask = (1 << (size * 8 - 1)) - 1. 220 * Directly set value_mask for code readers. 221 */ 222 switch (size) { 223 case 1: 224 value_mask = 0x7fULL; 225 break; 226 case 2: 227 value_mask = 0x7fffULL; 228 break; 229 case 4: 230 value_mask = 0x7fffffffULL; 231 break; 232 case 8: 233 /* 234 * For 64 bit value, return it self. There is no need 235 * to fill high bit. 236 */ 237 /* Fall through */ 238 default: 239 /* BUG! */ 240 return value_int; 241 } 242 243 /* If it is a positive value, don't adjust. */ 244 if ((value_int & (~0ULL - value_mask)) == 0) 245 return value_int; 246 247 /* Fill upper part of value_int with 1 to make it a negative long long. */ 248 return (value_int & value_mask) | ~value_mask; 249 } 250 251 static int string_set_value(struct bt_ctf_field *field, const char *string) 252 { 253 char *buffer = NULL; 254 size_t len = strlen(string), i, p; 255 int err; 256 257 for (i = p = 0; i < len; i++, p++) { 258 if (isprint(string[i])) { 259 if (!buffer) 260 continue; 261 buffer[p] = string[i]; 262 } else { 263 char numstr[5]; 264 265 snprintf(numstr, sizeof(numstr), "\\x%02x", 266 (unsigned int)(string[i]) & 0xff); 267 268 if (!buffer) { 269 buffer = zalloc(i + (len - i) * 4 + 2); 270 if (!buffer) { 271 pr_err("failed to set unprintable string '%s'\n", string); 272 return bt_ctf_field_string_set_value(field, "UNPRINTABLE-STRING"); 273 } 274 if (i > 0) 275 strncpy(buffer, string, i); 276 } 277 memcpy(buffer + p, numstr, 4); 278 p += 3; 279 } 280 } 281 282 if (!buffer) 283 return bt_ctf_field_string_set_value(field, string); 284 err = bt_ctf_field_string_set_value(field, buffer); 285 free(buffer); 286 return err; 287 } 288 289 static int add_tracepoint_field_value(struct ctf_writer *cw, 290 struct bt_ctf_event_class *event_class, 291 struct bt_ctf_event *event, 292 struct perf_sample *sample, 293 struct tep_format_field *fmtf) 294 { 295 struct bt_ctf_field_type *type; 296 struct bt_ctf_field *array_field; 297 struct bt_ctf_field *field; 298 const char *name = fmtf->name; 299 void *data = sample->raw_data; 300 unsigned long flags = fmtf->flags; 301 unsigned int n_items; 302 unsigned int i; 303 unsigned int offset; 304 unsigned int len; 305 int ret; 306 307 name = fmtf->alias; 308 offset = fmtf->offset; 309 len = fmtf->size; 310 if (flags & TEP_FIELD_IS_STRING) 311 flags &= ~TEP_FIELD_IS_ARRAY; 312 313 if (flags & TEP_FIELD_IS_DYNAMIC) { 314 unsigned long long tmp_val; 315 316 tmp_val = tep_read_number(fmtf->event->tep, 317 data + offset, len); 318 offset = tmp_val; 319 len = offset >> 16; 320 offset &= 0xffff; 321 } 322 323 if (flags & TEP_FIELD_IS_ARRAY) { 324 325 type = bt_ctf_event_class_get_field_by_name( 326 event_class, name); 327 array_field = bt_ctf_field_create(type); 328 bt_ctf_field_type_put(type); 329 if (!array_field) { 330 pr_err("Failed to create array type %s\n", name); 331 return -1; 332 } 333 334 len = fmtf->size / fmtf->arraylen; 335 n_items = fmtf->arraylen; 336 } else { 337 n_items = 1; 338 array_field = NULL; 339 } 340 341 type = get_tracepoint_field_type(cw, fmtf); 342 343 for (i = 0; i < n_items; i++) { 344 if (flags & TEP_FIELD_IS_ARRAY) 345 field = bt_ctf_field_array_get_field(array_field, i); 346 else 347 field = bt_ctf_field_create(type); 348 349 if (!field) { 350 pr_err("failed to create a field %s\n", name); 351 return -1; 352 } 353 354 if (flags & TEP_FIELD_IS_STRING) 355 ret = string_set_value(field, data + offset + i * len); 356 else { 357 unsigned long long value_int; 358 359 value_int = tep_read_number( 360 fmtf->event->tep, 361 data + offset + i * len, len); 362 363 if (!(flags & TEP_FIELD_IS_SIGNED)) 364 ret = bt_ctf_field_unsigned_integer_set_value( 365 field, value_int); 366 else 367 ret = bt_ctf_field_signed_integer_set_value( 368 field, adjust_signedness(value_int, len)); 369 } 370 371 if (ret) { 372 pr_err("failed to set file value %s\n", name); 373 goto err_put_field; 374 } 375 if (!(flags & TEP_FIELD_IS_ARRAY)) { 376 ret = bt_ctf_event_set_payload(event, name, field); 377 if (ret) { 378 pr_err("failed to set payload %s\n", name); 379 goto err_put_field; 380 } 381 } 382 bt_ctf_field_put(field); 383 } 384 if (flags & TEP_FIELD_IS_ARRAY) { 385 ret = bt_ctf_event_set_payload(event, name, array_field); 386 if (ret) { 387 pr_err("Failed add payload array %s\n", name); 388 return -1; 389 } 390 bt_ctf_field_put(array_field); 391 } 392 return 0; 393 394 err_put_field: 395 bt_ctf_field_put(field); 396 return -1; 397 } 398 399 static int add_tracepoint_fields_values(struct ctf_writer *cw, 400 struct bt_ctf_event_class *event_class, 401 struct bt_ctf_event *event, 402 struct tep_format_field *fields, 403 struct perf_sample *sample) 404 { 405 struct tep_format_field *field; 406 int ret; 407 408 for (field = fields; field; field = field->next) { 409 ret = add_tracepoint_field_value(cw, event_class, event, sample, 410 field); 411 if (ret) 412 return -1; 413 } 414 return 0; 415 } 416 417 static int add_tracepoint_values(struct ctf_writer *cw, 418 struct bt_ctf_event_class *event_class, 419 struct bt_ctf_event *event, 420 struct evsel *evsel, 421 struct perf_sample *sample) 422 { 423 struct tep_format_field *common_fields = evsel->tp_format->format.common_fields; 424 struct tep_format_field *fields = evsel->tp_format->format.fields; 425 int ret; 426 427 ret = add_tracepoint_fields_values(cw, event_class, event, 428 common_fields, sample); 429 if (!ret) 430 ret = add_tracepoint_fields_values(cw, event_class, event, 431 fields, sample); 432 433 return ret; 434 } 435 436 static int 437 add_bpf_output_values(struct bt_ctf_event_class *event_class, 438 struct bt_ctf_event *event, 439 struct perf_sample *sample) 440 { 441 struct bt_ctf_field_type *len_type, *seq_type; 442 struct bt_ctf_field *len_field, *seq_field; 443 unsigned int raw_size = sample->raw_size; 444 unsigned int nr_elements = raw_size / sizeof(u32); 445 unsigned int i; 446 int ret; 447 448 if (nr_elements * sizeof(u32) != raw_size) 449 pr_warning("Incorrect raw_size (%u) in bpf output event, skip %zu bytes\n", 450 raw_size, nr_elements * sizeof(u32) - raw_size); 451 452 len_type = bt_ctf_event_class_get_field_by_name(event_class, "raw_len"); 453 len_field = bt_ctf_field_create(len_type); 454 if (!len_field) { 455 pr_err("failed to create 'raw_len' for bpf output event\n"); 456 ret = -1; 457 goto put_len_type; 458 } 459 460 ret = bt_ctf_field_unsigned_integer_set_value(len_field, nr_elements); 461 if (ret) { 462 pr_err("failed to set field value for raw_len\n"); 463 goto put_len_field; 464 } 465 ret = bt_ctf_event_set_payload(event, "raw_len", len_field); 466 if (ret) { 467 pr_err("failed to set payload to raw_len\n"); 468 goto put_len_field; 469 } 470 471 seq_type = bt_ctf_event_class_get_field_by_name(event_class, "raw_data"); 472 seq_field = bt_ctf_field_create(seq_type); 473 if (!seq_field) { 474 pr_err("failed to create 'raw_data' for bpf output event\n"); 475 ret = -1; 476 goto put_seq_type; 477 } 478 479 ret = bt_ctf_field_sequence_set_length(seq_field, len_field); 480 if (ret) { 481 pr_err("failed to set length of 'raw_data'\n"); 482 goto put_seq_field; 483 } 484 485 for (i = 0; i < nr_elements; i++) { 486 struct bt_ctf_field *elem_field = 487 bt_ctf_field_sequence_get_field(seq_field, i); 488 489 ret = bt_ctf_field_unsigned_integer_set_value(elem_field, 490 ((u32 *)(sample->raw_data))[i]); 491 492 bt_ctf_field_put(elem_field); 493 if (ret) { 494 pr_err("failed to set raw_data[%d]\n", i); 495 goto put_seq_field; 496 } 497 } 498 499 ret = bt_ctf_event_set_payload(event, "raw_data", seq_field); 500 if (ret) 501 pr_err("failed to set payload for raw_data\n"); 502 503 put_seq_field: 504 bt_ctf_field_put(seq_field); 505 put_seq_type: 506 bt_ctf_field_type_put(seq_type); 507 put_len_field: 508 bt_ctf_field_put(len_field); 509 put_len_type: 510 bt_ctf_field_type_put(len_type); 511 return ret; 512 } 513 514 static int 515 add_callchain_output_values(struct bt_ctf_event_class *event_class, 516 struct bt_ctf_event *event, 517 struct ip_callchain *callchain) 518 { 519 struct bt_ctf_field_type *len_type, *seq_type; 520 struct bt_ctf_field *len_field, *seq_field; 521 unsigned int nr_elements = callchain->nr; 522 unsigned int i; 523 int ret; 524 525 len_type = bt_ctf_event_class_get_field_by_name( 526 event_class, "perf_callchain_size"); 527 len_field = bt_ctf_field_create(len_type); 528 if (!len_field) { 529 pr_err("failed to create 'perf_callchain_size' for callchain output event\n"); 530 ret = -1; 531 goto put_len_type; 532 } 533 534 ret = bt_ctf_field_unsigned_integer_set_value(len_field, nr_elements); 535 if (ret) { 536 pr_err("failed to set field value for perf_callchain_size\n"); 537 goto put_len_field; 538 } 539 ret = bt_ctf_event_set_payload(event, "perf_callchain_size", len_field); 540 if (ret) { 541 pr_err("failed to set payload to perf_callchain_size\n"); 542 goto put_len_field; 543 } 544 545 seq_type = bt_ctf_event_class_get_field_by_name( 546 event_class, "perf_callchain"); 547 seq_field = bt_ctf_field_create(seq_type); 548 if (!seq_field) { 549 pr_err("failed to create 'perf_callchain' for callchain output event\n"); 550 ret = -1; 551 goto put_seq_type; 552 } 553 554 ret = bt_ctf_field_sequence_set_length(seq_field, len_field); 555 if (ret) { 556 pr_err("failed to set length of 'perf_callchain'\n"); 557 goto put_seq_field; 558 } 559 560 for (i = 0; i < nr_elements; i++) { 561 struct bt_ctf_field *elem_field = 562 bt_ctf_field_sequence_get_field(seq_field, i); 563 564 ret = bt_ctf_field_unsigned_integer_set_value(elem_field, 565 ((u64 *)(callchain->ips))[i]); 566 567 bt_ctf_field_put(elem_field); 568 if (ret) { 569 pr_err("failed to set callchain[%d]\n", i); 570 goto put_seq_field; 571 } 572 } 573 574 ret = bt_ctf_event_set_payload(event, "perf_callchain", seq_field); 575 if (ret) 576 pr_err("failed to set payload for raw_data\n"); 577 578 put_seq_field: 579 bt_ctf_field_put(seq_field); 580 put_seq_type: 581 bt_ctf_field_type_put(seq_type); 582 put_len_field: 583 bt_ctf_field_put(len_field); 584 put_len_type: 585 bt_ctf_field_type_put(len_type); 586 return ret; 587 } 588 589 static int add_generic_values(struct ctf_writer *cw, 590 struct bt_ctf_event *event, 591 struct evsel *evsel, 592 struct perf_sample *sample) 593 { 594 u64 type = evsel->core.attr.sample_type; 595 int ret; 596 597 /* 598 * missing: 599 * PERF_SAMPLE_TIME - not needed as we have it in 600 * ctf event header 601 * PERF_SAMPLE_READ - TODO 602 * PERF_SAMPLE_RAW - tracepoint fields are handled separately 603 * PERF_SAMPLE_BRANCH_STACK - TODO 604 * PERF_SAMPLE_REGS_USER - TODO 605 * PERF_SAMPLE_STACK_USER - TODO 606 */ 607 608 if (type & PERF_SAMPLE_IP) { 609 ret = value_set_u64_hex(cw, event, "perf_ip", sample->ip); 610 if (ret) 611 return -1; 612 } 613 614 if (type & PERF_SAMPLE_TID) { 615 ret = value_set_s32(cw, event, "perf_tid", sample->tid); 616 if (ret) 617 return -1; 618 619 ret = value_set_s32(cw, event, "perf_pid", sample->pid); 620 if (ret) 621 return -1; 622 } 623 624 if ((type & PERF_SAMPLE_ID) || 625 (type & PERF_SAMPLE_IDENTIFIER)) { 626 ret = value_set_u64(cw, event, "perf_id", sample->id); 627 if (ret) 628 return -1; 629 } 630 631 if (type & PERF_SAMPLE_STREAM_ID) { 632 ret = value_set_u64(cw, event, "perf_stream_id", sample->stream_id); 633 if (ret) 634 return -1; 635 } 636 637 if (type & PERF_SAMPLE_PERIOD) { 638 ret = value_set_u64(cw, event, "perf_period", sample->period); 639 if (ret) 640 return -1; 641 } 642 643 if (type & PERF_SAMPLE_WEIGHT) { 644 ret = value_set_u64(cw, event, "perf_weight", sample->weight); 645 if (ret) 646 return -1; 647 } 648 649 if (type & PERF_SAMPLE_DATA_SRC) { 650 ret = value_set_u64(cw, event, "perf_data_src", 651 sample->data_src); 652 if (ret) 653 return -1; 654 } 655 656 if (type & PERF_SAMPLE_TRANSACTION) { 657 ret = value_set_u64(cw, event, "perf_transaction", 658 sample->transaction); 659 if (ret) 660 return -1; 661 } 662 663 return 0; 664 } 665 666 static int ctf_stream__flush(struct ctf_stream *cs) 667 { 668 int err = 0; 669 670 if (cs) { 671 err = bt_ctf_stream_flush(cs->stream); 672 if (err) 673 pr_err("CTF stream %d flush failed\n", cs->cpu); 674 675 pr("Flush stream for cpu %d (%u samples)\n", 676 cs->cpu, cs->count); 677 678 cs->count = 0; 679 } 680 681 return err; 682 } 683 684 static struct ctf_stream *ctf_stream__create(struct ctf_writer *cw, int cpu) 685 { 686 struct ctf_stream *cs; 687 struct bt_ctf_field *pkt_ctx = NULL; 688 struct bt_ctf_field *cpu_field = NULL; 689 struct bt_ctf_stream *stream = NULL; 690 int ret; 691 692 cs = zalloc(sizeof(*cs)); 693 if (!cs) { 694 pr_err("Failed to allocate ctf stream\n"); 695 return NULL; 696 } 697 698 stream = bt_ctf_writer_create_stream(cw->writer, cw->stream_class); 699 if (!stream) { 700 pr_err("Failed to create CTF stream\n"); 701 goto out; 702 } 703 704 pkt_ctx = bt_ctf_stream_get_packet_context(stream); 705 if (!pkt_ctx) { 706 pr_err("Failed to obtain packet context\n"); 707 goto out; 708 } 709 710 cpu_field = bt_ctf_field_structure_get_field(pkt_ctx, "cpu_id"); 711 bt_ctf_field_put(pkt_ctx); 712 if (!cpu_field) { 713 pr_err("Failed to obtain cpu field\n"); 714 goto out; 715 } 716 717 ret = bt_ctf_field_unsigned_integer_set_value(cpu_field, (u32) cpu); 718 if (ret) { 719 pr_err("Failed to update CPU number\n"); 720 goto out; 721 } 722 723 bt_ctf_field_put(cpu_field); 724 725 cs->cpu = cpu; 726 cs->stream = stream; 727 return cs; 728 729 out: 730 if (cpu_field) 731 bt_ctf_field_put(cpu_field); 732 if (stream) 733 bt_ctf_stream_put(stream); 734 735 free(cs); 736 return NULL; 737 } 738 739 static void ctf_stream__delete(struct ctf_stream *cs) 740 { 741 if (cs) { 742 bt_ctf_stream_put(cs->stream); 743 free(cs); 744 } 745 } 746 747 static struct ctf_stream *ctf_stream(struct ctf_writer *cw, int cpu) 748 { 749 struct ctf_stream *cs = cw->stream[cpu]; 750 751 if (!cs) { 752 cs = ctf_stream__create(cw, cpu); 753 cw->stream[cpu] = cs; 754 } 755 756 return cs; 757 } 758 759 static int get_sample_cpu(struct ctf_writer *cw, struct perf_sample *sample, 760 struct evsel *evsel) 761 { 762 int cpu = 0; 763 764 if (evsel->core.attr.sample_type & PERF_SAMPLE_CPU) 765 cpu = sample->cpu; 766 767 if (cpu > cw->stream_cnt) { 768 pr_err("Event was recorded for CPU %d, limit is at %d.\n", 769 cpu, cw->stream_cnt); 770 cpu = 0; 771 } 772 773 return cpu; 774 } 775 776 #define STREAM_FLUSH_COUNT 100000 777 778 /* 779 * Currently we have no other way to determine the 780 * time for the stream flush other than keep track 781 * of the number of events and check it against 782 * threshold. 783 */ 784 static bool is_flush_needed(struct ctf_stream *cs) 785 { 786 return cs->count >= STREAM_FLUSH_COUNT; 787 } 788 789 static int process_sample_event(struct perf_tool *tool, 790 union perf_event *_event, 791 struct perf_sample *sample, 792 struct evsel *evsel, 793 struct machine *machine __maybe_unused) 794 { 795 struct convert *c = container_of(tool, struct convert, tool); 796 struct evsel_priv *priv = evsel->priv; 797 struct ctf_writer *cw = &c->writer; 798 struct ctf_stream *cs; 799 struct bt_ctf_event_class *event_class; 800 struct bt_ctf_event *event; 801 int ret; 802 unsigned long type = evsel->core.attr.sample_type; 803 804 if (WARN_ONCE(!priv, "Failed to setup all events.\n")) 805 return 0; 806 807 event_class = priv->event_class; 808 809 /* update stats */ 810 c->events_count++; 811 c->events_size += _event->header.size; 812 813 pr_time2(sample->time, "sample %" PRIu64 "\n", c->events_count); 814 815 event = bt_ctf_event_create(event_class); 816 if (!event) { 817 pr_err("Failed to create an CTF event\n"); 818 return -1; 819 } 820 821 bt_ctf_clock_set_time(cw->clock, sample->time); 822 823 ret = add_generic_values(cw, event, evsel, sample); 824 if (ret) 825 return -1; 826 827 if (evsel->core.attr.type == PERF_TYPE_TRACEPOINT) { 828 ret = add_tracepoint_values(cw, event_class, event, 829 evsel, sample); 830 if (ret) 831 return -1; 832 } 833 834 if (type & PERF_SAMPLE_CALLCHAIN) { 835 ret = add_callchain_output_values(event_class, 836 event, sample->callchain); 837 if (ret) 838 return -1; 839 } 840 841 if (evsel__is_bpf_output(evsel)) { 842 ret = add_bpf_output_values(event_class, event, sample); 843 if (ret) 844 return -1; 845 } 846 847 cs = ctf_stream(cw, get_sample_cpu(cw, sample, evsel)); 848 if (cs) { 849 if (is_flush_needed(cs)) 850 ctf_stream__flush(cs); 851 852 cs->count++; 853 bt_ctf_stream_append_event(cs->stream, event); 854 } 855 856 bt_ctf_event_put(event); 857 return cs ? 0 : -1; 858 } 859 860 #define __NON_SAMPLE_SET_FIELD(_name, _type, _field) \ 861 do { \ 862 ret = value_set_##_type(cw, event, #_field, _event->_name._field);\ 863 if (ret) \ 864 return -1; \ 865 } while(0) 866 867 #define __FUNC_PROCESS_NON_SAMPLE(_name, body) \ 868 static int process_##_name##_event(struct perf_tool *tool, \ 869 union perf_event *_event, \ 870 struct perf_sample *sample, \ 871 struct machine *machine) \ 872 { \ 873 struct convert *c = container_of(tool, struct convert, tool);\ 874 struct ctf_writer *cw = &c->writer; \ 875 struct bt_ctf_event_class *event_class = cw->_name##_class;\ 876 struct bt_ctf_event *event; \ 877 struct ctf_stream *cs; \ 878 int ret; \ 879 \ 880 c->non_sample_count++; \ 881 c->events_size += _event->header.size; \ 882 event = bt_ctf_event_create(event_class); \ 883 if (!event) { \ 884 pr_err("Failed to create an CTF event\n"); \ 885 return -1; \ 886 } \ 887 \ 888 bt_ctf_clock_set_time(cw->clock, sample->time); \ 889 body \ 890 cs = ctf_stream(cw, 0); \ 891 if (cs) { \ 892 if (is_flush_needed(cs)) \ 893 ctf_stream__flush(cs); \ 894 \ 895 cs->count++; \ 896 bt_ctf_stream_append_event(cs->stream, event); \ 897 } \ 898 bt_ctf_event_put(event); \ 899 \ 900 return perf_event__process_##_name(tool, _event, sample, machine);\ 901 } 902 903 __FUNC_PROCESS_NON_SAMPLE(comm, 904 __NON_SAMPLE_SET_FIELD(comm, u32, pid); 905 __NON_SAMPLE_SET_FIELD(comm, u32, tid); 906 __NON_SAMPLE_SET_FIELD(comm, string, comm); 907 ) 908 __FUNC_PROCESS_NON_SAMPLE(fork, 909 __NON_SAMPLE_SET_FIELD(fork, u32, pid); 910 __NON_SAMPLE_SET_FIELD(fork, u32, ppid); 911 __NON_SAMPLE_SET_FIELD(fork, u32, tid); 912 __NON_SAMPLE_SET_FIELD(fork, u32, ptid); 913 __NON_SAMPLE_SET_FIELD(fork, u64, time); 914 ) 915 916 __FUNC_PROCESS_NON_SAMPLE(exit, 917 __NON_SAMPLE_SET_FIELD(fork, u32, pid); 918 __NON_SAMPLE_SET_FIELD(fork, u32, ppid); 919 __NON_SAMPLE_SET_FIELD(fork, u32, tid); 920 __NON_SAMPLE_SET_FIELD(fork, u32, ptid); 921 __NON_SAMPLE_SET_FIELD(fork, u64, time); 922 ) 923 __FUNC_PROCESS_NON_SAMPLE(mmap, 924 __NON_SAMPLE_SET_FIELD(mmap, u32, pid); 925 __NON_SAMPLE_SET_FIELD(mmap, u32, tid); 926 __NON_SAMPLE_SET_FIELD(mmap, u64_hex, start); 927 __NON_SAMPLE_SET_FIELD(mmap, string, filename); 928 ) 929 __FUNC_PROCESS_NON_SAMPLE(mmap2, 930 __NON_SAMPLE_SET_FIELD(mmap2, u32, pid); 931 __NON_SAMPLE_SET_FIELD(mmap2, u32, tid); 932 __NON_SAMPLE_SET_FIELD(mmap2, u64_hex, start); 933 __NON_SAMPLE_SET_FIELD(mmap2, string, filename); 934 ) 935 #undef __NON_SAMPLE_SET_FIELD 936 #undef __FUNC_PROCESS_NON_SAMPLE 937 938 /* If dup < 0, add a prefix. Else, add _dupl_X suffix. */ 939 static char *change_name(char *name, char *orig_name, int dup) 940 { 941 char *new_name = NULL; 942 size_t len; 943 944 if (!name) 945 name = orig_name; 946 947 if (dup >= 10) 948 goto out; 949 /* 950 * Add '_' prefix to potential keywork. According to 951 * Mathieu Desnoyers (https://lore.kernel.org/lkml/1074266107.40857.1422045946295.JavaMail.zimbra@efficios.com), 952 * further CTF spec updating may require us to use '$'. 953 */ 954 if (dup < 0) 955 len = strlen(name) + sizeof("_"); 956 else 957 len = strlen(orig_name) + sizeof("_dupl_X"); 958 959 new_name = malloc(len); 960 if (!new_name) 961 goto out; 962 963 if (dup < 0) 964 snprintf(new_name, len, "_%s", name); 965 else 966 snprintf(new_name, len, "%s_dupl_%d", orig_name, dup); 967 968 out: 969 if (name != orig_name) 970 free(name); 971 return new_name; 972 } 973 974 static int event_class_add_field(struct bt_ctf_event_class *event_class, 975 struct bt_ctf_field_type *type, 976 struct tep_format_field *field) 977 { 978 struct bt_ctf_field_type *t = NULL; 979 char *name; 980 int dup = 1; 981 int ret; 982 983 /* alias was already assigned */ 984 if (field->alias != field->name) 985 return bt_ctf_event_class_add_field(event_class, type, 986 (char *)field->alias); 987 988 name = field->name; 989 990 /* If 'name' is a keywork, add prefix. */ 991 if (bt_ctf_validate_identifier(name)) 992 name = change_name(name, field->name, -1); 993 994 if (!name) { 995 pr_err("Failed to fix invalid identifier."); 996 return -1; 997 } 998 while ((t = bt_ctf_event_class_get_field_by_name(event_class, name))) { 999 bt_ctf_field_type_put(t); 1000 name = change_name(name, field->name, dup++); 1001 if (!name) { 1002 pr_err("Failed to create dup name for '%s'\n", field->name); 1003 return -1; 1004 } 1005 } 1006 1007 ret = bt_ctf_event_class_add_field(event_class, type, name); 1008 if (!ret) 1009 field->alias = name; 1010 1011 return ret; 1012 } 1013 1014 static int add_tracepoint_fields_types(struct ctf_writer *cw, 1015 struct tep_format_field *fields, 1016 struct bt_ctf_event_class *event_class) 1017 { 1018 struct tep_format_field *field; 1019 int ret; 1020 1021 for (field = fields; field; field = field->next) { 1022 struct bt_ctf_field_type *type; 1023 unsigned long flags = field->flags; 1024 1025 pr2(" field '%s'\n", field->name); 1026 1027 type = get_tracepoint_field_type(cw, field); 1028 if (!type) 1029 return -1; 1030 1031 /* 1032 * A string is an array of chars. For this we use the string 1033 * type and don't care that it is an array. What we don't 1034 * support is an array of strings. 1035 */ 1036 if (flags & TEP_FIELD_IS_STRING) 1037 flags &= ~TEP_FIELD_IS_ARRAY; 1038 1039 if (flags & TEP_FIELD_IS_ARRAY) 1040 type = bt_ctf_field_type_array_create(type, field->arraylen); 1041 1042 ret = event_class_add_field(event_class, type, field); 1043 1044 if (flags & TEP_FIELD_IS_ARRAY) 1045 bt_ctf_field_type_put(type); 1046 1047 if (ret) { 1048 pr_err("Failed to add field '%s': %d\n", 1049 field->name, ret); 1050 return -1; 1051 } 1052 } 1053 1054 return 0; 1055 } 1056 1057 static int add_tracepoint_types(struct ctf_writer *cw, 1058 struct evsel *evsel, 1059 struct bt_ctf_event_class *class) 1060 { 1061 struct tep_format_field *common_fields = evsel->tp_format->format.common_fields; 1062 struct tep_format_field *fields = evsel->tp_format->format.fields; 1063 int ret; 1064 1065 ret = add_tracepoint_fields_types(cw, common_fields, class); 1066 if (!ret) 1067 ret = add_tracepoint_fields_types(cw, fields, class); 1068 1069 return ret; 1070 } 1071 1072 static int add_bpf_output_types(struct ctf_writer *cw, 1073 struct bt_ctf_event_class *class) 1074 { 1075 struct bt_ctf_field_type *len_type = cw->data.u32; 1076 struct bt_ctf_field_type *seq_base_type = cw->data.u32_hex; 1077 struct bt_ctf_field_type *seq_type; 1078 int ret; 1079 1080 ret = bt_ctf_event_class_add_field(class, len_type, "raw_len"); 1081 if (ret) 1082 return ret; 1083 1084 seq_type = bt_ctf_field_type_sequence_create(seq_base_type, "raw_len"); 1085 if (!seq_type) 1086 return -1; 1087 1088 return bt_ctf_event_class_add_field(class, seq_type, "raw_data"); 1089 } 1090 1091 static int add_generic_types(struct ctf_writer *cw, struct evsel *evsel, 1092 struct bt_ctf_event_class *event_class) 1093 { 1094 u64 type = evsel->core.attr.sample_type; 1095 1096 /* 1097 * missing: 1098 * PERF_SAMPLE_TIME - not needed as we have it in 1099 * ctf event header 1100 * PERF_SAMPLE_READ - TODO 1101 * PERF_SAMPLE_CALLCHAIN - TODO 1102 * PERF_SAMPLE_RAW - tracepoint fields and BPF output 1103 * are handled separately 1104 * PERF_SAMPLE_BRANCH_STACK - TODO 1105 * PERF_SAMPLE_REGS_USER - TODO 1106 * PERF_SAMPLE_STACK_USER - TODO 1107 */ 1108 1109 #define ADD_FIELD(cl, t, n) \ 1110 do { \ 1111 pr2(" field '%s'\n", n); \ 1112 if (bt_ctf_event_class_add_field(cl, t, n)) { \ 1113 pr_err("Failed to add field '%s';\n", n); \ 1114 return -1; \ 1115 } \ 1116 } while (0) 1117 1118 if (type & PERF_SAMPLE_IP) 1119 ADD_FIELD(event_class, cw->data.u64_hex, "perf_ip"); 1120 1121 if (type & PERF_SAMPLE_TID) { 1122 ADD_FIELD(event_class, cw->data.s32, "perf_tid"); 1123 ADD_FIELD(event_class, cw->data.s32, "perf_pid"); 1124 } 1125 1126 if ((type & PERF_SAMPLE_ID) || 1127 (type & PERF_SAMPLE_IDENTIFIER)) 1128 ADD_FIELD(event_class, cw->data.u64, "perf_id"); 1129 1130 if (type & PERF_SAMPLE_STREAM_ID) 1131 ADD_FIELD(event_class, cw->data.u64, "perf_stream_id"); 1132 1133 if (type & PERF_SAMPLE_PERIOD) 1134 ADD_FIELD(event_class, cw->data.u64, "perf_period"); 1135 1136 if (type & PERF_SAMPLE_WEIGHT) 1137 ADD_FIELD(event_class, cw->data.u64, "perf_weight"); 1138 1139 if (type & PERF_SAMPLE_DATA_SRC) 1140 ADD_FIELD(event_class, cw->data.u64, "perf_data_src"); 1141 1142 if (type & PERF_SAMPLE_TRANSACTION) 1143 ADD_FIELD(event_class, cw->data.u64, "perf_transaction"); 1144 1145 if (type & PERF_SAMPLE_CALLCHAIN) { 1146 ADD_FIELD(event_class, cw->data.u32, "perf_callchain_size"); 1147 ADD_FIELD(event_class, 1148 bt_ctf_field_type_sequence_create( 1149 cw->data.u64_hex, "perf_callchain_size"), 1150 "perf_callchain"); 1151 } 1152 1153 #undef ADD_FIELD 1154 return 0; 1155 } 1156 1157 static int add_event(struct ctf_writer *cw, struct evsel *evsel) 1158 { 1159 struct bt_ctf_event_class *event_class; 1160 struct evsel_priv *priv; 1161 const char *name = evsel__name(evsel); 1162 int ret; 1163 1164 pr("Adding event '%s' (type %d)\n", name, evsel->core.attr.type); 1165 1166 event_class = bt_ctf_event_class_create(name); 1167 if (!event_class) 1168 return -1; 1169 1170 ret = add_generic_types(cw, evsel, event_class); 1171 if (ret) 1172 goto err; 1173 1174 if (evsel->core.attr.type == PERF_TYPE_TRACEPOINT) { 1175 ret = add_tracepoint_types(cw, evsel, event_class); 1176 if (ret) 1177 goto err; 1178 } 1179 1180 if (evsel__is_bpf_output(evsel)) { 1181 ret = add_bpf_output_types(cw, event_class); 1182 if (ret) 1183 goto err; 1184 } 1185 1186 ret = bt_ctf_stream_class_add_event_class(cw->stream_class, event_class); 1187 if (ret) { 1188 pr("Failed to add event class into stream.\n"); 1189 goto err; 1190 } 1191 1192 priv = malloc(sizeof(*priv)); 1193 if (!priv) 1194 goto err; 1195 1196 priv->event_class = event_class; 1197 evsel->priv = priv; 1198 return 0; 1199 1200 err: 1201 bt_ctf_event_class_put(event_class); 1202 pr_err("Failed to add event '%s'.\n", name); 1203 return -1; 1204 } 1205 1206 static int setup_events(struct ctf_writer *cw, struct perf_session *session) 1207 { 1208 struct evlist *evlist = session->evlist; 1209 struct evsel *evsel; 1210 int ret; 1211 1212 evlist__for_each_entry(evlist, evsel) { 1213 ret = add_event(cw, evsel); 1214 if (ret) 1215 return ret; 1216 } 1217 return 0; 1218 } 1219 1220 #define __NON_SAMPLE_ADD_FIELD(t, n) \ 1221 do { \ 1222 pr2(" field '%s'\n", #n); \ 1223 if (bt_ctf_event_class_add_field(event_class, cw->data.t, #n)) {\ 1224 pr_err("Failed to add field '%s';\n", #n);\ 1225 return -1; \ 1226 } \ 1227 } while(0) 1228 1229 #define __FUNC_ADD_NON_SAMPLE_EVENT_CLASS(_name, body) \ 1230 static int add_##_name##_event(struct ctf_writer *cw) \ 1231 { \ 1232 struct bt_ctf_event_class *event_class; \ 1233 int ret; \ 1234 \ 1235 pr("Adding "#_name" event\n"); \ 1236 event_class = bt_ctf_event_class_create("perf_" #_name);\ 1237 if (!event_class) \ 1238 return -1; \ 1239 body \ 1240 \ 1241 ret = bt_ctf_stream_class_add_event_class(cw->stream_class, event_class);\ 1242 if (ret) { \ 1243 pr("Failed to add event class '"#_name"' into stream.\n");\ 1244 return ret; \ 1245 } \ 1246 \ 1247 cw->_name##_class = event_class; \ 1248 bt_ctf_event_class_put(event_class); \ 1249 return 0; \ 1250 } 1251 1252 __FUNC_ADD_NON_SAMPLE_EVENT_CLASS(comm, 1253 __NON_SAMPLE_ADD_FIELD(u32, pid); 1254 __NON_SAMPLE_ADD_FIELD(u32, tid); 1255 __NON_SAMPLE_ADD_FIELD(string, comm); 1256 ) 1257 1258 __FUNC_ADD_NON_SAMPLE_EVENT_CLASS(fork, 1259 __NON_SAMPLE_ADD_FIELD(u32, pid); 1260 __NON_SAMPLE_ADD_FIELD(u32, ppid); 1261 __NON_SAMPLE_ADD_FIELD(u32, tid); 1262 __NON_SAMPLE_ADD_FIELD(u32, ptid); 1263 __NON_SAMPLE_ADD_FIELD(u64, time); 1264 ) 1265 1266 __FUNC_ADD_NON_SAMPLE_EVENT_CLASS(exit, 1267 __NON_SAMPLE_ADD_FIELD(u32, pid); 1268 __NON_SAMPLE_ADD_FIELD(u32, ppid); 1269 __NON_SAMPLE_ADD_FIELD(u32, tid); 1270 __NON_SAMPLE_ADD_FIELD(u32, ptid); 1271 __NON_SAMPLE_ADD_FIELD(u64, time); 1272 ) 1273 1274 __FUNC_ADD_NON_SAMPLE_EVENT_CLASS(mmap, 1275 __NON_SAMPLE_ADD_FIELD(u32, pid); 1276 __NON_SAMPLE_ADD_FIELD(u32, tid); 1277 __NON_SAMPLE_ADD_FIELD(u64_hex, start); 1278 __NON_SAMPLE_ADD_FIELD(string, filename); 1279 ) 1280 1281 __FUNC_ADD_NON_SAMPLE_EVENT_CLASS(mmap2, 1282 __NON_SAMPLE_ADD_FIELD(u32, pid); 1283 __NON_SAMPLE_ADD_FIELD(u32, tid); 1284 __NON_SAMPLE_ADD_FIELD(u64_hex, start); 1285 __NON_SAMPLE_ADD_FIELD(string, filename); 1286 ) 1287 #undef __NON_SAMPLE_ADD_FIELD 1288 #undef __FUNC_ADD_NON_SAMPLE_EVENT_CLASS 1289 1290 static int setup_non_sample_events(struct ctf_writer *cw, 1291 struct perf_session *session __maybe_unused) 1292 { 1293 int ret; 1294 1295 ret = add_comm_event(cw); 1296 if (ret) 1297 return ret; 1298 ret = add_exit_event(cw); 1299 if (ret) 1300 return ret; 1301 ret = add_fork_event(cw); 1302 if (ret) 1303 return ret; 1304 ret = add_mmap_event(cw); 1305 if (ret) 1306 return ret; 1307 ret = add_mmap2_event(cw); 1308 if (ret) 1309 return ret; 1310 return 0; 1311 } 1312 1313 static void cleanup_events(struct perf_session *session) 1314 { 1315 struct evlist *evlist = session->evlist; 1316 struct evsel *evsel; 1317 1318 evlist__for_each_entry(evlist, evsel) { 1319 struct evsel_priv *priv; 1320 1321 priv = evsel->priv; 1322 bt_ctf_event_class_put(priv->event_class); 1323 zfree(&evsel->priv); 1324 } 1325 1326 evlist__delete(evlist); 1327 session->evlist = NULL; 1328 } 1329 1330 static int setup_streams(struct ctf_writer *cw, struct perf_session *session) 1331 { 1332 struct ctf_stream **stream; 1333 struct perf_header *ph = &session->header; 1334 int ncpus; 1335 1336 /* 1337 * Try to get the number of cpus used in the data file, 1338 * if not present fallback to the MAX_CPUS. 1339 */ 1340 ncpus = ph->env.nr_cpus_avail ?: MAX_CPUS; 1341 1342 stream = zalloc(sizeof(*stream) * ncpus); 1343 if (!stream) { 1344 pr_err("Failed to allocate streams.\n"); 1345 return -ENOMEM; 1346 } 1347 1348 cw->stream = stream; 1349 cw->stream_cnt = ncpus; 1350 return 0; 1351 } 1352 1353 static void free_streams(struct ctf_writer *cw) 1354 { 1355 int cpu; 1356 1357 for (cpu = 0; cpu < cw->stream_cnt; cpu++) 1358 ctf_stream__delete(cw->stream[cpu]); 1359 1360 zfree(&cw->stream); 1361 } 1362 1363 static int ctf_writer__setup_env(struct ctf_writer *cw, 1364 struct perf_session *session) 1365 { 1366 struct perf_header *header = &session->header; 1367 struct bt_ctf_writer *writer = cw->writer; 1368 1369 #define ADD(__n, __v) \ 1370 do { \ 1371 if (bt_ctf_writer_add_environment_field(writer, __n, __v)) \ 1372 return -1; \ 1373 } while (0) 1374 1375 ADD("host", header->env.hostname); 1376 ADD("sysname", "Linux"); 1377 ADD("release", header->env.os_release); 1378 ADD("version", header->env.version); 1379 ADD("machine", header->env.arch); 1380 ADD("domain", "kernel"); 1381 ADD("tracer_name", "perf"); 1382 1383 #undef ADD 1384 return 0; 1385 } 1386 1387 static int ctf_writer__setup_clock(struct ctf_writer *cw, 1388 struct perf_session *session, 1389 bool tod) 1390 { 1391 struct bt_ctf_clock *clock = cw->clock; 1392 const char *desc = "perf clock"; 1393 int64_t offset = 0; 1394 1395 if (tod) { 1396 struct perf_env *env = &session->header.env; 1397 1398 if (!env->clock.enabled) { 1399 pr_err("Can't provide --tod time, missing clock data. " 1400 "Please record with -k/--clockid option.\n"); 1401 return -1; 1402 } 1403 1404 desc = clockid_name(env->clock.clockid); 1405 offset = env->clock.tod_ns - env->clock.clockid_ns; 1406 } 1407 1408 #define SET(__n, __v) \ 1409 do { \ 1410 if (bt_ctf_clock_set_##__n(clock, __v)) \ 1411 return -1; \ 1412 } while (0) 1413 1414 SET(frequency, 1000000000); 1415 SET(offset, offset); 1416 SET(description, desc); 1417 SET(precision, 10); 1418 SET(is_absolute, 0); 1419 1420 #undef SET 1421 return 0; 1422 } 1423 1424 static struct bt_ctf_field_type *create_int_type(int size, bool sign, bool hex) 1425 { 1426 struct bt_ctf_field_type *type; 1427 1428 type = bt_ctf_field_type_integer_create(size); 1429 if (!type) 1430 return NULL; 1431 1432 if (sign && 1433 bt_ctf_field_type_integer_set_signed(type, 1)) 1434 goto err; 1435 1436 if (hex && 1437 bt_ctf_field_type_integer_set_base(type, BT_CTF_INTEGER_BASE_HEXADECIMAL)) 1438 goto err; 1439 1440 #if __BYTE_ORDER == __BIG_ENDIAN 1441 bt_ctf_field_type_set_byte_order(type, BT_CTF_BYTE_ORDER_BIG_ENDIAN); 1442 #else 1443 bt_ctf_field_type_set_byte_order(type, BT_CTF_BYTE_ORDER_LITTLE_ENDIAN); 1444 #endif 1445 1446 pr2("Created type: INTEGER %d-bit %ssigned %s\n", 1447 size, sign ? "un" : "", hex ? "hex" : ""); 1448 return type; 1449 1450 err: 1451 bt_ctf_field_type_put(type); 1452 return NULL; 1453 } 1454 1455 static void ctf_writer__cleanup_data(struct ctf_writer *cw) 1456 { 1457 unsigned int i; 1458 1459 for (i = 0; i < ARRAY_SIZE(cw->data.array); i++) 1460 bt_ctf_field_type_put(cw->data.array[i]); 1461 } 1462 1463 static int ctf_writer__init_data(struct ctf_writer *cw) 1464 { 1465 #define CREATE_INT_TYPE(type, size, sign, hex) \ 1466 do { \ 1467 (type) = create_int_type(size, sign, hex); \ 1468 if (!(type)) \ 1469 goto err; \ 1470 } while (0) 1471 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); 1478 1479 cw->data.string = bt_ctf_field_type_string_create(); 1480 if (cw->data.string) 1481 return 0; 1482 1483 err: 1484 ctf_writer__cleanup_data(cw); 1485 pr_err("Failed to create data types.\n"); 1486 return -1; 1487 } 1488 1489 static void ctf_writer__cleanup(struct ctf_writer *cw) 1490 { 1491 ctf_writer__cleanup_data(cw); 1492 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); 1497 1498 /* and NULL all the pointers */ 1499 memset(cw, 0, sizeof(*cw)); 1500 } 1501 1502 static int ctf_writer__init(struct ctf_writer *cw, const char *path, 1503 struct perf_session *session, bool tod) 1504 { 1505 struct bt_ctf_writer *writer; 1506 struct bt_ctf_stream_class *stream_class; 1507 struct bt_ctf_clock *clock; 1508 struct bt_ctf_field_type *pkt_ctx_type; 1509 int ret; 1510 1511 /* CTF writer */ 1512 writer = bt_ctf_writer_create(path); 1513 if (!writer) 1514 goto err; 1515 1516 cw->writer = writer; 1517 1518 /* CTF clock */ 1519 clock = bt_ctf_clock_create("perf_clock"); 1520 if (!clock) { 1521 pr("Failed to create CTF clock.\n"); 1522 goto err_cleanup; 1523 } 1524 1525 cw->clock = clock; 1526 1527 if (ctf_writer__setup_clock(cw, session, tod)) { 1528 pr("Failed to setup CTF clock.\n"); 1529 goto err_cleanup; 1530 } 1531 1532 /* CTF stream class */ 1533 stream_class = bt_ctf_stream_class_create("perf_stream"); 1534 if (!stream_class) { 1535 pr("Failed to create CTF stream class.\n"); 1536 goto err_cleanup; 1537 } 1538 1539 cw->stream_class = stream_class; 1540 1541 /* CTF clock stream setup */ 1542 if (bt_ctf_stream_class_set_clock(stream_class, clock)) { 1543 pr("Failed to assign CTF clock to stream class.\n"); 1544 goto err_cleanup; 1545 } 1546 1547 if (ctf_writer__init_data(cw)) 1548 goto err_cleanup; 1549 1550 /* Add cpu_id for packet context */ 1551 pkt_ctx_type = bt_ctf_stream_class_get_packet_context_type(stream_class); 1552 if (!pkt_ctx_type) 1553 goto err_cleanup; 1554 1555 ret = bt_ctf_field_type_structure_add_field(pkt_ctx_type, cw->data.u32, "cpu_id"); 1556 bt_ctf_field_type_put(pkt_ctx_type); 1557 if (ret) 1558 goto err_cleanup; 1559 1560 /* CTF clock writer setup */ 1561 if (bt_ctf_writer_add_clock(writer, clock)) { 1562 pr("Failed to assign CTF clock to writer.\n"); 1563 goto err_cleanup; 1564 } 1565 1566 return 0; 1567 1568 err_cleanup: 1569 ctf_writer__cleanup(cw); 1570 err: 1571 pr_err("Failed to setup CTF writer.\n"); 1572 return -1; 1573 } 1574 1575 static int ctf_writer__flush_streams(struct ctf_writer *cw) 1576 { 1577 int cpu, ret = 0; 1578 1579 for (cpu = 0; cpu < cw->stream_cnt && !ret; cpu++) 1580 ret = ctf_stream__flush(cw->stream[cpu]); 1581 1582 return ret; 1583 } 1584 1585 static int convert__config(const char *var, const char *value, void *cb) 1586 { 1587 struct convert *c = cb; 1588 1589 if (!strcmp(var, "convert.queue-size")) 1590 return perf_config_u64(&c->queue_size, var, value); 1591 1592 return 0; 1593 } 1594 1595 int bt_convert__perf2ctf(const char *input, const char *path, 1596 struct perf_data_convert_opts *opts) 1597 { 1598 struct perf_session *session; 1599 struct perf_data data = { 1600 .path = input, 1601 .mode = PERF_DATA_MODE_READ, 1602 .force = opts->force, 1603 }; 1604 struct convert c = { 1605 .tool = { 1606 .sample = process_sample_event, 1607 .mmap = perf_event__process_mmap, 1608 .mmap2 = perf_event__process_mmap2, 1609 .comm = perf_event__process_comm, 1610 .exit = perf_event__process_exit, 1611 .fork = perf_event__process_fork, 1612 .lost = perf_event__process_lost, 1613 .tracing_data = perf_event__process_tracing_data, 1614 .build_id = perf_event__process_build_id, 1615 .namespaces = perf_event__process_namespaces, 1616 .ordered_events = true, 1617 .ordering_requires_timestamps = true, 1618 }, 1619 }; 1620 struct ctf_writer *cw = &c.writer; 1621 int err; 1622 1623 if (opts->all) { 1624 c.tool.comm = process_comm_event; 1625 c.tool.exit = process_exit_event; 1626 c.tool.fork = process_fork_event; 1627 c.tool.mmap = process_mmap_event; 1628 c.tool.mmap2 = process_mmap2_event; 1629 } 1630 1631 err = perf_config(convert__config, &c); 1632 if (err) 1633 return err; 1634 1635 err = -1; 1636 /* perf.data session */ 1637 session = perf_session__new(&data, 0, &c.tool); 1638 if (IS_ERR(session)) 1639 return PTR_ERR(session); 1640 1641 /* CTF writer */ 1642 if (ctf_writer__init(cw, path, session, opts->tod)) 1643 goto free_session; 1644 1645 if (c.queue_size) { 1646 ordered_events__set_alloc_size(&session->ordered_events, 1647 c.queue_size); 1648 } 1649 1650 /* CTF writer env/clock setup */ 1651 if (ctf_writer__setup_env(cw, session)) 1652 goto free_writer; 1653 1654 /* CTF events setup */ 1655 if (setup_events(cw, session)) 1656 goto free_writer; 1657 1658 if (opts->all && setup_non_sample_events(cw, session)) 1659 goto free_writer; 1660 1661 if (setup_streams(cw, session)) 1662 goto free_writer; 1663 1664 err = perf_session__process_events(session); 1665 if (!err) 1666 err = ctf_writer__flush_streams(cw); 1667 else 1668 pr_err("Error during conversion.\n"); 1669 1670 fprintf(stderr, 1671 "[ perf data convert: Converted '%s' into CTF data '%s' ]\n", 1672 data.path, path); 1673 1674 fprintf(stderr, 1675 "[ perf data convert: Converted and wrote %.3f MB (%" PRIu64 " samples", 1676 (double) c.events_size / 1024.0 / 1024.0, 1677 c.events_count); 1678 1679 if (!c.non_sample_count) 1680 fprintf(stderr, ") ]\n"); 1681 else 1682 fprintf(stderr, ", %" PRIu64 " non-samples) ]\n", c.non_sample_count); 1683 1684 cleanup_events(session); 1685 perf_session__delete(session); 1686 ctf_writer__cleanup(cw); 1687 1688 return err; 1689 1690 free_writer: 1691 ctf_writer__cleanup(cw); 1692 free_session: 1693 perf_session__delete(session); 1694 pr_err("Error during conversion setup.\n"); 1695 return err; 1696 } 1697