mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-07-16 11:28:36 +00:00
9606e04895
In this mode we accept previously set filter caps until upstream renegotiates to something that is compatible to the current filter caps. This allows dynamic caps changes in the pipeline even if there is a queue between any conversion element and the capsfilter. Without this we would get not-negotiated errors if timing is bad. https://bugzilla.gnome.org/show_bug.cgi?id=739002
491 lines
16 KiB
C
491 lines
16 KiB
C
/* GStreamer unit test for capsfilter
|
|
* Copyright (C) <2008> Tim-Philipp Müller <tim centricular net>
|
|
*
|
|
* 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.
|
|
*/
|
|
|
|
#include <gst/check/gstcheck.h>
|
|
|
|
#define CAPS_TEMPLATE_STRING \
|
|
"audio/x-raw, " \
|
|
"channels = (int) [ 1, 2], " \
|
|
"rate = (int) [ 1, MAX ]"
|
|
|
|
static GstStaticPadTemplate sinktemplate = GST_STATIC_PAD_TEMPLATE ("sink",
|
|
GST_PAD_SINK,
|
|
GST_PAD_ALWAYS,
|
|
GST_STATIC_CAPS (CAPS_TEMPLATE_STRING)
|
|
);
|
|
|
|
static GstStaticPadTemplate srctemplate = GST_STATIC_PAD_TEMPLATE ("src",
|
|
GST_PAD_SRC,
|
|
GST_PAD_ALWAYS,
|
|
GST_STATIC_CAPS (CAPS_TEMPLATE_STRING)
|
|
);
|
|
|
|
static GstStaticPadTemplate any_sinktemplate = GST_STATIC_PAD_TEMPLATE ("sink",
|
|
GST_PAD_SINK,
|
|
GST_PAD_ALWAYS,
|
|
GST_STATIC_CAPS_ANY);
|
|
|
|
static GstStaticPadTemplate any_srctemplate = GST_STATIC_PAD_TEMPLATE ("src",
|
|
GST_PAD_SRC,
|
|
GST_PAD_ALWAYS,
|
|
GST_STATIC_CAPS_ANY);
|
|
|
|
static GList *events = NULL;
|
|
|
|
static gboolean
|
|
test_pad_eventfunc (GstPad * pad, GstObject * parent, GstEvent * event)
|
|
{
|
|
events = g_list_append (events, event);
|
|
return TRUE;
|
|
}
|
|
|
|
GST_START_TEST (test_unfixed_downstream_caps)
|
|
{
|
|
GstElement *pipe, *src, *filter;
|
|
GstCaps *filter_caps;
|
|
GstPad *mysinkpad;
|
|
GstMessage *msg;
|
|
|
|
pipe = gst_check_setup_element ("pipeline");
|
|
|
|
src = gst_check_setup_element ("fakesrc");
|
|
g_object_set (src, "sizetype", 2, "sizemax", 1024, "num-buffers", 1, NULL);
|
|
|
|
filter = gst_check_setup_element ("capsfilter");
|
|
filter_caps = gst_caps_from_string ("audio/x-raw, rate=(int)44100");
|
|
fail_unless (filter_caps != NULL);
|
|
g_object_set (filter, "caps", filter_caps, NULL);
|
|
|
|
gst_bin_add_many (GST_BIN (pipe), src, filter, NULL);
|
|
fail_unless (gst_element_link (src, filter));
|
|
|
|
mysinkpad = gst_check_setup_sink_pad (filter, &sinktemplate);
|
|
gst_pad_set_active (mysinkpad, TRUE);
|
|
|
|
fail_unless_equals_int (gst_element_set_state (pipe, GST_STATE_PLAYING),
|
|
GST_STATE_CHANGE_SUCCESS);
|
|
|
|
/* wait for error on bus */
|
|
msg = gst_bus_poll (GST_ELEMENT_BUS (pipe),
|
|
GST_MESSAGE_EOS | GST_MESSAGE_ERROR, -1);
|
|
|
|
fail_if (GST_MESSAGE_TYPE (msg) != GST_MESSAGE_ERROR,
|
|
"Expected ERROR message, got EOS message");
|
|
gst_message_unref (msg);
|
|
|
|
/* We don't expect any output buffers unless the check fails */
|
|
fail_unless (buffers == NULL);
|
|
|
|
/* cleanup */
|
|
GST_DEBUG ("cleanup");
|
|
|
|
gst_pad_set_active (mysinkpad, FALSE);
|
|
gst_check_teardown_sink_pad (filter);
|
|
gst_check_teardown_element (pipe);
|
|
gst_caps_unref (filter_caps);
|
|
}
|
|
|
|
GST_END_TEST;
|
|
|
|
GST_START_TEST (test_caps_property)
|
|
{
|
|
GstElement *filter;
|
|
GstCaps *filter_caps, *caps;
|
|
const gchar *caps_str;
|
|
|
|
filter = gst_check_setup_element ("capsfilter");
|
|
|
|
/* verify that the set caps are actually set */
|
|
caps_str = "audio/x-raw, rate=(int)44100, channels=(int)1";
|
|
|
|
filter_caps = gst_caps_from_string (caps_str);
|
|
fail_unless (GST_IS_CAPS (filter_caps));
|
|
g_object_set (filter, "caps", filter_caps, NULL);
|
|
|
|
g_object_get (filter, "caps", &caps, NULL);
|
|
fail_unless (gst_caps_is_equal (caps, filter_caps));
|
|
gst_caps_unref (caps);
|
|
gst_caps_unref (filter_caps);
|
|
|
|
/* verify that new caps set replace the old ones */
|
|
caps_str = "video/x-raw, width=(int)320, height=(int)240";
|
|
|
|
filter_caps = gst_caps_from_string (caps_str);
|
|
fail_unless (GST_IS_CAPS (filter_caps));
|
|
g_object_set (filter, "caps", filter_caps, NULL);
|
|
|
|
g_object_get (filter, "caps", &caps, NULL);
|
|
fail_unless (gst_caps_is_equal (caps, filter_caps));
|
|
gst_caps_unref (caps);
|
|
gst_caps_unref (filter_caps);
|
|
|
|
/* make sure that NULL caps is interpreted as ANY */
|
|
g_object_set (filter, "caps", NULL, NULL);
|
|
|
|
g_object_get (filter, "caps", &filter_caps, NULL);
|
|
fail_unless (gst_caps_is_any (filter_caps));
|
|
gst_caps_unref (filter_caps);
|
|
|
|
gst_object_unref (filter);
|
|
}
|
|
|
|
GST_END_TEST;
|
|
|
|
GST_START_TEST (test_caps_query)
|
|
{
|
|
GstElement *filter;
|
|
GstCaps *filter_caps;
|
|
const gchar *caps_str;
|
|
GstQuery *query;
|
|
GstCaps *caps;
|
|
|
|
filter = gst_check_setup_element ("capsfilter");
|
|
|
|
/* set some caps, do a caps query with a filter resulting in no
|
|
* intersecting caps */
|
|
caps_str = "audio/x-raw, rate=(int)44100, channels=(int)1";
|
|
|
|
filter_caps = gst_caps_from_string (caps_str);
|
|
fail_unless (GST_IS_CAPS (filter_caps));
|
|
g_object_set (filter, "caps", filter_caps, NULL);
|
|
gst_caps_unref (filter_caps);
|
|
|
|
caps_str = "video/x-raw, width=(int)320, height=(int)240";
|
|
filter_caps = gst_caps_from_string (caps_str);
|
|
query = gst_query_new_caps (filter_caps);
|
|
gst_caps_unref (filter_caps);
|
|
fail_unless (gst_element_query (filter, query));
|
|
gst_query_parse_caps_result (query, &caps);
|
|
fail_unless (gst_caps_is_empty (caps));
|
|
gst_query_unref (query);
|
|
|
|
gst_object_unref (filter);
|
|
}
|
|
|
|
GST_END_TEST;
|
|
|
|
GST_START_TEST (test_accept_caps_query)
|
|
{
|
|
GstElement *filter;
|
|
GstCaps *filter_caps;
|
|
const gchar *caps_str;
|
|
GstQuery *query;
|
|
gboolean accepted;
|
|
GstPad *sinkpad;
|
|
GstPad *srcpad;
|
|
|
|
filter = gst_check_setup_element ("capsfilter");
|
|
|
|
/* set some caps on (both pads of) the capsfilter */
|
|
caps_str = "audio/x-raw, rate=(int)44100, channels=(int)1";
|
|
|
|
filter_caps = gst_caps_from_string (caps_str);
|
|
fail_unless (GST_IS_CAPS (filter_caps));
|
|
g_object_set (filter, "caps", filter_caps, NULL);
|
|
gst_caps_unref (filter_caps);
|
|
|
|
sinkpad = gst_element_get_static_pad (filter, "sink");
|
|
|
|
/* check that the set caps are acceptable on the sinkpad */
|
|
caps_str = "audio/x-raw, rate=(int)44100, channels=(int)1";
|
|
filter_caps = gst_caps_from_string (caps_str);
|
|
query = gst_query_new_accept_caps (filter_caps);
|
|
gst_caps_unref (filter_caps);
|
|
fail_unless (gst_pad_query (sinkpad, query));
|
|
gst_query_parse_accept_caps_result (query, &accepted);
|
|
fail_unless (accepted);
|
|
gst_query_unref (query);
|
|
|
|
/* and that unrelated caps are not acceptable */
|
|
caps_str = "video/x-raw, width=(int)320, height=(int)240";
|
|
filter_caps = gst_caps_from_string (caps_str);
|
|
query = gst_query_new_accept_caps (filter_caps);
|
|
gst_caps_unref (filter_caps);
|
|
fail_unless (gst_pad_query (sinkpad, query));
|
|
gst_query_parse_accept_caps_result (query, &accepted);
|
|
fail_unless (!accepted);
|
|
gst_query_unref (query);
|
|
|
|
gst_object_unref (sinkpad);
|
|
|
|
/* now do the same for the src pad (which has the same caps) */
|
|
srcpad = gst_element_get_static_pad (filter, "src");
|
|
|
|
caps_str = "audio/x-raw, rate=(int)44100, channels=(int)1";
|
|
filter_caps = gst_caps_from_string (caps_str);
|
|
query = gst_query_new_accept_caps (filter_caps);
|
|
gst_caps_unref (filter_caps);
|
|
fail_unless (gst_pad_query (srcpad, query));
|
|
gst_query_parse_accept_caps_result (query, &accepted);
|
|
fail_unless (accepted);
|
|
gst_query_unref (query);
|
|
|
|
caps_str = "video/x-raw, width=(int)320, height=(int)240";
|
|
filter_caps = gst_caps_from_string (caps_str);
|
|
query = gst_query_new_accept_caps (filter_caps);
|
|
gst_caps_unref (filter_caps);
|
|
fail_unless (gst_pad_query (srcpad, query));
|
|
gst_query_parse_accept_caps_result (query, &accepted);
|
|
fail_unless (!accepted);
|
|
gst_query_unref (query);
|
|
|
|
gst_object_unref (srcpad);
|
|
|
|
gst_object_unref (filter);
|
|
}
|
|
|
|
GST_END_TEST;
|
|
|
|
GST_START_TEST (test_push_pending_events)
|
|
{
|
|
GstElement *filter;
|
|
GstPad *mysinkpad;
|
|
GstPad *mysrcpad;
|
|
GstSegment segment;
|
|
GstTagList *tags;
|
|
GstBuffer *buffer;
|
|
GstEvent *event;
|
|
GstCaps *caps;
|
|
|
|
filter = gst_check_setup_element ("capsfilter");
|
|
mysinkpad = gst_check_setup_sink_pad (filter, &sinktemplate);
|
|
gst_pad_set_event_function (mysinkpad, test_pad_eventfunc);
|
|
gst_pad_set_active (mysinkpad, TRUE);
|
|
mysrcpad = gst_check_setup_src_pad (filter, &srctemplate);
|
|
gst_pad_set_active (mysrcpad, TRUE);
|
|
|
|
fail_unless_equals_int (gst_element_set_state (filter, GST_STATE_PLAYING),
|
|
GST_STATE_CHANGE_SUCCESS);
|
|
|
|
/* push the stream start */
|
|
fail_unless (gst_pad_push_event (mysrcpad,
|
|
gst_event_new_stream_start ("test-stream")));
|
|
fail_unless (g_list_length (events) == 1);
|
|
event = events->data;
|
|
fail_unless (GST_EVENT_TYPE (event) == GST_EVENT_STREAM_START);
|
|
g_list_free_full (events, (GDestroyNotify) gst_event_unref);
|
|
events = NULL;
|
|
|
|
/* the tag should get trapped as we haven't pushed a caps yet */
|
|
tags = gst_tag_list_new (GST_TAG_COMMENT, "testcomment", NULL);
|
|
fail_unless (gst_pad_push_event (mysrcpad,
|
|
gst_event_new_tag (gst_tag_list_ref (tags))));
|
|
fail_unless (g_list_length (events) == 0);
|
|
|
|
/* push a caps */
|
|
caps = gst_caps_from_string ("audio/x-raw, "
|
|
"channels=(int)2, " "rate = (int)44100");
|
|
fail_unless (gst_pad_push_event (mysrcpad, gst_event_new_caps (caps)));
|
|
gst_caps_unref (caps);
|
|
fail_unless (g_list_length (events) == 1);
|
|
event = events->data;
|
|
fail_unless (GST_EVENT_TYPE (event) == GST_EVENT_CAPS);
|
|
g_list_free_full (events, (GDestroyNotify) gst_event_unref);
|
|
events = NULL;
|
|
|
|
/* push a segment */
|
|
gst_segment_init (&segment, GST_FORMAT_TIME);
|
|
fail_unless (gst_pad_push_event (mysrcpad, gst_event_new_segment (&segment)));
|
|
fail_unless (g_list_length (events) == 1);
|
|
event = events->data;
|
|
fail_unless (GST_EVENT_TYPE (event) == GST_EVENT_SEGMENT);
|
|
g_list_free_full (events, (GDestroyNotify) gst_event_unref);
|
|
events = NULL;
|
|
|
|
/* push a buffer, the tag should now be pushed downstream */
|
|
buffer = gst_buffer_new_wrapped (g_malloc0 (1024), 1024);
|
|
fail_unless (gst_pad_push (mysrcpad, buffer) == GST_FLOW_OK);
|
|
fail_unless (g_list_length (events) == 1);
|
|
event = events->data;
|
|
fail_unless (GST_EVENT_TYPE (event) == GST_EVENT_TAG);
|
|
g_list_free_full (events, (GDestroyNotify) gst_event_unref);
|
|
events = NULL;
|
|
|
|
/* We don't expect any output buffers unless the check fails */
|
|
fail_unless (g_list_length (buffers) == 1);
|
|
g_list_free_full (buffers, (GDestroyNotify) gst_buffer_unref);
|
|
buffers = NULL;
|
|
|
|
/* cleanup */
|
|
GST_DEBUG ("cleanup");
|
|
|
|
gst_pad_set_active (mysrcpad, FALSE);
|
|
gst_pad_set_active (mysinkpad, FALSE);
|
|
gst_check_teardown_src_pad (filter);
|
|
gst_check_teardown_sink_pad (filter);
|
|
gst_check_teardown_element (filter);
|
|
gst_tag_list_unref (tags);
|
|
}
|
|
|
|
GST_END_TEST;
|
|
|
|
GST_START_TEST (test_caps_change_mode_delayed)
|
|
{
|
|
GstElement *filter;
|
|
GstPad *mysinkpad;
|
|
GstPad *mysrcpad;
|
|
GstSegment segment;
|
|
GstEvent *event;
|
|
GstCaps *caps;
|
|
|
|
filter = gst_check_setup_element ("capsfilter");
|
|
mysinkpad = gst_check_setup_sink_pad (filter, &any_sinktemplate);
|
|
gst_pad_set_event_function (mysinkpad, test_pad_eventfunc);
|
|
gst_pad_set_active (mysinkpad, TRUE);
|
|
mysrcpad = gst_check_setup_src_pad (filter, &any_srctemplate);
|
|
gst_pad_set_active (mysrcpad, TRUE);
|
|
|
|
g_object_set (filter, "caps-change-mode", 1, NULL);
|
|
|
|
fail_unless_equals_int (gst_element_set_state (filter, GST_STATE_PLAYING),
|
|
GST_STATE_CHANGE_SUCCESS);
|
|
|
|
/* push the stream start */
|
|
fail_unless (gst_pad_push_event (mysrcpad,
|
|
gst_event_new_stream_start ("test-stream")));
|
|
fail_unless_equals_int (g_list_length (events), 1);
|
|
event = events->data;
|
|
fail_unless (GST_EVENT_TYPE (event) == GST_EVENT_STREAM_START);
|
|
g_list_free_full (events, (GDestroyNotify) gst_event_unref);
|
|
events = NULL;
|
|
|
|
/* push a caps */
|
|
caps = gst_caps_from_string ("audio/x-raw, "
|
|
"channels=(int)2, " "rate = (int)44100");
|
|
g_object_set (filter, "caps", caps, NULL);
|
|
fail_unless (gst_pad_push_event (mysrcpad, gst_event_new_caps (caps)));
|
|
gst_caps_unref (caps);
|
|
fail_unless_equals_int (g_list_length (events), 1);
|
|
event = events->data;
|
|
fail_unless (GST_EVENT_TYPE (event) == GST_EVENT_CAPS);
|
|
g_list_free_full (events, (GDestroyNotify) gst_event_unref);
|
|
events = NULL;
|
|
|
|
/* push a segment */
|
|
gst_segment_init (&segment, GST_FORMAT_TIME);
|
|
fail_unless (gst_pad_push_event (mysrcpad, gst_event_new_segment (&segment)));
|
|
fail_unless_equals_int (g_list_length (events), 1);
|
|
event = events->data;
|
|
fail_unless (GST_EVENT_TYPE (event) == GST_EVENT_SEGMENT);
|
|
g_list_free_full (events, (GDestroyNotify) gst_event_unref);
|
|
events = NULL;
|
|
|
|
/* push a buffer */
|
|
fail_unless_equals_int (gst_pad_push (mysrcpad,
|
|
gst_buffer_new_wrapped (g_malloc0 (1024), 1024)), GST_FLOW_OK);
|
|
fail_unless_equals_int (g_list_length (buffers), 1);
|
|
g_list_free_full (buffers, (GDestroyNotify) gst_buffer_unref);
|
|
buffers = NULL;
|
|
|
|
/* Set new incompatible caps */
|
|
caps = gst_caps_from_string ("audio/x-raw, "
|
|
"channels=(int)2, " "rate = (int)48000");
|
|
g_object_set (filter, "caps", caps, NULL);
|
|
|
|
/* push a buffer without updating the caps */
|
|
fail_unless_equals_int (gst_pad_push (mysrcpad,
|
|
gst_buffer_new_wrapped (g_malloc0 (1024), 1024)), GST_FLOW_OK);
|
|
fail_unless_equals_int (g_list_length (buffers), 1);
|
|
g_list_free_full (buffers, (GDestroyNotify) gst_buffer_unref);
|
|
buffers = NULL;
|
|
|
|
/* No caps event here, we're still at the old caps */
|
|
fail_unless (g_list_length (events) == 0);
|
|
|
|
fail_unless (gst_pad_push_event (mysrcpad, gst_event_new_caps (caps)));
|
|
gst_caps_unref (caps);
|
|
fail_unless_equals_int (g_list_length (events), 1);
|
|
event = events->data;
|
|
fail_unless (GST_EVENT_TYPE (event) == GST_EVENT_CAPS);
|
|
g_list_free_full (events, (GDestroyNotify) gst_event_unref);
|
|
events = NULL;
|
|
|
|
/* Push a new buffer, now we have the new caps */
|
|
fail_unless_equals_int (gst_pad_push (mysrcpad,
|
|
gst_buffer_new_wrapped (g_malloc0 (1024), 1024)), GST_FLOW_OK);
|
|
fail_unless_equals_int (g_list_length (buffers), 1);
|
|
g_list_free_full (buffers, (GDestroyNotify) gst_buffer_unref);
|
|
buffers = NULL;
|
|
|
|
/* Set back old caps */
|
|
caps = gst_caps_from_string ("audio/x-raw, "
|
|
"channels=(int)2, " "rate = (int)44100");
|
|
g_object_set (filter, "caps", caps, NULL);
|
|
gst_caps_unref (caps);
|
|
|
|
/* push a buffer without updating the caps */
|
|
fail_unless_equals_int (gst_pad_push (mysrcpad,
|
|
gst_buffer_new_wrapped (g_malloc0 (1024), 1024)), GST_FLOW_OK);
|
|
fail_unless_equals_int (g_list_length (buffers), 1);
|
|
g_list_free_full (buffers, (GDestroyNotify) gst_buffer_unref);
|
|
buffers = NULL;
|
|
|
|
/* Now set new caps again but the old caps are currently pushed */
|
|
caps = gst_caps_from_string ("audio/x-raw, "
|
|
"channels=(int)2, " "rate = (int)48000");
|
|
g_object_set (filter, "caps", caps, NULL);
|
|
gst_caps_unref (caps);
|
|
/* Race condition simulation here! */
|
|
caps = gst_caps_from_string ("audio/x-raw, "
|
|
"channels=(int)2, " "rate = (int)44100");
|
|
fail_unless (gst_pad_push_event (mysrcpad, gst_event_new_caps (caps)));
|
|
gst_caps_unref (caps);
|
|
fail_unless_equals_int (g_list_length (events), 1);
|
|
event = events->data;
|
|
fail_unless (GST_EVENT_TYPE (event) == GST_EVENT_CAPS);
|
|
g_list_free_full (events, (GDestroyNotify) gst_event_unref);
|
|
events = NULL;
|
|
|
|
fail_unless_equals_int (gst_pad_push (mysrcpad,
|
|
gst_buffer_new_wrapped (g_malloc0 (1024), 1024)), GST_FLOW_OK);
|
|
fail_unless_equals_int (g_list_length (buffers), 1);
|
|
g_list_free_full (buffers, (GDestroyNotify) gst_buffer_unref);
|
|
buffers = NULL;
|
|
|
|
/* cleanup */
|
|
GST_DEBUG ("cleanup");
|
|
|
|
gst_pad_set_active (mysrcpad, FALSE);
|
|
gst_pad_set_active (mysinkpad, FALSE);
|
|
gst_check_teardown_src_pad (filter);
|
|
gst_check_teardown_sink_pad (filter);
|
|
gst_check_teardown_element (filter);
|
|
}
|
|
|
|
GST_END_TEST;
|
|
|
|
static Suite *
|
|
capsfilter_suite (void)
|
|
{
|
|
Suite *s = suite_create ("capsfilter");
|
|
TCase *tc_chain = tcase_create ("general");
|
|
|
|
suite_add_tcase (s, tc_chain);
|
|
tcase_add_test (tc_chain, test_unfixed_downstream_caps);
|
|
tcase_add_test (tc_chain, test_caps_property);
|
|
tcase_add_test (tc_chain, test_caps_query);
|
|
tcase_add_test (tc_chain, test_accept_caps_query);
|
|
tcase_add_test (tc_chain, test_push_pending_events);
|
|
tcase_add_test (tc_chain, test_caps_change_mode_delayed);
|
|
|
|
return s;
|
|
}
|
|
|
|
GST_CHECK_MAIN (capsfilter)
|