subparse: ignore old segment event

- ignore the old segment event and return directly
  to avoid the deadlock
- additional patch of below commit:
  cc741d036ff84451132025cdc9c3e8c3920be7b4

Change-Id: I57e895a4335abe4d7e84ee3ad47966c536c3e1eb

diff --git a/gst/subparse/gstsubparse.c b/gst/subparse/gstsubparse.c
index 5e4bb0bef4117b82e138434e9f1c72cd8050af4d..3fd1d9d5609ea50dc3cb92880633b7ca06f60632 100644 (file)
--- a/gst/subparse/gstsubparse.c
+++ b/gst/subparse/gstsubparse.c
@@ -40,6 +40,13 @@
 
 GST_DEBUG_CATEGORY (sub_parse_debug);
 
+#ifdef TIZEN_FEATURE_SUBPARSE_MODIFICATION
+#define SUBPARSE_SEEK_GET_LOCK(elem)    (&elem->seek_lock)
+#define SUBPARSE_SEEK_LOCK(elem)        g_mutex_lock(SUBPARSE_SEEK_GET_LOCK(elem))
+#define SUBPARSE_SEEK_TRYLOCK(elem)     g_mutex_trylock(SUBPARSE_SEEK_GET_LOCK(elem))
+#define SUBPARSE_SEEK_UNLOCK(elem)      g_mutex_unlock(SUBPARSE_SEEK_GET_LOCK(elem))
+#endif
+
 #define DEFAULT_ENCODING   NULL
 #define ATTRIBUTE_REGEX "\\s?[a-zA-Z0-9\\. \t\\(\\)]*"
 static const gchar *allowed_srt_tags[] = { "i", "b", "u", NULL };
@@ -297,7 +304,7 @@ gst_sub_parse_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
       }
 
 #ifdef TIZEN_FEATURE_SUBPARSE_MODIFICATION
-      g_mutex_lock (&self->seek_lock);
+      SUBPARSE_SEEK_LOCK (self);
 #endif
       /* Convert that seek to a seeking in bytes at position 0,
          FIXME: could use an index */
@@ -318,7 +325,7 @@ gst_sub_parse_src_event (GstPad * pad, GstObject * parent, GstEvent * event)
       }
 
 #ifdef TIZEN_FEATURE_SUBPARSE_MODIFICATION
-      g_mutex_unlock (&self->seek_lock);
+      SUBPARSE_SEEK_UNLOCK (self);
 #endif
 
       gst_event_unref (event);
@@ -1949,6 +1956,17 @@ gst_sub_parse_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
     case GST_EVENT_SEGMENT:
     {
       const GstSegment *s;
+
+#ifdef TIZEN_FEATURE_SUBPARSE_MODIFICATION
+      if (!SUBPARSE_SEEK_TRYLOCK (self)) {
+        /* new seeking request is in process */
+        GST_WARNING_OBJECT (self, "ignore the old newsegment event");
+        ret = TRUE;
+        gst_event_unref (event);
+        break;
+      }
+#endif
+
       gst_event_parse_segment (event, &s);
       if (s->format == GST_FORMAT_TIME)
         gst_event_copy_segment (event, &self->segment);
@@ -1968,12 +1986,11 @@ gst_sub_parse_sink_event (GstPad * pad, GstObject * parent, GstEvent * event)
       /* in either case, let's not simply discard this event;
        * trigger sending of the saved requested seek segment
        * or the one taken here from upstream */
-#ifdef TIZEN_FEATURE_SUBPARSE_MODIFICATION
-      g_mutex_lock (&self->seek_lock);
-      self->need_segment = TRUE; /* upstream */
-      g_mutex_unlock (&self->seek_lock);
-#else
+
       self->need_segment = TRUE; /* upstream */
+
+#ifdef TIZEN_FEATURE_SUBPARSE_MODIFICATION
+      SUBPARSE_SEEK_UNLOCK (self);
 #endif
 
       break;