extern bool ctf_fs_debug;
struct ctf_fs_file {
+ bt_logging_level log_level;
+
+ /* Weak */
+ bt_self_component *self_comp;
+
/* Owned by this */
GString *path;
/* Weak (owned by `decoder` above) */
struct ctf_trace_class *tc;
- /* Owned by this */
-
/* Owned by this */
char *text;
};
struct ctf_fs_component {
- /* Weak, guaranteed to exist */
- bt_self_component_source *self_comp;
+ bt_logging_level log_level;
/* Array of struct ctf_fs_port_data *, owned by this */
GPtrArray *port_data;
};
struct ctf_fs_trace {
+ bt_logging_level log_level;
+
+ /* Weak */
+ bt_self_component *self_comp;
+
/* Owned by this */
struct ctf_fs_metadata *metadata;
};
struct ctf_fs_ds_index_entry {
+ /* Weak, belongs to ctf_fs_ds_file_info. */
+ const char *path;
+
/* Position, in bytes, of the packet from the beginning of the file. */
uint64_t offset;
};
struct ctf_fs_msg_iter_data {
+ bt_logging_level log_level;
+
+ /* Weak */
+ bt_self_component *self_comp;
+
/* Weak */
bt_self_message_iterator *pc_msg_iter;
};
BT_HIDDEN
-bt_self_component_status ctf_fs_init(
+bt_component_class_init_method_status ctf_fs_init(
bt_self_component_source *source,
const bt_value *params, void *init_method_data);
void ctf_fs_finalize(bt_self_component_source *component);
BT_HIDDEN
-bt_query_status ctf_fs_query(
+bt_component_class_query_method_status ctf_fs_query(
bt_self_component_class_source *comp_class,
- const bt_query_executor *query_exec,
+ bt_private_query_executor *priv_query_exec,
const char *object, const bt_value *params,
- const bt_value **result);
+ void *method_data, const bt_value **result);
BT_HIDDEN
-bt_self_message_iterator_status ctf_fs_iterator_init(
+bt_component_class_message_iterator_init_method_status ctf_fs_iterator_init(
bt_self_message_iterator *self_msg_iter,
bt_self_component_source *self_comp,
bt_self_component_port_output *self_port);
void ctf_fs_iterator_finalize(bt_self_message_iterator *it);
BT_HIDDEN
-bt_self_message_iterator_status ctf_fs_iterator_next(
+bt_component_class_message_iterator_next_method_status ctf_fs_iterator_next(
bt_self_message_iterator *iterator,
bt_message_array_const msgs, uint64_t capacity,
uint64_t *count);
BT_HIDDEN
-bt_self_message_iterator_status ctf_fs_iterator_seek_beginning(
+bt_component_class_message_iterator_seek_beginning_method_status ctf_fs_iterator_seek_beginning(
bt_self_message_iterator *message_iterator);
/* Create and initialize a new, empty ctf_fs_component. */
BT_HIDDEN
-struct ctf_fs_component *ctf_fs_component_create(void);
+struct ctf_fs_component *ctf_fs_component_create(bt_logging_level log_level,
+ bt_self_component *self_comp);
/*
* Search recursively under all paths in `paths_value` (an array of strings),
* for CTF traces. For each CTF trace found, create a ctf_fs_trace in
* `ctf_fs` representing that trace.
+ *
+ * `self_comp` and `self_comp_class` are used for logging, only one of them
+ * should be set.
*/
BT_HIDDEN
-int ctf_fs_component_create_ctf_fs_traces(bt_self_component_source *self_comp,
+int ctf_fs_component_create_ctf_fs_traces(
struct ctf_fs_component *ctf_fs,
- const bt_value *paths_value);
+ const bt_value *paths_value,
+ bt_self_component *self_comp,
+ bt_self_component_class *self_comp_class);
/* Free `ctf_fs` and everything it owns. */
* - The optional `clock-class-offset-s` and `clock-class-offset-ns`, if
* present, are recorded in the `ctf_fs` structure.
*
+ * `self_comp` and `self_comp_class` are used for logging, only one of them
+ * should be set.
+ *
* Return true on success, false if any parameter didn't pass validation.
*/
BT_HIDDEN
bool read_src_fs_parameters(const bt_value *params,
- const bt_value **paths, struct ctf_fs_component *ctf_fs);
+ const bt_value **paths, struct ctf_fs_component *ctf_fs,
+ bt_self_component *self_comp,
+ bt_self_component_class *self_comp_class);
/*
* Generate the port name to be used for a given data stream file group.