mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-11-27 04:01:08 +00:00
Code Issues 1 Projects Releases Wiki Activity

aggregator: rename buffers field to data

Browse source 
The queue stores buffers, events and queries.
This commit is contained in:
Stefan Sauer 2017-09-17 11:39:12 -07:00
parent 41a032470e
commit 54d44f31e3
1 changed files with 23 additions and 23 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

46
gst-libs/gst/base/gstaggregator.c
View file

@ -211,7 +211,7 @@ struct _GstAggregatorPadPrivate
gboolean first_buffer; gboolean first_buffer;
GQueue buffers; GQueue data; /* buffers, events and queries */
GstBuffer *clipped_buffer; GstBuffer *clipped_buffer;
guint num_buffers; guint num_buffers;
GstClockTime head_position; GstClockTime head_position;
@ -430,7 +430,7 @@ no_iter:
static gboolean static gboolean
gst_aggregator_pad_queue_is_empty (GstAggregatorPad * pad) gst_aggregator_pad_queue_is_empty (GstAggregatorPad * pad)
{ {
return (g_queue_peek_tail (&pad->priv->buffers) == NULL && return (g_queue_peek_tail (&pad->priv->data) == NULL &&
pad->priv->clipped_buffer == NULL); pad->priv->clipped_buffer == NULL);
} }
@ -766,11 +766,11 @@ check_events (GstAggregator * self, GstAggregatorPad * pad, gpointer user_data)
pad->priv->eos = TRUE; pad->priv->eos = TRUE;
} }
if (pad->priv->clipped_buffer == NULL && if (pad->priv->clipped_buffer == NULL &&
!GST_IS_BUFFER (g_queue_peek_tail (&pad->priv->buffers))) { !GST_IS_BUFFER (g_queue_peek_tail (&pad->priv->data))) {
if (GST_IS_EVENT (g_queue_peek_tail (&pad->priv->buffers))) if (GST_IS_EVENT (g_queue_peek_tail (&pad->priv->data)))
event = gst_event_ref (g_queue_peek_tail (&pad->priv->buffers)); event = gst_event_ref (g_queue_peek_tail (&pad->priv->data));
if (GST_IS_QUERY (g_queue_peek_tail (&pad->priv->buffers))) if (GST_IS_QUERY (g_queue_peek_tail (&pad->priv->data)))
query = g_queue_peek_tail (&pad->priv->buffers); query = g_queue_peek_tail (&pad->priv->data);
} }
PAD_UNLOCK (pad); PAD_UNLOCK (pad);
if (event || query) { if (event || query) {
@ -789,8 +789,8 @@ check_events (GstAggregator * self, GstAggregatorPad * pad, gpointer user_data)
PAD_LOCK (pad); PAD_LOCK (pad);
if (GST_EVENT_TYPE (event) == GST_EVENT_CAPS) if (GST_EVENT_TYPE (event) == GST_EVENT_CAPS)
pad->priv->negotiated = ret; pad->priv->negotiated = ret;
if (g_queue_peek_tail (&pad->priv->buffers) == event) if (g_queue_peek_tail (&pad->priv->data) == event)
gst_event_unref (g_queue_pop_tail (&pad->priv->buffers)); gst_event_unref (g_queue_pop_tail (&pad->priv->data));
gst_event_unref (event); gst_event_unref (event);
} }
@ -799,13 +799,13 @@ check_events (GstAggregator * self, GstAggregatorPad * pad, gpointer user_data)
ret = klass->sink_query (self, pad, query); ret = klass->sink_query (self, pad, query);
PAD_LOCK (pad); PAD_LOCK (pad);
if (g_queue_peek_tail (&pad->priv->buffers) == query) { if (g_queue_peek_tail (&pad->priv->data) == query) {
GstStructure *s; GstStructure *s;
s = gst_query_writable_structure (query); s = gst_query_writable_structure (query);
gst_structure_set (s, "gst-aggregator-retval", G_TYPE_BOOLEAN, ret, gst_structure_set (s, "gst-aggregator-retval", G_TYPE_BOOLEAN, ret,
NULL); NULL);
g_queue_pop_tail (&pad->priv->buffers); g_queue_pop_tail (&pad->priv->data);
} }
} }
@ -829,7 +829,7 @@ gst_aggregator_pad_set_flushing (GstAggregatorPad * aggpad,
else else
aggpad->priv->flow_return = flow_return; aggpad->priv->flow_return = flow_return;
item = g_queue_peek_head_link (&aggpad->priv->buffers); item = g_queue_peek_head_link (&aggpad->priv->data);
while (item) { while (item) {
GList *next = item->next; GList *next = item->next;
@ -842,7 +842,7 @@ gst_aggregator_pad_set_flushing (GstAggregatorPad * aggpad,
!GST_EVENT_IS_STICKY (item->data)) { !GST_EVENT_IS_STICKY (item->data)) {
if (!GST_IS_QUERY (item->data)) if (!GST_IS_QUERY (item->data))
gst_mini_object_unref (item->data); gst_mini_object_unref (item->data);
g_queue_delete_link (&aggpad->priv->buffers, item); g_queue_delete_link (&aggpad->priv->data, item);
} }
item = next; item = next;
} }
@ -1475,8 +1475,8 @@ gst_aggregator_default_sink_event (GstAggregator * self,
GST_BUFFER_FLAG_SET (gapbuf, GST_BUFFER_FLAG_DROPPABLE); GST_BUFFER_FLAG_SET (gapbuf, GST_BUFFER_FLAG_DROPPABLE);
/* Remove GAP event so we can replace it with the buffer */ /* Remove GAP event so we can replace it with the buffer */
if (g_queue_peek_tail (&aggpad->priv->buffers) == event) if (g_queue_peek_tail (&aggpad->priv->data) == event)
gst_event_unref (g_queue_pop_tail (&aggpad->priv->buffers)); gst_event_unref (g_queue_pop_tail (&aggpad->priv->data));
if (gst_aggregator_pad_chain_internal (self, aggpad, gapbuf, FALSE) != if (gst_aggregator_pad_chain_internal (self, aggpad, gapbuf, FALSE) !=
GST_FLOW_OK) { GST_FLOW_OK) {
@ -2523,9 +2523,9 @@ gst_aggregator_pad_chain_internal (GstAggregator * self,
if (gst_aggregator_pad_has_space (self, aggpad) if (gst_aggregator_pad_has_space (self, aggpad)
&& aggpad->priv->flow_return == GST_FLOW_OK) { && aggpad->priv->flow_return == GST_FLOW_OK) {
if (head) if (head)
g_queue_push_head (&aggpad->priv->buffers, buffer); g_queue_push_head (&aggpad->priv->data, buffer);
else else
g_queue_push_tail (&aggpad->priv->buffers, buffer); g_queue_push_tail (&aggpad->priv->data, buffer);
apply_buffer (aggpad, buffer, head); apply_buffer (aggpad, buffer, head);
aggpad->priv->num_buffers++; aggpad->priv->num_buffers++;
buffer = NULL; buffer = NULL;
@ -2650,7 +2650,7 @@ gst_aggregator_pad_query_func (GstPad * pad, GstObject * parent,
goto flushing; goto flushing;
} }
g_queue_push_head (&aggpad->priv->buffers, query); g_queue_push_head (&aggpad->priv->data, query);
SRC_BROADCAST (self); SRC_BROADCAST (self);
SRC_UNLOCK (self); SRC_UNLOCK (self);
@ -2664,7 +2664,7 @@ gst_aggregator_pad_query_func (GstPad * pad, GstObject * parent,
if (gst_structure_get_boolean (s, "gst-aggregator-retval", &ret)) if (gst_structure_get_boolean (s, "gst-aggregator-retval", &ret))
gst_structure_remove_field (s, "gst-aggregator-retval"); gst_structure_remove_field (s, "gst-aggregator-retval");
else else
g_queue_remove (&aggpad->priv->buffers, query); g_queue_remove (&aggpad->priv->data, query);
if (aggpad->priv->flow_return != GST_FLOW_OK) if (aggpad->priv->flow_return != GST_FLOW_OK)
goto flushing; goto flushing;
@ -2715,7 +2715,7 @@ gst_aggregator_pad_event_func (GstPad * pad, GstObject * parent,
if (GST_EVENT_TYPE (event) != GST_EVENT_FLUSH_STOP) { if (GST_EVENT_TYPE (event) != GST_EVENT_FLUSH_STOP) {
GST_DEBUG_OBJECT (aggpad, "Store event in queue: %" GST_PTR_FORMAT, GST_DEBUG_OBJECT (aggpad, "Store event in queue: %" GST_PTR_FORMAT,
event); event);
g_queue_push_head (&aggpad->priv->buffers, event); g_queue_push_head (&aggpad->priv->data, event);
event = NULL; event = NULL;
SRC_BROADCAST (self); SRC_BROADCAST (self);
} }
@ -2828,7 +2828,7 @@ gst_aggregator_pad_init (GstAggregatorPad * pad)
G_TYPE_INSTANCE_GET_PRIVATE (pad, GST_TYPE_AGGREGATOR_PAD, G_TYPE_INSTANCE_GET_PRIVATE (pad, GST_TYPE_AGGREGATOR_PAD,
GstAggregatorPadPrivate); GstAggregatorPadPrivate);
g_queue_init (&pad->priv->buffers); g_queue_init (&pad->priv->data);
g_cond_init (&pad->priv->event_cond); g_cond_init (&pad->priv->event_cond);
g_mutex_init (&pad->priv->flush_lock); g_mutex_init (&pad->priv->flush_lock);
@ -2860,8 +2860,8 @@ gst_aggregator_pad_clip_buffer_unlocked (GstAggregatorPad * pad)
GstBuffer *buffer = NULL; GstBuffer *buffer = NULL;
while (pad->priv->clipped_buffer == NULL && while (pad->priv->clipped_buffer == NULL &&
GST_IS_BUFFER (g_queue_peek_tail (&pad->priv->buffers))) { GST_IS_BUFFER (g_queue_peek_tail (&pad->priv->data))) {
buffer = g_queue_pop_tail (&pad->priv->buffers); buffer = g_queue_pop_tail (&pad->priv->data);
apply_buffer (pad, buffer, FALSE); apply_buffer (pad, buffer, FALSE);