mirror of
https://gitlab.freedesktop.org/gstreamer/gstreamer.git
synced 2024-09-19 10:30:30 +00:00
5b3ee70ea9
When no data is coming from sinkpads and eos events arrived at one of the sinkpad, funnel forwards the EOS event to downstream. It forwards the EOS because lastsink pad is NULL. Also the unit testcase of the funnel is not checking the correct behavior as it should. The unit test case should fail if one of the sink pad has already EOS present on it and we are trying to push one more EOS. https://bugzilla.gnome.org/show_bug.cgi?id=731716
260 lines
8 KiB
C
260 lines
8 KiB
C
/* GStreamer unit tests for the funnel
|
|
*
|
|
* Copyright (C) 2008 Collabora, Nokia
|
|
* @author: Olivier Crete <olivier.crete@collabora.co.uk>
|
|
*
|
|
* This library is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU Lesser General Public
|
|
* License as published by the Free Software Foundation; either
|
|
* version 2.1 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
|
|
* Lesser General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU Lesser General Public
|
|
* License along with this library; if not, write to the Free Software
|
|
* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
|
|
*/
|
|
|
|
|
|
#ifdef HAVE_CONFIG_H
|
|
# include <config.h>
|
|
#endif
|
|
|
|
#include <gst/check/gstcheck.h>
|
|
|
|
struct TestData
|
|
{
|
|
GstElement *funnel;
|
|
GstPad *funnelsrc, *funnelsink11, *funnelsink22;
|
|
GstPad *mysink, *mysrc1, *mysrc2;
|
|
GstCaps *mycaps;
|
|
};
|
|
|
|
static void
|
|
setup_test_objects (struct TestData *td, GstPadChainFunction chain_func)
|
|
{
|
|
td->mycaps = gst_caps_new_empty_simple ("test/test");
|
|
|
|
td->funnel = gst_element_factory_make ("funnel", NULL);
|
|
|
|
td->funnelsrc = gst_element_get_static_pad (td->funnel, "src");
|
|
fail_unless (td->funnelsrc != NULL);
|
|
|
|
td->funnelsink11 = gst_element_get_request_pad (td->funnel, "sink_11");
|
|
fail_unless (td->funnelsink11 != NULL);
|
|
fail_unless (!strcmp (GST_OBJECT_NAME (td->funnelsink11), "sink_11"));
|
|
|
|
td->funnelsink22 = gst_element_get_request_pad (td->funnel, "sink_22");
|
|
fail_unless (td->funnelsink22 != NULL);
|
|
fail_unless (!strcmp (GST_OBJECT_NAME (td->funnelsink22), "sink_22"));
|
|
|
|
fail_unless (gst_element_set_state (td->funnel, GST_STATE_PLAYING) ==
|
|
GST_STATE_CHANGE_SUCCESS);
|
|
|
|
td->mysink = gst_pad_new ("sink", GST_PAD_SINK);
|
|
gst_pad_set_chain_function (td->mysink, chain_func);
|
|
gst_pad_set_active (td->mysink, TRUE);
|
|
|
|
td->mysrc1 = gst_pad_new ("src1", GST_PAD_SRC);
|
|
gst_pad_set_active (td->mysrc1, TRUE);
|
|
gst_check_setup_events_with_stream_id (td->mysrc1, td->funnel, td->mycaps,
|
|
GST_FORMAT_BYTES, "test1");
|
|
|
|
td->mysrc2 = gst_pad_new ("src2", GST_PAD_SRC);
|
|
gst_pad_set_active (td->mysrc2, TRUE);
|
|
gst_check_setup_events_with_stream_id (td->mysrc2, td->funnel, td->mycaps,
|
|
GST_FORMAT_BYTES, "test2");
|
|
|
|
fail_unless (GST_PAD_LINK_SUCCESSFUL (gst_pad_link (td->funnelsrc,
|
|
td->mysink)));
|
|
|
|
fail_unless (GST_PAD_LINK_SUCCESSFUL (gst_pad_link (td->mysrc1,
|
|
td->funnelsink11)));
|
|
|
|
fail_unless (GST_PAD_LINK_SUCCESSFUL (gst_pad_link (td->mysrc2,
|
|
td->funnelsink22)));
|
|
|
|
}
|
|
|
|
static void
|
|
release_test_objects (struct TestData *td)
|
|
{
|
|
gst_pad_set_active (td->mysink, FALSE);
|
|
gst_pad_set_active (td->mysrc1, FALSE);
|
|
gst_pad_set_active (td->mysrc1, FALSE);
|
|
|
|
gst_object_unref (td->mysink);
|
|
gst_object_unref (td->mysrc1);
|
|
gst_object_unref (td->mysrc2);
|
|
|
|
fail_unless (gst_element_set_state (td->funnel, GST_STATE_NULL) ==
|
|
GST_STATE_CHANGE_SUCCESS);
|
|
|
|
gst_object_unref (td->funnelsrc);
|
|
gst_element_release_request_pad (td->funnel, td->funnelsink11);
|
|
gst_object_unref (td->funnelsink11);
|
|
gst_element_release_request_pad (td->funnel, td->funnelsink22);
|
|
gst_object_unref (td->funnelsink22);
|
|
|
|
gst_caps_unref (td->mycaps);
|
|
gst_object_unref (td->funnel);
|
|
}
|
|
|
|
static gint bufcount = 0;
|
|
static gint alloccount = 0;
|
|
|
|
static GstFlowReturn
|
|
chain_ok (GstPad * pad, GstObject * parent, GstBuffer * buffer)
|
|
{
|
|
bufcount++;
|
|
|
|
gst_buffer_unref (buffer);
|
|
|
|
return GST_FLOW_OK;
|
|
}
|
|
|
|
GST_START_TEST (test_funnel_simple)
|
|
{
|
|
struct TestData td;
|
|
|
|
setup_test_objects (&td, chain_ok);
|
|
|
|
bufcount = 0;
|
|
alloccount = 0;
|
|
|
|
fail_unless (gst_pad_push (td.mysrc1, gst_buffer_new ()) == GST_FLOW_OK);
|
|
fail_unless (gst_pad_push (td.mysrc2, gst_buffer_new ()) == GST_FLOW_OK);
|
|
|
|
fail_unless (bufcount == 2);
|
|
|
|
release_test_objects (&td);
|
|
}
|
|
|
|
GST_END_TEST;
|
|
|
|
guint num_eos = 0;
|
|
|
|
static gboolean
|
|
eos_event_func (GstPad * pad, GstObject * parent, GstEvent * event)
|
|
{
|
|
if (GST_EVENT_TYPE (event) == GST_EVENT_EOS)
|
|
++num_eos;
|
|
|
|
return gst_pad_event_default (pad, parent, event);
|
|
}
|
|
|
|
GST_START_TEST (test_funnel_eos)
|
|
{
|
|
struct TestData td;
|
|
GstSegment segment;
|
|
|
|
setup_test_objects (&td, chain_ok);
|
|
|
|
num_eos = 0;
|
|
bufcount = 0;
|
|
|
|
gst_pad_set_event_function (td.mysink, eos_event_func);
|
|
|
|
fail_unless (gst_pad_push (td.mysrc1, gst_buffer_new ()) == GST_FLOW_OK);
|
|
fail_unless (gst_pad_push (td.mysrc2, gst_buffer_new ()) == GST_FLOW_OK);
|
|
|
|
fail_unless (bufcount == 2);
|
|
|
|
fail_unless (gst_pad_push_event (td.mysrc1, gst_event_new_eos ()));
|
|
fail_unless (num_eos == 0);
|
|
|
|
fail_unless (gst_pad_push (td.mysrc1, gst_buffer_new ()) == GST_FLOW_EOS);
|
|
fail_unless (gst_pad_push (td.mysrc2, gst_buffer_new ()) == GST_FLOW_OK);
|
|
|
|
fail_unless (bufcount == 3);
|
|
|
|
fail_unless (gst_pad_push_event (td.mysrc2, gst_event_new_eos ()));
|
|
fail_unless (num_eos == 1);
|
|
|
|
fail_unless (gst_pad_push (td.mysrc1, gst_buffer_new ()) == GST_FLOW_EOS);
|
|
fail_unless (gst_pad_push (td.mysrc2, gst_buffer_new ()) == GST_FLOW_EOS);
|
|
|
|
fail_unless (bufcount == 3);
|
|
|
|
fail_unless (gst_pad_push_event (td.mysrc1, gst_event_new_flush_start ()));
|
|
fail_unless (gst_pad_push_event (td.mysrc1, gst_event_new_flush_stop (TRUE)));
|
|
|
|
gst_segment_init (&segment, GST_FORMAT_BYTES);
|
|
gst_pad_push_event (td.mysrc1, gst_event_new_segment (&segment));
|
|
gst_pad_push_event (td.mysrc2, gst_event_new_segment (&segment));
|
|
|
|
fail_unless (gst_pad_push (td.mysrc1, gst_buffer_new ()) == GST_FLOW_OK);
|
|
fail_unless (gst_pad_push (td.mysrc2, gst_buffer_new ()) == GST_FLOW_EOS);
|
|
|
|
fail_unless (bufcount == 4);
|
|
|
|
fail_unless (gst_pad_unlink (td.mysrc1, td.funnelsink11));
|
|
gst_element_release_request_pad (td.funnel, td.funnelsink11);
|
|
gst_object_unref (td.funnelsink11);
|
|
fail_unless (num_eos == 2);
|
|
|
|
td.funnelsink11 = gst_element_get_request_pad (td.funnel, "sink_11");
|
|
fail_unless (td.funnelsink11 != NULL);
|
|
fail_unless (!strcmp (GST_OBJECT_NAME (td.funnelsink11), "sink_11"));
|
|
|
|
fail_unless (GST_PAD_LINK_SUCCESSFUL (gst_pad_link (td.mysrc1,
|
|
td.funnelsink11)));
|
|
|
|
/* This will fail because everything is EOS already */
|
|
fail_if (gst_pad_push_event (td.mysrc1, gst_event_new_eos ()));
|
|
fail_unless (num_eos == 2);
|
|
|
|
fail_unless (gst_pad_unlink (td.mysrc1, td.funnelsink11));
|
|
gst_element_release_request_pad (td.funnel, td.funnelsink11);
|
|
gst_object_unref (td.funnelsink11);
|
|
fail_unless (num_eos == 2);
|
|
|
|
/* send only eos to check, it handles empty streams */
|
|
td.funnelsink11 = gst_element_get_request_pad (td.funnel, "sink_11");
|
|
fail_unless (td.funnelsink11 != NULL);
|
|
fail_unless (!strcmp (GST_OBJECT_NAME (td.funnelsink11), "sink_11"));
|
|
|
|
fail_unless (GST_PAD_LINK_SUCCESSFUL (gst_pad_link (td.mysrc1,
|
|
td.funnelsink11)));
|
|
|
|
fail_unless (gst_pad_push_event (td.mysrc1, gst_event_new_flush_start ()));
|
|
fail_unless (gst_pad_push_event (td.mysrc1, gst_event_new_flush_stop (TRUE)));
|
|
fail_unless (gst_pad_push_event (td.mysrc2, gst_event_new_flush_start ()));
|
|
fail_unless (gst_pad_push_event (td.mysrc2, gst_event_new_flush_stop (TRUE)));
|
|
|
|
fail_unless (gst_pad_push_event (td.mysrc1, gst_event_new_eos ()));
|
|
fail_unless (gst_pad_push_event (td.mysrc2, gst_event_new_eos ()));
|
|
fail_unless (num_eos == 3);
|
|
|
|
fail_unless (gst_pad_unlink (td.mysrc1, td.funnelsink11));
|
|
gst_element_release_request_pad (td.funnel, td.funnelsink11);
|
|
gst_object_unref (td.funnelsink11);
|
|
fail_unless (num_eos == 3);
|
|
|
|
td.funnelsink11 = gst_element_get_request_pad (td.funnel, "sink_11");
|
|
fail_unless (td.funnelsink11 != NULL);
|
|
fail_unless (!strcmp (GST_OBJECT_NAME (td.funnelsink11), "sink_11"));
|
|
|
|
release_test_objects (&td);
|
|
}
|
|
|
|
GST_END_TEST;
|
|
|
|
static Suite *
|
|
funnel_suite (void)
|
|
{
|
|
Suite *s = suite_create ("funnel");
|
|
TCase *tc_chain;
|
|
|
|
tc_chain = tcase_create ("funnel simple");
|
|
tcase_add_test (tc_chain, test_funnel_simple);
|
|
tcase_add_test (tc_chain, test_funnel_eos);
|
|
suite_add_tcase (s, tc_chain);
|
|
|
|
return s;
|
|
}
|
|
|
|
GST_CHECK_MAIN (funnel);
|