*/
#include <stdbool.h>
-#include <babeltrace/babeltrace-internal.h>
-#include <babeltrace/babeltrace.h>
+#include <babeltrace2/babeltrace-internal.h>
+#include <babeltrace2/babeltrace.h>
#include "data-stream-file.h"
#include "metadata.h"
#include "../common/metadata/decoder.h"
uint64_t next_stream_id;
};
+struct ctf_fs_ds_index_entry {
+ /* Position, in bytes, of the packet from the beginning of the file. */
+ uint64_t offset;
+
+ /* Size of the packet, in bytes. */
+ uint64_t packet_size;
+
+ /*
+ * Extracted from the packet context, relative to the respective fields'
+ * mapped clock classes (in cycles).
+ */
+ uint64_t timestamp_begin, timestamp_end;
+
+ /*
+ * Converted from the packet context, relative to the trace's EPOCH
+ * (in ns since EPOCH).
+ */
+ int64_t timestamp_begin_ns, timestamp_end_ns;
+};
+
+struct ctf_fs_ds_index {
+ /* Array of pointer to struct ctf_fs_fd_index_entry. */
+ GPtrArray *entries;
+};
+
struct ctf_fs_ds_file_group {
/*
* Array of struct ctf_fs_ds_file_info, owned by this.
/* Weak, belongs to component */
struct ctf_fs_trace *ctf_fs_trace;
+
+ /*
+ * Owned by this. May be NULL.
+ *
+ * A stream cannot be assumed to be indexed as the indexing might have
+ * been skipped. Moreover, the index's fields may not all be available
+ * depending on the producer (e.g. timestamp_begin/end are not
+ * mandatory).
+ */
+ struct ctf_fs_ds_index *index;
};
struct ctf_fs_port_data {
bool read_src_fs_parameters(const bt_value *params,
const bt_value **paths, struct ctf_fs_component *ctf_fs);
+/*
+ * Generate the port name to be used for a given data stream file group.
+ *
+ * The result must be freed using g_free by the caller.
+ */
+
+BT_HIDDEN
+gchar *ctf_fs_make_port_name(struct ctf_fs_ds_file_group *ds_file_group);
+
#endif /* BABELTRACE_PLUGIN_CTF_FS_H */