mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-04-26 06:54:49 +00:00
Code Issues 1 Projects Releases Wiki Activity

aggregator: add more comments

Browse source
This commit is contained in:
Stefan Sauer 2017-11-01 15:18:08 +01:00 committed by Tim-Philipp Müller
parent 917214ed91
commit f51557dbc5
1 changed files with 6 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
libs/gst/base/gstaggregator.c
View file

@ -286,6 +286,8 @@ struct _GstAggregatorPrivate
/* Our state is >= PAUSED */ /* Our state is >= PAUSED */
gboolean running; /* protected by src_lock */ gboolean running; /* protected by src_lock */
/* seqnum from seek or segment,
* to be applied to synthetic segment/eos events */
gint seqnum; gint seqnum;
gboolean send_stream_start; /* protected by srcpad stream lock */ gboolean send_stream_start; /* protected by srcpad stream lock */
gboolean send_segment; gboolean send_segment;
@ -561,6 +563,8 @@ gst_aggregator_push_mandatory_events (GstAggregator * self)
segment = gst_event_new_segment (&self->segment); segment = gst_event_new_segment (&self->segment);
if (!self->priv->seqnum) if (!self->priv->seqnum)
/* This code-path is in preparation to be able to run without a source
* connected. Then we won't have a seq-num from a segment event. */
self->priv->seqnum = gst_event_get_seqnum (segment); self->priv->seqnum = gst_event_get_seqnum (segment);
else else
gst_event_set_seqnum (segment, self->priv->seqnum); gst_event_set_seqnum (segment, self->priv->seqnum);
@ -1103,6 +1107,8 @@ gst_aggregator_aggregate_func (GstAggregator * self)
gst_aggregator_iterate_sinkpads (self, gst_aggregator_do_events_and_queries, gst_aggregator_iterate_sinkpads (self, gst_aggregator_do_events_and_queries,
NULL); NULL);
/* Ensure we have buffers ready (either in clipped_buffer or at the head of
* the queue */
if (!gst_aggregator_wait_and_check (self, &timeout)) if (!gst_aggregator_wait_and_check (self, &timeout))
continue; continue;