From 44aba00375f0a3b8cd8d698d305b480d3dc33ca4 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Sebastian=20Dr=C3=B6ge?= <sebastian.droege@collabora.co.uk>
Date: Wed, 9 Dec 2009 09:51:20 +0100
Subject: [PATCH] assrender: Implement srcpad event functions for seeking and
 correct event forwarding

Copied from textoverlay.
---
 ext/assrender/gstassrender.c | 52 ++++++++++++++++++++++++++++++++++++
 1 file changed, 52 insertions(+)

diff --git a/ext/assrender/gstassrender.c b/ext/assrender/gstassrender.c
index 83b18f3b20..69b90e7448 100644
--- a/ext/assrender/gstassrender.c
+++ b/ext/assrender/gstassrender.c
@@ -105,6 +105,7 @@ static GstFlowReturn gst_ass_render_chain_text (GstPad * pad, GstBuffer * buf);
 
 static gboolean gst_ass_render_event_video (GstPad * pad, GstEvent * event);
 static gboolean gst_ass_render_event_text (GstPad * pad, GstEvent * event);
+static gboolean gst_ass_render_event_src (GstPad * pad, GstEvent * event);
 
 static void
 gst_ass_render_base_init (gpointer gclass)
@@ -199,6 +200,8 @@ gst_ass_render_init (GstAssRender * render, GstAssRenderClass * gclass)
       GST_DEBUG_FUNCPTR (gst_ass_render_event_video));
   gst_pad_set_event_function (render->text_sinkpad,
       GST_DEBUG_FUNCPTR (gst_ass_render_event_text));
+  gst_pad_set_event_function (render->srcpad,
+      GST_DEBUG_FUNCPTR (gst_ass_render_event_src));
 
   gst_element_add_pad (GST_ELEMENT (render), render->srcpad);
   gst_element_add_pad (GST_ELEMENT (render), render->video_sinkpad);
@@ -349,6 +352,55 @@ gst_ass_render_change_state (GstElement * element, GstStateChange transition)
   return ret;
 }
 
+static gboolean
+gst_ass_render_event_src (GstPad * pad, GstEvent * event)
+{
+  GstAssRender *render = GST_ASS_RENDER (gst_pad_get_parent (pad));
+  gboolean ret = FALSE;
+
+  switch (GST_EVENT_TYPE (event)) {
+    case GST_EVENT_SEEK:{
+      GstSeekFlags flags;
+
+      GST_DEBUG_OBJECT (render, "seek received, driving from here");
+
+      gst_event_parse_seek (event, NULL, NULL, &flags, NULL, NULL, NULL, NULL);
+
+      /* Flush downstream, only for flushing seek */
+      if (flags & GST_SEEK_FLAG_FLUSH)
+        gst_pad_push_event (render->srcpad, gst_event_new_flush_start ());
+
+      /* Mark subtitle as flushing, unblocks chains */
+      g_mutex_lock (render->subtitle_mutex);
+      if (render->subtitle_pending)
+        gst_buffer_unref (render->subtitle_pending);
+      render->subtitle_pending = NULL;
+      render->subtitle_flushing = TRUE;
+      g_cond_signal (render->subtitle_cond);
+      g_mutex_unlock (render->subtitle_mutex);
+
+      /* Seek on each sink pad */
+      gst_event_ref (event);
+      ret = gst_pad_push_event (render->video_sinkpad, event);
+      if (ret) {
+        ret = gst_pad_push_event (render->text_sinkpad, event);
+      } else {
+        gst_event_unref (event);
+      }
+      break;
+    }
+    default:
+      gst_event_ref (event);
+      ret = gst_pad_push_event (render->video_sinkpad, event);
+      gst_pad_push_event (render->text_sinkpad, event);
+      break;
+  }
+
+  gst_object_unref (render);
+
+  return ret;
+}
+
 static GstCaps *
 gst_ass_render_getcaps (GstPad * pad)
 {