mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-07-27 16:55:05 +00:00
b660f258a6
If gst_buffer_pool_set_config() fails then the pool will use its old config. This may include different width or height when pic_width/pic_height != frame_width/frame_height. As a result, the assertions in theora_handle_image() will fail. So check the result of gst_buffer_pool_set_config() and only use the pool if it succeeds. Otherwise let the parrent decide_allocation() create a new pool. Part-of: <https://gitlab.freedesktop.org/gstreamer/gstreamer/-/merge_requests/4600>
139 lines
4.2 KiB
C
139 lines
4.2 KiB
C
/* GStreamer
|
|
*
|
|
* Copyright (C) <2021> Michael Olbrich <m.olbrich@pengutronix.de>
|
|
*
|
|
* This library is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Library General Public
|
|
* License as published by the Free Software Foundation; either
|
|
* version 2 of the License, or (at your option) any later version.
|
|
*
|
|
* This library is distributed in the hope that it will be useful,
|
|
* but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* Library General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Library General Public
|
|
* License along with this library; if not, write to the
|
|
* Free Software Foundation, Inc., 51 Franklin St, Fifth Floor,
|
|
* Boston, MA 02110-1301, USA.
|
|
*/
|
|
#ifdef HAVE_CONFIG_H
|
|
#include "config.h"
|
|
#endif
|
|
|
|
#include <gst/video/video.h>
|
|
#include <gst/check/gstcheck.h>
|
|
|
|
static GstPadProbeReturn
|
|
query_handler (GstPad * pad, GstPadProbeInfo * info, gpointer user_data)
|
|
{
|
|
GstQuery *query = GST_PAD_PROBE_INFO_QUERY (info);
|
|
GstBufferPool *pool;
|
|
GstStructure *config;
|
|
GstVideoInfo vinfo;
|
|
GstCaps *caps;
|
|
|
|
if (GST_QUERY_TYPE (query) != GST_QUERY_ALLOCATION)
|
|
return GST_PAD_PROBE_OK;
|
|
|
|
gst_query_parse_allocation (query, &caps, NULL);
|
|
fail_unless (caps != NULL);
|
|
|
|
gst_video_info_init (&vinfo);
|
|
gst_video_info_from_caps (&vinfo, caps);
|
|
|
|
pool = gst_video_buffer_pool_new ();
|
|
config = gst_buffer_pool_get_config (pool);
|
|
gst_buffer_pool_config_set_params (config, caps, vinfo.size, 0, 1);
|
|
gst_buffer_pool_set_config (pool, config);
|
|
/* activate the pool to ensure that gst_buffer_pool_set_config() will
|
|
* fail later */
|
|
gst_buffer_pool_set_active (pool, TRUE);
|
|
gst_query_add_allocation_pool (query, pool, vinfo.size, 0, 1);
|
|
gst_object_unref (pool);
|
|
gst_query_add_allocation_meta (query, GST_VIDEO_META_API_TYPE, NULL);
|
|
gst_query_add_allocation_meta (query, GST_VIDEO_CROP_META_API_TYPE, NULL);
|
|
|
|
return GST_PAD_PROBE_OK;
|
|
}
|
|
|
|
static void
|
|
demux_pad_added_cb (GstElement * dec, GstPad * pad, gpointer user_data)
|
|
{
|
|
GstElement *sink = user_data;
|
|
GstPad *sinkpad;
|
|
|
|
sinkpad = gst_element_get_static_pad (sink, "sink");
|
|
gst_pad_link (pad, sinkpad);
|
|
gst_object_unref (sinkpad);
|
|
}
|
|
|
|
GST_START_TEST (test_decide_allocation)
|
|
{
|
|
GstElement *pipe, *src, *demux, *decode, *sink;
|
|
GstStateChangeReturn sret;
|
|
GstMessage *msg;
|
|
GstPad *pad;
|
|
gchar *path;
|
|
|
|
pipe = gst_pipeline_new (NULL);
|
|
|
|
src = gst_element_factory_make ("filesrc", NULL);
|
|
fail_unless (src != NULL, "Failed to create filesrc element");
|
|
|
|
demux = gst_element_factory_make ("oggdemux", NULL);
|
|
fail_unless (demux != NULL, "Failed to create oggdemux element");
|
|
|
|
decode = gst_element_factory_make ("theoradec", NULL);
|
|
fail_unless (decode != NULL, "Failed to create theoradec element");
|
|
|
|
sink = gst_element_factory_make ("fakesink", NULL);
|
|
fail_unless (sink != NULL, "Failed to create fakesink element");
|
|
|
|
gst_bin_add_many (GST_BIN (pipe), src, demux, decode, sink, NULL);
|
|
gst_element_link (src, demux);
|
|
gst_element_link (decode, sink);
|
|
|
|
path = g_build_filename (GST_TEST_FILES_PATH, "theora.ogg", NULL);
|
|
g_object_set (src, "location", path, NULL);
|
|
g_free (path);
|
|
|
|
g_signal_connect (demux, "pad-added",
|
|
G_CALLBACK (demux_pad_added_cb), decode);
|
|
|
|
pad = gst_element_get_static_pad (decode, "src");
|
|
gst_pad_add_probe (pad, GST_PAD_PROBE_TYPE_QUERY_DOWNSTREAM,
|
|
query_handler, NULL, NULL);
|
|
gst_object_unref (pad);
|
|
|
|
sret = gst_element_set_state (pipe, GST_STATE_PLAYING);
|
|
fail_unless_equals_int (sret, GST_STATE_CHANGE_ASYNC);
|
|
|
|
/* wait for EOS or error */
|
|
msg = gst_bus_timed_pop_filtered (GST_ELEMENT_BUS (pipe),
|
|
GST_CLOCK_TIME_NONE, GST_MESSAGE_ERROR | GST_MESSAGE_EOS);
|
|
fail_unless (msg != NULL);
|
|
fail_unless (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_EOS);
|
|
gst_message_unref (msg);
|
|
|
|
gst_element_set_state (pipe, GST_STATE_NULL);
|
|
gst_object_unref (pipe);
|
|
}
|
|
|
|
GST_END_TEST;
|
|
|
|
|
|
static Suite *
|
|
theoradec_suite (void)
|
|
{
|
|
Suite *s = suite_create ("theoradec");
|
|
TCase *tc_chain = tcase_create ("general");
|
|
|
|
suite_add_tcase (s, tc_chain);
|
|
tcase_add_test (tc_chain, test_decide_allocation);
|
|
|
|
return s;
|
|
}
|
|
|
|
GST_CHECK_MAIN (theoradec);
|