X-Git-Url: http://git.efficios.com/?p=babeltrace.git;a=blobdiff_plain;f=plugins%2Fctf%2Ffs-sink%2Fwriter.c;h=e233a87da5ffa4d89da912a567fa57081b3dcea4;hp=56bab6e8f454670e8612127a5433466743bb9f71;hb=f384901f99784474c5c013dd16b4333d9125dfd5;hpb=f3168545b6b7501165eb94181b205b0d2afb6b19

diff --git a/plugins/ctf/fs-sink/writer.c b/plugins/ctf/fs-sink/writer.c
index 56bab6e8..e233a87d 100644
--- a/plugins/ctf/fs-sink/writer.c
+++ b/plugins/ctf/fs-sink/writer.c
@@ -191,6 +191,19 @@ enum bt_component_status handle_notification(
 		}
 		break;
 	}
+	case BT_NOTIFICATION_TYPE_STREAM_BEGIN:
+	{
+		struct bt_ctf_stream *stream =
+			bt_notification_stream_begin_get_stream(notification);
+
+		if (!stream) {
+			ret = BT_COMPONENT_STATUS_ERROR;
+			goto end;
+		}
+		ret = writer_stream_begin(writer_component, stream);
+		bt_put(stream);
+		break;
+	}
 	case BT_NOTIFICATION_TYPE_STREAM_END:
 	{
 		struct bt_ctf_stream *stream =
@@ -223,6 +236,7 @@ void writer_component_port_connected(
 		BT_NOTIFICATION_TYPE_EVENT,
 		BT_NOTIFICATION_TYPE_PACKET_BEGIN,
 		BT_NOTIFICATION_TYPE_PACKET_END,
+		BT_NOTIFICATION_TYPE_STREAM_BEGIN,
 		BT_NOTIFICATION_TYPE_STREAM_END,
 		BT_NOTIFICATION_TYPE_SENTINEL,
 	};