diff options
author | Luca Ognibene <luogni@tin.it> | 2006-05-09 16:18:17 +0000 |
---|---|---|
committer | Tim-Philipp Müller <tim@centricular.net> | 2006-05-09 16:18:17 +0000 |
commit | 72362cb208fa3b65b73b3a6ba17fef4bfa70a08a (patch) | |
tree | 9895a2041ff94b83da632cbef791e172d3826133 /tests | |
parent | 10e4f37d31bf1941f2a24cfbed58236833b606c2 (diff) | |
download | gst-libav-72362cb208fa3b65b73b3a6ba17fef4bfa70a08a.tar.gz |
tests/check/: Add test case for libavcodec locking
Original commit message from CVS:
Patch by: Luca Ognibene <luogni at tin dot it>
* tests/check/Makefile.am:
* tests/check/generic/libavcodec-locking.c: (setup_pipeline),
(run_pipeline), (GST_START_TEST), (simple_launch_lines_suite),
(main):
Add test case for libavcodec locking
Diffstat (limited to 'tests')
-rw-r--r-- | tests/check/Makefile.am | 10 | ||||
-rw-r--r-- | tests/check/generic/libavcodec-locking.c | 160 |
2 files changed, 164 insertions, 6 deletions
diff --git a/tests/check/Makefile.am b/tests/check/Makefile.am index 9ec19de..d6dbb6c 100644 --- a/tests/check/Makefile.am +++ b/tests/check/Makefile.am @@ -15,13 +15,11 @@ CLEANFILES = core.* test-registry.xml clean-local: clean-local-check -check_PROGRAMS = -####check_PROGRAMS = \ -#### generic/libavcodec-locking +check_PROGRAMS = \ + generic/libavcodec-locking -VALGRIND_TO_FIX = -####VALGRIND_TO_FIX = \ -#### generic/libavcodec-locking +VALGRIND_TO_FIX = \ + generic/libavcodec-locking TESTS = $(check_PROGRAMS) diff --git a/tests/check/generic/libavcodec-locking.c b/tests/check/generic/libavcodec-locking.c new file mode 100644 index 0000000..f71238c --- /dev/null +++ b/tests/check/generic/libavcodec-locking.c @@ -0,0 +1,160 @@ +/* GStreamer + * Copyright (C) 2005 Luca Ognibene <luogni@tin.it> + * Based (copied) on simple_launch_lines.c + * + * ffmpeg-lock.c: Unit test for libavcodec's locks + * + * 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., 59 Temple Place - Suite 330, + * Boston, MA 02111-1307, USA. + */ + + +#include <gst/check/gstcheck.h> +#include <stdlib.h> + +#define NUM_SINKS 10 + +static GstElement * +setup_pipeline (const gchar * pipe_descr) +{ + GstElement *pipeline; + + pipeline = gst_parse_launch (pipe_descr, NULL); + g_return_val_if_fail (GST_IS_PIPELINE (pipeline), NULL); + return pipeline; +} + +/* + * run_pipeline: + * @pipe: the pipeline to run + * @desc: the description for use in messages + * @events: is a mask of expected events + * @tevent: is the expected terminal event. + * + * the poll call will time out after half a second. + */ +static void +run_pipeline (GstElement * pipe, const gchar * descr, + GstMessageType events, GstMessageType tevent) +{ + GstBus *bus; + GstMessage *message; + GstMessageType revent; + GstStateChangeReturn ret; + + g_assert (pipe); + bus = gst_element_get_bus (pipe); + g_assert (bus); + + ret = gst_element_set_state (pipe, GST_STATE_PLAYING); + ret = gst_element_get_state (pipe, NULL, NULL, GST_CLOCK_TIME_NONE); + if (ret != GST_STATE_CHANGE_SUCCESS) { + g_critical ("Couldn't set pipeline to PLAYING"); + goto done; + } + + while (1) { + message = gst_bus_poll (bus, GST_MESSAGE_ANY, GST_SECOND / 2); + + /* always have to pop the message before getting back into poll */ + if (message) { + revent = GST_MESSAGE_TYPE (message); + gst_message_unref (message); + } else { + revent = GST_MESSAGE_UNKNOWN; + } + + if (revent == tevent) { + break; + } else if (revent == GST_MESSAGE_UNKNOWN) { + g_critical ("Unexpected timeout in gst_bus_poll, looking for %d: %s", + tevent, descr); + break; + } else if (revent & events) { + continue; + } + g_critical ("Unexpected message received of type %d, looking for %d: %s", + revent, tevent, descr); + } + +done: + gst_element_set_state (pipe, GST_STATE_NULL); + gst_object_unref (pipe); +} + +GST_START_TEST (test_libavcodec_locks) +{ + gchar *sink[NUM_SINKS+1], *s, *sinks; + gint i; + + for (i=0; i<NUM_SINKS; i++) + sink[i] = g_strdup_printf (" t.src%d ! queue ! ffenc_mpeg4 ! ffdec_mpeg4 ! fakesink", i); + + sink [NUM_SINKS] = NULL; + + sinks = g_strjoinv (" ", sink); + + s = g_strdup_printf ("videotestsrc ! video/x-raw-yuv,format:fourcc=I420,width=320,height=240 ! tee name=t %s", sinks); + + run_pipeline (setup_pipeline (s), s, + GST_MESSAGE_ANY & ~(GST_MESSAGE_ERROR | GST_MESSAGE_WARNING), + GST_MESSAGE_UNKNOWN); + + g_free (s); + + for (i=0; i<NUM_SINKS; i++) + g_free (sink[i]); + +} + +GST_END_TEST Suite * +simple_launch_lines_suite (void) +{ + gint timeout = 0; + + Suite *s = suite_create ("Pipelines"); + TCase *tc_chain = tcase_create ("linear"); + + if (g_getenv ("CK_DEFAULT_TIMEOUT")) + timeout = atoi (g_getenv ("CK_DEFAULT_TIMEOUT")); + + if (timeout == 0) + timeout = 3; + + /* set multiple of default timeout (random magic value) */ + tcase_set_timeout (tc_chain, timeout * 12); + + suite_add_tcase (s, tc_chain); + tcase_add_test (tc_chain, test_libavcodec_locks); + + return s; +} + +int +main (int argc, char **argv) +{ + int nf; + + Suite *s = simple_launch_lines_suite (); + SRunner *sr = srunner_create (s); + + gst_check_init (&argc, &argv); + + srunner_run_all (sr, CK_NORMAL); + nf = srunner_ntests_failed (sr); + srunner_free (sr); + + return nf; +} |