add end of stream notification

[babeltrace.git] / plugins / ctf / fs / fs.c

diff --git a/plugins/ctf/fs/fs.c b/plugins/ctf/fs/fs.c
index 6c7f2030b994a01c0a73a2b643916971c11b68b1..cf00fddd9986c2aa288d0b2e222d0d65342f3a1b 100644 (file)
--- a/plugins/ctf/fs/fs.c
+++ b/plugins/ctf/fs/fs.c
@@ -41,14 +41,52 @@ static
 struct bt_notification *ctf_fs_iterator_get(
                struct bt_notification_iterator *iterator)
 {
-       return NULL;
+       struct bt_notification *notification = NULL;
+       struct ctf_fs_component *ctf_fs;
+       struct bt_component *component = bt_notification_iterator_get_component(
+                       iterator);
+
+       if (!component) {
+               goto end;
+       }
+
+       ctf_fs = bt_component_get_private_data(component);
+       if (!ctf_fs) {
+               goto end;
+       }
+
+       notification = bt_get(ctf_fs->current_notification);
+end:
+       return notification;
 }
 
 static
 enum bt_notification_iterator_status ctf_fs_iterator_next(
                struct bt_notification_iterator *iterator)
 {
-       return BT_NOTIFICATION_ITERATOR_STATUS_UNSUPPORTED;
+       enum bt_notification_iterator_status ret;
+       struct bt_notification *notification = NULL;
+       struct ctf_fs_component *ctf_fs;
+       struct bt_component *component = bt_notification_iterator_get_component(
+                       iterator);
+
+       if (!component) {
+               ret = BT_NOTIFICATION_ITERATOR_STATUS_ERROR;
+               goto end;
+       }
+
+       ctf_fs = bt_component_get_private_data(component);
+       assert(ctf_fs);
+
+       ret = ctf_fs_data_stream_get_next_notification(ctf_fs, &notification);
+       if (ret || !notification) {
+               goto end;
+       }
+
+       bt_put(ctf_fs->current_notification);
+       ctf_fs->current_notification = notification;
+end:
+       return ret;
 }
 
 static
@@ -116,6 +154,7 @@ void ctf_fs_destroy_data(struct ctf_fs_component *component)
 
        ctf_fs_metadata_fini(&component->metadata);
        ctf_fs_data_stream_fini(&component->data_stream);
+       BT_PUT(component->current_notification);
        g_free(component);
 }
 
@@ -131,7 +170,7 @@ static
 struct ctf_fs_component *ctf_fs_create(struct bt_value *params)
 {
        struct ctf_fs_component *ctf_fs;
-       struct bt_value *value;
+       struct bt_value *value = NULL;
        const char *path;
        enum bt_value_status ret;
 
@@ -161,10 +200,12 @@ struct ctf_fs_component *ctf_fs_create(struct bt_value *params)
        ctf_fs_data_stream_init(ctf_fs, &ctf_fs->data_stream);
        ctf_fs_metadata_set_trace(ctf_fs);
        ctf_fs_data_stream_open_streams(ctf_fs);
-end:
-       return ctf_fs;
+       goto end;
+
 error:
        ctf_fs_destroy_data(ctf_fs);
+end:
+       BT_PUT(value);
        return ctf_fs;
 }
 
@@ -198,7 +239,6 @@ enum bt_component_status ctf_fs_init(struct bt_component *source,
        if (ret != BT_COMPONENT_STATUS_OK) {
                goto error;
        }
-
 end:
        return ret;
 error: