From da1b2a0a6fb36e4b22dad54b26cf561ca3c1aad1 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Sebastian=20Dr=C3=B6ge?= Date: Wed, 7 Nov 2007 15:18:54 +0000 Subject: ext/gio/gstgio.h: Add macro to check if a stream supports seeking. Original commit message from CVS: * ext/gio/gstgio.h: Add macro to check if a stream supports seeking. * ext/gio/Makefile.am: * ext/gio/gstgiobasesink.c: (gst_gio_base_sink_base_init), (gst_gio_base_sink_class_init), (gst_gio_base_sink_init), (gst_gio_base_sink_finalize), (gst_gio_base_sink_start), (gst_gio_base_sink_stop), (gst_gio_base_sink_unlock), (gst_gio_base_sink_unlock_stop), (gst_gio_base_sink_event), (gst_gio_base_sink_render), (gst_gio_base_sink_query), (gst_gio_base_sink_set_stream): * ext/gio/gstgiobasesink.h: * ext/gio/gstgiobasesrc.c: (gst_gio_base_src_base_init), (gst_gio_base_src_class_init), (gst_gio_base_src_init), (gst_gio_base_src_finalize), (gst_gio_base_src_start), (gst_gio_base_src_stop), (gst_gio_base_src_get_size), (gst_gio_base_src_is_seekable), (gst_gio_base_src_unlock), (gst_gio_base_src_unlock_stop), (gst_gio_base_src_check_get_range), (gst_gio_base_src_create), (gst_gio_base_src_set_stream): * ext/gio/gstgiobasesrc.h: Refactor common GIO functions to GstGioBaseSink and GstGioBaseSrc base classes that only require a GInputStream or GOutputStream to work. * ext/gio/gstgiosink.c: (gst_gio_sink_base_init), (gst_gio_sink_class_init), (gst_gio_sink_init), (gst_gio_sink_finalize), (gst_gio_sink_start): * ext/gio/gstgiosink.h: * ext/gio/gstgiosrc.c: (gst_gio_src_base_init), (gst_gio_src_class_init), (gst_gio_src_init), (gst_gio_src_finalize), (gst_gio_src_start): * ext/gio/gstgiosrc.h: Use the newly created base classes here. * ext/gio/gstgio.c: (plugin_init): * ext/gio/gstgiostreamsink.c: (gst_gio_stream_sink_base_init), (gst_gio_stream_sink_class_init), (gst_gio_stream_sink_init), (gst_gio_stream_sink_finalize), (gst_gio_stream_sink_set_property), (gst_gio_stream_sink_get_property): * ext/gio/gstgiostreamsink.h: * ext/gio/gstgiostreamsrc.c: (gst_gio_stream_src_base_init), (gst_gio_stream_src_class_init), (gst_gio_stream_src_init), (gst_gio_stream_src_finalize), (gst_gio_stream_src_set_property), (gst_gio_stream_src_get_property): * ext/gio/gstgiostreamsrc.h: Implement GstGioStreamSink and GstGioStreamSrc that have a property to set the GInputStream/GOutputStream that should be used. * tests/check/Makefile.am: * tests/check/pipelines/.cvsignore: * tests/check/pipelines/gio.c: (message_handler), (GST_START_TEST), (gio_testsuite), (main): Add unit test for giostreamsrc and giostreamsink. --- tests/check/pipelines/.gitignore | 2 + tests/check/pipelines/gio.c | 160 +++++++++++++++++++++++++++++++++++++++ 2 files changed, 162 insertions(+) create mode 100644 tests/check/pipelines/.gitignore create mode 100644 tests/check/pipelines/gio.c (limited to 'tests/check/pipelines') diff --git a/tests/check/pipelines/.gitignore b/tests/check/pipelines/.gitignore new file mode 100644 index 00000000..1acfc8c9 --- /dev/null +++ b/tests/check/pipelines/.gitignore @@ -0,0 +1,2 @@ +.dirstamp +gio diff --git a/tests/check/pipelines/gio.c b/tests/check/pipelines/gio.c new file mode 100644 index 00000000..75971237 --- /dev/null +++ b/tests/check/pipelines/gio.c @@ -0,0 +1,160 @@ +/* GStreamer + * + * unit test for GIO + * + * Copyright (C) 2007 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 +#include +#include + +static gboolean got_eos = FALSE; + +static gboolean +message_handler (GstBus * bus, GstMessage * msg, gpointer data) +{ + GMainLoop *loop = (GMainLoop *) data; + + switch (GST_MESSAGE_TYPE (msg)) { + case GST_MESSAGE_EOS: + got_eos = TRUE; + g_main_loop_quit (loop); + break; + case GST_MESSAGE_ERROR:{ + gchar *debug; + GError *err; + + gst_message_parse_error (msg, &err, &debug); + g_free (debug); + + /* Will abort the check */ + g_warning ("Error: %s\n", err->message); + g_error_free (err); + + g_main_loop_quit (loop); + break; + } + default: + break; + } + + return TRUE; +} + +GST_START_TEST (test_memory_stream) +{ + GMainLoop *loop; + GstElement *bin; + GstElement *src, *sink; + GstBus *bus; + + GMemoryInputStream *input; + GMemoryOutputStream *output; + + guint8 *in_data; + GByteArray *out_data; + gint i; + + got_eos = FALSE; + + in_data = g_new (guint8, 512); + for (i = 0; i < 512; i++) + in_data[i] = i % 256; + + input = + G_MEMORY_INPUT_STREAM (g_memory_input_stream_from_data (in_data, 512)); + g_memory_input_stream_set_free_data (input, TRUE); + + out_data = g_byte_array_new (); + output = G_MEMORY_OUTPUT_STREAM (g_memory_output_stream_new (out_data)); + g_memory_output_stream_set_free_on_close (output, FALSE); + + loop = g_main_loop_new (NULL, FALSE); + + bin = gst_pipeline_new ("bin"); + + src = gst_element_factory_make ("giostreamsrc", "src"); + fail_unless (src != NULL); + g_object_set (G_OBJECT (src), "stream", input, NULL); + + sink = gst_element_factory_make ("giostreamsink", "sink"); + fail_unless (sink != NULL); + g_object_set (G_OBJECT (sink), "stream", output, NULL); + + gst_bin_add_many (GST_BIN (bin), src, sink, NULL); + + fail_unless (gst_element_link_many (src, sink, NULL)); + + bus = gst_element_get_bus (bin); + gst_bus_add_watch (bus, message_handler, loop); + gst_object_unref (bus); + + gst_element_set_state (bin, GST_STATE_PLAYING); + + g_main_loop_run (loop); + + gst_element_set_state (bin, GST_STATE_NULL); + gst_object_unref (bin); + + fail_unless (got_eos); + + for (i = 0; i < 512; i++) { + fail_unless_equals_int (in_data[i], out_data->data[i]); + } + + g_byte_array_free (out_data, TRUE); + + g_object_unref (input); + g_object_unref (output); + + g_main_loop_unref (loop); + +} + +GST_END_TEST; + +Suite * +gio_testsuite (void) +{ + Suite *s = suite_create ("gio"); + TCase *tc_chain = tcase_create ("general"); + + suite_add_tcase (s, tc_chain); + tcase_add_test (tc_chain, test_memory_stream); + + return s; +} + +int +main (int argc, char **argv) +{ + int nf; + + Suite *s = gio_testsuite (); + 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; +} -- cgit v1.2.1