[gssdp] tests: Add some functional tests
- From: Jens Georg <jensgeorg src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [gssdp] tests: Add some functional tests
- Date: Thu, 3 May 2012 08:42:54 +0000 (UTC)
commit 445d02fe7c38d7f23b2715171f52a8cf3cda6ed2
Author: Jens Georg <mail jensge org>
Date: Mon Apr 2 18:08:20 2012 +0200
tests: Add some functional tests
https://bugzilla.gnome.org/show_bug.cgi?id=673150
tests/gtest/Makefile.am | 8 +-
tests/gtest/test-functional.c | 516 +++++++++++++++++++++++++++++++++++++++++
tests/gtest/test-regression.c | 9 +-
tests/gtest/test-util.c | 26 ++
tests/gtest/test-util.h | 46 ++++
5 files changed, 597 insertions(+), 8 deletions(-)
---
diff --git a/tests/gtest/Makefile.am b/tests/gtest/Makefile.am
index a9498a4..8a8fc8d 100644
--- a/tests/gtest/Makefile.am
+++ b/tests/gtest/Makefile.am
@@ -3,12 +3,18 @@ TESTS_ENVIRONMENT = G_SLICE=debug-blocks \
TESTS=$(check_PROGRAMS)
-check_PROGRAMS = test-regression
+check_PROGRAMS = test-regression test-functional
+
+noinst_LIBRARIES = libtestutil.a
+
+libtestutil_a_SOURCES = test-util.h test-util.c
test_regression_SOURCES = test-regression.c
+test_functional_SOURCES = test-functional.c
LDADD = \
$(top_builddir)/libgssdp/libgssdp-1.0.la \
+ libtestutil.a \
$(LIBGSSDP_LIBS)
AM_CFLAGS = \
diff --git a/tests/gtest/test-functional.c b/tests/gtest/test-functional.c
new file mode 100644
index 0000000..ba9aee5
--- /dev/null
+++ b/tests/gtest/test-functional.c
@@ -0,0 +1,516 @@
+/*
+ * Copyright (C) 2012 Openismus GmbH
+ *
+ * Author: Jens Georg <jensg openismus com>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Library General Public
+ * License as published by the Free Software Foundation; either
+ * version 2 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Library General Public License for more details.
+ *
+ * You should have received a copy of the GNU Library General Public
+ * License along with this library; if not, write to the
+ * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+ * Boston, MA 02111-1307, USA.
+ */
+
+#include <string.h>
+
+#include <gio/gio.h>
+
+#include <libgssdp/gssdp-resource-browser.h>
+#include <libgssdp/gssdp-protocol.h>
+
+#include "test-util.h"
+
+#define UUID_1 "uuid:81909e94-ebf4-469e-ac68-81f2f189de1b"
+#define VERSIONED_NT_1 "urn:org-gupnp:device:FunctionalTest:1"
+#define VERSIONED_NT_2 "urn:org-gupnp:device:FunctionalTest:9"
+#define VERSIONED_USN_1 UUID_1"::"VERSIONED_NT_1
+#define VERSIONED_USN_2 UUID_1"::"VERSIONED_NT_2
+
+/* Helper functions */
+
+static GSocket *
+create_socket()
+{
+ GSocket *socket;
+ GError *error = NULL;
+ GSocketAddress *sock_addr;
+ GInetAddress *address;
+
+ socket = g_socket_new (G_SOCKET_FAMILY_IPV4,
+ G_SOCKET_TYPE_DATAGRAM,
+ G_SOCKET_PROTOCOL_DEFAULT,
+ &error);
+ g_assert (error == NULL);
+
+ address = g_inet_address_new_from_string ("127.0.0.1");
+ sock_addr = g_inet_socket_address_new (address, 0);
+ g_object_unref (address);
+
+ g_socket_bind (socket, sock_addr, TRUE, &error);
+ g_assert (error == NULL);
+ g_object_unref (sock_addr);
+
+ return socket;
+}
+
+char *
+create_alive_message (const char *nt)
+{
+ char *usn, *msg;
+
+ if (strcmp (nt, UUID_1) == 0)
+ usn = g_strdup (UUID_1);
+ else
+ usn = g_strconcat (UUID_1, "::", nt, NULL);
+
+ msg = g_strdup_printf (SSDP_ALIVE_MESSAGE,
+ 1800,
+ "http://127.0.0.1:1234";,
+ "",
+ "Linux/3.0 UPnP/1.0 GSSDPTesting/0.0.0",
+ nt,
+ usn);
+ g_free (usn);
+
+ return msg;
+}
+
+char *
+create_byebye_message (const char *nt)
+{
+ char *usn, *msg;
+
+ if (strcmp (nt, UUID_1) == 0)
+ usn = g_strdup (UUID_1);
+ else
+ usn = g_strconcat (UUID_1, "::", nt, NULL);
+
+ msg = g_strdup_printf (SSDP_BYEBYE_MESSAGE, nt, usn);
+ g_free (usn);
+
+ return msg;
+}
+
+typedef struct {
+ const char *usn;
+ GMainLoop *loop;
+ gboolean found;
+} TestDiscoverySSDPAllData;
+
+
+static void
+on_test_discovery_ssdp_all_resource_available (GSSDPResourceBrowser *src,
+ const char *usn,
+ gpointer locations,
+ gpointer user_data)
+{
+ TestDiscoverySSDPAllData *data = (TestDiscoverySSDPAllData *) user_data;
+
+ g_assert_cmpstr (usn, ==, data->usn);
+
+ data->found = TRUE;
+
+ g_main_loop_quit (data->loop);
+}
+
+static void
+on_test_discovery_ssdp_all_resource_unavailable (GSSDPResourceBrowser *src,
+ const char *usn,
+ gpointer user_data)
+{
+ TestDiscoverySSDPAllData *data = (TestDiscoverySSDPAllData *) user_data;
+
+ g_assert_cmpstr (usn, ==, data->usn);
+
+ data->found = TRUE;
+
+ g_main_loop_quit (data->loop);
+}
+
+static gboolean
+test_discovery_send_packet (gpointer user_data)
+{
+ GSocket *socket;
+ GError *error = NULL;
+ GSocketAddress *sock_addr;
+ GInetAddress *address;
+ char *msg = (char *) user_data;
+
+ socket = create_socket ();
+
+ address = g_inet_address_new_from_string (SSDP_ADDR);
+
+ sock_addr = g_inet_socket_address_new (address, SSDP_PORT);
+ g_object_unref (address);
+
+ g_socket_send_to (socket, sock_addr, msg, strlen (msg), NULL, &error);
+ g_assert (error == NULL);
+
+ g_object_unref (sock_addr);
+ g_object_unref (socket);
+
+ g_free (msg);
+
+ return FALSE;
+}
+
+static void
+test_discovery_ssdp_all (void)
+{
+ GSSDPClient *client;
+ GSSDPResourceBrowser *browser;
+ GError *error = NULL;
+ TestDiscoverySSDPAllData data;
+ gulong signal_id;
+ guint timeout_id;
+
+ data.loop = g_main_loop_new (NULL, FALSE);
+ data.usn = UUID_1"::MyService:1";
+ data.found = FALSE;
+
+ client = gssdp_client_new (NULL, "lo", &error);
+ g_assert (client != NULL);
+ g_assert (error == NULL);
+
+ browser = gssdp_resource_browser_new (client, "ssdp:all");
+ signal_id = g_signal_connect (browser,
+ "resource-available",
+ G_CALLBACK (on_test_discovery_ssdp_all_resource_available),
+ &data);
+ gssdp_resource_browser_set_active (browser, TRUE);
+
+ timeout_id = g_timeout_add_seconds (10, quit_loop, data.loop);
+
+ /* delay announcement until browser issued its M-SEARCH */
+ g_timeout_add_seconds (1,
+ test_discovery_send_packet,
+ create_alive_message ("MyService:1"));
+ g_main_loop_run (data.loop);
+
+ g_assert (data.found);
+
+ data.found = FALSE;
+ g_signal_handler_disconnect (browser, signal_id);
+ g_timeout_add_seconds (1,
+ test_discovery_send_packet,
+ create_byebye_message ("MyService:1"));
+ signal_id = g_signal_connect (browser,
+ "resource-unavailable",
+ G_CALLBACK (on_test_discovery_ssdp_all_resource_unavailable),
+ &data);
+ g_main_loop_run (data.loop);
+
+ g_assert (data.found);
+
+ g_source_remove (timeout_id);
+ g_object_unref (browser);
+ g_object_unref (client);
+ g_main_loop_unref (data.loop);
+}
+
+static void
+test_discovery_upnp_rootdevice (void)
+{
+ GSSDPClient *client;
+ GSSDPResourceBrowser *browser;
+ GError *error = NULL;
+ TestDiscoverySSDPAllData data;
+ gulong signal_id;
+ guint timeout_id;
+
+ data.loop = g_main_loop_new (NULL, FALSE);
+ data.usn = UUID_1"::upnp:rootdevice";
+ data.found = FALSE;
+
+ client = gssdp_client_new (NULL, "lo", &error);
+ g_assert (client != NULL);
+ g_assert (error == NULL);
+
+ browser = gssdp_resource_browser_new (client, "upnp:rootdevice");
+ signal_id = g_signal_connect (browser,
+ "resource-available",
+ G_CALLBACK (on_test_discovery_ssdp_all_resource_available),
+ &data);
+ gssdp_resource_browser_set_active (browser, TRUE);
+
+ timeout_id = g_timeout_add_seconds (10, quit_loop, data.loop);
+
+ /* delay announcement until browser issued its M-SEARCH */
+ g_timeout_add_seconds (1,
+ test_discovery_send_packet,
+ create_alive_message ("upnp:rootdevice"));
+ g_main_loop_run (data.loop);
+
+ g_assert (data.found);
+
+ data.found = FALSE;
+ g_signal_handler_disconnect (browser, signal_id);
+ g_timeout_add_seconds (1,
+ test_discovery_send_packet,
+ create_byebye_message ("upnp:rootdevice"));
+ signal_id = g_signal_connect (browser,
+ "resource-unavailable",
+ G_CALLBACK (on_test_discovery_ssdp_all_resource_unavailable),
+ &data);
+ g_main_loop_run (data.loop);
+
+ g_assert (data.found);
+
+ g_source_remove (timeout_id);
+ g_object_unref (browser);
+ g_object_unref (client);
+ g_main_loop_unref (data.loop);
+}
+
+static void
+test_discovery_uuid (void)
+{
+ GSSDPClient *client;
+ GSSDPResourceBrowser *browser;
+ GError *error = NULL;
+ TestDiscoverySSDPAllData data;
+ gulong signal_id;
+ guint timeout_id;
+
+ data.loop = g_main_loop_new (NULL, FALSE);
+ data.usn = UUID_1;
+ data.found = FALSE;
+
+ client = gssdp_client_new (NULL, "lo", &error);
+ g_assert (client != NULL);
+ g_assert (error == NULL);
+
+ browser = gssdp_resource_browser_new (client, UUID_1);
+ signal_id = g_signal_connect (browser,
+ "resource-available",
+ G_CALLBACK (on_test_discovery_ssdp_all_resource_available),
+ &data);
+ gssdp_resource_browser_set_active (browser, TRUE);
+
+ timeout_id = g_timeout_add_seconds (10, quit_loop, data.loop);
+
+ /* delay announcement until browser issued its M-SEARCH */
+ g_timeout_add_seconds (1,
+ test_discovery_send_packet,
+ create_alive_message (UUID_1));
+ g_main_loop_run (data.loop);
+
+ g_assert (data.found);
+
+ data.found = FALSE;
+ g_signal_handler_disconnect (browser, signal_id);
+ g_timeout_add_seconds (1,
+ test_discovery_send_packet,
+ create_byebye_message (UUID_1));
+ signal_id = g_signal_connect (browser,
+ "resource-unavailable",
+ G_CALLBACK (on_test_discovery_ssdp_all_resource_unavailable),
+ &data);
+ g_main_loop_run (data.loop);
+
+ g_assert (data.found);
+
+ g_source_remove (timeout_id);
+ g_object_unref (browser);
+ g_object_unref (client);
+ g_main_loop_unref (data.loop);
+}
+
+
+static void
+test_discovery_versioned (void)
+{
+ GSSDPClient *client;
+ GSSDPResourceBrowser *browser;
+ GError *error = NULL;
+ TestDiscoverySSDPAllData data;
+ gulong signal_id;
+ guint timeout_id;
+
+ data.loop = g_main_loop_new (NULL, FALSE);
+ data.usn = VERSIONED_USN_1;
+ data.found = FALSE;
+
+ client = gssdp_client_new (NULL, "lo", &error);
+ g_assert (client != NULL);
+ g_assert (error == NULL);
+
+ browser = gssdp_resource_browser_new (client, VERSIONED_NT_1);
+ signal_id = g_signal_connect (browser,
+ "resource-available",
+ G_CALLBACK (on_test_discovery_ssdp_all_resource_available),
+ &data);
+ gssdp_resource_browser_set_active (browser, TRUE);
+
+ timeout_id = g_timeout_add_seconds (10, quit_loop, data.loop);
+
+ /* delay announcement until browser issued its M-SEARCH */
+ g_timeout_add_seconds (1,
+ test_discovery_send_packet,
+ create_alive_message (VERSIONED_NT_1));
+ g_main_loop_run (data.loop);
+
+ g_assert (data.found);
+
+ data.found = FALSE;
+ g_signal_handler_disconnect (browser, signal_id);
+ g_timeout_add_seconds (1,
+ test_discovery_send_packet,
+ create_byebye_message (VERSIONED_NT_1));
+ signal_id = g_signal_connect (browser,
+ "resource-unavailable",
+ G_CALLBACK (on_test_discovery_ssdp_all_resource_unavailable),
+ &data);
+ g_main_loop_run (data.loop);
+
+ g_assert (data.found);
+
+ /* check that the resource group doesn't trigger on other resources */
+ g_signal_handler_disconnect (browser, signal_id);
+ g_timeout_add_seconds (1,
+ test_discovery_send_packet,
+ create_byebye_message ("MyService:1"));
+ signal_id = g_signal_connect (browser,
+ "resource-available",
+ G_CALLBACK (on_resource_available_assert_not_reached),
+ NULL);
+ g_source_remove (timeout_id);
+ timeout_id = g_timeout_add_seconds (5, quit_loop, data.loop);
+ g_main_loop_run (data.loop);
+ g_source_remove (timeout_id);
+
+ g_object_unref (browser);
+ g_object_unref (client);
+ g_main_loop_unref (data.loop);
+}
+
+/*
+ * Search for FunctionalTest:1 and accept FunctionalTest:9
+ */
+static void
+test_discovery_versioned_backwards_compatible (void)
+{
+ GSSDPClient *client;
+ GSSDPResourceBrowser *browser;
+ GError *error = NULL;
+ TestDiscoverySSDPAllData data;
+ gulong signal_id;
+ guint timeout_id;
+
+ data.loop = g_main_loop_new (NULL, FALSE);
+ data.usn = VERSIONED_USN_2;
+ data.found = FALSE;
+
+ client = gssdp_client_new (NULL, "lo", &error);
+ g_assert (client != NULL);
+ g_assert (error == NULL);
+
+ browser = gssdp_resource_browser_new (client, VERSIONED_NT_1);
+ signal_id = g_signal_connect (browser,
+ "resource-available",
+ G_CALLBACK (on_test_discovery_ssdp_all_resource_available),
+ &data);
+ gssdp_resource_browser_set_active (browser, TRUE);
+
+ timeout_id = g_timeout_add_seconds (10, quit_loop, data.loop);
+
+ /* delay announcement until browser issued its M-SEARCH */
+ g_timeout_add_seconds (1,
+ test_discovery_send_packet,
+ create_alive_message (VERSIONED_NT_2));
+ g_main_loop_run (data.loop);
+
+ g_assert (data.found);
+
+ data.found = FALSE;
+ g_signal_handler_disconnect (browser, signal_id);
+ g_timeout_add_seconds (1,
+ test_discovery_send_packet,
+ create_byebye_message (VERSIONED_NT_2));
+ signal_id = g_signal_connect (browser,
+ "resource-unavailable",
+ G_CALLBACK (on_test_discovery_ssdp_all_resource_unavailable),
+ &data);
+ g_main_loop_run (data.loop);
+
+ g_assert (data.found);
+
+ g_source_remove (timeout_id);
+ g_object_unref (browser);
+ g_object_unref (client);
+ g_main_loop_unref (data.loop);
+}
+
+/*
+ * Search for FunctionalTest:9 and ignore FunctionalTest:1
+ */
+static void
+test_discovery_versioned_ignore_older (void)
+{
+ GSSDPClient *client;
+ GSSDPResourceBrowser *browser;
+ GError *error = NULL;
+ GMainLoop *loop;
+
+ loop = g_main_loop_new (NULL, FALSE);
+
+ client = gssdp_client_new (NULL, "lo", &error);
+ g_assert (client != NULL);
+ g_assert (error == NULL);
+
+ browser = gssdp_resource_browser_new (client, VERSIONED_NT_2);
+ g_signal_connect (browser,
+ "resource-available",
+ G_CALLBACK (on_resource_available_assert_not_reached),
+ NULL);
+ gssdp_resource_browser_set_active (browser, TRUE);
+
+ g_timeout_add_seconds (5, quit_loop, loop);
+
+ /* delay announcement until browser issued its M-SEARCH */
+ g_timeout_add_seconds (1,
+ test_discovery_send_packet,
+ create_alive_message (VERSIONED_NT_1));
+ g_main_loop_run (loop);
+
+ g_object_unref (browser);
+ g_object_unref (client);
+ g_main_loop_unref (loop);
+}
+
+
+int main(int argc, char *argv[])
+{
+ g_type_init ();
+ g_test_init (&argc, &argv, NULL);
+
+ g_test_add_func ("/functional/resource-group/discovery/ssdp:all",
+ test_discovery_ssdp_all);
+
+ g_test_add_func ("/functional/resource-group/discovery/upnp:rootdevice",
+ test_discovery_upnp_rootdevice);
+
+ g_test_add_func ("/functional/resource-group/discovery/uuid",
+ test_discovery_uuid);
+
+ g_test_add_func ("/functional/resource-group/discovery/versioned/matching",
+ test_discovery_versioned);
+
+ g_test_add_func ("/functional/resource-group/discovery/versioned/backwards-compatible",
+ test_discovery_versioned_backwards_compatible);
+
+ g_test_add_func ("/functional/resource-group/discovery/versioned/ignore-older",
+ test_discovery_versioned_ignore_older);
+
+ g_test_run ();
+
+ return 0;
+}
diff --git a/tests/gtest/test-regression.c b/tests/gtest/test-regression.c
index ec1b967..c93b9fc 100644
--- a/tests/gtest/test-regression.c
+++ b/tests/gtest/test-regression.c
@@ -26,12 +26,7 @@
#include <libgssdp/gssdp-resource-browser.h>
#include <libgssdp/gssdp-resource-group.h>
-static void
-on_test_bgo673150_resource_unavailable (GSSDPResourceBrowser *src,
- const char *usn)
-{
- g_assert_not_reached ();
-}
+#include "test-util.h"
static gboolean
on_test_bgo673150_delay_timeout (gpointer user_data)
@@ -73,7 +68,7 @@ test_bgo673150 (void)
signal_id = g_signal_connect (browser,
"resource-unavailable",
- G_CALLBACK (on_test_bgo673150_resource_unavailable),
+ G_CALLBACK (on_resource_unavailable_assert_not_reached),
NULL);
/* Delay resource browser until ressource group sent its initial
diff --git a/tests/gtest/test-util.c b/tests/gtest/test-util.c
new file mode 100644
index 0000000..8a620e6
--- /dev/null
+++ b/tests/gtest/test-util.c
@@ -0,0 +1,26 @@
+#include "test-util.h"
+
+void
+on_resource_unavailable_assert_not_reached (GSSDPResourceBrowser *src,
+ const char *usn,
+ gpointer user_data)
+{
+ g_assert_not_reached ();
+}
+
+void
+on_resource_available_assert_not_reached (GSSDPResourceBrowser *src,
+ const char *usn,
+ GList *locations,
+ gpointer user_data)
+{
+ g_assert_not_reached ();
+}
+
+gboolean
+quit_loop (gpointer user_data)
+{
+ g_main_loop_quit ((GMainLoop *) user_data);
+
+ return FALSE;
+}
diff --git a/tests/gtest/test-util.h b/tests/gtest/test-util.h
new file mode 100644
index 0000000..bd35b33
--- /dev/null
+++ b/tests/gtest/test-util.h
@@ -0,0 +1,46 @@
+/*
+ * Copyright (C) 2012 Openismus GmbH
+ *
+ * Author: Jens Georg <jensg openismus com>
+ *
+ * This library is free software; you can redistribute it and/or
+ * modify it under the terms of the GNU Library General Public
+ * License as published by the Free Software Foundation; either
+ * version 2 of the License, or (at your option) any later version.
+ *
+ * This library is distributed in the hope that it will be useful,
+ * but WITHOUT ANY WARRANTY; without even the implied warranty of
+ * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
+ * Library General Public License for more details.
+ *
+ * You should have received a copy of the GNU Library General Public
+ * License along with this library; if not, write to the
+ * Free Software Foundation, Inc., 59 Temple Place - Suite 330,
+ * Boston, MA 02111-1307, USA.
+ */
+
+#ifndef TESTUTIL_H
+#define TESTUTIL_H
+
+#include <libgssdp/gssdp-resource-browser.h>
+
+G_BEGIN_DECLS
+
+
+gboolean
+quit_loop (gpointer user_data);
+
+void
+on_resource_available_assert_not_reached (GSSDPResourceBrowser *src,
+ const char *usn,
+ GList *locations,
+ gpointer user_data);
+
+void
+on_resource_unavailable_assert_not_reached (GSSDPResourceBrowser *src,
+ const char *usn,
+ gpointer user_data);
+
+G_END_DECLS
+
+#endif // TESTUTIL_H
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]
