Added simple latency tester.

Original commit message from CVS:
Added simple latency tester.

test/.gitignore

@@ -52,4 +52,4 @@ dvshow
 video2mp1
 mp3mad
 videotest2
-
+lat

test/Makefile.am

@@ -12,7 +12,7 @@ noinst_PROGRAMS = qtest $(GNOME_PROGS) record mp3 teardown buffer mp3parse \
 		  mp3play ac3parse ac3play dvdcat fake cobin \
 		  vidcapture avi2mpg mp2tomp1 mp1tomp1 pipetest \
 		  vidcapture2 mp2toavi mp3tovorbis xmmstest \
-		  mp3mad
+		  mp3mad lat
 
 SUBDIRS = xml bindings
 

test/lat.c

@@ -0,0 +1,225 @@
+#include <gst/gst.h>
+#include <stdlib.h>
+
+__inline__ void lat_read_tsc(guint64 *dst) {
+//#ifdef HAVE_RDTS
+/*
+  __asm__ __volatile__
+    ("rdtsc"
+     : "=a" (*(guint32 *)dst), "=d" (*(((guint32 *)dst) + 1))
+     :
+     : "eax", "edx");
+*/
+  __asm__ __volatile__
+    ("rdtsc"
+     : "=a" (*(guint32 *)dst), "=d" (*(((guint32 *)dst) + 1))
+     :
+     );
+//#else
+//  *dst = 0;
+//#endif
+}
+
+static guint64 max = 0, min = -1, total = 0;
+static guint count = 0;
+static guint print_del = 1;
+static guint iterations = 0;
+static guint mhz = 0;
+
+void handoff_src(GstElement *src, GstBuffer *buf, gpointer user_data) {
+  guint64 start;
+  lat_read_tsc(&start);
+  GST_BUFFER_TIMESTAMP(buf) = start;
+}
+
+void handoff_sink(GstElement *sink, GstBuffer *buf, gpointer user_data) {
+  guint64 end, d, avg;
+  guint avg_ns;
+
+  lat_read_tsc(&end);
+  d = end - GST_BUFFER_TIMESTAMP(buf);
+  if (d > max) max = d;
+  if (d < min) min = d;
+  total += d;
+  count++;
+  avg = total/count;
+  avg_ns = (guint)(1000.0*(double)avg/(double)mhz);
+  
+  if ((count % print_del) == 0) {
+    g_print("%07d:%08lld min:%08lld max:%08lld avg:%08lld avg-s:0.%09d\r",
+        count, d, min, max, avg, avg_ns);
+  }
+}
+
+GstElement *identity_add(GstPipeline *pipeline, GstElement *first, int count) {
+  GstElement *last, *ident;
+  int i;
+
+  last = first;
+
+  for (i=0; i<count; i++) {
+    ident = gst_elementfactory_make("identity","identity");
+    g_return_val_if_fail(ident != NULL,NULL);
+    gtk_object_set(GTK_OBJECT(ident),"silent",TRUE,NULL);
+    gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(ident));
+    gst_pad_connect(gst_element_get_pad(last,"src"),
+                    gst_element_get_pad(ident,"sink"));
+    last = ident;
+  }
+
+  return last;
+}
+
+GstElement *fakesrc() {
+  GstElement *src;
+
+  src = gst_elementfactory_make("fakesrc","src");
+  g_return_val_if_fail(src != NULL,NULL);
+  gtk_object_set(GTK_OBJECT(src),"silent",TRUE,NULL);
+  gtk_object_set(GTK_OBJECT(src),"num_buffers",iterations,NULL);
+  gtk_signal_connect(GTK_OBJECT(src),
+      "handoff",GTK_SIGNAL_FUNC(handoff_src),NULL);
+
+  return src;
+}
+
+GstElement *fakesink() {
+  GstElement *sink;
+
+  sink = gst_elementfactory_make("fakesink","fakesink");
+  g_return_val_if_fail(sink != NULL,NULL);
+  gtk_object_set(GTK_OBJECT(sink),"silent",TRUE,NULL);
+  gtk_signal_connect(GTK_OBJECT(sink),
+      "handoff",GTK_SIGNAL_FUNC(handoff_sink),NULL);
+
+  return sink;
+}
+
+GstPipeline *simple(int argc, int argi, char *argv[]) {
+  GstPipeline *pipeline;
+  GstElement *last, *src, *sink;
+  int idents;
+
+  if ((argc - argi) < 1) {
+    fprintf(stderr, "bad params");
+    return NULL;
+  }
+  idents = atoi(argv[argi]);
+  pipeline = GST_PIPELINE(gst_pipeline_new("pipeline"));
+  g_return_val_if_fail(pipeline != NULL,NULL);
+
+  src = fakesrc();
+  gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(src));
+  last = identity_add(pipeline, src, idents);
+  sink = fakesink();
+  gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(sink));
+  gst_pad_connect(gst_element_get_pad(last,"src"),
+                  gst_element_get_pad(sink,"sink"));
+
+  return pipeline;
+}
+
+GstPipeline *queue(int argc, int argi, char *argv[]) {
+  GstPipeline *pipeline;
+  GstElement *last, *src, *sink, *src_thr, *src_q, *sink_q, *sink_thr;
+  int idents;
+
+  if ((argc - argi) < 1) {
+    fprintf(stderr, "bad params");
+    return NULL;
+  }
+  idents = atoi(argv[argi]);
+
+  pipeline = GST_PIPELINE(gst_pipeline_new("pipeline"));
+  g_return_val_if_fail(pipeline != NULL,NULL);
+
+  src_thr = GST_ELEMENT(gst_thread_new("src_thread"));
+  g_return_val_if_fail(src_thr != NULL,NULL);
+
+  src = fakesrc();
+  g_return_val_if_fail(src != NULL,NULL);
+  gst_bin_add(GST_BIN(src_thr),GST_ELEMENT(src));
+
+  src_q = gst_elementfactory_make("queue","src_q");
+  g_return_val_if_fail(src_q != NULL,NULL);
+  gst_bin_add(GST_BIN(src_thr),GST_ELEMENT(src_q));
+  gst_pad_connect(gst_element_get_pad(src,"src"),
+                  gst_element_get_pad(src_q,"sink"));
+
+  gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(src_thr));
+
+  last = identity_add(pipeline, src_q, idents);
+
+  sink_q = gst_elementfactory_make("queue","sink_q");
+  g_return_val_if_fail(sink_q != NULL,NULL);
+  gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(sink_q));
+  gst_pad_connect(gst_element_get_pad(last,"src"),
+                  gst_element_get_pad(sink_q,"sink"));
+
+  sink_thr = GST_ELEMENT(gst_thread_new("sink_thread"));
+  g_return_val_if_fail(sink_thr != NULL,NULL);
+
+  sink = fakesink();
+  g_return_val_if_fail(sink != NULL,NULL);
+  gst_bin_add(GST_BIN(sink_thr),GST_ELEMENT(sink));
+
+  gst_bin_add(GST_BIN(pipeline),GST_ELEMENT(sink_thr));
+
+  gst_pad_connect(gst_element_get_pad(sink_q,"src"),
+                  gst_element_get_pad(sink,"sink"));
+
+  return pipeline;
+}
+
+struct test {
+  char *name;
+  char *params;
+  GstPipeline *(*func)(int argc, int argi, char *argv[]);
+};
+
+static struct test tests[] = {
+  {"simple", "ident_count", simple},
+  {"queue", "ident_count", queue},
+  {NULL, NULL, NULL}
+};
+
+int main(int argc,char *argv[]) {
+  GstPipeline *pipeline;
+  int i;
+  char *name;
+
+  gst_init(&argc,&argv);
+
+  if (argc < 3) {
+    fprintf(stderr, "usage: %s iterations print_del mhz test_name [test_params...]\n",
+        argv[0]);
+    for (i=0; tests[i].name; i++) {
+      fprintf(stderr, "  %s %s\n", tests[i].name, tests[i].params);
+    }
+    exit(1);
+  } else {
+    iterations = atoi(argv[1]);
+    print_del = atoi(argv[2]);
+    mhz = atoi(argv[3]);
+    name = argv[4];
+  }
+
+  pipeline = NULL;
+  for (i=0; tests[i].name && !pipeline; i++) {
+    if (!strcmp(name, tests[i].name)) {
+        pipeline = tests[i].func(argc,5,argv);
+    }
+  }
+  g_return_val_if_fail(pipeline != NULL, -1);
+
+  //xmlSaveFile("lat.gst", gst_xml_write(GST_ELEMENT(pipeline)));
+
+  gst_element_set_state(GST_ELEMENT(pipeline),GST_STATE_PLAYING);
+
+  while (count < iterations) {
+    gst_bin_iterate(GST_BIN(pipeline));
+  }
+  g_print("\n");
+
+  return 0;
+}