From 72362cb208fa3b65b73b3a6ba17fef4bfa70a08a Mon Sep 17 00:00:00 2001 From: Luca Ognibene Date: Tue, 9 May 2006 16:18:17 +0000 Subject: [PATCH] tests/check/: Add test case for libavcodec locking Original commit message from CVS: Patch by: Luca Ognibene * 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 --- ChangeLog | 10 ++ tests/check/Makefile.am | 10 +- tests/check/generic/libavcodec-locking.c | 160 +++++++++++++++++++++++++++++++ 3 files changed, 174 insertions(+), 6 deletions(-) create mode 100644 tests/check/generic/libavcodec-locking.c diff --git a/ChangeLog b/ChangeLog index eed8381..b91c247 100644 --- a/ChangeLog +++ b/ChangeLog @@ -1,5 +1,15 @@ 2006-05-09 Tim-Philipp Müller + Patch by: Luca Ognibene + + * 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 + +2006-05-09 Tim-Philipp Müller + * Makefile.am: * configure.ac: * tests/Makefile.am: 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 + * 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 +#include + +#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