diff options
Diffstat (limited to 'gstreamer-properties/pipeline-tests.c')
| -rw-r--r-- | gstreamer-properties/pipeline-tests.c | 279 |
1 files changed, 279 insertions, 0 deletions
diff --git a/gstreamer-properties/pipeline-tests.c b/gstreamer-properties/pipeline-tests.c new file mode 100644 index 0000000..db5a387 --- /dev/null +++ b/gstreamer-properties/pipeline-tests.c @@ -0,0 +1,279 @@ +/* -*- mode: c; style: linux -*- */ +/* -*- c-basic-offset: 2 -*- */ + +/* pipeline-tests.c + * Copyright (C) 2002 Jan Schmidt + * Copyright (C) 2005 Tim-Philipp Müller <tim centricular net> + * + * Written by: Jan Schmidt <[email protected]> + * + * This program is free software; you can redistribute it and/or modify + * it under the terms of the GNU General Public License as published by + * the Free Software Foundation; either version 2, or (at your option) + * any later version. + * + * This program 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 General Public License for more details. + * + * You should have received a copy of the GNU General Public License + * along with this program; if not, write to the Free Software + * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA + * 02111-1307, USA. + */ +#ifdef HAVE_CONFIG_H +# include <config.h> +#endif + +#include <locale.h> +#include <string.h> + +#include <glib.h> +#include <glib/gi18n.h> +#include <gtk/gtk.h> +#include <gst/gst.h> + +#include "pipeline-tests.h" +#define WID(s) gtk_builder_get_object (builder, s) +static guint timeout_tag; + +static GstElement *gst_test_pipeline; + +static void pipeline_error_dlg (GtkWindow * parent, + GSTPPipelineDescription * pipeline_desc, const gchar * error_message); + +/* User responded in the dialog */ +static void +user_test_pipeline_response (GtkDialog * widget, gint response_id, + GtkBuilder * dialog) +{ + /* Close the window causing the test to end */ + gtk_widget_hide (GTK_WIDGET (widget)); +} + +/* Timer timeout has been occurred */ +static gint +user_test_pipeline_timeout (gpointer data) +{ + gtk_progress_bar_pulse (GTK_PROGRESS_BAR (data)); + return TRUE; +} + +gchar * +gst_pipeline_string_from_desc (GSTPPipelineDescription * pipeline_desc) +{ + gchar *pipeline = NULL; + if (pipeline_desc->device != NULL && *pipeline_desc->device != '\0') { + pipeline = g_strdup_printf ("%s device=\"%s\"", pipeline_desc->pipeline, + pipeline_desc->device); + } + else + pipeline = pipeline_desc->pipeline; + + return pipeline; +} + +gchar * +gst_pipeline_string_get_property_value (const gchar *pipeline_str, const gchar *propertyname) +{ + gchar **pipeline_nodes = NULL; + gchar *node = NULL; + gchar *node_value = NULL; + gchar **node_split = NULL; + gint i = 0; + + g_assert (pipeline_str != NULL); + + pipeline_nodes = g_strsplit (pipeline_str, " ", -1); + + while ((node = pipeline_nodes[i++])) { + /* Split into key = value pair */ + node_split = g_strsplit_set (node, "=", -1); + if (node_split != NULL && node_split[1] != NULL) { + if (!strcmp (node_split[0], propertyname)) { + node_value = g_shell_unquote(node_split[1], NULL); + } + } + g_strfreev (node_split); + + if (node_value != NULL) break; + } + + g_strfreev (pipeline_nodes); + + return node_value; +} + +/* Build the pipeline */ +static gboolean +build_test_pipeline (GSTPPipelineDescription * pipeline_desc, GError ** p_err) +{ + const gchar *in_between = NULL; + gboolean return_val = FALSE; + gchar *test_pipeline_str = NULL; + gchar *full_pipeline_str = NULL; + + g_assert (p_err != NULL); + + switch (pipeline_desc->test_type) { + case TEST_PIPE_AUDIOSINK: + test_pipeline_str = gst_properties_mateconf_get_string ("default/audiosink"); + break; + case TEST_PIPE_VIDEOSINK: + test_pipeline_str = gst_properties_mateconf_get_string ("default/videosink"); + break; + case TEST_PIPE_SUPPLIED: + test_pipeline_str = g_strdup (pipeline_desc->test_pipe); + break; + } + + switch (pipeline_desc->type) { + case PIPE_TYPE_AUDIOSINK: + case PIPE_TYPE_AUDIOSRC: + in_between = "audioconvert ! audioresample"; + break; + default: + in_between = "ffmpegcolorspace"; + break; + } + + switch (pipeline_desc->type) { + case PIPE_TYPE_AUDIOSINK: + case PIPE_TYPE_VIDEOSINK: + full_pipeline_str = g_strdup_printf ("%s ! %s ! %s", + test_pipeline_str, in_between, gst_pipeline_string_from_desc(pipeline_desc)); + break; + case PIPE_TYPE_AUDIOSRC: + case PIPE_TYPE_VIDEOSRC: + full_pipeline_str = g_strdup_printf ("%s ! %s ! %s", + gst_pipeline_string_from_desc(pipeline_desc), in_between, test_pipeline_str); + break; + } + + if (full_pipeline_str) { + gst_test_pipeline = gst_parse_launch (full_pipeline_str, p_err); + + if (*p_err == NULL && gst_test_pipeline != NULL) + return_val = TRUE; + } + + g_free (test_pipeline_str); + g_free (full_pipeline_str); + + return return_val; +} + +static void +pipeline_error_dlg (GtkWindow * parent, + GSTPPipelineDescription * pipeline_desc, const gchar * error_message) +{ + gchar *errstr; + + if (error_message) { + errstr = g_strdup_printf ("%s: %s", pipeline_desc->name, error_message); + } else { + errstr = g_strdup_printf (_("Failed to construct test pipeline for '%s'"), + pipeline_desc->name); + } + + if (parent == NULL) { + g_printerr ("%s", errstr); + } else { + GtkWidget *dialog; + + dialog = gtk_message_dialog_new (parent, + GTK_DIALOG_DESTROY_WITH_PARENT, + GTK_MESSAGE_ERROR, GTK_BUTTONS_CLOSE, "%s", errstr); + + gtk_dialog_run (GTK_DIALOG (dialog)); + gtk_widget_destroy (dialog); + } + + g_free (errstr); +} + +/* Construct and run the pipeline. Use the indicated parent + * for any user interaction window. + */ +void +user_test_pipeline (GtkBuilder * builder, + GtkWindow * parent, GSTPPipelineDescription * pipeline_desc) +{ + GstStateChangeReturn ret; + GtkDialog *dialog = NULL; + GstMessage *msg; + GError *err = NULL; + GstBus *bus; + + gst_test_pipeline = NULL; + + /* Build the pipeline */ + if (!build_test_pipeline (pipeline_desc, &err)) { + /* Show the error pipeline */ + pipeline_error_dlg (parent, pipeline_desc, (err) ? err->message : NULL); + if (err) + g_error_free (err); + return; + } + + /* Setup the 'click ok when done' dialog */ + if (parent) { + dialog = GTK_DIALOG (WID ("test_pipeline")); + /* g_return_if_fail(dialog != NULL); */ + gtk_window_set_modal (GTK_WINDOW (dialog), TRUE); + gtk_window_set_transient_for (GTK_WINDOW (dialog), parent); + g_signal_connect (G_OBJECT (dialog), "response", + (GCallback) user_test_pipeline_response, builder); + } + + /* Start the pipeline and wait for max. 3 seconds for it to start up */ + gst_element_set_state (gst_test_pipeline, GST_STATE_PLAYING); + ret = gst_element_get_state (gst_test_pipeline, NULL, NULL, 3 * GST_SECOND); + + /* Check if any error messages were posted on the bus */ + bus = gst_element_get_bus (gst_test_pipeline); + msg = gst_bus_poll (bus, GST_MESSAGE_ERROR, 0); + gst_object_unref (bus); + + if (msg != NULL) { + gchar *dbg = NULL; + + gst_message_parse_error (msg, &err, &dbg); + gst_message_unref (msg); + + g_message ("Error running pipeline '%s': %s [%s]", pipeline_desc->name, + (err) ? err->message : "(null error)", + (dbg) ? dbg : "no additional debugging details"); + pipeline_error_dlg (parent, pipeline_desc, err->message); + g_error_free (err); + g_free (dbg); + } else if (ret != GST_STATE_CHANGE_SUCCESS && ret != GST_STATE_CHANGE_ASYNC) { + pipeline_error_dlg (parent, pipeline_desc, NULL); + } else { + /* Show the dialog */ + if (dialog) { + gtk_window_present (GTK_WINDOW (dialog)); + timeout_tag = + g_timeout_add (50, user_test_pipeline_timeout, + WID ("test_pipeline_progress")); + gtk_dialog_run (GTK_DIALOG (dialog)); + g_source_remove (timeout_tag); + gtk_widget_hide (GTK_WIDGET (dialog)); + } else { + gint secs; + + /* A bit hacky: No parent dialog, run in limited test mode */ + for (secs = 0; secs < 5; ++secs) { + g_print ("."); + g_usleep (G_USEC_PER_SEC); /* 1 second */ + } + } + } + + if (gst_test_pipeline) { + gst_element_set_state (gst_test_pipeline, GST_STATE_NULL); + gst_object_unref (gst_test_pipeline); + gst_test_pipeline = NULL; + } +} |