mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2025-01-19 13:55:41 +00:00
tee: split the allocation query test
Split the large allocation_query test into seperate tests. Add a setup helper to reduce code duplication. Fix the original test that used fail_unless instead of ck_assert_int_eq and had it accidentially working.
This commit is contained in:
parent
eb329eec1c
commit
e364d7944e
1 changed files with 89 additions and 33 deletions
|
@ -762,44 +762,43 @@ allocation_query_fail (GstPad * pad, GstObject * parent, GstQuery * query)
|
||||||
return FALSE;
|
return FALSE;
|
||||||
}
|
}
|
||||||
|
|
||||||
GST_START_TEST (test_allocation_query)
|
static void
|
||||||
|
add_sink_pad_and_setup_query_func (GstElement * tee,
|
||||||
|
GstPadQueryFunction query_func)
|
||||||
|
{
|
||||||
|
GstPad *sink;
|
||||||
|
static GstStaticPadTemplate sinktemplate = GST_STATIC_PAD_TEMPLATE ("sink",
|
||||||
|
GST_PAD_SINK,
|
||||||
|
GST_PAD_ALWAYS,
|
||||||
|
GST_STATIC_CAPS_ANY);
|
||||||
|
|
||||||
|
sink = gst_check_setup_sink_pad_by_name (tee, &sinktemplate, "src_%u");
|
||||||
|
fail_unless (sink != NULL);
|
||||||
|
gst_pad_set_query_function (sink, query_func);
|
||||||
|
}
|
||||||
|
|
||||||
|
GST_START_TEST (test_allocation_query_aggregation)
|
||||||
{
|
{
|
||||||
GstElement *tee;
|
GstElement *tee;
|
||||||
GstPad *sink1, *sink2, *sink3;
|
|
||||||
GstPad *sinkpad, *srcpad;
|
GstPad *sinkpad, *srcpad;
|
||||||
GstCaps *caps;
|
GstCaps *caps;
|
||||||
GstQuery *query;
|
GstQuery *query;
|
||||||
guint size, min, max;
|
guint size, min, max;
|
||||||
GstAllocationParams param;
|
GstAllocationParams param;
|
||||||
|
|
||||||
static GstStaticPadTemplate sinktemplate = GST_STATIC_PAD_TEMPLATE ("sink",
|
|
||||||
GST_PAD_SINK,
|
|
||||||
GST_PAD_ALWAYS,
|
|
||||||
GST_STATIC_CAPS_ANY);
|
|
||||||
|
|
||||||
caps = gst_caps_new_empty_simple ("test/test");
|
|
||||||
|
|
||||||
tee = gst_check_setup_element ("tee");
|
tee = gst_check_setup_element ("tee");
|
||||||
fail_unless (tee);
|
fail_unless (tee);
|
||||||
|
|
||||||
sinkpad = gst_element_get_static_pad (tee, "sink");
|
sinkpad = gst_element_get_static_pad (tee, "sink");
|
||||||
|
add_sink_pad_and_setup_query_func (tee, allocation_query1);
|
||||||
|
add_sink_pad_and_setup_query_func (tee, allocation_query2);
|
||||||
|
add_sink_pad_and_setup_query_func (tee, allocation_query3);
|
||||||
|
|
||||||
sink1 = gst_check_setup_sink_pad_by_name (tee, &sinktemplate, "src_%u");
|
caps = gst_caps_new_empty_simple ("test/test");
|
||||||
fail_unless (sink1 != NULL);
|
|
||||||
gst_pad_set_query_function (sink1, allocation_query1);
|
|
||||||
|
|
||||||
sink2 = gst_check_setup_sink_pad_by_name (tee, &sinktemplate, "src_%u");
|
|
||||||
fail_unless (sink2 != NULL);
|
|
||||||
gst_pad_set_query_function (sink2, allocation_query2);
|
|
||||||
|
|
||||||
sink3 = gst_check_setup_sink_pad_by_name (tee, &sinktemplate, "src_%u");
|
|
||||||
fail_unless (sink3 != NULL);
|
|
||||||
gst_pad_set_query_function (sink3, allocation_query3);
|
|
||||||
|
|
||||||
query = gst_query_new_allocation (caps, TRUE);
|
query = gst_query_new_allocation (caps, TRUE);
|
||||||
fail_unless (gst_pad_query (sinkpad, query));
|
fail_unless (gst_pad_query (sinkpad, query));
|
||||||
|
|
||||||
fail_unless (gst_query_get_n_allocation_pools (query), 1);
|
ck_assert_int_eq (gst_query_get_n_allocation_pools (query), 1);
|
||||||
gst_query_parse_nth_allocation_pool (query, 0, NULL, &size, &min, &max);
|
gst_query_parse_nth_allocation_pool (query, 0, NULL, &size, &min, &max);
|
||||||
fail_unless (size == 130);
|
fail_unless (size == 130);
|
||||||
/* The tee will allocate one more buffer when multiplexing */
|
/* The tee will allocate one more buffer when multiplexing */
|
||||||
|
@ -816,21 +815,12 @@ GST_START_TEST (test_allocation_query)
|
||||||
fail_unless (gst_query_parse_nth_allocation_meta (query, 0, NULL) ==
|
fail_unless (gst_query_parse_nth_allocation_meta (query, 0, NULL) ==
|
||||||
GST_PARENT_BUFFER_META_API_TYPE);
|
GST_PARENT_BUFFER_META_API_TYPE);
|
||||||
|
|
||||||
|
/* TODO: what is this testing? move to a new test? */
|
||||||
srcpad = gst_element_get_request_pad (tee, "src_%u");
|
srcpad = gst_element_get_request_pad (tee, "src_%u");
|
||||||
gst_query_unref (query);
|
gst_query_unref (query);
|
||||||
query = gst_query_new_allocation (caps, TRUE);
|
query = gst_query_new_allocation (caps, TRUE);
|
||||||
fail_if (gst_pad_query (sinkpad, query));
|
fail_if (gst_pad_query (sinkpad, query));
|
||||||
|
|
||||||
g_object_set (tee, "allow-not-linked", TRUE, NULL);
|
|
||||||
gst_query_unref (query);
|
|
||||||
query = gst_query_new_allocation (caps, TRUE);
|
|
||||||
fail_unless (gst_pad_query (sinkpad, query));
|
|
||||||
|
|
||||||
gst_pad_set_query_function (sink3, allocation_query_fail);
|
|
||||||
gst_query_unref (query);
|
|
||||||
query = gst_query_new_allocation (caps, TRUE);
|
|
||||||
fail_if (gst_pad_query (sinkpad, query));
|
|
||||||
|
|
||||||
gst_caps_unref (caps);
|
gst_caps_unref (caps);
|
||||||
gst_query_unref (query);
|
gst_query_unref (query);
|
||||||
gst_check_teardown_pad_by_name (tee, "src_0");
|
gst_check_teardown_pad_by_name (tee, "src_0");
|
||||||
|
@ -844,6 +834,70 @@ GST_START_TEST (test_allocation_query)
|
||||||
|
|
||||||
GST_END_TEST;
|
GST_END_TEST;
|
||||||
|
|
||||||
|
|
||||||
|
GST_START_TEST (test_allocation_query_allow_not_linked)
|
||||||
|
{
|
||||||
|
GstElement *tee;
|
||||||
|
GstPad *sinkpad;
|
||||||
|
GstCaps *caps;
|
||||||
|
GstQuery *query;
|
||||||
|
|
||||||
|
tee = gst_check_setup_element ("tee");
|
||||||
|
fail_unless (tee);
|
||||||
|
g_object_set (tee, "allow-not-linked", TRUE, NULL);
|
||||||
|
|
||||||
|
sinkpad = gst_element_get_static_pad (tee, "sink");
|
||||||
|
add_sink_pad_and_setup_query_func (tee, allocation_query1);
|
||||||
|
add_sink_pad_and_setup_query_func (tee, allocation_query2);
|
||||||
|
add_sink_pad_and_setup_query_func (tee, allocation_query3);
|
||||||
|
|
||||||
|
caps = gst_caps_new_empty_simple ("test/test");
|
||||||
|
query = gst_query_new_allocation (caps, TRUE);
|
||||||
|
fail_unless (gst_pad_query (sinkpad, query));
|
||||||
|
|
||||||
|
gst_caps_unref (caps);
|
||||||
|
gst_query_unref (query);
|
||||||
|
gst_check_teardown_pad_by_name (tee, "src_0");
|
||||||
|
gst_check_teardown_pad_by_name (tee, "src_1");
|
||||||
|
gst_check_teardown_pad_by_name (tee, "src_2");
|
||||||
|
gst_object_unref (sinkpad);
|
||||||
|
gst_check_teardown_element (tee);
|
||||||
|
}
|
||||||
|
|
||||||
|
GST_END_TEST;
|
||||||
|
|
||||||
|
|
||||||
|
GST_START_TEST (test_allocation_query_failure)
|
||||||
|
{
|
||||||
|
GstElement *tee;
|
||||||
|
GstPad *sinkpad;
|
||||||
|
GstCaps *caps;
|
||||||
|
GstQuery *query;
|
||||||
|
|
||||||
|
tee = gst_check_setup_element ("tee");
|
||||||
|
fail_unless (tee);
|
||||||
|
g_object_set (tee, "allow-not-linked", TRUE, NULL);
|
||||||
|
|
||||||
|
sinkpad = gst_element_get_static_pad (tee, "sink");
|
||||||
|
add_sink_pad_and_setup_query_func (tee, allocation_query1);
|
||||||
|
add_sink_pad_and_setup_query_func (tee, allocation_query2);
|
||||||
|
add_sink_pad_and_setup_query_func (tee, allocation_query_fail);
|
||||||
|
|
||||||
|
caps = gst_caps_new_empty_simple ("test/test");
|
||||||
|
query = gst_query_new_allocation (caps, TRUE);
|
||||||
|
fail_if (gst_pad_query (sinkpad, query));
|
||||||
|
|
||||||
|
gst_caps_unref (caps);
|
||||||
|
gst_query_unref (query);
|
||||||
|
gst_check_teardown_pad_by_name (tee, "src_0");
|
||||||
|
gst_check_teardown_pad_by_name (tee, "src_1");
|
||||||
|
gst_check_teardown_pad_by_name (tee, "src_2");
|
||||||
|
gst_object_unref (sinkpad);
|
||||||
|
gst_check_teardown_element (tee);
|
||||||
|
}
|
||||||
|
|
||||||
|
GST_END_TEST;
|
||||||
|
|
||||||
static Suite *
|
static Suite *
|
||||||
tee_suite (void)
|
tee_suite (void)
|
||||||
{
|
{
|
||||||
|
@ -862,7 +916,9 @@ tee_suite (void)
|
||||||
tcase_add_test (tc_chain, test_flow_aggregation);
|
tcase_add_test (tc_chain, test_flow_aggregation);
|
||||||
tcase_add_test (tc_chain, test_request_pads);
|
tcase_add_test (tc_chain, test_request_pads);
|
||||||
tcase_add_test (tc_chain, test_allow_not_linked);
|
tcase_add_test (tc_chain, test_allow_not_linked);
|
||||||
tcase_add_test (tc_chain, test_allocation_query);
|
tcase_add_test (tc_chain, test_allocation_query_aggregation);
|
||||||
|
tcase_add_test (tc_chain, test_allocation_query_allow_not_linked);
|
||||||
|
tcase_add_test (tc_chain, test_allocation_query_failure);
|
||||||
|
|
||||||
return s;
|
return s;
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in a new issue