From b5e7ed0428f872fb18cb123e95c39aaf468bd18f 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:09:38 +0200
Subject: [PATCH] resindvd: Add support for group-id in the stream-start event

---
 ext/resindvd/gstmpegdemux.c | 24 +++++++++++++++++++++++-
 ext/resindvd/gstmpegdemux.h |  3 +++
 2 files changed, 26 insertions(+), 1 deletion(-)

diff --git a/ext/resindvd/gstmpegdemux.c b/ext/resindvd/gstmpegdemux.c
index 1f2497802c..267c9f792c 100644
--- a/ext/resindvd/gstmpegdemux.c
+++ b/ext/resindvd/gstmpegdemux.c
@@ -228,6 +228,9 @@ gst_flups_demux_init (GstFluPSDemux * demux)
       g_malloc0 (sizeof (GstFluPSStream *) * (GST_FLUPS_DEMUX_MAX_STREAMS));
 
   demux->scr_adjust = GSTTIME_TO_MPEGTIME (SCR_MUNGE);
+
+  demux->have_group_id = FALSE;
+  demux->group_id = G_MAXUINT;
 }
 
 static void
@@ -262,6 +265,8 @@ gst_flups_demux_reset (GstFluPSDemux * demux)
 
   gst_event_replace (p_ev, NULL);
   demux->scr_adjust = GSTTIME_TO_MPEGTIME (SCR_MUNGE);
+  demux->have_group_id = FALSE;
+  demux->group_id = G_MAXUINT;
 }
 
 static GstFluPSStream *
@@ -273,6 +278,7 @@ gst_flups_demux_create_stream (GstFluPSDemux * demux, gint id, gint stream_type)
   GstFluPSDemuxClass *klass = GST_FLUPS_DEMUX_GET_CLASS (demux);
   GstCaps *caps;
   GstClockTime threshold = SEGMENT_THRESHOLD;
+  GstEvent *event;
   gchar *stream_id;
 
   name = NULL;
@@ -395,7 +401,23 @@ gst_flups_demux_create_stream (GstFluPSDemux * demux, gint id, gint stream_type)
   stream_id =
       gst_pad_create_stream_id_printf (stream->pad, GST_ELEMENT_CAST (demux),
       "%02x", id);
-  gst_pad_push_event (stream->pad, gst_event_new_stream_start (stream_id));
+
+  event = gst_pad_get_sticky_event (demux->sinkpad, GST_EVENT_STREAM_START, 0);
+  if (event) {
+    if (gst_event_parse_group_id (event, &demux->group_id))
+      demux->have_group_id = TRUE;
+    else
+      demux->have_group_id = FALSE;
+    gst_event_unref (event);
+  } else if (!demux->have_group_id) {
+    demux->have_group_id = TRUE;
+    demux->group_id = gst_util_group_id_next ();
+  }
+  event = gst_event_new_stream_start (stream_id);
+  if (demux->have_group_id)
+    gst_event_set_group_id (event, demux->group_id);
+
+  gst_pad_push_event (stream->pad, event);
   g_free (stream_id);
 
   gst_pad_set_caps (stream->pad, caps);
diff --git a/ext/resindvd/gstmpegdemux.h b/ext/resindvd/gstmpegdemux.h
index ed730c03ec..d2393e1e4e 100644
--- a/ext/resindvd/gstmpegdemux.h
+++ b/ext/resindvd/gstmpegdemux.h
@@ -99,6 +99,9 @@ struct _GstFluPSDemux {
   gboolean flushing;
   gboolean in_still;
 
+  gboolean have_group_id;
+  guint group_id;
+
   GstAdapter     * adapter;
   GstAdapter     * rev_adapter;
   guint64        adapter_offset;