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

aggregator: bring start/stop vfunc semantics in line with other baseclasses

Browse source 
Sub-class should not have to chain up to GstAggregator's start/stop
vfuncs, same as in GstBaseSrc, GstBaseSink, GstBaseTransform etc.
This commit is contained in:
Tim-Philipp Müller 2014-12-30 17:50:17 +00:00
parent a7e2a01098
commit 601554df70
1 changed files with 36 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -621,8 +621,11 @@ aggregate_func (GstAggregator * self)
} }
static gboolean static gboolean
_start (GstAggregator * self) gst_aggregator_start (GstAggregator * self)
{ {
GstAggregatorClass *klass;
gboolean result;
self->priv->running = TRUE; self->priv->running = TRUE;
self->priv->send_stream_start = TRUE; self->priv->send_stream_start = TRUE;
self->priv->send_segment = TRUE; self->priv->send_segment = TRUE;
@ -630,7 +633,14 @@ _start (GstAggregator * self)
self->priv->srccaps = NULL; self->priv->srccaps = NULL;
self->priv->flow_return = GST_FLOW_OK; self->priv->flow_return = GST_FLOW_OK;
return TRUE; klass = GST_AGGREGATOR_GET_CLASS (self);
if (klass->start)
result = klass->start (self);
else
result = TRUE;
return result;
} }
static gboolean static gboolean
@ -867,8 +877,11 @@ _stop_pad (GstAggregator * self, GstAggregatorPad * pad, gpointer unused_udata)
} }
static gboolean static gboolean
_stop (GstAggregator * agg) gst_aggregator_stop (GstAggregator * agg)
{ {
GstAggregatorClass *klass;
gboolean result;
_reset_flow_values (agg); _reset_flow_values (agg);
gst_aggregator_iterate_sinkpads (agg, gst_aggregator_iterate_sinkpads (agg,
@ -878,7 +891,14 @@ _stop (GstAggregator * agg)
gst_tag_list_unref (agg->priv->tags); gst_tag_list_unref (agg->priv->tags);
agg->priv->tags = NULL; agg->priv->tags = NULL;
return TRUE; klass = GST_AGGREGATOR_GET_CLASS (agg);
if (klass->stop)
result = klass->stop (agg);
else
result = TRUE;
return result;
} }
/* GstElement vmethods implementations */ /* GstElement vmethods implementations */
@ -887,12 +907,11 @@ _change_state (GstElement * element, GstStateChange transition)
{ {
GstStateChangeReturn ret; GstStateChangeReturn ret;
GstAggregator *self = GST_AGGREGATOR (element); GstAggregator *self = GST_AGGREGATOR (element);
GstAggregatorClass *agg_class = GST_AGGREGATOR_GET_CLASS (self);
switch (transition) { switch (transition) {
case GST_STATE_CHANGE_READY_TO_PAUSED: case GST_STATE_CHANGE_READY_TO_PAUSED:
agg_class->start (self); if (!gst_aggregator_start (self))
goto error_start;
break; break;
default: default:
break; break;
@ -906,7 +925,10 @@ _change_state (GstElement * element, GstStateChange transition)
switch (transition) { switch (transition) {
case GST_STATE_CHANGE_PAUSED_TO_READY: case GST_STATE_CHANGE_PAUSED_TO_READY:
agg_class->stop (self); if (!gst_aggregator_stop (self)) {
/* What to do in this case? Error out? */
GST_ERROR_OBJECT (self, "Subclass failed to stop.");
}
break; break;
default: default:
break; break;
@ -914,11 +936,17 @@ _change_state (GstElement * element, GstStateChange transition)
return ret; return ret;
/* ERRORS */
failure: failure:
{ {
GST_ERROR_OBJECT (element, "parent failed state change"); GST_ERROR_OBJECT (element, "parent failed state change");
return ret; return ret;
} }
error_start:
{
GST_ERROR_OBJECT (element, "Subclass failed to start");
return GST_STATE_CHANGE_FAILURE;
}
} }
static void static void
@ -1552,8 +1580,6 @@ gst_aggregator_class_init (GstAggregatorClass * klass)
GST_DEBUG_FG_MAGENTA, "GstAggregator"); GST_DEBUG_FG_MAGENTA, "GstAggregator");
klass->sinkpads_type = GST_TYPE_AGGREGATOR_PAD; klass->sinkpads_type = GST_TYPE_AGGREGATOR_PAD;
klass->start = _start;
klass->stop = _stop;
klass->sink_event = _sink_event; klass->sink_event = _sink_event;
klass->sink_query = _sink_query; klass->sink_query = _sink_query;