[farsight2/master] Add simple test for multicast transmitter
Olivier Crête
olivier.crete at collabora.co.uk
Tue Dec 23 15:21:07 PST 2008
---
.gitignore | 2 +
tests/check/Makefile.am | 12 ++-
tests/check/transmitter/multicast.c | 230 +++++++++++++++++++++++++++++++++++
3 files changed, 243 insertions(+), 1 deletions(-)
create mode 100644 tests/check/transmitter/multicast.c
diff --git a/.gitignore b/.gitignore
index e52355e..274241a 100644
--- a/.gitignore
+++ b/.gitignore
@@ -39,6 +39,7 @@ tests/check/*/.dirstamp
tests/check/base/fscodec
tests/check/base/fstransmitter
tests/check/transmitter/rawudp
+tests/check/transmitter/multicast
tests/check/main/rtpconference
tests/check/main/rtpcodecs
tests/check/utils/binadded
@@ -56,6 +57,7 @@ config.log
config.status
config.sub
configure
+compile
depcomp
diff
install-sh
diff --git a/tests/check/Makefile.am b/tests/check/Makefile.am
index ad75f53..27a562e 100644
--- a/tests/check/Makefile.am
+++ b/tests/check/Makefile.am
@@ -11,7 +11,7 @@ TESTS_ENVIRONMENT = \
$(REGISTRY_ENVIRONMENT) \
GST_PLUGIN_SYSTEM_PATH= \
GST_PLUGIN_PATH=$(top_builddir)/gst:${GST_PLUGIN_PATH} \
- FS_PLUGIN_PATH=$(top_builddir)/transmitters/rawudp/.libs
+ FS_PLUGIN_PATH=$(top_builddir)/transmitters/rawudp/.libs:$(top_builddir)/transmitters/multicast/.libs
# ths core dumps of some machines have PIDs appended
@@ -35,6 +35,7 @@ check_PROGRAMS = \
base/fscodec \
base/fstransmitter \
transmitter/rawudp \
+ transmitter/multicast \
main/rtpconference \
main/rtpcodecs \
utils/binadded
@@ -60,6 +61,15 @@ transmitter_rawudp_SOURCES = \
transmitter/generic.h \
transmitter/rawudp.c
+transmitter_multicast_LDADD = $(LDADD) \
+ $(top_builddir)/gst-libs/gst/farsight/libgstfarsight-0.10.la
+transmitter_multicast_CFLAGS = $(FS2_INTERNAL_CFLAGS) $(CFLAGS) $(AM_CFLAGS)
+transmitter_multicast_SOURCES = \
+ check_threadsafe.h \
+ transmitter/generic.c \
+ transmitter/generic.h \
+ transmitter/multicast.c
+
main_rtpconference_LDADD = $(LDADD) \
diff --git a/tests/check/transmitter/multicast.c b/tests/check/transmitter/multicast.c
new file mode 100644
index 0000000..382d815
--- /dev/null
+++ b/tests/check/transmitter/multicast.c
@@ -0,0 +1,230 @@
+/* Farsight 2 unit tests for FsMulticastTransmitter
+ *
+ * Copyright (C) 2007 Collabora, Nokia
+ * @author: Olivier Crete <olivier.crete at collabora.co.uk>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Lesser General Public
+ * License as published by the Free Software Foundation; either
+ * version 2.1 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
+ * Lesser General Public License for more details.
+ *
+ * You should have received a copy of the GNU Lesser General Public
+ * License along with this library; if not, write to the Free Software
+ * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA
+*/
+
+#ifdef HAVE_CONFIG_H
+# include <config.h>
+#endif
+
+#include <gst/check/gstcheck.h>
+#include <gst/farsight/fs-transmitter.h>
+#include <gst/farsight/fs-conference-iface.h>
+
+#include "check-threadsafe.h"
+#include "generic.h"
+
+gint buffer_count[2] = {0, 0};
+GMainLoop *loop = NULL;
+gint candidates[2] = {0, 0};
+GstElement *pipeline = NULL;
+gboolean src_setup[2] = {FALSE, FALSE};
+
+GST_START_TEST (test_multicasttransmitter_new)
+{
+ GError *error = NULL;
+ FsTransmitter *trans;
+ GstElement *pipeline;
+ GstElement *trans_sink, *trans_src;
+
+ trans = fs_transmitter_new ("multicast", 2, &error);
+
+ if (error) {
+ ts_fail ("Error creating transmitter: (%s:%d) %s",
+ g_quark_to_string (error->domain), error->code, error->message);
+ }
+
+ ts_fail_if (trans == NULL, "No transmitter create, yet error is still NULL");
+
+ pipeline = setup_pipeline (trans, NULL);
+
+ g_object_get (trans, "gst-sink", &trans_sink, "gst-src", &trans_src, NULL);
+
+ g_object_unref (trans);
+
+ gst_object_unref (pipeline);
+
+}
+GST_END_TEST;
+
+
+
+static void
+_handoff_handler (GstElement *element, GstBuffer *buffer, GstPad *pad,
+ gpointer user_data)
+{
+ gint component_id = GPOINTER_TO_INT (user_data);
+
+ ts_fail_unless (GST_BUFFER_SIZE (buffer) == component_id * 10,
+ "Buffer is size %d but component_id is %d", GST_BUFFER_SIZE (buffer),
+ component_id);
+
+ buffer_count[component_id-1]++;
+
+ /*
+ g_debug ("Buffer %d component: %d size: %u", buffer_count[component_id-1],
+ component_id, GST_BUFFER_SIZE (buffer));
+ */
+
+ ts_fail_if (buffer_count[component_id-1] > 20,
+ "Too many buffers %d > 20 for component",
+ buffer_count[component_id-1], component_id);
+
+ if (buffer_count[0] == 20 && buffer_count[1] == 20) {
+ /* TEST OVER */
+ g_main_loop_quit (loop);
+ }
+}
+
+static void
+_new_active_candidate_pair (FsStreamTransmitter *st, FsCandidate *local,
+ FsCandidate *remote, gpointer user_data)
+{
+ ts_fail_if (local == NULL, "Local candidate NULL");
+ ts_fail_if (remote == NULL, "Remote candidate NULL");
+
+ ts_fail_unless (local->component_id == remote->component_id,
+ "Local and remote candidates dont have the same component id");
+
+ g_debug ("New active candidate pair for component %d", local->component_id);
+
+ if (!src_setup[local->component_id-1])
+ setup_fakesrc (user_data, pipeline, local->component_id);
+ src_setup[local->component_id-1] = TRUE;
+}
+
+static gboolean
+_start_pipeline (gpointer user_data)
+{
+ GstElement *pipeline = user_data;
+
+ g_debug ("Starting pipeline");
+
+ ts_fail_if (gst_element_set_state (pipeline, GST_STATE_PLAYING) ==
+ GST_STATE_CHANGE_FAILURE, "Could not set the pipeline to playing");
+
+ return FALSE;
+}
+
+static void
+run_multicast_transmitter_test (gint n_parameters, GParameter *params,
+ gint flags)
+{
+ GError *error = NULL;
+ FsTransmitter *trans;
+ FsStreamTransmitter *st;
+ GstElement *trans_sink, *trans_src;
+ FsCandidate *tmpcand = NULL;
+
+ loop = g_main_loop_new (NULL, FALSE);
+ trans = fs_transmitter_new ("multicast", 2, &error);
+
+ if (error) {
+ ts_fail ("Error creating transmitter: (%s:%d) %s",
+ g_quark_to_string (error->domain), error->code, error->message);
+ }
+
+ ts_fail_if (trans == NULL, "No transmitter create, yet error is still NULL");
+
+ pipeline = setup_pipeline (trans, G_CALLBACK (_handoff_handler));
+
+ g_object_get (trans, "gst-sink", &trans_sink, "gst-src", &trans_src, NULL);
+
+ st = fs_transmitter_new_stream_transmitter (trans, NULL, n_parameters, params,
+ &error);
+
+ if (error) {
+ ts_fail ("Error creating stream transmitter: (%s:%d) %s",
+ g_quark_to_string (error->domain), error->code, error->message);
+ }
+
+ ts_fail_if (st == NULL, "No stream transmitter created, yet error is NULL");
+
+ ts_fail_unless (g_signal_connect (st, "new-active-candidate-pair",
+ G_CALLBACK (_new_active_candidate_pair), trans),
+ "Coult not connect new-active-candidate-pair signal");
+ ts_fail_unless (g_signal_connect (st, "error",
+ G_CALLBACK (_stream_transmitter_error), NULL),
+ "Could not connect error signal");
+
+ g_idle_add (_start_pipeline, pipeline);
+
+ tmpcand = fs_candidate_new ("L1", FS_COMPONENT_RTP,
+ FS_CANDIDATE_TYPE_MULTICAST, FS_NETWORK_PROTOCOL_UDP,
+ "224.0.0.33", 2322);
+ if (!fs_stream_transmitter_add_remote_candidate (st, tmpcand, &error))
+ ts_fail ("Error setting the remote candidate: %p %s", error,
+ error ? error->message : "NO ERROR SET");
+ ts_fail_unless (error == NULL, "Error is not null after successful candidate"
+ " addition");
+ fs_candidate_destroy (tmpcand);
+
+ tmpcand = fs_candidate_new ("L2", FS_COMPONENT_RTCP,
+ FS_CANDIDATE_TYPE_MULTICAST, FS_NETWORK_PROTOCOL_UDP,
+ "224.0.0.33", 2323);
+ if (!fs_stream_transmitter_add_remote_candidate (st, tmpcand, &error))
+ ts_fail ("Error setting the remote candidate: %p %s", error,
+ error ? error->message : "NO ERROR SET");
+ ts_fail_unless (error == NULL, "Error is not null after successful candidate"
+ " addition");
+ fs_candidate_destroy (tmpcand);
+
+ g_debug ("STARTING");
+
+ g_main_run (loop);
+
+ g_object_unref (st);
+
+ g_object_unref (trans);
+
+ gst_element_set_state (pipeline, GST_STATE_NULL);
+
+ gst_object_unref (pipeline);
+
+ g_main_loop_unref (loop);
+
+}
+
+GST_START_TEST (test_multicasttransmitter_run)
+{
+ run_multicast_transmitter_test (0, NULL, 0);
+}
+GST_END_TEST;
+
+static Suite *
+multicasttransmitter_suite (void)
+{
+ Suite *s = suite_create ("multicasttransmitter");
+ TCase *tc_chain;
+ GLogLevelFlags fatal_mask;
+
+ fatal_mask = g_log_set_always_fatal (G_LOG_FATAL_MASK);
+ fatal_mask |= G_LOG_LEVEL_WARNING | G_LOG_LEVEL_CRITICAL;
+ g_log_set_always_fatal (fatal_mask);
+
+ tc_chain = tcase_create ("multicasttransmitter");
+ tcase_set_timeout (tc_chain, 5);
+ tcase_add_test (tc_chain, test_multicasttransmitter_new);
+ tcase_add_test (tc_chain, test_multicasttransmitter_run);
+ suite_add_tcase (s, tc_chain);
+
+ return s;
+}
+
+
+GST_CHECK_MAIN (multicasttransmitter);
--
1.5.6.5
More information about the farsight-commits
mailing list