Commit 443cfe92 authored by Stefan Kost's avatar Stefan Kost
Browse files

removed another obsolete example

Original commit message from CVS:
removed another obsolete example
parent 02898c27
examples = filter demo-dparams
noinst_PROGRAMS = $(examples)
# we have nothing but apps here, we can do this safely
#include "config.h"
#include <stdio.h>
#include <string.h>
#include <math.h>
#include <gtk/gtk.h>
#include <gst/gst.h>
#include <gst/control/control.h>
#define ZERO(mem) memset(&mem, 0, sizeof(mem))
static gint
quit_live (GtkWidget * window, GdkEventAny * e, gpointer data)
gtk_main_quit ();
return FALSE;
static void
dynparm_log_value_changed (GtkAdjustment * adj, GstDParam * dparam)
gdouble value;
g_return_if_fail (dparam != NULL);
g_return_if_fail (GST_IS_DPARAM (dparam));
value = exp (adj->value);
g_print ("setting value to %f\n", value);
g_object_set (G_OBJECT (dparam), "value_double", value, NULL);
static void
dynparm_value_changed (GtkAdjustment * adj, GstDParam * dparam)
g_return_if_fail (dparam != NULL);
g_return_if_fail (GST_IS_DPARAM (dparam));
g_print ("setting value to %f\n", adj->value);
g_object_set (G_OBJECT (dparam), "value_double", (gdouble) adj->value, NULL);
main (int argc, char *argv[])
GtkWidget *window;
GtkWidget *hbox;
GtkAdjustment *volume_adj;
GtkAdjustment *freq_adj;
GtkWidget *volume_slider;
GtkWidget *freq_slider;
GstElement *thread, *sinesrc, *volfilter, *audiosink;
GstDParamManager *dpman;
GstDParam *volume;
GstDParam *freq;
GParamSpecDouble *spec;
gtk_init (&argc, &argv);
gst_init (&argc, &argv);
gst_control_init (&argc, &argv);
/***** construct the pipeline *****/
g_print ("creating elements\n");
thread = gst_thread_new ("live-example");
sinesrc = gst_element_factory_make ("sinesrc", "sine-source");
audiosink = gst_element_factory_make (DEFAULT_AUDIOSINK, "sound-sink");
volfilter = gst_element_factory_make ("volume", "volume-filter");
gst_bin_add_many (GST_BIN (thread), sinesrc, volfilter, audiosink, NULL);
gst_element_link_many (sinesrc, volfilter, audiosink, NULL);
/* this breaks with current alsa oss compat lib */
g_object_set (G_OBJECT (audiosink), "fragment", 0x00180008, NULL);
g_object_set (G_OBJECT (audiosink), "sync", FALSE, NULL);
g_object_set (G_OBJECT (sinesrc), "samplesperbuffer", 1024, NULL);
/***** set up the GUI *****/
window = gtk_window_new (GTK_WINDOW_TOPLEVEL);
gtk_window_set_default_size (GTK_WINDOW (window), 80, 400);
g_signal_connect (window, "delete_event", GTK_SIGNAL_FUNC (quit_live), NULL);
hbox = gtk_hbox_new (TRUE, 0);
gtk_container_add (GTK_CONTAINER (window), hbox);
/***** set up the dparams *****/
freq = gst_dpsmooth_new (G_TYPE_DOUBLE);
g_object_set (G_OBJECT (freq), "update_period", 2000000LL, NULL);
/* this defines the maximum slope that this *
* param can change. This says that in 50ms *
* the value can change by a maximum of one semitone *
* (the log of one semitone is 0.693) */
g_object_set (G_OBJECT (freq), "slope_delta_double", 0.693, NULL);
g_object_set (G_OBJECT (freq), "slope_time", 50000000LL, NULL);
dpman = gst_dpman_get_manager (sinesrc);
if (!gst_dpman_attach_dparam (dpman, "freq", freq))
g_assert_not_reached ();
gst_dpman_set_mode (dpman, "asynchronous");
spec = (GParamSpecDouble *) gst_dpman_get_param_spec (dpman, "freq");
freq_adj = (GtkAdjustment *) gtk_adjustment_new (log (spec->default_value),
log (spec->minimum), log (spec->maximum), 0.1, 0.01, 0.01);
freq_slider = gtk_vscale_new (freq_adj);
gtk_scale_set_digits (GTK_SCALE (freq_slider), 2);
gtk_box_pack_start (GTK_BOX (hbox), freq_slider, TRUE, TRUE, 0);
volume = gst_dpsmooth_new (G_TYPE_DOUBLE);
g_object_set (G_OBJECT (volume), "update_period", 2000000LL, NULL);
/* this defines the maximum slope that this *
* param can change. This says that in 50ms *
* the value can change from 0.0 to 1.0 */
g_object_set (G_OBJECT (volume), "slope_delta_double", 0.1, NULL);
g_object_set (G_OBJECT (volume), "slope_time", 50000000LL, NULL);
dpman = gst_dpman_get_manager (volfilter);
if (!gst_dpman_attach_dparam (dpman, "volume", volume))
g_assert_not_reached ();
gst_dpman_set_mode (dpman, "asynchronous");
g_object_set (G_OBJECT (volfilter), "mute", FALSE, NULL);
spec = (GParamSpecDouble *) gst_dpman_get_param_spec (dpman, "volume");
volume_adj =
(GtkAdjustment *) gtk_adjustment_new (spec->default_value, 0.0, 1.2, 0.1,
0.01, 0.01);
volume_slider = gtk_vscale_new (volume_adj);
gtk_scale_set_digits (GTK_SCALE (volume_slider), 2);
gtk_box_pack_start (GTK_BOX (hbox), volume_slider, TRUE, TRUE, 0);
/***** set up the handlers and such *****/
/*gtk_signal_connect(volume_adj,"value-changed",GTK_SIGNAL_FUNC(volume_changed),sinesrc); */
g_signal_connect (volume_adj, "value-changed",
GTK_SIGNAL_FUNC (dynparm_value_changed), volume);
g_signal_connect (freq_adj, "value-changed",
GTK_SIGNAL_FUNC (dynparm_log_value_changed), freq);
gtk_adjustment_value_changed (volume_adj);
gtk_adjustment_value_changed (freq_adj);
g_print ("starting pipeline\n");
/***** start everything up *****/
gst_element_set_state (thread, GST_STATE_PLAYING);
gtk_widget_show_all (window);
gtk_main ();
return 0;
* filter.c
* demo application for filters using dparams
* dparams get their sliders which you can play with
* you can also enter an input and output part of a pipeline
#include "config.h"
#include <string.h>
#include <gtk/gtk.h>
#include <gst/gst.h>
#include <gst/control/control.h>
/* filter UI data */
struct _filter_ui
GtkWidget *window; /* top-level interface window */
GtkWidget *buttons; /* all of the control buttons */
GtkWidget *parse, *play, *stop; /* control buttons */
GtkWidget *feedback; /* here's where we'll tell you stuff */
GtkTextBuffer *fb_buffer; /* feedback buffer */
GtkWidget *selection; /* the place to input element stuff */
GtkWidget *input, *filter, *output; /* the selection widgets */
GtkWidget *control; /* the dynamically generated control UI */
typedef struct _filter_ui _filter_ui_t;
/* back-end data */
struct _filter_data
_filter_ui_t *ui; /* the UI data */
gchar *input_pipe, *output_pipe, *filter_element;
gchar *pipe_string;
GList *filter_choices;
gboolean playing;
GstElement *input, *output; /* these are in and out bins */
GstElement *pipeline;
GstElement *filter;
typedef struct _filter_data _filter_data_t;
/* internal prototypes when they can't be avoided */
void cb_remove_and_destroy (GtkWidget * widget, gpointer user_data);
//void cb_dynparm_value_changed (GtkWidget *widget, gpointer user_data);
void cb_dynparm_value_changed (GtkRange * range, GstDParam * dparam);
/* GStreamer helper functions go here */
/* go through a bin, finding the one pad that is unconnected in the given
* direction, and return a ghost pad */
GstPad *
gst_bin_find_unconnected_pad (GstBin * bin, GstPadDirection direction,
gchar * name)
GstPad *pad = NULL;
GList *elements = NULL;
const GList *pads = NULL;
GstElement *element = NULL;
g_print ("DEBUG: find_unconnected start\n");
elements = (GList *) gst_bin_get_list (bin);
/* traverse all elements looking for unconnected pads */
while (elements && pad == NULL) {
element = GST_ELEMENT (elements->data);
g_print ("DEBUG: looking in element %s\n", gst_element_get_name (element));
pads = gst_element_get_pad_list (element);
while (pads) {
/* check if the direction matches */
if (GST_PAD_DIRECTION (GST_PAD (pads->data)) == direction) {
if (GST_PAD_PEER (GST_PAD (pads->data)) == NULL) {
/* found it ! */
g_print ("DEBUG: found an unconnected pad !\n");
pad = GST_PAD (pads->data);
if (pad)
break; /* found one already */
pads = g_list_next (pads);
elements = g_list_next (elements);
g_print ("DEBUG: find_unconnected stop\n");
if (pad == NULL) /* we didn't find it at all */
return NULL;
pad = gst_ghost_pad_new (name, pad);
return pad;
ui_feedback_add_text (_filter_ui_t * ui, const gchar * text)
GtkTextIter iter;
gtk_text_buffer_get_end_iter (ui->fb_buffer, &iter);
gtk_text_buffer_insert (ui->fb_buffer, &iter, text, -1);
ui_feedback_add (_filter_ui_t * ui, const gchar * format, ...)
va_list args;
gchar *buffer = NULL;
va_start (args, format);
buffer = g_strdup_vprintf (format, args);
va_end (args);
ui_feedback_add_text (ui, buffer);
g_free (buffer);
ui_feedback_clear (_filter_ui_t * ui)
gtk_text_buffer_set_text (ui->fb_buffer, "", 0);
/* create the control widget using the element's dynparams
* control is a vbox which we need to empty first */
ui_control_create (GstElement * element, GtkWidget * control, _filter_ui_t * ui)
GtkWidget *hbox = NULL;
GtkWidget *widget = NULL;
GstDParamManager *dpman = NULL;
GstDParam *dparam = NULL;
GParamSpec **specs = NULL;
int i = 0;
g_assert (GTK_IS_VBOX (control));
/* empty control vbox */
g_print ("DEBUG: emptying control widget\n");
gtk_container_foreach (GTK_CONTAINER (control), cb_remove_and_destroy,
(gpointer) control);
g_print ("DEBUG: adding label to control widget\n");
widget = gtk_label_new ("Dynamic Parameters");
gtk_container_add (GTK_CONTAINER (control), widget);
gtk_widget_show (widget);
if ((dpman = gst_dpman_get_manager (element))) {
ui_feedback_add (ui, "Found Dynamic Parameters on filter element.\n");
specs = gst_dpman_list_dparam_specs (dpman);
for (i = 0; specs[i] != NULL; ++i) {
hbox = gtk_hbox_new (FALSE, 0);
widget = gtk_label_new (g_param_spec_get_name (specs[i]));
gtk_container_add (GTK_CONTAINER (hbox), widget);
gtk_widget_show (widget);
switch (G_PARAM_SPEC_VALUE_TYPE (specs[i])) {
case G_TYPE_INT64:
widget = gtk_hscale_new_with_range (
(gdouble) (((GParamSpecInt64 *) specs[i])->minimum),
(gdouble) (((GParamSpecInt64 *) specs[i])->maximum), 1.0);
gtk_range_set_value (GTK_RANGE (widget),
(gdouble) ((GParamSpecInt64 *) specs[i])->default_value);
case G_TYPE_INT:
widget = gtk_hscale_new_with_range (
(gdouble) (((GParamSpecInt *) specs[i])->minimum),
(gdouble) (((GParamSpecInt *) specs[i])->maximum), 1.0);
gtk_range_set_value (GTK_RANGE (widget),
(gdouble) ((GParamSpecInt *) specs[i])->default_value);
widget = gtk_hscale_new_with_range (
(gdouble) (((GParamSpecFloat *) specs[i])->minimum),
(gdouble) (((GParamSpecFloat *) specs[i])->maximum), 0.00001);
gtk_range_set_value (GTK_RANGE (widget),
(gdouble) ((GParamSpecFloat *) specs[i])->default_value);
/* create the dparam object */
dparam = gst_dpsmooth_new (G_PARAM_SPEC_VALUE_TYPE (specs[i]));
g_object_set (G_OBJECT (dparam), "update_period", 2000000LL, NULL);
if (!gst_dpman_attach_dparam (dpman,
(gchar *) g_param_spec_get_name (specs[i]), dparam))
g_assert_not_reached ();
gst_dpman_set_mode (dpman, "asynchronous");
g_signal_connect (widget, "value-changed",
G_CALLBACK (cb_dynparm_value_changed), dparam);
cb_dynparm_value_changed (GTK_RANGE (widget), dparam);
gtk_container_add (GTK_CONTAINER (hbox), widget);
gtk_widget_show (widget);
gtk_container_add (GTK_CONTAINER (control), hbox);
gtk_widget_show (hbox);
/* all the pretty callbacks gather here please */
cb_remove_and_destroy (GtkWidget * widget, gpointer user_data)
GtkContainer *container = GTK_CONTAINER (user_data);
g_print ("DEBUG: trying to remove widget from a container.\n");
gtk_container_remove (container, widget);
gtk_widget_destroy (widget);
/* when the scale associated with a dparam changes, respond */
cb_dynparm_value_changed (GtkRange * range, GstDParam * dparam)
GstDParam *dparam = GST_DPARAM (user_data);
GtkHScale *adj = GTK_HSCALE (widget);
gdouble value = 0.0;
g_assert (GST_IS_DPARAM (dparam));
g_assert (GTK_IS_RANGE (range));
value = gtk_range_get_value (range);
g_print ("DEBUG: setting value to %f\n", value);
case G_TYPE_INT64:
g_object_set (G_OBJECT (dparam), "value_int64", (gint64) value, NULL);
case G_TYPE_INT:
g_object_set (G_OBJECT (dparam), "value_int", (gint) value, NULL);
g_object_set (G_OBJECT (dparam), "value_float", (gfloat) value, NULL);
cb_entry_activate (GtkEntry * entry, gpointer user_data)
g_print ("DEBUG: oi ! you activated an entry !\n");
g_print ("DEBUG: pipeline: %s\n", gtk_entry_get_text (entry));
cb_play_clicked (GtkButton * button, gpointer * user_data)
_filter_data_t *fd = (_filter_data_t *) user_data;
g_return_if_fail (GST_IS_PIPELINE (fd->pipeline));
if (GST_STATE (fd->pipeline) == GST_STATE_PLAYING) {
ui_feedback_add (fd->ui, "Pipeline is already playing !\n");
gst_element_set_state (fd->pipeline, GST_STATE_PLAYING);
cb_stop_clicked (GtkButton * button, gpointer * user_data)
_filter_data_t *fd = (_filter_data_t *) user_data;
if (GST_STATE (fd->pipeline) != GST_STATE_PLAYING) {
ui_feedback_add (fd->ui, "Pipeline is not playing !\n");
gst_element_set_state (fd->pipeline, GST_STATE_NULL);
cb_parse_clicked (GtkButton * button, gpointer * user_data)
_filter_data_t *fd = (_filter_data_t *) user_data;
GtkCombo *filter = GTK_COMBO (fd->ui->filter);
GError *error = NULL;
GstPad *src_pad, *sink_pad;
g_print ("DEBUG: you pressed parse.\n");
ui_feedback_clear (fd->ui);
ui_feedback_add (fd->ui, "Parsing pipeline ...\n");
if (fd->input_pipe)
g_free (fd->input_pipe);
if (fd->output_pipe)
g_free (fd->output_pipe);
if (fd->filter_element)
g_free (fd->filter_element);
fd->input_pipe = g_strdup_printf ("bin.( %s )",
gtk_entry_get_text (GTK_ENTRY (fd->ui->input)));
fd->output_pipe = g_strdup_printf ("bin.( %s )",
gtk_entry_get_text (GTK_ENTRY (fd->ui->output)));
/* gtkcombo.h says I can access the entry field directly */
fd->filter_element =
g_strdup (gtk_entry_get_text (GTK_ENTRY (filter->entry)));
g_print ("Input pipeline :\t%s (%d)\n", fd->input_pipe,
(int) strlen (fd->input_pipe));
g_print ("Filter element :\t%s (%d)\n", fd->filter_element,
(int) strlen (fd->filter_element));
g_print ("Output pipeline :\t%s (%d)\n", fd->output_pipe,
(int) strlen (fd->output_pipe));
/* try to create in and out bins */
if (strlen (fd->input_pipe) == 0) {
ui_feedback_add (fd->ui, "Error : try setting an input pipe.\n");
if (fd->input)
gst_object_unref (fd->input);
fd->input = GST_ELEMENT (gst_parse_launch (fd->input_pipe, &error));
if (error) {
ui_feedback_add (fd->ui, "Error : parsing input pipeline : %s\n",
g_error_free (error);
if (strlen (fd->output_pipe) == 0) {
ui_feedback_add (fd->ui, "Error : try setting an output pipe.\n");
if (fd->output)
gst_object_unref (fd->output);
fd->output = GST_ELEMENT (gst_parse_launch (fd->output_pipe, &error));
if (error) {
ui_feedback_add (fd->ui, "Error : parsing output pipeline : %s\n",
g_error_free (error);
/* try to create filter */
if (fd->filter)
gst_object_unref (fd->filter);
fd->filter = gst_element_factory_make (fd->filter_element, "filter");
if (fd->filter == NULL) {
ui_feedback_add (fd->ui, "Error : could not create element %s\n",
/* set up dynparam controls for filter */
ui_control_create (fd->filter, fd->ui->control, fd->ui);
/* create toplevel bin */
fd->pipeline = gst_thread_new ("toplevel");
/* add the players to it */
gst_bin_add_many (GST_BIN (fd->pipeline),
fd->input, fd->filter, fd->output, NULL);
/* connect filter to input and output bin */
src_pad = gst_bin_find_unconnected_pad (GST_BIN (fd->input), GST_PAD_SRC,
if (src_pad == NULL) {
ui_feedback_add (fd->ui,
"Error : could not find an unconnected source pad !\n");
sink_pad = gst_bin_find_unconnected_pad (GST_BIN (fd->output), GST_PAD_SINK,
if (sink_pad == NULL) {
ui_feedback_add (fd->ui,
"Error : could not find an unconnected sink pad !\n");
gst_element_add_pad (fd->input, src_pad);
gst_element_add_pad (fd->output, sink_pad);
gst_element_link_many (fd->input, fd->filter, fd->output, NULL);
if (fd->pipe_string)
g_free (fd->pipe_string);
fd->pipe_string = g_strdup_printf ("%s ! %s ! %s", fd->input_pipe,
fd->filter_element, fd->output_pipe);
g_print ("Pipeline : %s\n", fd->pipe_string);
ui_feedback_add (fd->ui, "Complete parsed pipeline: %s\n", fd->pipe_string);
/* find out the list of choices for GStreamer filters */
GList *
get_filter_choices (void)
GList *choices = NULL;
choices = g_list_append (choices, "volume");
choices = g_list_append (choices, "ladspa_lpf");
choices = g_list_append (choices, "ladspa_hpf");
return choices;
init_data (_filter_data_t * fd)
fd->input_pipe = NULL;
fd->output_pipe = NULL;
fd->filter_element = NULL;
fd->pipe_string = NULL;
fd->filter_choices = get_filter_choices ();
/* GStreamer stuff */
fd->input = NULL;
fd->output = NULL;
fd->filter = NULL;
fd->pipeline = NULL;
fd->playing = FALSE;
create_ui (_filter_ui_t * fui, _filter_data_t * fd)
GtkWidget *widget; /* temporary widget */
GtkWidget *vbox; /* temporary vbox */
g_print ("DEBUG: creating top-level window\n");
fui->window = gtk_window_new (GTK_WINDOW_TOPLEVEL);
widget = gtk_vbox_new (FALSE, 0);
gtk_container_add (GTK_CONTAINER (fui->window), widget);
gtk_window_set_title (GTK_WINDOW (fui->window), "Gee, I can set titles too");
/* top level window division */
g_print ("DEBUG: creating top-level window contents\n");