Merge branch 'master' into 0.11
[platform/upstream/gstreamer.git] / tests / benchmarks / controller.c
1 /* GStreamer
2  * Copyright (C) 2009 Stefan Kost <ensonic@users.sf.net>
3  *
4  * controller.c: benchmark for interpolation control-source
5  *
6  * This library is free software; you can redistribute it and/or
7  * modify it under the terms of the GNU Library General Public
8  * License as published by the Free Software Foundation; either
9  * version 2 of the License, or (at your option) any later version.
10  *
11  * This library is distributed in the hope that it will be useful,
12  * but WITHOUT ANY WARRANTY; without even the implied warranty of
13  * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
14  * Library General Public License for more details.
15  *
16  * You should have received a copy of the GNU Library General Public
17  * License along with this library; if not, write to the
18  * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
19  * Boston, MA 02111-1307, USA.
20  */
21
22 #include <stdio.h>
23
24 #include <gst/gst.h>
25 #include <gst/controller/gstinterpolationcontrolsource.h>
26
27 /* a song in buzztard can easily reach 30000 here */
28 #define NUM_CP 15000
29 #define BLOCK_SIZE 64
30
31 static void
32 event_loop (GstElement * pipe)
33 {
34   GstBus *bus;
35   GstMessage *message = NULL;
36   gboolean running = TRUE;
37
38   bus = gst_element_get_bus (GST_ELEMENT (pipe));
39
40   while (running) {
41     message = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
42
43     g_assert (message != NULL);
44
45     switch (message->type) {
46       case GST_MESSAGE_EOS:
47         running = FALSE;
48         break;
49       case GST_MESSAGE_WARNING:{
50         GError *gerror;
51         gchar *debug;
52
53         gst_message_parse_warning (message, &gerror, &debug);
54         gst_object_default_error (GST_MESSAGE_SRC (message), gerror, debug);
55         g_error_free (gerror);
56         g_free (debug);
57         break;
58       }
59       case GST_MESSAGE_ERROR:{
60         GError *gerror;
61         gchar *debug;
62
63         gst_message_parse_error (message, &gerror, &debug);
64         gst_object_default_error (GST_MESSAGE_SRC (message), gerror, debug);
65         g_error_free (gerror);
66         g_free (debug);
67         running = FALSE;
68         break;
69       }
70       default:
71         break;
72     }
73     gst_message_unref (message);
74   }
75   gst_object_unref (bus);
76 }
77
78 gint
79 main (gint argc, gchar * argv[])
80 {
81   gint res = 1;
82   gint i, j;
83   GstElement *src, *sink;
84   GstElement *bin;
85   GstInterpolationControlSource *csource;
86   GstClockTime bt, ct;
87   GstClockTimeDiff elapsed;
88   GstClockTime tick;
89
90   gst_init (&argc, &argv);
91
92   /* build pipeline */
93   bin = gst_pipeline_new ("pipeline");
94   src = gst_element_factory_make ("audiotestsrc", "gen_audio");
95   if (!src) {
96     GST_WARNING ("need audiotestsrc from gst-plugins-base");
97     goto Error;
98   }
99   sink = gst_element_factory_make ("fakesink", "swallow_audio");
100
101   gst_bin_add_many (GST_BIN (bin), src, sink, NULL);
102   if (!gst_element_link (src, sink)) {
103     GST_WARNING ("can't link elements");
104     goto Error;
105   }
106
107   g_object_set (G_OBJECT (src), "wave", 7,      /* sine table - we don't want to benchmark the fpu */
108       "num-buffers", NUM_CP, "samplesperbuffer", BLOCK_SIZE, NULL);
109
110   tick = BLOCK_SIZE * GST_SECOND / 44100;
111
112   /* create and configure control source */
113   csource = gst_interpolation_control_source_new ();
114   gst_object_set_control_source (GST_OBJECT (src), "freq",
115       GST_CONTROL_SOURCE (csource));
116   g_object_set (csource, "mode", GST_INTERPOLATION_MODE_LINEAR, NULL);
117
118
119   /* set control values, we set them in a linear order as we would when loading
120    * a stored project
121    */
122   bt = gst_util_get_timestamp ();
123
124   for (i = 0; i < NUM_CP; i++) {
125     gst_timed_value_control_source_set ((GstTimedValueControlSource *) csource,
126         i * tick, g_random_double_range (50.0, 3000.0));
127   }
128
129   ct = gst_util_get_timestamp ();
130   elapsed = GST_CLOCK_DIFF (bt, ct);
131   printf ("linear insert of control-points: %" GST_TIME_FORMAT "\n",
132       GST_TIME_ARGS (elapsed));
133
134
135   /* set extra control values, we set them in arbitrary order to simulate
136    * the user editing a project from the ui
137    */
138   bt = gst_util_get_timestamp ();
139
140   for (i = 0; i < 100; i++) {
141     j = g_random_int_range (0, NUM_CP - 1);
142     gst_timed_value_control_source_set ((GstTimedValueControlSource *) csource,
143         j * tick, g_random_double_range (50.0, 3000.0));
144   }
145
146   ct = gst_util_get_timestamp ();
147   elapsed = GST_CLOCK_DIFF (bt, ct);
148   printf ("random insert of control-points: %" GST_TIME_FORMAT "\n",
149       GST_TIME_ARGS (elapsed));
150
151   {
152     GstClockTime sample_duration =
153         gst_util_uint64_scale_int (1, GST_SECOND, 44100);
154     gdouble *values = g_new0 (gdouble, BLOCK_SIZE * NUM_CP);
155
156     bt = gst_util_get_timestamp ();
157     gst_control_source_get_value_array (GST_CONTROL_SOURCE (csource), 0,
158         sample_duration, BLOCK_SIZE * NUM_CP, values);
159     ct = gst_util_get_timestamp ();
160     g_free (values);
161     elapsed = GST_CLOCK_DIFF (bt, ct);
162     printf ("linear array for control-points: %" GST_TIME_FORMAT "\n",
163         GST_TIME_ARGS (elapsed));
164   }
165
166   gst_object_unref (csource);
167
168   /* play, this test sequential reads */
169   bt = gst_util_get_timestamp ();
170
171   if (gst_element_set_state (bin, GST_STATE_PLAYING)) {
172     /* wait for EOS */
173     event_loop (bin);
174     gst_element_set_state (bin, GST_STATE_NULL);
175   }
176
177   ct = gst_util_get_timestamp ();
178   elapsed = GST_CLOCK_DIFF (bt, ct);
179   printf ("linear read of control-points  : %" GST_TIME_FORMAT "\n",
180       GST_TIME_ARGS (elapsed));
181
182   /* cleanup */
183   gst_object_unref (G_OBJECT (bin));
184   res = 0;
185 Error:
186   return res;
187 }