From ec1a826cc8a74e57a4428b6e957d80034e500528 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sebastian=20Dr=C3=B6ge?= Date: Thu, 3 Apr 2008 20:05:31 +0000 Subject: [PATCH] tests/check/: Add unit test that encodes and decodes some data, checks that it is still the same and that all timesta... Original commit message from CVS: * tests/check/Makefile.am: * tests/check/pipelines/wavpack.c: (bus_handler), (identity_handoff), (fakesink_handoff), (GST_START_TEST), (wavpack_suite), (main): Add unit test that encodes and decodes some data, checks that it is still the same and that all timestamps/offsets are perfect. --- ChangeLog | 9 ++ tests/check/Makefile.am | 6 +- tests/check/pipelines/wavpack.c | 224 ++++++++++++++++++++++++++++++++ 3 files changed, 238 insertions(+), 1 deletion(-) create mode 100644 tests/check/pipelines/wavpack.c diff --git a/ChangeLog b/ChangeLog index 245edd13d6..4dc27a1502 100644 --- a/ChangeLog +++ b/ChangeLog @@ -1,3 +1,12 @@ +2008-04-03 Sebastian Dröge + + * tests/check/Makefile.am: + * tests/check/pipelines/wavpack.c: (bus_handler), + (identity_handoff), (fakesink_handoff), (GST_START_TEST), + (wavpack_suite), (main): + Add unit test that encodes and decodes some data, checks that it + is still the same and that all timestamps/offsets are perfect. + 2008-04-03 Sebastian Dröge * ext/wavpack/gstwavpackdec.c: (gst_wavpack_dec_base_init): diff --git a/tests/check/Makefile.am b/tests/check/Makefile.am index 7b6fee70fe..bc1b3244e7 100644 --- a/tests/check/Makefile.am +++ b/tests/check/Makefile.am @@ -44,7 +44,8 @@ if USE_WAVPACK check_wavpack = \ elements/wavpackparse \ elements/wavpackdec \ - elements/wavpackenc + elements/wavpackenc \ + pipelines/wavpack else check_wavpack = endif @@ -122,3 +123,6 @@ elements_sunaudio_LDADD = \ elements_videocrop_LDADD = $(LDADD) $(GST_BASE_LIBS) elements_videocrop_CFLAGS = $(GST_BASE_CFLAGS) $(CFLAGS) $(AM_CFLAGS) +pipelines_wavpack_LDADD = $(LDADD) $(GST_BASE_LIBS) +pipelines_wavpack_CFLAGS = $(GST_BASE_CFLAGS) $(CFLAGS) $(AM_CFLAGS) + diff --git a/tests/check/pipelines/wavpack.c b/tests/check/pipelines/wavpack.c new file mode 100644 index 0000000000..bd81872355 --- /dev/null +++ b/tests/check/pipelines/wavpack.c @@ -0,0 +1,224 @@ +/* GStreamer + * Copyright (C) 2008 Sebastian Dröge + * + * 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 + +static gboolean +bus_handler (GstBus * bus, GstMessage * message, gpointer data) +{ + GMainLoop *loop = (GMainLoop *) data; + + switch (message->type) { + case GST_MESSAGE_EOS: + g_main_loop_quit (loop); + break; + case GST_MESSAGE_WARNING: + case GST_MESSAGE_ERROR:{ + GError *gerror; + gchar *debug; + + gst_message_parse_error (message, &gerror, &debug); + gst_object_default_error (GST_MESSAGE_SRC (message), gerror, debug); + gst_message_unref (message); + g_error_free (gerror); + g_free (debug); + g_main_loop_quit (loop); + break; + } + case GST_MESSAGE_ELEMENT: + { + const GstStructure *s = gst_message_get_structure (message); + const gchar *name = gst_structure_get_name (s); + + /* FIXME: identity bug http://bugzilla.gnome.org/show_bug.cgi?id=526042 */ + if (strcmp (name, "imperfect-timestamp") == 0 + || strcmp (name, "imperfect-offset") == 0) { + const GValue *cur_offset = gst_structure_get_value (s, "cur-offset"); + + fail_unless (G_VALUE_HOLDS_UINT64 (cur_offset)); + if (g_value_get_uint64 (cur_offset) == 0) + break; + } + + fail_unless (strcmp (name, "imperfect-timestamp") != 0); + fail_unless (strcmp (name, "imperfect-offset") != 0); + break; + } + default: + break; + } + + return TRUE; +} + +static gboolean had_first_buffer = FALSE; + +static void +identity_handoff (GstElement * object, GstBuffer * buffer, gpointer user_data) +{ + GstAdapter *adapter = GST_ADAPTER (user_data); + + gst_adapter_push (adapter, gst_buffer_ref (buffer)); +} + +static void +fakesink_handoff (GstElement * object, GstBuffer * buffer, GstPad * pad, + gpointer user_data) +{ + GstAdapter *adapter = GST_ADAPTER (user_data); + + /* Don't allow the second buffer with offset=0 as it's the decoded + * rewrite of the first + */ + if (had_first_buffer == FALSE && GST_BUFFER_OFFSET (buffer) == 0) + had_first_buffer = TRUE; + else if (GST_BUFFER_OFFSET (buffer) == 0) + return; + + gst_adapter_push (adapter, gst_buffer_ref (buffer)); +} + +GST_START_TEST (test_encode_decode) +{ + GstElement *pipeline; + GstElement *audiotestsrc, *identity1, *wavpackenc, *identity2, *wavpackdec, + *identity3, *fakesink; + GstAdapter *srcadapter, *sinkadapter; + + GstBus *bus; + GMainLoop *loop; + + GstBuffer *in, *out; + + srcadapter = gst_adapter_new (); + fail_unless (srcadapter != NULL); + sinkadapter = gst_adapter_new (); + fail_unless (sinkadapter != NULL); + + pipeline = gst_pipeline_new ("pipeline"); + fail_unless (pipeline != NULL); + + audiotestsrc = gst_element_factory_make ("audiotestsrc", "src"); + fail_unless (audiotestsrc != NULL); + g_object_set (G_OBJECT (audiotestsrc), "wave", 0, "freq", 440.0, + "num-buffers", 2000, NULL); + + identity1 = gst_element_factory_make ("identity", "identity1"); + fail_unless (identity1 != NULL); + g_object_set (G_OBJECT (identity1), "signal-handoffs", TRUE, NULL); + g_signal_connect (G_OBJECT (identity1), "handoff", + G_CALLBACK (identity_handoff), srcadapter); + + wavpackenc = gst_element_factory_make ("wavpackenc", "enc"); + fail_unless (wavpackenc != NULL); + + identity2 = gst_element_factory_make ("identity", "identity2"); + fail_unless (identity2 != NULL); + g_object_set (G_OBJECT (identity2), "check-imperfect-timestamp", TRUE, + "check-imperfect-offset", TRUE, NULL); + + wavpackdec = gst_element_factory_make ("wavpackdec", "dec"); + fail_unless (wavpackdec != NULL); + + identity3 = gst_element_factory_make ("identity", "identity3"); + fail_unless (identity3 != NULL); + g_object_set (G_OBJECT (identity3), "check-imperfect-timestamp", TRUE, + "check-imperfect-offset", TRUE, NULL); + + fakesink = gst_element_factory_make ("fakesink", "sink"); + fail_unless (fakesink != NULL); + g_object_set (G_OBJECT (fakesink), "signal-handoffs", TRUE, NULL); + g_signal_connect (G_OBJECT (fakesink), "handoff", + G_CALLBACK (fakesink_handoff), sinkadapter); + + gst_bin_add_many (GST_BIN (pipeline), audiotestsrc, identity1, wavpackenc, + identity2, wavpackdec, identity3, fakesink, NULL); + + fail_unless (gst_element_link_many (audiotestsrc, identity1, wavpackenc, + identity2, wavpackdec, identity3, fakesink, NULL)); + + loop = g_main_loop_new (NULL, TRUE); + fail_unless (loop != NULL); + + bus = gst_element_get_bus (pipeline); + fail_unless (bus != NULL); + gst_bus_add_watch (bus, bus_handler, loop); + gst_object_unref (bus); + + had_first_buffer = FALSE; + gst_element_set_state (pipeline, GST_STATE_PLAYING); + g_main_loop_run (loop); + gst_element_set_state (pipeline, GST_STATE_NULL); + + fail_unless (had_first_buffer == TRUE); + fail_unless (gst_adapter_available (srcadapter) > 0); + fail_unless (gst_adapter_available (sinkadapter) > 0); + fail_unless_equals_int (gst_adapter_available (srcadapter), + gst_adapter_available (sinkadapter)); + + in = gst_adapter_take_buffer (srcadapter, gst_adapter_available (srcadapter)); + fail_unless (in != NULL); + out = + gst_adapter_take_buffer (sinkadapter, + gst_adapter_available (sinkadapter)); + fail_unless (out != NULL); + + fail_unless_equals_int (GST_BUFFER_SIZE (in), GST_BUFFER_SIZE (out)); + fail_unless (memcmp (GST_BUFFER_DATA (in), GST_BUFFER_DATA (out), + GST_BUFFER_SIZE (in)) == 0); + + gst_buffer_unref (in); + gst_buffer_unref (out); + g_object_unref (pipeline); + g_main_loop_unref (loop); + g_object_unref (srcadapter); + g_object_unref (sinkadapter); +} + +GST_END_TEST; + +Suite * +wavpack_suite (void) +{ + Suite *s = suite_create ("Wavpack"); + TCase *tc_chain = tcase_create ("linear"); + + suite_add_tcase (s, tc_chain); + tcase_add_test (tc_chain, test_encode_decode); + + return s; +} + +int +main (int argc, char **argv) +{ + int nf; + + Suite *s = wavpack_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; +}