From: Wim Taymans Date: Tue, 15 Nov 2011 15:13:59 +0000 (+0100) Subject: utils: fix the proxy functions X-Git-Tag: RELEASE-0.11.2~439 X-Git-Url: http://review.tizen.org/git/?a=commitdiff_plain;h=0796586fcec361a58bc8acf7d2641c5b2eef23be;p=platform%2Fupstream%2Fgstreamer.git utils: fix the proxy functions fix the proxy functions for query_accept_caps and query_caps to use the pad forward helper functions which correctly forwards on the internally linked pads. --- diff --git a/gst/gstutils.c b/gst/gstutils.c index cc1134e..f82671b 100644 --- a/gst/gstutils.c +++ b/gst/gstutils.c @@ -2696,19 +2696,22 @@ gst_buffer_join (GstBuffer * buf1, GstBuffer * buf2) return result; } +typedef struct +{ + GstQuery *query; + gboolean ret; +} QueryAcceptCapsData; + static gboolean -query_accept_caps_fold_func (const GValue * vpad, GValue * ret, - GstQuery * query) +query_accept_caps_func (GstPad * pad, QueryAcceptCapsData * data) { - GstPad *pad = g_value_get_object (vpad); - gboolean result = TRUE; + if (G_LIKELY (gst_pad_peer_query (pad, data->query))) { + gboolean result; - if (G_LIKELY (gst_pad_peer_query (pad, query))) { - gst_query_parse_accept_caps_result (query, &result); - result &= g_value_get_boolean (ret); - g_value_set_boolean (ret, result); + gst_query_parse_accept_caps_result (data->query, &result); + data->ret &= result; } - return result; + return FALSE; } /** @@ -2729,9 +2732,7 @@ gboolean gst_pad_proxy_query_accept_caps (GstPad * pad, GstQuery * query) { GstElement *element; - GstIterator *iter; - GstIteratorResult res; - GValue ret = { 0, }; + QueryAcceptCapsData data; g_return_val_if_fail (GST_IS_PAD (pad), FALSE); g_return_val_if_fail (GST_IS_QUERY (query), FALSE); @@ -2744,43 +2745,15 @@ gst_pad_proxy_query_accept_caps (GstPad * pad, GstQuery * query) if (element == NULL) goto no_parent; + data.query = query; /* value to hold the return, by default it holds TRUE */ - g_value_init (&ret, G_TYPE_BOOLEAN); - g_value_set_boolean (&ret, TRUE); + data.ret = TRUE; - /* only iterate the pads in the oposite direction */ - if (GST_PAD_IS_SRC (pad)) - iter = gst_element_iterate_sink_pads (element); - else - iter = gst_element_iterate_src_pads (element); + gst_pad_forward (pad, (GstPadForwardFunction) query_accept_caps_func, &data); - while (1) { - res = - gst_iterator_fold (iter, - (GstIteratorFoldFunction) query_accept_caps_fold_func, &ret, query); - switch (res) { - case GST_ITERATOR_RESYNC: - /* need to reset the result again to TRUE */ - g_value_set_boolean (&ret, TRUE); - gst_iterator_resync (iter); - break; - case GST_ITERATOR_DONE: - /* all pads iterated, return collected value */ - goto done; - case GST_ITERATOR_OK: - /* premature exit (happens if caps intersection is empty) */ - goto done; - default: - /* iterator returned _ERROR, mark an error and exit */ - goto error; - } - } -done: - gst_iterator_free (iter); gst_object_unref (element); - gst_query_set_accept_caps_result (query, g_value_get_boolean (&ret)); - g_value_unset (&ret); + gst_query_set_accept_caps_result (query, data.ret); return TRUE; @@ -2790,37 +2763,34 @@ no_parent: GST_DEBUG_OBJECT (pad, "no parent"); return FALSE; } -error: - { - g_warning ("Pad list returned error on element %s", - GST_ELEMENT_NAME (element)); - gst_iterator_free (iter); - gst_object_unref (element); - return FALSE; - } } +typedef struct +{ + GstQuery *query; + GstCaps *ret; +} QueryCapsData; + static gboolean -query_caps_fold_func (const GValue * vpad, GValue * ret, GstQuery * query) +query_caps_func (GstPad * pad, QueryCapsData * data) { - GstPad *pad = g_value_get_object (vpad); gboolean empty = FALSE; - if (G_LIKELY (gst_pad_peer_query (pad, query))) { - GstCaps *existing, *peercaps, *intersection; - - existing = g_value_get_pointer (ret); - gst_query_parse_caps_result (query, &peercaps); + if (G_LIKELY (gst_pad_peer_query (pad, data->query))) { + GstCaps *peercaps, *intersection; + gst_query_parse_caps_result (data->query, &peercaps); GST_DEBUG_OBJECT (pad, "intersect with result %" GST_PTR_FORMAT, peercaps); - intersection = gst_caps_intersect (existing, peercaps); + intersection = gst_caps_intersect (data->ret, peercaps); GST_DEBUG_OBJECT (pad, "intersected %" GST_PTR_FORMAT, intersection); - empty = gst_caps_is_empty (intersection); - g_value_set_pointer (ret, intersection); - gst_caps_unref (existing); + gst_caps_unref (data->ret); + data->ret = intersection; + + /* stop when empty */ + empty = gst_caps_is_empty (intersection); } - return !empty; + return empty; } /** @@ -2840,12 +2810,9 @@ query_caps_fold_func (const GValue * vpad, GValue * ret, GstQuery * query) gboolean gst_pad_proxy_query_caps (GstPad * pad, GstQuery * query) { - gboolean result = TRUE; GstElement *element; - GstCaps *caps, *intersected; - GstIterator *iter; - GstIteratorResult res; - GValue ret = { 0, }; + GstCaps *intersected; + QueryCapsData data; g_return_val_if_fail (GST_IS_PAD (pad), FALSE); g_return_val_if_fail (GST_IS_QUERY (query), FALSE); @@ -2858,64 +2825,25 @@ gst_pad_proxy_query_caps (GstPad * pad, GstQuery * query) if (element == NULL) goto no_parent; - /* value to hold the return, by default it holds ANY, the ref is taken by - * the GValue. */ - g_value_init (&ret, G_TYPE_POINTER); - g_value_set_pointer (&ret, gst_caps_new_any ()); + data.query = query; + /* value to hold the return, by default it holds ANY */ + data.ret = gst_caps_new_any (); - /* only iterate the pads in the oposite direction */ - if (GST_PAD_IS_SRC (pad)) - iter = gst_element_iterate_sink_pads (element); - else - iter = gst_element_iterate_src_pads (element); - - while (1) { - res = - gst_iterator_fold (iter, (GstIteratorFoldFunction) query_caps_fold_func, - &ret, query); - switch (res) { - case GST_ITERATOR_RESYNC: - /* unref any value stored */ - if ((caps = g_value_get_pointer (&ret))) - gst_caps_unref (caps); - /* need to reset the result again to ANY */ - g_value_set_pointer (&ret, gst_caps_new_any ()); - gst_iterator_resync (iter); - break; - case GST_ITERATOR_DONE: - /* all pads iterated, return collected value */ - goto done; - case GST_ITERATOR_OK: - /* premature exit (happens if caps intersection is empty) */ - goto done; - default: - /* iterator returned _ERROR, mark an error and exit */ - if ((caps = g_value_get_pointer (&ret))) - gst_caps_unref (caps); - g_value_set_pointer (&ret, NULL); - goto error; - } - } -done: - gst_iterator_free (iter); + gst_pad_forward (pad, (GstPadForwardFunction) query_caps_func, &data); gst_object_unref (element); - caps = g_value_get_pointer (&ret); - g_value_unset (&ret); - - if (caps) { + if (data.ret) { intersected = - gst_caps_intersect (caps, gst_pad_get_pad_template_caps (pad)); - gst_caps_unref (caps); + gst_caps_intersect (data.ret, gst_pad_get_pad_template_caps (pad)); + gst_caps_unref (data.ret); } else { intersected = gst_caps_copy (gst_pad_get_pad_template_caps (pad)); } - gst_query_set_caps_result (query, intersected); gst_caps_unref (intersected); - return result; + return TRUE; /* ERRORS */ no_parent: @@ -2923,14 +2851,6 @@ no_parent: GST_DEBUG_OBJECT (pad, "no parent"); return FALSE; } -error: - { - g_warning ("Pad list returned error on element %s", - GST_ELEMENT_NAME (element)); - gst_iterator_free (iter); - gst_object_unref (element); - return FALSE; - } } /**