de47fec95561fbfe56464a871b3a97e72547868e
[babeltrace.git] / src / plugins / ctf / fs-src / fs.cpp
1 /*
2 * SPDX-License-Identifier: MIT
3 *
4 * Copyright 2015-2017 Philippe Proulx <pproulx@efficios.com>
5 * Copyright 2016 Jérémie Galarneau <jeremie.galarneau@efficios.com>
6 *
7 * Babeltrace CTF file system Reader Component
8 */
9
10 #include <glib.h>
11 #include <inttypes.h>
12
13 #include <babeltrace2/babeltrace.h>
14
15 #include "common/assert.h"
16 #include "common/common.h"
17 #include "common/uuid.h"
18 #include "cpp-common/bt2s/make-unique.hpp"
19
20 #include "plugins/common/param-validation/param-validation.h"
21
22 #include "../common/src/metadata/tsdl/ctf-meta-configure-ir-trace.hpp"
23 #include "../common/src/msg-iter/msg-iter.hpp"
24 #include "data-stream-file.hpp"
25 #include "file.hpp"
26 #include "fs.hpp"
27 #include "metadata.hpp"
28 #include "query.hpp"
29
30 struct tracer_info
31 {
32 const char *name;
33 int64_t major;
34 int64_t minor;
35 int64_t patch;
36 };
37
38 static bt_message_iterator_class_next_method_status
39 ctf_fs_iterator_next_one(struct ctf_fs_msg_iter_data *msg_iter_data, const bt_message **out_msg)
40 {
41 bt_message_iterator_class_next_method_status status;
42 const auto msg_iter_status =
43 ctf_msg_iter_get_next_message(msg_iter_data->msg_iter.get(), out_msg);
44
45 switch (msg_iter_status) {
46 case CTF_MSG_ITER_STATUS_OK:
47 /* Cool, message has been written to *out_msg. */
48 status = BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_OK;
49 break;
50
51 case CTF_MSG_ITER_STATUS_EOF:
52 status = BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_END;
53 break;
54
55 case CTF_MSG_ITER_STATUS_AGAIN:
56 /*
57 * Should not make it this far as this is
58 * medium-specific; there is nothing for the user to do
59 * and it should have been handled upstream.
60 */
61 bt_common_abort();
62
63 case CTF_MSG_ITER_STATUS_ERROR:
64 BT_CPPLOGE_APPEND_CAUSE_SPEC(msg_iter_data->logger,
65 "Failed to get next message from CTF message iterator.");
66 status = BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_ERROR;
67 break;
68
69 case CTF_MSG_ITER_STATUS_MEMORY_ERROR:
70 BT_CPPLOGE_APPEND_CAUSE_SPEC(msg_iter_data->logger,
71 "Failed to get next message from CTF message iterator.");
72 status = BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_MEMORY_ERROR;
73 break;
74
75 default:
76 bt_common_abort();
77 }
78
79 return status;
80 }
81
82 bt_message_iterator_class_next_method_status
83 ctf_fs_iterator_next(bt_self_message_iterator *iterator, bt_message_array_const msgs,
84 uint64_t capacity, uint64_t *count)
85 {
86 try {
87 bt_message_iterator_class_next_method_status status;
88 struct ctf_fs_msg_iter_data *msg_iter_data =
89 (struct ctf_fs_msg_iter_data *) bt_self_message_iterator_get_data(iterator);
90 uint64_t i = 0;
91
92 if (G_UNLIKELY(msg_iter_data->next_saved_error)) {
93 /*
94 * Last time we were called, we hit an error but had some
95 * messages to deliver, so we stashed the error here. Return
96 * it now.
97 */
98 BT_CURRENT_THREAD_MOVE_ERROR_AND_RESET(msg_iter_data->next_saved_error);
99 status = msg_iter_data->next_saved_status;
100 goto end;
101 }
102
103 do {
104 status = ctf_fs_iterator_next_one(msg_iter_data, &msgs[i]);
105 if (status == BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_OK) {
106 i++;
107 }
108 } while (i < capacity && status == BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_OK);
109
110 if (i > 0) {
111 /*
112 * Even if ctf_fs_iterator_next_one() returned something
113 * else than BT_MESSAGE_ITERATOR_NEXT_METHOD_STATUS_OK, we
114 * accumulated message objects in the output
115 * message array, so we need to return
116 * BT_MESSAGE_ITERATOR_NEXT_METHOD_STATUS_OK so that they are
117 * transferred to downstream. This other status occurs
118 * again the next time muxer_msg_iter_do_next() is
119 * called, possibly without any accumulated
120 * message, in which case we'll return it.
121 */
122 if (status < 0) {
123 /*
124 * Save this error for the next _next call. Assume that
125 * this component always appends error causes when
126 * returning an error status code, which will cause the
127 * current thread error to be non-NULL.
128 */
129 msg_iter_data->next_saved_error = bt_current_thread_take_error();
130 BT_ASSERT(msg_iter_data->next_saved_error);
131 msg_iter_data->next_saved_status = status;
132 }
133
134 *count = i;
135 status = BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_OK;
136 }
137
138 end:
139 return status;
140 return status;
141 } catch (const std::bad_alloc&) {
142 return BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_MEMORY_ERROR;
143 } catch (const bt2::Error&) {
144 return BT_MESSAGE_ITERATOR_CLASS_NEXT_METHOD_STATUS_ERROR;
145 }
146 }
147
148 bt_message_iterator_class_seek_beginning_method_status
149 ctf_fs_iterator_seek_beginning(bt_self_message_iterator *it)
150 {
151 try {
152 struct ctf_fs_msg_iter_data *msg_iter_data =
153 (struct ctf_fs_msg_iter_data *) bt_self_message_iterator_get_data(it);
154
155 BT_ASSERT(msg_iter_data);
156
157 ctf_msg_iter_reset(msg_iter_data->msg_iter.get());
158 ctf_fs_ds_group_medops_data_reset(msg_iter_data->msg_iter_medops_data.get());
159
160 return BT_MESSAGE_ITERATOR_CLASS_SEEK_BEGINNING_METHOD_STATUS_OK;
161 } catch (const std::bad_alloc&) {
162 return BT_MESSAGE_ITERATOR_CLASS_SEEK_BEGINNING_METHOD_STATUS_MEMORY_ERROR;
163 } catch (const bt2::Error&) {
164 return BT_MESSAGE_ITERATOR_CLASS_SEEK_BEGINNING_METHOD_STATUS_ERROR;
165 }
166 }
167
168 void ctf_fs_iterator_finalize(bt_self_message_iterator *it)
169 {
170 ctf_fs_msg_iter_data::UP {
171 (static_cast<ctf_fs_msg_iter_data *>(bt_self_message_iterator_get_data(it)))};
172 }
173
174 static bt_message_iterator_class_initialize_method_status
175 ctf_msg_iter_medium_status_to_msg_iter_initialize_status(enum ctf_msg_iter_medium_status status)
176 {
177 switch (status) {
178 case CTF_MSG_ITER_MEDIUM_STATUS_EOF:
179 case CTF_MSG_ITER_MEDIUM_STATUS_AGAIN:
180 case CTF_MSG_ITER_MEDIUM_STATUS_ERROR:
181 return BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_ERROR;
182 case CTF_MSG_ITER_MEDIUM_STATUS_MEMORY_ERROR:
183 return BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR;
184 case CTF_MSG_ITER_MEDIUM_STATUS_OK:
185 return BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_OK;
186 }
187
188 bt_common_abort();
189 }
190
191 bt_message_iterator_class_initialize_method_status
192 ctf_fs_iterator_init(bt_self_message_iterator *self_msg_iter,
193 bt_self_message_iterator_configuration *config,
194 bt_self_component_port_output *self_port)
195 {
196 try {
197 struct ctf_fs_port_data *port_data;
198 bt_message_iterator_class_initialize_method_status status;
199 enum ctf_msg_iter_medium_status medium_status;
200
201 port_data = (struct ctf_fs_port_data *) bt_self_component_port_get_data(
202 bt_self_component_port_output_as_self_component_port(self_port));
203 BT_ASSERT(port_data);
204
205 auto msg_iter_data = bt2s::make_unique<ctf_fs_msg_iter_data>(self_msg_iter);
206 msg_iter_data->ds_file_group = port_data->ds_file_group;
207
208 medium_status = ctf_fs_ds_group_medops_data_create(msg_iter_data->ds_file_group,
209 self_msg_iter, msg_iter_data->logger,
210 msg_iter_data->msg_iter_medops_data);
211 BT_ASSERT(medium_status == CTF_MSG_ITER_MEDIUM_STATUS_OK ||
212 medium_status == CTF_MSG_ITER_MEDIUM_STATUS_ERROR ||
213 medium_status == CTF_MSG_ITER_MEDIUM_STATUS_MEMORY_ERROR);
214 if (medium_status != CTF_MSG_ITER_MEDIUM_STATUS_OK) {
215 BT_CPPLOGE_APPEND_CAUSE_SPEC(msg_iter_data->logger,
216 "Failed to create ctf_fs_ds_group_medops");
217 status = ctf_msg_iter_medium_status_to_msg_iter_initialize_status(medium_status);
218 goto error;
219 }
220
221 msg_iter_data->msg_iter = ctf_msg_iter_create(
222 msg_iter_data->ds_file_group->ctf_fs_trace->metadata->tc,
223 bt_common_get_page_size(static_cast<int>(msg_iter_data->logger.level())) * 8,
224 ctf_fs_ds_group_medops, msg_iter_data->msg_iter_medops_data.get(), self_msg_iter,
225 msg_iter_data->logger);
226 if (!msg_iter_data->msg_iter) {
227 BT_CPPLOGE_APPEND_CAUSE_SPEC(msg_iter_data->logger,
228 "Cannot create a CTF message iterator.");
229 status = BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR;
230 goto error;
231 }
232
233 /*
234 * This iterator can seek forward if its stream class has a default
235 * clock class.
236 */
237 if (msg_iter_data->ds_file_group->sc->default_clock_class) {
238 bt_self_message_iterator_configuration_set_can_seek_forward(config, true);
239 }
240
241 bt_self_message_iterator_set_data(self_msg_iter, msg_iter_data.release());
242
243 status = BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_OK;
244 goto end;
245
246 error:
247 bt_self_message_iterator_set_data(self_msg_iter, NULL);
248
249 end:
250 return status;
251 } catch (const std::bad_alloc&) {
252 return BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR;
253 } catch (const bt2::Error&) {
254 return BT_MESSAGE_ITERATOR_CLASS_INITIALIZE_METHOD_STATUS_ERROR;
255 }
256 }
257
258 ctf_fs_component::UP ctf_fs_component_create(const bt2c::Logger& parentLogger)
259 {
260 return bt2s::make_unique<ctf_fs_component>(parentLogger);
261 }
262
263 void ctf_fs_finalize(bt_self_component_source *component)
264 {
265 ctf_fs_component::UP {static_cast<ctf_fs_component *>(
266 bt_self_component_get_data(bt_self_component_source_as_self_component(component)))};
267 }
268
269 bt2c::GCharUP ctf_fs_make_port_name(struct ctf_fs_ds_file_group *ds_file_group)
270 {
271 GString *name = g_string_new(NULL);
272
273 /*
274 * The unique port name is generated by concatenating unique identifiers
275 * for:
276 *
277 * - the trace
278 * - the stream class
279 * - the stream
280 */
281
282 /* For the trace, use the uuid if present, else the path. */
283 if (ds_file_group->ctf_fs_trace->metadata->tc->is_uuid_set) {
284 char uuid_str[BT_UUID_STR_LEN + 1];
285
286 bt_uuid_to_str(ds_file_group->ctf_fs_trace->metadata->tc->uuid, uuid_str);
287 g_string_assign(name, uuid_str);
288 } else {
289 g_string_assign(name, ds_file_group->ctf_fs_trace->path.c_str());
290 }
291
292 /*
293 * For the stream class, use the id if present. We can omit this field
294 * otherwise, as there will only be a single stream class.
295 */
296 if (ds_file_group->sc->id != UINT64_C(-1)) {
297 g_string_append_printf(name, " | %" PRIu64, ds_file_group->sc->id);
298 }
299
300 /* For the stream, use the id if present, else, use the path. */
301 if (ds_file_group->stream_id != UINT64_C(-1)) {
302 g_string_append_printf(name, " | %" PRIu64, ds_file_group->stream_id);
303 } else {
304 BT_ASSERT(ds_file_group->ds_file_infos.size() == 1);
305 const auto& ds_file_info = *ds_file_group->ds_file_infos[0];
306 g_string_append_printf(name, " | %s", ds_file_info.path.c_str());
307 }
308
309 return bt2c::GCharUP {g_string_free(name, FALSE)};
310 }
311
312 static int create_one_port_for_trace(struct ctf_fs_component *ctf_fs,
313 struct ctf_fs_ds_file_group *ds_file_group,
314 bt_self_component_source *self_comp_src)
315 {
316 int ret = 0;
317 ctf_fs_port_data::UP port_data;
318
319 bt2c::GCharUP port_name = ctf_fs_make_port_name(ds_file_group);
320 if (!port_name) {
321 goto error;
322 }
323
324 BT_CPPLOGI_SPEC(ctf_fs->logger, "Creating one port named `{}`", port_name.get());
325
326 /* Create output port for this file */
327 port_data = bt2s::make_unique<ctf_fs_port_data>();
328 port_data->ctf_fs = ctf_fs;
329 port_data->ds_file_group = ds_file_group;
330 ret = bt_self_component_source_add_output_port(self_comp_src, port_name.get(), port_data.get(),
331 NULL);
332 if (ret) {
333 goto error;
334 }
335
336 ctf_fs->port_data.emplace_back(std::move(port_data));
337 goto end;
338
339 error:
340 ret = -1;
341
342 end:
343 return ret;
344 }
345
346 static int create_ports_for_trace(struct ctf_fs_component *ctf_fs,
347 struct ctf_fs_trace *ctf_fs_trace,
348 bt_self_component_source *self_comp_src)
349 {
350 int ret = 0;
351
352 /* Create one output port for each stream file group */
353 for (const auto& ds_file_group : ctf_fs_trace->ds_file_groups) {
354 ret = create_one_port_for_trace(ctf_fs, ds_file_group.get(), self_comp_src);
355 if (ret) {
356 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs->logger, "Cannot create output port.");
357 goto end;
358 }
359 }
360
361 end:
362 return ret;
363 }
364
365 /*
366 * Insert ds_file_info in ds_file_group's list of ds_file_infos at the right
367 * place to keep it sorted.
368 */
369
370 static void ds_file_group_insert_ds_file_info_sorted(struct ctf_fs_ds_file_group *ds_file_group,
371 ctf_fs_ds_file_info::UP ds_file_info)
372 {
373 /* Find the spot where to insert this ds_file_info. */
374 auto it = ds_file_group->ds_file_infos.begin();
375
376 for (; it != ds_file_group->ds_file_infos.end(); ++it) {
377 const ctf_fs_ds_file_info& other_ds_file_info = **it;
378
379 if (ds_file_info->begin_ns < other_ds_file_info.begin_ns) {
380 break;
381 }
382 }
383
384 ds_file_group->ds_file_infos.insert(it, std::move(ds_file_info));
385 }
386
387 static bool ds_index_entries_equal(const struct ctf_fs_ds_index_entry *left,
388 const struct ctf_fs_ds_index_entry *right)
389 {
390 if (left->packetSize != right->packetSize) {
391 return false;
392 }
393
394 if (left->timestamp_begin != right->timestamp_begin) {
395 return false;
396 }
397
398 if (left->timestamp_end != right->timestamp_end) {
399 return false;
400 }
401
402 if (left->packet_seq_num != right->packet_seq_num) {
403 return false;
404 }
405
406 return true;
407 }
408
409 /*
410 * Insert `entry` into `index`, without duplication.
411 *
412 * The entry is inserted only if there isn't an identical entry already.
413 *
414 * In any case, the ownership of `entry` is transferred to this function. So if
415 * the entry is not inserted, it is freed.
416 */
417
418 static void ds_index_insert_ds_index_entry_sorted(struct ctf_fs_ds_index *index,
419 ctf_fs_ds_index_entry::UP entry)
420 {
421 /* Find the spot where to insert this index entry. */
422 auto otherEntry = index->entries.begin();
423 for (; otherEntry != index->entries.end(); ++otherEntry) {
424 if (entry->timestamp_begin_ns <= (*otherEntry)->timestamp_begin_ns) {
425 break;
426 }
427 }
428
429 /*
430 * Insert the entry only if a duplicate doesn't already exist.
431 *
432 * There can be duplicate packets if reading multiple overlapping
433 * snapshots of the same trace. We then want the index to contain
434 * a reference to only one copy of that packet.
435 */
436 if (otherEntry == index->entries.end() ||
437 !ds_index_entries_equal(entry.get(), otherEntry->get())) {
438 index->entries.insert(otherEntry, std::move(entry));
439 }
440 }
441
442 static void merge_ctf_fs_ds_indexes(struct ctf_fs_ds_index *dest, ctf_fs_ds_index::UP src)
443 {
444 for (auto& entry : src->entries) {
445 ds_index_insert_ds_index_entry_sorted(dest, std::move(entry));
446 }
447 }
448
449 static int add_ds_file_to_ds_file_group(struct ctf_fs_trace *ctf_fs_trace, const char *path)
450 {
451 int64_t stream_instance_id = -1;
452 int64_t begin_ns = -1;
453 struct ctf_fs_ds_file_group *ds_file_group = NULL;
454 ctf_fs_ds_file_group::UP new_ds_file_group;
455 int ret;
456 ctf_fs_ds_file_info::UP ds_file_info;
457 ctf_fs_ds_index::UP index;
458 ctf_msg_iter_up msg_iter;
459 struct ctf_stream_class *sc = NULL;
460 struct ctf_msg_iter_packet_properties props;
461
462 /*
463 * Create a temporary ds_file to read some properties about the data
464 * stream file.
465 */
466 const auto ds_file =
467 ctf_fs_ds_file_create(ctf_fs_trace, bt2::Stream::Shared {}, path, ctf_fs_trace->logger);
468 if (!ds_file) {
469 goto error;
470 }
471
472 /* Create a temporary iterator to read the ds_file. */
473 msg_iter = ctf_msg_iter_create(
474 ctf_fs_trace->metadata->tc,
475 bt_common_get_page_size(static_cast<int>(ctf_fs_trace->logger.level())) * 8,
476 ctf_fs_ds_file_medops, ds_file.get(), nullptr, ctf_fs_trace->logger);
477 if (!msg_iter) {
478 BT_CPPLOGE_STR_SPEC(ctf_fs_trace->logger, "Cannot create a CTF message iterator.");
479 goto error;
480 }
481
482 ctf_msg_iter_set_dry_run(msg_iter.get(), true);
483
484 ret = ctf_msg_iter_get_packet_properties(msg_iter.get(), &props);
485 if (ret) {
486 BT_CPPLOGE_APPEND_CAUSE_SPEC(
487 ctf_fs_trace->logger,
488 "Cannot get stream file's first packet's header and context fields (`{}`).", path);
489 goto error;
490 }
491
492 sc = ctf_trace_class_borrow_stream_class_by_id(ds_file->metadata->tc, props.stream_class_id);
493 BT_ASSERT(sc);
494 stream_instance_id = props.data_stream_id;
495
496 if (props.snapshots.beginning_clock != UINT64_C(-1)) {
497 BT_ASSERT(sc->default_clock_class);
498 ret = bt_util_clock_cycles_to_ns_from_origin(
499 props.snapshots.beginning_clock, sc->default_clock_class->frequency,
500 sc->default_clock_class->offset_seconds, sc->default_clock_class->offset_cycles,
501 &begin_ns);
502 if (ret) {
503 BT_CPPLOGE_APPEND_CAUSE_SPEC(
504 ctf_fs_trace->logger,
505 "Cannot convert clock cycles to nanoseconds from origin (`{}`).", path);
506 goto error;
507 }
508 }
509
510 ds_file_info = ctf_fs_ds_file_info_create(path, begin_ns);
511 if (!ds_file_info) {
512 goto error;
513 }
514
515 index = ctf_fs_ds_file_build_index(ds_file.get(), ds_file_info.get(), msg_iter.get());
516 if (!index) {
517 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs_trace->logger, "Failed to index CTF stream file \'{}\'",
518 ds_file->file->path);
519 goto error;
520 }
521
522 if (begin_ns == -1) {
523 /*
524 * No beginning timestamp to sort the stream files
525 * within a stream file group, so consider that this
526 * file must be the only one within its group.
527 */
528 stream_instance_id = -1;
529 }
530
531 if (stream_instance_id == -1) {
532 /*
533 * No stream instance ID or no beginning timestamp:
534 * create a unique stream file group for this stream
535 * file because, even if there's a stream instance ID,
536 * there's no timestamp to order the file within its
537 * group.
538 */
539 new_ds_file_group =
540 ctf_fs_ds_file_group_create(ctf_fs_trace, sc, UINT64_C(-1), std::move(index));
541
542 if (!new_ds_file_group) {
543 goto error;
544 }
545
546 ds_file_group_insert_ds_file_info_sorted(new_ds_file_group.get(), std::move(ds_file_info));
547 ctf_fs_trace->ds_file_groups.emplace_back(std::move(new_ds_file_group));
548 goto end;
549 }
550
551 BT_ASSERT(stream_instance_id != -1);
552 BT_ASSERT(begin_ns != -1);
553
554 /* Find an existing stream file group with this ID */
555 for (const auto& candidate : ctf_fs_trace->ds_file_groups) {
556 if (candidate->sc == sc && candidate->stream_id == stream_instance_id) {
557 ds_file_group = candidate.get();
558 break;
559 }
560 }
561
562 if (!ds_file_group) {
563 new_ds_file_group =
564 ctf_fs_ds_file_group_create(ctf_fs_trace, sc, stream_instance_id, std::move(index));
565 if (!new_ds_file_group) {
566 goto error;
567 }
568
569 ds_file_group = new_ds_file_group.get();
570 ctf_fs_trace->ds_file_groups.emplace_back(std::move(new_ds_file_group));
571 } else {
572 merge_ctf_fs_ds_indexes(ds_file_group->index.get(), std::move(index));
573 }
574
575 ds_file_group_insert_ds_file_info_sorted(ds_file_group, std::move(ds_file_info));
576
577 goto end;
578
579 error:
580 ret = -1;
581
582 end:
583 return ret;
584 }
585
586 static int create_ds_file_groups(struct ctf_fs_trace *ctf_fs_trace)
587 {
588 int ret = 0;
589 const char *basename;
590 GError *error = NULL;
591 GDir *dir = NULL;
592
593 /* Check each file in the path directory, except specific ones */
594 dir = g_dir_open(ctf_fs_trace->path.c_str(), 0, &error);
595 if (!dir) {
596 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs_trace->logger,
597 "Cannot open directory `{}`: {} (code {})", ctf_fs_trace->path,
598 error->message, error->code);
599 goto error;
600 }
601
602 while ((basename = g_dir_read_name(dir))) {
603 if (strcmp(basename, CTF_FS_METADATA_FILENAME) == 0) {
604 /* Ignore the metadata stream. */
605 BT_CPPLOGI_SPEC(ctf_fs_trace->logger,
606 "Ignoring metadata file `{}" G_DIR_SEPARATOR_S "{}`",
607 ctf_fs_trace->path, basename);
608 continue;
609 }
610
611 if (basename[0] == '.') {
612 BT_CPPLOGI_SPEC(ctf_fs_trace->logger,
613 "Ignoring hidden file `{}" G_DIR_SEPARATOR_S "{}`", ctf_fs_trace->path,
614 basename);
615 continue;
616 }
617
618 /* Create the file. */
619 const auto file = ctf_fs_file_create(ctf_fs_trace->logger);
620 if (!file) {
621 BT_CPPLOGE_APPEND_CAUSE_SPEC(
622 ctf_fs_trace->logger,
623 "Cannot create stream file object for file `{}" G_DIR_SEPARATOR_S "{}`",
624 ctf_fs_trace->path, basename);
625 goto error;
626 }
627
628 /* Create full path string. */
629 file->path = fmt::format("{}" G_DIR_SEPARATOR_S "{}", ctf_fs_trace->path, basename);
630
631 if (!g_file_test(file->path.c_str(), G_FILE_TEST_IS_REGULAR)) {
632 BT_CPPLOGI_SPEC(ctf_fs_trace->logger, "Ignoring non-regular file `{}`", file->path);
633 continue;
634 }
635
636 ret = ctf_fs_file_open(file.get(), "rb");
637 if (ret) {
638 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs_trace->logger, "Cannot open stream file `{}`",
639 file->path);
640 goto error;
641 }
642
643 if (file->size == 0) {
644 /* Skip empty stream. */
645 BT_CPPLOGI_SPEC(ctf_fs_trace->logger, "Ignoring empty file `{}`", file->path);
646 continue;
647 }
648
649 ret = add_ds_file_to_ds_file_group(ctf_fs_trace, file->path.c_str());
650 if (ret) {
651 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs_trace->logger,
652 "Cannot add stream file `{}` to stream file group",
653 file->path);
654 goto error;
655 }
656 }
657
658 goto end;
659
660 error:
661 ret = -1;
662
663 end:
664 if (dir) {
665 g_dir_close(dir);
666 dir = NULL;
667 }
668
669 if (error) {
670 g_error_free(error);
671 }
672
673 return ret;
674 }
675
676 static int set_trace_name(bt_trace *trace, const char *name_suffix)
677 {
678 int ret = 0;
679 const bt_value *val;
680 std::string name;
681
682 /*
683 * Check if we have a trace environment string value named `hostname`.
684 * If so, use it as the trace name's prefix.
685 */
686 val = bt_trace_borrow_environment_entry_value_by_name_const(trace, "hostname");
687 if (val && bt_value_is_string(val)) {
688 name += bt_value_string_get(val);
689
690 if (name_suffix) {
691 name += G_DIR_SEPARATOR;
692 }
693 }
694
695 if (name_suffix) {
696 name += name_suffix;
697 }
698
699 ret = bt_trace_set_name(trace, name.c_str());
700 if (ret) {
701 goto end;
702 }
703
704 goto end;
705
706 end:
707 return ret;
708 }
709
710 static ctf_fs_trace::UP ctf_fs_trace_create(const char *path, const char *name,
711 const ctf::src::ClkClsCfg& clkClsCfg,
712 bt_self_component *selfComp,
713 const bt2c::Logger& parentLogger)
714 {
715 int ret;
716 ctf_fs_trace::UP ctf_fs_trace {new struct ctf_fs_trace(parentLogger)};
717
718 ctf_fs_trace->path = path;
719 ctf_fs_trace->metadata = bt2s::make_unique<ctf_fs_metadata>();
720
721 ret = ctf_fs_metadata_set_trace_class(selfComp, ctf_fs_trace.get(), clkClsCfg);
722 if (ret) {
723 goto error;
724 }
725
726 if (ctf_fs_trace->metadata->trace_class) {
727 bt_trace *trace = bt_trace_create(ctf_fs_trace->metadata->trace_class->libObjPtr());
728 if (!trace) {
729 goto error;
730 }
731
732 ctf_fs_trace->trace = bt2::Trace::Shared::createWithoutRef(trace);
733 }
734
735 if (ctf_fs_trace->trace) {
736 ret = ctf_trace_class_configure_ir_trace(ctf_fs_trace->metadata->tc,
737 ctf_fs_trace->trace->libObjPtr());
738 if (ret) {
739 goto error;
740 }
741
742 ret = set_trace_name(ctf_fs_trace->trace->libObjPtr(), name);
743 if (ret) {
744 goto error;
745 }
746 }
747
748 ret = create_ds_file_groups(ctf_fs_trace.get());
749 if (ret) {
750 goto error;
751 }
752
753 goto end;
754
755 error:
756 ctf_fs_trace.reset();
757
758 end:
759 return ctf_fs_trace;
760 }
761
762 static int path_is_ctf_trace(const char *path)
763 {
764 return g_file_test(fmt::format("{}" G_DIR_SEPARATOR_S CTF_FS_METADATA_FILENAME, path).c_str(),
765 G_FILE_TEST_IS_REGULAR);
766 }
767
768 /* Helper for ctf_fs_component_create_ctf_fs_trace, to handle a single path. */
769
770 static int ctf_fs_component_create_ctf_fs_trace_one_path(struct ctf_fs_component *ctf_fs,
771 const char *path_param,
772 const char *trace_name,
773 std::vector<ctf_fs_trace::UP>& traces,
774 bt_self_component *selfComp)
775 {
776 ctf_fs_trace::UP ctf_fs_trace;
777 int ret;
778
779 bt2c::GStringUP norm_path {bt_common_normalize_path(path_param, NULL)};
780 if (!norm_path) {
781 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs->logger, "Failed to normalize path: `{}`.", path_param);
782 goto error;
783 }
784
785 ret = path_is_ctf_trace(norm_path->str);
786 if (ret < 0) {
787 BT_CPPLOGE_APPEND_CAUSE_SPEC(
788 ctf_fs->logger, "Failed to check if path is a CTF trace: path={}", norm_path->str);
789 goto error;
790 } else if (ret == 0) {
791 BT_CPPLOGE_APPEND_CAUSE_SPEC(
792 ctf_fs->logger, "Path is not a CTF trace (does not contain a metadata file): `{}`.",
793 norm_path->str);
794 goto error;
795 }
796
797 // FIXME: Remove or ifdef for __MINGW32__
798 if (strcmp(norm_path->str, "/") == 0) {
799 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs->logger, "Opening a trace in `/` is not supported.");
800 ret = -1;
801 goto end;
802 }
803
804 ctf_fs_trace = ctf_fs_trace_create(norm_path->str, trace_name, ctf_fs->clkClsCfg, selfComp,
805 ctf_fs->logger);
806 if (!ctf_fs_trace) {
807 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs->logger, "Cannot create trace for `{}`.",
808 norm_path->str);
809 goto error;
810 }
811
812 traces.emplace_back(std::move(ctf_fs_trace));
813
814 ret = 0;
815 goto end;
816
817 error:
818 ret = -1;
819
820 end:
821 return ret;
822 }
823
824 /*
825 * Count the number of stream and event classes defined by this trace's metadata.
826 *
827 * This is used to determine which metadata is the "latest", out of multiple
828 * traces sharing the same UUID. It is assumed that amongst all these metadatas,
829 * a bigger metadata is a superset of a smaller metadata. Therefore, it is
830 * enough to just count the classes.
831 */
832
833 static unsigned int metadata_count_stream_and_event_classes(struct ctf_fs_trace *trace)
834 {
835 unsigned int num = trace->metadata->tc->stream_classes->len;
836 guint i;
837
838 for (i = 0; i < trace->metadata->tc->stream_classes->len; i++) {
839 struct ctf_stream_class *sc =
840 (struct ctf_stream_class *) trace->metadata->tc->stream_classes->pdata[i];
841 num += sc->event_classes->len;
842 }
843
844 return num;
845 }
846
847 /*
848 * Merge the src ds_file_group into dest. This consists of merging their
849 * ds_file_infos, making sure to keep the result sorted.
850 */
851
852 static void merge_ctf_fs_ds_file_groups(struct ctf_fs_ds_file_group *dest,
853 ctf_fs_ds_file_group::UP src)
854 {
855 for (auto& ds_file_info : src->ds_file_infos) {
856 ds_file_group_insert_ds_file_info_sorted(dest, std::move(ds_file_info));
857 }
858
859 /* Merge both indexes. */
860 merge_ctf_fs_ds_indexes(dest->index.get(), std::move(src->index));
861 }
862
863 /* Merge src_trace's data stream file groups into dest_trace's. */
864
865 static int merge_matching_ctf_fs_ds_file_groups(struct ctf_fs_trace *dest_trace,
866 ctf_fs_trace::UP src_trace)
867 {
868 std::vector<ctf_fs_ds_file_group::UP>& dest = dest_trace->ds_file_groups;
869 std::vector<ctf_fs_ds_file_group::UP>& src = src_trace->ds_file_groups;
870 int ret = 0;
871
872 /*
873 * Save the initial length of dest: we only want to check against the
874 * original elements in the inner loop.
875 */
876 size_t dest_len = dest.size();
877
878 for (auto& src_group : src) {
879 struct ctf_fs_ds_file_group *dest_group = NULL;
880
881 /* A stream instance without ID can't match a stream in the other trace. */
882 if (src_group->stream_id != -1) {
883 /* Let's search for a matching ds_file_group in the destination. */
884 for (size_t d_i = 0; d_i < dest_len; ++d_i) {
885 ctf_fs_ds_file_group *candidate_dest = dest[d_i].get();
886
887 /* Can't match a stream instance without ID. */
888 if (candidate_dest->stream_id == -1) {
889 continue;
890 }
891
892 /*
893 * If the two groups have the same stream instance id
894 * and belong to the same stream class (stream instance
895 * ids are per-stream class), they represent the same
896 * stream instance.
897 */
898 if (candidate_dest->stream_id != src_group->stream_id ||
899 candidate_dest->sc->id != src_group->sc->id) {
900 continue;
901 }
902
903 dest_group = candidate_dest;
904 break;
905 }
906 }
907
908 /*
909 * Didn't find a friend in dest to merge our src_group into?
910 * Create a new empty one. This can happen if a stream was
911 * active in the source trace chunk but not in the destination
912 * trace chunk.
913 */
914 if (!dest_group) {
915 struct ctf_stream_class *sc;
916
917 sc = ctf_trace_class_borrow_stream_class_by_id(dest_trace->metadata->tc,
918 src_group->sc->id);
919 BT_ASSERT(sc);
920
921 auto index = ctf_fs_ds_index_create();
922 if (!index) {
923 ret = -1;
924 goto end;
925 }
926
927 auto new_dest_group =
928 ctf_fs_ds_file_group_create(dest_trace, sc, src_group->stream_id, std::move(index));
929
930 if (!new_dest_group) {
931 ret = -1;
932 goto end;
933 }
934
935 dest_group = new_dest_group.get();
936 dest_trace->ds_file_groups.emplace_back(std::move(new_dest_group));
937 }
938
939 BT_ASSERT(dest_group);
940 merge_ctf_fs_ds_file_groups(dest_group, std::move(src_group));
941 }
942
943 end:
944 return ret;
945 }
946
947 /*
948 * Collapse the given traces, which must all share the same UUID, in a single
949 * one.
950 *
951 * The trace with the most expansive metadata is chosen and all other traces
952 * are merged into that one. On return, the elements of `traces` are nullptr
953 * and the merged trace is placed in `out_trace`.
954 */
955
956 static int merge_ctf_fs_traces(std::vector<ctf_fs_trace::UP> traces, ctf_fs_trace::UP& out_trace)
957 {
958 unsigned int winner_count;
959 struct ctf_fs_trace *winner;
960 guint i, winner_i;
961 int ret = 0;
962
963 BT_ASSERT(traces.size() >= 2);
964
965 winner_count = metadata_count_stream_and_event_classes(traces[0].get());
966 winner = traces[0].get();
967 winner_i = 0;
968
969 /* Find the trace with the largest metadata. */
970 for (i = 1; i < traces.size(); i++) {
971 ctf_fs_trace *candidate = traces[i].get();
972 unsigned int candidate_count;
973
974 /* A bit of sanity check. */
975 BT_ASSERT(bt_uuid_compare(winner->metadata->tc->uuid, candidate->metadata->tc->uuid) == 0);
976
977 candidate_count = metadata_count_stream_and_event_classes(candidate);
978
979 if (candidate_count > winner_count) {
980 winner_count = candidate_count;
981 winner = candidate;
982 winner_i = i;
983 }
984 }
985
986 /* Merge all the other traces in the winning trace. */
987 for (ctf_fs_trace::UP& trace : traces) {
988 /* Don't merge the winner into itself. */
989 if (trace.get() == winner) {
990 continue;
991 }
992
993 /* Merge trace's data stream file groups into winner's. */
994 ret = merge_matching_ctf_fs_ds_file_groups(winner, std::move(trace));
995 if (ret) {
996 goto end;
997 }
998 }
999
1000 /*
1001 * Move the winner out of the array, into `*out_trace`.
1002 */
1003 out_trace = std::move(traces[winner_i]);
1004
1005 end:
1006 return ret;
1007 }
1008
1009 enum target_event
1010 {
1011 FIRST_EVENT,
1012 LAST_EVENT,
1013 };
1014
1015 static int decode_clock_snapshot_after_event(struct ctf_fs_trace *ctf_fs_trace,
1016 struct ctf_clock_class *default_cc,
1017 struct ctf_fs_ds_index_entry *index_entry,
1018 enum target_event target_event, uint64_t *cs,
1019 int64_t *ts_ns)
1020 {
1021 enum ctf_msg_iter_status iter_status = CTF_MSG_ITER_STATUS_OK;
1022 ctf_msg_iter_up msg_iter;
1023 int ret = 0;
1024
1025 BT_ASSERT(ctf_fs_trace);
1026 BT_ASSERT(index_entry);
1027 BT_ASSERT(index_entry->path);
1028
1029 const auto ds_file = ctf_fs_ds_file_create(ctf_fs_trace, bt2::Stream::Shared {},
1030 index_entry->path, ctf_fs_trace->logger);
1031 if (!ds_file) {
1032 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs_trace->logger, "Failed to create a ctf_fs_ds_file");
1033 ret = -1;
1034 goto end;
1035 }
1036
1037 BT_ASSERT(ctf_fs_trace->metadata);
1038 BT_ASSERT(ctf_fs_trace->metadata->tc);
1039
1040 msg_iter = ctf_msg_iter_create(
1041 ctf_fs_trace->metadata->tc,
1042 bt_common_get_page_size(static_cast<int>(ctf_fs_trace->logger.level())) * 8,
1043 ctf_fs_ds_file_medops, ds_file.get(), NULL, ctf_fs_trace->logger);
1044 if (!msg_iter) {
1045 /* ctf_msg_iter_create() logs errors. */
1046 ret = -1;
1047 goto end;
1048 }
1049
1050 /*
1051 * Turn on dry run mode to prevent the creation and usage of Babeltrace
1052 * library objects (bt_field, bt_message_*, etc.).
1053 */
1054 ctf_msg_iter_set_dry_run(msg_iter.get(), true);
1055
1056 /* Seek to the beginning of the target packet. */
1057 iter_status = ctf_msg_iter_seek(msg_iter.get(), index_entry->offset.bytes());
1058 if (iter_status) {
1059 /* ctf_msg_iter_seek() logs errors. */
1060 ret = -1;
1061 goto end;
1062 }
1063
1064 switch (target_event) {
1065 case FIRST_EVENT:
1066 /*
1067 * Start to decode the packet until we reach the end of
1068 * the first event. To extract the first event's clock
1069 * snapshot.
1070 */
1071 iter_status = ctf_msg_iter_curr_packet_first_event_clock_snapshot(msg_iter.get(), cs);
1072 break;
1073 case LAST_EVENT:
1074 /* Decode the packet to extract the last event's clock snapshot. */
1075 iter_status = ctf_msg_iter_curr_packet_last_event_clock_snapshot(msg_iter.get(), cs);
1076 break;
1077 default:
1078 bt_common_abort();
1079 }
1080 if (iter_status) {
1081 ret = -1;
1082 goto end;
1083 }
1084
1085 /* Convert clock snapshot to timestamp. */
1086 ret = bt_util_clock_cycles_to_ns_from_origin(
1087 *cs, default_cc->frequency, default_cc->offset_seconds, default_cc->offset_cycles, ts_ns);
1088 if (ret) {
1089 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs_trace->logger,
1090 "Failed to convert clock snapshot to timestamp");
1091 goto end;
1092 }
1093
1094 end:
1095 return ret;
1096 }
1097
1098 static int decode_packet_first_event_timestamp(struct ctf_fs_trace *ctf_fs_trace,
1099 struct ctf_clock_class *default_cc,
1100 struct ctf_fs_ds_index_entry *index_entry,
1101 uint64_t *cs, int64_t *ts_ns)
1102 {
1103 return decode_clock_snapshot_after_event(ctf_fs_trace, default_cc, index_entry, FIRST_EVENT, cs,
1104 ts_ns);
1105 }
1106
1107 static int decode_packet_last_event_timestamp(struct ctf_fs_trace *ctf_fs_trace,
1108 struct ctf_clock_class *default_cc,
1109 struct ctf_fs_ds_index_entry *index_entry,
1110 uint64_t *cs, int64_t *ts_ns)
1111 {
1112 return decode_clock_snapshot_after_event(ctf_fs_trace, default_cc, index_entry, LAST_EVENT, cs,
1113 ts_ns);
1114 }
1115
1116 /*
1117 * Fix up packet index entries for lttng's "event-after-packet" bug.
1118 * Some buggy lttng tracer versions may emit events with a timestamp that is
1119 * larger (after) than the timestamp_end of the their packets.
1120 *
1121 * To fix up this erroneous data we do the following:
1122 * 1. If it's not the stream file's last packet: set the packet index entry's
1123 * end time to the next packet's beginning time.
1124 * 2. If it's the stream file's last packet, set the packet index entry's end
1125 * time to the packet's last event's time, if any, or to the packet's
1126 * beginning time otherwise.
1127 *
1128 * Known buggy tracer versions:
1129 * - before lttng-ust 2.11.0
1130 * - before lttng-module 2.11.0
1131 * - before lttng-module 2.10.10
1132 * - before lttng-module 2.9.13
1133 */
1134 static int fix_index_lttng_event_after_packet_bug(struct ctf_fs_trace *trace)
1135 {
1136 int ret = 0;
1137
1138 for (const auto& ds_file_group : trace->ds_file_groups) {
1139 struct ctf_clock_class *default_cc;
1140
1141 BT_ASSERT(ds_file_group);
1142 const auto index = ds_file_group->index.get();
1143
1144 BT_ASSERT(index);
1145 BT_ASSERT(!index->entries.empty());
1146
1147 /*
1148 * Iterate over all entries but the last one. The last one is
1149 * fixed differently after.
1150 */
1151 for (size_t entry_i = 0; entry_i < index->entries.size() - 1; ++entry_i) {
1152 ctf_fs_ds_index_entry *curr_entry = index->entries[entry_i].get();
1153 ctf_fs_ds_index_entry *next_entry = index->entries[entry_i + 1].get();
1154
1155 /*
1156 * 1. Set the current index entry `end` timestamp to
1157 * the next index entry `begin` timestamp.
1158 */
1159 curr_entry->timestamp_end = next_entry->timestamp_begin;
1160 curr_entry->timestamp_end_ns = next_entry->timestamp_begin_ns;
1161 }
1162
1163 /*
1164 * 2. Fix the last entry by decoding the last event of the last
1165 * packet.
1166 */
1167 const auto last_entry = index->entries.back().get();
1168 BT_ASSERT(last_entry);
1169
1170 BT_ASSERT(ds_file_group->sc->default_clock_class);
1171 default_cc = ds_file_group->sc->default_clock_class;
1172
1173 /*
1174 * Decode packet to read the timestamp of the last event of the
1175 * entry.
1176 */
1177 ret = decode_packet_last_event_timestamp(trace, default_cc, last_entry,
1178 &last_entry->timestamp_end,
1179 &last_entry->timestamp_end_ns);
1180 if (ret) {
1181 BT_CPPLOGE_APPEND_CAUSE_SPEC(
1182 trace->logger,
1183 "Failed to decode stream's last packet to get its last event's clock snapshot.");
1184 goto end;
1185 }
1186 }
1187
1188 end:
1189 return ret;
1190 }
1191
1192 /*
1193 * Fix up packet index entries for barectf's "event-before-packet" bug.
1194 * Some buggy barectf tracer versions may emit events with a timestamp that is
1195 * less than the timestamp_begin of the their packets.
1196 *
1197 * To fix up this erroneous data we do the following:
1198 * 1. Starting at the second index entry, set the timestamp_begin of the
1199 * current entry to the timestamp of the first event of the packet.
1200 * 2. Set the previous entry's timestamp_end to the timestamp_begin of the
1201 * current packet.
1202 *
1203 * Known buggy tracer versions:
1204 * - before barectf 2.3.1
1205 */
1206 static int fix_index_barectf_event_before_packet_bug(struct ctf_fs_trace *trace)
1207 {
1208 int ret = 0;
1209
1210 for (const auto& ds_file_group : trace->ds_file_groups) {
1211 struct ctf_clock_class *default_cc;
1212 const auto index = ds_file_group->index.get();
1213
1214 BT_ASSERT(index);
1215 BT_ASSERT(!index->entries.empty());
1216
1217 BT_ASSERT(ds_file_group->sc->default_clock_class);
1218 default_cc = ds_file_group->sc->default_clock_class;
1219
1220 /*
1221 * 1. Iterate over the index, starting from the second entry
1222 * (index = 1).
1223 */
1224 for (size_t entry_i = 1; entry_i < index->entries.size(); ++entry_i) {
1225 ctf_fs_ds_index_entry *prev_entry = index->entries[entry_i - 1].get();
1226 ctf_fs_ds_index_entry *curr_entry = index->entries[entry_i].get();
1227 /*
1228 * 2. Set the current entry `begin` timestamp to the
1229 * timestamp of the first event of the current packet.
1230 */
1231 ret = decode_packet_first_event_timestamp(trace, default_cc, curr_entry,
1232 &curr_entry->timestamp_begin,
1233 &curr_entry->timestamp_begin_ns);
1234 if (ret) {
1235 BT_CPPLOGE_APPEND_CAUSE_SPEC(trace->logger,
1236 "Failed to decode first event's clock snapshot");
1237 goto end;
1238 }
1239
1240 /*
1241 * 3. Set the previous entry `end` timestamp to the
1242 * timestamp of the first event of the current packet.
1243 */
1244 prev_entry->timestamp_end = curr_entry->timestamp_begin;
1245 prev_entry->timestamp_end_ns = curr_entry->timestamp_begin_ns;
1246 }
1247 }
1248 end:
1249 return ret;
1250 }
1251
1252 /*
1253 * When using the lttng-crash feature it's likely that the last packets of each
1254 * stream have their timestamp_end set to zero. This is caused by the fact that
1255 * the tracer crashed and was not able to properly close the packets.
1256 *
1257 * To fix up this erroneous data we do the following:
1258 * For each index entry, if the entry's timestamp_end is 0 and the
1259 * timestamp_begin is not 0:
1260 * - If it's the stream file's last packet: set the packet index entry's end
1261 * time to the packet's last event's time, if any, or to the packet's
1262 * beginning time otherwise.
1263 * - If it's not the stream file's last packet: set the packet index
1264 * entry's end time to the next packet's beginning time.
1265 *
1266 * Affected versions:
1267 * - All current and future lttng-ust and lttng-modules versions.
1268 */
1269 static int fix_index_lttng_crash_quirk(struct ctf_fs_trace *trace)
1270 {
1271 int ret = 0;
1272
1273 for (const auto& ds_file_group : trace->ds_file_groups) {
1274 struct ctf_clock_class *default_cc;
1275
1276 BT_ASSERT(ds_file_group);
1277 const auto index = ds_file_group->index.get();
1278
1279 BT_ASSERT(ds_file_group->sc->default_clock_class);
1280 default_cc = ds_file_group->sc->default_clock_class;
1281
1282 BT_ASSERT(index);
1283 BT_ASSERT(!index->entries.empty());
1284
1285 const auto last_entry = index->entries.back().get();
1286 BT_ASSERT(last_entry);
1287
1288 /* 1. Fix the last entry first. */
1289 if (last_entry->timestamp_end == 0 && last_entry->timestamp_begin != 0) {
1290 /*
1291 * Decode packet to read the timestamp of the
1292 * last event of the stream file.
1293 */
1294 ret = decode_packet_last_event_timestamp(trace, default_cc, last_entry,
1295 &last_entry->timestamp_end,
1296 &last_entry->timestamp_end_ns);
1297 if (ret) {
1298 BT_CPPLOGE_APPEND_CAUSE_SPEC(trace->logger,
1299 "Failed to decode last event's clock snapshot");
1300 goto end;
1301 }
1302 }
1303
1304 /* Iterate over all entries but the last one. */
1305 for (size_t entry_idx = 0; entry_idx < index->entries.size() - 1; ++entry_idx) {
1306 ctf_fs_ds_index_entry *curr_entry = index->entries[entry_idx].get();
1307 ctf_fs_ds_index_entry *next_entry = index->entries[entry_idx + 1].get();
1308
1309 if (curr_entry->timestamp_end == 0 && curr_entry->timestamp_begin != 0) {
1310 /*
1311 * 2. Set the current index entry `end` timestamp to
1312 * the next index entry `begin` timestamp.
1313 */
1314 curr_entry->timestamp_end = next_entry->timestamp_begin;
1315 curr_entry->timestamp_end_ns = next_entry->timestamp_begin_ns;
1316 }
1317 }
1318 }
1319
1320 end:
1321 return ret;
1322 }
1323
1324 /*
1325 * Extract the tracer information necessary to compare versions.
1326 * Returns 0 on success, and -1 if the extraction is not successful because the
1327 * necessary fields are absents in the trace metadata.
1328 */
1329 static int extract_tracer_info(struct ctf_fs_trace *trace, struct tracer_info *current_tracer_info)
1330 {
1331 int ret = 0;
1332 struct ctf_trace_class_env_entry *entry;
1333
1334 /* Clear the current_tracer_info struct */
1335 memset(current_tracer_info, 0, sizeof(*current_tracer_info));
1336
1337 /*
1338 * To compare 2 tracer versions, at least the tracer name and it's
1339 * major version are needed. If one of these is missing, consider it an
1340 * extraction failure.
1341 */
1342 entry = ctf_trace_class_borrow_env_entry_by_name(trace->metadata->tc, "tracer_name");
1343 if (!entry || entry->type != CTF_TRACE_CLASS_ENV_ENTRY_TYPE_STR) {
1344 goto missing_bare_minimum;
1345 }
1346
1347 /* Set tracer name. */
1348 current_tracer_info->name = entry->value.str->str;
1349
1350 entry = ctf_trace_class_borrow_env_entry_by_name(trace->metadata->tc, "tracer_major");
1351 if (!entry || entry->type != CTF_TRACE_CLASS_ENV_ENTRY_TYPE_INT) {
1352 goto missing_bare_minimum;
1353 }
1354
1355 /* Set major version number. */
1356 current_tracer_info->major = entry->value.i;
1357
1358 entry = ctf_trace_class_borrow_env_entry_by_name(trace->metadata->tc, "tracer_minor");
1359 if (!entry || entry->type != CTF_TRACE_CLASS_ENV_ENTRY_TYPE_INT) {
1360 goto end;
1361 }
1362
1363 /* Set minor version number. */
1364 current_tracer_info->minor = entry->value.i;
1365
1366 entry = ctf_trace_class_borrow_env_entry_by_name(trace->metadata->tc, "tracer_patch");
1367 if (!entry) {
1368 /*
1369 * If `tracer_patch` doesn't exist `tracer_patchlevel` might.
1370 * For example, `lttng-modules` uses entry name
1371 * `tracer_patchlevel`.
1372 */
1373 entry = ctf_trace_class_borrow_env_entry_by_name(trace->metadata->tc, "tracer_patchlevel");
1374 }
1375
1376 if (!entry || entry->type != CTF_TRACE_CLASS_ENV_ENTRY_TYPE_INT) {
1377 goto end;
1378 }
1379
1380 /* Set patch version number. */
1381 current_tracer_info->patch = entry->value.i;
1382
1383 goto end;
1384
1385 missing_bare_minimum:
1386 ret = -1;
1387 end:
1388 return ret;
1389 }
1390
1391 static bool is_tracer_affected_by_lttng_event_after_packet_bug(struct tracer_info *curr_tracer_info)
1392 {
1393 bool is_affected = false;
1394
1395 if (strcmp(curr_tracer_info->name, "lttng-ust") == 0) {
1396 if (curr_tracer_info->major < 2) {
1397 is_affected = true;
1398 } else if (curr_tracer_info->major == 2) {
1399 /* fixed in lttng-ust 2.11.0 */
1400 if (curr_tracer_info->minor < 11) {
1401 is_affected = true;
1402 }
1403 }
1404 } else if (strcmp(curr_tracer_info->name, "lttng-modules") == 0) {
1405 if (curr_tracer_info->major < 2) {
1406 is_affected = true;
1407 } else if (curr_tracer_info->major == 2) {
1408 /* fixed in lttng-modules 2.11.0 */
1409 if (curr_tracer_info->minor == 10) {
1410 /* fixed in lttng-modules 2.10.10 */
1411 if (curr_tracer_info->patch < 10) {
1412 is_affected = true;
1413 }
1414 } else if (curr_tracer_info->minor == 9) {
1415 /* fixed in lttng-modules 2.9.13 */
1416 if (curr_tracer_info->patch < 13) {
1417 is_affected = true;
1418 }
1419 } else if (curr_tracer_info->minor < 9) {
1420 is_affected = true;
1421 }
1422 }
1423 }
1424
1425 return is_affected;
1426 }
1427
1428 static bool
1429 is_tracer_affected_by_barectf_event_before_packet_bug(struct tracer_info *curr_tracer_info)
1430 {
1431 bool is_affected = false;
1432
1433 if (strcmp(curr_tracer_info->name, "barectf") == 0) {
1434 if (curr_tracer_info->major < 2) {
1435 is_affected = true;
1436 } else if (curr_tracer_info->major == 2) {
1437 if (curr_tracer_info->minor < 3) {
1438 is_affected = true;
1439 } else if (curr_tracer_info->minor == 3) {
1440 /* fixed in barectf 2.3.1 */
1441 if (curr_tracer_info->patch < 1) {
1442 is_affected = true;
1443 }
1444 }
1445 }
1446 }
1447
1448 return is_affected;
1449 }
1450
1451 static bool is_tracer_affected_by_lttng_crash_quirk(struct tracer_info *curr_tracer_info)
1452 {
1453 bool is_affected = false;
1454
1455 /* All LTTng tracer may be affected by this lttng crash quirk. */
1456 if (strcmp(curr_tracer_info->name, "lttng-ust") == 0) {
1457 is_affected = true;
1458 } else if (strcmp(curr_tracer_info->name, "lttng-modules") == 0) {
1459 is_affected = true;
1460 }
1461
1462 return is_affected;
1463 }
1464
1465 /*
1466 * Looks for trace produced by known buggy tracers and fix up the index
1467 * produced earlier.
1468 */
1469 static int fix_packet_index_tracer_bugs(ctf_fs_trace *trace)
1470 {
1471 int ret = 0;
1472 struct tracer_info current_tracer_info;
1473
1474 ret = extract_tracer_info(trace, &current_tracer_info);
1475 if (ret) {
1476 /*
1477 * A trace may not have all the necessary environment
1478 * entries to do the tracer version comparison.
1479 * At least, the tracer name and major version number
1480 * are needed. Failing to extract these entries is not
1481 * an error.
1482 */
1483 ret = 0;
1484 BT_CPPLOGI_STR_SPEC(
1485 trace->logger,
1486 "Cannot extract tracer information necessary to compare with buggy versions.");
1487 goto end;
1488 }
1489
1490 /* Check if the trace may be affected by old tracer bugs. */
1491 if (is_tracer_affected_by_lttng_event_after_packet_bug(&current_tracer_info)) {
1492 BT_CPPLOGI_STR_SPEC(
1493 trace->logger,
1494 "Trace may be affected by LTTng tracer packet timestamp bug. Fixing up.");
1495 ret = fix_index_lttng_event_after_packet_bug(trace);
1496 if (ret) {
1497 BT_CPPLOGE_APPEND_CAUSE_SPEC(trace->logger,
1498 "Failed to fix LTTng event-after-packet bug.");
1499 goto end;
1500 }
1501 trace->metadata->tc->quirks.lttng_event_after_packet = true;
1502 }
1503
1504 if (is_tracer_affected_by_barectf_event_before_packet_bug(&current_tracer_info)) {
1505 BT_CPPLOGI_STR_SPEC(
1506 trace->logger,
1507 "Trace may be affected by barectf tracer packet timestamp bug. Fixing up.");
1508 ret = fix_index_barectf_event_before_packet_bug(trace);
1509 if (ret) {
1510 BT_CPPLOGE_APPEND_CAUSE_SPEC(trace->logger,
1511 "Failed to fix barectf event-before-packet bug.");
1512 goto end;
1513 }
1514 trace->metadata->tc->quirks.barectf_event_before_packet = true;
1515 }
1516
1517 if (is_tracer_affected_by_lttng_crash_quirk(&current_tracer_info)) {
1518 ret = fix_index_lttng_crash_quirk(trace);
1519 if (ret) {
1520 BT_CPPLOGE_APPEND_CAUSE_SPEC(trace->logger,
1521 "Failed to fix lttng-crash timestamp quirks.");
1522 goto end;
1523 }
1524 trace->metadata->tc->quirks.lttng_crash = true;
1525 }
1526
1527 end:
1528 return ret;
1529 }
1530
1531 static bool compare_ds_file_groups_by_first_path(const ctf_fs_ds_file_group::UP& ds_file_group_a,
1532 const ctf_fs_ds_file_group::UP& ds_file_group_b)
1533 {
1534 BT_ASSERT(!ds_file_group_a->ds_file_infos.empty());
1535 BT_ASSERT(!ds_file_group_b->ds_file_infos.empty());
1536
1537 const auto& first_ds_file_info_a = *ds_file_group_a->ds_file_infos[0];
1538 const auto& first_ds_file_info_b = *ds_file_group_b->ds_file_infos[0];
1539
1540 return first_ds_file_info_a.path < first_ds_file_info_b.path;
1541 }
1542
1543 int ctf_fs_component_create_ctf_fs_trace(struct ctf_fs_component *ctf_fs,
1544 const bt_value *paths_value,
1545 const bt_value *trace_name_value,
1546 bt_self_component *selfComp)
1547 {
1548 int ret = 0;
1549 std::vector<std::string> paths;
1550 std::vector<ctf_fs_trace::UP> traces;
1551 const char *trace_name;
1552
1553 BT_ASSERT(bt_value_get_type(paths_value) == BT_VALUE_TYPE_ARRAY);
1554 BT_ASSERT(!bt_value_array_is_empty(paths_value));
1555
1556 trace_name = trace_name_value ? bt_value_string_get(trace_name_value) : NULL;
1557
1558 /*
1559 * Create a sorted array of the paths, to make the execution of this
1560 * component deterministic.
1561 */
1562 for (std::uint64_t i = 0; i < bt_value_array_get_length(paths_value); i++) {
1563 const bt_value *path_value = bt_value_array_borrow_element_by_index_const(paths_value, i);
1564 const char *input = bt_value_string_get(path_value);
1565 paths.emplace_back(input);
1566 }
1567
1568 std::sort(paths.begin(), paths.end());
1569
1570 /* Create a separate ctf_fs_trace object for each path. */
1571 for (const auto& path : paths) {
1572 ret = ctf_fs_component_create_ctf_fs_trace_one_path(ctf_fs, path.c_str(), trace_name,
1573 traces, selfComp);
1574 if (ret) {
1575 goto end;
1576 }
1577 }
1578
1579 if (traces.size() > 1) {
1580 ctf_fs_trace *first_trace = traces[0].get();
1581 const uint8_t *first_trace_uuid = first_trace->metadata->tc->uuid;
1582
1583 /*
1584 * We have more than one trace, they must all share the same
1585 * UUID, verify that.
1586 */
1587 for (size_t i = 0; i < traces.size(); i++) {
1588 ctf_fs_trace *this_trace = traces[i].get();
1589 const uint8_t *this_trace_uuid = this_trace->metadata->tc->uuid;
1590
1591 if (!this_trace->metadata->tc->is_uuid_set) {
1592 BT_CPPLOGE_APPEND_CAUSE_SPEC(
1593 ctf_fs->logger,
1594 "Multiple traces given, but a trace does not have a UUID: path={}",
1595 this_trace->path);
1596 goto error;
1597 }
1598
1599 if (bt_uuid_compare(first_trace_uuid, this_trace_uuid) != 0) {
1600 char first_trace_uuid_str[BT_UUID_STR_LEN + 1];
1601 char this_trace_uuid_str[BT_UUID_STR_LEN + 1];
1602
1603 bt_uuid_to_str(first_trace_uuid, first_trace_uuid_str);
1604 bt_uuid_to_str(this_trace_uuid, this_trace_uuid_str);
1605
1606 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs->logger,
1607 "Multiple traces given, but UUIDs don't match: "
1608 "first-trace-uuid={}, first-trace-path={}, "
1609 "trace-uuid={}, trace-path={}",
1610 first_trace_uuid_str, first_trace->path,
1611 this_trace_uuid_str, this_trace->path);
1612 goto error;
1613 }
1614 }
1615
1616 ret = merge_ctf_fs_traces(std::move(traces), ctf_fs->trace);
1617 if (ret) {
1618 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs->logger,
1619 "Failed to merge traces with the same UUID.");
1620 goto error;
1621 }
1622 } else {
1623 /* Just one trace, it may or may not have a UUID, both are fine. */
1624 ctf_fs->trace = std::move(traces[0]);
1625 }
1626
1627 ret = fix_packet_index_tracer_bugs(ctf_fs->trace.get());
1628 if (ret) {
1629 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs->logger, "Failed to fix packet index tracer bugs.");
1630 }
1631
1632 /*
1633 * Sort data stream file groups by first data stream file info
1634 * path to get a deterministic order. This order influences the
1635 * order of the output ports. It also influences the order of
1636 * the automatic stream IDs if the trace's packet headers do not
1637 * contain a `stream_instance_id` field, in which case the data
1638 * stream file to stream ID association is always the same,
1639 * whatever the build and the system.
1640 *
1641 * Having a deterministic order here can help debugging and
1642 * testing.
1643 */
1644 std::sort(ctf_fs->trace->ds_file_groups.begin(), ctf_fs->trace->ds_file_groups.end(),
1645 compare_ds_file_groups_by_first_path);
1646 goto end;
1647
1648 error:
1649 ret = -1;
1650
1651 end:
1652 return ret;
1653 }
1654
1655 static const std::string&
1656 get_stream_instance_unique_name(struct ctf_fs_ds_file_group *ds_file_group)
1657 {
1658 /*
1659 * The first (earliest) stream file's path is used as the stream's unique
1660 * name.
1661 */
1662 BT_ASSERT(!ds_file_group->ds_file_infos.empty());
1663 return ds_file_group->ds_file_infos[0]->path;
1664 }
1665
1666 /* Create the IR stream objects for ctf_fs_trace. */
1667
1668 static int create_streams_for_trace(struct ctf_fs_trace *ctf_fs_trace)
1669 {
1670 int ret;
1671
1672 for (const auto& ds_file_group : ctf_fs_trace->ds_file_groups) {
1673 const std::string& name = get_stream_instance_unique_name(ds_file_group.get());
1674
1675 BT_ASSERT(ds_file_group->sc->ir_sc);
1676 BT_ASSERT(ctf_fs_trace->trace);
1677
1678 bt_stream *stream;
1679
1680 if (ds_file_group->stream_id == UINT64_C(-1)) {
1681 /* No stream ID: use 0 */
1682 stream =
1683 bt_stream_create_with_id(ds_file_group->sc->ir_sc, ctf_fs_trace->trace->libObjPtr(),
1684 ctf_fs_trace->next_stream_id);
1685 ctf_fs_trace->next_stream_id++;
1686 } else {
1687 /* Specific stream ID */
1688 stream =
1689 bt_stream_create_with_id(ds_file_group->sc->ir_sc, ctf_fs_trace->trace->libObjPtr(),
1690 (uint64_t) ds_file_group->stream_id);
1691 }
1692
1693 if (!stream) {
1694 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs_trace->logger,
1695 "Cannot create stream for DS file group: "
1696 "addr={}, stream-name=\"{}\"",
1697 fmt::ptr(ds_file_group), name);
1698 goto error;
1699 }
1700
1701 ds_file_group->stream = bt2::Stream::Shared::createWithoutRef(stream);
1702
1703 ret = bt_stream_set_name(ds_file_group->stream->libObjPtr(), name.c_str());
1704 if (ret) {
1705 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs_trace->logger,
1706 "Cannot set stream's name: "
1707 "addr={}, stream-name=\"{}\"",
1708 fmt::ptr(ds_file_group->stream->libObjPtr()), name);
1709 goto error;
1710 }
1711 }
1712
1713 ret = 0;
1714 goto end;
1715
1716 error:
1717 ret = -1;
1718
1719 end:
1720 return ret;
1721 }
1722
1723 static const bt_param_validation_value_descr inputs_elem_descr =
1724 bt_param_validation_value_descr::makeString();
1725
1726 static bt_param_validation_map_value_entry_descr fs_params_entries_descr[] = {
1727 {"inputs", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_MANDATORY,
1728 bt_param_validation_value_descr::makeArray(1, BT_PARAM_VALIDATION_INFINITE,
1729 inputs_elem_descr)},
1730 {"trace-name", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL,
1731 bt_param_validation_value_descr::makeString()},
1732 {"clock-class-offset-s", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL,
1733 bt_param_validation_value_descr::makeSignedInteger()},
1734 {"clock-class-offset-ns", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL,
1735 bt_param_validation_value_descr::makeSignedInteger()},
1736 {"force-clock-class-origin-unix-epoch", BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_OPTIONAL,
1737 bt_param_validation_value_descr::makeBool()},
1738 BT_PARAM_VALIDATION_MAP_VALUE_ENTRY_END};
1739
1740 bool read_src_fs_parameters(const bt_value *params, const bt_value **inputs,
1741 const bt_value **trace_name, struct ctf_fs_component *ctf_fs)
1742 {
1743 bool ret;
1744 const bt_value *value;
1745 enum bt_param_validation_status validate_value_status;
1746 gchar *error = NULL;
1747
1748 validate_value_status = bt_param_validation_validate(params, fs_params_entries_descr, &error);
1749 if (validate_value_status != BT_PARAM_VALIDATION_STATUS_OK) {
1750 BT_CPPLOGE_APPEND_CAUSE_SPEC(ctf_fs->logger, "{}", error);
1751 ret = false;
1752 goto end;
1753 }
1754
1755 /* inputs parameter */
1756 *inputs = bt_value_map_borrow_entry_value_const(params, "inputs");
1757
1758 /* clock-class-offset-s parameter */
1759 value = bt_value_map_borrow_entry_value_const(params, "clock-class-offset-s");
1760 if (value) {
1761 ctf_fs->clkClsCfg.offsetSec = bt_value_integer_signed_get(value);
1762 }
1763
1764 /* clock-class-offset-ns parameter */
1765 value = bt_value_map_borrow_entry_value_const(params, "clock-class-offset-ns");
1766 if (value) {
1767 ctf_fs->clkClsCfg.offsetNanoSec = bt_value_integer_signed_get(value);
1768 }
1769
1770 /* force-clock-class-origin-unix-epoch parameter */
1771 value = bt_value_map_borrow_entry_value_const(params, "force-clock-class-origin-unix-epoch");
1772 if (value) {
1773 ctf_fs->clkClsCfg.forceOriginIsUnixEpoch = bt_value_bool_get(value);
1774 }
1775
1776 /* trace-name parameter */
1777 *trace_name = bt_value_map_borrow_entry_value_const(params, "trace-name");
1778
1779 ret = true;
1780
1781 end:
1782 g_free(error);
1783 return ret;
1784 }
1785
1786 static ctf_fs_component::UP ctf_fs_create(const bt_value *params,
1787 bt_self_component_source *self_comp_src)
1788 {
1789 const bt_value *inputs_value;
1790 const bt_value *trace_name_value;
1791 bt_self_component *self_comp = bt_self_component_source_as_self_component(self_comp_src);
1792
1793 ctf_fs_component::UP ctf_fs = ctf_fs_component_create(
1794 bt2c::Logger {bt2::SelfSourceComponent {self_comp_src}, "PLUGIN/SRC.CTF.FS/COMP"});
1795 if (!ctf_fs) {
1796 return nullptr;
1797 }
1798
1799 if (!read_src_fs_parameters(params, &inputs_value, &trace_name_value, ctf_fs.get())) {
1800 return nullptr;
1801 }
1802
1803 if (ctf_fs_component_create_ctf_fs_trace(ctf_fs.get(), inputs_value, trace_name_value,
1804 self_comp)) {
1805 return nullptr;
1806 }
1807
1808 if (create_streams_for_trace(ctf_fs->trace.get())) {
1809 return nullptr;
1810 }
1811
1812 if (create_ports_for_trace(ctf_fs.get(), ctf_fs->trace.get(), self_comp_src)) {
1813 return nullptr;
1814 }
1815
1816 return ctf_fs;
1817 }
1818
1819 bt_component_class_initialize_method_status ctf_fs_init(bt_self_component_source *self_comp_src,
1820 bt_self_component_source_configuration *,
1821 const bt_value *params, void *)
1822 {
1823 try {
1824 bt_component_class_initialize_method_status ret =
1825 BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_OK;
1826
1827 ctf_fs_component::UP ctf_fs = ctf_fs_create(params, self_comp_src);
1828 if (!ctf_fs) {
1829 ret = BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_ERROR;
1830 }
1831
1832 bt_self_component_set_data(bt_self_component_source_as_self_component(self_comp_src),
1833 ctf_fs.release());
1834 return ret;
1835 } catch (const std::bad_alloc&) {
1836 return BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_MEMORY_ERROR;
1837 } catch (const bt2::Error&) {
1838 return BT_COMPONENT_CLASS_INITIALIZE_METHOD_STATUS_ERROR;
1839 }
1840 }
1841
1842 bt_component_class_query_method_status ctf_fs_query(bt_self_component_class_source *comp_class_src,
1843 bt_private_query_executor *priv_query_exec,
1844 const char *object, const bt_value *params,
1845 __attribute__((unused)) void *method_data,
1846 const bt_value **result)
1847 {
1848 try {
1849 bt2c::Logger logger {bt2::SelfComponentClass {comp_class_src},
1850 bt2::PrivateQueryExecutor {priv_query_exec},
1851 "PLUGIN/SRC.CTF.FS/QUERY"};
1852 bt2::ConstMapValue paramsObj(params);
1853 bt2::Value::Shared resultObj;
1854
1855 if (strcmp(object, "metadata-info") == 0) {
1856 resultObj = metadata_info_query(paramsObj, logger);
1857 } else if (strcmp(object, "babeltrace.trace-infos") == 0) {
1858 resultObj = trace_infos_query(paramsObj, logger);
1859 } else if (!strcmp(object, "babeltrace.support-info")) {
1860 resultObj = support_info_query(paramsObj, logger);
1861 } else {
1862 BT_CPPLOGE_SPEC(logger, "Unknown query object `{}`", object);
1863 return BT_COMPONENT_CLASS_QUERY_METHOD_STATUS_UNKNOWN_OBJECT;
1864 }
1865
1866 *result = resultObj.release().libObjPtr();
1867
1868 return BT_COMPONENT_CLASS_QUERY_METHOD_STATUS_OK;
1869 } catch (const std::bad_alloc&) {
1870 return BT_COMPONENT_CLASS_QUERY_METHOD_STATUS_MEMORY_ERROR;
1871 } catch (const bt2::Error&) {
1872 return BT_COMPONENT_CLASS_QUERY_METHOD_STATUS_ERROR;
1873 }
1874 }
This page took 0.063398 seconds and 3 git commands to generate.