mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2024-12-25 17:50:36 +00:00
Code Issues 1 Projects Releases Wiki Activity

aggregator: make GstAggregatorPadForeachFunc take an GstAggregatorPad

Browse source
This commit is contained in:
Tim-Philipp Müller 2014-12-30 19:22:01 +00:00
parent 601554df70
commit 9f417fb08e
2 changed files with 16 additions and 15 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -297,7 +297,7 @@ gst_aggregator_iterate_sinkpads (GstAggregator * self,
switch (gst_iterator_next (iter, &item)) {
case GST_ITERATOR_OK:
{
GstPad *pad;
GstAggregatorPad *pad;
pad = g_value_get_object (&item);
@ -307,8 +307,9 @@ gst_aggregator_iterate_sinkpads (GstAggregator * self,
break;
}
GST_LOG_OBJECT (self, "calling function on pad %s:%s",
GST_DEBUG_PAD_NAME (pad));
GST_LOG_OBJECT (pad, "calling function %s on pad",
GST_DEBUG_FUNCPTR_NAME (func));
result = func (self, pad, user_data);
done = !result;
@ -346,7 +347,7 @@ no_iter:
}
static inline gboolean
_check_all_pads_with_data_or_eos (GstAggregator * self,
gst_aggregator_check_all_pads_with_data_or_eos (GstAggregator * self,
GstAggregatorPad * aggpad, gpointer user_data)
{
if (aggpad->buffer || aggpad->eos) {
@ -498,8 +499,7 @@ _wait_and_check (GstAggregator * self, gboolean * timeout)
gst_aggregator_get_latency (self, &live, &latency_min, &latency_max);
if (gst_aggregator_iterate_sinkpads (self,
(GstAggregatorPadForeachFunc) _check_all_pads_with_data_or_eos,
NULL)) {
gst_aggregator_check_all_pads_with_data_or_eos, NULL)) {
GST_DEBUG_OBJECT (self, "all pads have data");
SRC_STREAM_UNLOCK (self);
@ -577,7 +577,7 @@ _wait_and_check (GstAggregator * self, gboolean * timeout)
}
res = gst_aggregator_iterate_sinkpads (self,
(GstAggregatorPadForeachFunc) _check_all_pads_with_data_or_eos, NULL);
gst_aggregator_check_all_pads_with_data_or_eos, NULL);
SRC_STREAM_UNLOCK (self);
return res;
@ -868,8 +868,9 @@ eat:
return res;
}
static gboolean
_stop_pad (GstAggregator * self, GstAggregatorPad * pad, gpointer unused_udata)
static inline gboolean
gst_aggregator_stop_pad (GstAggregator * self, GstAggregatorPad * pad,
gpointer unused_udata)
{
_aggpad_flush (pad, self);
@ -884,8 +885,7 @@ gst_aggregator_stop (GstAggregator * agg)
_reset_flow_values (agg);
gst_aggregator_iterate_sinkpads (agg,
(GstAggregatorPadForeachFunc) _stop_pad, NULL);
gst_aggregator_iterate_sinkpads (agg, gst_aggregator_stop_pad, NULL);
if (agg->priv->tags)
gst_tag_list_unref (agg->priv->tags);
@ -1722,7 +1722,7 @@ _chain (GstPad * pad, GstObject * object, GstBuffer * buffer)
SRC_STREAM_LOCK (self);
if (gst_aggregator_iterate_sinkpads (self,
(GstAggregatorPadForeachFunc) _check_all_pads_with_data_or_eos, NULL))
gst_aggregator_check_all_pads_with_data_or_eos, NULL))
SRC_STREAM_BROADCAST_UNLOCKED (self);
SRC_STREAM_UNLOCK (self);

7
libs/gst/base/gstaggregator.h
View file

@ -267,10 +267,11 @@ void gst_aggregator_set_latency (GstAggregator
GType gst_aggregator_get_type(void);
/* API that should eventually land in GstElement itself*/
typedef gboolean (*GstAggregatorPadForeachFunc) (GstAggregator * self,
GstPad * pad,
/* API that should eventually land in GstElement itself (FIXME) */
typedef gboolean (*GstAggregatorPadForeachFunc) (GstAggregator * aggregator,
GstAggregatorPad * aggregator_pad,
gpointer user_data);
gboolean gst_aggregator_iterate_sinkpads (GstAggregator * self,
GstAggregatorPadForeachFunc func,
gpointer user_data);