controller: add a benchmark to verify the switch to gsequence

tests/benchmarks/.gitignore

@@ -2,6 +2,7 @@ Makefile
 Makefile.in
 caps
 complexity
+controller
 gstclockstress
 gstpollstress
 mass-elements

tests/benchmarks/Makefile.am

@@ -1,6 +1,7 @@
 noinst_PROGRAMS = \
         caps \
         complexity \
+        controller \
         init \
         mass-elements \
         gstpollstress \
@@ -9,3 +10,6 @@ noinst_PROGRAMS = \
 LDADD = $(GST_OBJ_LIBS)
 AM_CFLAGS = $(GST_OBJ_CFLAGS)
 
+controller_CFLAGS  = $(GST_OBJ_CFLAGS) -I$(top_builddir)/libs
+controller_LDFLAGS = $(top_builddir)/libs/gst/controller/libgstcontroller-@GST_MAJORMINOR@.la
+

tests/benchmarks/controller.c

@@ -0,0 +1,172 @@
+/* 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>
+
+#define NUM_CP 5000
+#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));
+
+  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;
+}