playbin2: Add unit test for compressed stream support in playbin2/playsink
authorSebastian Dröge <sebastian.droege@collabora.co.uk>
Tue, 15 Mar 2011 10:41:14 +0000 (11:41 +0100)
committerSebastian Dröge <sebastian.droege@collabora.co.uk>
Sat, 14 May 2011 09:42:32 +0000 (11:42 +0200)
tests/check/Makefile.am
tests/check/elements/playbin2-compressed.c [new file with mode: 0644]

index 8b8782d..b6fa73e 100644 (file)
@@ -129,6 +129,7 @@ check_PROGRAMS = \
        elements/multifdsink \
        elements/playbin \
        elements/playbin2 \
+       elements/playbin2-compressed \
        $(check_subparse) \
        elements/videorate \
        elements/videoscale \
@@ -376,6 +377,9 @@ elements_playbin_CFLAGS = $(GST_BASE_CFLAGS) $(AM_CFLAGS)
 elements_playbin2_LDADD = $(GST_BASE_LIBS) $(LDADD)
 elements_playbin2_CFLAGS = $(GST_BASE_CFLAGS) $(AM_CFLAGS)
 
+elements_playbin2_compressed_LDADD = $(top_builddir)/gst-libs/gst/interfaces/libgstinterfaces-@GST_MAJORMINOR@.la $(GST_BASE_LIBS) $(LDADD)
+elements_playbin2_compressed_CFLAGS = $(GST_PLUGINS_BASE_CFLAGS) $(GST_BASE_CFLAGS) $(AM_CFLAGS)
+
 elements_decodebin_LDADD = $(GST_BASE_LIBS) $(LDADD)
 elements_decodebin_CFLAGS = $(GST_BASE_CFLAGS) $(AM_CFLAGS)
 
diff --git a/tests/check/elements/playbin2-compressed.c b/tests/check/elements/playbin2-compressed.c
new file mode 100644 (file)
index 0000000..205442c
--- /dev/null
@@ -0,0 +1,2515 @@
+/* GStreamer unit tests for playbin2 compressed stream support
+ *
+ * Copyright (C) 2006 Tim-Philipp Müller <tim centricular net>
+ * Copyright (C) 2010 Sebastian Dröge <sebastian.droege@collabora.co.uk>
+ *
+ * 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/check/gstcheck.h>
+#include <gst/base/gstpushsrc.h>
+#include <gst/base/gstbasesink.h>
+#include <gst/interfaces/streamvolume.h>
+
+#ifndef GST_DISABLE_REGISTRY
+
+#define NBUFFERS 100
+
+static GType gst_caps_src_get_type (void);
+static GType gst_codec_demuxer_get_type (void);
+static GType gst_codec_sink_get_type (void);
+static GType gst_audio_codec_sink_get_type (void);
+static GType gst_video_codec_sink_get_type (void);
+
+#undef parent_class
+#define parent_class caps_src_parent_class
+typedef struct _GstCapsSrc GstCapsSrc;
+typedef GstPushSrcClass GstCapsSrcClass;
+
+struct _GstCapsSrc
+{
+  GstPushSrc parent;
+
+  GstCaps *caps;
+  gchar *uri;
+  gint nbuffers;
+};
+
+static GstURIType
+gst_caps_src_uri_get_type (void)
+{
+  return GST_URI_SRC;
+}
+
+static gchar **
+gst_caps_src_uri_get_protocols (void)
+{
+  static gchar *protocols[] = { (char *) "caps", NULL };
+
+  return protocols;
+}
+
+static const gchar *
+gst_caps_src_uri_get_uri (GstURIHandler * handler)
+{
+  GstCapsSrc *src = (GstCapsSrc *) handler;
+
+  return src->uri;
+}
+
+static gboolean
+gst_caps_src_uri_set_uri (GstURIHandler * handler, const gchar * uri)
+{
+  GstCapsSrc *src = (GstCapsSrc *) handler;
+
+  if (uri == NULL || !g_str_has_prefix (uri, "caps:"))
+    return FALSE;
+
+  g_free (src->uri);
+  src->uri = g_strdup (uri);
+
+  if (src->caps)
+    gst_caps_unref (src->caps);
+  src->caps = NULL;
+
+  return TRUE;
+}
+
+static void
+gst_caps_src_uri_handler_init (gpointer g_iface, gpointer iface_data)
+{
+  GstURIHandlerInterface *iface = (GstURIHandlerInterface *) g_iface;
+
+  iface->get_type = gst_caps_src_uri_get_type;
+  iface->get_protocols = gst_caps_src_uri_get_protocols;
+  iface->get_uri = gst_caps_src_uri_get_uri;
+  iface->set_uri = gst_caps_src_uri_set_uri;
+}
+
+static void
+gst_caps_src_init_type (GType type)
+{
+  static const GInterfaceInfo uri_hdlr_info = {
+    gst_caps_src_uri_handler_init, NULL, NULL
+  };
+
+  g_type_add_interface_static (type, GST_TYPE_URI_HANDLER, &uri_hdlr_info);
+}
+
+GST_BOILERPLATE_FULL (GstCapsSrc, gst_caps_src, GstPushSrc,
+    GST_TYPE_PUSH_SRC, gst_caps_src_init_type);
+
+static void
+gst_caps_src_base_init (gpointer klass)
+{
+  static GstStaticPadTemplate src_templ = GST_STATIC_PAD_TEMPLATE ("src",
+      GST_PAD_SRC, GST_PAD_ALWAYS,
+      GST_STATIC_CAPS_ANY);
+  GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
+
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&src_templ));
+  gst_element_class_set_details_simple (element_class,
+      "CapsSource", "Source/Generic", "yep", "me");
+}
+
+static void
+gst_caps_src_finalize (GObject * object)
+{
+  GstCapsSrc *src = (GstCapsSrc *) object;
+
+  if (src->caps)
+    gst_caps_unref (src->caps);
+  src->caps = NULL;
+  g_free (src->uri);
+
+  G_OBJECT_CLASS (parent_class)->finalize (object);
+}
+
+static GstFlowReturn
+gst_caps_src_create (GstPushSrc * psrc, GstBuffer ** p_buf)
+{
+  GstCapsSrc *src = (GstCapsSrc *) psrc;
+  GstBuffer *buf;
+
+  if (src->nbuffers >= NBUFFERS) {
+    return GST_FLOW_UNEXPECTED;
+  }
+
+  if (!src->caps) {
+    if (!src->uri) {
+      return GST_FLOW_ERROR;
+    }
+
+    src->caps = gst_caps_from_string (src->uri + sizeof ("caps"));
+    if (!src->caps) {
+      return GST_FLOW_ERROR;
+    }
+  }
+
+  buf = gst_buffer_new ();
+  gst_buffer_set_caps (buf, src->caps);
+  GST_BUFFER_TIMESTAMP (buf) =
+      gst_util_uint64_scale (src->nbuffers, GST_SECOND, 25);
+  src->nbuffers++;
+
+  *p_buf = buf;
+  return GST_FLOW_OK;
+}
+
+static void
+gst_caps_src_class_init (GstCapsSrcClass * klass)
+{
+  GObjectClass *gobject_class = (GObjectClass *) klass;
+  GstPushSrcClass *pushsrc_class = (GstPushSrcClass *) klass;
+
+  gobject_class->finalize = gst_caps_src_finalize;
+  pushsrc_class->create = gst_caps_src_create;
+}
+
+static void
+gst_caps_src_init (GstCapsSrc * src, GstCapsSrcClass * klass)
+{
+  gst_base_src_set_format (GST_BASE_SRC (src), GST_FORMAT_TIME);
+}
+
+#undef parent_class
+#define parent_class codec_sink_parent_class
+
+typedef struct _GstCodecSink GstCodecSink;
+typedef GstBaseSinkClass GstCodecSinkClass;
+
+struct _GstCodecSink
+{
+  GstBaseSink parent;
+
+  gboolean audio;
+  gboolean raw;
+  gint n_raw, n_compressed;
+};
+
+GST_BOILERPLATE (GstCodecSink, gst_codec_sink, GstBaseSink, GST_TYPE_BASE_SINK);
+
+static void
+gst_codec_sink_base_init (gpointer klass)
+{
+}
+
+static GstFlowReturn
+gst_codec_sink_render (GstBaseSink * bsink, GstBuffer * buffer)
+{
+  GstCodecSink *sink = (GstCodecSink *) bsink;
+
+  if (sink->raw)
+    sink->n_raw++;
+  else
+    sink->n_compressed++;
+
+  return GST_FLOW_OK;
+}
+
+static void
+gst_codec_sink_class_init (GstCodecSinkClass * klass)
+{
+  GstBaseSinkClass *basesink_class = (GstBaseSinkClass *) klass;
+
+  basesink_class->render = gst_codec_sink_render;
+}
+
+static void
+gst_codec_sink_init (GstCodecSink * sink, GstCodecSinkClass * klass)
+{
+}
+
+#undef parent_class
+#define parent_class audio_codec_sink_parent_class
+
+typedef GstCodecSink GstAudioCodecSink;
+typedef GstCodecSinkClass GstAudioCodecSinkClass;
+
+static void
+gst_audio_codec_sink_init_type (GType type)
+{
+  static const GInterfaceInfo svol_iface_info = {
+    NULL, NULL, NULL
+  };
+
+  g_type_add_interface_static (type, GST_TYPE_STREAM_VOLUME, &svol_iface_info);
+}
+
+GST_BOILERPLATE_FULL (GstAudioCodecSink, gst_audio_codec_sink, GstBaseSink,
+    gst_codec_sink_get_type (), gst_audio_codec_sink_init_type);
+
+static void
+gst_audio_codec_sink_base_init (gpointer klass)
+{
+  static GstStaticPadTemplate sink_templ = GST_STATIC_PAD_TEMPLATE ("sink",
+      GST_PAD_SINK, GST_PAD_ALWAYS,
+      GST_STATIC_CAPS ("audio/x-raw-int; audio/x-compressed")
+      );
+  GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
+
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&sink_templ));
+  gst_element_class_set_details_simple (element_class,
+      "AudioCodecSink", "Sink/Audio", "yep", "me");
+}
+
+static void
+gst_audio_codec_sink_set_property (GObject * object,
+    guint prop_id, const GValue * value, GParamSpec * pspec)
+{
+  switch (prop_id) {
+    case 1:
+    case 2:
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
+}
+
+static void
+gst_audio_codec_sink_get_property (GObject * object,
+    guint prop_id, GValue * value, GParamSpec * pspec)
+{
+
+  switch (prop_id) {
+    case 1:
+      g_value_set_double (value, 1.0);
+      break;
+    case 2:
+      g_value_set_boolean (value, FALSE);
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+  }
+}
+
+static gboolean
+gst_audio_codec_sink_set_caps (GstBaseSink * bsink, GstCaps * caps)
+{
+  GstAudioCodecSink *sink = (GstAudioCodecSink *) bsink;
+  GstStructure *s;
+
+  s = gst_caps_get_structure (caps, 0);
+
+  if (gst_structure_has_name (s, "audio/x-raw-int")) {
+    sink->raw = TRUE;
+  } else if (gst_structure_has_name (s, "audio/x-compressed")) {
+    sink->raw = FALSE;
+  } else {
+    fail_unless (gst_structure_has_name (s, "audio/x-raw-int")
+        || gst_structure_has_name (s, "audio/x-compressed"));
+    return FALSE;
+  }
+
+  return TRUE;
+}
+
+static void
+gst_audio_codec_sink_class_init (GstAudioCodecSinkClass * klass)
+{
+  GObjectClass *gobject_class = (GObjectClass *) klass;
+  GstBaseSinkClass *basesink_class = (GstBaseSinkClass *) klass;
+
+  gobject_class->set_property = gst_audio_codec_sink_set_property;
+  gobject_class->get_property = gst_audio_codec_sink_get_property;
+
+  g_object_class_install_property (gobject_class,
+      1,
+      g_param_spec_double ("volume", "Volume",
+          "Linear volume of this stream, 1.0=100%", 0.0, 10.0,
+          1.0, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
+  g_object_class_install_property (gobject_class,
+      2,
+      g_param_spec_boolean ("mute", "Mute",
+          "Mute", FALSE, G_PARAM_READWRITE | G_PARAM_STATIC_STRINGS));
+
+  basesink_class->set_caps = gst_audio_codec_sink_set_caps;
+}
+
+static void
+gst_audio_codec_sink_init (GstAudioCodecSink * sink,
+    GstAudioCodecSinkClass * klass)
+{
+  sink->audio = TRUE;
+}
+
+#undef parent_class
+#define parent_class video_codec_sink_parent_class
+
+typedef GstCodecSink GstVideoCodecSink;
+typedef GstCodecSinkClass GstVideoCodecSinkClass;
+
+GST_BOILERPLATE (GstVideoCodecSink, gst_video_codec_sink, GstBaseSink,
+    gst_codec_sink_get_type ());
+
+static void
+gst_video_codec_sink_base_init (gpointer klass)
+{
+  static GstStaticPadTemplate sink_templ = GST_STATIC_PAD_TEMPLATE ("sink",
+      GST_PAD_SINK, GST_PAD_ALWAYS,
+      GST_STATIC_CAPS ("video/x-raw-yuv; video/x-compressed")
+      );
+  GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
+
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&sink_templ));
+  gst_element_class_set_details_simple (element_class,
+      "VideoCodecSink", "Sink/Video", "yep", "me");
+}
+
+static gboolean
+gst_video_codec_sink_set_caps (GstBaseSink * bsink, GstCaps * caps)
+{
+  GstVideoCodecSink *sink = (GstVideoCodecSink *) bsink;
+  GstStructure *s;
+
+  s = gst_caps_get_structure (caps, 0);
+
+  if (gst_structure_has_name (s, "video/x-raw-yuv")) {
+    sink->raw = TRUE;
+  } else if (gst_structure_has_name (s, "video/x-compressed")) {
+    sink->raw = FALSE;
+  } else {
+    fail_unless (gst_structure_has_name (s, "video/x-raw-yuv")
+        || gst_structure_has_name (s, "video/x-compressed"));
+    return FALSE;
+  }
+
+  return TRUE;
+}
+
+static void
+gst_video_codec_sink_class_init (GstVideoCodecSinkClass * klass)
+{
+  GstBaseSinkClass *basesink_class = (GstBaseSinkClass *) klass;
+
+  basesink_class->set_caps = gst_video_codec_sink_set_caps;
+}
+
+static void
+gst_video_codec_sink_init (GstVideoCodecSink * sink,
+    GstVideoCodecSinkClass * klass)
+{
+  sink->audio = FALSE;
+}
+
+#undef parent_class
+#define parent_class codec_demuxer_parent_class
+typedef struct _GstCodecDemuxer GstCodecDemuxer;
+typedef GstElementClass GstCodecDemuxerClass;
+
+struct _GstCodecDemuxer
+{
+  GstElement parent;
+
+  GstPad *sinkpad;
+  GstPad *srcpad0, *srcpad1;
+
+  GstEvent *newseg_event;
+};
+
+GST_BOILERPLATE (GstCodecDemuxer, gst_codec_demuxer, GstElement,
+    GST_TYPE_ELEMENT);
+
+#define STREAM_TYPES "{ " \
+    "none, " \
+    "raw-audio, " \
+    "compressed-audio, " \
+    "raw-video, " \
+    "compressed-video " \
+    "}"
+
+static void
+gst_codec_demuxer_base_init (gpointer klass)
+{
+  static GstStaticPadTemplate sink_templ = GST_STATIC_PAD_TEMPLATE ("sink",
+      GST_PAD_SINK, GST_PAD_ALWAYS,
+      GST_STATIC_CAPS ("application/x-container,"
+          " stream0 = (string)" STREAM_TYPES " ,"
+          " stream1 = (string)" STREAM_TYPES)
+      );
+  static GstStaticPadTemplate src_templ = GST_STATIC_PAD_TEMPLATE ("src_%d",
+      GST_PAD_SRC, GST_PAD_SOMETIMES,
+      GST_STATIC_CAPS ("audio/x-raw-int; audio/x-compressed; "
+          "video/x-raw-yuv; video/x-compressed")
+      );
+  GstElementClass *element_class = GST_ELEMENT_CLASS (klass);
+
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&sink_templ));
+  gst_element_class_add_pad_template (element_class,
+      gst_static_pad_template_get (&src_templ));
+  gst_element_class_set_details_simple (element_class,
+      "CodecDemuxer", "Codec/Demuxer", "yep", "me");
+}
+
+static void
+gst_codec_demuxer_finalize (GObject * object)
+{
+  GstCodecDemuxer *demux = (GstCodecDemuxer *) object;
+
+  if (demux->newseg_event)
+    gst_event_unref (demux->newseg_event);
+  demux->newseg_event = NULL;
+
+  G_OBJECT_CLASS (parent_class)->finalize (object);
+}
+
+static void
+gst_codec_demuxer_class_init (GstCodecDemuxerClass * klass)
+{
+  GObjectClass *gobject_class = (GObjectClass *) klass;
+
+  gobject_class->finalize = gst_codec_demuxer_finalize;
+}
+
+static GstFlowReturn
+gst_codec_demuxer_chain (GstPad * pad, GstBuffer * buf)
+{
+  GstCodecDemuxer *demux = (GstCodecDemuxer *) GST_PAD_PARENT (pad);
+  GstFlowReturn ret0 = GST_FLOW_OK, ret1 = GST_FLOW_OK;
+
+  if (demux->srcpad0) {
+    GstBuffer *outbuf = gst_buffer_new ();
+
+    GST_BUFFER_TIMESTAMP (outbuf) = GST_BUFFER_TIMESTAMP (buf);
+    gst_buffer_set_caps (outbuf, GST_PAD_CAPS (demux->srcpad0));
+    ret0 = gst_pad_push (demux->srcpad0, outbuf);
+  }
+  if (demux->srcpad1) {
+    GstBuffer *outbuf = gst_buffer_new ();
+
+    GST_BUFFER_TIMESTAMP (outbuf) = GST_BUFFER_TIMESTAMP (buf);
+    gst_buffer_set_caps (outbuf, GST_PAD_CAPS (demux->srcpad1));
+    ret1 = gst_pad_push (demux->srcpad1, outbuf);
+  }
+  gst_buffer_unref (buf);
+
+  if (ret0 == GST_FLOW_NOT_LINKED && ret1 == GST_FLOW_NOT_LINKED)
+    return GST_FLOW_NOT_LINKED;
+  if (ret0 == GST_FLOW_OK && ret1 == GST_FLOW_OK)
+    return GST_FLOW_OK;
+
+  return MIN (ret0, ret1);
+}
+
+static gboolean
+gst_codec_demuxer_event (GstPad * pad, GstEvent * event)
+{
+  GstCodecDemuxer *demux = (GstCodecDemuxer *) gst_pad_get_parent (pad);
+  gboolean ret = TRUE;
+
+  /* The single newsegment event is pushed when the pads are created */
+  if (GST_EVENT_TYPE (event) != GST_EVENT_NEWSEGMENT) {
+    if (demux->srcpad0)
+      ret = ret && gst_pad_push_event (demux->srcpad0, gst_event_ref (event));
+    if (demux->srcpad1)
+      ret = ret && gst_pad_push_event (demux->srcpad1, gst_event_ref (event));
+  } else {
+    gst_event_replace (&demux->newseg_event, event);
+  }
+
+  gst_event_unref (event);
+
+  gst_object_unref (demux);
+  return ret;
+}
+
+static void
+gst_codec_demuxer_setup_pad (GstCodecDemuxer * demux, GstPad ** pad,
+    const gchar * streaminfo)
+{
+  if (g_str_equal (streaminfo, "none")) {
+    if (*pad) {
+      gst_pad_set_active (*pad, FALSE);
+      gst_element_remove_pad (GST_ELEMENT (demux), *pad);
+      *pad = NULL;
+    }
+  } else {
+    GstCaps *caps;
+
+    if (!*pad) {
+      GstPadTemplate *templ;
+
+      templ =
+          gst_element_class_get_pad_template (GST_ELEMENT_GET_CLASS (demux),
+          "src_%d");
+      if (pad == &demux->srcpad0)
+        *pad = gst_pad_new_from_template (templ, "src_0");
+      else
+        *pad = gst_pad_new_from_template (templ, "src_1");
+      gst_pad_set_active (*pad, TRUE);
+      gst_pad_use_fixed_caps (*pad);
+      gst_element_add_pad (GST_ELEMENT (demux), *pad);
+    }
+
+    if (g_str_equal (streaminfo, "raw-video")) {
+      caps = gst_caps_new_simple ("video/x-raw-yuv",
+          "format", GST_TYPE_FOURCC, GST_MAKE_FOURCC ('I', '4', '2', '0'),
+          "width", G_TYPE_INT, 320,
+          "height", G_TYPE_INT, 240,
+          "framerate", GST_TYPE_FRACTION, 25, 1,
+          "pixel-aspect-ratio", GST_TYPE_FRACTION, 1, 1, NULL);
+    } else if (g_str_equal (streaminfo, "compressed-video")) {
+      caps = gst_caps_new_simple ("video/x-compressed", NULL);
+    } else if (g_str_equal (streaminfo, "raw-audio")) {
+      caps = gst_caps_new_simple ("audio/x-raw-int",
+          "rate", G_TYPE_INT, 48000,
+          "channels", G_TYPE_INT, 2,
+          "endianness", G_TYPE_INT, G_LITTLE_ENDIAN,
+          "width", G_TYPE_INT, 16,
+          "depth", G_TYPE_INT, 16, "signed", G_TYPE_BOOLEAN, TRUE, NULL);
+    } else {
+      caps = gst_caps_new_simple ("audio/x-compressed", NULL);
+    }
+    gst_pad_set_caps (*pad, caps);
+    gst_caps_unref (caps);
+
+    if (demux->newseg_event)
+      gst_pad_push_event (*pad, gst_event_ref (demux->newseg_event));
+  }
+}
+
+static gboolean
+gst_codec_demuxer_setcaps (GstPad * pad, GstCaps * caps)
+{
+  GstCodecDemuxer *demux = (GstCodecDemuxer *) gst_pad_get_parent (pad);
+  GstStructure *s;
+  const gchar *streaminfo;
+
+  s = gst_caps_get_structure (caps, 0);
+
+  streaminfo = gst_structure_get_string (s, "stream0");
+  gst_codec_demuxer_setup_pad (demux, &demux->srcpad0, streaminfo);
+
+  streaminfo = gst_structure_get_string (s, "stream1");
+  gst_codec_demuxer_setup_pad (demux, &demux->srcpad1, streaminfo);
+
+  gst_object_unref (demux);
+  return TRUE;
+}
+
+static void
+gst_codec_demuxer_init (GstCodecDemuxer * demux, GstCodecDemuxerClass * klass)
+{
+  GstPadTemplate *templ;
+
+  templ = gst_element_class_get_pad_template (klass, "sink");
+  demux->sinkpad = gst_pad_new_from_template (templ, "sink");
+  gst_pad_set_setcaps_function (demux->sinkpad,
+      GST_DEBUG_FUNCPTR (gst_codec_demuxer_setcaps));
+  gst_pad_set_chain_function (demux->sinkpad,
+      GST_DEBUG_FUNCPTR (gst_codec_demuxer_chain));
+  gst_pad_set_event_function (demux->sinkpad,
+      GST_DEBUG_FUNCPTR (gst_codec_demuxer_event));
+  gst_element_add_pad (GST_ELEMENT (demux), demux->sinkpad);
+}
+
+/****
+ * Start of the tests
+ ***/
+
+static GstElement *
+create_playbin (const gchar * uri, gboolean set_sink)
+{
+  GstElement *playbin, *sink;
+
+  playbin = gst_element_factory_make ("playbin2", "playbin2");
+  fail_unless (playbin != NULL, "Failed to create playbin element");
+
+  if (set_sink) {
+    sink = gst_element_factory_make ("videocodecsink", NULL);
+    fail_unless (sink != NULL, "Failed to create videocodecsink element");
+
+    /* Set sync to FALSE to prevent buffers from being dropped because
+     * they're too late */
+    g_object_set (sink, "sync", FALSE, NULL);
+
+    g_object_set (playbin, "video-sink", sink, NULL);
+
+    sink = gst_element_factory_make ("audiocodecsink", NULL);
+    fail_unless (sink != NULL, "Failed to create audiocodecsink");
+
+    /* Set sync to FALSE to prevent buffers from being dropped because
+     * they're too late */
+    g_object_set (sink, "sync", FALSE, NULL);
+
+    g_object_set (playbin, "audio-sink", sink, NULL);
+  }
+
+  g_object_set (playbin, "uri", uri, NULL);
+
+  return playbin;
+}
+
+GST_START_TEST (test_raw_single_video_stream_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin =
+      create_playbin
+      ("caps:video/x-raw-yuv, "
+      "format=(fourcc)I420, "
+      "width=(int)320, "
+      "height=(int)240, "
+      "framerate=(fraction)0/1, " "pixel-aspect-ratio=(fraction)1/1", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless (csink->raw == TRUE);
+    fail_unless_equals_int (csink->n_raw, NBUFFERS);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless (csink->raw == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST (test_compressed_single_video_stream_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:video/x-compressed", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless (csink->raw == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, NBUFFERS);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless (csink->raw == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST (test_raw_single_video_stream_demuxer_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)raw-video, " "stream1=(string)none", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless (csink->raw == TRUE);
+    fail_unless_equals_int (csink->n_raw, NBUFFERS);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless (csink->raw == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST (test_compressed_single_video_stream_demuxer_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)compressed-video, " "stream1=(string)none", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless (csink->raw == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, NBUFFERS);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless (csink->raw == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST (test_raw_single_audio_stream_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin =
+      create_playbin
+      ("caps:audio/x-raw-int,"
+      " rate=(int)48000, "
+      " channels=(int)2, "
+      " endianness=(int)LITTLE_ENDIAN, "
+      " width=(int)16, " " depth=(int)16, " " signed=(bool)TRUE", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless (csink->raw == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless (csink->raw == TRUE);
+    fail_unless_equals_int (csink->n_raw, NBUFFERS);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST (test_compressed_single_audio_stream_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:audio/x-compressed", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless (csink->raw == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless (csink->raw == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, NBUFFERS);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST (test_raw_single_audio_stream_demuxer_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)raw-audio, " "stream1=(string)none", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless (csink->raw == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless (csink->raw == TRUE);
+    fail_unless_equals_int (csink->n_raw, NBUFFERS);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST (test_compressed_single_audio_stream_demuxer_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)compressed-audio, " "stream1=(string)none", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless (csink->raw == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless (csink->raw == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, NBUFFERS);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST (test_raw_audio_video_stream_demuxer_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)raw-audio, " "stream1=(string)raw-video", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless (csink->raw == TRUE);
+    fail_unless_equals_int (csink->n_raw, NBUFFERS);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless (csink->raw == TRUE);
+    fail_unless_equals_int (csink->n_raw, NBUFFERS);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST (test_compressed_audio_video_stream_demuxer_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)compressed-audio, " "stream1=(string)compressed-video",
+      TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless (csink->raw == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, NBUFFERS);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless (csink->raw == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, NBUFFERS);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST (test_raw_compressed_video_stream_demuxer_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)raw-video, " "stream1=(string)compressed-video", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless_equals_int (csink->n_raw + csink->n_compressed, NBUFFERS);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST (test_raw_compressed_audio_stream_demuxer_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)raw-audio, " "stream1=(string)compressed-audio", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless_equals_int (csink->n_raw + csink->n_compressed, NBUFFERS);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+typedef struct
+{
+  GstElement *playbin;
+  GstElement *sink;
+} SwitchBufferProbeCtx;
+
+static gboolean
+switch_video_buffer_probe (GstPad * pad, GstBuffer * buffer,
+    SwitchBufferProbeCtx * ctx)
+{
+  GstElement *playbin = ctx->playbin;
+  GstVideoCodecSink *sink = (GstVideoCodecSink *) ctx->sink;
+
+  if (sink->n_raw + sink->n_compressed == NBUFFERS / 2) {
+    gint cur_video;
+
+    g_object_get (G_OBJECT (playbin), "current-video", &cur_video, NULL);
+    cur_video = (cur_video == 0) ? 1 : 0;
+    g_object_set (G_OBJECT (playbin), "current-video", cur_video, NULL);
+  }
+
+  return TRUE;
+}
+
+GST_START_TEST (test_raw_compressed_video_stream_demuxer_switch_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+  GstPad *pad;
+  SwitchBufferProbeCtx switch_ctx;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)raw-video, " "stream1=(string)compressed-video", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  pad = gst_element_get_static_pad (sink, "sink");
+  fail_unless (pad != NULL);
+  switch_ctx.playbin = playbin;
+  switch_ctx.sink = sink;
+  gst_pad_add_buffer_probe (pad, G_CALLBACK (switch_video_buffer_probe),
+      &switch_ctx);
+  gst_object_unref (pad);
+  gst_object_unref (sink);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless (csink->n_raw > 0);
+    fail_unless (csink->n_compressed > 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST (test_compressed_raw_video_stream_demuxer_switch_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+  GstPad *pad;
+  SwitchBufferProbeCtx switch_ctx;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)compressed-video, " "stream1=(string)raw-video", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  pad = gst_element_get_static_pad (sink, "sink");
+  fail_unless (pad != NULL);
+  switch_ctx.playbin = playbin;
+  switch_ctx.sink = sink;
+  gst_pad_add_buffer_probe (pad, G_CALLBACK (switch_video_buffer_probe),
+      &switch_ctx);
+  gst_object_unref (pad);
+  gst_object_unref (sink);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless (csink->n_raw > 0);
+    fail_unless (csink->n_compressed > 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST (test_raw_raw_video_stream_demuxer_switch_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+  GstPad *pad;
+  SwitchBufferProbeCtx switch_ctx;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)raw-video, " "stream1=(string)raw-video", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  pad = gst_element_get_static_pad (sink, "sink");
+  fail_unless (pad != NULL);
+  switch_ctx.playbin = playbin;
+  switch_ctx.sink = sink;
+  gst_pad_add_buffer_probe (pad, G_CALLBACK (switch_video_buffer_probe),
+      &switch_ctx);
+  gst_object_unref (pad);
+  gst_object_unref (sink);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless (csink->n_raw > 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST
+    (test_compressed_compressed_video_stream_demuxer_switch_manual_sink) {
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+  GstPad *pad;
+  SwitchBufferProbeCtx switch_ctx;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)compressed-video, " "stream1=(string)compressed-video",
+      TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  pad = gst_element_get_static_pad (sink, "sink");
+  fail_unless (pad != NULL);
+  switch_ctx.playbin = playbin;
+  switch_ctx.sink = sink;
+  gst_pad_add_buffer_probe (pad, G_CALLBACK (switch_video_buffer_probe),
+      &switch_ctx);
+  gst_object_unref (pad);
+  gst_object_unref (sink);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless (csink->n_compressed > 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+static gboolean
+switch_audio_buffer_probe (GstPad * pad, GstBuffer * buffer,
+    SwitchBufferProbeCtx * ctx)
+{
+  GstElement *playbin = ctx->playbin;
+  GstAudioCodecSink *sink = (GstAudioCodecSink *) ctx->sink;
+
+  if (sink->n_raw + sink->n_compressed == NBUFFERS / 3) {
+    gint cur_audio;
+
+    g_object_get (G_OBJECT (playbin), "current-audio", &cur_audio, NULL);
+    cur_audio = (cur_audio == 0) ? 1 : 0;
+    g_object_set (G_OBJECT (playbin), "current-audio", cur_audio, NULL);
+  }
+
+  return TRUE;
+}
+
+GST_START_TEST (test_raw_compressed_audio_stream_demuxer_switch_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+  GstPad *pad;
+  SwitchBufferProbeCtx switch_ctx;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)raw-audio, " "stream1=(string)compressed-audio", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  pad = gst_element_get_static_pad (sink, "sink");
+  fail_unless (pad != NULL);
+  switch_ctx.playbin = playbin;
+  switch_ctx.sink = sink;
+  gst_pad_add_buffer_probe (pad, G_CALLBACK (switch_audio_buffer_probe),
+      &switch_ctx);
+  gst_object_unref (pad);
+  gst_object_unref (sink);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless (csink->n_raw > 0);
+    fail_unless (csink->n_compressed > 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST (test_compressed_raw_audio_stream_demuxer_switch_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+  GstPad *pad;
+  SwitchBufferProbeCtx switch_ctx;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)compressed-audio, " "stream1=(string)raw-audio", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  pad = gst_element_get_static_pad (sink, "sink");
+  fail_unless (pad != NULL);
+  switch_ctx.playbin = playbin;
+  switch_ctx.sink = sink;
+  gst_pad_add_buffer_probe (pad, G_CALLBACK (switch_audio_buffer_probe),
+      &switch_ctx);
+  gst_object_unref (pad);
+  gst_object_unref (sink);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless (csink->n_raw > 0);
+    fail_unless (csink->n_compressed > 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST (test_raw_raw_audio_stream_demuxer_switch_manual_sink)
+{
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+  GstPad *pad;
+  SwitchBufferProbeCtx switch_ctx;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)raw-audio, " "stream1=(string)raw-audio", TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  pad = gst_element_get_static_pad (sink, "sink");
+  fail_unless (pad != NULL);
+  switch_ctx.playbin = playbin;
+  switch_ctx.sink = sink;
+  gst_pad_add_buffer_probe (pad, G_CALLBACK (switch_audio_buffer_probe),
+      &switch_ctx);
+  gst_object_unref (pad);
+  gst_object_unref (sink);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless (csink->n_raw > 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+GST_START_TEST
+    (test_compressed_compressed_audio_stream_demuxer_switch_manual_sink) {
+  GstMessage *msg;
+  GstElement *playbin;
+  GstElement *sink;
+  GstBus *bus;
+  gboolean done = FALSE;
+  GstPad *pad;
+  SwitchBufferProbeCtx switch_ctx;
+
+  fail_unless (gst_element_register (NULL, "capssrc", GST_RANK_PRIMARY,
+          gst_caps_src_get_type ()));
+  fail_unless (gst_element_register (NULL, "codecdemuxer",
+          GST_RANK_PRIMARY + 100, gst_codec_demuxer_get_type ()));
+  fail_unless (gst_element_register (NULL, "audiocodecsink",
+          GST_RANK_PRIMARY + 100, gst_audio_codec_sink_get_type ()));
+  fail_unless (gst_element_register (NULL, "videocodecsink",
+          GST_RANK_PRIMARY + 100, gst_video_codec_sink_get_type ()));
+
+  playbin = create_playbin ("caps:application/x-container, "
+      "stream0=(string)compressed-audio, " "stream1=(string)compressed-audio",
+      TRUE);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_READY),
+      GST_STATE_CHANGE_SUCCESS);
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  pad = gst_element_get_static_pad (sink, "sink");
+  fail_unless (pad != NULL);
+  switch_ctx.playbin = playbin;
+  switch_ctx.sink = sink;
+  gst_pad_add_buffer_probe (pad, G_CALLBACK (switch_audio_buffer_probe),
+      &switch_ctx);
+  gst_object_unref (pad);
+  gst_object_unref (sink);
+
+  fail_unless_equals_int (gst_element_set_state (playbin, GST_STATE_PLAYING),
+      GST_STATE_CHANGE_ASYNC);
+
+  bus = gst_element_get_bus (playbin);
+
+  while (!done) {
+    msg = gst_bus_poll (bus, GST_MESSAGE_ANY, -1);
+
+    switch (GST_MESSAGE_TYPE (msg)) {
+      case GST_MESSAGE_EOS:
+        done = TRUE;
+        break;
+      case GST_MESSAGE_ERROR:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_ERROR);
+        break;
+      case GST_MESSAGE_WARNING:
+        fail_if (GST_MESSAGE_TYPE (msg) == GST_MESSAGE_WARNING);
+        break;
+      default:
+        break;
+    }
+    gst_message_unref (msg);
+  }
+  gst_object_unref (bus);
+
+  g_object_get (G_OBJECT (playbin), "video-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstVideoCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_video_codec_sink_get_type ());
+    csink = (GstVideoCodecSink *) sink;
+    fail_unless (csink->audio == FALSE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless_equals_int (csink->n_compressed, 0);
+    gst_object_unref (sink);
+  }
+
+  g_object_get (G_OBJECT (playbin), "audio-sink", &sink, NULL);
+  fail_unless (sink != NULL);
+  {
+    GstAudioCodecSink *csink;
+
+    fail_unless (G_TYPE_FROM_INSTANCE (sink) ==
+        gst_audio_codec_sink_get_type ());
+    csink = (GstAudioCodecSink *) sink;
+    fail_unless (csink->audio == TRUE);
+    fail_unless_equals_int (csink->n_raw, 0);
+    fail_unless (csink->n_compressed > 0);
+    gst_object_unref (sink);
+  }
+
+  gst_element_set_state (playbin, GST_STATE_NULL);
+  gst_object_unref (playbin);
+}
+
+GST_END_TEST;
+
+#endif
+
+static Suite *
+playbin2_compressed_suite (void)
+{
+  Suite *s = suite_create ("playbin2_compressed");
+  TCase *tc_chain = tcase_create ("general");
+
+  suite_add_tcase (s, tc_chain);
+
+#ifndef GST_DISABLE_REGISTRY
+  tcase_add_test (tc_chain, test_raw_single_video_stream_manual_sink);
+  tcase_add_test (tc_chain, test_raw_single_audio_stream_manual_sink);
+  tcase_add_test (tc_chain, test_compressed_single_video_stream_manual_sink);
+  tcase_add_test (tc_chain, test_compressed_single_audio_stream_manual_sink);
+
+  tcase_add_test (tc_chain, test_raw_single_video_stream_demuxer_manual_sink);
+  tcase_add_test (tc_chain, test_raw_single_audio_stream_demuxer_manual_sink);
+  tcase_add_test (tc_chain,
+      test_compressed_single_video_stream_demuxer_manual_sink);
+  tcase_add_test (tc_chain,
+      test_compressed_single_audio_stream_demuxer_manual_sink);
+
+  tcase_add_test (tc_chain, test_raw_audio_video_stream_demuxer_manual_sink);
+  tcase_add_test (tc_chain,
+      test_compressed_audio_video_stream_demuxer_manual_sink);
+
+  tcase_add_test (tc_chain,
+      test_raw_compressed_audio_stream_demuxer_manual_sink);
+  tcase_add_test (tc_chain,
+      test_raw_compressed_video_stream_demuxer_manual_sink);
+
+  tcase_add_test (tc_chain,
+      test_raw_raw_audio_stream_demuxer_switch_manual_sink);
+  tcase_add_test (tc_chain,
+      test_raw_compressed_audio_stream_demuxer_switch_manual_sink);
+  tcase_add_test (tc_chain,
+      test_compressed_raw_audio_stream_demuxer_switch_manual_sink);
+  tcase_add_test (tc_chain,
+      test_compressed_compressed_audio_stream_demuxer_switch_manual_sink);
+  tcase_add_test (tc_chain,
+      test_raw_raw_video_stream_demuxer_switch_manual_sink);
+  tcase_add_test (tc_chain,
+      test_raw_compressed_video_stream_demuxer_switch_manual_sink);
+  tcase_add_test (tc_chain,
+      test_compressed_raw_video_stream_demuxer_switch_manual_sink);
+  tcase_add_test (tc_chain,
+      test_compressed_compressed_video_stream_demuxer_switch_manual_sink);
+
+#endif
+
+  return s;
+}
+
+GST_CHECK_MAIN (playbin2_compressed);