/* GStreamer * Copyright (C) 2009 Stefan Kost <ensonic@users.sf.net> * * controller.c: benchmark for interpolation control-source * * 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 <gst/gst.h> #include <gst/controller/gstcontroller.h> #include <gst/controller/gstinterpolationcontrolsource.h> /* a song in buzztard can easily reach 30000 here */ #define NUM_CP 15000 #define BLOCK_SIZE 64 static void event_loop (GstElement * pipe) { GstBus *bus; GstMessage *message = NULL; bus = gst_element_get_bus (GST_ELEMENT (pipe)); while (TRUE) { message = gst_bus_poll (bus, GST_MESSAGE_ANY, -1); g_assert (message != NULL); switch (message->type) { case GST_MESSAGE_EOS: gst_message_unref (message); return; 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); return; } default: gst_message_unref (message); break; } } } gint main (gint argc, gchar * argv[]) { gint res = 1; gint i, j; GstElement *src, *sink; GstElement *bin; GstController *ctrl; GstInterpolationControlSource *csource; GValue freq = { 0, }; GstClockTime bt, ct; GstClockTimeDiff elapsed; GstClockTime tick; gst_init (&argc, &argv); gst_controller_init (&argc, &argv); /* build pipeline */ bin = gst_pipeline_new ("pipeline"); src = gst_element_factory_make ("audiotestsrc", "gen_audio"); if (!src) { GST_WARNING ("need audiotestsrc from gst-plugins-base"); goto Error; } sink = gst_element_factory_make ("fakesink", "swallow_audio"); gst_bin_add_many (GST_BIN (bin), src, sink, NULL); if (!gst_element_link (src, sink)) { GST_WARNING ("can't link elements"); goto Error; } g_object_set (G_OBJECT (src), "wave", 7, /* sine table - we don't want to benchmark the fpu */ "num-buffers", NUM_CP, "samplesperbuffer", BLOCK_SIZE, NULL); tick = BLOCK_SIZE * GST_SECOND / 44100; /* add a controller to the source */ if (!(ctrl = gst_controller_new (G_OBJECT (src), "freq", NULL))) { GST_WARNING ("can't control source element"); goto Error; } /* create and configure control source */ csource = gst_interpolation_control_source_new (); gst_controller_set_control_source (ctrl, "freq", GST_CONTROL_SOURCE (csource)); gst_interpolation_control_source_set_interpolation_mode (csource, GST_INTERPOLATE_LINEAR); g_value_init (&freq, G_TYPE_DOUBLE); /* set control values, we set them in a linear order as we would when loading * a stored project */ bt = gst_util_get_timestamp (); for (i = 0; i < NUM_CP; i++) { g_value_set_double (&freq, g_random_double_range (50.0, 3000.0)); gst_interpolation_control_source_set (csource, i * tick, &freq); } ct = gst_util_get_timestamp (); elapsed = GST_CLOCK_DIFF (bt, ct); printf ("linear insert of control-points: %" GST_TIME_FORMAT "\n", GST_TIME_ARGS (elapsed)); /* set extra control values, we set them in arbitrary order to simulate * the user editing a project from the ui */ bt = gst_util_get_timestamp (); for (i = 0; i < 100; i++) { j = g_random_int_range (0, NUM_CP - 1); g_value_set_double (&freq, g_random_double_range (50.0, 3000.0)); gst_interpolation_control_source_set (csource, j * tick, &freq); } ct = gst_util_get_timestamp (); elapsed = GST_CLOCK_DIFF (bt, ct); printf ("random insert of control-points: %" GST_TIME_FORMAT "\n", GST_TIME_ARGS (elapsed)); { GstClockTime sample_duration = gst_util_uint64_scale_int (1, GST_SECOND, 44100); GstValueArray va = { "freq", BLOCK_SIZE * NUM_CP, sample_duration, NULL }; gdouble *values = g_new0 (gdouble, BLOCK_SIZE * NUM_CP); va.values = (gpointer *) values; bt = gst_util_get_timestamp (); gst_control_source_get_value_array (GST_CONTROL_SOURCE (csource), 0, &va); ct = gst_util_get_timestamp (); g_free (values); elapsed = GST_CLOCK_DIFF (bt, ct); printf ("linear array for control-points: %" GST_TIME_FORMAT "\n", GST_TIME_ARGS (elapsed)); } g_object_unref (csource); /* play, this test sequential reads */ bt = gst_util_get_timestamp (); if (gst_element_set_state (bin, GST_STATE_PLAYING)) { /* wait for EOS */ event_loop (bin); gst_element_set_state (bin, GST_STATE_NULL); } ct = gst_util_get_timestamp (); elapsed = GST_CLOCK_DIFF (bt, ct); printf ("linear read of control-points : %" GST_TIME_FORMAT "\n", GST_TIME_ARGS (elapsed)); /* cleanup */ g_object_unref (G_OBJECT (ctrl)); gst_object_unref (G_OBJECT (bin)); res = 0; Error: return res; }