From 5b702b894e5f7f8b1db5cbee92252404607328ff Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Sebastian=20Dr=C3=B6ge?= <slomo@circular-chaos.org>
Date: Tue, 23 Jul 2013 10:11:49 +0200
Subject: mssdemux: Add support for group-id in the stream-start event

---
 ext/smoothstreaming/gstmssdemux.c | 26 +++++++++++++++++++++++++-
 ext/smoothstreaming/gstmssdemux.h |  3 +++
 2 files changed, 28 insertions(+), 1 deletion(-)

diff --git a/ext/smoothstreaming/gstmssdemux.c b/ext/smoothstreaming/gstmssdemux.c
index 1cc3a59e8..8ee0ae69d 100644
--- a/ext/smoothstreaming/gstmssdemux.c
+++ b/ext/smoothstreaming/gstmssdemux.c
@@ -207,6 +207,9 @@ gst_mss_demux_init (GstMssDemux * mssdemux)
 
   mssdemux->data_queue_max_size = DEFAULT_MAX_QUEUE_SIZE_BUFFERS;
   mssdemux->bitrate_limit = DEFAULT_BITRATE_LIMIT;
+
+  mssdemux->have_group_id = FALSE;
+  mssdemux->group_id = G_MAXUINT;
 }
 
 static gboolean
@@ -337,6 +340,9 @@ gst_mss_demux_reset (GstMssDemux * mssdemux)
   mssdemux->base_url = NULL;
   g_free (mssdemux->manifest_uri);
   mssdemux->manifest_uri = NULL;
+
+  mssdemux->have_group_id = FALSE;
+  mssdemux->group_id = G_MAXUINT;
 }
 
 static void
@@ -819,6 +825,7 @@ gst_mss_demux_expose_stream (GstMssDemux * mssdemux, GstMssDemuxStream * stream)
 
   if (media_caps) {
     gchar *name = gst_pad_get_name (pad);
+    GstEvent *event;
     gchar *stream_id;
     gst_pad_set_active (pad, TRUE);
 
@@ -827,7 +834,24 @@ gst_mss_demux_expose_stream (GstMssDemux * mssdemux, GstMssDemuxStream * stream)
 
     stream_id =
         gst_pad_create_stream_id (pad, GST_ELEMENT_CAST (mssdemux), name);
-    gst_pad_push_event (pad, gst_event_new_stream_start (stream_id));
+
+    event =
+        gst_pad_get_sticky_event (mssdemux->sinkpad, GST_EVENT_STREAM_START, 0);
+    if (event) {
+      if (gst_event_parse_group_id (event, &mssdemux->group_id))
+        mssdemux->have_group_id = TRUE;
+      else
+        mssdemux->have_group_id = FALSE;
+      gst_event_unref (event);
+    } else if (!mssdemux->have_group_id) {
+      mssdemux->have_group_id = TRUE;
+      mssdemux->group_id = gst_util_group_id_next ();
+    }
+    event = gst_event_new_stream_start (stream_id);
+    if (mssdemux->have_group_id)
+      gst_event_set_group_id (event, mssdemux->group_id);
+
+    gst_pad_push_event (pad, event);
     g_free (stream_id);
     g_free (name);
 
diff --git a/ext/smoothstreaming/gstmssdemux.h b/ext/smoothstreaming/gstmssdemux.h
index c50260757..6bc3ba465 100644
--- a/ext/smoothstreaming/gstmssdemux.h
+++ b/ext/smoothstreaming/gstmssdemux.h
@@ -87,6 +87,9 @@ struct _GstMssDemux {
   /* pads */
   GstPad *sinkpad;
 
+  gboolean have_group_id;
+  guint group_id;
+
   GstBuffer *manifest_buffer;
 
   GstMssManifest *manifest;
-- 
cgit v1.2.1