tests/examples/adapter/: Add new files from the previous commit

Original commit message from CVS:
* tests/examples/adapter/Makefile.am:
* tests/examples/adapter/adapter_test.c: (run_test_take),
(run_test_take_buffer), (run_tests), (main):
Add new files from the previous commit

ChangeLog

@@ -1,3 +1,11 @@
+2006-11-09  Jan Schmidt  <thaytan@mad.scientist.com>
+
+	* tests/examples/adapter/Makefile.am:
+	* tests/examples/adapter/adapter_test.c: (run_test_take),
+	(run_test_take_buffer), (run_tests), (main):
+
+	Add new files from the previous commit
+
 2006-11-09  Jan Schmidt  <thaytan@mad.scientist.com>
 
 	* Makefile.am:

tests/examples/adapter/Makefile.am

@@ -0,0 +1,4 @@
+noinst_PROGRAMS = adapter_test
+
+adapter_test_LDADD = $(GST_OBJ_LIBS) $(top_builddir)/libs/gst/base/libgstbase-@GST_MAJORMINOR@.la
+adapter_test_CFLAGS = $(GST_OBJ_CFLAGS)

tests/examples/adapter/adapter_test.c

@@ -0,0 +1,131 @@
+#include <stdlib.h>
+#include <string.h>
+#include <unistd.h>
+#include <sys/times.h>
+
+#include <gst/gst.h>
+#include <gst/base/gstadapter.h>
+
+struct TestParams
+{
+  gint tot_size;
+  gint read_size;
+  gint write_size;
+};
+
+/* This test pushes 'n' buffers of 'write size' into an adapter, then reads
+ * them out in 'read size' sized pieces, using take and then take_buffer, 
+ * and prints the timings */
+
+struct TestParams param_sets[] = {
+/* These values put ~256MB in 1MB chunks in an adapter, then reads them out
+ * in 250kb blocks */
+  {256000000, 250000, 1000000},
+/* These values put ~256MB in 1000 byte chunks in an adapter, then reads them 
+ * out in 200 byte blocks */
+  {25600000, 200, 1000},
+/* These values put ~256MB in 200 chunks in an adapter, then reads them out
+ * in 1000 byte blocks */
+  {25600000, 1000, 200}
+};
+const gint n_tests = sizeof (param_sets) / sizeof (struct TestParams);
+
+gint ticks_per_sec;
+
+static void
+run_test_take (struct TestParams *params)
+{
+  /* Create an adapter and feed it data of fixed size, then retrieve it in 
+   * a different size */
+  GstAdapter *adapter = gst_adapter_new ();
+  guint8 *data;
+  GstBuffer *buf;
+  int i;
+  gint ntimes = params->tot_size / params->write_size;
+
+  for (i = 0; i < ntimes; i++) {
+    buf = gst_buffer_new_and_alloc (params->write_size);
+    memset (GST_BUFFER_DATA (buf), 0, params->write_size);
+
+    gst_adapter_push (adapter, buf);
+  }
+
+  do {
+    data = gst_adapter_take (adapter, params->read_size);
+    if (data == NULL)
+      break;
+    g_free (data);
+  } while (TRUE);
+
+  g_object_unref (adapter);
+}
+
+static void
+run_test_take_buffer (struct TestParams *params)
+{
+  /* Create an adapter and feed it data of fixed size, then retrieve it in 
+   * a different size
+   */
+  GstAdapter *adapter = gst_adapter_new ();
+  GstBuffer *buf;
+  int i;
+  gint ntimes = params->tot_size / params->write_size;
+
+  for (i = 0; i < ntimes; i++) {
+    buf = gst_buffer_new_and_alloc (params->write_size);
+    memset (GST_BUFFER_DATA (buf), 0, params->write_size);
+
+    gst_adapter_push (adapter, buf);
+  }
+
+  do {
+    buf = gst_adapter_take_buffer (adapter, params->read_size);
+    if (buf == NULL)
+      break;
+    gst_buffer_unref (buf);
+  } while (TRUE);
+
+  g_object_unref (adapter);
+}
+
+void
+run_tests (struct TestParams *params)
+{
+  struct tms time_data;
+  gdouble start;
+  gdouble dur;
+
+  g_print ("Running on %d bytes, writing %d bytes/buf, reading %d bytes/buf\n",
+      params->tot_size, params->write_size, params->read_size);
+
+  start = 0.0;
+  run_test_take (params);
+
+  times (&time_data);
+  dur = (gdouble) (time_data.tms_utime + time_data.tms_stime) / ticks_per_sec;
+  g_print ("Time for take test: %g secs\n", dur - start);
+
+  start = dur;
+  run_test_take_buffer (params);
+
+  times (&time_data);
+  dur = (gdouble) (time_data.tms_utime + time_data.tms_stime) / ticks_per_sec;
+  g_print ("Time for TakeBuffer test: %g secs\n", dur - start);
+
+  g_print ("\n");
+}
+
+int
+main (int argc, char **argv)
+{
+  gint i;
+
+  ticks_per_sec = sysconf (_SC_CLK_TCK);
+
+  gst_init (&argc, &argv);
+
+  for (i = 0; i < n_tests; i++)
+    run_tests (param_sets + i);
+
+  return 0;
+}