mirror of
https://gitlab.freedesktop.org/pipewire/wireplumber.git
synced 2026-04-10 12:50:38 +02:00
399 lines
16 KiB
C
399 lines
16 KiB
C
/* WirePlumber
|
|
*
|
|
* Copyright © 2019 Collabora Ltd.
|
|
* @author Julian Bouzas <julian.bouzas@collabora.com>
|
|
*
|
|
* SPDX-License-Identifier: MIT
|
|
*/
|
|
|
|
#include "../common/base-test-fixture.h"
|
|
#include "config-policy/context.h"
|
|
|
|
typedef struct {
|
|
WpBaseTestFixture base;
|
|
} TestConfigPolicyFixture;
|
|
|
|
static void
|
|
config_policy_setup (TestConfigPolicyFixture *self, gconstpointer user_data)
|
|
{
|
|
wp_base_test_fixture_setup (&self->base, 0);
|
|
}
|
|
|
|
static void
|
|
config_policy_teardown (TestConfigPolicyFixture *self, gconstpointer user_data)
|
|
{
|
|
wp_base_test_fixture_teardown (&self->base);
|
|
}
|
|
|
|
static void
|
|
playback (TestConfigPolicyFixture *f, gconstpointer data)
|
|
{
|
|
g_autoptr (WpConfigPolicyContext) ctx = wp_config_policy_context_new (
|
|
f->base.core, f->base.loop, "config-policy/config-playback");
|
|
WpBaseEndpointLink *link = NULL;
|
|
g_autoptr (WpBaseEndpoint) src = NULL;
|
|
g_autoptr (WpBaseEndpoint) sink = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep1 = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep2 = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep3 = NULL;
|
|
|
|
/* Create the device endpoint */
|
|
ep1 = wp_config_policy_context_add_endpoint (ctx, "ep1", "Fake/Sink",
|
|
PW_DIRECTION_INPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep1);
|
|
g_assert_false (wp_base_endpoint_is_linked (ep1));
|
|
|
|
/* Create the first client endpoint */
|
|
ep2 = wp_config_policy_context_add_endpoint (ctx, "ep2", "Stream/Output/Fake",
|
|
PW_DIRECTION_OUTPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep2);
|
|
g_assert_true (wp_base_endpoint_is_linked (ep2));
|
|
g_assert_true (wp_base_endpoint_is_linked (ep1));
|
|
link = g_ptr_array_index (wp_base_endpoint_get_links (ep2), 0);
|
|
src = wp_base_endpoint_link_get_source_endpoint (link);
|
|
sink = wp_base_endpoint_link_get_sink_endpoint (link);
|
|
g_assert_true (ep2 == src);
|
|
g_assert_true (ep1 == sink);
|
|
|
|
/* Create the second client endpoint */
|
|
ep3 = wp_config_policy_context_add_endpoint (ctx, "ep3", "Stream/Output/Fake",
|
|
PW_DIRECTION_OUTPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep2);
|
|
g_assert_true (wp_base_endpoint_is_linked (ep3));
|
|
g_assert_true (wp_base_endpoint_is_linked (ep1));
|
|
link = g_ptr_array_index (wp_base_endpoint_get_links (ep3), 0);
|
|
src = wp_base_endpoint_link_get_source_endpoint (link);
|
|
sink = wp_base_endpoint_link_get_sink_endpoint (link);
|
|
g_assert_true (ep3 == src);
|
|
g_assert_true (ep1 == sink);
|
|
|
|
/* Make sure ep2 is unlinked after ep3 was linked */
|
|
g_assert_false (wp_base_endpoint_is_linked (ep2));
|
|
|
|
/* Remove the client endpoints */
|
|
wp_config_policy_context_remove_endpoint (ctx, ep2);
|
|
wp_config_policy_context_remove_endpoint (ctx, ep3);
|
|
}
|
|
|
|
static void
|
|
capture (TestConfigPolicyFixture *f, gconstpointer data)
|
|
{
|
|
g_autoptr (WpConfigPolicyContext) ctx = wp_config_policy_context_new (
|
|
f->base.core, f->base.loop, "config-policy/config-capture");
|
|
WpBaseEndpointLink *link = NULL;
|
|
g_autoptr (WpBaseEndpoint) src = NULL;
|
|
g_autoptr (WpBaseEndpoint) sink = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep1 = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep2 = NULL;
|
|
|
|
/* Create the device endpoint */
|
|
ep1 = wp_config_policy_context_add_endpoint (ctx, "ep1", "Fake/Source",
|
|
PW_DIRECTION_OUTPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep1);
|
|
g_assert_false (wp_base_endpoint_is_linked (ep1));
|
|
|
|
/* Create the client endpoint */
|
|
ep2 = wp_config_policy_context_add_endpoint (ctx, "ep2", "Stream/Input/Fake",
|
|
PW_DIRECTION_INPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep2);
|
|
link = g_ptr_array_index (wp_base_endpoint_get_links (ep2), 0);
|
|
g_assert_true (wp_base_endpoint_is_linked (ep2));
|
|
g_assert_true (wp_base_endpoint_is_linked (ep1));
|
|
src = wp_base_endpoint_link_get_source_endpoint (link);
|
|
sink = wp_base_endpoint_link_get_sink_endpoint (link);
|
|
g_assert_true (ep1 == src);
|
|
g_assert_true (ep2 == sink);
|
|
|
|
/* Remove the client endpoint */
|
|
wp_config_policy_context_remove_endpoint (ctx, ep2);
|
|
}
|
|
|
|
static void
|
|
playback_capture (TestConfigPolicyFixture *f, gconstpointer data)
|
|
{
|
|
g_autoptr (WpConfigPolicyContext) ctx = wp_config_policy_context_new (
|
|
f->base.core, f->base.loop, "config-policy/config-playback-capture");
|
|
WpBaseEndpointLink *link = NULL;
|
|
g_autoptr (WpBaseEndpoint) src = NULL;
|
|
g_autoptr (WpBaseEndpoint) sink = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep1 = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep2 = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep3 = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep4 = NULL;
|
|
|
|
/* Create the device endpoints */
|
|
ep1 = wp_config_policy_context_add_endpoint (ctx, "ep1", "Fake/Sink",
|
|
PW_DIRECTION_INPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep1);
|
|
g_assert_false (wp_base_endpoint_is_linked (ep1));
|
|
ep2 = wp_config_policy_context_add_endpoint (ctx, "ep2", "Fake/Source",
|
|
PW_DIRECTION_OUTPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep2);
|
|
g_assert_false (wp_base_endpoint_is_linked (ep2));
|
|
|
|
/* Create the playback client endpoint */
|
|
ep3 = wp_config_policy_context_add_endpoint (ctx, "ep3", "Stream/Output/Fake",
|
|
PW_DIRECTION_OUTPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep3);
|
|
g_assert_true (wp_base_endpoint_is_linked (ep3));
|
|
g_assert_true (wp_base_endpoint_is_linked (ep1));
|
|
g_assert_false (wp_base_endpoint_is_linked (ep2));
|
|
link = g_ptr_array_index (wp_base_endpoint_get_links (ep3), 0);
|
|
src = wp_base_endpoint_link_get_source_endpoint (link);
|
|
sink = wp_base_endpoint_link_get_sink_endpoint (link);
|
|
g_assert_true (ep3 == src);
|
|
g_assert_true (ep1 == sink);
|
|
|
|
/* Create the capture client endpoint */
|
|
ep4 = wp_config_policy_context_add_endpoint (ctx, "ep4", "Stream/Input/Fake",
|
|
PW_DIRECTION_INPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep4);
|
|
g_assert_true (wp_base_endpoint_is_linked (ep4));
|
|
g_assert_true (wp_base_endpoint_is_linked (ep2));
|
|
g_assert_true (wp_base_endpoint_is_linked (ep3));
|
|
g_assert_true (wp_base_endpoint_is_linked (ep1));
|
|
link = g_ptr_array_index (wp_base_endpoint_get_links (ep4), 0);
|
|
src = wp_base_endpoint_link_get_source_endpoint (link);
|
|
sink = wp_base_endpoint_link_get_sink_endpoint (link);
|
|
g_assert_true (ep2 == src);
|
|
g_assert_true (ep4 == sink);
|
|
|
|
/* Remove the client endpoints */
|
|
wp_config_policy_context_remove_endpoint (ctx, ep4);
|
|
wp_config_policy_context_remove_endpoint (ctx, ep3);
|
|
}
|
|
|
|
static void
|
|
playback_priority (TestConfigPolicyFixture *f, gconstpointer data)
|
|
{
|
|
g_autoptr (WpConfigPolicyContext) ctx = wp_config_policy_context_new (
|
|
f->base.core, f->base.loop, "config-policy/config-playback-priority");
|
|
WpBaseEndpointLink *link = NULL;
|
|
g_autoptr (WpBaseEndpoint) src = NULL;
|
|
g_autoptr (WpBaseEndpoint) sink = NULL;
|
|
g_autoptr (WpBaseEndpoint) dev = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep1 = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep2 = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep3 = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep4 = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep5 = NULL;
|
|
|
|
/* Create the device endpoint with 4 streams */
|
|
dev = wp_config_policy_context_add_endpoint (ctx, "dev", "Fake/Sink",
|
|
PW_DIRECTION_INPUT, NULL, NULL, 4);
|
|
g_assert_nonnull (dev);
|
|
g_assert_false (wp_base_endpoint_is_linked (dev));
|
|
|
|
/* Create the client endpoint for steam 2 (priority 2) and make sure it
|
|
* is linked */
|
|
ep2 = wp_config_policy_context_add_endpoint (ctx, "ep_for_stream_2",
|
|
"Stream/Output/Fake", PW_DIRECTION_OUTPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep2);
|
|
g_assert_true (wp_base_endpoint_is_linked (ep2));
|
|
g_assert_true (wp_base_endpoint_is_linked (dev));
|
|
link = g_ptr_array_index (wp_base_endpoint_get_links (ep2), 0);
|
|
src = wp_base_endpoint_link_get_source_endpoint (link);
|
|
sink = wp_base_endpoint_link_get_sink_endpoint (link);
|
|
g_assert_true (ep2 == src);
|
|
g_assert_true (dev == sink);
|
|
|
|
/* Create the client endpoint for steam 1 (priority 1) and make sure it
|
|
* is not linked */
|
|
ep1 = wp_config_policy_context_add_endpoint (ctx, "ep_for_stream_1",
|
|
"Stream/Output/Fake", PW_DIRECTION_OUTPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep1);
|
|
g_assert_false (wp_base_endpoint_is_linked (ep1));
|
|
g_assert_true (wp_base_endpoint_is_linked (ep2));
|
|
g_assert_true (wp_base_endpoint_is_linked (dev));
|
|
|
|
/* Create the client endpoint for steam 3 (priority 3) and make sure it
|
|
* is linked */
|
|
ep3 = wp_config_policy_context_add_endpoint (ctx, "ep_for_stream_3",
|
|
"Stream/Output/Fake", PW_DIRECTION_OUTPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep3);
|
|
g_assert_true (wp_base_endpoint_is_linked (ep3));
|
|
g_assert_true (wp_base_endpoint_is_linked (dev));
|
|
g_assert_false (wp_base_endpoint_is_linked (ep1));
|
|
g_assert_false (wp_base_endpoint_is_linked (ep2));
|
|
link = g_ptr_array_index (wp_base_endpoint_get_links (ep3), 0);
|
|
src = wp_base_endpoint_link_get_source_endpoint (link);
|
|
sink = wp_base_endpoint_link_get_sink_endpoint (link);
|
|
g_assert_true (ep3 == src);
|
|
g_assert_true (dev == sink);
|
|
|
|
/* Remove ep2 and ep1 */
|
|
wp_config_policy_context_remove_endpoint (ctx, ep2);
|
|
wp_config_policy_context_remove_endpoint (ctx, ep1);
|
|
|
|
/* Create the client endpoint with role "1" (priority 1) and make sure it
|
|
* is not linked */
|
|
ep4 = wp_config_policy_context_add_endpoint (ctx, "ep_with_role",
|
|
"Stream/Output/Fake", PW_DIRECTION_OUTPUT, NULL, "1", 0);
|
|
g_assert_nonnull (ep4);
|
|
g_assert_false (wp_base_endpoint_is_linked (ep4));
|
|
|
|
/* Create the client endpoint with role "3" (priority 3) and make sure it
|
|
* is linked (last one wins) */
|
|
ep5 = wp_config_policy_context_add_endpoint (ctx, "ep_with_role",
|
|
"Stream/Output/Fake", PW_DIRECTION_OUTPUT, NULL, "3", 0);
|
|
g_assert_nonnull (ep5);
|
|
g_assert_true (wp_base_endpoint_is_linked (ep5));
|
|
g_assert_true (wp_base_endpoint_is_linked (dev));
|
|
g_assert_false (wp_base_endpoint_is_linked (ep4));
|
|
g_assert_false (wp_base_endpoint_is_linked (ep3));
|
|
link = g_ptr_array_index (wp_base_endpoint_get_links (ep5), 0);
|
|
src = wp_base_endpoint_link_get_source_endpoint (link);
|
|
sink = wp_base_endpoint_link_get_sink_endpoint (link);
|
|
g_assert_true (ep5 == src);
|
|
g_assert_true (dev == sink);
|
|
|
|
/* Remove ep4, ep5 and ep3 */
|
|
wp_config_policy_context_remove_endpoint (ctx, ep4);
|
|
wp_config_policy_context_remove_endpoint (ctx, ep5);
|
|
wp_config_policy_context_remove_endpoint (ctx, ep3);
|
|
}
|
|
|
|
static void
|
|
playback_keep (TestConfigPolicyFixture *f, gconstpointer data)
|
|
{
|
|
g_autoptr (WpConfigPolicyContext) ctx = wp_config_policy_context_new (
|
|
f->base.core, f->base.loop, "config-policy/config-playback-keep");
|
|
WpBaseEndpointLink *link = NULL;
|
|
g_autoptr (WpBaseEndpoint) src = NULL;
|
|
g_autoptr (WpBaseEndpoint) sink = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep1 = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep2 = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep3 = NULL;
|
|
|
|
/* Create the device endpoint */
|
|
ep1 = wp_config_policy_context_add_endpoint (ctx, "ep1", "Fake/Sink",
|
|
PW_DIRECTION_INPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep1);
|
|
g_assert_false (wp_base_endpoint_is_linked (ep1));
|
|
|
|
/* Create the first client endpoint */
|
|
ep2 = wp_config_policy_context_add_endpoint (ctx, "ep2", "Stream/Output/Fake",
|
|
PW_DIRECTION_OUTPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep2);
|
|
g_assert_true (wp_base_endpoint_is_linked (ep2));
|
|
g_assert_true (wp_base_endpoint_is_linked (ep1));
|
|
link = g_ptr_array_index (wp_base_endpoint_get_links (ep2), 0);
|
|
src = wp_base_endpoint_link_get_source_endpoint (link);
|
|
sink = wp_base_endpoint_link_get_sink_endpoint (link);
|
|
g_assert_true (ep2 == src);
|
|
g_assert_true (ep1 == sink);
|
|
|
|
/* Create the second client endpoint */
|
|
ep3 = wp_config_policy_context_add_endpoint (ctx, "ep3", "Stream/Output/Fake",
|
|
PW_DIRECTION_OUTPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep2);
|
|
g_assert_true (wp_base_endpoint_is_linked (ep3));
|
|
g_assert_true (wp_base_endpoint_is_linked (ep1));
|
|
link = g_ptr_array_index (wp_base_endpoint_get_links (ep3), 0);
|
|
src = wp_base_endpoint_link_get_source_endpoint (link);
|
|
sink = wp_base_endpoint_link_get_sink_endpoint (link);
|
|
g_assert_true (ep3 == src);
|
|
g_assert_true (ep1 == sink);
|
|
|
|
/* Make sure ep2 is still linked after ep3 was linked */
|
|
g_assert_true (wp_base_endpoint_is_linked (ep2));
|
|
|
|
/* Remove the client endpoints */
|
|
wp_config_policy_context_remove_endpoint (ctx, ep2);
|
|
wp_config_policy_context_remove_endpoint (ctx, ep3);
|
|
}
|
|
|
|
static void
|
|
playback_role (TestConfigPolicyFixture *f, gconstpointer data)
|
|
{
|
|
g_autoptr (WpConfigPolicyContext) ctx = wp_config_policy_context_new (
|
|
f->base.core, f->base.loop, "config-policy/config-playback-role");
|
|
WpBaseEndpointLink *link = NULL;
|
|
g_autoptr (WpBaseEndpoint) src = NULL;
|
|
g_autoptr (WpBaseEndpoint) sink = NULL;
|
|
g_autoptr (WpBaseEndpoint) dev = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep1 = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep2 = NULL;
|
|
g_autoptr (WpBaseEndpoint) ep3 = NULL;
|
|
|
|
/* Create the device with 2 roles: "0" with id 0, and "1" with id 1 */
|
|
dev = wp_config_policy_context_add_endpoint (ctx, "dev", "Fake/Sink",
|
|
PW_DIRECTION_INPUT, NULL, NULL, 2);
|
|
g_assert_nonnull (dev);
|
|
g_assert_false (wp_base_endpoint_is_linked (dev));
|
|
|
|
/* Create the first client endpoint with role "0" and make sure the role
|
|
* defined in the configuration file which is "1" is used */
|
|
ep1 = wp_config_policy_context_add_endpoint (ctx, "ep1", "Stream/Output/Fake",
|
|
PW_DIRECTION_OUTPUT, NULL, "0", 0);
|
|
g_assert_nonnull (ep1);
|
|
g_assert_true (wp_base_endpoint_is_linked (ep1));
|
|
g_assert_true (wp_base_endpoint_is_linked (dev));
|
|
link = g_ptr_array_index (wp_base_endpoint_get_links (ep1), 0);
|
|
src = wp_base_endpoint_link_get_source_endpoint (link);
|
|
sink = wp_base_endpoint_link_get_sink_endpoint (link);
|
|
g_assert_true (ep1 == src);
|
|
g_assert_true (dev == sink);
|
|
g_assert_true (
|
|
WP_STREAM_ID_NONE == wp_base_endpoint_link_get_source_stream (link));
|
|
g_assert_true (1 == wp_base_endpoint_link_get_sink_stream (link));
|
|
wp_config_policy_context_remove_endpoint (ctx, ep1);
|
|
|
|
/* Create the second client endpoint with role "1" and make sure it uses it
|
|
* because there is none defined in the configuration file */
|
|
ep2 = wp_config_policy_context_add_endpoint (ctx, "ep2", "Stream/Output/Fake",
|
|
PW_DIRECTION_OUTPUT, NULL, "1", 0);
|
|
g_assert_nonnull (ep2);
|
|
g_assert_true (wp_base_endpoint_is_linked (ep2));
|
|
g_assert_true (wp_base_endpoint_is_linked (dev));
|
|
link = g_ptr_array_index (wp_base_endpoint_get_links (ep2), 0);
|
|
src = wp_base_endpoint_link_get_source_endpoint (link);
|
|
sink = wp_base_endpoint_link_get_sink_endpoint (link);
|
|
g_assert_true (ep2 == src);
|
|
g_assert_true (dev == sink);
|
|
g_assert_true (
|
|
WP_STREAM_ID_NONE == wp_base_endpoint_link_get_source_stream (link));
|
|
g_assert_true (1 == wp_base_endpoint_link_get_sink_stream (link));
|
|
wp_config_policy_context_remove_endpoint (ctx, ep2);
|
|
|
|
/* Create the third client endpoint without role and make sure it uses the
|
|
* lowest priority on from the streams file because the endpoint-link file
|
|
* does not have any either */
|
|
ep3 = wp_config_policy_context_add_endpoint (ctx, "ep3", "Stream/Output/Fake",
|
|
PW_DIRECTION_OUTPUT, NULL, NULL, 0);
|
|
g_assert_nonnull (ep3);
|
|
g_assert_true (wp_base_endpoint_is_linked (ep3));
|
|
g_assert_true (wp_base_endpoint_is_linked (dev));
|
|
link = g_ptr_array_index (wp_base_endpoint_get_links (ep3), 0);
|
|
src = wp_base_endpoint_link_get_source_endpoint (link);
|
|
sink = wp_base_endpoint_link_get_sink_endpoint (link);
|
|
g_assert_true (ep3 == src);
|
|
g_assert_true (dev == sink);
|
|
g_assert_true (
|
|
WP_STREAM_ID_NONE == wp_base_endpoint_link_get_source_stream (link));
|
|
g_assert_true (0 == wp_base_endpoint_link_get_sink_stream (link));
|
|
wp_config_policy_context_remove_endpoint (ctx, ep3);
|
|
}
|
|
|
|
int
|
|
main (int argc, char *argv[])
|
|
{
|
|
g_test_init (&argc, &argv, NULL);
|
|
pw_init (NULL, NULL);
|
|
g_log_set_writer_func (wp_log_writer_default, NULL, NULL);
|
|
|
|
g_test_add ("/modules/config-policy/playback", TestConfigPolicyFixture,
|
|
NULL, config_policy_setup, playback, config_policy_teardown);
|
|
g_test_add ("/modules/config-policy/capture", TestConfigPolicyFixture,
|
|
NULL, config_policy_setup, capture, config_policy_teardown);
|
|
g_test_add ("/modules/config-policy/playback-capture", TestConfigPolicyFixture,
|
|
NULL, config_policy_setup, playback_capture, config_policy_teardown);
|
|
g_test_add ("/modules/config-policy/playback-priority", TestConfigPolicyFixture,
|
|
NULL, config_policy_setup, playback_priority, config_policy_teardown);
|
|
g_test_add ("/modules/config-policy/playback-keep", TestConfigPolicyFixture,
|
|
NULL, config_policy_setup, playback_keep, config_policy_teardown);
|
|
g_test_add ("/modules/config-policy/playback-role", TestConfigPolicyFixture,
|
|
NULL, config_policy_setup, playback_role, config_policy_teardown);
|
|
|
|
return g_test_run ();
|
|
}
|