Rename correlator to muxer

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

diff --git a/plugins/ctf/fs/fs.c b/plugins/ctf/fs/fs.c
index 2e44c31723c3eddd6da0274f28a78257bc2b2375..b80e4e152095c4e3ed19a0abf80b72dc2fe3974b 100644 (file)
--- a/plugins/ctf/fs/fs.c
+++ b/plugins/ctf/fs/fs.c
@@ -57,6 +57,7 @@ struct bt_notification *ctf_fs_iterator_get(
 
        notification = bt_get(ctf_fs->current_notification);
 end:
+       BT_PUT(component);
        return notification;
 }
 
@@ -65,8 +66,7 @@ enum bt_notification_iterator_status ctf_fs_iterator_next(
                struct bt_notification_iterator *iterator)
 {
        enum bt_notification_iterator_status ret;
-       struct bt_ctf_notif_iter_notif *notification;
-//     struct bt_notification *notification = NULL;
+       struct bt_notification *notification = NULL;
        struct ctf_fs_component *ctf_fs;
        struct bt_component *component = bt_notification_iterator_get_component(
                        iterator);
@@ -84,35 +84,11 @@ enum bt_notification_iterator_status ctf_fs_iterator_next(
                goto end;
        }
 
-       switch (notification->type) {
-       case BT_CTF_NOTIF_ITER_NOTIF_NEW_PACKET:
-       {
-               struct bt_ctf_notif_iter_notif_new_packet *notif =
-                       (struct bt_ctf_notif_iter_notif_new_packet *) notification;
-               puts("<packet>");
-               break;
-       }
-       case BT_CTF_NOTIF_ITER_NOTIF_EVENT:
-       {
-               struct bt_ctf_notif_iter_notif_event *notif =
-                       (struct bt_ctf_notif_iter_notif_event *) notification;
-               puts("\tevent");
-               break;
-       }
-       case BT_CTF_NOTIF_ITER_NOTIF_END_OF_PACKET:
-       {
-               struct bt_ctf_notif_iter_notif_end_of_packet *notif =
-                       (struct bt_ctf_notif_iter_notif_end_of_packet *) notification;
-               puts("</packet>");
-               break;
-       }
-       default:
-               break;
-       }
-
-       bt_ctf_notif_iter_notif_destroy(notification);
+       bt_put(ctf_fs->current_notification);
+       ctf_fs->current_notification = notification;
 end:
-       return BT_NOTIFICATION_ITERATOR_STATUS_OK;
+       BT_PUT(component);
+       return ret;
 }
 
 static
@@ -265,7 +241,6 @@ enum bt_component_status ctf_fs_init(struct bt_component *source,
        if (ret != BT_COMPONENT_STATUS_OK) {
                goto error;
        }
-
 end:
        return ret;
 error: