summaryrefslogtreecommitdiff
path: root/tests
diff options
context:
space:
mode:
authorTim-Philipp Müller <tim@centricular.com>2018-02-13 00:28:36 +0000
committerTim-Philipp Müller <tim@centricular.com>2018-02-13 00:37:35 +0000
commitc180f8ffed60134cac1773fb29f1acd156f04933 (patch)
tree8448d6472ec3038d5950911618e1863cdadcbfa5 /tests
parent843f11852392f1770718ab7ca3c6e248f558382f (diff)
downloadgstreamer-plugins-bad-c180f8ffed60134cac1773fb29f1acd156f04933.tar.gz
audiomixer: remove, moved to -base
https://bugzilla.gnome.org/show_bug.cgi?id=791218
Diffstat (limited to 'tests')
-rw-r--r--tests/check/Makefile.am18
-rw-r--r--tests/check/elements/.gitignore2
-rw-r--r--tests/check/elements/audiointerleave.c1128
-rw-r--r--tests/check/elements/audiomixer.c1894
-rw-r--r--tests/check/meson.build2
5 files changed, 1 insertions, 3043 deletions
diff --git a/tests/check/Makefile.am b/tests/check/Makefile.am
index 0343da7eb..5a7c497b2 100644
--- a/tests/check/Makefile.am
+++ b/tests/check/Makefile.am
@@ -127,7 +127,7 @@ check_kate=
endif
if HAVE_ORC
-check_orc = orc/bayer orc/audiomixer orc/compositor
+check_orc = orc/bayer orc/compositor
else
check_orc =
endif
@@ -257,8 +257,6 @@ check_PROGRAMS = \
elements/videoframe-audiolevel \
elements/autoconvert \
elements/autovideoconvert \
- elements/audiointerleave \
- elements/audiomixer \
elements/asfmux \
elements/camerabin \
elements/gdppay \
@@ -313,12 +311,6 @@ LDADD = $(GST_CHECK_LIBS)
generic_states_CFLAGS = $(AM_CFLAGS) $(GLIB_CFLAGS)
generic_states_LDADD = $(LDADD) $(GLIB_LIBS)
-elements_audiomixer_LDADD = $(GST_BASE_LIBS) $(GST_CONTROLLER_LIBS) -lgstbase-@GST_API_VERSION@ $(LDADD)
-elements_audiomixer_CFLAGS = $(GST_PLUGINS_BASE_CFLAGS) $(GST_BASE_CFLAGS) $(GST_CONTROLLER_CFLAGS) $(AM_CFLAGS)
-
-elements_audiointerleave_LDADD = $(GST_BASE_LIBS) -lgstbase-@GST_API_VERSION@ $(GST_AUDIO_LIBS) $(LDADD)
-elements_audiointerleave_CFLAGS = $(GST_PLUGINS_BASE_CFLAGS) $(GST_BASE_CFLAGS) $(AM_CFLAGS)
-
elements_pnm_CFLAGS = \
$(GST_PLUGINS_BASE_CFLAGS) \
$(GST_BASE_CFLAGS) $(GST_CFLAGS) $(AM_CFLAGS)
@@ -542,14 +534,6 @@ orc/bayer.c: $(top_srcdir)/gst/bayer/gstbayerorc.orc
$(MKDIR_P) orc
$(ORCC) --test -o $@ $<
-orc_audiomixer_CFLAGS = $(ORC_CFLAGS)
-orc_audiomixer_LDADD = $(ORC_LIBS) -lorc-test-0.4
-nodist_orc_audiomixer_SOURCES = orc/audiomixer.c
-
-orc/audiomixer.c: $(top_srcdir)/gst/audiomixer/gstaudiomixerorc.orc
- $(MKDIR_P) orc
- $(ORCC) --test -o $@ $<
-
elements_compositor_LDADD = \
$(GST_PLUGINS_BASE_LIBS) $(GST_VIDEO_LIBS) $(GST_BASE_LIBS) $(LDADD)
elements_compositor_CFLAGS = \
diff --git a/tests/check/elements/.gitignore b/tests/check/elements/.gitignore
index 741772b5a..d264dae57 100644
--- a/tests/check/elements/.gitignore
+++ b/tests/check/elements/.gitignore
@@ -2,8 +2,6 @@
aiffparse
asfmux
assrender
-audiointerleave
-audiomixer
autoconvert
autovideoconvert
baseaudiovisualizer
diff --git a/tests/check/elements/audiointerleave.c b/tests/check/elements/audiointerleave.c
deleted file mode 100644
index 71348f459..000000000
--- a/tests/check/elements/audiointerleave.c
+++ /dev/null
@@ -1,1128 +0,0 @@
-/* GStreamer unit tests for the audiointerleave element
- * Copyright (C) 2007 Tim-Philipp Müller <tim centricular net>
- * Copyright (C) 2008 Sebastian Dröge <slomo@circular-chaos.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., 51 Franklin St, Fifth Floor,
- * Boston, MA 02110-1301, USA.
- */
-
-/* FIXME 0.11: suppress warnings for deprecated API such as GValueArray
- * with newer GLib versions (>= 2.31.0) */
-#define GLIB_DISABLE_DEPRECATION_WARNINGS
-
-#ifdef HAVE_CONFIG_H
-# include "config.h"
-#endif
-
-#ifdef HAVE_VALGRIND
-# include <valgrind/valgrind.h>
-#endif
-
-#include <gst/check/gstcheck.h>
-#include <gst/audio/audio.h>
-#include <gst/audio/audio-enumtypes.h>
-
-#include <gst/check/gstharness.h>
-
-static void
-gst_check_setup_events_audiointerleave (GstPad * srcpad, GstElement * element,
- GstCaps * caps, GstFormat format, const gchar * stream_id)
-{
- GstSegment segment;
-
- gst_segment_init (&segment, format);
-
- fail_unless (gst_pad_push_event (srcpad,
- gst_event_new_stream_start (stream_id)));
- if (caps)
- fail_unless (gst_pad_push_event (srcpad, gst_event_new_caps (caps)));
- fail_unless (gst_pad_push_event (srcpad, gst_event_new_segment (&segment)));
-}
-
-GST_START_TEST (test_create_and_unref)
-{
- GstElement *interleave;
-
- interleave = gst_element_factory_make ("audiointerleave", NULL);
- fail_unless (interleave != NULL);
-
- gst_element_set_state (interleave, GST_STATE_NULL);
- gst_object_unref (interleave);
-}
-
-GST_END_TEST;
-
-GST_START_TEST (test_request_pads)
-{
- GstElement *interleave;
- GstPad *pad1, *pad2;
-
- interleave = gst_element_factory_make ("audiointerleave", NULL);
- fail_unless (interleave != NULL);
-
- pad1 = gst_element_get_request_pad (interleave, "sink_%u");
- fail_unless (pad1 != NULL);
- fail_unless_equals_string (GST_OBJECT_NAME (pad1), "sink_0");
-
- pad2 = gst_element_get_request_pad (interleave, "sink_%u");
- fail_unless (pad2 != NULL);
- fail_unless_equals_string (GST_OBJECT_NAME (pad2), "sink_1");
-
- gst_element_release_request_pad (interleave, pad2);
- gst_object_unref (pad2);
- gst_element_release_request_pad (interleave, pad1);
- gst_object_unref (pad1);
-
- gst_element_set_state (interleave, GST_STATE_NULL);
- gst_object_unref (interleave);
-}
-
-GST_END_TEST;
-
-static GstPad **mysrcpads, *mysinkpad;
-static GstBus *bus;
-static GstElement *interleave;
-static GMutex data_mutex;
-static GCond data_cond;
-static gint have_data;
-static gfloat input[2];
-
-static GstStaticPadTemplate sinktemplate = GST_STATIC_PAD_TEMPLATE ("sink",
- GST_PAD_SINK,
- GST_PAD_ALWAYS,
- GST_STATIC_CAPS ("audio/x-raw, "
- "format = (string) " GST_AUDIO_NE (F32) ", "
- "channels = (int) 2, layout = (string) {interleaved, non-interleaved}, rate = (int) 48000"));
-
-static GstStaticPadTemplate srctemplate = GST_STATIC_PAD_TEMPLATE ("src",
- GST_PAD_SRC,
- GST_PAD_ALWAYS,
- GST_STATIC_CAPS ("audio/x-raw, "
- "format = (string) " GST_AUDIO_NE (F32) ", "
- "channels = (int) 1, layout = (string) interleaved, rate = (int) 48000"));
-
-#define CAPS_48khz \
- "audio/x-raw, " \
- "format = (string) " GST_AUDIO_NE (F32) ", " \
- "channels = (int) 1, layout = (string) non-interleaved," \
- "rate = (int) 48000"
-
-static GstFlowReturn
-interleave_chain_func (GstPad * pad, GstObject * parent, GstBuffer * buffer)
-{
- GstMapInfo map;
- gfloat *outdata;
- gint i;
-
- fail_unless (GST_IS_BUFFER (buffer));
- fail_unless (!GST_BUFFER_FLAG_IS_SET (buffer, GST_BUFFER_FLAG_GAP));
- gst_buffer_map (buffer, &map, GST_MAP_READ);
- outdata = (gfloat *) map.data;
- fail_unless (outdata != NULL);
-
-#ifdef HAVE_VALGRIND
- if (!(RUNNING_ON_VALGRIND))
-#endif
- for (i = 0; i < map.size / sizeof (float); i += 2) {
- fail_unless_equals_float (outdata[i], input[0]);
- fail_unless_equals_float (outdata[i + 1], input[1]);
- }
-
- g_mutex_lock (&data_mutex);
- have_data += map.size;
- g_cond_signal (&data_cond);
- g_mutex_unlock (&data_mutex);
-
- gst_buffer_unmap (buffer, &map);
- gst_buffer_unref (buffer);
-
-
- return GST_FLOW_OK;
-}
-
-GST_START_TEST (test_audiointerleave_2ch)
-{
- GstElement *queue;
- GstPad *sink0, *sink1, *src, *tmp;
- GstCaps *caps;
- gint i;
- GstBuffer *inbuf;
- gfloat *indata;
- GstMapInfo map;
-
- mysrcpads = g_new0 (GstPad *, 2);
-
- have_data = 0;
-
- interleave = gst_element_factory_make ("audiointerleave", NULL);
- fail_unless (interleave != NULL);
-
- g_object_set (interleave, "latency", GST_SECOND / 4, NULL);
-
- queue = gst_element_factory_make ("queue", "queue");
- fail_unless (queue != NULL);
-
- sink0 = gst_element_get_request_pad (interleave, "sink_%u");
- fail_unless (sink0 != NULL);
- fail_unless_equals_string (GST_OBJECT_NAME (sink0), "sink_0");
-
- sink1 = gst_element_get_request_pad (interleave, "sink_%u");
- fail_unless (sink1 != NULL);
- fail_unless_equals_string (GST_OBJECT_NAME (sink1), "sink_1");
-
- mysrcpads[0] = gst_pad_new_from_static_template (&srctemplate, "src0");
- fail_unless (mysrcpads[0] != NULL);
-
- caps = gst_caps_from_string (CAPS_48khz);
- gst_pad_set_active (mysrcpads[0], TRUE);
- gst_check_setup_events_audiointerleave (mysrcpads[0], interleave, caps,
- GST_FORMAT_TIME, "0");
- gst_pad_use_fixed_caps (mysrcpads[0]);
-
- mysrcpads[1] = gst_pad_new_from_static_template (&srctemplate, "src1");
- fail_unless (mysrcpads[1] != NULL);
-
- gst_pad_set_active (mysrcpads[1], TRUE);
- gst_check_setup_events_audiointerleave (mysrcpads[1], interleave, caps,
- GST_FORMAT_TIME, "1");
- gst_pad_use_fixed_caps (mysrcpads[1]);
-
- tmp = gst_element_get_static_pad (queue, "sink");
- fail_unless (gst_pad_link (mysrcpads[0], tmp) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
- tmp = gst_element_get_static_pad (queue, "src");
- fail_unless (gst_pad_link (tmp, sink0) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
-
- fail_unless (gst_pad_link (mysrcpads[1], sink1) == GST_PAD_LINK_OK);
-
- mysinkpad = gst_pad_new_from_static_template (&sinktemplate, "sink");
- fail_unless (mysinkpad != NULL);
- gst_pad_set_chain_function (mysinkpad, interleave_chain_func);
- gst_pad_set_active (mysinkpad, TRUE);
-
- src = gst_element_get_static_pad (interleave, "src");
- fail_unless (src != NULL);
- fail_unless (gst_pad_link (src, mysinkpad) == GST_PAD_LINK_OK);
- gst_object_unref (src);
-
- bus = gst_bus_new ();
- gst_element_set_bus (interleave, bus);
-
- fail_unless (gst_element_set_state (interleave,
- GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS);
- fail_unless (gst_element_set_state (queue,
- GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS);
-
- input[0] = -1.0;
- inbuf = gst_buffer_new_and_alloc (48000 * sizeof (gfloat));
- //GST_BUFFER_PTS (inbuf) = 0;
- gst_buffer_map (inbuf, &map, GST_MAP_WRITE);
- indata = (gfloat *) map.data;
- for (i = 0; i < 48000; i++)
- indata[i] = -1.0;
- gst_buffer_unmap (inbuf, &map);
- fail_unless (gst_pad_push (mysrcpads[0], inbuf) == GST_FLOW_OK);
-
- input[1] = 1.0;
- inbuf = gst_buffer_new_and_alloc (48000 * sizeof (gfloat));
- //GST_BUFFER_PTS (inbuf) = 0;
- gst_buffer_map (inbuf, &map, GST_MAP_WRITE);
- indata = (gfloat *) map.data;
- for (i = 0; i < 48000; i++)
- indata[i] = 1.0;
- gst_buffer_unmap (inbuf, &map);
- fail_unless (gst_pad_push (mysrcpads[1], inbuf) == GST_FLOW_OK);
-
- inbuf = gst_buffer_new_and_alloc (48000 * sizeof (gfloat));
- //GST_BUFFER_PTS (inbuf) = GST_SECOND;
- gst_buffer_map (inbuf, &map, GST_MAP_WRITE);
- indata = (gfloat *) map.data;
- for (i = 0; i < 48000; i++)
- indata[i] = -1.0;
- gst_buffer_unmap (inbuf, &map);
- fail_unless (gst_pad_push (mysrcpads[0], inbuf) == GST_FLOW_OK);
-
- inbuf = gst_buffer_new_and_alloc (48000 * sizeof (gfloat));
- //GST_BUFFER_PTS (inbuf) = GST_SECOND;
- gst_buffer_map (inbuf, &map, GST_MAP_WRITE);
- indata = (gfloat *) map.data;
- for (i = 0; i < 48000; i++)
- indata[i] = 1.0;
- gst_buffer_unmap (inbuf, &map);
- fail_unless (gst_pad_push (mysrcpads[1], inbuf) == GST_FLOW_OK);
-
- g_mutex_lock (&data_mutex);
- while (have_data < 48000 * 2 * 2 * sizeof (float))
- g_cond_wait (&data_cond, &data_mutex);
- g_mutex_unlock (&data_mutex);
-
- gst_bus_set_flushing (bus, TRUE);
- gst_element_set_state (interleave, GST_STATE_NULL);
- gst_element_set_state (queue, GST_STATE_NULL);
-
- gst_object_unref (mysrcpads[0]);
- gst_object_unref (mysrcpads[1]);
- gst_object_unref (mysinkpad);
-
- gst_element_release_request_pad (interleave, sink0);
- gst_object_unref (sink0);
- gst_element_release_request_pad (interleave, sink1);
- gst_object_unref (sink1);
-
- gst_object_unref (interleave);
- gst_object_unref (queue);
- gst_object_unref (bus);
- gst_caps_unref (caps);
-
- g_free (mysrcpads);
-}
-
-GST_END_TEST;
-
-GST_START_TEST (test_audiointerleave_2ch_1eos)
-{
- GstElement *queue;
- GstPad *sink0, *sink1, *src, *tmp;
- GstCaps *caps;
- gint i;
- GstBuffer *inbuf;
- gfloat *indata;
- GstMapInfo map;
-
- mysrcpads = g_new0 (GstPad *, 2);
-
- have_data = 0;
-
- interleave = gst_element_factory_make ("audiointerleave", NULL);
- fail_unless (interleave != NULL);
-
- g_object_set (interleave, "latency", GST_SECOND / 4, NULL);
-
- queue = gst_element_factory_make ("queue", "queue");
- fail_unless (queue != NULL);
-
- sink0 = gst_element_get_request_pad (interleave, "sink_%u");
- fail_unless (sink0 != NULL);
- fail_unless_equals_string (GST_OBJECT_NAME (sink0), "sink_0");
-
- sink1 = gst_element_get_request_pad (interleave, "sink_%u");
- fail_unless (sink1 != NULL);
- fail_unless_equals_string (GST_OBJECT_NAME (sink1), "sink_1");
-
- mysrcpads[0] = gst_pad_new_from_static_template (&srctemplate, "src0");
- fail_unless (mysrcpads[0] != NULL);
-
- caps = gst_caps_from_string (CAPS_48khz);
- gst_pad_set_active (mysrcpads[0], TRUE);
- gst_check_setup_events_audiointerleave (mysrcpads[0], interleave, caps,
- GST_FORMAT_TIME, "0");
- gst_pad_use_fixed_caps (mysrcpads[0]);
-
- mysrcpads[1] = gst_pad_new_from_static_template (&srctemplate, "src1");
- fail_unless (mysrcpads[1] != NULL);
-
- gst_pad_set_active (mysrcpads[1], TRUE);
- gst_check_setup_events_audiointerleave (mysrcpads[1], interleave, caps,
- GST_FORMAT_TIME, "1");
- gst_pad_use_fixed_caps (mysrcpads[1]);
-
- tmp = gst_element_get_static_pad (queue, "sink");
- fail_unless (gst_pad_link (mysrcpads[0], tmp) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
- tmp = gst_element_get_static_pad (queue, "src");
- fail_unless (gst_pad_link (tmp, sink0) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
-
- fail_unless (gst_pad_link (mysrcpads[1], sink1) == GST_PAD_LINK_OK);
-
- mysinkpad = gst_pad_new_from_static_template (&sinktemplate, "sink");
- fail_unless (mysinkpad != NULL);
- gst_pad_set_chain_function (mysinkpad, interleave_chain_func);
- gst_pad_set_active (mysinkpad, TRUE);
-
- src = gst_element_get_static_pad (interleave, "src");
- fail_unless (src != NULL);
- fail_unless (gst_pad_link (src, mysinkpad) == GST_PAD_LINK_OK);
- gst_object_unref (src);
-
- bus = gst_bus_new ();
- gst_element_set_bus (interleave, bus);
-
- fail_unless (gst_element_set_state (interleave,
- GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS);
- fail_unless (gst_element_set_state (queue,
- GST_STATE_PLAYING) == GST_STATE_CHANGE_SUCCESS);
-
- input[0] = -1.0;
- inbuf = gst_buffer_new_and_alloc (48000 * sizeof (gfloat));
- GST_BUFFER_PTS (inbuf) = 0;
- gst_buffer_map (inbuf, &map, GST_MAP_WRITE);
- indata = (gfloat *) map.data;
- for (i = 0; i < 48000; i++)
- indata[i] = -1.0;
- gst_buffer_unmap (inbuf, &map);
- fail_unless (gst_pad_push (mysrcpads[0], inbuf) == GST_FLOW_OK);
-
- input[1] = 1.0;
- inbuf = gst_buffer_new_and_alloc (48000 * sizeof (gfloat));
- GST_BUFFER_PTS (inbuf) = 0;
- gst_buffer_map (inbuf, &map, GST_MAP_WRITE);
- indata = (gfloat *) map.data;
- for (i = 0; i < 48000; i++)
- indata[i] = 1.0;
- gst_buffer_unmap (inbuf, &map);
- fail_unless (gst_pad_push (mysrcpads[1], inbuf) == GST_FLOW_OK);
-
- g_mutex_lock (&data_mutex);
- /* 48000 samples per buffer * 2 sources * 2 buffers */
- while (have_data != 48000 * 2 * sizeof (float))
- g_cond_wait (&data_cond, &data_mutex);
- g_mutex_unlock (&data_mutex);
-
- input[0] = 0.0;
- gst_pad_push_event (mysrcpads[0], gst_event_new_eos ());
-
- input[1] = 1.0;
- inbuf = gst_buffer_new_and_alloc (48000 * sizeof (gfloat));
- GST_BUFFER_PTS (inbuf) = GST_SECOND;
- gst_buffer_map (inbuf, &map, GST_MAP_WRITE);
- indata = (gfloat *) map.data;
- for (i = 0; i < 48000; i++)
- indata[i] = 1.0;
- gst_buffer_unmap (inbuf, &map);
- fail_unless (gst_pad_push (mysrcpads[1], inbuf) == GST_FLOW_OK);
-
- g_mutex_lock (&data_mutex);
- /* 48000 samples per buffer * 2 sources * 2 buffers */
- while (have_data != 48000 * 2 * 2 * sizeof (float))
- g_cond_wait (&data_cond, &data_mutex);
- g_mutex_unlock (&data_mutex);
-
- gst_bus_set_flushing (bus, TRUE);
- gst_element_set_state (interleave, GST_STATE_NULL);
- gst_element_set_state (queue, GST_STATE_NULL);
-
- gst_object_unref (mysrcpads[0]);
- gst_object_unref (mysrcpads[1]);
- gst_object_unref (mysinkpad);
-
- gst_element_release_request_pad (interleave, sink0);
- gst_object_unref (sink0);
- gst_element_release_request_pad (interleave, sink1);
- gst_object_unref (sink1);
-
- gst_object_unref (interleave);
- gst_object_unref (queue);
- gst_object_unref (bus);
- gst_caps_unref (caps);
-
- g_free (mysrcpads);
-}
-
-GST_END_TEST;
-
-static void
-src_handoff_float32 (GstElement * element, GstBuffer * buffer, GstPad * pad,
- gboolean interleaved, gpointer user_data)
-{
- gint n = GPOINTER_TO_INT (user_data);
- gfloat *data;
- gint i, num_samples;
- GstCaps *caps;
- guint64 mask;
- GstAudioChannelPosition pos;
- GstMapInfo map;
-
- fail_unless (gst_buffer_is_writable (buffer));
-
- switch (n) {
- case 0:
- case 1:
- case 2:
- pos = GST_AUDIO_CHANNEL_POSITION_FRONT_LEFT;
- break;
- case 3:
- pos = GST_AUDIO_CHANNEL_POSITION_FRONT_RIGHT;
- break;
- default:
- pos = GST_AUDIO_CHANNEL_POSITION_INVALID;
- break;
- }
-
- mask = G_GUINT64_CONSTANT (1) << pos;
-
- caps = gst_caps_new_simple ("audio/x-raw",
- "format", G_TYPE_STRING, GST_AUDIO_NE (F32),
- "channels", G_TYPE_INT, 1,
- "layout", G_TYPE_STRING, interleaved ? "interleaved" : "non-interleaved",
- "channel-mask", GST_TYPE_BITMASK, mask, "rate", G_TYPE_INT, 48000, NULL);
-
- gst_pad_set_caps (pad, caps);
- gst_caps_unref (caps);
-
- fail_unless (gst_buffer_map (buffer, &map, GST_MAP_WRITE));
- fail_unless (map.size % sizeof (gfloat) == 0);
-
- fail_unless (map.size > 480);
-
- num_samples = map.size / sizeof (gfloat);
- data = (gfloat *) map.data;
-
- for (i = 0; i < num_samples; i++)
- data[i] = (n % 2 == 0) ? -1.0 : 1.0;
-
- gst_buffer_unmap (buffer, &map);
-}
-
-static void
-src_handoff_float32_audiointerleaved (GstElement * element, GstBuffer * buffer,
- GstPad * pad, gpointer user_data)
-{
- src_handoff_float32 (element, buffer, pad, TRUE, user_data);
-}
-
-static void
-src_handoff_float32_non_audiointerleaved (GstElement * element,
- GstBuffer * buffer, GstPad * pad, gpointer user_data)
-{
- src_handoff_float32 (element, buffer, pad, FALSE, user_data);
-}
-
-static void
-sink_handoff_float32 (GstElement * element, GstBuffer * buffer, GstPad * pad,
- gpointer user_data)
-{
- gint i;
- GstMapInfo map;
- gfloat *data;
- GstCaps *caps, *ccaps;
- gint n = GPOINTER_TO_INT (user_data);
- guint64 mask;
-
- fail_unless (GST_IS_BUFFER (buffer));
- gst_buffer_map (buffer, &map, GST_MAP_READ);
- data = (gfloat *) map.data;
-
- /* Give a little leeway for rounding errors */
- fail_unless (gst_util_uint64_scale (map.size, GST_SECOND,
- 48000 * 2 * sizeof (gfloat)) <= GST_BUFFER_DURATION (buffer) + 1 ||
- gst_util_uint64_scale (map.size, GST_SECOND,
- 48000 * 2 * sizeof (gfloat)) >= GST_BUFFER_DURATION (buffer) - 1);
-
- if (n == 0 || n == 3) {
- GstAudioChannelPosition pos[2] =
- { GST_AUDIO_CHANNEL_POSITION_NONE, GST_AUDIO_CHANNEL_POSITION_NONE };
- gst_audio_channel_positions_to_mask (pos, 2, FALSE, &mask);
- } else if (n == 1) {
- GstAudioChannelPosition pos[2] = { GST_AUDIO_CHANNEL_POSITION_FRONT_LEFT,
- GST_AUDIO_CHANNEL_POSITION_FRONT_RIGHT
- };
- gst_audio_channel_positions_to_mask (pos, 2, FALSE, &mask);
- } else if (n == 2) {
- GstAudioChannelPosition pos[2] = { GST_AUDIO_CHANNEL_POSITION_FRONT_CENTER,
- GST_AUDIO_CHANNEL_POSITION_REAR_CENTER
- };
- gst_audio_channel_positions_to_mask (pos, 2, FALSE, &mask);
- } else {
- g_assert_not_reached ();
- }
-
- if (pad) {
- caps = gst_caps_new_simple ("audio/x-raw",
- "format", G_TYPE_STRING, GST_AUDIO_NE (F32),
- "channels", G_TYPE_INT, 2, "rate", G_TYPE_INT, 48000,
- "layout", G_TYPE_STRING, "interleaved",
- "channel-mask", GST_TYPE_BITMASK, mask, NULL);
-
- ccaps = gst_pad_get_current_caps (pad);
- fail_unless (gst_caps_is_equal (caps, ccaps));
- gst_caps_unref (ccaps);
- gst_caps_unref (caps);
- }
-#ifdef HAVE_VALGRIND
- if (!(RUNNING_ON_VALGRIND))
-#endif
- for (i = 0; i < map.size / sizeof (float); i += 2) {
- fail_unless_equals_float (data[i], -1.0);
- if (n != 3)
- fail_unless_equals_float (data[i + 1], 1.0);
- }
- have_data += map.size;
-
- gst_buffer_unmap (buffer, &map);
-
-}
-
-static void
-test_audiointerleave_2ch_pipeline (gboolean interleaved)
-{
- GstElement *pipeline, *queue, *src1, *src2, *interleave, *sink;
- GstPad *sinkpad0, *sinkpad1, *tmp, *tmp2;
- GstMessage *msg;
- void *src_handoff_float32 =
- interleaved ? &src_handoff_float32_audiointerleaved :
- &src_handoff_float32_non_audiointerleaved;
-
- have_data = 0;
-
- pipeline = (GstElement *) gst_pipeline_new ("pipeline");
- fail_unless (pipeline != NULL);
-
- src1 = gst_element_factory_make ("fakesrc", "src1");
- fail_unless (src1 != NULL);
- g_object_set (src1, "num-buffers", 4, NULL);
- g_object_set (src1, "sizetype", 2,
- "sizemax", (int) 48000 * sizeof (gfloat),
- "datarate", (int) 48000 * sizeof (gfloat), NULL);
- g_object_set (src1, "signal-handoffs", TRUE, NULL);
- g_object_set (src1, "format", GST_FORMAT_TIME, NULL);
- g_signal_connect (src1, "handoff", G_CALLBACK (src_handoff_float32),
- GINT_TO_POINTER (0));
- gst_bin_add (GST_BIN (pipeline), src1);
-
- src2 = gst_element_factory_make ("fakesrc", "src2");
- fail_unless (src2 != NULL);
- g_object_set (src2, "num-buffers", 4, NULL);
- g_object_set (src2, "sizetype", 2,
- "sizemax", (int) 48000 * sizeof (gfloat),
- "datarate", (int) 48000 * sizeof (gfloat), NULL);
- g_object_set (src2, "signal-handoffs", TRUE, NULL);
- g_object_set (src2, "format", GST_FORMAT_TIME, NULL);
- g_signal_connect (src2, "handoff", G_CALLBACK (src_handoff_float32),
- GINT_TO_POINTER (1));
- gst_bin_add (GST_BIN (pipeline), src2);
-
- queue = gst_element_factory_make ("queue", "queue");
- fail_unless (queue != NULL);
- gst_bin_add (GST_BIN (pipeline), queue);
-
- interleave = gst_element_factory_make ("audiointerleave", "audiointerleave");
- fail_unless (interleave != NULL);
- gst_bin_add (GST_BIN (pipeline), gst_object_ref (interleave));
-
- sinkpad0 = gst_element_get_request_pad (interleave, "sink_%u");
- fail_unless (sinkpad0 != NULL);
- tmp = gst_element_get_static_pad (src1, "src");
- fail_unless (gst_pad_link (tmp, sinkpad0) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
-
- sinkpad1 = gst_element_get_request_pad (interleave, "sink_%u");
- fail_unless (sinkpad1 != NULL);
- tmp = gst_element_get_static_pad (src2, "src");
- tmp2 = gst_element_get_static_pad (queue, "sink");
- fail_unless (gst_pad_link (tmp, tmp2) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
- gst_object_unref (tmp2);
- tmp = gst_element_get_static_pad (queue, "src");
- fail_unless (gst_pad_link (tmp, sinkpad1) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
-
- sink = gst_element_factory_make ("fakesink", "sink");
- fail_unless (sink != NULL);
- g_object_set (sink, "signal-handoffs", TRUE, NULL);
- g_signal_connect (sink, "handoff", G_CALLBACK (sink_handoff_float32),
- GINT_TO_POINTER (0));
- gst_bin_add (GST_BIN (pipeline), sink);
- tmp = gst_element_get_static_pad (interleave, "src");
- tmp2 = gst_element_get_static_pad (sink, "sink");
- fail_unless (gst_pad_link (tmp, tmp2) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
- gst_object_unref (tmp2);
-
- gst_element_set_state (pipeline, GST_STATE_PLAYING);
-
- msg = gst_bus_poll (GST_ELEMENT_BUS (pipeline), GST_MESSAGE_EOS, -1);
- gst_message_unref (msg);
-
- /* 48000 samples per buffer * 2 sources * 4 buffers */
- fail_unless (have_data == 48000 * 2 * 4 * sizeof (gfloat));
-
- gst_element_set_state (pipeline, GST_STATE_NULL);
- gst_element_release_request_pad (interleave, sinkpad0);
- gst_object_unref (sinkpad0);
- gst_element_release_request_pad (interleave, sinkpad1);
- gst_object_unref (sinkpad1);
- gst_object_unref (interleave);
- gst_object_unref (pipeline);
-}
-
-GST_START_TEST (test_audiointerleave_2ch_pipeline_audiointerleaved)
-{
- test_audiointerleave_2ch_pipeline (TRUE);
-}
-
-GST_END_TEST;
-
-GST_START_TEST (test_audiointerleave_2ch_pipeline_non_audiointerleaved)
-{
- test_audiointerleave_2ch_pipeline (FALSE);
-}
-
-GST_END_TEST;
-
-GST_START_TEST (test_audiointerleave_2ch_pipeline_input_chanpos)
-{
- GstElement *pipeline, *queue, *src1, *src2, *interleave, *sink;
- GstPad *sinkpad0, *sinkpad1, *tmp, *tmp2;
- GstMessage *msg;
-
- have_data = 0;
-
- pipeline = (GstElement *) gst_pipeline_new ("pipeline");
- fail_unless (pipeline != NULL);
-
- src1 = gst_element_factory_make ("fakesrc", "src1");
- fail_unless (src1 != NULL);
- g_object_set (src1, "num-buffers", 4, NULL);
- g_object_set (src1, "sizetype", 2,
- "sizemax", (int) 48000 * sizeof (gfloat),
- "datarate", (int) 48000 * sizeof (gfloat), NULL);
- g_object_set (src1, "signal-handoffs", TRUE, NULL);
- g_object_set (src1, "format", GST_FORMAT_TIME, NULL);
- g_signal_connect (src1, "handoff",
- G_CALLBACK (src_handoff_float32_audiointerleaved), GINT_TO_POINTER (2));
- gst_bin_add (GST_BIN (pipeline), src1);
-
- src2 = gst_element_factory_make ("fakesrc", "src2");
- fail_unless (src2 != NULL);
- g_object_set (src2, "num-buffers", 4, NULL);
- g_object_set (src2, "sizetype", 2,
- "sizemax", (int) 48000 * sizeof (gfloat),
- "datarate", (int) 48000 * sizeof (gfloat), NULL);
- g_object_set (src2, "signal-handoffs", TRUE, NULL);
- g_object_set (src2, "format", GST_FORMAT_TIME, NULL);
- g_signal_connect (src2, "handoff",
- G_CALLBACK (src_handoff_float32_audiointerleaved), GINT_TO_POINTER (3));
- gst_bin_add (GST_BIN (pipeline), src2);
-
- queue = gst_element_factory_make ("queue", "queue");
- fail_unless (queue != NULL);
- gst_bin_add (GST_BIN (pipeline), queue);
-
- interleave = gst_element_factory_make ("audiointerleave", "audiointerleave");
- fail_unless (interleave != NULL);
- g_object_set (interleave, "channel-positions-from-input", TRUE, NULL);
- gst_bin_add (GST_BIN (pipeline), gst_object_ref (interleave));
-
- sinkpad0 = gst_element_get_request_pad (interleave, "sink_%u");
- fail_unless (sinkpad0 != NULL);
- tmp = gst_element_get_static_pad (src1, "src");
- fail_unless (gst_pad_link (tmp, sinkpad0) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
-
- sinkpad1 = gst_element_get_request_pad (interleave, "sink_%u");
- fail_unless (sinkpad1 != NULL);
- tmp = gst_element_get_static_pad (src2, "src");
- tmp2 = gst_element_get_static_pad (queue, "sink");
- fail_unless (gst_pad_link (tmp, tmp2) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
- gst_object_unref (tmp2);
- tmp = gst_element_get_static_pad (queue, "src");
- fail_unless (gst_pad_link (tmp, sinkpad1) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
-
- sink = gst_element_factory_make ("fakesink", "sink");
- fail_unless (sink != NULL);
- g_object_set (sink, "signal-handoffs", TRUE, NULL);
- g_signal_connect (sink, "handoff", G_CALLBACK (sink_handoff_float32),
- GINT_TO_POINTER (1));
- gst_bin_add (GST_BIN (pipeline), sink);
- tmp = gst_element_get_static_pad (interleave, "src");
- tmp2 = gst_element_get_static_pad (sink, "sink");
- fail_unless (gst_pad_link (tmp, tmp2) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
- gst_object_unref (tmp2);
-
- gst_element_set_state (pipeline, GST_STATE_PLAYING);
-
- msg = gst_bus_poll (GST_ELEMENT_BUS (pipeline), GST_MESSAGE_EOS, -1);
- gst_message_unref (msg);
-
- /* 48000 samples per buffer * 2 sources * 4 buffers */
- fail_unless (have_data == 48000 * 2 * 4 * sizeof (gfloat));
-
- gst_element_set_state (pipeline, GST_STATE_NULL);
- gst_element_release_request_pad (interleave, sinkpad0);
- gst_object_unref (sinkpad0);
- gst_element_release_request_pad (interleave, sinkpad1);
- gst_object_unref (sinkpad1);
- gst_object_unref (interleave);
- gst_object_unref (pipeline);
-}
-
-GST_END_TEST;
-
-GST_START_TEST (test_audiointerleave_2ch_pipeline_custom_chanpos)
-{
- GstElement *pipeline, *queue, *src1, *src2, *interleave, *sink;
- GstPad *sinkpad0, *sinkpad1, *tmp, *tmp2;
- GstMessage *msg;
- GValueArray *arr;
- GValue val = { 0, };
-
- have_data = 0;
-
- pipeline = (GstElement *) gst_pipeline_new ("pipeline");
- fail_unless (pipeline != NULL);
-
- src1 = gst_element_factory_make ("fakesrc", "src1");
- fail_unless (src1 != NULL);
- g_object_set (src1, "num-buffers", 4, NULL);
- g_object_set (src1, "signal-handoffs", TRUE, NULL);
- g_object_set (src1, "sizetype", 2,
- "sizemax", (int) 48000 * sizeof (gfloat),
- "datarate", (int) 48000 * sizeof (gfloat), NULL);
- g_object_set (src1, "format", GST_FORMAT_TIME, NULL);
- g_signal_connect (src1, "handoff",
- G_CALLBACK (src_handoff_float32_audiointerleaved), GINT_TO_POINTER (0));
- gst_bin_add (GST_BIN (pipeline), src1);
-
- src2 = gst_element_factory_make ("fakesrc", "src2");
- fail_unless (src2 != NULL);
- g_object_set (src2, "num-buffers", 4, NULL);
- g_object_set (src2, "signal-handoffs", TRUE, NULL);
- g_object_set (src2, "sizetype", 2,
- "sizemax", (int) 48000 * sizeof (gfloat),
- "datarate", (int) 48000 * sizeof (gfloat), NULL);
- g_object_set (src2, "format", GST_FORMAT_TIME, NULL);
- g_signal_connect (src2, "handoff",
- G_CALLBACK (src_handoff_float32_audiointerleaved), GINT_TO_POINTER (1));
- gst_bin_add (GST_BIN (pipeline), src2);
-
- queue = gst_element_factory_make ("queue", "queue");
- fail_unless (queue != NULL);
- gst_bin_add (GST_BIN (pipeline), queue);
-
- interleave = gst_element_factory_make ("audiointerleave", "audiointerleave");
- fail_unless (interleave != NULL);
- g_object_set (interleave, "channel-positions-from-input", FALSE, NULL);
- arr = g_value_array_new (2);
-
- g_value_init (&val, GST_TYPE_AUDIO_CHANNEL_POSITION);
- g_value_set_enum (&val, GST_AUDIO_CHANNEL_POSITION_FRONT_CENTER);
- g_value_array_append (arr, &val);
- g_value_reset (&val);
- g_value_set_enum (&val, GST_AUDIO_CHANNEL_POSITION_REAR_CENTER);
- g_value_array_append (arr, &val);
- g_value_unset (&val);
-
- g_object_set (interleave, "channel-positions", arr, NULL);
- g_value_array_free (arr);
- gst_bin_add (GST_BIN (pipeline), gst_object_ref (interleave));
-
- sinkpad0 = gst_element_get_request_pad (interleave, "sink_%u");
- fail_unless (sinkpad0 != NULL);
- tmp = gst_element_get_static_pad (src1, "src");
- fail_unless (gst_pad_link (tmp, sinkpad0) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
-
- sinkpad1 = gst_element_get_request_pad (interleave, "sink_%u");
- fail_unless (sinkpad1 != NULL);
- tmp = gst_element_get_static_pad (src2, "src");
- tmp2 = gst_element_get_static_pad (queue, "sink");
- fail_unless (gst_pad_link (tmp, tmp2) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
- gst_object_unref (tmp2);
- tmp = gst_element_get_static_pad (queue, "src");
- fail_unless (gst_pad_link (tmp, sinkpad1) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
-
- sink = gst_element_factory_make ("fakesink", "sink");
- fail_unless (sink != NULL);
- g_object_set (sink, "signal-handoffs", TRUE, NULL);
- g_signal_connect (sink, "handoff", G_CALLBACK (sink_handoff_float32),
- GINT_TO_POINTER (2));
- gst_bin_add (GST_BIN (pipeline), sink);
- tmp = gst_element_get_static_pad (interleave, "src");
- tmp2 = gst_element_get_static_pad (sink, "sink");
- fail_unless (gst_pad_link (tmp, tmp2) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
- gst_object_unref (tmp2);
-
- gst_element_set_state (pipeline, GST_STATE_PLAYING);
-
- msg = gst_bus_poll (GST_ELEMENT_BUS (pipeline), GST_MESSAGE_EOS, -1);
- gst_message_unref (msg);
-
- /* 48000 samples per buffer * 2 sources * 4 buffers */
- fail_unless (have_data == 48000 * 2 * 4 * sizeof (gfloat));
-
- gst_element_set_state (pipeline, GST_STATE_NULL);
- gst_element_release_request_pad (interleave, sinkpad0);
- gst_object_unref (sinkpad0);
- gst_element_release_request_pad (interleave, sinkpad1);
- gst_object_unref (sinkpad1);
- gst_object_unref (interleave);
- gst_object_unref (pipeline);
-}
-
-GST_END_TEST;
-
-GST_START_TEST (test_audiointerleave_2ch_pipeline_no_chanpos)
-{
- GstElement *pipeline, *queue, *src1, *src2, *interleave, *sink;
- GstPad *sinkpad0, *sinkpad1, *tmp, *tmp2;
- GstMessage *msg;
-
- have_data = 0;
-
- pipeline = (GstElement *) gst_pipeline_new ("pipeline");
- fail_unless (pipeline != NULL);
-
- src1 = gst_element_factory_make ("fakesrc", "src1");
- fail_unless (src1 != NULL);
- g_object_set (src1, "num-buffers", 4, NULL);
- g_object_set (src1, "signal-handoffs", TRUE, NULL);
- g_object_set (src1, "sizetype", 2,
- "sizemax", (int) 48000 * sizeof (gfloat),
- "datarate", (int) 48000 * sizeof (gfloat), NULL);
- g_object_set (src1, "format", GST_FORMAT_TIME, NULL);
- g_signal_connect (src1, "handoff",
- G_CALLBACK (src_handoff_float32_audiointerleaved), GINT_TO_POINTER (0));
- gst_bin_add (GST_BIN (pipeline), src1);
-
- src2 = gst_element_factory_make ("fakesrc", "src2");
- fail_unless (src2 != NULL);
- g_object_set (src2, "num-buffers", 4, NULL);
- g_object_set (src2, "signal-handoffs", TRUE, NULL);
- g_object_set (src2, "sizetype", 2,
- "sizemax", (int) 48000 * sizeof (gfloat),
- "datarate", (int) 48000 * sizeof (gfloat), NULL);
- g_object_set (src2, "format", GST_FORMAT_TIME, NULL);
- g_signal_connect (src2, "handoff",
- G_CALLBACK (src_handoff_float32_audiointerleaved), GINT_TO_POINTER (1));
- gst_bin_add (GST_BIN (pipeline), src2);
-
- queue = gst_element_factory_make ("queue", "queue");
- fail_unless (queue != NULL);
- gst_bin_add (GST_BIN (pipeline), queue);
-
- interleave = gst_element_factory_make ("audiointerleave", "audiointerleave");
- fail_unless (interleave != NULL);
- g_object_set (interleave, "channel-positions-from-input", FALSE, NULL);
- gst_bin_add (GST_BIN (pipeline), gst_object_ref (interleave));
-
- sinkpad0 = gst_element_get_request_pad (interleave, "sink_%u");
- fail_unless (sinkpad0 != NULL);
- tmp = gst_element_get_static_pad (src1, "src");
- fail_unless (gst_pad_link (tmp, sinkpad0) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
-
- sinkpad1 = gst_element_get_request_pad (interleave, "sink_%u");
- fail_unless (sinkpad1 != NULL);
- tmp = gst_element_get_static_pad (src2, "src");
- tmp2 = gst_element_get_static_pad (queue, "sink");
- fail_unless (gst_pad_link (tmp, tmp2) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
- gst_object_unref (tmp2);
- tmp = gst_element_get_static_pad (queue, "src");
- fail_unless (gst_pad_link (tmp, sinkpad1) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
-
- sink = gst_element_factory_make ("fakesink", "sink");
- fail_unless (sink != NULL);
- g_object_set (sink, "signal-handoffs", TRUE, NULL);
- g_signal_connect (sink, "handoff", G_CALLBACK (sink_handoff_float32),
- GINT_TO_POINTER (0));
- gst_bin_add (GST_BIN (pipeline), sink);
- tmp = gst_element_get_static_pad (interleave, "src");
- tmp2 = gst_element_get_static_pad (sink, "sink");
- fail_unless (gst_pad_link (tmp, tmp2) == GST_PAD_LINK_OK);
- gst_object_unref (tmp);
- gst_object_unref (tmp2);
-
- gst_element_set_state (pipeline, GST_STATE_PLAYING);
-
- msg = gst_bus_poll (GST_ELEMENT_BUS (pipeline), GST_MESSAGE_EOS, -1);
- gst_message_unref (msg);
-
- /* 48000 samples per buffer * 2 sources * 4 buffers */
- fail_unless (have_data == 48000 * 2 * 4 * sizeof (gfloat));
-
- gst_element_set_state (pipeline, GST_STATE_NULL);
- gst_element_release_request_pad (interleave, sinkpad0);
- gst_object_unref (sinkpad0);
- gst_element_release_request_pad (interleave, sinkpad1);
- gst_object_unref (sinkpad1);
- gst_object_unref (interleave);
- gst_object_unref (pipeline);
-}
-
-GST_END_TEST;
-
-static void
-forward_check_event (GstHarness * h, GstHarness * hsrc, GstEventType type)
-{
- GstEvent *e;
-
- e = gst_harness_pull_event (hsrc);
- fail_unless (GST_EVENT_TYPE (e) == type);
- gst_harness_push_event (h, e);
-}
-
-GST_START_TEST (test_audiointerleave_2ch_smallbuf)
-{
- GstElement *audiointerleave;
- GstHarness *hsrc;
- GstHarness *h;
- GstHarness *h2;
- GstBuffer *buffer;
- gint i;
- GstEvent *ev;
- GstCaps *ecaps, *caps;
-
- audiointerleave = gst_element_factory_make ("audiointerleave", NULL);
-
- g_object_set (audiointerleave, "latency", GST_SECOND / 2,
- "output-buffer-duration", GST_SECOND / 4, NULL);
-
- h = gst_harness_new_with_element (audiointerleave, "sink_0", "src");
- gst_harness_use_testclock (h);
-
- h2 = gst_harness_new_with_element (audiointerleave, "sink_1", NULL);
- gst_harness_set_src_caps_str (h2, "audio/x-raw, "
- "format=" GST_AUDIO_NE (F32) ", channels=(int)1,"
- " layout=interleaved, rate=48000, channel-mask=(bitmask)8");
-
- hsrc = gst_harness_new ("fakesrc");
- gst_harness_use_testclock (hsrc);
- g_object_set (hsrc->element,
- "is-live", TRUE,
- "sync", TRUE,
- "signal-handoffs", TRUE,
- "format", GST_FORMAT_TIME,
- "sizetype", 2,
- "sizemax", (int) 480 * sizeof (gfloat),
- "datarate", (int) 48000 * sizeof (gfloat), NULL);
- g_signal_connect (hsrc->element, "handoff",
- G_CALLBACK (src_handoff_float32_audiointerleaved), GINT_TO_POINTER (2));
- gst_harness_play (hsrc);
-
- gst_harness_crank_single_clock_wait (hsrc);
- forward_check_event (h, hsrc, GST_EVENT_STREAM_START);
- forward_check_event (h, hsrc, GST_EVENT_CAPS);
- forward_check_event (h, hsrc, GST_EVENT_SEGMENT);
- gst_harness_push (h, gst_harness_pull (hsrc)); /* buffer */
-
- for (i = 0; i < 24; i++) {
- gst_harness_crank_single_clock_wait (hsrc);
- forward_check_event (h, hsrc, GST_EVENT_CAPS);
- gst_harness_push (h, gst_harness_pull (hsrc)); /* buffer */
- }
-
- gst_harness_crank_single_clock_wait (h);
-
-
- gst_event_unref (gst_harness_pull_event (h)); /* stream-start */
- ev = gst_harness_pull_event (h); /* caps */
- fail_unless_equals_int (GST_EVENT_CAPS, GST_EVENT_TYPE (ev));
-
- caps = gst_caps_new_simple ("audio/x-raw",
- "format", G_TYPE_STRING, GST_AUDIO_NE (F32),
- "channels", G_TYPE_INT, 2,
- "layout", G_TYPE_STRING, "interleaved",
- "rate", G_TYPE_INT, 48000, "channel-mask", GST_TYPE_BITMASK,
- (guint64) 0x9, NULL);
-
- gst_event_parse_caps (ev, &ecaps);
- gst_check_caps_equal (ecaps, caps);
- gst_caps_unref (caps);
- gst_event_unref (ev);
-
- /* eat the caps processing */
- gst_harness_crank_single_clock_wait (h);
- for (i = 0; i < 23; i++)
- gst_harness_crank_single_clock_wait (h);
- fail_unless_equals_uint64 (gst_clock_get_time (GST_ELEMENT_CLOCK
- (h->element)), 750 * GST_MSECOND);
-
- buffer = gst_harness_pull (h);
- sink_handoff_float32 (NULL, buffer, NULL, GUINT_TO_POINTER (3));
- gst_buffer_unref (buffer);
- fail_unless_equals_int (gst_harness_buffers_received (h), 1);
-
- for (i = 0; i < 50; i++) {
- gst_harness_crank_single_clock_wait (hsrc);
- forward_check_event (h, hsrc, GST_EVENT_CAPS);
- gst_harness_push (h, gst_harness_pull (hsrc)); /* buffer */
- }
- for (i = 0; i < 25; i++)
- gst_harness_crank_single_clock_wait (h);
- fail_unless_equals_uint64 (gst_clock_get_time (GST_ELEMENT_CLOCK
- (h->element)), 1000 * GST_MSECOND);
- buffer = gst_harness_pull (h);
- sink_handoff_float32 (NULL, buffer, NULL, GUINT_TO_POINTER (3));
- gst_buffer_unref (buffer);
- fail_unless_equals_int (gst_harness_buffers_received (h), 2);
-
- for (i = 0; i < 25; i++) {
- gst_harness_crank_single_clock_wait (hsrc);
- forward_check_event (h, hsrc, GST_EVENT_CAPS);
- gst_harness_push (h, gst_harness_pull (hsrc)); /* buffer */
- }
- for (i = 0; i < 25; i++)
- gst_harness_crank_single_clock_wait (h);
- fail_unless_equals_uint64 (gst_clock_get_time (GST_ELEMENT_CLOCK
- (h->element)), 1250 * GST_MSECOND);
- buffer = gst_harness_pull (h);
- sink_handoff_float32 (NULL, buffer, NULL, GUINT_TO_POINTER (3));
- gst_buffer_unref (buffer);
- fail_unless_equals_int (gst_harness_buffers_received (h), 3);
-
- gst_harness_push_event (h, gst_event_new_eos ());
-
- for (i = 0; i < 25; i++)
- gst_harness_crank_single_clock_wait (h);
- fail_unless_equals_uint64 (gst_clock_get_time (GST_ELEMENT_CLOCK
- (h->element)), 1500 * GST_MSECOND);
- buffer = gst_harness_pull (h);
- sink_handoff_float32 (NULL, buffer, NULL, GUINT_TO_POINTER (3));
- gst_buffer_unref (buffer);
-
- fail_unless_equals_int (gst_harness_buffers_received (h), 4);
-
- gst_harness_teardown (h2);
- gst_harness_teardown (h);
- gst_harness_teardown (hsrc);
- gst_object_unref (audiointerleave);
-}
-
-GST_END_TEST;
-
-static Suite *
-audiointerleave_suite (void)
-{
- Suite *s = suite_create ("audiointerleave");
- TCase *tc_chain = tcase_create ("general");
-
- suite_add_tcase (s, tc_chain);
- tcase_set_timeout (tc_chain, 180);
- tcase_add_test (tc_chain, test_create_and_unref);
- tcase_add_test (tc_chain, test_request_pads);
- tcase_add_test (tc_chain, test_audiointerleave_2ch);
- tcase_add_test (tc_chain, test_audiointerleave_2ch_1eos);
- tcase_add_test (tc_chain, test_audiointerleave_2ch_pipeline_audiointerleaved);
- tcase_add_test (tc_chain,
- test_audiointerleave_2ch_pipeline_non_audiointerleaved);
- tcase_add_test (tc_chain, test_audiointerleave_2ch_pipeline_input_chanpos);
- tcase_add_test (tc_chain, test_audiointerleave_2ch_pipeline_custom_chanpos);
- tcase_add_test (tc_chain, test_audiointerleave_2ch_pipeline_no_chanpos);
- tcase_add_test (tc_chain, test_audiointerleave_2ch_smallbuf);
-
- return s;
-}
-
-GST_CHECK_MAIN (audiointerleave);
diff --git a/tests/check/elements/audiomixer.c b/tests/check/elements/audiomixer.c
deleted file mode 100644
index 4a8a8233b..000000000
--- a/tests/check/elements/audiomixer.c
+++ /dev/null
@@ -1,1894 +0,0 @@
-/* GStreamer
- *
- * unit test for audiomixer
- *
- * Copyright (C) 2005 Thomas Vander Stichele <thomas at apestaart dot org>
- * Copyright (C) 2013 Sebastian Dröge <sebastian@centricular.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., 51 Franklin St, Fifth Floor,
- * Boston, MA 02110-1301, USA.
- */
-
-#ifdef HAVE_CONFIG_H
-# include <config.h>
-#endif
-
-#ifdef HAVE_VALGRIND
-# include <valgrind/valgrind.h>
-#endif
-
-#include <unistd.h>
-
-#include <gst/check/gstcheck.h>
-#include <gst/check/gstconsistencychecker.h>
-#include <gst/audio/audio.h>
-#include <gst/base/gstbasesrc.h>
-#include <gst/controller/gstdirectcontrolbinding.h>
-#include <gst/controller/gstinterpolationcontrolsource.h>
-
-static GMainLoop *main_loop;
-
-/* fixtures */
-
-static void
-test_setup (void)
-{
- main_loop = g_main_loop_new (NULL, FALSE);
-}
-
-static void
-test_teardown (void)
-{
- g_main_loop_unref (main_loop);
- main_loop = NULL;
-}
-
-
-/* some test helpers */
-
-static GstElement *
-setup_pipeline (GstElement * audiomixer, gint num_srcs, GstElement * capsfilter)
-{
- GstElement *pipeline, *src, *sink;
- gint i;
-
- pipeline = gst_pipeline_new ("pipeline");
- if (!audiomixer) {
- audiomixer = gst_element_factory_make ("audiomixer", "audiomixer");
- }
-
- sink = gst_element_factory_make ("fakesink", "sink");
- gst_bin_add_many (GST_BIN (pipeline), audiomixer, sink, NULL);
-
- if (capsfilter) {
- gst_bin_add (GST_BIN (pipeline), capsfilter);
- gst_element_link_many (audiomixer, capsfilter, sink, NULL);
- } else {
- gst_element_link (audiomixer, sink);
- }
-
- for (i = 0; i < num_srcs; i++) {
- src = gst_element_factory_make ("audiotestsrc", NULL);
- g_object_set (src, "wave", 4, NULL); /* silence */
- gst_bin_add (GST_BIN (pipeline), src);
- gst_element_link (src, audiomixer);
- }
- return pipeline;
-}
-
-static GstCaps *
-get_element_sink_pad_caps (GstElement * pipeline, const gchar * element_name)
-{
- GstElement *sink;
- GstCaps *caps;
- GstPad *pad;
-
- sink = gst_bin_get_by_name (GST_BIN (pipeline), "sink");
- pad = gst_element_get_static_pad (sink, "sink");
- caps = gst_pad_get_current_caps (pad);
- gst_object_unref (pad);
- gst_object_unref (sink);
-
- return caps;
-}
-
-static void
-set_state_and_wait (GstElement * pipeline, GstState state)
-{
- GstStateChangeReturn state_res;
-
- /* prepare paused/playing */
- state_res = gst_element_set_state (pipeline, state);
- ck_assert_int_ne (state_res, GST_STATE_CHANGE_FAILURE);
-
- /* wait for preroll */
- state_res = gst_element_get_state (pipeline, NULL, NULL, GST_CLOCK_TIME_NONE);
- ck_assert_int_ne (state_res, GST_STATE_CHANGE_FAILURE);
-}
-
-static gboolean
-set_playing (GstElement * element)
-{
- GstStateChangeReturn state_res;
-
- state_res = gst_element_set_state (element, GST_STATE_PLAYING);
- ck_assert_int_ne (state_res, GST_STATE_CHANGE_FAILURE);
-
- return FALSE;
-}
-
-static void
-play_and_wait (GstElement * pipeline)
-{
- GstStateChangeReturn state_res;
-
- g_idle_add ((GSourceFunc) set_playing, pipeline);
-
- GST_INFO ("running main loop");
- g_main_loop_run (main_loop);
-
- state_res = gst_element_set_state (pipeline, GST_STATE_NULL);
- ck_assert_int_ne (state_res, GST_STATE_CHANGE_FAILURE);
-}
-
-static void
-message_received (GstBus * bus, GstMessage * message, GstPipeline * bin)
-{
- GST_INFO ("bus message from \"%" GST_PTR_FORMAT "\": %" GST_PTR_FORMAT,
- GST_MESSAGE_SRC (message), message);
-
- switch (message->type) {
- case GST_MESSAGE_EOS:
- g_main_loop_quit (main_loop);
- break;
- case GST_MESSAGE_WARNING:{
- GError *gerror;
- gchar *debug;
-
- gst_message_parse_warning (message, &gerror, &debug);
- gst_object_default_error (GST_MESSAGE_SRC (message), gerror, debug);
- g_error_free (gerror);
- g_free (debug);
- break;
- }
- case GST_MESSAGE_ERROR:{
- GError *gerror;
- gchar *debug;
-
- gst_message_parse_error (message, &gerror, &debug);
- gst_object_default_error (GST_MESSAGE_SRC (message), gerror, debug);
- g_error_free (gerror);
- g_free (debug);
- g_main_loop_quit (main_loop);
- break;
- }
- default:
- break;
- }
-}
-
-static GstBuffer *
-new_buffer (gsize num_bytes, gint data, GstClockTime ts, GstClockTime dur,
- GstBufferFlags flags)
-{
- GstMapInfo map;
- GstBuffer *buffer = gst_buffer_new_and_alloc (num_bytes);
-
- gst_buffer_map (buffer, &map, GST_MAP_WRITE);
- memset (map.data, data, map.size);
- gst_buffer_unmap (buffer, &map);
- GST_BUFFER_TIMESTAMP (buffer) = ts;
- GST_BUFFER_DURATION (buffer) = dur;
- if (flags)
- GST_BUFFER_FLAG_SET (buffer, flags);
- GST_DEBUG ("created buffer %p", buffer);
- return buffer;
-}
-
-/* make sure downstream gets a CAPS event before buffers are sent */
-GST_START_TEST (test_caps)
-{
- GstElement *pipeline;
- GstCaps *caps;
-
- /* build pipeline */
- pipeline = setup_pipeline (NULL, 1, NULL);
-
- /* prepare playing */
- set_state_and_wait (pipeline, GST_STATE_PAUSED);
-
- /* check caps on fakesink */
- caps = get_element_sink_pad_caps (pipeline, "sink");
- fail_unless (caps != NULL);
- gst_caps_unref (caps);
-
- gst_element_set_state (pipeline, GST_STATE_NULL);
- gst_object_unref (pipeline);
-}
-
-GST_END_TEST;
-
-/* check that caps set on the property are honoured */
-GST_START_TEST (test_filter_caps)
-{
- GstElement *pipeline, *audiomixer, *capsfilter;
- GstCaps *filter_caps, *caps;
-
- filter_caps = gst_caps_new_simple ("audio/x-raw",
- "format", G_TYPE_STRING, GST_AUDIO_NE (F32),
- "layout", G_TYPE_STRING, "interleaved",
- "rate", G_TYPE_INT, 44100, "channels", G_TYPE_INT, 1,
- "channel-mask", GST_TYPE_BITMASK, (guint64) 0x04, NULL);
-
- capsfilter = gst_element_factory_make ("capsfilter", NULL);
-
- /* build pipeline */
- audiomixer = gst_element_factory_make ("audiomixer", NULL);
- g_object_set (capsfilter, "caps", filter_caps, NULL);
- pipeline = setup_pipeline (audiomixer, 1, capsfilter);
-
- /* prepare playing */
- set_state_and_wait (pipeline, GST_STATE_PAUSED);
-
- /* check caps on fakesink */
- caps = get_element_sink_pad_caps (pipeline, "sink");
- fail_unless (caps != NULL);
- GST_INFO_OBJECT (pipeline, "received caps: %" GST_PTR_FORMAT, caps);
- fail_unless (gst_caps_is_equal_fixed (caps, filter_caps));
- gst_caps_unref (caps);
-
- gst_element_set_state (pipeline, GST_STATE_NULL);
- gst_object_unref (pipeline);
-
- gst_caps_unref (filter_caps);
-}
-
-GST_END_TEST;
-
-static GstFormat format = GST_FORMAT_UNDEFINED;
-static gint64 position = -1;
-
-static void
-test_event_message_received (GstBus * bus, GstMessage * message,
- GstPipeline * bin)
-{
- GST_INFO ("bus message from \"%" GST_PTR_FORMAT "\": %" GST_PTR_FORMAT,
- GST_MESSAGE_SRC (message), message);
-
- switch (message->type) {
- case GST_MESSAGE_SEGMENT_DONE:
- gst_message_parse_segment_done (message, &format, &position);
- GST_INFO ("received segment_done : %" G_GINT64_FORMAT, position);
- g_main_loop_quit (main_loop);
- break;
- default:
- g_assert_not_reached ();
- break;
- }
-}
-
-
-GST_START_TEST (test_event)
-{
- GstElement *bin, *src1, *src2, *audiomixer, *sink;
- GstBus *bus;
- GstEvent *seek_event;
- gboolean res;
- GstPad *srcpad, *sinkpad;
- GstStreamConsistency *chk_1, *chk_2, *chk_3;
-
- GST_INFO ("preparing test");
-
- /* build pipeline */
- bin = gst_pipeline_new ("pipeline");
- bus = gst_element_get_bus (bin);
- gst_bus_add_signal_watch_full (bus, G_PRIORITY_HIGH);
-
- src1 = gst_element_factory_make ("audiotestsrc", "src1");
- g_object_set (src1, "wave", 4, NULL); /* silence */
- src2 = gst_element_factory_make ("audiotestsrc", "src2");
- g_object_set (src2, "wave", 4, NULL); /* silence */
- audiomixer = gst_element_factory_make ("audiomixer", "audiomixer");
- sink = gst_element_factory_make ("fakesink", "sink");
- gst_bin_add_many (GST_BIN (bin), src1, src2, audiomixer, sink, NULL);
-
- res = gst_element_link (src1, audiomixer);
- fail_unless (res == TRUE, NULL);
- res = gst_element_link (src2, audiomixer);
- fail_unless (res == TRUE, NULL);
- res = gst_element_link (audiomixer, sink);
- fail_unless (res == TRUE, NULL);
-
- srcpad = gst_element_get_static_pad (audiomixer, "src");
- chk_3 = gst_consistency_checker_new (srcpad);
- gst_object_unref (srcpad);
-
- /* create consistency checkers for the pads */
- srcpad = gst_element_get_static_pad (src1, "src");
- chk_1 = gst_consistency_checker_new (srcpad);
- sinkpad = gst_pad_get_peer (srcpad);
- gst_consistency_checker_add_pad (chk_3, sinkpad);
- gst_object_unref (sinkpad);
- gst_object_unref (srcpad);
-
- srcpad = gst_element_get_static_pad (src2, "src");
- chk_2 = gst_consistency_checker_new (srcpad);
- sinkpad = gst_pad_get_peer (srcpad);
- gst_consistency_checker_add_pad (chk_3, sinkpad);
- gst_object_unref (sinkpad);
- gst_object_unref (srcpad);
-
- seek_event = gst_event_new_seek (1.0, GST_FORMAT_TIME,
- GST_SEEK_FLAG_SEGMENT | GST_SEEK_FLAG_FLUSH,
- GST_SEEK_TYPE_SET, (GstClockTime) 0,
- GST_SEEK_TYPE_SET, (GstClockTime) 2 * GST_SECOND);
-
- format = GST_FORMAT_UNDEFINED;
- position = -1;
-
- g_signal_connect (bus, "message::segment-done",
- (GCallback) test_event_message_received, bin);
- g_signal_connect (bus, "message::error", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::warning", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::eos", (GCallback) message_received, bin);
-
- GST_INFO ("starting test");
-
- /* prepare playing */
- set_state_and_wait (bin, GST_STATE_PAUSED);
-
- res = gst_element_send_event (bin, seek_event);
- fail_unless (res == TRUE, NULL);
-
- /* run pipeline */
- play_and_wait (bin);
-
- ck_assert_int_eq (position, 2 * GST_SECOND);
-
- /* cleanup */
- gst_consistency_checker_free (chk_1);
- gst_consistency_checker_free (chk_2);
- gst_consistency_checker_free (chk_3);
- gst_bus_remove_signal_watch (bus);
- gst_object_unref (bus);
- gst_object_unref (bin);
-}
-
-GST_END_TEST;
-
-static guint play_count = 0;
-static GstEvent *play_seek_event = NULL;
-
-static void
-test_play_twice_message_received (GstBus * bus, GstMessage * message,
- GstElement * bin)
-{
- gboolean res;
- GstStateChangeReturn state_res;
-
- GST_INFO ("bus message from \"%" GST_PTR_FORMAT "\": %" GST_PTR_FORMAT,
- GST_MESSAGE_SRC (message), message);
-
- switch (message->type) {
- case GST_MESSAGE_SEGMENT_DONE:
- play_count++;
- if (play_count == 1) {
- state_res = gst_element_set_state (bin, GST_STATE_READY);
- ck_assert_int_ne (state_res, GST_STATE_CHANGE_FAILURE);
-
- /* prepare playing again */
- set_state_and_wait (bin, GST_STATE_PAUSED);
-
- res = gst_element_send_event (bin, gst_event_ref (play_seek_event));
- fail_unless (res == TRUE, NULL);
-
- state_res = gst_element_set_state (bin, GST_STATE_PLAYING);
- ck_assert_int_ne (state_res, GST_STATE_CHANGE_FAILURE);
- } else {
- g_main_loop_quit (main_loop);
- }
- break;
- default:
- g_assert_not_reached ();
- break;
- }
-}
-
-
-GST_START_TEST (test_play_twice)
-{
- GstElement *bin, *audiomixer;
- GstBus *bus;
- gboolean res;
- GstPad *srcpad;
- GstStreamConsistency *consist;
-
- GST_INFO ("preparing test");
-
- /* build pipeline */
- audiomixer = gst_element_factory_make ("audiomixer", "audiomixer");
- bin = setup_pipeline (audiomixer, 2, NULL);
- bus = gst_element_get_bus (bin);
- gst_bus_add_signal_watch_full (bus, G_PRIORITY_HIGH);
-
- srcpad = gst_element_get_static_pad (audiomixer, "src");
- consist = gst_consistency_checker_new (srcpad);
- gst_object_unref (srcpad);
-
- play_seek_event = gst_event_new_seek (1.0, GST_FORMAT_TIME,
- GST_SEEK_FLAG_SEGMENT | GST_SEEK_FLAG_FLUSH,
- GST_SEEK_TYPE_SET, (GstClockTime) 0,
- GST_SEEK_TYPE_SET, (GstClockTime) 2 * GST_SECOND);
-
- play_count = 0;
-
- g_signal_connect (bus, "message::segment-done",
- (GCallback) test_play_twice_message_received, bin);
- g_signal_connect (bus, "message::error", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::warning", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::eos", (GCallback) message_received, bin);
-
- GST_INFO ("starting test");
-
- /* prepare playing */
- set_state_and_wait (bin, GST_STATE_PAUSED);
-
- res = gst_element_send_event (bin, gst_event_ref (play_seek_event));
- fail_unless (res == TRUE, NULL);
-
- GST_INFO ("seeked");
-
- /* run pipeline */
- play_and_wait (bin);
-
- ck_assert_int_eq (play_count, 2);
-
- /* cleanup */
- gst_consistency_checker_free (consist);
- gst_event_unref (play_seek_event);
- gst_bus_remove_signal_watch (bus);
- gst_object_unref (bus);
- gst_object_unref (bin);
-}
-
-GST_END_TEST;
-
-GST_START_TEST (test_play_twice_then_add_and_play_again)
-{
- GstElement *bin, *src, *audiomixer;
- GstBus *bus;
- gboolean res;
- GstStateChangeReturn state_res;
- gint i;
- GstPad *srcpad;
- GstStreamConsistency *consist;
-
- GST_INFO ("preparing test");
-
- /* build pipeline */
- audiomixer = gst_element_factory_make ("audiomixer", "audiomixer");
- bin = setup_pipeline (audiomixer, 2, NULL);
- bus = gst_element_get_bus (bin);
- gst_bus_add_signal_watch_full (bus, G_PRIORITY_HIGH);
-
- srcpad = gst_element_get_static_pad (audiomixer, "src");
- consist = gst_consistency_checker_new (srcpad);
- gst_object_unref (srcpad);
-
- play_seek_event = gst_event_new_seek (1.0, GST_FORMAT_TIME,
- GST_SEEK_FLAG_SEGMENT | GST_SEEK_FLAG_FLUSH,
- GST_SEEK_TYPE_SET, (GstClockTime) 0,
- GST_SEEK_TYPE_SET, (GstClockTime) 2 * GST_SECOND);
-
- g_signal_connect (bus, "message::segment-done",
- (GCallback) test_play_twice_message_received, bin);
- g_signal_connect (bus, "message::error", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::warning", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::eos", (GCallback) message_received, bin);
-
- /* run it twice */
- for (i = 0; i < 2; i++) {
- play_count = 0;
-
- GST_INFO ("starting test-loop %d", i);
-
- /* prepare playing */
- set_state_and_wait (bin, GST_STATE_PAUSED);
-
- res = gst_element_send_event (bin, gst_event_ref (play_seek_event));
- fail_unless (res == TRUE, NULL);
-
- GST_INFO ("seeked");
-
- /* run pipeline */
- play_and_wait (bin);
-
- ck_assert_int_eq (play_count, 2);
-
- /* plug another source */
- if (i == 0) {
- src = gst_element_factory_make ("audiotestsrc", NULL);
- g_object_set (src, "wave", 4, NULL); /* silence */
- gst_bin_add (GST_BIN (bin), src);
-
- res = gst_element_link (src, audiomixer);
- fail_unless (res == TRUE, NULL);
- }
-
- gst_consistency_checker_reset (consist);
- }
-
- state_res = gst_element_set_state (bin, GST_STATE_NULL);
- ck_assert_int_ne (state_res, GST_STATE_CHANGE_FAILURE);
-
- /* cleanup */
- gst_event_unref (play_seek_event);
- gst_consistency_checker_free (consist);
- gst_bus_remove_signal_watch (bus);
- gst_object_unref (bus);
- gst_object_unref (bin);
-}
-
-GST_END_TEST;
-
-
-static GstElement *
-test_live_seeking_try_audiosrc (const gchar * factory_name)
-{
- GstElement *src;
- GstStateChangeReturn state_res;
-
- if (!(src = gst_element_factory_make (factory_name, NULL))) {
- GST_INFO ("can't make '%s', skipping", factory_name);
- return NULL;
- }
-
- /* Test that the audio source can get to ready, else skip */
- state_res = gst_element_set_state (src, GST_STATE_READY);
- gst_element_set_state (src, GST_STATE_NULL);
-
- if (state_res == GST_STATE_CHANGE_FAILURE) {
- GST_INFO_OBJECT (src, "can't go to ready, skipping");
- gst_object_unref (src);
- return NULL;
- }
-
- return src;
-}
-
-/* test failing seeks on live-sources */
-GST_START_TEST (test_live_seeking)
-{
- GstElement *bin, *src1 = NULL, *cf, *src2, *audiomixer, *sink;
- GstCaps *caps;
- GstBus *bus;
- gboolean res;
- GstPad *srcpad;
- GstPad *sinkpad;
- gint i;
- GstStreamConsistency *consist;
- /* don't use autoaudiosrc, as then we can't set anything here */
- const gchar *audio_src_factories[] = {
- "alsasrc",
- "pulseaudiosrc"
- };
-
- GST_INFO ("preparing test");
- play_seek_event = NULL;
-
- /* build pipeline */
- bin = gst_pipeline_new ("pipeline");
- bus = gst_element_get_bus (bin);
- gst_bus_add_signal_watch_full (bus, G_PRIORITY_HIGH);
-
- for (i = 0; (i < G_N_ELEMENTS (audio_src_factories) && src1 == NULL); i++) {
- src1 = test_live_seeking_try_audiosrc (audio_src_factories[i]);
- }
- if (!src1) {
- /* normal audiosources behave differently than audiotestsrc */
- GST_WARNING ("no real audiosrc found, using audiotestsrc is-live");
- src1 = gst_element_factory_make ("audiotestsrc", "src1");
- g_object_set (src1, "wave", 4, "is-live", TRUE, NULL); /* silence */
- } else {
- /* live sources ignore seeks, force eos after 2 sec (4 buffers half second
- * each)
- */
- g_object_set (src1, "num-buffers", 4, "blocksize", 44100, NULL);
- }
-
- audiomixer = gst_element_factory_make ("audiomixer", "audiomixer");
- cf = gst_element_factory_make ("capsfilter", "capsfilter");
- sink = gst_element_factory_make ("fakesink", "sink");
-
- gst_bin_add_many (GST_BIN (bin), src1, cf, audiomixer, sink, NULL);
- res = gst_element_link_many (src1, cf, audiomixer, sink, NULL);
- fail_unless (res == TRUE, NULL);
-
- /* get the caps for the livesrc, we'll reuse this for the non-live source */
- set_state_and_wait (bin, GST_STATE_PLAYING);
-
- sinkpad = gst_element_get_static_pad (sink, "sink");
- fail_unless (sinkpad != NULL);
- caps = gst_pad_get_current_caps (sinkpad);
- fail_unless (caps != NULL);
- gst_object_unref (sinkpad);
-
- gst_element_set_state (bin, GST_STATE_NULL);
-
- g_object_set (cf, "caps", caps, NULL);
-
- src2 = gst_element_factory_make ("audiotestsrc", "src2");
- g_object_set (src2, "wave", 4, NULL); /* silence */
- gst_bin_add (GST_BIN (bin), src2);
-
- res = gst_element_link_filtered (src2, audiomixer, caps);
- fail_unless (res == TRUE, NULL);
-
- gst_caps_unref (caps);
-
- play_seek_event = gst_event_new_seek (1.0, GST_FORMAT_TIME,
- GST_SEEK_FLAG_FLUSH,
- GST_SEEK_TYPE_SET, (GstClockTime) 0,
- GST_SEEK_TYPE_SET, (GstClockTime) 2 * GST_SECOND);
-
- g_signal_connect (bus, "message::error", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::warning", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::eos", (GCallback) message_received, bin);
-
- srcpad = gst_element_get_static_pad (audiomixer, "src");
- consist = gst_consistency_checker_new (srcpad);
- gst_object_unref (srcpad);
-
- GST_INFO ("starting test");
-
- /* run it twice */
- for (i = 0; i < 2; i++) {
-
- GST_INFO ("starting test-loop %d", i);
-
- /* prepare playing */
- set_state_and_wait (bin, GST_STATE_PAUSED);
-
- res = gst_element_send_event (bin, gst_event_ref (play_seek_event));
- fail_unless (res == TRUE, NULL);
-
- GST_INFO ("seeked");
-
- /* run pipeline */
- play_and_wait (bin);
-
- gst_consistency_checker_reset (consist);
- }
-
- /* cleanup */
- GST_INFO ("cleaning up");
- gst_consistency_checker_free (consist);
- if (play_seek_event)
- gst_event_unref (play_seek_event);
- gst_bus_remove_signal_watch (bus);
- gst_object_unref (bus);
- gst_object_unref (bin);
-}
-
-GST_END_TEST;
-
-/* check if adding pads work as expected */
-GST_START_TEST (test_add_pad)
-{
- GstElement *bin, *src1, *src2, *audiomixer, *sink;
- GstBus *bus;
- GstPad *srcpad;
- gboolean res;
- GstStateChangeReturn state_res;
-
- GST_INFO ("preparing test");
-
- /* build pipeline */
- bin = gst_pipeline_new ("pipeline");
- bus = gst_element_get_bus (bin);
- gst_bus_add_signal_watch_full (bus, G_PRIORITY_HIGH);
-
- src1 = gst_element_factory_make ("audiotestsrc", "src1");
- g_object_set (src1, "num-buffers", 4, "wave", /* silence */ 4, NULL);
- src2 = gst_element_factory_make ("audiotestsrc", "src2");
- /* one buffer less, we connect with 1 buffer of delay */
- g_object_set (src2, "num-buffers", 3, "wave", /* silence */ 4, NULL);
- audiomixer = gst_element_factory_make ("audiomixer", "audiomixer");
- sink = gst_element_factory_make ("fakesink", "sink");
- gst_bin_add_many (GST_BIN (bin), src1, audiomixer, sink, NULL);
-
- res = gst_element_link (src1, audiomixer);
- fail_unless (res == TRUE, NULL);
- res = gst_element_link (audiomixer, sink);
- fail_unless (res == TRUE, NULL);
-
- srcpad = gst_element_get_static_pad (audiomixer, "src");
- gst_object_unref (srcpad);
-
- g_signal_connect (bus, "message::segment-done", (GCallback) message_received,
- bin);
- g_signal_connect (bus, "message::error", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::warning", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::eos", (GCallback) message_received, bin);
-
- GST_INFO ("starting test");
-
- /* prepare playing */
- set_state_and_wait (bin, GST_STATE_PAUSED);
-
- /* add other element */
- gst_bin_add_many (GST_BIN (bin), src2, NULL);
-
- /* now link the second element */
- res = gst_element_link (src2, audiomixer);
- fail_unless (res == TRUE, NULL);
-
- /* set to PAUSED as well */
- state_res = gst_element_set_state (src2, GST_STATE_PAUSED);
- ck_assert_int_ne (state_res, GST_STATE_CHANGE_FAILURE);
-
- /* now play all */
- play_and_wait (bin);
-
- /* cleanup */
- gst_bus_remove_signal_watch (bus);
- gst_object_unref (bus);
- gst_object_unref (bin);
-}
-
-GST_END_TEST;
-
-/* check if removing pads work as expected */
-GST_START_TEST (test_remove_pad)
-{
- GstElement *bin, *src, *audiomixer, *sink;
- GstBus *bus;
- GstPad *pad, *srcpad;
- gboolean res;
- GstStateChangeReturn state_res;
-
- GST_INFO ("preparing test");
-
- /* build pipeline */
- bin = gst_pipeline_new ("pipeline");
- bus = gst_element_get_bus (bin);
- gst_bus_add_signal_watch_full (bus, G_PRIORITY_HIGH);
-
- src = gst_element_factory_make ("audiotestsrc", "src");
- g_object_set (src, "num-buffers", 4, "wave", 4, NULL);
- audiomixer = gst_element_factory_make ("audiomixer", "audiomixer");
- sink = gst_element_factory_make ("fakesink", "sink");
- gst_bin_add_many (GST_BIN (bin), src, audiomixer, sink, NULL);
-
- res = gst_element_link (src, audiomixer);
- fail_unless (res == TRUE, NULL);
- res = gst_element_link (audiomixer, sink);
- fail_unless (res == TRUE, NULL);
-
- /* create an unconnected sinkpad in audiomixer */
- pad = gst_element_get_request_pad (audiomixer, "sink_%u");
- fail_if (pad == NULL, NULL);
-
- srcpad = gst_element_get_static_pad (audiomixer, "src");
- gst_object_unref (srcpad);
-
- g_signal_connect (bus, "message::segment-done", (GCallback) message_received,
- bin);
- g_signal_connect (bus, "message::error", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::warning", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::eos", (GCallback) message_received, bin);
-
- GST_INFO ("starting test");
-
- /* prepare playing, this will not preroll as audiomixer is waiting
- * on the unconnected sinkpad. */
- state_res = gst_element_set_state (bin, GST_STATE_PAUSED);
- ck_assert_int_ne (state_res, GST_STATE_CHANGE_FAILURE);
-
- /* wait for completion for one second, will return ASYNC */
- state_res = gst_element_get_state (GST_ELEMENT (bin), NULL, NULL, GST_SECOND);
- ck_assert_int_eq (state_res, GST_STATE_CHANGE_ASYNC);
-
- /* get rid of the pad now, audiomixer should stop waiting on it and
- * continue the preroll */
- gst_element_release_request_pad (audiomixer, pad);
- gst_object_unref (pad);
-
- /* wait for completion, should work now */
- state_res =
- gst_element_get_state (GST_ELEMENT (bin), NULL, NULL,
- GST_CLOCK_TIME_NONE);
- ck_assert_int_ne (state_res, GST_STATE_CHANGE_FAILURE);
-
- /* now play all */
- play_and_wait (bin);
-
- /* cleanup */
- gst_bus_remove_signal_watch (bus);
- gst_object_unref (G_OBJECT (bus));
- gst_object_unref (G_OBJECT (bin));
-}
-
-GST_END_TEST;
-
-
-static GstBuffer *handoff_buffer = NULL;
-
-static void
-handoff_buffer_cb (GstElement * fakesink, GstBuffer * buffer, GstPad * pad,
- gpointer user_data)
-{
- GST_DEBUG ("got buffer -- SIZE: %" G_GSIZE_FORMAT
- " -- %p PTS is %" GST_TIME_FORMAT " END is %" GST_TIME_FORMAT,
- gst_buffer_get_size (buffer), buffer,
- GST_TIME_ARGS (GST_BUFFER_PTS (buffer)),
- GST_TIME_ARGS (GST_BUFFER_PTS (buffer) + GST_BUFFER_DURATION (buffer)));
-
- gst_buffer_replace (&handoff_buffer, buffer);
-}
-
-/* check if clipping works as expected */
-GST_START_TEST (test_clip)
-{
- GstSegment segment;
- GstElement *bin, *audiomixer, *sink;
- GstBus *bus;
- GstPad *sinkpad;
- gboolean res;
- GstStateChangeReturn state_res;
- GstFlowReturn ret;
- GstEvent *event;
- GstBuffer *buffer;
- GstCaps *caps;
- GstQuery *drain = gst_query_new_drain ();
-
- GST_INFO ("preparing test");
-
- /* build pipeline */
- bin = gst_pipeline_new ("pipeline");
- bus = gst_element_get_bus (bin);
- gst_bus_add_signal_watch_full (bus, G_PRIORITY_HIGH);
-
- g_signal_connect (bus, "message::error", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::warning", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::eos", (GCallback) message_received, bin);
-
- /* just an audiomixer and a fakesink */
- audiomixer = gst_element_factory_make ("audiomixer", "audiomixer");
- g_object_set (audiomixer, "output-buffer-duration", 50 * GST_MSECOND, NULL);
- sink = gst_element_factory_make ("fakesink", "sink");
- g_object_set (sink, "signal-handoffs", TRUE, NULL);
- g_signal_connect (sink, "handoff", (GCallback) handoff_buffer_cb, NULL);
- gst_bin_add_many (GST_BIN (bin), audiomixer, sink, NULL);
-
- res = gst_element_link (audiomixer, sink);
- fail_unless (res == TRUE, NULL);
-
- /* set to playing */
- state_res = gst_element_set_state (bin, GST_STATE_PLAYING);
- ck_assert_int_ne (state_res, GST_STATE_CHANGE_FAILURE);
-
- /* create an unconnected sinkpad in audiomixer, should also automatically activate
- * the pad */
- sinkpad = gst_element_get_request_pad (audiomixer, "sink_%u");
- fail_if (sinkpad == NULL, NULL);
-
- gst_pad_send_event (sinkpad, gst_event_new_stream_start ("test"));
-
- caps = gst_caps_new_simple ("audio/x-raw",
- "format", G_TYPE_STRING, GST_AUDIO_NE (S16),
- "layout", G_TYPE_STRING, "interleaved",
- "rate", G_TYPE_INT, 44100, "channels", G_TYPE_INT, 2, NULL);
-
- gst_pad_set_caps (sinkpad, caps);
- gst_caps_unref (caps);
-
- /* send segment to audiomixer */
- gst_segment_init (&segment, GST_FORMAT_TIME);
- segment.start = GST_SECOND;
- segment.stop = 2 * GST_SECOND;
- segment.time = 0;
- event = gst_event_new_segment (&segment);
- gst_pad_send_event (sinkpad, event);
-
- /* should be clipped and ok */
- buffer = new_buffer (44100, 0, 0, 250 * GST_MSECOND, 0);
- GST_DEBUG ("pushing buffer %p END is %" GST_TIME_FORMAT,
- buffer,
- GST_TIME_ARGS (GST_BUFFER_PTS (buffer) + GST_BUFFER_DURATION (buffer)));
- ret = gst_pad_chain (sinkpad, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
- /* The aggregation is done in a dedicated thread, so we can't
- * know when it is actually going to happen, so we use a DRAIN query
- * to wait for it to complete.
- */
- gst_pad_query (sinkpad, drain);
- fail_unless (handoff_buffer == NULL);
-
- /* should be partially clipped */
- buffer = new_buffer (44100, 0, 900 * GST_MSECOND, 250 * GST_MSECOND,
- GST_BUFFER_FLAG_DISCONT);
- GST_DEBUG ("pushing buffer %p START %" GST_TIME_FORMAT " -- DURATION is %"
- GST_TIME_FORMAT, buffer, GST_TIME_ARGS (GST_BUFFER_PTS (buffer)),
- GST_TIME_ARGS (GST_BUFFER_DURATION (buffer)));
- ret = gst_pad_chain (sinkpad, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
- gst_pad_query (sinkpad, drain);
-
- fail_unless (handoff_buffer != NULL);
- ck_assert_int_eq (GST_BUFFER_PTS (handoff_buffer) +
- GST_BUFFER_DURATION (handoff_buffer), 150 * GST_MSECOND);
- gst_buffer_replace (&handoff_buffer, NULL);
-
- /* should not be clipped */
- buffer = new_buffer (44100, 0, 1150 * GST_MSECOND, 250 * GST_MSECOND, 0);
- GST_DEBUG ("pushing buffer %p END is %" GST_TIME_FORMAT,
- buffer,
- GST_TIME_ARGS (GST_BUFFER_PTS (buffer) + GST_BUFFER_DURATION (buffer)));
- ret = gst_pad_chain (sinkpad, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
- gst_pad_query (sinkpad, drain);
- fail_unless (handoff_buffer != NULL);
- ck_assert_int_eq (GST_BUFFER_PTS (handoff_buffer) +
- GST_BUFFER_DURATION (handoff_buffer), 400 * GST_MSECOND);
- gst_buffer_replace (&handoff_buffer, NULL);
- fail_unless (handoff_buffer == NULL);
-
- /* should be clipped and ok */
- buffer = new_buffer (44100, 0, 2 * GST_SECOND, 250 * GST_MSECOND,
- GST_BUFFER_FLAG_DISCONT);
- GST_DEBUG ("pushing buffer %p PTS is %" GST_TIME_FORMAT
- " END is %" GST_TIME_FORMAT,
- buffer,
- GST_TIME_ARGS (GST_BUFFER_PTS (buffer)),
- GST_TIME_ARGS (GST_BUFFER_PTS (buffer) + GST_BUFFER_DURATION (buffer)));
- ret = gst_pad_chain (sinkpad, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
- gst_pad_query (sinkpad, drain);
- fail_unless (handoff_buffer == NULL);
-
- gst_element_release_request_pad (audiomixer, sinkpad);
- gst_object_unref (sinkpad);
- gst_element_set_state (bin, GST_STATE_NULL);
- gst_bus_remove_signal_watch (bus);
- gst_object_unref (bus);
- gst_object_unref (bin);
- gst_query_unref (drain);
-}
-
-GST_END_TEST;
-
-GST_START_TEST (test_duration_is_max)
-{
- GstElement *bin, *src[3], *audiomixer, *sink;
- GstStateChangeReturn state_res;
- GstFormat format = GST_FORMAT_TIME;
- gboolean res;
- gint64 duration;
-
- GST_INFO ("preparing test");
-
- /* build pipeline */
- bin = gst_pipeline_new ("pipeline");
-
- /* 3 sources, an audiomixer and a fakesink */
- src[0] = gst_element_factory_make ("audiotestsrc", NULL);
- src[1] = gst_element_factory_make ("audiotestsrc", NULL);
- src[2] = gst_element_factory_make ("audiotestsrc", NULL);
- audiomixer = gst_element_factory_make ("audiomixer", "audiomixer");
- sink = gst_element_factory_make ("fakesink", "sink");
- gst_bin_add_many (GST_BIN (bin), src[0], src[1], src[2], audiomixer, sink,
- NULL);
-
- gst_element_link (src[0], audiomixer);
- gst_element_link (src[1], audiomixer);
- gst_element_link (src[2], audiomixer);
- gst_element_link (audiomixer, sink);
-
- /* irks, duration is reset on basesrc */
- state_res = gst_element_set_state (bin, GST_STATE_PAUSED);
- fail_unless (state_res != GST_STATE_CHANGE_FAILURE, NULL);
-
- /* set durations on src */
- GST_BASE_SRC (src[0])->segment.duration = 1000;
- GST_BASE_SRC (src[1])->segment.duration = 3000;
- GST_BASE_SRC (src[2])->segment.duration = 2000;
-
- /* set to playing */
- set_state_and_wait (bin, GST_STATE_PLAYING);
-
- res = gst_element_query_duration (GST_ELEMENT (bin), format, &duration);
- fail_unless (res, NULL);
-
- ck_assert_int_eq (duration, 3000);
-
- gst_element_set_state (bin, GST_STATE_NULL);
- gst_object_unref (bin);
-}
-
-GST_END_TEST;
-
-GST_START_TEST (test_duration_unknown_overrides)
-{
- GstElement *bin, *src[3], *audiomixer, *sink;
- GstStateChangeReturn state_res;
- GstFormat format = GST_FORMAT_TIME;
- gboolean res;
- gint64 duration;
-
- GST_INFO ("preparing test");
-
- /* build pipeline */
- bin = gst_pipeline_new ("pipeline");
-
- /* 3 sources, an audiomixer and a fakesink */
- src[0] = gst_element_factory_make ("audiotestsrc", NULL);
- src[1] = gst_element_factory_make ("audiotestsrc", NULL);
- src[2] = gst_element_factory_make ("audiotestsrc", NULL);
- audiomixer = gst_element_factory_make ("audiomixer", "audiomixer");
- sink = gst_element_factory_make ("fakesink", "sink");
- gst_bin_add_many (GST_BIN (bin), src[0], src[1], src[2], audiomixer, sink,
- NULL);
-
- gst_element_link (src[0], audiomixer);
- gst_element_link (src[1], audiomixer);
- gst_element_link (src[2], audiomixer);
- gst_element_link (audiomixer, sink);
-
- /* irks, duration is reset on basesrc */
- state_res = gst_element_set_state (bin, GST_STATE_PAUSED);
- fail_unless (state_res != GST_STATE_CHANGE_FAILURE, NULL);
-
- /* set durations on src */
- GST_BASE_SRC (src[0])->segment.duration = GST_CLOCK_TIME_NONE;
- GST_BASE_SRC (src[1])->segment.duration = 3000;
- GST_BASE_SRC (src[2])->segment.duration = 2000;
-
- /* set to playing */
- set_state_and_wait (bin, GST_STATE_PLAYING);
-
- res = gst_element_query_duration (GST_ELEMENT (bin), format, &duration);
- fail_unless (res, NULL);
-
- ck_assert_int_eq (duration, GST_CLOCK_TIME_NONE);
-
- gst_element_set_state (bin, GST_STATE_NULL);
- gst_object_unref (bin);
-}
-
-GST_END_TEST;
-
-
-static gboolean looped = FALSE;
-
-static void
-loop_segment_done (GstBus * bus, GstMessage * message, GstElement * bin)
-{
- GST_INFO ("bus message from \"%" GST_PTR_FORMAT "\": %" GST_PTR_FORMAT,
- GST_MESSAGE_SRC (message), message);
-
- if (looped) {
- g_main_loop_quit (main_loop);
- } else {
- GstEvent *seek_event;
- gboolean res;
-
- seek_event = gst_event_new_seek (1.0, GST_FORMAT_TIME,
- GST_SEEK_FLAG_SEGMENT,
- GST_SEEK_TYPE_SET, (GstClockTime) 0,
- GST_SEEK_TYPE_SET, (GstClockTime) 1 * GST_SECOND);
-
- res = gst_element_send_event (bin, seek_event);
- fail_unless (res == TRUE, NULL);
- looped = TRUE;
- }
-}
-
-GST_START_TEST (test_loop)
-{
- GstElement *bin;
- GstBus *bus;
- GstEvent *seek_event;
- gboolean res;
-
- GST_INFO ("preparing test");
-
- /* build pipeline */
- bin = setup_pipeline (NULL, 2, NULL);
- bus = gst_element_get_bus (bin);
- gst_bus_add_signal_watch_full (bus, G_PRIORITY_HIGH);
-
- seek_event = gst_event_new_seek (1.0, GST_FORMAT_TIME,
- GST_SEEK_FLAG_SEGMENT | GST_SEEK_FLAG_FLUSH,
- GST_SEEK_TYPE_SET, (GstClockTime) 0,
- GST_SEEK_TYPE_SET, (GstClockTime) 1 * GST_SECOND);
-
- g_signal_connect (bus, "message::segment-done",
- (GCallback) loop_segment_done, bin);
- g_signal_connect (bus, "message::error", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::warning", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::eos", (GCallback) message_received, bin);
-
- GST_INFO ("starting test");
-
- /* prepare playing */
- set_state_and_wait (bin, GST_STATE_PAUSED);
-
- res = gst_element_send_event (bin, seek_event);
- fail_unless (res == TRUE, NULL);
-
- /* run pipeline */
- play_and_wait (bin);
-
- fail_unless (looped);
-
- /* cleanup */
- gst_bus_remove_signal_watch (bus);
- gst_object_unref (bus);
- gst_object_unref (bin);
-}
-
-GST_END_TEST;
-
-GST_START_TEST (test_flush_start_flush_stop)
-{
- GstPadTemplate *sink_template;
- GstPad *tmppad, *srcpad1, *sinkpad1, *sinkpad2, *audiomixer_src;
- GstElement *pipeline, *src1, *src2, *audiomixer, *sink;
-
- GST_INFO ("preparing test");
-
- /* build pipeline */
- pipeline = gst_pipeline_new ("pipeline");
- src1 = gst_element_factory_make ("audiotestsrc", "src1");
- g_object_set (src1, "wave", 4, NULL); /* silence */
- src2 = gst_element_factory_make ("audiotestsrc", "src2");
- g_object_set (src2, "wave", 4, NULL); /* silence */
- audiomixer = gst_element_factory_make ("audiomixer", "audiomixer");
- sink = gst_element_factory_make ("fakesink", "sink");
- gst_bin_add_many (GST_BIN (pipeline), src1, src2, audiomixer, sink, NULL);
-
- sink_template =
- gst_element_class_get_pad_template (GST_ELEMENT_GET_CLASS (audiomixer),
- "sink_%u");
- fail_unless (GST_IS_PAD_TEMPLATE (sink_template));
- sinkpad1 = gst_element_request_pad (audiomixer, sink_template, NULL, NULL);
- srcpad1 = gst_element_get_static_pad (src1, "src");
- gst_pad_link (srcpad1, sinkpad1);
-
- sinkpad2 = gst_element_request_pad (audiomixer, sink_template, NULL, NULL);
- tmppad = gst_element_get_static_pad (src2, "src");
- gst_pad_link (tmppad, sinkpad2);
- gst_object_unref (tmppad);
-
- gst_element_link (audiomixer, sink);
-
- /* prepare playing */
- set_state_and_wait (pipeline, GST_STATE_PLAYING);
-
- audiomixer_src = gst_element_get_static_pad (audiomixer, "src");
- fail_if (GST_PAD_IS_FLUSHING (audiomixer_src));
- gst_pad_send_event (sinkpad1, gst_event_new_flush_start ());
- fail_if (GST_PAD_IS_FLUSHING (audiomixer_src));
- fail_unless (GST_PAD_IS_FLUSHING (sinkpad1));
- /* Hold the streamlock to make sure the flush stop is not between
- the attempted push of a segment event and of the following buffer. */
- GST_PAD_STREAM_LOCK (srcpad1);
- gst_pad_send_event (sinkpad1, gst_event_new_flush_stop (TRUE));
- GST_PAD_STREAM_UNLOCK (srcpad1);
- fail_if (GST_PAD_IS_FLUSHING (audiomixer_src));
- fail_if (GST_PAD_IS_FLUSHING (sinkpad1));
- gst_object_unref (audiomixer_src);
-
- gst_element_release_request_pad (audiomixer, sinkpad1);
- gst_object_unref (sinkpad1);
- gst_element_release_request_pad (audiomixer, sinkpad2);
- gst_object_unref (sinkpad2);
- gst_object_unref (srcpad1);
-
- /* cleanup */
- gst_element_set_state (pipeline, GST_STATE_NULL);
- gst_object_unref (pipeline);
-}
-
-GST_END_TEST;
-
-static void
-handoff_buffer_collect_cb (GstElement * fakesink, GstBuffer * buffer,
- GstPad * pad, gpointer user_data)
-{
- GList **received_buffers = user_data;
-
- GST_DEBUG ("got buffer %p", buffer);
- *received_buffers =
- g_list_append (*received_buffers, gst_buffer_ref (buffer));
-}
-
-typedef void (*SendBuffersFunction) (GstPad * pad1, GstPad * pad2);
-typedef void (*CheckBuffersFunction) (GList * buffers);
-
-static void
-run_sync_test (SendBuffersFunction send_buffers,
- CheckBuffersFunction check_buffers)
-{
- GstSegment segment;
- GstElement *bin, *audiomixer, *queue1, *queue2, *sink;
- GstBus *bus;
- GstPad *sinkpad1, *sinkpad2;
- GstPad *queue1_sinkpad, *queue2_sinkpad;
- GstPad *pad;
- gboolean res;
- GstStateChangeReturn state_res;
- GstEvent *event;
- GstCaps *caps;
- GList *received_buffers = NULL;
-
- GST_INFO ("preparing test");
-
- /* build pipeline */
- bin = gst_pipeline_new ("pipeline");
- bus = gst_element_get_bus (bin);
- gst_bus_add_signal_watch_full (bus, G_PRIORITY_HIGH);
-
- g_signal_connect (bus, "message::error", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::warning", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::eos", (GCallback) message_received, bin);
-
- /* just an audiomixer and a fakesink */
- queue1 = gst_element_factory_make ("queue", "queue1");
- queue2 = gst_element_factory_make ("queue", "queue2");
- audiomixer = gst_element_factory_make ("audiomixer", "audiomixer");
- g_object_set (audiomixer, "output-buffer-duration", 500 * GST_MSECOND, NULL);
- sink = gst_element_factory_make ("fakesink", "sink");
- g_object_set (sink, "signal-handoffs", TRUE, NULL);
- g_signal_connect (sink, "handoff", (GCallback) handoff_buffer_collect_cb,
- &received_buffers);
- gst_bin_add_many (GST_BIN (bin), queue1, queue2, audiomixer, sink, NULL);
-
- res = gst_element_link (audiomixer, sink);
- fail_unless (res == TRUE, NULL);
-
- /* set to paused */
- state_res = gst_element_set_state (bin, GST_STATE_PAUSED);
- ck_assert_int_ne (state_res, GST_STATE_CHANGE_FAILURE);
-
- /* create an unconnected sinkpad in audiomixer, should also automatically activate
- * the pad */
- sinkpad1 = gst_element_get_request_pad (audiomixer, "sink_%u");
- fail_if (sinkpad1 == NULL, NULL);
-
- queue1_sinkpad = gst_element_get_static_pad (queue1, "sink");
- pad = gst_element_get_static_pad (queue1, "src");
- fail_unless (gst_pad_link (pad, sinkpad1) == GST_PAD_LINK_OK);
- gst_object_unref (pad);
-
- sinkpad2 = gst_element_get_request_pad (audiomixer, "sink_%u");
- fail_if (sinkpad2 == NULL, NULL);
-
- queue2_sinkpad = gst_element_get_static_pad (queue2, "sink");
- pad = gst_element_get_static_pad (queue2, "src");
- fail_unless (gst_pad_link (pad, sinkpad2) == GST_PAD_LINK_OK);
- gst_object_unref (pad);
-
- gst_pad_send_event (queue1_sinkpad, gst_event_new_stream_start ("test"));
- gst_pad_send_event (queue2_sinkpad, gst_event_new_stream_start ("test"));
-
- caps = gst_caps_new_simple ("audio/x-raw",
- "format", G_TYPE_STRING, GST_AUDIO_NE (S16),
- "layout", G_TYPE_STRING, "interleaved",
- "rate", G_TYPE_INT, 1000, "channels", G_TYPE_INT, 1, NULL);
-
- gst_pad_set_caps (queue1_sinkpad, caps);
- gst_pad_set_caps (queue2_sinkpad, caps);
- gst_caps_unref (caps);
-
- /* send segment to audiomixer */
- gst_segment_init (&segment, GST_FORMAT_TIME);
- event = gst_event_new_segment (&segment);
- gst_pad_send_event (queue1_sinkpad, gst_event_ref (event));
- gst_pad_send_event (queue2_sinkpad, event);
-
- /* Push buffers */
- send_buffers (queue1_sinkpad, queue2_sinkpad);
-
- /* Set PLAYING */
- g_idle_add ((GSourceFunc) set_playing, bin);
-
- /* Collect buffers and messages */
- g_main_loop_run (main_loop);
-
- /* Here we get once we got EOS, for errors we failed */
-
- check_buffers (received_buffers);
-
- g_list_free_full (received_buffers, (GDestroyNotify) gst_buffer_unref);
-
- gst_element_release_request_pad (audiomixer, sinkpad1);
- gst_object_unref (sinkpad1);
- gst_object_unref (queue1_sinkpad);
- gst_element_release_request_pad (audiomixer, sinkpad2);
- gst_object_unref (sinkpad2);
- gst_object_unref (queue2_sinkpad);
- gst_element_set_state (bin, GST_STATE_NULL);
- gst_bus_remove_signal_watch (bus);
- gst_object_unref (bus);
- gst_object_unref (bin);
-}
-
-static void
-send_buffers_sync (GstPad * pad1, GstPad * pad2)
-{
- GstBuffer *buffer;
- GstFlowReturn ret;
-
- buffer = new_buffer (2000, 1, 1 * GST_SECOND, 1 * GST_SECOND, 0);
- ret = gst_pad_chain (pad1, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
-
- buffer = new_buffer (2000, 1, 2 * GST_SECOND, 1 * GST_SECOND, 0);
- ret = gst_pad_chain (pad1, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
-
- gst_pad_send_event (pad1, gst_event_new_eos ());
-
- buffer = new_buffer (2000, 2, 2 * GST_SECOND, 1 * GST_SECOND, 0);
- ret = gst_pad_chain (pad2, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
-
- buffer = new_buffer (2000, 2, 3 * GST_SECOND, 1 * GST_SECOND, 0);
- ret = gst_pad_chain (pad2, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
-
- gst_pad_send_event (pad2, gst_event_new_eos ());
-}
-
-static void
-check_buffers_sync (GList * received_buffers)
-{
- GstBuffer *buffer;
- GList *l;
- gint i;
- GstMapInfo map;
-
- /* Should have 8 * 0.5s buffers */
- fail_unless_equals_int (g_list_length (received_buffers), 8);
- for (i = 0, l = received_buffers; l; l = l->next, i++) {
- buffer = l->data;
-
- gst_buffer_map (buffer, &map, GST_MAP_READ);
-
- if (i == 0 && GST_BUFFER_TIMESTAMP (buffer) == 0) {
- fail_unless (map.data[0] == 0);
- fail_unless (map.data[map.size - 1] == 0);
- } else if (i == 1 && GST_BUFFER_TIMESTAMP (buffer) == 500 * GST_MSECOND) {
- fail_unless (map.data[0] == 0);
- fail_unless (map.data[map.size - 1] == 0);
- } else if (i == 2 && GST_BUFFER_TIMESTAMP (buffer) == 1000 * GST_MSECOND) {
- fail_unless (map.data[0] == 1);
- fail_unless (map.data[map.size - 1] == 1);
- } else if (i == 3 && GST_BUFFER_TIMESTAMP (buffer) == 1500 * GST_MSECOND) {
- fail_unless (map.data[0] == 1);
- fail_unless (map.data[map.size - 1] == 1);
- } else if (i == 4 && GST_BUFFER_TIMESTAMP (buffer) == 2000 * GST_MSECOND) {
- fail_unless (map.data[0] == 3);
- fail_unless (map.data[map.size - 1] == 3);
- } else if (i == 5 && GST_BUFFER_TIMESTAMP (buffer) == 2500 * GST_MSECOND) {
- fail_unless (map.data[0] == 3);
- fail_unless (map.data[map.size - 1] == 3);
- } else if (i == 6 && GST_BUFFER_TIMESTAMP (buffer) == 3000 * GST_MSECOND) {
- fail_unless (map.data[0] == 2);
- fail_unless (map.data[map.size - 1] == 2);
- } else if (i == 7 && GST_BUFFER_TIMESTAMP (buffer) == 3500 * GST_MSECOND) {
- fail_unless (map.data[0] == 2);
- fail_unless (map.data[map.size - 1] == 2);
- } else {
- g_assert_not_reached ();
- }
-
- gst_buffer_unmap (buffer, &map);
-
- }
-}
-
-GST_START_TEST (test_sync)
-{
- run_sync_test (send_buffers_sync, check_buffers_sync);
-}
-
-GST_END_TEST;
-
-static void
-send_buffers_sync_discont (GstPad * pad1, GstPad * pad2)
-{
- GstBuffer *buffer;
- GstFlowReturn ret;
-
- buffer = new_buffer (2000, 1, 1 * GST_SECOND, 1 * GST_SECOND, 0);
- ret = gst_pad_chain (pad1, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
-
- buffer = new_buffer (2000, 1, 3 * GST_SECOND, 1 * GST_SECOND,
- GST_BUFFER_FLAG_DISCONT);
- ret = gst_pad_chain (pad1, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
-
- gst_pad_send_event (pad1, gst_event_new_eos ());
-
- buffer = new_buffer (2000, 2, 2 * GST_SECOND, 1 * GST_SECOND, 0);
- ret = gst_pad_chain (pad2, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
-
- buffer = new_buffer (2000, 2, 3 * GST_SECOND, 1 * GST_SECOND, 0);
- ret = gst_pad_chain (pad2, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
-
- gst_pad_send_event (pad2, gst_event_new_eos ());
-}
-
-static void
-check_buffers_sync_discont (GList * received_buffers)
-{
- GstBuffer *buffer;
- GList *l;
- gint i;
- GstMapInfo map;
-
- /* Should have 8 * 0.5s buffers */
- fail_unless_equals_int (g_list_length (received_buffers), 8);
- for (i = 0, l = received_buffers; l; l = l->next, i++) {
- buffer = l->data;
-
- gst_buffer_map (buffer, &map, GST_MAP_READ);
-
- if (i == 0 && GST_BUFFER_TIMESTAMP (buffer) == 0) {
- fail_unless (map.data[0] == 0);
- fail_unless (map.data[map.size - 1] == 0);
- } else if (i == 1 && GST_BUFFER_TIMESTAMP (buffer) == 500 * GST_MSECOND) {
- fail_unless (map.data[0] == 0);
- fail_unless (map.data[map.size - 1] == 0);
- } else if (i == 2 && GST_BUFFER_TIMESTAMP (buffer) == 1000 * GST_MSECOND) {
- fail_unless (map.data[0] == 1);
- fail_unless (map.data[map.size - 1] == 1);
- } else if (i == 3 && GST_BUFFER_TIMESTAMP (buffer) == 1500 * GST_MSECOND) {
- fail_unless (map.data[0] == 1);
- fail_unless (map.data[map.size - 1] == 1);
- } else if (i == 4 && GST_BUFFER_TIMESTAMP (buffer) == 2000 * GST_MSECOND) {
- fail_unless (map.data[0] == 2);
- fail_unless (map.data[map.size - 1] == 2);
- } else if (i == 5 && GST_BUFFER_TIMESTAMP (buffer) == 2500 * GST_MSECOND) {
- fail_unless (map.data[0] == 2);
- fail_unless (map.data[map.size - 1] == 2);
- } else if (i == 6 && GST_BUFFER_TIMESTAMP (buffer) == 3000 * GST_MSECOND) {
- fail_unless (map.data[0] == 3);
- fail_unless (map.data[map.size - 1] == 3);
- } else if (i == 7 && GST_BUFFER_TIMESTAMP (buffer) == 3500 * GST_MSECOND) {
- fail_unless (map.data[0] == 3);
- fail_unless (map.data[map.size - 1] == 3);
- } else {
- g_assert_not_reached ();
- }
-
- gst_buffer_unmap (buffer, &map);
-
- }
-}
-
-GST_START_TEST (test_sync_discont)
-{
- run_sync_test (send_buffers_sync_discont, check_buffers_sync_discont);
-}
-
-GST_END_TEST;
-
-static void
-send_buffers_sync_unaligned (GstPad * pad1, GstPad * pad2)
-{
- GstBuffer *buffer;
- GstFlowReturn ret;
-
- buffer = new_buffer (2000, 1, 750 * GST_MSECOND, 1 * GST_SECOND, 0);
- ret = gst_pad_chain (pad1, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
-
- buffer = new_buffer (2000, 1, 1750 * GST_MSECOND, 1 * GST_SECOND, 0);
- ret = gst_pad_chain (pad1, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
-
- gst_pad_send_event (pad1, gst_event_new_eos ());
-
- buffer = new_buffer (2000, 2, 1750 * GST_MSECOND, 1 * GST_SECOND, 0);
- ret = gst_pad_chain (pad2, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
-
- buffer = new_buffer (2000, 2, 2750 * GST_MSECOND, 1 * GST_SECOND, 0);
- ret = gst_pad_chain (pad2, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
-
- gst_pad_send_event (pad2, gst_event_new_eos ());
-}
-
-static void
-check_buffers_sync_unaligned (GList * received_buffers)
-{
- GstBuffer *buffer;
- GList *l;
- gint i;
- GstMapInfo map;
-
- /* Should have 8 * 0.5s buffers */
- fail_unless_equals_int (g_list_length (received_buffers), 8);
- for (i = 0, l = received_buffers; l; l = l->next, i++) {
- buffer = l->data;
-
- gst_buffer_map (buffer, &map, GST_MAP_READ);
-
- if (i == 0 && GST_BUFFER_TIMESTAMP (buffer) == 0) {
- fail_unless (map.data[0] == 0);
- fail_unless (map.data[map.size - 1] == 0);
- } else if (i == 1 && GST_BUFFER_TIMESTAMP (buffer) == 500 * GST_MSECOND) {
- fail_unless (map.data[0] == 0);
- fail_unless (map.data[499] == 0);
- fail_unless (map.data[500] == 1);
- fail_unless (map.data[map.size - 1] == 1);
- } else if (i == 2 && GST_BUFFER_TIMESTAMP (buffer) == 1000 * GST_MSECOND) {
- fail_unless (map.data[0] == 1);
- fail_unless (map.data[map.size - 1] == 1);
- } else if (i == 3 && GST_BUFFER_TIMESTAMP (buffer) == 1500 * GST_MSECOND) {
- fail_unless (map.data[0] == 1);
- fail_unless (map.data[499] == 1);
- fail_unless (map.data[500] == 3);
- fail_unless (map.data[map.size - 1] == 3);
- } else if (i == 4 && GST_BUFFER_TIMESTAMP (buffer) == 2000 * GST_MSECOND) {
- fail_unless (map.data[0] == 3);
- fail_unless (map.data[499] == 3);
- fail_unless (map.data[500] == 3);
- fail_unless (map.data[map.size - 1] == 3);
- } else if (i == 5 && GST_BUFFER_TIMESTAMP (buffer) == 2500 * GST_MSECOND) {
- fail_unless (map.data[0] == 3);
- fail_unless (map.data[499] == 3);
- fail_unless (map.data[500] == 2);
- fail_unless (map.data[map.size - 1] == 2);
- } else if (i == 6 && GST_BUFFER_TIMESTAMP (buffer) == 3000 * GST_MSECOND) {
- fail_unless (map.data[0] == 2);
- fail_unless (map.data[499] == 2);
- fail_unless (map.data[500] == 2);
- fail_unless (map.data[map.size - 1] == 2);
- } else if (i == 7 && GST_BUFFER_TIMESTAMP (buffer) == 3500 * GST_MSECOND) {
- fail_unless (map.size == 500);
- fail_unless (GST_BUFFER_DURATION (buffer) == 250 * GST_MSECOND);
- fail_unless (map.data[0] == 2);
- fail_unless (map.data[499] == 2);
- } else {
- g_assert_not_reached ();
- }
-
- gst_buffer_unmap (buffer, &map);
-
- }
-}
-
-GST_START_TEST (test_sync_unaligned)
-{
- run_sync_test (send_buffers_sync_unaligned, check_buffers_sync_unaligned);
-}
-
-GST_END_TEST;
-
-GST_START_TEST (test_segment_base_handling)
-{
- GstElement *pipeline, *sink, *mix, *src1, *src2;
- GstPad *srcpad, *sinkpad;
- GstClockTime end_time;
- GstSample *last_sample = NULL;
- GstSample *sample;
- GstBuffer *buf;
- GstCaps *caps;
-
- caps = gst_caps_new_simple ("audio/x-raw", "rate", G_TYPE_INT, 44100,
- "channels", G_TYPE_INT, 2, NULL);
-
- pipeline = gst_pipeline_new ("pipeline");
- mix = gst_element_factory_make ("audiomixer", "audiomixer");
- sink = gst_element_factory_make ("appsink", "sink");
- g_object_set (sink, "caps", caps, "sync", FALSE, NULL);
- gst_caps_unref (caps);
- /* 50 buffers of 1/10 sec = 5 sec */
- src1 = gst_element_factory_make ("audiotestsrc", "src1");
- g_object_set (src1, "samplesperbuffer", 4410, "num-buffers", 50, NULL);
- src2 = gst_element_factory_make ("audiotestsrc", "src2");
- g_object_set (src2, "samplesperbuffer", 4410, "num-buffers", 50, NULL);
- gst_bin_add_many (GST_BIN (pipeline), src1, src2, mix, sink, NULL);
- fail_unless (gst_element_link (mix, sink));
-
- srcpad = gst_element_get_static_pad (src1, "src");
- sinkpad = gst_element_get_request_pad (mix, "sink_1");
- fail_unless (gst_pad_link (srcpad, sinkpad) == GST_PAD_LINK_OK);
- gst_object_unref (sinkpad);
- gst_object_unref (srcpad);
-
- srcpad = gst_element_get_static_pad (src2, "src");
- sinkpad = gst_element_get_request_pad (mix, "sink_2");
- fail_unless (gst_pad_link (srcpad, sinkpad) == GST_PAD_LINK_OK);
- /* set a pad offset of another 5 seconds */
- gst_pad_set_offset (sinkpad, 5 * GST_SECOND);
- gst_object_unref (sinkpad);
- gst_object_unref (srcpad);
-
- gst_element_set_state (pipeline, GST_STATE_PLAYING);
-
- do {
- g_signal_emit_by_name (sink, "pull-sample", &sample);
- if (sample == NULL)
- break;
- if (last_sample)
- gst_sample_unref (last_sample);
- last_sample = sample;
- } while (TRUE);
-
- buf = gst_sample_get_buffer (last_sample);
- end_time = GST_BUFFER_TIMESTAMP (buf) + GST_BUFFER_DURATION (buf);
- fail_unless_equals_int64 (end_time, 10 * GST_SECOND);
- gst_sample_unref (last_sample);
-
- gst_element_set_state (pipeline, GST_STATE_NULL);
- gst_object_unref (pipeline);
-}
-
-GST_END_TEST;
-
-static void
-set_pad_volume_fade (GstPad * pad, GstClockTime start, gdouble start_value,
- GstClockTime end, gdouble end_value)
-{
- GstControlSource *cs;
- GstTimedValueControlSource *tvcs;
-
- cs = gst_interpolation_control_source_new ();
- fail_unless (gst_object_add_control_binding (GST_OBJECT_CAST (pad),
- gst_direct_control_binding_new_absolute (GST_OBJECT_CAST (pad),
- "volume", cs)));
-
- /* set volume interpolation mode */
- g_object_set (cs, "mode", GST_INTERPOLATION_MODE_LINEAR, NULL);
-
- tvcs = (GstTimedValueControlSource *) cs;
- fail_unless (gst_timed_value_control_source_set (tvcs, start, start_value));
- fail_unless (gst_timed_value_control_source_set (tvcs, end, end_value));
- gst_object_unref (cs);
-}
-
-GST_START_TEST (test_sinkpad_property_controller)
-{
- GstBus *bus;
- GstMessage *msg;
- GstElement *pipeline, *sink, *mix, *src1;
- GstPad *srcpad, *sinkpad;
- GError *error = NULL;
- gchar *debug;
-
- pipeline = gst_pipeline_new ("pipeline");
- mix = gst_element_factory_make ("audiomixer", "audiomixer");
- sink = gst_element_factory_make ("fakesink", "sink");
- src1 = gst_element_factory_make ("audiotestsrc", "src1");
- g_object_set (src1, "num-buffers", 100, NULL);
- gst_bin_add_many (GST_BIN (pipeline), src1, mix, sink, NULL);
- fail_unless (gst_element_link (mix, sink));
-
- srcpad = gst_element_get_static_pad (src1, "src");
- sinkpad = gst_element_get_request_pad (mix, "sink_0");
- fail_unless (gst_pad_link (srcpad, sinkpad) == GST_PAD_LINK_OK);
- set_pad_volume_fade (sinkpad, 0, 0, 1.0, 2.0);
- gst_object_unref (sinkpad);
- gst_object_unref (srcpad);
-
- gst_element_set_state (pipeline, GST_STATE_PLAYING);
-
- bus = gst_pipeline_get_bus (GST_PIPELINE (pipeline));
- msg = gst_bus_timed_pop_filtered (bus, GST_CLOCK_TIME_NONE,
- GST_MESSAGE_EOS | GST_MESSAGE_ERROR);
- switch (GST_MESSAGE_TYPE (msg)) {
- case GST_MESSAGE_ERROR:
- gst_message_parse_error (msg, &error, &debug);
- g_printerr ("ERROR from element %s: %s\n",
- GST_OBJECT_NAME (msg->src), error->message);
- g_printerr ("Debug info: %s\n", debug);
- g_error_free (error);
- g_free (debug);
- break;
- case GST_MESSAGE_EOS:
- break;
- default:
- g_assert_not_reached ();
- }
- gst_message_unref (msg);
- g_object_unref (bus);
-
- gst_element_set_state (pipeline, GST_STATE_NULL);
- gst_object_unref (pipeline);
-}
-
-GST_END_TEST;
-
-static void
-change_src_caps (GstElement * fakesink, GstBuffer * buffer, GstPad * pad,
- GstElement * capsfilter)
-{
- GstCaps *caps = gst_caps_new_simple ("audio/x-raw",
- "format", G_TYPE_STRING, GST_AUDIO_NE (S32),
- "layout", G_TYPE_STRING, "interleaved",
- "rate", G_TYPE_INT, 10, "channels", G_TYPE_INT, 1, NULL);
-
- g_object_set (capsfilter, "caps", caps, NULL);
- g_signal_connect (fakesink, "handoff", (GCallback) handoff_buffer_cb, NULL);
- g_signal_handlers_disconnect_by_func (fakesink, change_src_caps, capsfilter);
-}
-
-/* In this test, we create an input buffer with a duration of 2 seconds,
- * and require the audiomixer to output 1 second long buffers.
- * The input buffer will thus be mixed twice, and the audiomixer will
- * output two buffers.
- *
- * After audiomixer has output a first buffer, we change its output format
- * from S8 to S32. As our sample rate stays the same at 10 fps, and we use
- * mono, the first buffer should be 10 bytes long, and the second 40.
- *
- * The input buffer is made up of 15 0-valued bytes, and 5 1-valued bytes.
- * We verify that the second buffer contains 5 0-valued integers, and
- * 5 1 << 24 valued integers.
- */
-GST_START_TEST (test_change_output_caps)
-{
- GstSegment segment;
- GstElement *bin, *audiomixer, *capsfilter, *sink;
- GstBus *bus;
- GstPad *sinkpad;
- gboolean res;
- GstStateChangeReturn state_res;
- GstFlowReturn ret;
- GstEvent *event;
- GstBuffer *buffer;
- GstCaps *caps;
- GstQuery *drain = gst_query_new_drain ();
- GstMapInfo inmap;
- GstMapInfo outmap;
- gsize i;
-
- bin = gst_pipeline_new ("pipeline");
- bus = gst_element_get_bus (bin);
- gst_bus_add_signal_watch_full (bus, G_PRIORITY_HIGH);
-
- g_signal_connect (bus, "message::error", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::warning", (GCallback) message_received, bin);
- g_signal_connect (bus, "message::eos", (GCallback) message_received, bin);
-
- audiomixer = gst_element_factory_make ("audiomixer", "audiomixer");
- g_object_set (audiomixer, "output-buffer-duration", GST_SECOND, NULL);
- capsfilter = gst_element_factory_make ("capsfilter", NULL);
- sink = gst_element_factory_make ("fakesink", "sink");
- g_object_set (sink, "signal-handoffs", TRUE, NULL);
- g_signal_connect (sink, "handoff", (GCallback) change_src_caps, capsfilter);
- gst_bin_add_many (GST_BIN (bin), audiomixer, capsfilter, sink, NULL);
-
- res = gst_element_link_many (audiomixer, capsfilter, sink, NULL);
- fail_unless (res == TRUE, NULL);
-
- state_res = gst_element_set_state (bin, GST_STATE_PLAYING);
- ck_assert_int_ne (state_res, GST_STATE_CHANGE_FAILURE);
-
- sinkpad = gst_element_get_request_pad (audiomixer, "sink_%u");
- fail_if (sinkpad == NULL, NULL);
-
- gst_pad_send_event (sinkpad, gst_event_new_stream_start ("test"));
-
- caps = gst_caps_new_simple ("audio/x-raw",
- "format", G_TYPE_STRING, "S8",
- "layout", G_TYPE_STRING, "interleaved",
- "rate", G_TYPE_INT, 10, "channels", G_TYPE_INT, 1, NULL);
-
- gst_pad_set_caps (sinkpad, caps);
- g_object_set (capsfilter, "caps", caps, NULL);
- gst_caps_unref (caps);
-
- gst_segment_init (&segment, GST_FORMAT_TIME);
- segment.start = 0;
- segment.stop = 2 * GST_SECOND;
- segment.time = 0;
- event = gst_event_new_segment (&segment);
- gst_pad_send_event (sinkpad, event);
-
- gst_buffer_replace (&handoff_buffer, NULL);
-
- buffer = new_buffer (20, 0, 0, 2 * GST_SECOND, 0);
- gst_buffer_map (buffer, &inmap, GST_MAP_WRITE);
- memset (inmap.data + 15, 1, 5);
- gst_buffer_unmap (buffer, &inmap);
- ret = gst_pad_chain (sinkpad, buffer);
- ck_assert_int_eq (ret, GST_FLOW_OK);
- gst_pad_query (sinkpad, drain);
- fail_unless (handoff_buffer != NULL);
- fail_unless_equals_int (gst_buffer_get_size (handoff_buffer), 40);
-
- gst_buffer_map (handoff_buffer, &outmap, GST_MAP_READ);
- for (i = 0; i < 10; i++) {
- guint32 sample;
-
-#if G_BYTE_ORDER == G_LITTLE_ENDIAN
- sample = GUINT32_FROM_LE (((guint32 *) outmap.data)[i]);
-#else
- sample = GUINT32_FROM_BE (((guint32 *) outmap.data)[i]);
-#endif
-
- if (i < 5) {
- fail_unless_equals_int (sample, 0);
- } else {
- fail_unless_equals_int (sample, 1 << 24);
- }
- }
- gst_buffer_unmap (handoff_buffer, &outmap);
-
- gst_element_release_request_pad (audiomixer, sinkpad);
- gst_object_unref (sinkpad);
- gst_element_set_state (bin, GST_STATE_NULL);
- gst_bus_remove_signal_watch (bus);
- gst_object_unref (bus);
- gst_object_unref (bin);
- gst_query_unref (drain);
-}
-
-GST_END_TEST;
-
-static Suite *
-audiomixer_suite (void)
-{
- Suite *s = suite_create ("audiomixer");
- TCase *tc_chain = tcase_create ("general");
-
- suite_add_tcase (s, tc_chain);
- tcase_add_test (tc_chain, test_caps);
- tcase_add_test (tc_chain, test_filter_caps);
- tcase_add_test (tc_chain, test_event);
- tcase_add_test (tc_chain, test_play_twice);
- tcase_add_test (tc_chain, test_play_twice_then_add_and_play_again);
- tcase_add_test (tc_chain, test_live_seeking);
- tcase_add_test (tc_chain, test_add_pad);
- tcase_add_test (tc_chain, test_remove_pad);
- tcase_add_test (tc_chain, test_clip);
- tcase_add_test (tc_chain, test_duration_is_max);
- tcase_add_test (tc_chain, test_duration_unknown_overrides);
- tcase_add_test (tc_chain, test_loop);
- tcase_add_test (tc_chain, test_flush_start_flush_stop);
- tcase_add_test (tc_chain, test_sync);
- tcase_add_test (tc_chain, test_sync_discont);
- tcase_add_test (tc_chain, test_sync_unaligned);
- tcase_add_test (tc_chain, test_segment_base_handling);
- tcase_add_test (tc_chain, test_sinkpad_property_controller);
- tcase_add_checked_fixture (tc_chain, test_setup, test_teardown);
- tcase_add_test (tc_chain, test_change_output_caps);
-
- /* Use a longer timeout */
-#ifdef HAVE_VALGRIND
- if (RUNNING_ON_VALGRIND) {
- tcase_set_timeout (tc_chain, 5 * 60);
- } else
-#endif
- {
- /* this is shorter than the default 60 seconds?! (tpm) */
- /* tcase_set_timeout (tc_chain, 6); */
- }
-
- return s;
-}
-
-GST_CHECK_MAIN (audiomixer);
diff --git a/tests/check/meson.build b/tests/check/meson.build
index 55f1513e8..1cb817164 100644
--- a/tests/check/meson.build
+++ b/tests/check/meson.build
@@ -18,8 +18,6 @@ base_tests = [
[['elements/aiffparse.c']],
[['elements/asfmux.c']],
[['elements/assrender.c'], not ass_dep.found(), [ass_dep]],
- [['elements/audiointerleave.c']],
- [['elements/audiomixer.c']],
[['elements/autoconvert.c']],
[['elements/autovideoconvert.c']],
[['elements/camerabin.c']],