add end of stream notification

[babeltrace.git] / plugins / ctf / common / notif-iter / notif-iter.c

diff --git a/plugins/ctf/common/notif-iter/notif-iter.c b/plugins/ctf/common/notif-iter/notif-iter.c
index ee4cd2be3acd2d4cd02ce5357a3b382d64bf7270..5de812b026bd36ecab472b36d1246e4231c8900a 100644 (file)
--- a/plugins/ctf/common/notif-iter/notif-iter.c
+++ b/plugins/ctf/common/notif-iter/notif-iter.c
@@ -1735,6 +1735,28 @@ end:
        BT_PUT(event);
 }
 
+static
+void notify_eos(struct bt_ctf_notif_iter *notit,
+               struct bt_notification **notification)
+{
+       struct bt_ctf_event *event;
+       struct bt_notification *ret = NULL;
+
+       /* Create event */
+       event = create_event(notit);
+       if (!event) {
+               goto end;
+       }
+
+       ret = bt_notification_stream_end_create(event);
+       if (!ret) {
+               goto end;
+       }
+       *notification = ret;
+end:
+       BT_PUT(event);
+}
+
 struct bt_ctf_notif_iter *bt_ctf_notif_iter_create(struct bt_ctf_trace *trace,
                size_t max_request_sz,
                struct bt_ctf_notif_iter_medium_ops medops,