X-Git-Url: http://git.efficios.com/?a=blobdiff_plain;f=plugins%2Fctf%2Ffs-src%2Ffs.h;h=c5c12fb4e6b22a13815053b5430bf59f4c73a982;hb=97ade20be9c0184f651dc247a19e68a11afdeab3;hp=a4b04f372002800fe02fcf7c644816cd67a2dee4;hpb=0bb3da025004205aa2c32812328030ac69b358a3;p=babeltrace.git diff --git a/plugins/ctf/fs-src/fs.h b/plugins/ctf/fs-src/fs.h index a4b04f37..c5c12fb4 100644 --- a/plugins/ctf/fs-src/fs.h +++ b/plugins/ctf/fs-src/fs.h @@ -33,6 +33,7 @@ #include #include #include "data-stream-file.h" +#include "metadata.h" BT_HIDDEN extern bool ctf_fs_debug; @@ -59,43 +60,6 @@ struct ctf_fs_metadata { int bo; }; -struct ctf_fs_ds_file_info { - GString *path; - uint64_t begin_ns; -}; - -struct ctf_fs_ds_file { - /* Owned by this */ - struct ctf_fs_file *file; - - /* Owned by this */ - struct bt_ctf_stream *stream; - - /* Owned by this */ - struct bt_clock_class_priority_map *cc_prio_map; - - /* Owned by this */ - struct bt_ctf_notif_iter *notif_iter; - - /* A stream is assumed to be indexed. */ - struct index index; - void *mmap_addr; - /* Max length of chunk to mmap() when updating the current mapping. */ - size_t mmap_max_len; - /* Length of the current mapping. */ - size_t mmap_len; - /* Length of the current mapping which *exists* in the backing file. */ - size_t mmap_valid_len; - /* Offset in the file where the current mapping starts. */ - off_t mmap_offset; - /* - * Offset, in the current mapping, of the address to return on the next - * request. - */ - off_t request_offset; - bool end_reached; -}; - struct ctf_fs_component_options { int64_t clock_offset; int64_t clock_offset_ns; @@ -173,23 +137,31 @@ enum bt_component_status ctf_fs_init(struct bt_private_component *source, BT_HIDDEN void ctf_fs_finalize(struct bt_private_component *component); -BT_HIDDEN -enum bt_notification_iterator_status ctf_fs_iterator_init( - struct bt_private_notification_iterator *it, - struct bt_private_port *port); - BT_HIDDEN struct bt_value *ctf_fs_query(struct bt_component_class *comp_class, const char *object, struct bt_value *params); +BT_HIDDEN +struct ctf_fs_trace *ctf_fs_trace_create(const char *path, const char *name, + struct metadata_overrides *overrides); + +BT_HIDDEN +void ctf_fs_trace_destroy(struct ctf_fs_trace *trace); + BT_HIDDEN int ctf_fs_find_traces(GList **trace_paths, const char *start_path); BT_HIDDEN GList *ctf_fs_create_trace_names(GList *trace_paths, const char *base_path); +BT_HIDDEN +enum bt_notification_iterator_status ctf_fs_iterator_init( + struct bt_private_notification_iterator *it, + struct bt_private_port *port); +BT_HIDDEN void ctf_fs_iterator_finalize(struct bt_private_notification_iterator *it); +BT_HIDDEN struct bt_notification_iterator_next_return ctf_fs_iterator_next( struct bt_private_notification_iterator *iterator);