element, GstStateChange transition);
static gboolean gst_adaptive_demux_query (GstElement * element,
GstQuery * query);
+static gboolean gst_adaptive_demux_send_event (GstElement * element,
+ GstEvent * event);
static void gst_adaptive_demux_handle_message (GstBin * bin, GstMessage * msg);
GstQuery * query);
static gboolean gst_adaptive_demux_src_event (GstPad * pad, GstObject * parent,
GstEvent * event);
+static gboolean gst_adaptive_demux_handle_seek_event (GstAdaptiveDemux * demux,
+ GstEvent * event);
+static gboolean gst_adaptive_demux_handle_select_streams_event (GstAdaptiveDemux
+ * demux, GstEvent * event);
static gboolean
gst_adaptive_demux_push_src_event (GstAdaptiveDemux * demux, GstEvent * event);
gstelement_class->change_state = gst_adaptive_demux_change_state;
gstelement_class->query = gst_adaptive_demux_query;
+ gstelement_class->send_event = gst_adaptive_demux_send_event;
gstbin_class->handle_message = gst_adaptive_demux_handle_message;
return GST_ELEMENT_CLASS (parent_class)->query (element, query);
}
+static gboolean
+gst_adaptive_demux_send_event (GstElement * element, GstEvent * event)
+{
+ GstAdaptiveDemux *demux = GST_ADAPTIVE_DEMUX_CAST (element);
+ gboolean res = FALSE;
+
+ GST_DEBUG_OBJECT (demux, "Received event %" GST_PTR_FORMAT, event);
+
+ switch (GST_EVENT_TYPE (event)) {
+ case GST_EVENT_SEEK:
+ {
+ res = gst_adaptive_demux_handle_seek_event (demux, event);
+ break;
+ }
+ case GST_EVENT_SELECT_STREAMS:
+ {
+ res = gst_adaptive_demux_handle_select_streams_event (demux, event);
+ break;
+ }
+ default:
+ res = GST_ELEMENT_CLASS (parent_class)->send_event (element, event);
+ break;
+ }
+ return res;
+}
+
/* MANIFEST_LOCK held. Find the stream that owns the given element */
static GstAdaptiveDemux2Stream *
find_stream_for_element_locked (GstAdaptiveDemux * demux, GstObject * o)
}
static gboolean
+gst_adaptive_demux_handle_select_streams_event (GstAdaptiveDemux * demux,
+ GstEvent * event)
+{
+ GList *streams;
+ gboolean selection_handled;
+
+ if (GST_EVENT_SEQNUM (event) ==
+ g_atomic_int_get (&demux->priv->requested_selection_seqnum)) {
+ GST_DEBUG_OBJECT (demux, "Already handled/handling select-streams %d",
+ GST_EVENT_SEQNUM (event));
+ return TRUE;
+ }
+
+ gst_event_parse_select_streams (event, &streams);
+ selection_handled =
+ handle_stream_selection (demux, streams, GST_EVENT_SEQNUM (event));
+ g_list_free_full (streams, g_free);
+
+ gst_event_unref (event);
+ return selection_handled;
+}
+
+static gboolean
gst_adaptive_demux_src_event (GstPad * pad, GstObject * parent,
GstEvent * event)
{
}
case GST_EVENT_SELECT_STREAMS:
{
- GList *streams;
- gboolean selection_handled;
-
- if (GST_EVENT_SEQNUM (event) ==
- g_atomic_int_get (&demux->priv->requested_selection_seqnum)) {
- GST_DEBUG_OBJECT (demux, "Already handled/handling select-streams %d",
- GST_EVENT_SEQNUM (event));
- return TRUE;
- }
-
- gst_event_parse_select_streams (event, &streams);
- selection_handled =
- handle_stream_selection (demux, streams, GST_EVENT_SEQNUM (event));
- g_list_free_full (streams, g_free);
- return selection_handled;
+ return gst_adaptive_demux_handle_select_streams_event (demux, event);
}
default:
break;