mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-07-03 05:05:52 +00:00
Code Issues 1 Projects Releases Wiki Activity

basesrc: Send the stream-start event as first event ever

Browse source
This commit is contained in:
Sebastian Dröge 2012-01-27 10:41:07 +01:00
parent 9318934cf0
commit 0d4081fbbb
1 changed files with 21 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

21
libs/gst/base/gstbasesrc.c
View file

@ -212,6 +212,9 @@ struct _GstBaseSrcPrivate
GstFlowReturn start_result; GstFlowReturn start_result;
gboolean async; gboolean async;
/* if a stream-start event should be sent */
gboolean stream_start_pending;
/* if segment should be sent */ /* if segment should be sent */
gboolean segment_pending; gboolean segment_pending;
@ -830,6 +833,19 @@ gst_base_src_new_seamless_segment (GstBaseSrc * src, gint64 start, gint64 stop,
return res; return res;
} }
static gboolean
gst_base_src_send_stream_start (GstBaseSrc * src)
{
gboolean ret = TRUE;
if (src->priv->stream_start_pending) {
ret = gst_pad_push_event (src->srcpad, gst_event_new_stream_start ());
src->priv->stream_start_pending = FALSE;
}
return ret;
}
/** /**
* gst_base_src_set_caps: * gst_base_src_set_caps:
* @src: a #GstBaseSrc * @src: a #GstBaseSrc
@ -847,6 +863,7 @@ gst_base_src_set_caps (GstBaseSrc * src, GstCaps * caps)
bclass = GST_BASE_SRC_GET_CLASS (src); bclass = GST_BASE_SRC_GET_CLASS (src);
gst_base_src_send_stream_start (src);
gst_pad_push_event (src->srcpad, gst_event_new_caps (caps)); gst_pad_push_event (src->srcpad, gst_event_new_caps (caps));
if (bclass->set_caps) if (bclass->set_caps)
@ -2452,6 +2469,8 @@ gst_base_src_loop (GstPad * pad)
src = GST_BASE_SRC (GST_OBJECT_PARENT (pad)); src = GST_BASE_SRC (GST_OBJECT_PARENT (pad));
gst_base_src_send_stream_start (src);
/* check if we need to renegotiate */ /* check if we need to renegotiate */
if (gst_pad_check_reconfigure (pad)) { if (gst_pad_check_reconfigure (pad)) {
if (!gst_base_src_negotiate (src)) if (!gst_base_src_negotiate (src))
@ -3398,6 +3417,7 @@ gst_base_src_change_state (GstElement * element, GstStateChange transition)
case GST_STATE_CHANGE_NULL_TO_READY: case GST_STATE_CHANGE_NULL_TO_READY:
break; break;
case GST_STATE_CHANGE_READY_TO_PAUSED: case GST_STATE_CHANGE_READY_TO_PAUSED:
basesrc->priv->stream_start_pending = TRUE;
no_preroll = gst_base_src_is_live (basesrc); no_preroll = gst_base_src_is_live (basesrc);
break; break;
case GST_STATE_CHANGE_PAUSED_TO_PLAYING: case GST_STATE_CHANGE_PAUSED_TO_PLAYING:
@ -3431,6 +3451,7 @@ gst_base_src_change_state (GstElement * element, GstStateChange transition)
* already did this */ * already did this */
g_atomic_int_set (&basesrc->priv->pending_eos, FALSE); g_atomic_int_set (&basesrc->priv->pending_eos, FALSE);
gst_event_replace (&basesrc->pending_seek, NULL); gst_event_replace (&basesrc->pending_seek, NULL);
basesrc->priv->stream_start_pending = FALSE;
break; break;
} }
case GST_STATE_CHANGE_READY_TO_NULL: case GST_STATE_CHANGE_READY_TO_NULL: