debug: rename debug to debugutils to avoid clash with --disable-debug. Fixes #562168

23 files changed, 4935 insertions, 0 deletions

diff --git a/gst/debugutils/Makefile.am b/gst/debugutils/Makefile.am
new file mode 100644
index 00000000..8c53cdf3
--- /dev/null
+++ b/gst/debugutils/Makefile.am
@@ -0,0 +1,49 @@
+if GST_HAVE_MMAP
+EFENCE_PLUGIN=libgstefence.la
+else
+EFENCE_PLUGIN=
+endif
+
+plugin_LTLIBRARIES = $(EFENCE_PLUGIN) libgstdebug.la libgstnavigationtest.la 
+
+noinst_HEADERS = \
+	efence.h \
+	gstnavigationtest.h \
+	gstnavseek.h \
+	gstpushfilesrc.h \
+	gsttaginject.h \
+	progressreport.h \
+	tests.h
+
+libgstefence_la_SOURCES = efence.c
+libgstefence_la_CFLAGS = $(GST_CFLAGS)
+libgstefence_la_LIBADD = $(GST_LIBS)
+libgstefence_la_LDFLAGS = $(GST_PLUGIN_LDFLAGS)
+libgstefence_la_LIBTOOLFLAGS = --tag=disable-static
+
+libgstnavigationtest_la_SOURCES = gstnavigationtest.c
+libgstnavigationtest_la_CFLAGS = $(GST_CFLAGS) $(GST_BASE_CFLAGS) \
+				 $(GST_PLUGINS_BASE_CFLAGS)
+libgstnavigationtest_la_LIBADD = $(GST_LIBS) $(GST_BASE_LIBS) \
+	$(GST_PLUGINS_BASE_LIBS) -lgstvideo-@GST_MAJORMINOR@ $(LIBM)
+libgstnavigationtest_la_LDFLAGS = $(GST_PLUGIN_LDFLAGS)
+libgstnavigationtest_la_LIBTOOLFLAGS = --tag=disable-static
+
+libgstdebug_la_SOURCES = \
+	gstdebug.c \
+	breakmydata.c \
+	gstnavseek.c \
+	gstpushfilesrc.c \
+	gsttaginject.c \
+	rndbuffersize.c \
+	progressreport.c \
+	tests.c \
+	testplugin.c
+
+# 	negotiation.c
+
+libgstdebug_la_CFLAGS = $(GST_CFLAGS) $(GST_BASE_CFLAGS)
+libgstdebug_la_LIBADD = $(GST_LIBS) $(GST_BASE_LIBS)
+libgstdebug_la_LDFLAGS = $(GST_PLUGIN_LDFLAGS)
+libgstdebug_la_LIBTOOLFLAGS = --tag=disable-static
+
diff --git a/gst/debugutils/breakmydata.c b/gst/debugutils/breakmydata.c
new file mode 100644
index 00000000..63e30b6c
--- /dev/null
+++ b/gst/debugutils/breakmydata.c
@@ -0,0 +1,297 @@
+/* GStreamer
+ * Copyright (C) 2004 Benjamin Otte <otte@gnome.org>
+ *
+ * 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.
+ */
+/**
+ * SECTION:element-breakmydata
+ *
+ * This element modifies the contents of the buffer it is passed randomly
+ * according to the parameters set.
+ * It otherwise acts as an identity.
+ */
+
+#ifdef HAVE_CONFIG_H
+#  include "config.h"
+#endif
+
+#include <gst/gst.h>
+#include <gst/base/gstbasetransform.h>
+
+GST_DEBUG_CATEGORY_STATIC (gst_break_my_data_debug);
+#define GST_CAT_DEFAULT gst_break_my_data_debug
+
+#define GST_TYPE_BREAK_MY_DATA \
+  (gst_break_my_data_get_type())
+#define GST_BREAK_MY_DATA(obj) \
+  (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_BREAK_MY_DATA,GstBreakMyData))
+#define GST_BREAK_MY_DATA_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_BREAK_MY_DATA,GstBreakMyDataClass))
+#define GST_IS_BREAK_MY_DATA(obj) \
+  (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_BREAK_MY_DATA))
+#define GST_IS_BREAK_MY_DATA_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_BREAK_MY_DATA))
+
+enum
+{
+  ARG_0,
+  ARG_SEED,
+  ARG_SET_TO,
+  ARG_SKIP,
+  ARG_PROBABILITY
+};
+
+typedef struct _GstBreakMyData GstBreakMyData;
+typedef struct _GstBreakMyDataClass GstBreakMyDataClass;
+
+struct _GstBreakMyData
+{
+  GstBaseTransform basetransform;
+
+  GRand *rand;
+  guint skipped;
+
+  guint32 seed;
+  gint set;
+  guint skip;
+  gdouble probability;
+};
+
+struct _GstBreakMyDataClass
+{
+  GstBaseTransformClass parent_class;
+};
+
+static void gst_break_my_data_set_property (GObject * object,
+    guint prop_id, const GValue * value, GParamSpec * pspec);
+static void gst_break_my_data_get_property (GObject * object,
+    guint prop_id, GValue * value, GParamSpec * pspec);
+
+static GstFlowReturn gst_break_my_data_transform_ip (GstBaseTransform * trans,
+    GstBuffer * buf);
+static gboolean gst_break_my_data_stop (GstBaseTransform * trans);
+static gboolean gst_break_my_data_start (GstBaseTransform * trans);
+
+static const GstElementDetails details = GST_ELEMENT_DETAILS ("Break my data",
+    "Testing",
+    "randomly change data in the stream",
+    "Benjamin Otte <otte@gnome>");
+
+GstStaticPadTemplate bmd_src_template = GST_STATIC_PAD_TEMPLATE ("src",
+    GST_PAD_SRC,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+GstStaticPadTemplate bmd_sink_template = GST_STATIC_PAD_TEMPLATE ("sink",
+    GST_PAD_SINK,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+
+#define DEBUG_INIT(bla) \
+  GST_DEBUG_CATEGORY_INIT (gst_break_my_data_debug, "breakmydata", 0, \
+      "debugging category for breakmydata element");
+
+GST_BOILERPLATE_FULL (GstBreakMyData, gst_break_my_data, GstBaseTransform,
+    GST_TYPE_BASE_TRANSFORM, DEBUG_INIT);
+
+
+static void
+gst_break_my_data_base_init (gpointer g_class)
+{
+  GstElementClass *gstelement_class = GST_ELEMENT_CLASS (g_class);
+
+  gst_element_class_add_pad_template (gstelement_class,
+      gst_static_pad_template_get (&bmd_sink_template));
+  gst_element_class_add_pad_template (gstelement_class,
+      gst_static_pad_template_get (&bmd_src_template));
+
+  gst_element_class_set_details (gstelement_class, &details);
+}
+
+static void
+gst_break_my_data_class_init (GstBreakMyDataClass * klass)
+{
+  GstBaseTransformClass *gstbasetrans_class;
+  GObjectClass *gobject_class;
+
+  gobject_class = G_OBJECT_CLASS (klass);
+  gstbasetrans_class = GST_BASE_TRANSFORM_CLASS (klass);
+
+  gobject_class->set_property =
+      GST_DEBUG_FUNCPTR (gst_break_my_data_set_property);
+  gobject_class->get_property =
+      GST_DEBUG_FUNCPTR (gst_break_my_data_get_property);
+
+  g_object_class_install_property (gobject_class, ARG_SEED,
+      g_param_spec_uint ("seed", "seed",
+          "seed for randomness (initialized when going from READY to PAUSED)",
+          0, G_MAXUINT32, 0, G_PARAM_READWRITE | G_PARAM_CONSTRUCT));
+  g_object_class_install_property (gobject_class, ARG_SET_TO,
+      g_param_spec_int ("set-to", "set-to",
+          "set changed bytes to this value (-1 means random value",
+          -1, G_MAXUINT8, -1, G_PARAM_READWRITE | G_PARAM_CONSTRUCT));
+  g_object_class_install_property (gobject_class, ARG_SKIP,
+      g_param_spec_uint ("skip", "skip",
+          "amount of bytes skipped at the beginning of stream",
+          0, G_MAXUINT, 0, G_PARAM_READWRITE | G_PARAM_CONSTRUCT));
+  g_object_class_install_property (gobject_class, ARG_PROBABILITY,
+      g_param_spec_double ("probability", "probability",
+          "probability for each byte in the buffer to be changed", 0.0, 1.0,
+          0.0, G_PARAM_READWRITE | G_PARAM_CONSTRUCT));
+
+  gstbasetrans_class->transform_ip =
+      GST_DEBUG_FUNCPTR (gst_break_my_data_transform_ip);
+  gstbasetrans_class->start = GST_DEBUG_FUNCPTR (gst_break_my_data_start);
+  gstbasetrans_class->stop = GST_DEBUG_FUNCPTR (gst_break_my_data_stop);
+}
+
+static void
+gst_break_my_data_init (GstBreakMyData * bmd, GstBreakMyDataClass * g_class)
+{
+  gst_base_transform_set_in_place (GST_BASE_TRANSFORM (bmd), TRUE);
+  gst_base_transform_set_passthrough (GST_BASE_TRANSFORM (bmd), TRUE);
+}
+
+static void
+gst_break_my_data_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec)
+{
+  GstBreakMyData *bmd = GST_BREAK_MY_DATA (object);
+
+  GST_OBJECT_LOCK (bmd);
+
+  switch (prop_id) {
+    case ARG_SEED:
+      bmd->seed = g_value_get_uint (value);
+      break;
+    case ARG_SET_TO:
+      bmd->set = g_value_get_int (value);
+      break;
+    case ARG_SKIP:
+      bmd->skip = g_value_get_uint (value);
+      break;
+    case ARG_PROBABILITY:
+      bmd->probability = g_value_get_double (value);
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
+
+  GST_OBJECT_UNLOCK (bmd);
+}
+
+static void
+gst_break_my_data_get_property (GObject * object, guint prop_id, GValue * value,
+    GParamSpec * pspec)
+{
+  GstBreakMyData *bmd = GST_BREAK_MY_DATA (object);
+
+  GST_OBJECT_LOCK (bmd);
+
+  switch (prop_id) {
+    case ARG_SEED:
+      g_value_set_uint (value, bmd->seed);
+      break;
+    case ARG_SET_TO:
+      g_value_set_int (value, bmd->set);
+      break;
+    case ARG_SKIP:
+      g_value_set_uint (value, bmd->skip);
+      break;
+    case ARG_PROBABILITY:
+      g_value_set_double (value, bmd->probability);
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
+
+  GST_OBJECT_UNLOCK (bmd);
+}
+
+static GstFlowReturn
+gst_break_my_data_transform_ip (GstBaseTransform * trans, GstBuffer * buf)
+{
+  GstBreakMyData *bmd = GST_BREAK_MY_DATA (trans);
+  guint i, size;
+
+  g_return_val_if_fail (gst_buffer_is_writable (buf), GST_FLOW_ERROR);
+
+  GST_OBJECT_LOCK (bmd);
+
+  if (bmd->skipped < bmd->skip) {
+    i = bmd->skip - bmd->skipped;
+  } else {
+    i = 0;
+  }
+
+  size = GST_BUFFER_SIZE (buf);
+
+  GST_LOG_OBJECT (bmd,
+      "got buffer %p (size %u, timestamp %" G_GUINT64_FORMAT ", offset %"
+      G_GUINT64_FORMAT "", buf, size, GST_BUFFER_TIMESTAMP (buf),
+      GST_BUFFER_OFFSET (buf));
+
+  for (; i < size; i++) {
+    if (g_rand_double_range (bmd->rand, 0, 1.0) <= bmd->probability) {
+      guint8 new;
+
+      if (bmd->set < 0) {
+        new = g_rand_int_range (bmd->rand, 0, 256);
+      } else {
+        new = bmd->set;
+      }
+      GST_INFO_OBJECT (bmd, "changing byte %u from 0x%02X to 0x%02X", i,
+          (guint) GST_READ_UINT8 (GST_BUFFER_DATA (buf) + i),
+          (guint) ((guint8) new));
+      GST_BUFFER_DATA (buf)[i] = new;
+    }
+  }
+  /* don't overflow */
+  bmd->skipped += MIN (G_MAXUINT - bmd->skipped, GST_BUFFER_SIZE (buf));
+
+  GST_OBJECT_UNLOCK (bmd);
+
+  return GST_FLOW_OK;
+}
+
+static gboolean
+gst_break_my_data_start (GstBaseTransform * trans)
+{
+  GstBreakMyData *bmd = GST_BREAK_MY_DATA (trans);
+
+  GST_OBJECT_LOCK (bmd);
+  bmd->rand = g_rand_new_with_seed (bmd->seed);
+  bmd->skipped = 0;
+  GST_OBJECT_UNLOCK (bmd);
+
+  return TRUE;
+}
+
+static gboolean
+gst_break_my_data_stop (GstBaseTransform * trans)
+{
+  GstBreakMyData *bmd = GST_BREAK_MY_DATA (trans);
+
+  GST_OBJECT_LOCK (bmd);
+  g_rand_free (bmd->rand);
+  bmd->rand = NULL;
+  GST_OBJECT_UNLOCK (bmd);
+
+  return TRUE;
+}
diff --git a/gst/debugutils/debug.vcproj b/gst/debugutils/debug.vcproj
new file mode 100644
index 00000000..3093ae7b
--- /dev/null
+++ b/gst/debugutils/debug.vcproj
@@ -0,0 +1,166 @@
+<?xml version="1.0" encoding="Windows-1252"?>
+<VisualStudioProject
+	ProjectType="Visual C++"
+	Version="7.10"
+	Name="debug"
+	ProjectGUID="{979C216F-0ACF-4956-AE00-055A42D678AF}"
+	Keyword="Win32Proj">
+	<Platforms>
+		<Platform
+			Name="Win32"/>
+	</Platforms>
+	<Configurations>
+		<Configuration
+			Name="Debug|Win32"
+			OutputDirectory="../../win32/Debug"
+			IntermediateDirectory="../../win32/Debug"
+			ConfigurationType="2"
+			CharacterSet="2">
+			<Tool
+				Name="VCCLCompilerTool"
+				Optimization="0"
+				AdditionalIncludeDirectories="../../../gstreamer/win32;../../../gstreamer;../../../gstreamer/libs;../../../glib;../../../glib/glib;../../../glib/gmodule;&quot;../../gst-libs&quot;;../../../popt/include;../../../libxml2/include/libxml2"
+				PreprocessorDefinitions="WIN32;_DEBUG;_WINDOWS;_USRDLL;debug_EXPORTS;HAVE_CONFIG_H;_USE_MATH_DEFINES"
+				MinimalRebuild="TRUE"
+				BasicRuntimeChecks="3"
+				RuntimeLibrary="3"
+				UsePrecompiledHeader="0"
+				WarningLevel="3"
+				Detect64BitPortabilityProblems="TRUE"
+				DebugInformationFormat="4"/>
+			<Tool
+				Name="VCCustomBuildTool"/>
+			<Tool
+				Name="VCLinkerTool"
+				AdditionalDependencies="glib-2.0.lib gmodule-2.0.lib gthread-2.0.lib gobject-2.0.lib libgstreamer.lib gstbytestream.lib iconv.lib intl.lib"
+				OutputFile="$(OutDir)/gstdebug.dll"
+				LinkIncremental="2"
+				AdditionalLibraryDirectories="../../../gstreamer/win32/Debug;../../../glib/glib;../../../glib/gmodule;../../../glib/gthread;../../../glib/gobject;../../../gettext/lib;../../../libiconv/lib"
+				ModuleDefinitionFile=""
+				GenerateDebugInformation="TRUE"
+				ProgramDatabaseFile="$(OutDir)/debug.pdb"
+				SubSystem="2"
+				OptimizeReferences="2"
+				ImportLibrary="$(OutDir)/gstdebug.lib"
+				TargetMachine="1"/>
+			<Tool
+				Name="VCMIDLTool"/>
+			<Tool
+				Name="VCPostBuildEventTool"
+				CommandLine="copy /Y $(TargetPath) c:\gstreamer\plugins"/>
+			<Tool
+				Name="VCPreBuildEventTool"/>
+			<Tool
+				Name="VCPreLinkEventTool"/>
+			<Tool
+				Name="VCResourceCompilerTool"/>
+			<Tool
+				Name="VCWebServiceProxyGeneratorTool"/>
+			<Tool
+				Name="VCXMLDataGeneratorTool"/>
+			<Tool
+				Name="VCWebDeploymentTool"/>
+			<Tool
+				Name="VCManagedWrapperGeneratorTool"/>
+			<Tool
+				Name="VCAuxiliaryManagedWrapperGeneratorTool"/>
+		</Configuration>
+		<Configuration
+			Name="Release|Win32"
+			OutputDirectory="../../win32/Release"
+			IntermediateDirectory="../../win32/Release"
+			ConfigurationType="2"
+			CharacterSet="2">
+			<Tool
+				Name="VCCLCompilerTool"
+				AdditionalIncludeDirectories="../../../gstreamer/win32;../../../gstreamer;../../../gstreamer/libs;../../../glib;../../../glib/glib;../../../glib/gmodule;&quot;../../gst-libs&quot;;../../../popt/include;../../../libxml2/include/libxml2"
+				PreprocessorDefinitions="WIN32;NDEBUG;_WINDOWS;_USRDLL;debug_EXPORTS;HAVE_CONFIG_H;_USE_MATH_DEFINES"
+				RuntimeLibrary="2"
+				UsePrecompiledHeader="0"
+				WarningLevel="3"
+				Detect64BitPortabilityProblems="TRUE"
+				DebugInformationFormat="3"/>
+			<Tool
+				Name="VCCustomBuildTool"/>
+			<Tool
+				Name="VCLinkerTool"
+				AdditionalDependencies="glib-2.0.lib gmodule-2.0.lib gthread-2.0.lib gobject-2.0.lib libgstreamer.lib gstbytestream.lib iconv.lib intl.lib"
+				OutputFile="$(OutDir)/gstdebug.dll"
+				LinkIncremental="1"
+				AdditionalLibraryDirectories="../../../gstreamer/win32/Release;../../../glib/glib;../../../glib/gmodule;../../../glib/gthread;../../../glib/gobject;../../../gettext/lib;../../../libiconv/lib"
+				ModuleDefinitionFile=""
+				GenerateDebugInformation="TRUE"
+				SubSystem="2"
+				OptimizeReferences="2"
+				EnableCOMDATFolding="2"
+				ImportLibrary="$(OutDir)/gstdebug.lib"
+				TargetMachine="1"/>
+			<Tool
+				Name="VCMIDLTool"/>
+			<Tool
+				Name="VCPostBuildEventTool"
+				CommandLine="copy /Y $(TargetPath) c:\gstreamer\plugins"/>
+			<Tool
+				Name="VCPreBuildEventTool"/>
+			<Tool
+				Name="VCPreLinkEventTool"/>
+			<Tool
+				Name="VCResourceCompilerTool"/>
+			<Tool
+				Name="VCWebServiceProxyGeneratorTool"/>
+			<Tool
+				Name="VCXMLDataGeneratorTool"/>
+			<Tool
+				Name="VCWebDeploymentTool"/>
+			<Tool
+				Name="VCManagedWrapperGeneratorTool"/>
+			<Tool
+				Name="VCAuxiliaryManagedWrapperGeneratorTool"/>
+		</Configuration>
+	</Configurations>
+	<References>
+	</References>
+	<Files>
+		<Filter
+			Name="Source Files"
+			Filter="cpp;c;cxx;def;odl;idl;hpj;bat;asm;asmx"
+			UniqueIdentifier="{4FC737F1-C7A5-4376-A066-2A32D752A2FF}">
+			<File
+				RelativePath=".\gstdebug.c">
+			</File>
+			<File
+				RelativePath=".\breakmydata.c">
+			</File>
+			<File
+				RelativePath=".\negotiation.c">
+			</File>
+			<File
+				RelativePath=".\gstnavseek.c">
+			</File>
+			<File
+				RelativePath=".\progressreport.c">
+			</File>
+			<File
+				RelativePath=".\tests.c">
+			</File>
+			<File
+				RelativePath=".\testplugin.c">
+			</File>
+		</Filter>
+		<Filter
+			Name="Header Files"
+			Filter="h;hpp;hxx;hm;inl;inc;xsd"
+			UniqueIdentifier="{93995380-89BD-4b04-88EB-625FBE52EBFB}">
+			<File
+				RelativePath=".\tests.h">
+			</File>
+		</Filter>
+		<Filter
+			Name="Resource Files"
+			Filter="rc;ico;cur;bmp;dlg;rc2;rct;bin;rgs;gif;jpg;jpeg;jpe;resx"
+			UniqueIdentifier="{67DA6AB6-F800-4c08-8B7A-83BB121AAD01}">
+		</Filter>
+	</Files>
+	<Globals>
+	</Globals>
+</VisualStudioProject>
diff --git a/gst/debugutils/efence.c b/gst/debugutils/efence.c
new file mode 100644
index 00000000..a46bf1ac
--- /dev/null
+++ b/gst/debugutils/efence.c
@@ -0,0 +1,537 @@
+/*
+ * GStreamer
+ * Copyright (C) 1999-2001 Erik Walthinsen <omega@cse.ogi.edu>
+ * Copyright (C) 2002 David A. Schleef <ds@schleef.org>
+ *
+ * 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.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+#include <gst/gst.h>
+
+#include <string.h>
+#include <unistd.h>
+#include <sys/mman.h>
+
+#include "efence.h"
+
+#ifndef MAP_ANONYMOUS
+#ifdef MAP_ANON
+#define MAP_ANONYMOUS MAP_ANON
+#else
+/* assume we don't need it */
+#define MAP_ANONYMOUS 0
+#endif
+#endif
+
+GST_DEBUG_CATEGORY_STATIC (gst_efence_debug);
+#define GST_CAT_DEFAULT  gst_efence_debug
+
+static const GstElementDetails plugin_details =
+GST_ELEMENT_DETAILS ("Electric Fence",
+    "Testing",
+    "This element converts a stream of normal GStreamer buffers into a "
+    "stream of buffers that are allocated in such a way that out-of-bounds "
+    "access to data in the buffer is more likely to cause segmentation "
+    "faults.  This allocation method is very similar to the debugging tool "
+    "\"Electric Fence\".",
+    "David A. Schleef <ds@schleef.org>");
+
+/* Filter signals and args */
+enum
+{
+  /* FILL ME */
+  LAST_SIGNAL
+};
+
+enum
+{
+  ARG_0,
+  ARG_FENCE_TOP
+};
+
+static GstStaticPadTemplate gst_efence_sink_factory =
+GST_STATIC_PAD_TEMPLATE ("sink",
+    GST_PAD_SINK,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+static GstStaticPadTemplate gst_efence_src_factory =
+GST_STATIC_PAD_TEMPLATE ("src",
+    GST_PAD_SRC,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+static void gst_efence_base_init (gpointer g_class);
+static void gst_efence_class_init (GstEFenceClass * klass);
+static void gst_efence_init (GstEFence * filter);
+
+static void gst_efence_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec);
+static void gst_efence_get_property (GObject * object, guint prop_id,
+    GValue * value, GParamSpec * pspec);
+
+static GstFlowReturn gst_efence_chain (GstPad * pad, GstBuffer * buf);
+static GstFlowReturn gst_efence_getrange (GstPad * pad, guint64 offset,
+    guint length, GstBuffer ** buffer);
+static gboolean gst_efence_checkgetrange (GstPad * pad);
+static gboolean gst_efence_activate_src_pull (GstPad * pad, gboolean active);
+
+static GstElementClass *parent_class = NULL;
+
+typedef struct _GstFencedBuffer GstFencedBuffer;
+struct _GstFencedBuffer
+{
+  GstBuffer buffer;
+  void *region;
+  unsigned int length;
+};
+
+GType gst_fenced_buffer_get_type (void);
+static void gst_fenced_buffer_finalize (GstFencedBuffer * buf);
+static GstFencedBuffer *gst_fenced_buffer_copy (const GstBuffer * buffer);
+static void *gst_fenced_buffer_alloc (GstBuffer * buffer, unsigned int length,
+    gboolean fence_top);
+static GstFlowReturn gst_efence_buffer_alloc (GstPad * pad, guint64 offset,
+    guint size, GstCaps * caps, GstBuffer ** buf);
+
+#define GST_TYPE_FENCED_BUFFER (gst_fenced_buffer_get_type())
+
+#define GST_IS_FENCED_BUFFER(obj) (G_TYPE_CHECK_INSTANCE_TYPE ((obj), GST_TYPE_FENCED_BUFFER))
+#define GST_FENCED_BUFFER(obj) (G_TYPE_CHECK_INSTANCE_CAST ((obj), GST_TYPE_FENCED_BUFFER, GstFencedBuffer))
+
+GType
+gst_gst_efence_get_type (void)
+{
+  static GType plugin_type = 0;
+
+  if (!plugin_type) {
+    static const GTypeInfo plugin_info = {
+      sizeof (GstEFenceClass),
+      gst_efence_base_init,
+      NULL,
+      (GClassInitFunc) gst_efence_class_init,
+      NULL,
+      NULL,
+      sizeof (GstEFence),
+      0,
+      (GInstanceInitFunc) gst_efence_init,
+    };
+
+    plugin_type = g_type_register_static (GST_TYPE_ELEMENT,
+        "GstEFence", &plugin_info, 0);
+  }
+  return plugin_type;
+}
+
+static void
+gst_efence_base_init (gpointer g_class)
+{
+  GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);
+
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&gst_efence_sink_factory));
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&gst_efence_src_factory));
+  gst_element_class_set_details (element_class, &plugin_details);
+}
+
+/* initialize the plugin's class */
+static void
+gst_efence_class_init (GstEFenceClass * klass)
+{
+  GObjectClass *gobject_class;
+  GstElementClass *gstelement_class;
+
+  gobject_class = (GObjectClass *) klass;
+  gstelement_class = (GstElementClass *) klass;
+
+  parent_class = g_type_class_peek_parent (klass);
+
+  gobject_class->set_property = gst_efence_set_property;
+  gobject_class->get_property = gst_efence_get_property;
+
+  g_object_class_install_property (gobject_class, ARG_FENCE_TOP,
+      g_param_spec_boolean ("fence_top", "Fence Top",
+          "Align buffers with top of fenced region", TRUE, G_PARAM_READWRITE));
+}
+
+/* initialize the new element
+ * instantiate pads and add them to element
+ * set functions
+ * initialize structure
+ */
+static void
+gst_efence_init (GstEFence * filter)
+{
+  filter->sinkpad =
+      gst_pad_new_from_static_template (&gst_efence_sink_factory, "sink");
+  gst_pad_set_getcaps_function (filter->sinkpad,
+      GST_DEBUG_FUNCPTR (gst_pad_proxy_getcaps));
+  gst_pad_set_setcaps_function (filter->sinkpad,
+      GST_DEBUG_FUNCPTR (gst_pad_proxy_setcaps));
+  gst_pad_set_chain_function (filter->sinkpad,
+      GST_DEBUG_FUNCPTR (gst_efence_chain));
+  gst_pad_set_bufferalloc_function (filter->sinkpad,
+      GST_DEBUG_FUNCPTR (gst_efence_buffer_alloc));
+  gst_element_add_pad (GST_ELEMENT (filter), filter->sinkpad);
+
+  filter->srcpad =
+      gst_pad_new_from_static_template (&gst_efence_src_factory, "src");
+  gst_pad_set_getcaps_function (filter->srcpad,
+      GST_DEBUG_FUNCPTR (gst_pad_proxy_getcaps));
+  gst_pad_set_setcaps_function (filter->srcpad,
+      GST_DEBUG_FUNCPTR (gst_pad_proxy_setcaps));
+  gst_pad_set_checkgetrange_function (filter->srcpad,
+      GST_DEBUG_FUNCPTR (gst_efence_checkgetrange));
+  gst_pad_set_getrange_function (filter->srcpad,
+      GST_DEBUG_FUNCPTR (gst_efence_getrange));
+  gst_pad_set_activatepull_function (filter->srcpad,
+      GST_DEBUG_FUNCPTR (gst_efence_activate_src_pull));
+
+  gst_element_add_pad (GST_ELEMENT (filter), filter->srcpad);
+
+  filter->fence_top = TRUE;
+}
+
+/* chain function
+ * this function does the actual processing
+ */
+
+static GstFlowReturn
+gst_efence_chain (GstPad * pad, GstBuffer * buffer)
+{
+  GstEFence *efence;
+  GstBuffer *copy;
+
+  efence = GST_EFENCE (GST_OBJECT_PARENT (pad));
+  g_return_val_if_fail (GST_IS_EFENCE (efence), GST_FLOW_ERROR);
+
+  if (GST_IS_FENCED_BUFFER (buffer)) {
+    GST_DEBUG_OBJECT (efence, "Passing on existing fenced buffer with caps %"
+        GST_PTR_FORMAT, GST_BUFFER_CAPS (buffer));
+    return gst_pad_push (efence->srcpad, buffer);
+  }
+
+  copy = (GstBuffer *) gst_fenced_buffer_copy (buffer);
+
+  GST_DEBUG_OBJECT (efence, "Pushing newly fenced buffer with caps %"
+      GST_PTR_FORMAT ", data=%p, size=%u", GST_BUFFER_CAPS (copy),
+      GST_BUFFER_DATA (copy), GST_BUFFER_SIZE (copy));
+
+  gst_buffer_unref (buffer);
+
+  return gst_pad_push (efence->srcpad, copy);
+}
+
+static GstFlowReturn
+gst_efence_getrange (GstPad * pad, guint64 offset,
+    guint length, GstBuffer ** buffer)
+{
+  GstEFence *efence;
+  GstFlowReturn ret;
+  GstBuffer *ownbuf;
+  GstPad *peer;
+
+  efence = GST_EFENCE (GST_OBJECT_PARENT (pad));
+
+  peer = gst_pad_get_peer (efence->sinkpad);
+  if (!peer)
+    return GST_FLOW_NOT_LINKED;
+
+  if ((ret = gst_pad_get_range (peer, offset, length, buffer)) != GST_FLOW_OK)
+    goto beach;
+
+  ownbuf = (GstBuffer *) gst_fenced_buffer_copy (*buffer);
+  gst_buffer_unref ((GstBuffer *) * buffer);
+  *buffer = ownbuf;
+
+beach:
+  gst_object_unref (peer);
+  return ret;
+}
+
+static gboolean
+gst_efence_checkgetrange (GstPad * pad)
+{
+  GstEFence *efence = GST_EFENCE (GST_OBJECT_PARENT (pad));
+
+  return gst_pad_check_pull_range (efence->sinkpad);
+}
+
+static gboolean
+gst_efence_activate_src_pull (GstPad * pad, gboolean active)
+{
+  GstEFence *efence = GST_EFENCE (GST_OBJECT_PARENT (pad));
+
+  return gst_pad_activate_pull (efence->sinkpad, active);
+}
+
+static GstFlowReturn
+gst_efence_buffer_alloc (GstPad * pad, guint64 offset,
+    guint size, GstCaps * caps, GstBuffer ** buf)
+{
+  GstBuffer *buffer;
+  GstEFence *efence;
+
+  g_return_val_if_fail (buf != NULL, GST_FLOW_ERROR);
+  g_return_val_if_fail (GST_IS_PAD (pad), GST_FLOW_ERROR);
+
+  efence = GST_EFENCE (GST_OBJECT_PARENT (pad));
+
+  buffer = (GstBuffer *) gst_mini_object_new (GST_TYPE_FENCED_BUFFER);
+
+  GST_BUFFER_DATA (buffer) = gst_fenced_buffer_alloc (buffer, size,
+      efence->fence_top);
+  GST_BUFFER_SIZE (buffer) = size;
+  GST_BUFFER_OFFSET (buffer) = offset;
+
+  if (caps)
+    gst_buffer_set_caps (buffer, caps);
+
+  *buf = buffer;
+
+  GST_DEBUG_OBJECT (efence, "Allocated buffer of size %u, caps: %"
+      GST_PTR_FORMAT, GST_BUFFER_SIZE (buffer), GST_BUFFER_CAPS (buffer));
+
+  return GST_FLOW_OK;
+}
+
+static void
+gst_efence_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec)
+{
+  GstEFence *filter;
+
+  g_return_if_fail (GST_IS_EFENCE (object));
+  filter = GST_EFENCE (object);
+
+  switch (prop_id) {
+    case ARG_FENCE_TOP:
+      filter->fence_top = g_value_get_boolean (value);
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
+}
+
+static void
+gst_efence_get_property (GObject * object, guint prop_id,
+    GValue * value, GParamSpec * pspec)
+{
+  GstEFence *filter;
+
+  g_return_if_fail (GST_IS_EFENCE (object));
+  filter = GST_EFENCE (object);
+
+  switch (prop_id) {
+    case ARG_FENCE_TOP:
+      g_value_set_boolean (value, filter->fence_top);
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
+}
+
+/* entry point to initialize the plug-in
+ * initialize the plug-in itself
+ * register the element factories and pad templates
+ * register the features
+ */
+static gboolean
+plugin_init (GstPlugin * plugin)
+{
+  if (!gst_element_register (plugin, "efence", GST_RANK_NONE, GST_TYPE_EFENCE))
+    return FALSE;
+
+  GST_DEBUG_CATEGORY_INIT (gst_efence_debug, "efence", 0,
+      "Debug output from the efence element");
+
+  /* plugin initialisation succeeded */
+  return TRUE;
+}
+
+GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
+    GST_VERSION_MINOR,
+    "efence",
+    "This element converts a stream of normal GStreamer buffers into a "
+    "stream of buffers that are allocated in such a way that out-of-bounds "
+    "access to data in the buffer is more likely to cause segmentation "
+    "faults.  This allocation method is very similar to the debugging tool "
+    "\"Electric Fence\".",
+    plugin_init, VERSION, "LGPL", GST_PACKAGE_NAME, GST_PACKAGE_ORIGIN);
+
+
+static GstBufferClass *fenced_buffer_parent_class = NULL;
+
+static void
+gst_fenced_buffer_finalize (GstFencedBuffer * buffer)
+{
+  GstFencedBuffer *fenced_buffer;
+
+  GST_DEBUG ("free buffer=%p", buffer);
+
+  fenced_buffer = GST_FENCED_BUFFER (buffer);
+
+  /* free our data */
+  if (GST_BUFFER_DATA (buffer)) {
+    GST_DEBUG ("free region %p %d", fenced_buffer->region,
+        fenced_buffer->length);
+    munmap (fenced_buffer->region, fenced_buffer->length);
+  }
+
+  GST_MINI_OBJECT_CLASS (fenced_buffer_parent_class)->finalize (GST_MINI_OBJECT
+      (buffer));
+}
+
+static GstFencedBuffer *
+gst_fenced_buffer_copy (const GstBuffer * buffer)
+{
+  GstBuffer *copy;
+  void *ptr;
+  guint mask;
+
+  g_return_val_if_fail (buffer != NULL, NULL);
+
+  /* create a fresh new buffer */
+  copy = (GstBuffer *) gst_mini_object_new (GST_TYPE_FENCED_BUFFER);
+
+  /* we simply copy everything from our parent */
+  ptr = gst_fenced_buffer_alloc (GST_BUFFER (copy),
+      GST_BUFFER_SIZE (buffer), TRUE);
+  memcpy (ptr, GST_BUFFER_DATA (buffer), GST_BUFFER_SIZE (buffer));
+
+  /* copy relevant flags */
+  mask = GST_BUFFER_FLAG_PREROLL | GST_BUFFER_FLAG_IN_CAPS |
+      GST_BUFFER_FLAG_DELTA_UNIT;
+  GST_MINI_OBJECT (copy)->flags |= GST_MINI_OBJECT (buffer)->flags & mask;
+
+  GST_BUFFER_DATA (copy) = ptr;
+  GST_BUFFER_SIZE (copy) = GST_BUFFER_SIZE (buffer);
+  GST_BUFFER_TIMESTAMP (copy) = GST_BUFFER_TIMESTAMP (buffer);
+  GST_BUFFER_DURATION (copy) = GST_BUFFER_DURATION (buffer);
+  GST_BUFFER_OFFSET (copy) = GST_BUFFER_OFFSET (buffer);
+  GST_BUFFER_OFFSET_END (copy) = GST_BUFFER_OFFSET_END (buffer);
+
+  if (GST_BUFFER_CAPS (buffer))
+    GST_BUFFER_CAPS (copy) = gst_caps_ref (GST_BUFFER_CAPS (buffer));
+  else
+    GST_BUFFER_CAPS (copy) = NULL;
+
+  GST_DEBUG ("Copied buffer %p with ts %" GST_TIME_FORMAT
+      ", caps: %" GST_PTR_FORMAT, buffer,
+      GST_TIME_ARGS (GST_BUFFER_TIMESTAMP (copy)), GST_BUFFER_CAPS (copy));
+
+  return GST_FENCED_BUFFER (copy);
+}
+
+void *
+gst_fenced_buffer_alloc (GstBuffer * buffer, unsigned int length,
+    gboolean fence_top)
+{
+  int alloc_size;
+  void *region;
+  GstFencedBuffer *fenced_buffer = (GstFencedBuffer *) buffer;
+  int page_size;
+
+  GST_DEBUG ("buffer=%p length=%d fence_top=%d", buffer, length, fence_top);
+
+  if (length == 0)
+    return NULL;
+
+#ifdef _SC_PAGESIZE
+  page_size = sysconf (_SC_PAGESIZE);
+#else
+  page_size = getpagesize ();
+#endif
+
+  /* Allocate a complete page, and one on either side */
+  alloc_size = ((length - 1) & ~(page_size - 1)) + page_size;
+  alloc_size += 2 * page_size;
+
+  region = mmap (NULL, alloc_size, PROT_READ | PROT_WRITE,
+      MAP_PRIVATE | MAP_ANONYMOUS, -1, 0);
+  if (region == MAP_FAILED) {
+    g_warning ("mmap failed");
+    return NULL;
+  }
+#if 0
+  munmap (region, page_size);
+  munmap (region + alloc_size - page_size, page_size);
+
+  fenced_buffer->region = region + page_size;
+  fenced_buffer->length = alloc_size - page_size;
+#else
+  mprotect (region, page_size, PROT_NONE);
+  mprotect ((char *) region + alloc_size - page_size, page_size, PROT_NONE);
+
+  fenced_buffer->region = region;
+  fenced_buffer->length = alloc_size;
+#endif
+
+  GST_DEBUG ("new region %p %d", fenced_buffer->region, fenced_buffer->length);
+
+  if (fence_top) {
+    int offset;
+
+    /* Align to top of region, but force alignment to 4 bytes */
+    offset = alloc_size - page_size - length;
+    offset &= ~0x3;
+    return (void *) ((char *) region + offset);
+  } else {
+    return (void *) ((char *) region + page_size);
+  }
+}
+
+static void
+gst_fenced_buffer_class_init (gpointer g_class, gpointer class_data)
+{
+  GstMiniObjectClass *mini_object_class = GST_MINI_OBJECT_CLASS (g_class);
+
+  fenced_buffer_parent_class = g_type_class_peek_parent (g_class);
+
+  mini_object_class->finalize =
+      (GstMiniObjectFinalizeFunction) gst_fenced_buffer_finalize;
+  mini_object_class->copy = (GstMiniObjectCopyFunction) gst_fenced_buffer_copy;
+}
+
+GType
+gst_fenced_buffer_get_type (void)
+{
+  static GType fenced_buf_type = 0;
+
+  if (G_UNLIKELY (!fenced_buf_type)) {
+    static const GTypeInfo fenced_buf_info = {
+      sizeof (GstBufferClass),
+      NULL,
+      NULL,
+      (GClassInitFunc) gst_fenced_buffer_class_init,
+      NULL,
+      NULL,
+      sizeof (GstFencedBuffer),
+      0,
+      NULL,
+    };
+
+    fenced_buf_type = g_type_register_static (GST_TYPE_BUFFER,
+        "GstFencedBuffer", &fenced_buf_info, 0);
+  }
+  return fenced_buf_type;
+}
diff --git a/gst/debugutils/efence.h b/gst/debugutils/efence.h
new file mode 100644
index 00000000..7c4acb5d
--- /dev/null
+++ b/gst/debugutils/efence.h
@@ -0,0 +1,50 @@
+/* 
+ * efence.h
+ */
+
+#ifndef __GST_EFENCE_H__
+#define __GST_EFENCE_H__
+
+#include <gst/gst.h>
+
+#ifdef __cplusplus
+extern "C"
+{
+#endif                          /* __cplusplus */
+
+/* #define's don't like whitespacey bits */
+#define GST_TYPE_EFENCE \
+  (gst_gst_efence_get_type())
+#define GST_EFENCE(obj) \
+  (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_EFENCE,GstEFence))
+#define GST_EFENCE_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_EFENCE,GstEFenceClass))
+#define GST_IS_EFENCE(obj) \
+  (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_EFENCE))
+#define GST_IS_EFENCE_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_EFENCE))
+
+  typedef struct _GstEFence GstEFence;
+  typedef struct _GstEFenceClass GstEFenceClass;
+
+  struct _GstEFence
+  {
+    GstElement element;
+
+    GstPad *sinkpad, *srcpad;
+
+    gboolean fence_top;
+  };
+
+  struct _GstEFenceClass
+  {
+    GstElementClass parent_class;
+  };
+
+  GType gst_gst_efence_get_type (void);
+
+#ifdef __cplusplus
+}
+#endif                          /* __cplusplus */
+
+#endif                          /* __GST_EFENCE_H__ */
diff --git a/gst/debugutils/efence.vcproj b/gst/debugutils/efence.vcproj
new file mode 100644
index 00000000..c01fcd28
--- /dev/null
+++ b/gst/debugutils/efence.vcproj
@@ -0,0 +1,148 @@
+<?xml version="1.0" encoding="Windows-1252"?>
+<VisualStudioProject
+	ProjectType="Visual C++"
+	Version="7.10"
+	Name="efence"
+	ProjectGUID="{979C216F-0ACF-4956-AE00-055A42D678AE}"
+	Keyword="Win32Proj">
+	<Platforms>
+		<Platform
+			Name="Win32"/>
+	</Platforms>
+	<Configurations>
+		<Configuration
+			Name="Debug|Win32"
+			OutputDirectory="../../win32/Debug"
+			IntermediateDirectory="../../win32/Debug"
+			ConfigurationType="2"
+			CharacterSet="2">
+			<Tool
+				Name="VCCLCompilerTool"
+				Optimization="0"
+				AdditionalIncludeDirectories="../../../gstreamer/win32;../../../gstreamer;../../../gstreamer/libs;../../../glib;../../../glib/glib;../../../glib/gmodule;&quot;../../gst-libs&quot;;../../../popt/include;../../../libxml2/include/libxml2"
+				PreprocessorDefinitions="WIN32;_DEBUG;_WINDOWS;_USRDLL;efence_EXPORTS;HAVE_CONFIG_H;_USE_MATH_DEFINES"
+				MinimalRebuild="TRUE"
+				BasicRuntimeChecks="3"
+				RuntimeLibrary="3"
+				UsePrecompiledHeader="0"
+				WarningLevel="3"
+				Detect64BitPortabilityProblems="TRUE"
+				DebugInformationFormat="4"/>
+			<Tool
+				Name="VCCustomBuildTool"/>
+			<Tool
+				Name="VCLinkerTool"
+				AdditionalDependencies="glib-2.0.lib gmodule-2.0.lib gthread-2.0.lib gobject-2.0.lib libgstreamer.lib gstbytestream.lib iconv.lib intl.lib"
+				OutputFile="$(OutDir)/gstefence.dll"
+				LinkIncremental="2"
+				AdditionalLibraryDirectories="../../../gstreamer/win32/Debug;../../../glib/glib;../../../glib/gmodule;../../../glib/gthread;../../../glib/gobject;../../../gettext/lib;../../../libiconv/lib"
+				ModuleDefinitionFile=""
+				GenerateDebugInformation="TRUE"
+				ProgramDatabaseFile="$(OutDir)/efence.pdb"
+				SubSystem="2"
+				OptimizeReferences="2"
+				ImportLibrary="$(OutDir)/gstefence.lib"
+				TargetMachine="1"/>
+			<Tool
+				Name="VCMIDLTool"/>
+			<Tool
+				Name="VCPostBuildEventTool"
+				CommandLine="copy /Y $(TargetPath) c:\gstreamer\plugins"/>
+			<Tool
+				Name="VCPreBuildEventTool"/>
+			<Tool
+				Name="VCPreLinkEventTool"/>
+			<Tool
+				Name="VCResourceCompilerTool"/>
+			<Tool
+				Name="VCWebServiceProxyGeneratorTool"/>
+			<Tool
+				Name="VCXMLDataGeneratorTool"/>
+			<Tool
+				Name="VCWebDeploymentTool"/>
+			<Tool
+				Name="VCManagedWrapperGeneratorTool"/>
+			<Tool
+				Name="VCAuxiliaryManagedWrapperGeneratorTool"/>
+		</Configuration>
+		<Configuration
+			Name="Release|Win32"
+			OutputDirectory="../../win32/Release"
+			IntermediateDirectory="../../win32/Release"
+			ConfigurationType="2"
+			CharacterSet="2">
+			<Tool
+				Name="VCCLCompilerTool"
+				AdditionalIncludeDirectories="../../../gstreamer/win32;../../../gstreamer;../../../gstreamer/libs;../../../glib;../../../glib/glib;../../../glib/gmodule;&quot;../../gst-libs&quot;;../../../popt/include;../../../libxml2/include/libxml2"
+				PreprocessorDefinitions="WIN32;NDEBUG;_WINDOWS;_USRDLL;efence_EXPORTS;HAVE_CONFIG_H;_USE_MATH_DEFINES"
+				RuntimeLibrary="2"
+				UsePrecompiledHeader="0"
+				WarningLevel="3"
+				Detect64BitPortabilityProblems="TRUE"
+				DebugInformationFormat="3"/>
+			<Tool
+				Name="VCCustomBuildTool"/>
+			<Tool
+				Name="VCLinkerTool"
+				AdditionalDependencies="glib-2.0.lib gmodule-2.0.lib gthread-2.0.lib gobject-2.0.lib libgstreamer.lib gstbytestream.lib iconv.lib intl.lib"
+				OutputFile="$(OutDir)/gstefence.dll"
+				LinkIncremental="1"
+				AdditionalLibraryDirectories="../../../gstreamer/win32/Release;../../../glib/glib;../../../glib/gmodule;../../../glib/gthread;../../../glib/gobject;../../../gettext/lib;../../../libiconv/lib"
+				ModuleDefinitionFile=""
+				GenerateDebugInformation="TRUE"
+				SubSystem="2"
+				OptimizeReferences="2"
+				EnableCOMDATFolding="2"
+				ImportLibrary="$(OutDir)/gstefence.lib"
+				TargetMachine="1"/>
+			<Tool
+				Name="VCMIDLTool"/>
+			<Tool
+				Name="VCPostBuildEventTool"
+				CommandLine="copy /Y $(TargetPath) c:\gstreamer\plugins"/>
+			<Tool
+				Name="VCPreBuildEventTool"/>
+			<Tool
+				Name="VCPreLinkEventTool"/>
+			<Tool
+				Name="VCResourceCompilerTool"/>
+			<Tool
+				Name="VCWebServiceProxyGeneratorTool"/>
+			<Tool
+				Name="VCXMLDataGeneratorTool"/>
+			<Tool
+				Name="VCWebDeploymentTool"/>
+			<Tool
+				Name="VCManagedWrapperGeneratorTool"/>
+			<Tool
+				Name="VCAuxiliaryManagedWrapperGeneratorTool"/>
+		</Configuration>
+	</Configurations>
+	<References>
+	</References>
+	<Files>
+		<Filter
+			Name="Source Files"
+			Filter="cpp;c;cxx;def;odl;idl;hpj;bat;asm;asmx"
+			UniqueIdentifier="{4FC737F1-C7A5-4376-A066-2A32D752A2FF}">
+			<File
+				RelativePath=".\efence.c">
+			</File>
+		</Filter>
+		<Filter
+			Name="Header Files"
+			Filter="h;hpp;hxx;hm;inl;inc;xsd"
+			UniqueIdentifier="{93995380-89BD-4b04-88EB-625FBE52EBFB}">
+			<File
+				RelativePath=".\efence.h">
+			</File>
+		</Filter>
+		<Filter
+			Name="Resource Files"
+			Filter="rc;ico;cur;bmp;dlg;rc2;rct;bin;rgs;gif;jpg;jpeg;jpe;resx"
+			UniqueIdentifier="{67DA6AB6-F800-4c08-8B7A-83BB121AAD01}">
+		</Filter>
+	</Files>
+	<Globals>
+	</Globals>
+</VisualStudioProject>
diff --git a/gst/debugutils/gstdebug.c b/gst/debugutils/gstdebug.c
new file mode 100644
index 00000000..53f24d50
--- /dev/null
+++ b/gst/debugutils/gstdebug.c
@@ -0,0 +1,63 @@
+/* GStreamer
+ * Copyright (C) 2004 Benjamin Otte <otte@gnome.org>
+ *
+ * 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.
+ */
+
+#ifdef HAVE_CONFIG_H
+#  include "config.h"
+#endif
+
+#include <gst/gst.h>
+
+GType gst_break_my_data_get_type (void);
+GType gst_rnd_buffer_size_get_type (void);
+GType gst_navseek_get_type (void);
+GType gst_progress_report_get_type (void);
+GType gst_tag_inject_get_type (void);
+GType gst_test_get_type (void);
+/*
+GType gst_push_file_src_get_type (void);
+GType gst_gst_negotiation_get_type (void);
+*/
+
+static gboolean
+plugin_init (GstPlugin * plugin)
+{
+  if (!gst_element_register (plugin, "breakmydata", GST_RANK_NONE,
+          gst_break_my_data_get_type ())
+      || !gst_element_register (plugin, "rndbuffersize", GST_RANK_NONE,
+          gst_rnd_buffer_size_get_type ())
+      || !gst_element_register (plugin, "navseek", GST_RANK_NONE,
+          gst_navseek_get_type ()) ||
+/*    !gst_element_register (plugin, "pushfilesrc", GST_RANK_NONE, gst_push_file_src_get_type ()) || */
+/*    !gst_element_register (plugin, "negotiation", GST_RANK_NONE, gst_gst_negotiation_get_type ()) || */
+      !gst_element_register (plugin, "progressreport", GST_RANK_NONE,
+          gst_progress_report_get_type ())
+      || !gst_element_register (plugin, "taginject", GST_RANK_NONE,
+          gst_tag_inject_get_type ())
+      || !gst_element_register (plugin, "testsink", GST_RANK_NONE,
+          gst_test_get_type ()))
+    return FALSE;
+
+  return TRUE;
+}
+
+GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
+    GST_VERSION_MINOR,
+    "debug",
+    "elements for testing and debugging",
+    plugin_init, VERSION, "LGPL", GST_PACKAGE_NAME, GST_PACKAGE_ORIGIN)
diff --git a/gst/debugutils/gstnavigationtest.c b/gst/debugutils/gstnavigationtest.c
new file mode 100644
index 00000000..5c339252
--- /dev/null
+++ b/gst/debugutils/gstnavigationtest.c
@@ -0,0 +1,357 @@
+/* GStreamer
+ * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
+ * Copyright (C) <2003> David Schleef <ds@schleef.org>
+ *
+ * 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.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include "gstnavigationtest.h"
+#include <string.h>
+#include <math.h>
+
+#include <gst/video/video.h>
+
+#ifdef _MSC_VER
+#define rint(x) (floor((x)+0.5))
+#endif
+
+GST_DEBUG_CATEGORY_STATIC (navigationtest_debug);
+#define GST_CAT_DEFAULT navigationtest_debug
+
+static const GstElementDetails navigationtest_details =
+GST_ELEMENT_DETAILS ("Video navigation test",
+    "Filter/Effect/Video",
+    "Handle navigation events showing a black square following mouse pointer",
+    "David Schleef <ds@schleef.org>");
+
+static GstStaticPadTemplate gst_navigationtest_src_template =
+GST_STATIC_PAD_TEMPLATE ("src",
+    GST_PAD_SRC,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS (GST_VIDEO_CAPS_YUV ("I420"))
+    );
+
+static GstStaticPadTemplate gst_navigationtest_sink_template =
+GST_STATIC_PAD_TEMPLATE ("sink",
+    GST_PAD_SINK,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS (GST_VIDEO_CAPS_YUV ("I420"))
+    );
+
+static GstVideoFilterClass *parent_class = NULL;
+
+static gboolean
+gst_navigationtest_handle_src_event (GstPad * pad, GstEvent * event)
+{
+  GstNavigationtest *navtest;
+  const gchar *type;
+
+  navtest = GST_NAVIGATIONTEST (GST_PAD_PARENT (pad));
+
+  switch (GST_EVENT_TYPE (event)) {
+    case GST_EVENT_NAVIGATION:
+    {
+      const GstStructure *s = gst_event_get_structure (event);
+      gint fps_n, fps_d;
+
+      fps_n = gst_value_get_fraction_numerator ((&navtest->framerate));
+      fps_d = gst_value_get_fraction_denominator ((&navtest->framerate));
+
+      type = gst_structure_get_string (s, "event");
+      if (g_str_equal (type, "mouse-move")) {
+        gst_structure_get_double (s, "pointer_x", &navtest->x);
+        gst_structure_get_double (s, "pointer_y", &navtest->y);
+      } else if (g_str_equal (type, "mouse-button-press")) {
+        ButtonClick *click = g_new (ButtonClick, 1);
+
+        gst_structure_get_double (s, "pointer_x", &click->x);
+        gst_structure_get_double (s, "pointer_y", &click->y);
+        click->images_left = (fps_n + fps_d - 1) / fps_d;
+        /* green */
+        click->cy = 150;
+        click->cu = 46;
+        click->cv = 21;
+        navtest->clicks = g_slist_prepend (navtest->clicks, click);
+      } else if (g_str_equal (type, "mouse-button-release")) {
+        ButtonClick *click = g_new (ButtonClick, 1);
+
+        gst_structure_get_double (s, "pointer_x", &click->x);
+        gst_structure_get_double (s, "pointer_y", &click->y);
+        click->images_left = (fps_n + fps_d - 1) / fps_d;
+        /* red */
+        click->cy = 76;
+        click->cu = 85;
+        click->cv = 255;
+        navtest->clicks = g_slist_prepend (navtest->clicks, click);
+      }
+      break;
+    }
+    default:
+      break;
+  }
+  return gst_pad_event_default (pad, event);
+}
+
+/* Useful macros */
+#define GST_VIDEO_I420_Y_ROWSTRIDE(width) (GST_ROUND_UP_4(width))
+#define GST_VIDEO_I420_U_ROWSTRIDE(width) (GST_ROUND_UP_8(width)/2)
+#define GST_VIDEO_I420_V_ROWSTRIDE(width) ((GST_ROUND_UP_8(GST_VIDEO_I420_Y_ROWSTRIDE(width)))/2)
+
+#define GST_VIDEO_I420_Y_OFFSET(w,h) (0)
+#define GST_VIDEO_I420_U_OFFSET(w,h) (GST_VIDEO_I420_Y_OFFSET(w,h)+(GST_VIDEO_I420_Y_ROWSTRIDE(w)*GST_ROUND_UP_2(h)))
+#define GST_VIDEO_I420_V_OFFSET(w,h) (GST_VIDEO_I420_U_OFFSET(w,h)+(GST_VIDEO_I420_U_ROWSTRIDE(w)*GST_ROUND_UP_2(h)/2))
+
+#define GST_VIDEO_I420_SIZE(w,h)     (GST_VIDEO_I420_V_OFFSET(w,h)+(GST_VIDEO_I420_V_ROWSTRIDE(w)*GST_ROUND_UP_2(h)/2))
+
+static gboolean
+gst_navigationtest_get_unit_size (GstBaseTransform * btrans, GstCaps * caps,
+    guint * size)
+{
+  GstNavigationtest *navtest;
+  GstStructure *structure;
+  gboolean ret = FALSE;
+  gint width, height;
+
+  navtest = GST_NAVIGATIONTEST (btrans);
+
+  structure = gst_caps_get_structure (caps, 0);
+
+  if (gst_structure_get_int (structure, "width", &width) &&
+      gst_structure_get_int (structure, "height", &height)) {
+    *size = GST_VIDEO_I420_SIZE (width, height);
+    ret = TRUE;
+    GST_DEBUG_OBJECT (navtest, "our frame size is %d bytes (%dx%d)", *size,
+        width, height);
+  }
+
+  return ret;
+}
+
+static gboolean
+gst_navigationtest_set_caps (GstBaseTransform * btrans, GstCaps * incaps,
+    GstCaps * outcaps)
+{
+  GstNavigationtest *navtest = GST_NAVIGATIONTEST (btrans);
+  gboolean ret = FALSE;
+  GstStructure *structure;
+
+  structure = gst_caps_get_structure (incaps, 0);
+
+  if (gst_structure_get_int (structure, "width", &navtest->width) &&
+      gst_structure_get_int (structure, "height", &navtest->height)) {
+    const GValue *framerate;
+
+    framerate = gst_structure_get_value (structure, "framerate");
+    if (framerate && GST_VALUE_HOLDS_FRACTION (framerate)) {
+      g_value_copy (framerate, &navtest->framerate);
+      ret = TRUE;
+    }
+  }
+
+  return ret;
+}
+
+static void
+draw_box_planar411 (guint8 * dest, int width, int height, int x, int y,
+    guint8 colory, guint8 coloru, guint8 colorv)
+{
+  int x1, x2, y1, y2;
+  guint8 *d = dest;
+
+  if (x < 0 || y < 0 || x >= width || y >= height)
+    return;
+
+  x1 = MAX (x - 5, 0);
+  x2 = MIN (x + 5, width);
+  y1 = MAX (y - 5, 0);
+  y2 = MIN (y + 5, height);
+
+  for (y = y1; y < y2; y++) {
+    for (x = x1; x < x2; x++) {
+      ((guint8 *) d)[y * GST_VIDEO_I420_Y_ROWSTRIDE (width) + x] = colory;
+    }
+  }
+
+  d = dest + GST_VIDEO_I420_U_OFFSET (width, height);
+  x1 /= 2;
+  x2 /= 2;
+  y1 /= 2;
+  y2 /= 2;
+  for (y = y1; y < y2; y++) {
+    for (x = x1; x < x2; x++) {
+      ((guint8 *) d)[y * GST_VIDEO_I420_U_ROWSTRIDE (width) + x] = coloru;
+    }
+  }
+
+  d = dest + GST_VIDEO_I420_V_OFFSET (width, height);
+  for (y = y1; y < y2; y++) {
+    for (x = x1; x < x2; x++) {
+      ((guint8 *) d)[y * GST_VIDEO_I420_V_ROWSTRIDE (width) + x] = colorv;
+    }
+  }
+}
+
+static GstFlowReturn
+gst_navigationtest_transform (GstBaseTransform * trans, GstBuffer * in,
+    GstBuffer * out)
+{
+  GstNavigationtest *navtest = GST_NAVIGATIONTEST (trans);
+  GSList *walk;
+  GstFlowReturn ret = GST_FLOW_OK;
+
+  /* do something interesting here.  This simply copies the source
+   * to the destination. */
+  gst_buffer_copy_metadata (out, in, GST_BUFFER_COPY_TIMESTAMPS);
+
+  memcpy (GST_BUFFER_DATA (out), GST_BUFFER_DATA (in),
+      MIN (GST_BUFFER_SIZE (in), GST_BUFFER_SIZE (out)));
+
+  walk = navtest->clicks;
+  while (walk) {
+    ButtonClick *click = walk->data;
+
+    walk = g_slist_next (walk);
+    draw_box_planar411 (GST_BUFFER_DATA (out), navtest->width, navtest->height,
+        rint (click->x), rint (click->y), click->cy, click->cu, click->cv);
+    if (--click->images_left < 1) {
+      navtest->clicks = g_slist_remove (navtest->clicks, click);
+      g_free (click);
+    }
+  }
+  draw_box_planar411 (GST_BUFFER_DATA (out), navtest->width, navtest->height,
+      rint (navtest->x), rint (navtest->y), 0, 128, 128);
+
+  return ret;
+}
+
+static GstStateChangeReturn
+gst_navigationtest_change_state (GstElement * element,
+    GstStateChange transition)
+{
+  GstStateChangeReturn ret = GST_STATE_CHANGE_SUCCESS;
+  GstNavigationtest *navtest = GST_NAVIGATIONTEST (element);
+
+  if (GST_ELEMENT_CLASS (parent_class)->change_state)
+    ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition);
+
+  /* downwards state changes */
+  switch (transition) {
+    case GST_STATE_CHANGE_PAUSED_TO_READY:
+    {
+      g_slist_foreach (navtest->clicks, (GFunc) g_free, NULL);
+      g_slist_free (navtest->clicks);
+      navtest->clicks = NULL;
+      break;
+    }
+    default:
+      break;
+  }
+
+  return ret;
+}
+
+static void
+gst_navigationtest_base_init (gpointer g_class)
+{
+  GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);
+
+  gst_element_class_set_details (element_class, &navigationtest_details);
+
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&gst_navigationtest_sink_template));
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&gst_navigationtest_src_template));
+}
+
+static void
+gst_navigationtest_class_init (gpointer klass, gpointer class_data)
+{
+  GObjectClass *gobject_class;
+  GstElementClass *element_class;
+  GstBaseTransformClass *trans_class;
+
+  gobject_class = (GObjectClass *) klass;
+  element_class = (GstElementClass *) klass;
+  trans_class = (GstBaseTransformClass *) klass;
+
+  parent_class = g_type_class_peek_parent (klass);
+
+  element_class->change_state =
+      GST_DEBUG_FUNCPTR (gst_navigationtest_change_state);
+
+  trans_class->set_caps = GST_DEBUG_FUNCPTR (gst_navigationtest_set_caps);
+  trans_class->get_unit_size =
+      GST_DEBUG_FUNCPTR (gst_navigationtest_get_unit_size);
+  trans_class->transform = GST_DEBUG_FUNCPTR (gst_navigationtest_transform);
+}
+
+static void
+gst_navigationtest_init (GTypeInstance * instance, gpointer g_class)
+{
+  GstNavigationtest *navtest = GST_NAVIGATIONTEST (instance);
+  GstBaseTransform *btrans = GST_BASE_TRANSFORM (instance);
+
+  gst_pad_set_event_function (btrans->srcpad,
+      GST_DEBUG_FUNCPTR (gst_navigationtest_handle_src_event));
+
+  navtest->x = -1;
+  navtest->y = -1;
+  g_value_init (&navtest->framerate, GST_TYPE_FRACTION);
+}
+
+GType
+gst_navigationtest_get_type (void)
+{
+  static GType navigationtest_type = 0;
+
+  if (!navigationtest_type) {
+    static const GTypeInfo navigationtest_info = {
+      sizeof (GstNavigationtestClass),
+      gst_navigationtest_base_init,
+      NULL,
+      gst_navigationtest_class_init,
+      NULL,
+      NULL,
+      sizeof (GstNavigationtest),
+      0,
+      gst_navigationtest_init,
+    };
+
+    navigationtest_type = g_type_register_static (GST_TYPE_VIDEO_FILTER,
+        "GstNavigationtest", &navigationtest_info, 0);
+  }
+  return navigationtest_type;
+}
+
+static gboolean
+plugin_init (GstPlugin * plugin)
+{
+  GST_DEBUG_CATEGORY_INIT (navigationtest_debug, "navigationtest", 0,
+      "navigationtest");
+
+  return gst_element_register (plugin, "navigationtest", GST_RANK_NONE,
+      GST_TYPE_NAVIGATIONTEST);
+}
+
+GST_PLUGIN_DEFINE (GST_VERSION_MAJOR,
+    GST_VERSION_MINOR,
+    "navigationtest",
+    "Template for a video filter",
+    plugin_init, VERSION, GST_LICENSE, GST_PACKAGE_NAME, GST_PACKAGE_ORIGIN)
diff --git a/gst/debugutils/gstnavigationtest.h b/gst/debugutils/gstnavigationtest.h
new file mode 100644
index 00000000..efdbb228
--- /dev/null
+++ b/gst/debugutils/gstnavigationtest.h
@@ -0,0 +1,68 @@
+/* GStreamer
+ * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
+ *
+ * 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.
+ */
+
+
+#ifndef __GST_NAVIGATIONTEST_H__
+#define __GST_NAVIGATIONTEST_H__
+
+#include <gst/video/gstvideofilter.h>
+
+G_BEGIN_DECLS
+#define GST_TYPE_NAVIGATIONTEST \
+  (gst_navigationtest_get_type())
+#define GST_NAVIGATIONTEST(obj) \
+  (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_NAVIGATIONTEST,GstNavigationtest))
+#define GST_NAVIGATIONTEST_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_NAVIGATIONTEST,GstNavigationtestClass))
+#define GST_IS_NAVIGATIONTEST(obj) \
+  (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_NAVIGATIONTEST))
+#define GST_IS_NAVIGATIONTEST_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_NAVIGATIONTEST))
+typedef struct _GstNavigationtest GstNavigationtest;
+typedef struct _GstNavigationtestClass GstNavigationtestClass;
+
+typedef struct
+{
+  gdouble x;
+  gdouble y;
+  gint images_left;
+  guint8 cy, cu, cv;
+} ButtonClick;
+
+struct _GstNavigationtest
+{
+  GstVideoFilter videofilter;
+
+  gint width, height;
+
+  GValue framerate;
+  gdouble x, y;
+
+  GSList *clicks;
+};
+
+struct _GstNavigationtestClass
+{
+  GstVideoFilterClass parent_class;
+};
+
+GType gst_navigationtest_get_type (void);
+
+G_END_DECLS
+#endif /* __GST_NAVIGATIONTEST_H__ */
diff --git a/gst/debugutils/gstnavseek.c b/gst/debugutils/gstnavseek.c
new file mode 100644
index 00000000..c47bf42f
--- /dev/null
+++ b/gst/debugutils/gstnavseek.c
@@ -0,0 +1,340 @@
+/* GStreamer
+ * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
+ * Copyright (C) <2003> David Schleef <ds@schleef.org>
+ *
+ * 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.
+ */
+
+/*
+ * This file was (probably) generated from gstnavseek.c,
+ * gstnavseek.c,v 1.7 2003/11/08 02:48:59 dschleef Exp 
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include "gstnavseek.h"
+#include <string.h>
+#include <math.h>
+
+enum
+{
+  ARG_0,
+  ARG_SEEKOFFSET
+};
+
+GstStaticPadTemplate navseek_src_template = GST_STATIC_PAD_TEMPLATE ("src",
+    GST_PAD_SRC,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+GstStaticPadTemplate navseek_sink_template = GST_STATIC_PAD_TEMPLATE ("sink",
+    GST_PAD_SINK,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+static const GstElementDetails navseek_details =
+GST_ELEMENT_DETAILS ("Seek based on left-right arrows",
+    "Filter/Video",
+    "Seek based on navigation keys left-right",
+    "Jan Schmidt <thaytan@mad.scientist.com>");
+
+static gboolean gst_navseek_event (GstBaseTransform * trans, GstEvent * event);
+static GstFlowReturn gst_navseek_transform_ip (GstBaseTransform * basetrans,
+    GstBuffer * buf);
+static gboolean gst_navseek_handle_src_event (GstPad * pad, GstEvent * event);
+static gboolean gst_navseek_stop (GstBaseTransform * trans);
+static gboolean gst_navseek_start (GstBaseTransform * trans);
+
+static void gst_navseek_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec);
+static void gst_navseek_get_property (GObject * object, guint prop_id,
+    GValue * value, GParamSpec * pspec);
+
+GST_BOILERPLATE (GstNavSeek, gst_navseek, GstBaseTransform,
+    GST_TYPE_BASE_TRANSFORM);
+
+static void
+gst_navseek_base_init (gpointer g_class)
+{
+  GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);
+
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&navseek_sink_template));
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&navseek_src_template));
+
+  gst_element_class_set_details (element_class, &navseek_details);
+}
+
+static void
+gst_navseek_class_init (GstNavSeekClass * klass)
+{
+  GstBaseTransformClass *gstbasetrans_class;
+  GObjectClass *gobject_class;
+
+  gobject_class = G_OBJECT_CLASS (klass);
+  gstbasetrans_class = GST_BASE_TRANSFORM_CLASS (klass);
+
+  gobject_class->set_property = gst_navseek_set_property;
+  gobject_class->get_property = gst_navseek_get_property;
+
+  g_object_class_install_property (gobject_class,
+      ARG_SEEKOFFSET, g_param_spec_double ("seek-offset", "Seek Offset",
+          "Time in seconds to seek by", 0.0, G_MAXDOUBLE, 5.0,
+          G_PARAM_READWRITE));
+
+  gstbasetrans_class->event = GST_DEBUG_FUNCPTR (gst_navseek_event);
+  gstbasetrans_class->transform_ip =
+      GST_DEBUG_FUNCPTR (gst_navseek_transform_ip);
+  gstbasetrans_class->start = GST_DEBUG_FUNCPTR (gst_navseek_start);
+  gstbasetrans_class->stop = GST_DEBUG_FUNCPTR (gst_navseek_stop);
+}
+
+static void
+gst_navseek_init (GstNavSeek * navseek, GstNavSeekClass * g_class)
+{
+  gst_pad_set_event_function (GST_BASE_TRANSFORM (navseek)->srcpad,
+      GST_DEBUG_FUNCPTR (gst_navseek_handle_src_event));
+
+  gst_base_transform_set_passthrough (GST_BASE_TRANSFORM (navseek), TRUE);
+
+  navseek->seek_offset = 5.0;
+  navseek->loop = FALSE;
+  navseek->grab_seg_start = FALSE;
+  navseek->grab_seg_end = FALSE;
+  navseek->segment_start = GST_CLOCK_TIME_NONE;
+  navseek->segment_end = GST_CLOCK_TIME_NONE;
+}
+
+static void
+gst_navseek_seek (GstNavSeek * navseek, gint64 offset)
+{
+  GstFormat peer_format = GST_FORMAT_TIME;
+  gboolean ret;
+  GstPad *peer_pad;
+  gint64 peer_value;
+
+  /* Query for the current time then attempt to set to time + offset */
+  peer_pad = gst_pad_get_peer (GST_BASE_TRANSFORM (navseek)->sinkpad);
+  ret = gst_pad_query_position (peer_pad, &peer_format, &peer_value);
+
+  if (ret && peer_format == GST_FORMAT_TIME) {
+    GstEvent *event;
+
+    peer_value += offset;
+    if (peer_value < 0)
+      peer_value = 0;
+
+    event = gst_event_new_seek (1.0, GST_FORMAT_TIME,
+        GST_SEEK_FLAG_ACCURATE | GST_SEEK_FLAG_FLUSH,
+        GST_SEEK_TYPE_SET, peer_value, GST_SEEK_TYPE_NONE, GST_CLOCK_TIME_NONE);
+
+    gst_pad_send_event (peer_pad, event);
+  }
+
+  gst_object_unref (peer_pad);
+}
+
+static void
+gst_navseek_segseek (GstNavSeek * navseek)
+{
+  GstEvent *event;
+  GstPad *peer_pad;
+
+  if ((navseek->segment_start == GST_CLOCK_TIME_NONE) ||
+      (navseek->segment_end == GST_CLOCK_TIME_NONE) ||
+      (!GST_PAD_IS_LINKED (GST_BASE_TRANSFORM (navseek)->sinkpad))) {
+    return;
+  }
+
+  if (navseek->loop) {
+    event =
+        gst_event_new_seek (1.0, GST_FORMAT_TIME,
+        GST_SEEK_FLAG_ACCURATE | GST_SEEK_FLAG_SEGMENT,
+        GST_SEEK_TYPE_SET, navseek->segment_start, GST_SEEK_TYPE_SET,
+        navseek->segment_end);
+  } else {
+    event =
+        gst_event_new_seek (1.0, GST_FORMAT_TIME, GST_SEEK_FLAG_ACCURATE,
+        GST_SEEK_TYPE_SET, navseek->segment_start, GST_SEEK_TYPE_SET,
+        navseek->segment_end);
+  }
+
+  peer_pad = gst_pad_get_peer (GST_BASE_TRANSFORM (navseek)->sinkpad);
+  gst_pad_send_event (peer_pad, event);
+  gst_object_unref (peer_pad);
+}
+
+static gboolean
+gst_navseek_handle_src_event (GstPad * pad, GstEvent * event)
+{
+  GstNavSeek *navseek;
+  gboolean ret = TRUE;
+
+  navseek = GST_NAVSEEK (GST_PAD_PARENT (pad));
+
+  switch (GST_EVENT_TYPE (event)) {
+    case GST_EVENT_NAVIGATION:
+      /* Check for a keyup and convert left/right to a seek event */
+    {
+      const GstStructure *structure;
+      const gchar *event_type;
+
+      structure = gst_event_get_structure (event);
+      g_return_val_if_fail (structure != NULL, FALSE);
+
+      event_type = gst_structure_get_string (structure, "event");
+      g_return_val_if_fail (event_type != NULL, FALSE);
+
+      if (strcmp (event_type, "key-press") == 0) {
+        const gchar *key;
+
+        key = gst_structure_get_string (structure, "key");
+        g_return_val_if_fail (key != NULL, FALSE);
+
+        if (strcmp (key, "Left") == 0) {
+          /* Seek backward by 5 secs */
+          gst_navseek_seek (navseek, -1.0 * navseek->seek_offset * GST_SECOND);
+        } else if (strcmp (key, "Right") == 0) {
+          /* Seek forward */
+          gst_navseek_seek (navseek, navseek->seek_offset * GST_SECOND);
+        } else if (strcmp (key, "s") == 0) {
+          /* Grab the next frame as the start frame of a segment */
+          navseek->grab_seg_start = TRUE;
+        } else if (strcmp (key, "e") == 0) {
+          /* Grab the next frame as the end frame of a segment */
+          navseek->grab_seg_end = TRUE;
+        } else if (strcmp (key, "l") == 0) {
+          /* Toggle the loop flag. If we have both start and end segment times send a seek */
+          navseek->loop = !navseek->loop;
+          gst_navseek_segseek (navseek);
+        }
+      } else {
+        break;
+      }
+      gst_event_unref (event);
+      event = NULL;
+    }
+      break;
+    default:
+      break;
+  }
+
+  if (event && GST_PAD_IS_LINKED (GST_BASE_TRANSFORM (navseek)->sinkpad)) {
+    GstPad *peer_pad = gst_pad_get_peer (GST_BASE_TRANSFORM (navseek)->sinkpad);
+
+    ret = gst_pad_send_event (peer_pad, event);
+    gst_object_unref (peer_pad);
+  }
+
+  return ret;
+}
+
+static void
+gst_navseek_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec)
+{
+  GstNavSeek *navseek = GST_NAVSEEK (object);
+
+  switch (prop_id) {
+    case ARG_SEEKOFFSET:
+      GST_OBJECT_LOCK (navseek);
+      navseek->seek_offset = g_value_get_double (value);
+      GST_OBJECT_UNLOCK (navseek);
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
+}
+
+static void
+gst_navseek_get_property (GObject * object, guint prop_id,
+    GValue * value, GParamSpec * pspec)
+{
+  GstNavSeek *navseek = GST_NAVSEEK (object);
+
+  switch (prop_id) {
+    case ARG_SEEKOFFSET:
+      GST_OBJECT_LOCK (navseek);
+      g_value_set_double (value, navseek->seek_offset);
+      GST_OBJECT_UNLOCK (navseek);
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
+}
+
+static gboolean
+gst_navseek_event (GstBaseTransform * trans, GstEvent * event)
+{
+  GstNavSeek *navseek = GST_NAVSEEK (trans);
+
+  switch (GST_EVENT_TYPE (event)) {
+    case GST_EVENT_EOS:
+      GST_OBJECT_LOCK (navseek);
+      if (navseek->loop)
+        gst_navseek_segseek (navseek);
+      GST_OBJECT_UNLOCK (navseek);
+      break;
+    default:
+      break;
+  }
+  return GST_BASE_TRANSFORM_CLASS (parent_class)->event (trans, event);
+}
+
+static GstFlowReturn
+gst_navseek_transform_ip (GstBaseTransform * basetrans, GstBuffer * buf)
+{
+  GstNavSeek *navseek = GST_NAVSEEK (basetrans);
+
+  GST_OBJECT_LOCK (navseek);
+
+  if (GST_BUFFER_TIMESTAMP_IS_VALID (buf)) {
+    if (navseek->grab_seg_start) {
+      navseek->segment_start = GST_BUFFER_TIMESTAMP (buf);
+      navseek->segment_end = GST_CLOCK_TIME_NONE;
+      navseek->grab_seg_start = FALSE;
+    }
+
+    if (navseek->grab_seg_end) {
+      navseek->segment_end = GST_BUFFER_TIMESTAMP (buf);
+      navseek->grab_seg_end = FALSE;
+      gst_navseek_segseek (navseek);
+    }
+  }
+
+  GST_OBJECT_UNLOCK (navseek);
+
+  return GST_FLOW_OK;
+}
+
+static gboolean
+gst_navseek_start (GstBaseTransform * trans)
+{
+  /* anything we should be doing here? */
+  return TRUE;
+}
+
+static gboolean
+gst_navseek_stop (GstBaseTransform * trans)
+{
+  /* anything we should be doing here? */
+  return TRUE;
+}
diff --git a/gst/debugutils/gstnavseek.h b/gst/debugutils/gstnavseek.h
new file mode 100644
index 00000000..af7e9d21
--- /dev/null
+++ b/gst/debugutils/gstnavseek.h
@@ -0,0 +1,60 @@
+/* GStreamer
+ * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
+ *
+ * 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.
+ */
+
+
+#ifndef __GST_NAVSEEK_H__
+#define __GST_NAVSEEK_H__
+
+
+#include <gst/gst.h>
+#include <gst/base/gstbasetransform.h>
+
+G_BEGIN_DECLS
+#define GST_TYPE_NAVSEEK \
+  (gst_navseek_get_type())
+#define GST_NAVSEEK(obj) \
+  (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_NAVSEEK,GstNavSeek))
+#define GST_NAVSEEK_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_NAVSEEK,GstNavSeekClass))
+#define GST_IS_NAVSEEK(obj) \
+  (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_NAVSEEK))
+#define GST_IS_NAVSEEK_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_NAVSEEK))
+typedef struct _GstNavSeek GstNavSeek;
+typedef struct _GstNavSeekClass GstNavSeekClass;
+
+struct _GstNavSeek
+{
+  GstBaseTransform basetransform;
+
+  gdouble seek_offset;
+  gboolean loop;
+  gboolean grab_seg_start;
+  gboolean grab_seg_end;
+  GstClockTime segment_start;
+  GstClockTime segment_end;
+};
+
+struct _GstNavSeekClass
+{
+  GstBaseTransformClass parent_class;
+};
+
+G_END_DECLS
+#endif /* __GST_NAVSEEK_H__ */
diff --git a/gst/debugutils/gstpushfilesrc.c b/gst/debugutils/gstpushfilesrc.c
new file mode 100644
index 00000000..47daa83e
--- /dev/null
+++ b/gst/debugutils/gstpushfilesrc.c
@@ -0,0 +1,195 @@
+/* GStreamer Push File Source
+ * Copyright (C) <2007> Tim-Philipp Müller <tim centricular net>
+ *
+ * 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.
+ */
+
+/**
+ * SECTION:element-pushfilesrc
+ * @see_also: filesrc
+ *
+ * This element is only useful for debugging purposes. It implements an URI
+ * protocol handler for the 'pushfile' protocol and behaves like a file source
+ * element that cannot be activated in pull-mode. This makes it very easy to
+ * debug demuxers or decoders that can operate both pull and push-based in
+ * connection with the playbin element (which creates a source based on the
+ * URI passed).
+ *
+ * <refsect2>
+ * <title>Example launch line</title>
+ * |[
+ * gst-launch -m playbin uri=pushfile:///home/you/some/file.ogg
+ * ]| This plays back the given file using playbin, with the demuxer operating
+ * push-based.
+ * </refsect2>
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include "gstpushfilesrc.h"
+
+#include <gst/gst.h>
+
+GST_DEBUG_CATEGORY_STATIC (pushfilesrc_debug);
+#define GST_CAT_DEFAULT pushfilesrc_debug
+
+static const GstElementDetails pushfilesrc_details =
+GST_ELEMENT_DETAILS ("Push File Source",
+    "Testing",
+    "Implements pushfile:// URI-handler for push-based file access",
+    "Tim-Philipp Müller <tim centricular net>");
+
+static GstStaticPadTemplate srctemplate = GST_STATIC_PAD_TEMPLATE ("src",
+    GST_PAD_SRC,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+static void gst_push_file_src_uri_handler_init (gpointer g_iface,
+    gpointer iface_data);
+static void gst_file_push_src_add_uri_handler (GType type);
+
+GST_BOILERPLATE_FULL (GstPushFileSrc, gst_push_file_src, GstBin, GST_TYPE_BIN,
+    gst_file_push_src_add_uri_handler);
+
+static void
+gst_file_push_src_add_uri_handler (GType type)
+{
+  static const GInterfaceInfo info = {
+    gst_push_file_src_uri_handler_init,
+    NULL,
+    NULL
+  };
+
+  g_type_add_interface_static (type, GST_TYPE_URI_HANDLER, &info);
+  GST_DEBUG_CATEGORY_INIT (pushfilesrc_debug, "pushfilesrc", 0,
+      "pushfilesrc element");
+}
+
+static void
+gst_push_file_src_base_init (gpointer g_class)
+{
+  GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);
+
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&srctemplate));
+
+  gst_element_class_set_details (element_class, &pushfilesrc_details);
+}
+
+static void
+gst_push_file_src_dispose (GObject * obj)
+{
+  GstPushFileSrc *src = GST_PUSH_FILE_SRC (obj);
+
+  if (src->srcpad) {
+    gst_element_remove_pad (GST_ELEMENT (src), src->srcpad);
+    src->srcpad = NULL;
+  }
+  if (src->filesrc) {
+    gst_bin_remove (GST_BIN (src), src->filesrc);
+    src->filesrc = NULL;
+  }
+
+  G_OBJECT_CLASS (parent_class)->dispose (obj);
+}
+
+static void
+gst_push_file_src_class_init (GstPushFileSrcClass * g_class)
+{
+  GObjectClass *gobject_class;
+
+  gobject_class = G_OBJECT_CLASS (g_class);
+
+  gobject_class->dispose = gst_push_file_src_dispose;
+}
+
+static gboolean
+gst_push_file_src_ghostpad_checkgetrange (GstPad * pad)
+{
+  return FALSE;
+}
+
+static void
+gst_push_file_src_init (GstPushFileSrc * src, GstPushFileSrcClass * g_class)
+{
+  src->filesrc = gst_element_factory_make ("filesrc", "real-filesrc");
+  if (src->filesrc) {
+    GstPad *pad;
+
+    gst_bin_add (GST_BIN (src), src->filesrc);
+    pad = gst_element_get_static_pad (src->filesrc, "src");
+    g_assert (pad != NULL);
+    src->srcpad = gst_ghost_pad_new ("src", pad);
+    /* FIXME^H^HCORE: try pushfile:///foo/bar.ext ! typefind ! fakesink without
+     * this and watch core bugginess (some pad stays in flushing state) */
+    gst_pad_set_checkgetrange_function (src->srcpad,
+        GST_DEBUG_FUNCPTR (gst_push_file_src_ghostpad_checkgetrange));
+    gst_element_add_pad (GST_ELEMENT (src), src->srcpad);
+    gst_object_unref (pad);
+  }
+}
+
+/*** GSTURIHANDLER INTERFACE *************************************************/
+
+static GstURIType
+gst_push_file_src_uri_get_type (void)
+{
+  return GST_URI_SRC;
+}
+
+static gchar **
+gst_push_file_src_uri_get_protocols (void)
+{
+  static gchar *protocols[] = { "pushfile", NULL };
+
+  return protocols;
+}
+
+static const gchar *
+gst_push_file_src_uri_get_uri (GstURIHandler * handler)
+{
+  GstPushFileSrc *src = GST_PUSH_FILE_SRC (handler);
+
+  if (src->filesrc == NULL)
+    return NULL;
+
+  return gst_uri_handler_get_uri (GST_URI_HANDLER (src->filesrc));
+}
+
+static gboolean
+gst_push_file_src_uri_set_uri (GstURIHandler * handler, const gchar * uri)
+{
+  GstPushFileSrc *src = GST_PUSH_FILE_SRC (handler);
+
+  if (src->filesrc == NULL || !g_str_has_prefix (uri, "pushfile://"))
+    return FALSE;
+
+  /* skip 'push' bit */
+  return gst_uri_handler_set_uri (GST_URI_HANDLER (src->filesrc), uri + 4);
+}
+
+static void
+gst_push_file_src_uri_handler_init (gpointer g_iface, gpointer iface_data)
+{
+  GstURIHandlerInterface *iface = (GstURIHandlerInterface *) g_iface;
+
+  iface->get_type = gst_push_file_src_uri_get_type;
+  iface->get_protocols = gst_push_file_src_uri_get_protocols;
+  iface->get_uri = gst_push_file_src_uri_get_uri;
+  iface->set_uri = gst_push_file_src_uri_set_uri;
+}
diff --git a/gst/debugutils/gstpushfilesrc.h b/gst/debugutils/gstpushfilesrc.h
new file mode 100644
index 00000000..d9333444
--- /dev/null
+++ b/gst/debugutils/gstpushfilesrc.h
@@ -0,0 +1,56 @@
+/* GStreamer Push File Source
+ * Copyright (C) <2007> Tim-Philipp Müller <tim centricular net>
+ *
+ * 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.
+ */
+
+#ifndef __GST_PUSH_FILE_SRC_H__
+#define __GST_PUSH_FILE_SRC_H__
+
+#include <gst/gstbin.h>
+
+G_BEGIN_DECLS
+#define GST_TYPE_PUSH_FILE_SRC \
+  (gst_push_file_src_get_type())
+#define GST_PUSH_FILE_SRC(obj) \
+  (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_PUSH_FILE_SRC,GstPushFileSrc))
+#define GST_PUSH_FILE_SRC_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_PUSH_FILE_SRC,GstPushFileSrcClass))
+#define GST_IS_PUSH_FILE_SRC(obj) \
+  (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_PUSH_FILE_SRC))
+#define GST_IS_PUSH_FILE_SRC_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_PUSH_FILE_SRC))
+typedef struct _GstPushFileSrc GstPushFileSrc;
+typedef struct _GstPushFileSrcClass GstPushFileSrcClass;
+
+struct _GstPushFileSrc
+{
+  GstBin parent;
+
+  /*< private > */
+  GstElement *filesrc;
+  GstPad *srcpad;
+};
+
+struct _GstPushFileSrcClass
+{
+  GstBinClass parent_class;
+};
+
+GType gst_push_file_src_get_type (void);
+
+G_END_DECLS
+#endif /* __GST_PUSH_FILE_SRC_H__ */
diff --git a/gst/debugutils/gsttaginject.c b/gst/debugutils/gsttaginject.c
new file mode 100644
index 00000000..3429fb14
--- /dev/null
+++ b/gst/debugutils/gsttaginject.c
@@ -0,0 +1,204 @@
+/* GStreamer
+ * Copyright (C) 2008 Stefan Kost <ensonic@users.sf.net>
+ *
+ * gsttaginject.c:
+ *
+ * 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.
+ */
+/**
+ * SECTION:element-taginject
+ *
+ * Element that injects new metadata tags, but passes incomming data through
+ * unmodified.
+ *
+ * <refsect2>
+ * <title>Example launch lines</title>
+ * |[
+ * gst-launch audiotestsrc num-buffers=100 ! taginject tags="title=testsrc,artist=gstreamer" ! vorbisenc ! oggmux ! filesink location=test.ogg
+ * ]| set title and artist
+ * |[
+ * gst-launch audiotestsrc num-buffers=100 ! taginject tags="keywords=\"testone,audio\",title=\"audio testtone\"" ! vorbisenc ! oggmux ! filesink location=test.ogg
+ * ]| set keywords and title demonstrating quoting of special chars
+ * </refsect2>
+ */
+
+#ifdef HAVE_CONFIG_H
+#  include "config.h"
+#endif
+
+#include <stdlib.h>
+
+#include "gsttaginject.h"
+
+static GstStaticPadTemplate sinktemplate = GST_STATIC_PAD_TEMPLATE ("sink",
+    GST_PAD_SINK,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+static GstStaticPadTemplate srctemplate = GST_STATIC_PAD_TEMPLATE ("src",
+    GST_PAD_SRC,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+GST_DEBUG_CATEGORY_STATIC (gst_tag_inject_debug);
+#define GST_CAT_DEFAULT gst_tag_inject_debug
+
+enum
+{
+  PROP_TAGS = 1
+};
+
+
+#define DEBUG_INIT(bla) \
+    GST_DEBUG_CATEGORY_INIT (gst_tag_inject_debug, "taginject", 0, "tag inject element");
+
+GST_BOILERPLATE_FULL (GstTagInject, gst_tag_inject, GstBaseTransform,
+    GST_TYPE_BASE_TRANSFORM, DEBUG_INIT);
+
+static void gst_tag_inject_finalize (GObject * object);
+static void gst_tag_inject_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec);
+static void gst_tag_inject_get_property (GObject * object, guint prop_id,
+    GValue * value, GParamSpec * pspec);
+
+static GstFlowReturn gst_tag_inject_transform_ip (GstBaseTransform * trans,
+    GstBuffer * buf);
+static gboolean gst_tag_inject_start (GstBaseTransform * trans);
+
+
+static void
+gst_tag_inject_base_init (gpointer g_class)
+{
+  GstElementClass *gstelement_class = GST_ELEMENT_CLASS (g_class);
+
+  gst_element_class_set_details_simple (gstelement_class,
+      "TagInject",
+      "Generic", "inject metadata tags", "Stefan Kost <ensonic@users.sf.net>");
+  gst_element_class_add_pad_template (gstelement_class,
+      gst_static_pad_template_get (&srctemplate));
+  gst_element_class_add_pad_template (gstelement_class,
+      gst_static_pad_template_get (&sinktemplate));
+}
+
+static void
+gst_tag_inject_finalize (GObject * object)
+{
+  GstTagInject *self = GST_TAG_INJECT (object);
+
+  if (self->tags) {
+    gst_tag_list_free (self->tags);
+    self->tags = NULL;
+  }
+
+  G_OBJECT_CLASS (parent_class)->finalize (object);
+}
+
+static void
+gst_tag_inject_class_init (GstTagInjectClass * klass)
+{
+  GObjectClass *gobject_class;
+  GstElementClass *gstelement_class;
+  GstBaseTransformClass *gstbasetrans_class;
+
+  gobject_class = G_OBJECT_CLASS (klass);
+  gstelement_class = GST_ELEMENT_CLASS (klass);
+  gstbasetrans_class = GST_BASE_TRANSFORM_CLASS (klass);
+
+  gobject_class->set_property = GST_DEBUG_FUNCPTR (gst_tag_inject_set_property);
+  gobject_class->get_property = GST_DEBUG_FUNCPTR (gst_tag_inject_get_property);
+
+  g_object_class_install_property (gobject_class, PROP_TAGS,
+      g_param_spec_string ("tags", "taglist",
+          "List of tags to inject into the target file",
+          NULL, G_PARAM_WRITABLE | G_PARAM_STATIC_STRINGS));
+
+  gobject_class->finalize = GST_DEBUG_FUNCPTR (gst_tag_inject_finalize);
+
+  gstbasetrans_class->transform_ip =
+      GST_DEBUG_FUNCPTR (gst_tag_inject_transform_ip);
+
+  gstbasetrans_class->start = GST_DEBUG_FUNCPTR (gst_tag_inject_start);
+}
+
+static void
+gst_tag_inject_init (GstTagInject * self, GstTagInjectClass * g_class)
+{
+  self->tags = NULL;
+}
+
+static GstFlowReturn
+gst_tag_inject_transform_ip (GstBaseTransform * trans, GstBuffer * buf)
+{
+  GstTagInject *self = GST_TAG_INJECT (trans);
+
+  if (G_UNLIKELY (!self->tags_sent)) {
+    self->tags_sent = TRUE;
+    /* send tags */
+    if (self->tags && !gst_tag_list_is_empty (self->tags)) {
+      GST_DEBUG ("tag event :%" GST_PTR_FORMAT, self->tags);
+      gst_element_found_tags (GST_ELEMENT (trans),
+          gst_tag_list_copy (self->tags));
+    }
+  }
+
+  return GST_FLOW_OK;
+}
+
+static void
+gst_tag_inject_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec)
+{
+  GstTagInject *self = GST_TAG_INJECT (object);
+
+  switch (prop_id) {
+    case PROP_TAGS:{
+      gchar *structure =
+          g_strdup_printf ("taglist,%s", g_value_get_string (value));
+      if (!(self->tags = gst_structure_from_string (structure, NULL))) {
+        GST_WARNING ("unparsable taglist = '%s'", structure);
+      }
+      g_free (structure);
+      break;
+    }
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
+}
+
+static void
+gst_tag_inject_get_property (GObject * object, guint prop_id, GValue * value,
+    GParamSpec * pspec)
+{
+  /*GstTagInject *self = GST_TAG_INJECT (object); */
+
+  switch (prop_id) {
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
+}
+
+static gboolean
+gst_tag_inject_start (GstBaseTransform * trans)
+{
+  GstTagInject *self = GST_TAG_INJECT (trans);
+
+  /* we need to sent tags _transform_ip() once */
+  self->tags_sent = FALSE;
+
+  return TRUE;
+}
diff --git a/gst/debugutils/gsttaginject.h b/gst/debugutils/gsttaginject.h
new file mode 100644
index 00000000..8e8de1ee
--- /dev/null
+++ b/gst/debugutils/gsttaginject.h
@@ -0,0 +1,66 @@
+/* GStreamer
+ * Copyright (C) 2008 Stefan Kost <ensonic@users.sf.net>
+ *
+ * gsttaginject.h:
+ *
+ * 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.
+ */
+
+
+#ifndef __GST_TAG_INJECT_H__
+#define __GST_TAG_INJECT_H__
+
+
+#include <gst/gst.h>
+#include <gst/base/gstbasetransform.h>
+
+G_BEGIN_DECLS
+#define GST_TYPE_TAG_INJECT \
+  (gst_tag_inject_get_type())
+#define GST_TAG_INJECT(obj) \
+  (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_TAG_INJECT,GstTagInject))
+#define GST_TAG_INJECT_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_TAG_INJECT,GstTagInjectClass))
+#define GST_IS_TAG_INJECT(obj) \
+  (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_TAG_INJECT))
+#define GST_IS_TAG_INJECT_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_TAG_INJECT))
+typedef struct _GstTagInject GstTagInject;
+typedef struct _GstTagInjectClass GstTagInjectClass;
+
+/**
+ * GstTagInject:
+ *
+ * Opaque #GstTagInject data structure
+ */
+struct _GstTagInject
+{
+  GstBaseTransform element;
+
+  /*< private > */
+  GstTagList *tags;
+  gboolean tags_sent;
+};
+
+struct _GstTagInjectClass
+{
+  GstBaseTransformClass parent_class;
+};
+
+GType gst_tag_inject_get_type (void);
+
+G_END_DECLS
+#endif /* __GST_TAG_INJECT_H__ */
diff --git a/gst/debugutils/navigationtest.vcproj b/gst/debugutils/navigationtest.vcproj
new file mode 100644
index 00000000..0bcc0ff7
--- /dev/null
+++ b/gst/debugutils/navigationtest.vcproj
@@ -0,0 +1,148 @@
+<?xml version="1.0" encoding="Windows-1252"?>
+<VisualStudioProject
+	ProjectType="Visual C++"
+	Version="7.10"
+	Name="navigationtest"
+	ProjectGUID="{979C216F-0ACF-4956-AE00-055A42D678AD}"
+	Keyword="Win32Proj">
+	<Platforms>
+		<Platform
+			Name="Win32"/>
+	</Platforms>
+	<Configurations>
+		<Configuration
+			Name="Debug|Win32"
+			OutputDirectory="../../win32/Debug"
+			IntermediateDirectory="../../win32/Debug"
+			ConfigurationType="2"
+			CharacterSet="2">
+			<Tool
+				Name="VCCLCompilerTool"
+				Optimization="0"
+				AdditionalIncludeDirectories="../../../gstreamer/win32;../../../gstreamer;../../../gstreamer/libs;../../../glib;../../../glib/glib;../../../glib/gmodule;&quot;../../gst-libs&quot;;../../../popt/include;../../../libxml2/include/libxml2"
+				PreprocessorDefinitions="WIN32;_DEBUG;_WINDOWS;_USRDLL;navigationtest_EXPORTS;HAVE_CONFIG_H;_USE_MATH_DEFINES"
+				MinimalRebuild="TRUE"
+				BasicRuntimeChecks="3"
+				RuntimeLibrary="3"
+				UsePrecompiledHeader="0"
+				WarningLevel="3"
+				Detect64BitPortabilityProblems="TRUE"
+				DebugInformationFormat="4"/>
+			<Tool
+				Name="VCCustomBuildTool"/>
+			<Tool
+				Name="VCLinkerTool"
+				AdditionalDependencies="glib-2.0.lib gmodule-2.0.lib gthread-2.0.lib gobject-2.0.lib libgstreamer.lib gstbytestream.lib iconv.lib intl.lib"
+				OutputFile="$(OutDir)/gstnavigationtest.dll"
+				LinkIncremental="2"
+				AdditionalLibraryDirectories="../../../gstreamer/win32/Debug;../../../glib/glib;../../../glib/gmodule;../../../glib/gthread;../../../glib/gobject;../../../gettext/lib;../../../libiconv/lib"
+				ModuleDefinitionFile=""
+				GenerateDebugInformation="TRUE"
+				ProgramDatabaseFile="$(OutDir)/navigationtest.pdb"
+				SubSystem="2"
+				OptimizeReferences="2"
+				ImportLibrary="$(OutDir)/gstnavigationtest.lib"
+				TargetMachine="1"/>
+			<Tool
+				Name="VCMIDLTool"/>
+			<Tool
+				Name="VCPostBuildEventTool"
+				CommandLine="copy /Y $(TargetPath) c:\gstreamer\plugins"/>
+			<Tool
+				Name="VCPreBuildEventTool"/>
+			<Tool
+				Name="VCPreLinkEventTool"/>
+			<Tool
+				Name="VCResourceCompilerTool"/>
+			<Tool
+				Name="VCWebServiceProxyGeneratorTool"/>
+			<Tool
+				Name="VCXMLDataGeneratorTool"/>
+			<Tool
+				Name="VCWebDeploymentTool"/>
+			<Tool
+				Name="VCManagedWrapperGeneratorTool"/>
+			<Tool
+				Name="VCAuxiliaryManagedWrapperGeneratorTool"/>
+		</Configuration>
+		<Configuration
+			Name="Release|Win32"
+			OutputDirectory="../../win32/Release"
+			IntermediateDirectory="../../win32/Release"
+			ConfigurationType="2"
+			CharacterSet="2">
+			<Tool
+				Name="VCCLCompilerTool"
+				AdditionalIncludeDirectories="../../../gstreamer/win32;../../../gstreamer;../../../gstreamer/libs;../../../glib;../../../glib/glib;../../../glib/gmodule;&quot;../../gst-libs&quot;;../../../popt/include;../../../libxml2/include/libxml2"
+				PreprocessorDefinitions="WIN32;NDEBUG;_WINDOWS;_USRDLL;navigationtest_EXPORTS;HAVE_CONFIG_H;_USE_MATH_DEFINES"
+				RuntimeLibrary="2"
+				UsePrecompiledHeader="0"
+				WarningLevel="3"
+				Detect64BitPortabilityProblems="TRUE"
+				DebugInformationFormat="3"/>
+			<Tool
+				Name="VCCustomBuildTool"/>
+			<Tool
+				Name="VCLinkerTool"
+				AdditionalDependencies="glib-2.0.lib gmodule-2.0.lib gthread-2.0.lib gobject-2.0.lib libgstreamer.lib gstbytestream.lib iconv.lib intl.lib"
+				OutputFile="$(OutDir)/gstnavigationtest.dll"
+				LinkIncremental="1"
+				AdditionalLibraryDirectories="../../../gstreamer/win32/Release;../../../glib/glib;../../../glib/gmodule;../../../glib/gthread;../../../glib/gobject;../../../gettext/lib;../../../libiconv/lib"
+				ModuleDefinitionFile=""
+				GenerateDebugInformation="TRUE"
+				SubSystem="2"
+				OptimizeReferences="2"
+				EnableCOMDATFolding="2"
+				ImportLibrary="$(OutDir)/gstnavigationtest.lib"
+				TargetMachine="1"/>
+			<Tool
+				Name="VCMIDLTool"/>
+			<Tool
+				Name="VCPostBuildEventTool"
+				CommandLine="copy /Y $(TargetPath) c:\gstreamer\plugins"/>
+			<Tool
+				Name="VCPreBuildEventTool"/>
+			<Tool
+				Name="VCPreLinkEventTool"/>
+			<Tool
+				Name="VCResourceCompilerTool"/>
+			<Tool
+				Name="VCWebServiceProxyGeneratorTool"/>
+			<Tool
+				Name="VCXMLDataGeneratorTool"/>
+			<Tool
+				Name="VCWebDeploymentTool"/>
+			<Tool
+				Name="VCManagedWrapperGeneratorTool"/>
+			<Tool
+				Name="VCAuxiliaryManagedWrapperGeneratorTool"/>
+		</Configuration>
+	</Configurations>
+	<References>
+	</References>
+	<Files>
+		<Filter
+			Name="Source Files"
+			Filter="cpp;c;cxx;def;odl;idl;hpj;bat;asm;asmx"
+			UniqueIdentifier="{4FC737F1-C7A5-4376-A066-2A32D752A2FF}">
+			<File
+				RelativePath=".\gstnavigationtest.c">
+			</File>
+		</Filter>
+		<Filter
+			Name="Header Files"
+			Filter="h;hpp;hxx;hm;inl;inc;xsd"
+			UniqueIdentifier="{93995380-89BD-4b04-88EB-625FBE52EBFB}">
+			<File
+				RelativePath=".\navigationtest.h">
+			</File>
+		</Filter>
+		<Filter
+			Name="Resource Files"
+			Filter="rc;ico;cur;bmp;dlg;rc2;rct;bin;rgs;gif;jpg;jpeg;jpe;resx"
+			UniqueIdentifier="{67DA6AB6-F800-4c08-8B7A-83BB121AAD01}">
+		</Filter>
+	</Files>
+	<Globals>
+	</Globals>
+</VisualStudioProject>
diff --git a/gst/debugutils/negotiation.c b/gst/debugutils/negotiation.c
new file mode 100644
index 00000000..12082273
--- /dev/null
+++ b/gst/debugutils/negotiation.c
@@ -0,0 +1,287 @@
+/*
+ * GStreamer
+ * Copyright (C) 1999-2001 Erik Walthinsen <omega@cse.ogi.edu>
+ * Copyright (C) 2002 David A. Schleef <ds@schleef.org>
+ *
+ * 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.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+#include <gst/gst.h>
+
+#include <string.h>
+#include <unistd.h>
+#include <sys/mman.h>
+
+
+#define GST_TYPE_NEGOTIATION \
+  (gst_gst_negotiation_get_type())
+#define GST_NEGOTIATION(obj) \
+  (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_NEGOTIATION,GstNegotiation))
+#define GST_NEGOTIATION_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_NEGOTIATION,GstNegotiation))
+#define GST_IS_NEGOTIATION(obj) \
+  (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_NEGOTIATION))
+#define GST_IS_NEGOTIATION_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_NEGOTIATION))
+
+typedef struct _GstNegotiation GstNegotiation;
+typedef struct _GstNegotiationClass GstNegotiationClass;
+
+struct _GstNegotiation
+{
+  GstElement element;
+
+  GstPad *sinkpad, *srcpad;
+
+  GstCaps *caps;
+};
+
+struct _GstNegotiationClass
+{
+  GstElementClass parent_class;
+};
+
+GType gst_gst_negotiation_get_type (void);
+
+
+static const GstElementDetails plugin_details =
+GST_ELEMENT_DETAILS ("Negotiation",
+    "Testing",
+    "This element acts like identity, except that one can control how "
+    "negotiation works",
+    "David A. Schleef <ds@schleef.org>");
+
+/* Filter signals and args */
+enum
+{
+  /* FILL ME */
+  LAST_SIGNAL
+};
+
+enum
+{
+  ARG_0,
+  ARG_ALLOWED_CAPS
+};
+
+static GstStaticPadTemplate gst_negotiation_sink_factory =
+GST_STATIC_PAD_TEMPLATE ("sink",
+    GST_PAD_SINK,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+static GstStaticPadTemplate gst_negotiation_src_factory =
+GST_STATIC_PAD_TEMPLATE ("src",
+    GST_PAD_SRC,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+static void gst_negotiation_base_init (gpointer g_class);
+static void gst_negotiation_class_init (GstNegotiationClass * klass);
+static void gst_negotiation_init (GstNegotiation * filter);
+
+static GstCaps *gst_negotiation_getcaps (GstPad * pad);
+static GstPadLinkReturn gst_negotiation_pad_link (GstPad * pad,
+    const GstCaps * caps);
+
+static void gst_negotiation_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec);
+static void gst_negotiation_get_property (GObject * object, guint prop_id,
+    GValue * value, GParamSpec * pspec);
+
+static void gst_negotiation_update_caps (GstNegotiation * negotiation);
+static void gst_negotiation_chain (GstPad * pad, GstData * _data);
+
+static GstElementClass *parent_class = NULL;
+
+GType
+gst_gst_negotiation_get_type (void)
+{
+  static GType plugin_type = 0;
+
+  if (!plugin_type) {
+    static const GTypeInfo plugin_info = {
+      sizeof (GstNegotiationClass),
+      gst_negotiation_base_init,
+      NULL,
+      (GClassInitFunc) gst_negotiation_class_init,
+      NULL,
+      NULL,
+      sizeof (GstNegotiation),
+      0,
+      (GInstanceInitFunc) gst_negotiation_init,
+    };
+
+    plugin_type = g_type_register_static (GST_TYPE_ELEMENT,
+        "GstNegotiation", &plugin_info, 0);
+  }
+  return plugin_type;
+}
+
+static void
+gst_negotiation_base_init (gpointer g_class)
+{
+  GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);
+
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&gst_negotiation_sink_factory));
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&gst_negotiation_src_factory));
+  gst_element_class_set_details (element_class, &plugin_details);
+}
+
+static void
+gst_negotiation_class_init (GstNegotiationClass * klass)
+{
+  GObjectClass *gobject_class;
+  GstElementClass *gstelement_class;
+
+  gobject_class = (GObjectClass *) klass;
+  gstelement_class = (GstElementClass *) klass;
+
+  parent_class = g_type_class_peek_parent (klass);
+
+  gobject_class->set_property = gst_negotiation_set_property;
+  gobject_class->get_property = gst_negotiation_get_property;
+
+  g_object_class_install_property (gobject_class, ARG_ALLOWED_CAPS,
+      g_param_spec_boxed ("allowed-caps", "Caps",
+          "The range of formats allowed by " "this element's peers",
+          GST_TYPE_CAPS, G_PARAM_READABLE));
+}
+
+static void
+gst_negotiation_init (GstNegotiation * filter)
+{
+  filter->sinkpad =
+      gst_pad_new_from_static_template (&gst_negotiation_sink_factory, "sink");
+  gst_pad_set_getcaps_function (filter->sinkpad, gst_negotiation_getcaps);
+  gst_pad_set_link_function (filter->sinkpad, gst_negotiation_pad_link);
+  filter->srcpad =
+      gst_pad_new_from_static_template (&gst_negotiation_src_factory, "src");
+  gst_pad_set_getcaps_function (filter->srcpad, gst_negotiation_getcaps);
+  gst_pad_set_link_function (filter->srcpad, gst_negotiation_pad_link);
+
+  gst_element_add_pad (GST_ELEMENT (filter), filter->sinkpad);
+  gst_element_add_pad (GST_ELEMENT (filter), filter->srcpad);
+  gst_pad_set_chain_function (filter->sinkpad, gst_negotiation_chain);
+}
+
+static GstCaps *
+gst_negotiation_getcaps (GstPad * pad)
+{
+  GstNegotiation *negotiation = GST_NEGOTIATION (gst_pad_get_parent (pad));
+  GstPad *otherpad;
+  GstCaps *caps;
+
+  otherpad = (pad == negotiation->sinkpad) ? negotiation->srcpad :
+      negotiation->sinkpad;
+
+  caps = gst_pad_get_allowed_caps (otherpad);
+
+  GST_ERROR ("getcaps called on %" GST_PTR_FORMAT ", returning %"
+      GST_PTR_FORMAT, pad, caps);
+
+  gst_negotiation_update_caps (negotiation);
+  gst_object_unref (negotiation);
+
+  return caps;
+}
+
+static GstPadLinkReturn
+gst_negotiation_pad_link (GstPad * pad, const GstCaps * caps)
+{
+  GstNegotiation *negotiation = GST_NEGOTIATION (gst_pad_get_parent (pad));
+  GstPad *otherpad;
+  GstPadLinkReturn ret;
+
+  otherpad = (pad == negotiation->sinkpad) ? negotiation->srcpad :
+      negotiation->sinkpad;
+
+  ret = gst_pad_try_set_caps (otherpad, caps);
+
+  GST_ERROR ("pad_link called on %" GST_PTR_FORMAT " with caps %"
+      GST_PTR_FORMAT ", returning %d", pad, caps, ret);
+  gst_object_unref (negotiation);
+
+  return ret;
+}
+
+static void
+gst_negotiation_update_caps (GstNegotiation * negotiation)
+{
+  GstCaps *srccaps;
+  GstCaps *sinkcaps;
+  GstCaps *icaps;
+
+  srccaps = gst_pad_get_allowed_caps (negotiation->srcpad);
+  sinkcaps = gst_pad_get_allowed_caps (negotiation->sinkpad);
+
+  icaps = gst_caps_intersect (srccaps, sinkcaps);
+  gst_caps_free (srccaps);
+  gst_caps_free (sinkcaps);
+
+  gst_caps_replace (&negotiation->caps, icaps);
+  g_object_notify (G_OBJECT (negotiation), "allowed-caps");
+  GST_DEBUG ("notify %" GST_PTR_FORMAT, icaps);
+}
+
+static void
+gst_negotiation_chain (GstPad * pad, GstData * _data)
+{
+  GstNegotiation *negotiation = GST_NEGOTIATION (gst_pad_get_parent (pad));
+
+  gst_pad_push (negotiation->srcpad, _data);
+  gst_object_unref (negotiation);
+}
+
+static void
+gst_negotiation_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec)
+{
+  GstNegotiation *filter;
+
+  g_return_if_fail (GST_IS_NEGOTIATION (object));
+  filter = GST_NEGOTIATION (object);
+
+  switch (prop_id) {
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
+}
+
+static void
+gst_negotiation_get_property (GObject * object, guint prop_id,
+    GValue * value, GParamSpec * pspec)
+{
+  GstNegotiation *filter;
+
+  g_return_if_fail (GST_IS_NEGOTIATION (object));
+  filter = GST_NEGOTIATION (object);
+
+  switch (prop_id) {
+    case ARG_ALLOWED_CAPS:
+      g_value_set_boxed (value, filter->caps);
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
+}
diff --git a/gst/debugutils/progressreport.c b/gst/debugutils/progressreport.c
new file mode 100644
index 00000000..8f2547b3
--- /dev/null
+++ b/gst/debugutils/progressreport.c
@@ -0,0 +1,478 @@
+/* GStreamer Progress Report Element
+ * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
+ * Copyright (C) <2003> David Schleef <ds@schleef.org>
+ * Copyright (C) <2004> Jan Schmidt <thaytan@mad.scientist.com>
+ * Copyright (C) <2006> Tim-Philipp Müller <tim centricular net>
+ *
+ * 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.
+ */
+
+/**
+ * SECTION:element-progressreport
+ *
+ * The progressreport element can be put into a pipeline to report progress,
+ * which is done by doing upstream duration and position queries in regular
+ * (real-time) intervals. Both the interval and the prefered query format
+ * can be specified via the #GstProgressReport:update-freq and the
+ * #GstProgressReport:format property.
+ *
+ * Element messages containing a "progress" structure are posted on the bus
+ * whenever progress has been queried (since gst-plugins-good 0.10.6 only).
+ *
+ * Since the element was originally designed for debugging purposes, it will
+ * by default also print information about the current progress to the
+ * terminal. This can be prevented by setting the #GstProgressReport:silent
+ * property to %TRUE.
+ *
+ * This element is most useful in transcoding pipelines or other situations
+ * where just querying the pipeline might not lead to the wanted result. For
+ * progress in TIME format, the element is best placed in a 'raw stream'
+ * section of the pipeline (or after any demuxers/decoders/parsers).
+ *
+ * Three more things should be pointed out: firstly, the element will only
+ * query progress when data flow happens. If data flow is stalled for some
+ * reason, no progress messages will be posted. Secondly, there are other
+ * elements (like qtdemux, for example) that may also post "progress" element
+ * messages on the bus. Applications should check the source of any element
+ * messages they receive, if needed. Finally, applications should not take
+ * action on receiving notification of progress being 100%, they should only
+ * take action when they receive an EOS message (since the progress reported
+ * is in reference to an internal point of a pipeline and not the pipeline as
+ * a whole).
+ *
+ * <refsect2>
+ * <title>Example launch line</title>
+ * |[
+ * gst-launch -m filesrc location=foo.ogg ! decodebin ! progressreport update-freq=1 ! audioconvert ! audioresample ! autoaudiosink
+ * ]| This shows a progress query where a duration is available.
+ * |[
+ * gst-launch -m audiotestsrc ! progressreport update-freq=1 ! audioconvert ! autoaudiosink
+ * ]| This shows a progress query where no duration is available.
+ * </refsect2>
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include <gst/gst.h>
+#include <string.h>
+#include <math.h>
+#include <time.h>
+
+#include "progressreport.h"
+
+
+enum
+{
+  ARG_0,
+  ARG_UPDATE_FREQ,
+  ARG_SILENT,
+  ARG_FORMAT
+};
+
+GstStaticPadTemplate progress_report_src_template =
+GST_STATIC_PAD_TEMPLATE ("src",
+    GST_PAD_SRC,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+GstStaticPadTemplate progress_report_sink_template =
+GST_STATIC_PAD_TEMPLATE ("sink",
+    GST_PAD_SINK,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+static const GstElementDetails progress_report_details =
+GST_ELEMENT_DETAILS ("Progress report",
+    "Testing",
+    "Periodically query and report on processing progress",
+    "Jan Schmidt <thaytan@mad.scientist.com>");
+
+#define DEFAULT_UPDATE_FREQ  5
+#define DEFAULT_SILENT       FALSE
+#define DEFAULT_FORMAT       "auto"
+
+static void gst_progress_report_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec);
+static void gst_progress_report_get_property (GObject * object, guint prop_id,
+    GValue * value, GParamSpec * pspec);
+
+static gboolean gst_progress_report_event (GstBaseTransform * trans,
+    GstEvent * event);
+static GstFlowReturn gst_progress_report_transform_ip (GstBaseTransform * trans,
+    GstBuffer * buf);
+
+static gboolean gst_progress_report_start (GstBaseTransform * trans);
+static gboolean gst_progress_report_stop (GstBaseTransform * trans);
+
+GST_BOILERPLATE (GstProgressReport, gst_progress_report, GstBaseTransform,
+    GST_TYPE_BASE_TRANSFORM);
+
+static void
+gst_progress_report_base_init (gpointer g_class)
+{
+  GstElementClass *element_class = GST_ELEMENT_CLASS (g_class);
+
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&progress_report_sink_template));
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&progress_report_src_template));
+
+  gst_element_class_set_details (element_class, &progress_report_details);
+}
+
+static void
+gst_progress_report_finalize (GObject * obj)
+{
+  GstProgressReport *filter = GST_PROGRESS_REPORT (obj);
+
+  g_free (filter->format);
+  filter->format = NULL;
+
+  G_OBJECT_CLASS (parent_class)->finalize (obj);
+}
+
+static void
+gst_progress_report_class_init (GstProgressReportClass * g_class)
+{
+  GstBaseTransformClass *gstbasetrans_class;
+  GObjectClass *gobject_class;
+
+  gobject_class = G_OBJECT_CLASS (g_class);
+  gstbasetrans_class = GST_BASE_TRANSFORM_CLASS (g_class);
+
+  gobject_class->finalize = gst_progress_report_finalize;
+  gobject_class->set_property = gst_progress_report_set_property;
+  gobject_class->get_property = gst_progress_report_get_property;
+
+  g_object_class_install_property (gobject_class,
+      ARG_UPDATE_FREQ, g_param_spec_int ("update-freq", "Update Frequency",
+          "Number of seconds between reports when data is flowing", 1, G_MAXINT,
+          DEFAULT_UPDATE_FREQ, G_PARAM_READWRITE));
+
+  g_object_class_install_property (gobject_class,
+      ARG_SILENT, g_param_spec_boolean ("silent",
+          "Do not print output to stdout", "Do not print output to stdout",
+          DEFAULT_SILENT, G_PARAM_READWRITE));
+
+  g_object_class_install_property (gobject_class,
+      ARG_FORMAT, g_param_spec_string ("format", "format",
+          "Format to use for the querying", DEFAULT_FORMAT, G_PARAM_READWRITE));
+
+  gstbasetrans_class->event = GST_DEBUG_FUNCPTR (gst_progress_report_event);
+  gstbasetrans_class->transform_ip =
+      GST_DEBUG_FUNCPTR (gst_progress_report_transform_ip);
+  gstbasetrans_class->start = GST_DEBUG_FUNCPTR (gst_progress_report_start);
+  gstbasetrans_class->stop = GST_DEBUG_FUNCPTR (gst_progress_report_stop);
+}
+
+static void
+gst_progress_report_init (GstProgressReport * report,
+    GstProgressReportClass * g_class)
+{
+  gst_base_transform_set_passthrough (GST_BASE_TRANSFORM (report), TRUE);
+
+  report->update_freq = DEFAULT_UPDATE_FREQ;
+  report->silent = DEFAULT_SILENT;
+  report->format = g_strdup (DEFAULT_FORMAT);
+}
+
+static void
+gst_progress_report_post_progress (GstProgressReport * filter,
+    GstFormat format, gint64 current, gint64 total)
+{
+  GstStructure *s = NULL;
+
+  if (current >= 0 && total > 0) {
+    gdouble perc;
+
+    perc = gst_util_guint64_to_gdouble (current) * 100.0 /
+        gst_util_guint64_to_gdouble (total);
+    perc = CLAMP (perc, 0.0, 100.0);
+
+    /* we provide a "percent" field of integer type to stay compatible
+     * with qtdemux, but add a second "percent-double" field for those who
+     * want more precision and are too lazy to calculate it themselves */
+    s = gst_structure_new ("progress", "percent", G_TYPE_INT, (gint) perc,
+        "percent-double", G_TYPE_DOUBLE, perc, "current", G_TYPE_INT64, current,
+        "total", G_TYPE_INT64, total, NULL);
+  } else if (current >= 0) {
+    s = gst_structure_new ("progress", "current", G_TYPE_INT64, current, NULL);
+  }
+
+  if (s) {
+    GST_LOG_OBJECT (filter, "posting progress message: %" GST_PTR_FORMAT, s);
+    gst_structure_set (s, "format", GST_TYPE_FORMAT, format, NULL);
+    /* can't post it right here because we're holding the object lock */
+    filter->pending_msg = gst_message_new_element (GST_OBJECT_CAST (filter), s);
+  }
+}
+
+static gboolean
+gst_progress_report_do_query (GstProgressReport * filter, GstFormat format,
+    gint hh, gint mm, gint ss)
+{
+  const gchar *format_name = NULL;
+  GstPad *sink_pad;
+  gint64 cur, total;
+
+  sink_pad = GST_BASE_TRANSFORM (filter)->sinkpad;
+
+  GST_LOG_OBJECT (filter, "querying using format %d (%s)", format,
+      gst_format_get_name (format));
+
+  if (!gst_pad_query_peer_position (sink_pad, &format, &cur) ||
+      !gst_pad_query_peer_duration (sink_pad, &format, &total)) {
+    return FALSE;
+  }
+
+  switch (format) {
+    case GST_FORMAT_BYTES:
+      format_name = "bytes";
+      break;
+    case GST_FORMAT_BUFFERS:
+      format_name = "buffers";
+      break;
+    case GST_FORMAT_PERCENT:
+      format_name = "percent";
+      break;
+    case GST_FORMAT_TIME:
+      format_name = "seconds";
+      cur /= GST_SECOND;
+      total /= GST_SECOND;
+      break;
+    case GST_FORMAT_DEFAULT:{
+      GstCaps *caps;
+
+      format_name = "bogounits";
+      caps = GST_PAD_CAPS (GST_BASE_TRANSFORM (filter)->sinkpad);
+      if (caps && gst_caps_is_fixed (caps) && !gst_caps_is_any (caps)) {
+        GstStructure *s = gst_caps_get_structure (caps, 0);
+        const gchar *mime_type = gst_structure_get_name (s);
+
+        if (g_str_has_prefix (mime_type, "video/") ||
+            g_str_has_prefix (mime_type, "image/")) {
+          format_name = "frames";
+        } else if (g_str_has_prefix (mime_type, "audio/")) {
+          format_name = "samples";
+        }
+      }
+      break;
+    }
+    default:{
+      const GstFormatDefinition *details;
+
+      details = gst_format_get_details (format);
+      if (details) {
+        format_name = details->nick;
+      } else {
+        format_name = "unknown";
+      }
+      break;
+    }
+  }
+
+  if (!filter->silent) {
+    if (total > 0) {
+      g_print ("%s (%02d:%02d:%02d): %" G_GINT64_FORMAT " / %"
+          G_GINT64_FORMAT " %s (%4.1f %%)\n", GST_OBJECT_NAME (filter), hh,
+          mm, ss, cur, total, format_name, (gdouble) cur / total * 100.0);
+    } else {
+      g_print ("%s (%02d:%02d:%02d): %" G_GINT64_FORMAT " %s\n",
+          GST_OBJECT_NAME (filter), hh, mm, ss, cur, format_name);
+    }
+  }
+
+  gst_progress_report_post_progress (filter, format, cur, total);
+  return TRUE;
+}
+
+static void
+gst_progress_report_report (GstProgressReport * filter, GTimeVal cur_time)
+{
+  GstFormat try_formats[] = { GST_FORMAT_TIME, GST_FORMAT_BYTES,
+    GST_FORMAT_PERCENT, GST_FORMAT_BUFFERS,
+    GST_FORMAT_DEFAULT
+  };
+  GstMessage *msg;
+  GstFormat format = GST_FORMAT_UNDEFINED;
+  gboolean done = FALSE;
+  glong run_time;
+  gint hh, mm, ss;
+
+  run_time = cur_time.tv_sec - filter->start_time.tv_sec;
+
+  hh = (run_time / 3600) % 100;
+  mm = (run_time / 60) % 60;
+  ss = (run_time % 60);
+
+  GST_OBJECT_LOCK (filter);
+
+  if (filter->format != NULL && strcmp (filter->format, "auto") != 0) {
+    format = gst_format_get_by_nick (filter->format);
+  }
+
+  if (format != GST_FORMAT_UNDEFINED) {
+    done = gst_progress_report_do_query (filter, format, hh, mm, ss);
+  } else {
+    gint i;
+
+    for (i = 0; i < G_N_ELEMENTS (try_formats); ++i) {
+      done = gst_progress_report_do_query (filter, try_formats[i], hh, mm, ss);
+      if (done)
+        break;
+    }
+  }
+
+  if (!done && !filter->silent) {
+    g_print ("%s (%2d:%2d:%2d): Could not query position and/or duration\n",
+        GST_OBJECT_NAME (filter), hh, mm, ss);
+  }
+
+  msg = filter->pending_msg;
+  filter->pending_msg = NULL;
+  GST_OBJECT_UNLOCK (filter);
+
+  if (msg) {
+    gst_element_post_message (GST_ELEMENT_CAST (filter), msg);
+  }
+}
+
+static gboolean
+gst_progress_report_event (GstBaseTransform * trans, GstEvent * event)
+{
+  GstProgressReport *filter;
+
+  filter = GST_PROGRESS_REPORT (trans);
+
+  if (GST_EVENT_TYPE (event) == GST_EVENT_EOS) {
+    GTimeVal cur_time;
+
+    g_get_current_time (&cur_time);
+    gst_progress_report_report (filter, cur_time);
+  }
+  return GST_BASE_TRANSFORM_CLASS (parent_class)->event (trans, event);
+}
+
+static GstFlowReturn
+gst_progress_report_transform_ip (GstBaseTransform * trans, GstBuffer * buf)
+{
+  GstProgressReport *filter;
+  gboolean need_update;
+  GTimeVal cur_time;
+
+  g_get_current_time (&cur_time);
+
+  filter = GST_PROGRESS_REPORT (trans);
+
+  /* Check if update_freq seconds have passed since the last update */
+  GST_OBJECT_LOCK (filter);
+  need_update =
+      ((cur_time.tv_sec - filter->last_report.tv_sec) >= filter->update_freq);
+  GST_OBJECT_UNLOCK (filter);
+
+  if (need_update) {
+    gst_progress_report_report (filter, cur_time);
+    GST_OBJECT_LOCK (filter);
+    filter->last_report = cur_time;
+    GST_OBJECT_UNLOCK (filter);
+  }
+
+  return GST_FLOW_OK;
+}
+
+static gboolean
+gst_progress_report_start (GstBaseTransform * trans)
+{
+  GstProgressReport *filter;
+
+  filter = GST_PROGRESS_REPORT (trans);
+
+  g_get_current_time (&filter->last_report);
+  filter->start_time = filter->last_report;
+
+  return TRUE;
+}
+
+static gboolean
+gst_progress_report_stop (GstBaseTransform * trans)
+{
+  /* anything we should be doing here? */
+  return TRUE;
+}
+
+static void
+gst_progress_report_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec)
+{
+  GstProgressReport *filter;
+
+  filter = GST_PROGRESS_REPORT (object);
+
+  switch (prop_id) {
+    case ARG_UPDATE_FREQ:
+      GST_OBJECT_LOCK (filter);
+      filter->update_freq = g_value_get_int (value);
+      GST_OBJECT_UNLOCK (filter);
+      break;
+    case ARG_SILENT:
+      GST_OBJECT_LOCK (filter);
+      filter->silent = g_value_get_boolean (value);
+      GST_OBJECT_UNLOCK (filter);
+      break;
+    case ARG_FORMAT:
+      GST_OBJECT_LOCK (filter);
+      g_free (filter->format);
+      filter->format = g_value_dup_string (value);
+      if (filter->format == NULL)
+        filter->format = g_strdup ("auto");
+      GST_OBJECT_UNLOCK (filter);
+      break;
+    default:
+      break;
+  }
+}
+
+static void
+gst_progress_report_get_property (GObject * object, guint prop_id,
+    GValue * value, GParamSpec * pspec)
+{
+  GstProgressReport *filter;
+
+  filter = GST_PROGRESS_REPORT (object);
+
+  switch (prop_id) {
+    case ARG_UPDATE_FREQ:
+      GST_OBJECT_LOCK (filter);
+      g_value_set_int (value, filter->update_freq);
+      GST_OBJECT_UNLOCK (filter);
+      break;
+    case ARG_SILENT:
+      GST_OBJECT_LOCK (filter);
+      g_value_set_boolean (value, filter->silent);
+      GST_OBJECT_UNLOCK (filter);
+      break;
+    case ARG_FORMAT:
+      GST_OBJECT_LOCK (filter);
+      g_value_set_string (value, filter->format);
+      GST_OBJECT_UNLOCK (filter);
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
+}
diff --git a/gst/debugutils/progressreport.h b/gst/debugutils/progressreport.h
new file mode 100644
index 00000000..92886b29
--- /dev/null
+++ b/gst/debugutils/progressreport.h
@@ -0,0 +1,66 @@
+/* GStreamer Progress Report Element
+ * Copyright (C) <1999> Erik Walthinsen <omega@cse.ogi.edu>
+ * Copyright (C) <2003> David Schleef <ds@schleef.org>
+ * Copyright (C) <2004> Jan Schmidt <thaytan@mad.scientist.com>
+ * Copyright (C) <2006> Tim-Philipp Müller <tim centricular net>
+ *
+ * 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.
+ */
+
+#ifndef __GST_PROGRESS_REPORT_H__
+#define __GST_PROGRESS_REPORT_H__
+
+#include <gst/base/gstbasetransform.h>
+
+G_BEGIN_DECLS
+#define GST_TYPE_PROGRESS_REPORT \
+  (gst_progress_report_get_type())
+#define GST_PROGRESS_REPORT(obj) \
+  (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_PROGRESS_REPORT,GstProgressReport))
+#define GST_PROGRESS_REPORT_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_PROGRESS_REPORT,GstProgressReportClass))
+#define GST_IS_PROGRESS_REPORT(obj) \
+  (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_PROGRESS_REPORT))
+#define GST_IS_PROGRESS_REPORT_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_PROGRESS_REPORT))
+typedef struct _GstProgressReport GstProgressReport;
+typedef struct _GstProgressReportClass GstProgressReportClass;
+
+struct _GstProgressReport
+{
+  GstBaseTransform basetransform;
+
+  GstMessage *pending_msg;
+
+  gint update_freq;
+  gboolean silent;
+  GTimeVal start_time;
+  GTimeVal last_report;
+
+  /* Format used for querying. Using a string here because the
+   * format might not be registered yet when the property is set */
+  gchar *format;
+};
+
+struct _GstProgressReportClass
+{
+  GstBaseTransformClass parent_class;
+};
+
+GType gst_progress_report_get_type (void);
+
+G_END_DECLS
+#endif /* __GST_PROGRESS_REPORT_H__ */
diff --git a/gst/debugutils/rndbuffersize.c b/gst/debugutils/rndbuffersize.c
new file mode 100644
index 00000000..7a8abd6b
--- /dev/null
+++ b/gst/debugutils/rndbuffersize.c
@@ -0,0 +1,371 @@
+/* GStreamer
+ * Copyright (C) 2007 Nokia Corporation (contact <stefan.kost@nokia.com>)
+ *
+ * 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.
+ */
+/**
+ * SECTION:element-rndbuffersize
+ *
+ * This element pulls buffers with random sizes from the source.
+ */
+
+#ifdef HAVE_CONFIG_H
+#  include "config.h"
+#endif
+
+#include <gst/gst.h>
+
+GST_DEBUG_CATEGORY_STATIC (gst_rnd_buffer_size_debug);
+#define GST_CAT_DEFAULT gst_rnd_buffer_size_debug
+
+#define GST_TYPE_RND_BUFFER_SIZE            (gst_rnd_buffer_size_get_type())
+#define GST_RND_BUFFER_SIZE(obj)            (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_RND_BUFFER_SIZE,GstRndBufferSize))
+#define GST_RND_BUFFER_SIZE_CLASS(klass)    (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_RND_BUFFER_SIZE,GstRndBufferSizeClass))
+#define GST_IS_RND_BUFFER_SIZE(obj)         (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_RND_BUFFER_SIZE))
+#define GST_IS_RND_BUFFER_SIZE_CLASS(klass) (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_RND_BUFFER_SIZE))
+
+typedef struct _GstRndBufferSize GstRndBufferSize;
+typedef struct _GstRndBufferSizeClass GstRndBufferSizeClass;
+
+struct _GstRndBufferSize
+{
+  GstElement parent;
+
+  /*< private > */
+  GRand *rand;
+  gulong seed;
+  glong min, max;
+
+  GstPad *sinkpad, *srcpad;
+  guint64 offset;
+};
+
+struct _GstRndBufferSizeClass
+{
+  GstElementClass parent_class;
+};
+
+enum
+{
+  ARG_SEED = 1,
+  ARG_MINIMUM,
+  ARG_MAXIMUM
+};
+
+#define DEFAULT_SEED 0
+#define DEFAULT_MIN  1
+#define DEFAULT_MAX  (8*1024)
+
+static GstStaticPadTemplate src_template = GST_STATIC_PAD_TEMPLATE ("src",
+    GST_PAD_SRC,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+static GstStaticPadTemplate sink_template = GST_STATIC_PAD_TEMPLATE ("sink",
+    GST_PAD_SINK,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+static void gst_rnd_buffer_size_finalize (GObject * object);
+static void gst_rnd_buffer_size_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec);
+static void gst_rnd_buffer_size_get_property (GObject * object, guint prop_id,
+    GValue * value, GParamSpec * pspec);
+
+static gboolean gst_rnd_buffer_size_activate (GstPad * pad);
+static gboolean gst_rnd_buffer_size_activate_pull (GstPad * pad,
+    gboolean active);
+static void gst_rnd_buffer_size_loop (GstRndBufferSize * self);
+static GstStateChangeReturn gst_rnd_buffer_size_change_state (GstElement *
+    element, GstStateChange transition);
+
+#define DEBUG_INIT(bla) \
+  GST_DEBUG_CATEGORY_INIT (gst_rnd_buffer_size_debug, "rndbuffersize", 0, \
+      "rndbuffersize element");
+
+GST_BOILERPLATE_FULL (GstRndBufferSize, gst_rnd_buffer_size, GstElement,
+    GST_TYPE_ELEMENT, DEBUG_INIT);
+
+
+static void
+gst_rnd_buffer_size_base_init (gpointer g_class)
+{
+  GstElementClass *gstelement_class = GST_ELEMENT_CLASS (g_class);
+
+  gst_element_class_add_pad_template (gstelement_class,
+      gst_static_pad_template_get (&sink_template));
+  gst_element_class_add_pad_template (gstelement_class,
+      gst_static_pad_template_get (&src_template));
+
+  gst_element_class_set_details_simple (gstelement_class, "Random buffer size",
+      "Testing", "pull random sized buffers",
+      "Stefan Kost <stefan.kost@nokia.com>)");
+}
+
+
+static void
+gst_rnd_buffer_size_class_init (GstRndBufferSizeClass * klass)
+{
+  GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
+  GstElementClass *gstelement_class = GST_ELEMENT_CLASS (klass);
+
+  gobject_class->set_property =
+      GST_DEBUG_FUNCPTR (gst_rnd_buffer_size_set_property);
+  gobject_class->get_property =
+      GST_DEBUG_FUNCPTR (gst_rnd_buffer_size_get_property);
+  gobject_class->finalize = GST_DEBUG_FUNCPTR (gst_rnd_buffer_size_finalize);
+
+  gstelement_class->change_state =
+      GST_DEBUG_FUNCPTR (gst_rnd_buffer_size_change_state);
+
+  /* FIXME 0.11: these should all be int instead of long, to avoid bugs
+   * when passing these as varargs with g_object_set(), and there was no
+   * reason to use long in the first place here */
+  g_object_class_install_property (gobject_class, ARG_SEED,
+      g_param_spec_ulong ("seed", "random number seed",
+          "seed for randomness (initialized when going from READY to PAUSED)",
+          0, G_MAXUINT32, DEFAULT_SEED, G_PARAM_READWRITE | G_PARAM_CONSTRUCT));
+  g_object_class_install_property (gobject_class, ARG_MINIMUM,
+      g_param_spec_long ("min", "mininum", "mininum buffer size",
+          0, G_MAXINT32, DEFAULT_MIN, G_PARAM_READWRITE | G_PARAM_CONSTRUCT));
+  g_object_class_install_property (gobject_class, ARG_MAXIMUM,
+      g_param_spec_long ("max", "maximum", "maximum buffer size",
+          1, G_MAXINT32, DEFAULT_MAX, G_PARAM_READWRITE | G_PARAM_CONSTRUCT));
+}
+
+static void
+gst_rnd_buffer_size_init (GstRndBufferSize * self,
+    GstRndBufferSizeClass * g_class)
+{
+  self->sinkpad = gst_pad_new_from_static_template (&sink_template, "sink");
+  gst_pad_set_activate_function (self->sinkpad,
+      GST_DEBUG_FUNCPTR (gst_rnd_buffer_size_activate));
+  gst_pad_set_activatepull_function (self->sinkpad,
+      GST_DEBUG_FUNCPTR (gst_rnd_buffer_size_activate_pull));
+  gst_element_add_pad (GST_ELEMENT (self), self->sinkpad);
+
+  self->srcpad = gst_pad_new_from_static_template (&src_template, "src");
+  gst_element_add_pad (GST_ELEMENT (self), self->srcpad);
+}
+
+
+static void
+gst_rnd_buffer_size_finalize (GObject * object)
+{
+  GstRndBufferSize *self = GST_RND_BUFFER_SIZE (object);
+
+  if (self->rand) {
+    g_rand_free (self->rand);
+    self->rand = NULL;
+  }
+
+  G_OBJECT_CLASS (parent_class)->finalize (object);
+}
+
+
+static void
+gst_rnd_buffer_size_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec)
+{
+  GstRndBufferSize *self = GST_RND_BUFFER_SIZE (object);
+
+  switch (prop_id) {
+    case ARG_SEED:
+      self->seed = g_value_get_ulong (value);
+      break;
+    case ARG_MINIMUM:
+      self->min = g_value_get_long (value);
+      break;
+    case ARG_MAXIMUM:
+      self->max = g_value_get_long (value);
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
+}
+
+
+static void
+gst_rnd_buffer_size_get_property (GObject * object, guint prop_id,
+    GValue * value, GParamSpec * pspec)
+{
+  GstRndBufferSize *self = GST_RND_BUFFER_SIZE (object);
+
+  switch (prop_id) {
+    case ARG_SEED:
+      g_value_set_ulong (value, self->seed);
+      break;
+    case ARG_MINIMUM:
+      g_value_set_long (value, self->min);
+      break;
+    case ARG_MAXIMUM:
+      g_value_set_long (value, self->max);
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
+}
+
+
+static gboolean
+gst_rnd_buffer_size_activate (GstPad * pad)
+{
+  if (gst_pad_check_pull_range (pad)) {
+    return gst_pad_activate_pull (pad, TRUE);
+  } else {
+    GST_INFO_OBJECT (pad, "push mode not supported");
+    return FALSE;
+  }
+}
+
+
+static gboolean
+gst_rnd_buffer_size_activate_pull (GstPad * pad, gboolean active)
+{
+  GstRndBufferSize *self = GST_RND_BUFFER_SIZE (GST_OBJECT_PARENT (pad));
+
+  if (active) {
+    GST_INFO_OBJECT (self, "starting pull");
+    return gst_pad_start_task (pad, (GstTaskFunction) gst_rnd_buffer_size_loop,
+        self);
+  } else {
+    GST_INFO_OBJECT (self, "stopping pull");
+    return gst_pad_stop_task (pad);
+  }
+}
+
+
+static void
+gst_rnd_buffer_size_loop (GstRndBufferSize * self)
+{
+  GstBuffer *buf = NULL;
+  GstFlowReturn ret;
+  guint num_bytes;
+
+  if (G_UNLIKELY (self->min > self->max))
+    goto bogus_minmax;
+
+  if (G_UNLIKELY (self->min != self->max)) {
+    num_bytes = g_rand_int_range (self->rand, self->min, self->max);
+  } else {
+    num_bytes = self->min;
+  }
+
+  GST_LOG_OBJECT (self, "pulling %u bytes at offset %" G_GUINT64_FORMAT,
+      num_bytes, self->offset);
+
+  ret = gst_pad_pull_range (self->sinkpad, self->offset, num_bytes, &buf);
+
+  if (ret != GST_FLOW_OK)
+    goto pull_failed;
+
+  if (GST_BUFFER_SIZE (buf) < num_bytes) {
+    GST_WARNING_OBJECT (self, "short buffer: %u bytes", GST_BUFFER_SIZE (buf));
+  }
+
+  self->offset += GST_BUFFER_SIZE (buf);
+
+  ret = gst_pad_push (self->srcpad, buf);
+
+  if (ret != GST_FLOW_OK)
+    goto push_failed;
+
+  return;
+
+pause_task:
+  {
+    GST_DEBUG_OBJECT (self, "pausing task");
+    gst_pad_pause_task (self->sinkpad);
+    return;
+  }
+
+pull_failed:
+  {
+    if (ret == GST_FLOW_UNEXPECTED) {
+      GST_DEBUG_OBJECT (self, "eos");
+      gst_pad_push_event (self->srcpad, gst_event_new_eos ());
+    } else {
+      GST_WARNING_OBJECT (self, "pull_range flow: %s", gst_flow_get_name (ret));
+    }
+    goto pause_task;
+  }
+
+push_failed:
+  {
+    GST_DEBUG_OBJECT (self, "push flow: %s", gst_flow_get_name (ret));
+    if (ret == GST_FLOW_UNEXPECTED) {
+      GST_DEBUG_OBJECT (self, "eos");
+      gst_pad_push_event (self->srcpad, gst_event_new_eos ());
+    } else if (GST_FLOW_IS_FATAL (ret) || ret == GST_FLOW_NOT_LINKED) {
+      GST_ELEMENT_ERROR (self, STREAM, FAILED,
+          ("Internal data stream error."),
+          ("streaming stopped, reason: %s", gst_flow_get_name (ret)));
+    }
+    goto pause_task;
+  }
+
+bogus_minmax:
+  {
+    GST_ELEMENT_ERROR (self, LIBRARY, SETTINGS,
+        ("The minimum buffer size is smaller than the maximum buffer size."),
+        ("buffer sizes: max=%ld, min=%ld", self->min, self->max));
+    goto pause_task;
+  }
+}
+
+static GstStateChangeReturn
+gst_rnd_buffer_size_change_state (GstElement * element,
+    GstStateChange transition)
+{
+  GstRndBufferSize *self = GST_RND_BUFFER_SIZE (element);
+  GstStateChangeReturn ret;
+
+  switch (transition) {
+    case GST_STATE_CHANGE_NULL_TO_READY:
+      break;
+    case GST_STATE_CHANGE_READY_TO_PAUSED:
+      self->offset = 0;
+      if (!self->rand) {
+        self->rand = g_rand_new_with_seed (self->seed);
+      }
+      break;
+    case GST_STATE_CHANGE_PAUSED_TO_PLAYING:
+      break;
+    default:
+      break;
+  }
+
+  ret = GST_ELEMENT_CLASS (parent_class)->change_state (element, transition);
+
+  switch (transition) {
+    case GST_STATE_CHANGE_PLAYING_TO_PAUSED:
+      break;
+    case GST_STATE_CHANGE_PAUSED_TO_READY:
+      if (self->rand) {
+        g_rand_free (self->rand);
+        self->rand = NULL;
+      }
+      break;
+    case GST_STATE_CHANGE_READY_TO_NULL:
+      break;
+    default:
+      break;
+  }
+
+  return ret;
+}
diff --git a/gst/debugutils/testplugin.c b/gst/debugutils/testplugin.c
new file mode 100644
index 00000000..dbb1e618
--- /dev/null
+++ b/gst/debugutils/testplugin.c
@@ -0,0 +1,318 @@
+/* GStreamer
+ * Copyright (C) 2004 Benjamin Otte <otte@gnome.org>
+ *
+ * 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.
+ */
+
+#ifdef HAVE_CONFIG_H
+#  include "config.h"
+#endif
+
+#include <gst/gst.h>
+#include <gst/base/gstbasesink.h>
+#include "tests.h"
+
+GST_DEBUG_CATEGORY_STATIC (gst_test_debug);
+#define GST_CAT_DEFAULT gst_test_debug
+
+/* This plugin does all the tests registered in the tests.h file
+ */
+
+#define GST_TYPE_TEST \
+  (gst_test_get_type())
+#define GST_TEST(obj) \
+  (G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_TEST,GstTest))
+#define GST_TEST_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_TEST,GstTestClass))
+#define GST_TEST_GET_CLASS(obj) \
+  (G_TYPE_INSTANCE_GET_CLASS ((obj),GST_TYPE_TEST,GstTestClass))
+#define GST_IS_TEST(obj) \
+  (G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_TEST))
+#define GST_IS_TEST_CLASS(klass) \
+  (G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_TEST))
+
+typedef struct _GstTest GstTest;
+typedef struct _GstTestClass GstTestClass;
+
+struct _GstTest
+{
+  GstBaseSink basesink;
+
+  gpointer tests[TESTS_COUNT];
+  GValue values[TESTS_COUNT];
+};
+
+struct _GstTestClass
+{
+  GstBaseSinkClass parent_class;
+
+  gchar *param_names[2 * TESTS_COUNT];
+};
+
+static void gst_test_finalize (GstTest * test);
+
+static gboolean gst_test_start (GstBaseSink * trans);
+static gboolean gst_test_stop (GstBaseSink * trans);
+static gboolean gst_test_sink_event (GstBaseSink * basesink, GstEvent * event);
+static GstFlowReturn gst_test_render_buffer (GstBaseSink * basesink,
+    GstBuffer * buf);
+
+static void gst_test_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec);
+static void gst_test_get_property (GObject * object, guint prop_id,
+    GValue * value, GParamSpec * pspec);
+
+static GstStaticPadTemplate sinktemplate = GST_STATIC_PAD_TEMPLATE ("sink",
+    GST_PAD_SINK,
+    GST_PAD_ALWAYS,
+    GST_STATIC_CAPS_ANY);
+
+
+static const GstElementDetails details = GST_ELEMENT_DETAILS ("Test plugin",
+    "Testing",
+    "perform a number of tests",
+    "Benjamin Otte <otte@gnome>");
+
+#define DEBUG_INIT(bla) \
+  GST_DEBUG_CATEGORY_INIT (gst_test_debug, "testsink", 0, \
+      "debugging category for testsink element");
+
+GST_BOILERPLATE_FULL (GstTest, gst_test, GstBaseSink, GST_TYPE_BASE_SINK,
+    DEBUG_INIT);
+
+
+static void
+gst_test_base_init (gpointer g_class)
+{
+  GstElementClass *gstelement_class = GST_ELEMENT_CLASS (g_class);
+
+  gst_element_class_add_pad_template (gstelement_class,
+      gst_static_pad_template_get (&sinktemplate));
+
+  gst_element_class_set_details (gstelement_class, &details);
+}
+
+static void
+gst_test_class_init (GstTestClass * klass)
+{
+  GstBaseSinkClass *basesink_class = GST_BASE_SINK_CLASS (klass);
+  GObjectClass *object_class = G_OBJECT_CLASS (klass);
+  guint i;
+
+  object_class->set_property = GST_DEBUG_FUNCPTR (gst_test_set_property);
+  object_class->get_property = GST_DEBUG_FUNCPTR (gst_test_get_property);
+
+  object_class->finalize = (GObjectFinalizeFunc) gst_test_finalize;
+
+  for (i = 0; i < TESTS_COUNT; i++) {
+    GParamSpec *spec;
+
+    spec = tests[i].get_spec (&tests[i], FALSE);
+    klass->param_names[2 * i] = g_strdup (g_param_spec_get_name (spec));
+    g_object_class_install_property (object_class, 2 * i + 1, spec);
+    spec = tests[i].get_spec (&tests[i], TRUE);
+    klass->param_names[2 * i + 1] = g_strdup (g_param_spec_get_name (spec));
+    g_object_class_install_property (object_class, 2 * i + 2, spec);
+  }
+
+  basesink_class->preroll = GST_DEBUG_FUNCPTR (gst_test_render_buffer);
+  basesink_class->render = GST_DEBUG_FUNCPTR (gst_test_render_buffer);
+  basesink_class->event = GST_DEBUG_FUNCPTR (gst_test_sink_event);
+  basesink_class->start = GST_DEBUG_FUNCPTR (gst_test_start);
+  basesink_class->stop = GST_DEBUG_FUNCPTR (gst_test_stop);
+}
+
+static void
+gst_test_init (GstTest * test, GstTestClass * g_class)
+{
+  GstTestClass *klass;
+  guint i;
+
+  klass = GST_TEST_GET_CLASS (test);
+  for (i = 0; i < TESTS_COUNT; i++) {
+    GParamSpec *spec = g_object_class_find_property (G_OBJECT_CLASS (klass),
+        klass->param_names[2 * i + 1]);
+
+    g_value_init (&test->values[i], G_PARAM_SPEC_VALUE_TYPE (spec));
+  }
+}
+
+static void
+gst_test_finalize (GstTest * test)
+{
+  guint i;
+
+  for (i = 0; i < TESTS_COUNT; i++) {
+    g_value_unset (&test->values[i]);
+  }
+
+  G_OBJECT_CLASS (parent_class)->finalize ((GObject *) test);
+}
+
+static void
+tests_unset (GstTest * test)
+{
+  guint i;
+
+  for (i = 0; i < TESTS_COUNT; i++) {
+    if (test->tests[i]) {
+      tests[i].free (test->tests[i]);
+      test->tests[i] = NULL;
+    }
+  }
+}
+
+static void
+tests_set (GstTest * test)
+{
+  guint i;
+
+  for (i = 0; i < TESTS_COUNT; i++) {
+    g_assert (test->tests[i] == NULL);
+    test->tests[i] = tests[i].new (&tests[i]);
+  }
+}
+
+static gboolean
+gst_test_sink_event (GstBaseSink * basesink, GstEvent * event)
+{
+  GstTestClass *klass = GST_TEST_GET_CLASS (basesink);
+  GstTest *test = GST_TEST (basesink);
+  gboolean ret = FALSE;
+
+  switch (GST_EVENT_TYPE (event)) {
+/*
+    case GST_EVENT_NEWSEGMENT:
+      if (GST_EVENT_DISCONT_NEW_MEDIA (event)) {
+        tests_unset (test);
+        tests_set (test);
+      }
+      break;
+*/
+    case GST_EVENT_EOS:{
+      gint i;
+
+      g_object_freeze_notify (G_OBJECT (test));
+      for (i = 0; i < TESTS_COUNT; i++) {
+        if (test->tests[i]) {
+          if (!tests[i].finish (test->tests[i], &test->values[i])) {
+            GValue v = { 0, };
+            gchar *real, *expected;
+
+            expected = gst_value_serialize (&test->values[i]);
+            g_value_init (&v, G_VALUE_TYPE (&test->values[i]));
+            g_object_get_property (G_OBJECT (test), klass->param_names[2 * i],
+                &v);
+            real = gst_value_serialize (&v);
+            g_value_unset (&v);
+            GST_ELEMENT_ERROR (test, STREAM, FORMAT, (NULL),
+                ("test %s returned value \"%s\" and not expected value \"%s\"",
+                    klass->param_names[2 * i], real, expected));
+            g_free (real);
+            g_free (expected);
+          }
+          g_object_notify (G_OBJECT (test), klass->param_names[2 * i]);
+        }
+      }
+      g_object_thaw_notify (G_OBJECT (test));
+      ret = TRUE;
+      break;
+    }
+    default:
+      break;
+  }
+
+  return ret;
+}
+
+static GstFlowReturn
+gst_test_render_buffer (GstBaseSink * basesink, GstBuffer * buf)
+{
+  GstTest *test = GST_TEST (basesink);
+  guint i;
+
+  for (i = 0; i < TESTS_COUNT; i++) {
+    if (test->tests[i]) {
+      tests[i].add (test->tests[i], buf);
+    }
+  }
+  return GST_FLOW_OK;
+}
+
+static gboolean
+gst_test_start (GstBaseSink * sink)
+{
+  GstTest *test = GST_TEST (sink);
+
+  tests_set (test);
+  return TRUE;
+}
+
+static gboolean
+gst_test_stop (GstBaseSink * sink)
+{
+  GstTest *test = GST_TEST (sink);
+
+  tests_unset (test);
+  return TRUE;
+}
+
+static void
+gst_test_set_property (GObject * object, guint prop_id,
+    const GValue * value, GParamSpec * pspec)
+{
+  GstTest *test = GST_TEST (object);
+
+  if (prop_id == 0 || prop_id > 2 * TESTS_COUNT) {
+    G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+    return;
+  }
+
+  if (prop_id % 2) {
+    /* real values can't be set */
+    G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+  } else {
+    /* expected values */
+    GST_OBJECT_LOCK (test);
+    g_value_copy (value, &test->values[prop_id / 2 - 1]);
+    GST_OBJECT_UNLOCK (test);
+  }
+}
+
+static void
+gst_test_get_property (GObject * object, guint prop_id, GValue * value,
+    GParamSpec * pspec)
+{
+  GstTest *test = GST_TEST (object);
+  guint id = (prop_id - 1) / 2;
+
+  if (prop_id == 0 || prop_id > 2 * TESTS_COUNT) {
+    G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+    return;
+  }
+
+  GST_OBJECT_LOCK (test);
+
+  if (prop_id % 2) {
+    /* real values */
+    tests[id].get_value (test->tests[id], value);
+  } else {
+    /* expected values */
+    g_value_copy (&test->values[id], value);
+  }
+
+  GST_OBJECT_UNLOCK (test);
+}
diff --git a/gst/debugutils/tests.c b/gst/debugutils/tests.c
new file mode 100644
index 00000000..cd382782
--- /dev/null
+++ b/gst/debugutils/tests.c
@@ -0,0 +1,568 @@
+/* GStreamer
+ * Copyright (C) 2004 Benjamin Otte <otte@gnome.org>
+ *
+ * includes code based on glibc 2.2.3's crypt/md5.c,
+ * Copyright (C) 1995, 1996, 1997, 1999, 2000 Free Software Foundation, Inc. 
+ *
+ * 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.
+ */
+
+#ifdef HAVE_CONFIG_H
+#include "config.h"
+#endif
+
+#include "tests.h"
+#include <stdlib.h>
+#include <string.h>
+
+
+/*
+ *** LENGTH ***
+ */
+
+typedef struct
+{
+  gint64 value;
+}
+LengthTest;
+
+static GParamSpec *
+length_get_spec (const GstTestInfo * info, gboolean compare_value)
+{
+  if (compare_value) {
+    return g_param_spec_int64 ("expected-length", "expected length",
+        "expected length of stream", -1, G_MAXINT64, -1,
+        G_PARAM_READWRITE | G_PARAM_CONSTRUCT);
+  } else {
+    return g_param_spec_int64 ("length", "length", "length of stream",
+        -1, G_MAXINT64, -1, G_PARAM_READABLE);
+  }
+}
+
+static gpointer
+length_new (const GstTestInfo * info)
+{
+  return g_new0 (LengthTest, 1);
+}
+
+static void
+length_add (gpointer test, GstBuffer * buffer)
+{
+  LengthTest *t = test;
+
+  t->value += GST_BUFFER_SIZE (buffer);
+}
+
+static gboolean
+length_finish (gpointer test, GValue * value)
+{
+  LengthTest *t = test;
+
+  if (g_value_get_int64 (value) == -1)
+    return TRUE;
+
+  return t->value == g_value_get_int64 (value);
+}
+
+static void
+length_get_value (gpointer test, GValue * value)
+{
+  LengthTest *t = test;
+
+  g_value_set_int64 (value, t ? t->value : -1);
+}
+
+/*
+ *** BUFFER COUNT ***
+ */
+
+static GParamSpec *
+buffer_count_get_spec (const GstTestInfo * info, gboolean compare_value)
+{
+  if (compare_value) {
+    return g_param_spec_int64 ("expected-buffer-count", "expected buffer count",
+        "expected number of buffers in stream",
+        -1, G_MAXINT64, -1, G_PARAM_READWRITE | G_PARAM_CONSTRUCT);
+  } else {
+    return g_param_spec_int64 ("buffer-count", "buffer count",
+        "number of buffers in stream", -1, G_MAXINT64, -1, G_PARAM_READABLE);
+  }
+}
+
+static void
+buffer_count_add (gpointer test, GstBuffer * buffer)
+{
+  LengthTest *t = test;
+
+  t->value++;
+}
+
+/*
+ *** TIMESTAMP / DURATION MATCHING ***
+ */
+
+typedef struct
+{
+  guint64 diff;
+  guint count;
+  GstClockTime expected;
+}
+TimeDurTest;
+
+static GParamSpec *
+timedur_get_spec (const GstTestInfo * info, gboolean compare_value)
+{
+  if (compare_value) {
+    return g_param_spec_int64 ("allowed-timestamp-deviation",
+        "allowed timestamp deviation",
+        "allowed average difference in usec between timestamp of next buffer "
+        "and expected timestamp from analyzing last buffer",
+        -1, G_MAXINT64, -1, G_PARAM_READWRITE | G_PARAM_CONSTRUCT);
+  } else {
+    return g_param_spec_int64 ("timestamp-deviation",
+        "timestamp deviation",
+        "average difference in usec between timestamp of next buffer "
+        "and expected timestamp from analyzing last buffer",
+        -1, G_MAXINT64, -1, G_PARAM_READABLE);
+  }
+}
+
+static gpointer
+timedur_new (const GstTestInfo * info)
+{
+  TimeDurTest *ret = g_new0 (TimeDurTest, 1);
+
+  ret->expected = GST_CLOCK_TIME_NONE;
+
+  return ret;
+}
+
+static void
+timedur_add (gpointer test, GstBuffer * buffer)
+{
+  TimeDurTest *t = test;
+
+  if (GST_BUFFER_TIMESTAMP_IS_VALID (buffer) &&
+      GST_CLOCK_TIME_IS_VALID (t->expected)) {
+    t->diff += labs (GST_BUFFER_TIMESTAMP (buffer) - t->expected);
+    t->count++;
+  }
+  if (GST_BUFFER_TIMESTAMP_IS_VALID (buffer) &&
+      GST_BUFFER_DURATION_IS_VALID (buffer)) {
+    t->expected = GST_BUFFER_TIMESTAMP (buffer) + GST_BUFFER_DURATION (buffer);
+  } else {
+    t->expected = GST_CLOCK_TIME_NONE;
+  }
+}
+
+static gboolean
+timedur_finish (gpointer test, GValue * value)
+{
+  TimeDurTest *t = test;
+
+  if (g_value_get_int64 (value) == -1)
+    return TRUE;
+
+  return (t->diff / MAX (1, t->count)) <= g_value_get_int64 (value);
+}
+
+static void
+timedur_get_value (gpointer test, GValue * value)
+{
+  TimeDurTest *t = test;
+
+  g_value_set_int64 (value, t ? (t->diff / MAX (1, t->count)) : -1);
+}
+
+/*
+ *** MD5 ***
+ */
+
+typedef struct
+{
+  /* md5 information */
+  guint32 A;
+  guint32 B;
+  guint32 C;
+  guint32 D;
+
+  guint32 total[2];
+  guint32 buflen;
+  gchar buffer[128];
+
+  gchar result[33];
+}
+MD5Test;
+
+static void md5_process_block (const void *buffer, size_t len, MD5Test * ctx);
+static void md5_read_ctx (MD5Test * ctx, gchar * result);
+
+static GParamSpec *
+md5_get_spec (const GstTestInfo * info, gboolean compare_value)
+{
+  if (compare_value) {
+    return g_param_spec_string ("expected-md5", "expected md5",
+        "expected md5 of processing the whole data",
+        "---", G_PARAM_READWRITE | G_PARAM_CONSTRUCT);
+  } else {
+    return g_param_spec_string ("md5", "md5",
+        "md5 of processing the whole data", "---", G_PARAM_READABLE);
+  }
+}
+
+/* This array contains the bytes used to pad the buffer to the next
+   64-byte boundary.  (RFC 1321, 3.1: Step 1)  */
+static const guchar fillbuf[64] = { 0x80, 0 /* , 0, 0, ...  */  };
+
+/* MD5 functions */
+/* Initialize structure containing state of computation.
+   (RFC 1321, 3.3: Step 3)  */
+static gpointer
+md5_new (const GstTestInfo * info)
+{
+  MD5Test *ctx = g_new (MD5Test, 1);
+
+  ctx->A = 0x67452301;
+  ctx->B = 0xefcdab89;
+  ctx->C = 0x98badcfe;
+  ctx->D = 0x10325476;
+
+  ctx->total[0] = ctx->total[1] = 0;
+  ctx->buflen = 0;
+
+  memset (ctx->result, 0, 33);
+
+  return ctx;
+}
+
+/* Process the remaining bytes in the internal buffer and the usual
+   prolog according to the standard and write the result to RESBUF.
+
+   IMPORTANT: On some systems it is required that RESBUF is correctly
+   aligned for a 32 bits value.  */
+static gboolean
+md5_finish (gpointer test, GValue * value)
+{
+  MD5Test *ctx = test;
+  const gchar *str_val = g_value_get_string (value);
+
+  /* Take yet unprocessed bytes into account.  */
+  guint32 bytes = ctx->buflen;
+  size_t pad;
+
+  /* Now count remaining bytes.  */
+  ctx->total[0] += bytes;
+  if (ctx->total[0] < bytes)
+    ++ctx->total[1];
+
+  pad = bytes >= 56 ? 64 + 56 - bytes : 56 - bytes;
+  memcpy (&ctx->buffer[bytes], fillbuf, pad);
+
+  /* Put the 64-bit file length in *bits* at the end of the buffer.  */
+  *(guint32 *) & ctx->buffer[bytes + pad] = GUINT32_TO_LE (ctx->total[0] << 3);
+  *(guint32 *) & ctx->buffer[bytes + pad + 4] =
+      GUINT32_TO_LE ((ctx->total[1] << 3) | (ctx->total[0] >> 29));
+
+  /* Process last bytes.  */
+  md5_process_block (ctx->buffer, bytes + pad + 8, ctx);
+
+  md5_read_ctx (ctx, ctx->result);
+  if (g_str_equal (str_val, "---"))
+    return TRUE;
+  if (g_str_equal (str_val, ctx->result))
+    return TRUE;
+  return FALSE;
+}
+
+/* Put result from CTX in first 16 bytes following RESBUF.  The result
+   must be in little endian byte order.
+
+   IMPORTANT: On some systems it is required that RESBUF is correctly
+   aligned for a 32 bits value.  */
+static void
+md5_read_ctx (MD5Test * ctx, gchar * result)
+{
+  guint32 resbuf[4];
+  guint i;
+
+  resbuf[0] = GUINT32_TO_LE (ctx->A);
+  resbuf[1] = GUINT32_TO_LE (ctx->B);
+  resbuf[2] = GUINT32_TO_LE (ctx->C);
+  resbuf[3] = GUINT32_TO_LE (ctx->D);
+
+  for (i = 0; i < 16; i++)
+    sprintf (result + i * 2, "%02x", ((guchar *) resbuf)[i]);
+}
+
+static void
+md5_add (gpointer test, GstBuffer * gstbuffer)
+{
+  const void *buffer = GST_BUFFER_DATA (gstbuffer);
+  gsize len = GST_BUFFER_SIZE (gstbuffer);
+  MD5Test *ctx = test;
+
+  /*const void aligned_buffer = buffer; */
+
+  /* When we already have some bits in our internal buffer concatenate
+     both inputs first.  */
+  if (ctx->buflen != 0) {
+    gsize left_over = ctx->buflen;
+    gsize add = 128 - left_over > len ? len : 128 - left_over;
+
+    /* Only put full words in the buffer.  */
+    /* Forcing alignment here appears to be only an optimization.
+     * The glibc source uses __alignof__, which seems to be a
+     * gratuitous usage of a GCC extension, when sizeof() will
+     * work fine.  (And don't question the sanity of using
+     * sizeof(guint32) instead of 4. */
+    /* add -= add % __alignof__ (guint32); */
+    add -= add % sizeof (guint32);
+
+    memcpy (&ctx->buffer[left_over], buffer, add);
+    ctx->buflen += add;
+
+    if (ctx->buflen > 64) {
+      md5_process_block (ctx->buffer, ctx->buflen & ~63, ctx);
+
+      ctx->buflen &= 63;
+      /* The regions in the following copy operation cannot overlap.  */
+      memcpy (ctx->buffer, &ctx->buffer[(left_over + add) & ~63], ctx->buflen);
+    }
+
+    buffer = (const char *) buffer + add;
+    len -= add;
+  }
+
+  /* Process available complete blocks.  */
+  if (len > 64) {
+    md5_process_block (buffer, len & ~63, ctx);
+    buffer = (const char *) buffer + (len & ~63);
+    len &= 63;
+  }
+
+  /* Move remaining bytes in internal buffer.  */
+  if (len > 0) {
+    size_t left_over = ctx->buflen;
+
+    memcpy (&ctx->buffer[left_over], buffer, len);
+    left_over += len;
+    if (left_over >= 64) {
+      md5_process_block (ctx->buffer, 64, ctx);
+      left_over -= 64;
+      memcpy (ctx->buffer, &ctx->buffer[64], left_over);
+    }
+    ctx->buflen = left_over;
+  }
+}
+
+
+/* These are the four functions used in the four steps of the MD5 algorithm
+   and defined in the RFC 1321.  The first function is a little bit optimized
+   (as found in Colin Plumbs public domain implementation).  */
+/* #define FF(b, c, d) ((b & c) | (~b & d)) */
+#define FF(b, c, d) (d ^ (b & (c ^ d)))
+#define FG(b, c, d) FF (d, b, c)
+#define FH(b, c, d) (b ^ c ^ d)
+#define FI(b, c, d) (c ^ (b | ~d))
+
+static void
+md5_process_block (const void *buffer, size_t len, MD5Test * ctx)
+{
+/* Process LEN bytes of BUFFER, accumulating context into CTX.
+   It is assumed that LEN % 64 == 0.  */
+  guint32 correct_words[16];
+  const guint32 *words = buffer;
+  size_t nwords = len / sizeof (guint32);
+  const guint32 *endp = words + nwords;
+  guint32 A = ctx->A;
+  guint32 B = ctx->B;
+  guint32 C = ctx->C;
+  guint32 D = ctx->D;
+
+  /* First increment the byte count.  RFC 1321 specifies the possible
+     length of the file up to 2^64 bits.  Here we only compute the
+     number of bytes.  Do a double word increment.  */
+  ctx->total[0] += len;
+  if (ctx->total[0] < len)
+    ++ctx->total[1];
+
+  /* Process all bytes in the buffer with 64 bytes in each round of
+     the loop.  */
+  while (words < endp) {
+    guint32 *cwp = correct_words;
+    guint32 A_save = A;
+    guint32 B_save = B;
+    guint32 C_save = C;
+    guint32 D_save = D;
+
+    /* First round: using the given function, the context and a constant
+       the next context is computed.  Because the algorithms processing
+       unit is a 32-bit word and it is determined to work on words in
+       little endian byte order we perhaps have to change the byte order
+       before the computation.  To reduce the work for the next steps
+       we store the swapped words in the array CORRECT_WORDS.  */
+
+#define OP(a, b, c, d, s, T)                                            \
+      do                                                                \
+        {                                                               \
+          a += FF (b, c, d) + (*cwp++ = GUINT32_TO_LE (*words)) + T;            \
+          ++words;                                                      \
+          CYCLIC (a, s);                                                \
+          a += b;                                                       \
+        }                                                               \
+      while (0)
+
+    /* It is unfortunate that C does not provide an operator for
+       cyclic rotation.  Hope the C compiler is smart enough.  */
+#define CYCLIC(w, s) (w = (w << s) | (w >> (32 - s)))
+
+    /* Before we start, one word to the strange constants.
+       They are defined in RFC 1321 as
+
+       T[i] = (int) (4294967296.0 * fabs (sin (i))), i=1..64
+     */
+
+    /* Round 1.  */
+    OP (A, B, C, D, 7, 0xd76aa478);
+    OP (D, A, B, C, 12, 0xe8c7b756);
+    OP (C, D, A, B, 17, 0x242070db);
+    OP (B, C, D, A, 22, 0xc1bdceee);
+    OP (A, B, C, D, 7, 0xf57c0faf);
+    OP (D, A, B, C, 12, 0x4787c62a);
+    OP (C, D, A, B, 17, 0xa8304613);
+    OP (B, C, D, A, 22, 0xfd469501);
+    OP (A, B, C, D, 7, 0x698098d8);
+    OP (D, A, B, C, 12, 0x8b44f7af);
+    OP (C, D, A, B, 17, 0xffff5bb1);
+    OP (B, C, D, A, 22, 0x895cd7be);
+    OP (A, B, C, D, 7, 0x6b901122);
+    OP (D, A, B, C, 12, 0xfd987193);
+    OP (C, D, A, B, 17, 0xa679438e);
+    OP (B, C, D, A, 22, 0x49b40821);
+
+    /* For the second to fourth round we have the possibly swapped words
+       in CORRECT_WORDS.  Redefine the macro to take an additional first
+       argument specifying the function to use.  */
+#undef OP
+#define OP(f, a, b, c, d, k, s, T)                                      \
+      do                                                                \
+        {                                                               \
+          a += f (b, c, d) + correct_words[k] + T;                      \
+          CYCLIC (a, s);                                                \
+          a += b;                                                       \
+        }                                                               \
+      while (0)
+
+    /* Round 2.  */
+    OP (FG, A, B, C, D, 1, 5, 0xf61e2562);
+    OP (FG, D, A, B, C, 6, 9, 0xc040b340);
+    OP (FG, C, D, A, B, 11, 14, 0x265e5a51);
+    OP (FG, B, C, D, A, 0, 20, 0xe9b6c7aa);
+    OP (FG, A, B, C, D, 5, 5, 0xd62f105d);
+    OP (FG, D, A, B, C, 10, 9, 0x02441453);
+    OP (FG, C, D, A, B, 15, 14, 0xd8a1e681);
+    OP (FG, B, C, D, A, 4, 20, 0xe7d3fbc8);
+    OP (FG, A, B, C, D, 9, 5, 0x21e1cde6);
+    OP (FG, D, A, B, C, 14, 9, 0xc33707d6);
+    OP (FG, C, D, A, B, 3, 14, 0xf4d50d87);
+    OP (FG, B, C, D, A, 8, 20, 0x455a14ed);
+    OP (FG, A, B, C, D, 13, 5, 0xa9e3e905);
+    OP (FG, D, A, B, C, 2, 9, 0xfcefa3f8);
+    OP (FG, C, D, A, B, 7, 14, 0x676f02d9);
+    OP (FG, B, C, D, A, 12, 20, 0x8d2a4c8a);
+
+    /* Round 3.  */
+    OP (FH, A, B, C, D, 5, 4, 0xfffa3942);
+    OP (FH, D, A, B, C, 8, 11, 0x8771f681);
+    OP (FH, C, D, A, B, 11, 16, 0x6d9d6122);
+    OP (FH, B, C, D, A, 14, 23, 0xfde5380c);
+    OP (FH, A, B, C, D, 1, 4, 0xa4beea44);
+    OP (FH, D, A, B, C, 4, 11, 0x4bdecfa9);
+    OP (FH, C, D, A, B, 7, 16, 0xf6bb4b60);
+    OP (FH, B, C, D, A, 10, 23, 0xbebfbc70);
+    OP (FH, A, B, C, D, 13, 4, 0x289b7ec6);
+    OP (FH, D, A, B, C, 0, 11, 0xeaa127fa);
+    OP (FH, C, D, A, B, 3, 16, 0xd4ef3085);
+    OP (FH, B, C, D, A, 6, 23, 0x04881d05);
+    OP (FH, A, B, C, D, 9, 4, 0xd9d4d039);
+    OP (FH, D, A, B, C, 12, 11, 0xe6db99e5);
+    OP (FH, C, D, A, B, 15, 16, 0x1fa27cf8);
+    OP (FH, B, C, D, A, 2, 23, 0xc4ac5665);
+
+    /* Round 4.  */
+    OP (FI, A, B, C, D, 0, 6, 0xf4292244);
+    OP (FI, D, A, B, C, 7, 10, 0x432aff97);
+    OP (FI, C, D, A, B, 14, 15, 0xab9423a7);
+    OP (FI, B, C, D, A, 5, 21, 0xfc93a039);
+    OP (FI, A, B, C, D, 12, 6, 0x655b59c3);
+    OP (FI, D, A, B, C, 3, 10, 0x8f0ccc92);
+    OP (FI, C, D, A, B, 10, 15, 0xffeff47d);
+    OP (FI, B, C, D, A, 1, 21, 0x85845dd1);
+    OP (FI, A, B, C, D, 8, 6, 0x6fa87e4f);
+    OP (FI, D, A, B, C, 15, 10, 0xfe2ce6e0);
+    OP (FI, C, D, A, B, 6, 15, 0xa3014314);
+    OP (FI, B, C, D, A, 13, 21, 0x4e0811a1);
+    OP (FI, A, B, C, D, 4, 6, 0xf7537e82);
+    OP (FI, D, A, B, C, 11, 10, 0xbd3af235);
+    OP (FI, C, D, A, B, 2, 15, 0x2ad7d2bb);
+    OP (FI, B, C, D, A, 9, 21, 0xeb86d391);
+
+    /* Add the starting values of the context.  */
+    A += A_save;
+    B += B_save;
+    C += C_save;
+    D += D_save;
+  }
+
+  /* Put checksum in context given as argument.  */
+  ctx->A = A;
+  ctx->B = B;
+  ctx->C = C;
+  ctx->D = D;
+}
+
+static void
+md5_get_value (gpointer test, GValue * value)
+{
+  MD5Test *ctx = test;
+
+  if (!ctx) {
+    g_value_set_string (value, "---");
+  } else if (ctx->result[0] == 0) {
+    gchar *str = g_new (gchar, 33);
+
+    str[32] = 0;
+    md5_read_ctx (ctx, str);
+    g_value_take_string (value, str);
+  } else {
+    g_value_set_string (value, ctx->result);
+  }
+}
+
+/*
+ *** TESTINFO ***
+ */
+
+const GstTestInfo tests[] = {
+  {length_get_spec, length_new, length_add,
+      length_finish, length_get_value, g_free},
+  {buffer_count_get_spec, length_new, buffer_count_add,
+      length_finish, length_get_value, g_free},
+  {timedur_get_spec, timedur_new, timedur_add,
+      timedur_finish, timedur_get_value, g_free},
+  {md5_get_spec, md5_new, md5_add,
+      md5_finish, md5_get_value, g_free}
+};
diff --git a/gst/debugutils/tests.h b/gst/debugutils/tests.h
new file mode 100644
index 00000000..9926af62
--- /dev/null
+++ b/gst/debugutils/tests.h
@@ -0,0 +1,43 @@
+/* GStreamer
+ * Copyright (C) 2004 Benjamin Otte <otte@gnome.org>
+ *
+ * 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>
+
+#ifndef __GST_TESTS_H__
+#define __GST_TESTS_H__
+
+
+typedef struct _GstTestInfo GstTestInfo;
+
+struct _GstTestInfo
+{
+  GParamSpec *(*get_spec) (const GstTestInfo * info, gboolean compare_value);
+    gpointer (*new) (const GstTestInfo * info);
+  void (*add) (gpointer test, GstBuffer * buffer);
+    gboolean (*finish) (gpointer test, GValue * value);
+  void (*get_value) (gpointer test, GValue * value);
+  void (*free) (gpointer test);
+};
+
+extern const GstTestInfo tests[];
+/* keep up to date! */
+#define TESTS_COUNT (4)
+
+
+#endif /* __GST_TESTS_H__ */