mirror of
https://gitlab.freedesktop.org/pipewire/wireplumber.git
synced 2026-05-08 22:08:45 +02:00
modules: add si-audio-endpoint session item
This commit is contained in:
Julian Bouzas
parent
e3cc3c330d
commit
325522ae51
4 changed files with 801 additions and 0 deletions
|
|
@ -112,6 +112,17 @@ shared_library(
|
|||
dependencies : [wp_dep, pipewire_dep],
|
||||
)
|
||||
|
||||
shared_library(
|
||||
'wireplumber-module-si-audio-endpoint',
|
||||
[
|
||||
'module-si-audio-endpoint.c',
|
||||
],
|
||||
c_args : [common_c_args, '-DG_LOG_DOMAIN="m-si-audio-endpoint"'],
|
||||
install : true,
|
||||
install_dir : wireplumber_module_dir,
|
||||
dependencies : [wp_dep, pipewire_dep],
|
||||
)
|
||||
|
||||
shared_library(
|
||||
'wireplumber-module-si-node',
|
||||
[
|
||||
|
|
|
|||
509
modules/module-si-audio-endpoint.c
Normal file
509
modules/module-si-audio-endpoint.c
Normal file
|
|
@ -0,0 +1,509 @@
|
|||
/* WirePlumber
|
||||
*
|
||||
* Copyright © 2020 Collabora Ltd.
|
||||
* @author Julian Bouzas <julian.bouzas@collabora.com>
|
||||
*
|
||||
* SPDX-License-Identifier: MIT
|
||||
*/
|
||||
|
||||
#include <wp/wp.h>
|
||||
#include <pipewire/pipewire.h>
|
||||
#include <pipewire/extensions/session-manager/keys.h>
|
||||
#include <spa/param/audio/raw.h>
|
||||
|
||||
#define SI_FACTORY_NAME "si-audio-endpoint"
|
||||
|
||||
struct _WpSiAudioEndpoint
|
||||
{
|
||||
WpSessionItem parent;
|
||||
|
||||
/* configuration */
|
||||
gchar name[96];
|
||||
WpSessionItem *target;
|
||||
WpSession *session;
|
||||
WpDirection direction;
|
||||
gchar role[32];
|
||||
guint priority;
|
||||
|
||||
/* activation */
|
||||
WpNode *node;
|
||||
WpObjectManager *links_om;
|
||||
WpSessionItem *target_link;
|
||||
|
||||
/* export */
|
||||
WpImplEndpoint *impl_endpoint;
|
||||
};
|
||||
|
||||
static void si_audio_endpoint_endpoint_init (WpSiEndpointInterface * iface);
|
||||
static void si_audio_endpoint_port_info_init (WpSiPortInfoInterface * iface);
|
||||
|
||||
G_DECLARE_FINAL_TYPE(WpSiAudioEndpoint, si_audio_endpoint, WP,
|
||||
SI_AUDIO_ENDPOINT, WpSessionItem)
|
||||
G_DEFINE_TYPE_WITH_CODE (WpSiAudioEndpoint, si_audio_endpoint,
|
||||
WP_TYPE_SESSION_ITEM,
|
||||
G_IMPLEMENT_INTERFACE (WP_TYPE_SI_ENDPOINT, si_audio_endpoint_endpoint_init)
|
||||
G_IMPLEMENT_INTERFACE (WP_TYPE_SI_PORT_INFO,
|
||||
si_audio_endpoint_port_info_init))
|
||||
|
||||
static void
|
||||
si_audio_endpoint_init (WpSiAudioEndpoint * self)
|
||||
{
|
||||
}
|
||||
|
||||
static void
|
||||
si_audio_endpoint_reset (WpSessionItem * item)
|
||||
{
|
||||
WpSiAudioEndpoint *self = WP_SI_AUDIO_ENDPOINT (item);
|
||||
|
||||
/* deactivate first */
|
||||
wp_object_deactivate (WP_OBJECT (self),
|
||||
WP_SESSION_ITEM_FEATURE_ACTIVE | WP_SESSION_ITEM_FEATURE_EXPORTED);
|
||||
|
||||
/* reset */
|
||||
self->name[0] = '\0';
|
||||
g_clear_object (&self->target);
|
||||
g_clear_object (&self->session);
|
||||
self->direction = WP_DIRECTION_INPUT;
|
||||
self->role[0] = '\0';
|
||||
self->priority = 0;
|
||||
|
||||
WP_SESSION_ITEM_CLASS (si_audio_endpoint_parent_class)->reset (item);
|
||||
}
|
||||
|
||||
static gboolean
|
||||
si_audio_endpoint_configure (WpSessionItem * item, WpProperties *p)
|
||||
{
|
||||
WpSiAudioEndpoint *self = WP_SI_AUDIO_ENDPOINT (item);
|
||||
g_autoptr (WpProperties) si_props = wp_properties_ensure_unique_owner (p);
|
||||
WpSessionItem *target;
|
||||
WpProperties *target_props = NULL;
|
||||
WpSession *session = NULL;
|
||||
const gchar *str;
|
||||
|
||||
/* reset previous config */
|
||||
si_audio_endpoint_reset (item);
|
||||
|
||||
str = wp_properties_get (si_props, "name");
|
||||
if (!str)
|
||||
return FALSE;
|
||||
strncpy (self->name, str, sizeof (self->name) - 1);
|
||||
|
||||
str = wp_properties_get (si_props, "target");
|
||||
if (!str || sscanf(str, "%p", &target) != 1 || !WP_IS_SI_PORT_INFO (target))
|
||||
return FALSE;
|
||||
|
||||
target_props = wp_session_item_get_properties (WP_SESSION_ITEM (target));
|
||||
|
||||
str = wp_properties_get (si_props, "direction");
|
||||
if (!str) {
|
||||
str = wp_properties_get (target_props, "direction");
|
||||
wp_properties_set (si_props, "direction", str);
|
||||
}
|
||||
if (!str || sscanf(str, "%u", &self->direction) != 1)
|
||||
return FALSE;
|
||||
|
||||
str = wp_properties_get (si_props, "role");
|
||||
if (str) {
|
||||
strncpy (self->role, str, sizeof (self->role) - 1);
|
||||
} else {
|
||||
strncpy (self->role, "Unknown", sizeof (self->role) - 1);
|
||||
wp_properties_set (si_props, "role", self->role);
|
||||
}
|
||||
|
||||
str = wp_properties_get (si_props, "priority");
|
||||
if (str && sscanf(str, "%u", &self->priority) != 1)
|
||||
return FALSE;
|
||||
if (!str)
|
||||
wp_properties_setf (si_props, "priority", "%u", self->priority);
|
||||
|
||||
/* session is optional (only needed if we want to export) */
|
||||
str = wp_properties_get (si_props, "session");
|
||||
if (str && (sscanf(str, "%p", &session) != 1 || !WP_IS_SESSION (session)))
|
||||
return FALSE;
|
||||
if (!str)
|
||||
wp_properties_setf (si_props, "session", "%p", session);
|
||||
|
||||
self->target = g_object_ref (target);
|
||||
if (session)
|
||||
self->session = g_object_ref (session);
|
||||
|
||||
wp_properties_set (si_props, "si-factory-name", SI_FACTORY_NAME);
|
||||
wp_session_item_set_properties (WP_SESSION_ITEM (self),
|
||||
g_steal_pointer (&si_props));
|
||||
return TRUE;
|
||||
}
|
||||
|
||||
static gpointer
|
||||
si_audio_endpoint_get_associated_proxy (WpSessionItem * item, GType proxy_type)
|
||||
{
|
||||
WpSiAudioEndpoint *self = WP_SI_AUDIO_ENDPOINT (item);
|
||||
|
||||
if (proxy_type == WP_TYPE_NODE)
|
||||
return self->node ? g_object_ref (self->node) : NULL;
|
||||
if (proxy_type == WP_TYPE_SESSION)
|
||||
return self->session ? g_object_ref (self->session) : NULL;
|
||||
else if (proxy_type == WP_TYPE_ENDPOINT)
|
||||
return self->impl_endpoint ? g_object_ref (self->impl_endpoint) : NULL;
|
||||
|
||||
return NULL;
|
||||
}
|
||||
|
||||
static void
|
||||
si_audio_endpoint_disable_active (WpSessionItem *si)
|
||||
{
|
||||
WpSiAudioEndpoint *self = WP_SI_AUDIO_ENDPOINT (si);
|
||||
|
||||
g_clear_object (&self->node);
|
||||
g_clear_object (&self->links_om);
|
||||
g_clear_object (&self->target_link);
|
||||
wp_object_update_features (WP_OBJECT (self), 0,
|
||||
WP_SESSION_ITEM_FEATURE_ACTIVE);
|
||||
}
|
||||
|
||||
static void
|
||||
si_audio_endpoint_disable_exported (WpSessionItem *si)
|
||||
{
|
||||
WpSiAudioEndpoint *self = WP_SI_AUDIO_ENDPOINT (si);
|
||||
|
||||
g_clear_object (&self->impl_endpoint);
|
||||
wp_object_update_features (WP_OBJECT (self), 0,
|
||||
WP_SESSION_ITEM_FEATURE_EXPORTED);
|
||||
}
|
||||
|
||||
static void
|
||||
on_target_link_activated (WpSessionItem * item, GAsyncResult * res,
|
||||
WpSiAudioEndpoint * self)
|
||||
{
|
||||
g_autoptr (GError) error = NULL;
|
||||
if (!wp_object_activate_finish (WP_OBJECT (item), res, &error))
|
||||
wp_warning_object (item, "failed to activate target link: %s",
|
||||
error->message);
|
||||
}
|
||||
|
||||
static void
|
||||
link_to_target (WpSiAudioEndpoint * self)
|
||||
{
|
||||
g_autoptr (WpCore) core = wp_object_get_core (WP_OBJECT (self->node));
|
||||
WpProperties *props = NULL;
|
||||
g_autoptr (WpSessionItem) link = NULL;
|
||||
|
||||
link = wp_session_item_make (core, "si-standard-link");
|
||||
if (G_UNLIKELY (!link)) {
|
||||
wp_warning_object (self, "could not create link; is the module loaded?");
|
||||
return;
|
||||
}
|
||||
|
||||
props = wp_properties_new_empty ();
|
||||
if (self->direction == WP_DIRECTION_INPUT) {
|
||||
/* Playback */
|
||||
wp_properties_setf (props, "out-item", "%p", self);
|
||||
wp_properties_setf (props, "in-item", "%p", self->target);
|
||||
wp_properties_set (props, "out-item-port-context", "reverse");
|
||||
} else {
|
||||
/* Capture */
|
||||
wp_properties_setf (props, "out-item", "%p", self->target);
|
||||
wp_properties_setf (props, "in-item", "%p", self);
|
||||
wp_properties_set (props, "in-item-port-context", "reverse");
|
||||
}
|
||||
|
||||
/* always create passive links; that means that they won't hold the graph
|
||||
running if they are the only links left around */
|
||||
wp_properties_setf (props, "passive", "%u", TRUE);
|
||||
|
||||
wp_session_item_configure (link, props);
|
||||
wp_object_activate (WP_OBJECT (link), WP_SESSION_ITEM_FEATURE_ACTIVE, NULL,
|
||||
(GAsyncReadyCallback) on_target_link_activated, self);
|
||||
self->target_link = g_steal_pointer (&link);
|
||||
}
|
||||
|
||||
static void
|
||||
on_links_changed (WpObjectManager * om, WpSiAudioEndpoint * self)
|
||||
{
|
||||
if (wp_object_manager_get_n_objects (om) == 0)
|
||||
g_clear_object (&self->target_link);
|
||||
else if (!self->target_link)
|
||||
link_to_target (self);
|
||||
}
|
||||
|
||||
static void
|
||||
si_audio_endpoint_setup_links_om (WpSiAudioEndpoint *self,
|
||||
WpTransition *transition)
|
||||
{
|
||||
g_autoptr (WpCore) core = wp_object_get_core (WP_OBJECT (self));
|
||||
g_auto (GVariantBuilder) b = G_VARIANT_BUILDER_INIT (G_VARIANT_TYPE_TUPLE);
|
||||
g_autoptr (WpIterator) it = NULL;
|
||||
g_auto (GValue) val = G_VALUE_INIT;
|
||||
GVariant *ports_v = NULL;
|
||||
|
||||
/* get a list of our output ports */
|
||||
for (it = wp_node_new_ports_iterator (self->node);
|
||||
wp_iterator_next (it, &val);
|
||||
g_value_unset (&val)) {
|
||||
WpPort *port = g_value_get_object (&val);
|
||||
if (wp_port_get_direction (port) != WP_DIRECTION_OUTPUT)
|
||||
continue;
|
||||
g_variant_builder_add (&b, "u", wp_proxy_get_bound_id (WP_PROXY (port)));
|
||||
}
|
||||
ports_v = g_variant_builder_end (&b);
|
||||
|
||||
/* create the links object manager */
|
||||
self->links_om = wp_object_manager_new ();
|
||||
wp_object_manager_request_object_features (self->links_om,
|
||||
WP_TYPE_LINK, WP_PROXY_FEATURE_BOUND);
|
||||
|
||||
/* interested in links that have one of our ports in their
|
||||
'link.output.port' global property */
|
||||
wp_object_manager_add_interest_full (self->links_om, ({
|
||||
WpObjectInterest *interest = wp_object_interest_new_type (WP_TYPE_LINK);
|
||||
wp_object_interest_add_constraint (interest,
|
||||
WP_CONSTRAINT_TYPE_PW_GLOBAL_PROPERTY, PW_KEY_LINK_OUTPUT_PORT,
|
||||
WP_CONSTRAINT_VERB_IN_LIST,
|
||||
ports_v);
|
||||
interest;
|
||||
}));
|
||||
|
||||
g_signal_connect_object (self->links_om, "objects-changed",
|
||||
G_CALLBACK (on_links_changed), self, 0);
|
||||
wp_core_install_object_manager (core, self->links_om);
|
||||
|
||||
wp_object_update_features (WP_OBJECT (self),
|
||||
WP_SESSION_ITEM_FEATURE_ACTIVE, 0);
|
||||
}
|
||||
|
||||
static void
|
||||
on_node_activate_done (WpObject * node, GAsyncResult * res,
|
||||
WpTransition * transition)
|
||||
{
|
||||
WpSiAudioEndpoint *self = wp_transition_get_source_object (transition);
|
||||
g_autoptr (WpCore) core = wp_object_get_core (WP_OBJECT (self));
|
||||
g_autoptr (GError) error = NULL;
|
||||
|
||||
if (!wp_object_activate_finish (node, res, &error)) {
|
||||
wp_transition_return_error (transition, g_steal_pointer (&error));
|
||||
return;
|
||||
}
|
||||
|
||||
si_audio_endpoint_setup_links_om (self, transition);
|
||||
}
|
||||
|
||||
static void
|
||||
si_audio_endpoint_enable_active (WpSessionItem *si, WpTransition *transition)
|
||||
{
|
||||
WpSiAudioEndpoint *self = WP_SI_AUDIO_ENDPOINT (si);
|
||||
g_autoptr (WpCore) core = wp_object_get_core (WP_OBJECT (self));
|
||||
g_autoptr (WpSpaPod) format = NULL;
|
||||
g_autofree gchar *name =g_strdup_printf ("control.%s", self->name);
|
||||
g_autofree gchar *desc =g_strdup_printf ("Control for %s", self->name);
|
||||
|
||||
if (!wp_session_item_is_configured (si)) {
|
||||
wp_transition_return_error (transition,
|
||||
g_error_new (WP_DOMAIN_LIBRARY, WP_LIBRARY_ERROR_INVARIANT,
|
||||
"si-audio-endpoint: item is not configured"));
|
||||
return;
|
||||
}
|
||||
|
||||
/* create the node */
|
||||
self->node = wp_node_new_from_factory (core, "adapter",
|
||||
wp_properties_new (
|
||||
PW_KEY_NODE_NAME, name,
|
||||
PW_KEY_MEDIA_CLASS, self->direction == WP_DIRECTION_INPUT ?
|
||||
"Audio/Sink" : "Audio/Source",
|
||||
PW_KEY_FACTORY_NAME, "support.null-audio-sink",
|
||||
PW_KEY_NODE_DESCRIPTION, desc,
|
||||
SPA_KEY_AUDIO_POSITION, "FL,FR",
|
||||
NULL));
|
||||
if (!self->node) {
|
||||
wp_transition_return_error (transition,
|
||||
g_error_new (WP_DOMAIN_LIBRARY, WP_LIBRARY_ERROR_INVARIANT,
|
||||
"si-audio-endpoint: could not create null-audio-sink node"));
|
||||
return;
|
||||
}
|
||||
|
||||
/* TODO: for now we always configure ports to be 2 channels at 48KHz */
|
||||
format = wp_spa_pod_new_object (
|
||||
"Spa:Pod:Object:Param:Format", "Format",
|
||||
"mediaType", "K", "audio",
|
||||
"mediaSubtype", "K", "raw",
|
||||
"format", "K", "F32P",
|
||||
"rate", "i", 48000,
|
||||
"channels", "i", 2,
|
||||
NULL);
|
||||
wp_pipewire_object_set_param (WP_PIPEWIRE_OBJECT (self->node),
|
||||
"PortConfig", 0,
|
||||
wp_spa_pod_new_object (
|
||||
"Spa:Pod:Object:Param:PortConfig", "PortConfig",
|
||||
"direction", "I", WP_DIRECTION_INPUT,
|
||||
"mode", "K", "dsp",
|
||||
"format", "P", format,
|
||||
NULL));
|
||||
wp_pipewire_object_set_param (WP_PIPEWIRE_OBJECT (self->node),
|
||||
"PortConfig", 0,
|
||||
wp_spa_pod_new_object (
|
||||
"Spa:Pod:Object:Param:PortConfig", "PortConfig",
|
||||
"direction", "I", WP_DIRECTION_OUTPUT,
|
||||
"mode", "K", "dsp",
|
||||
"control", "b", FALSE,
|
||||
"format", "P", format,
|
||||
NULL));
|
||||
|
||||
/* activate node */
|
||||
wp_object_activate (WP_OBJECT (self->node),
|
||||
WP_PIPEWIRE_OBJECT_FEATURES_MINIMAL | WP_NODE_FEATURE_PORTS, NULL,
|
||||
(GAsyncReadyCallback) on_node_activate_done, transition);
|
||||
}
|
||||
|
||||
static void
|
||||
on_impl_endpoint_activated (WpObject * object, GAsyncResult * res,
|
||||
WpTransition * transition)
|
||||
{
|
||||
WpSiAudioEndpoint *self = wp_transition_get_source_object (transition);
|
||||
g_autoptr (GError) error = NULL;
|
||||
|
||||
if (!wp_object_activate_finish (object, res, &error)) {
|
||||
wp_transition_return_error (transition, g_steal_pointer (&error));
|
||||
return;
|
||||
}
|
||||
|
||||
wp_object_update_features (WP_OBJECT (self),
|
||||
WP_SESSION_ITEM_FEATURE_EXPORTED, 0);
|
||||
}
|
||||
|
||||
static void
|
||||
si_audio_endpoint_enable_exported (WpSessionItem *si, WpTransition *transition)
|
||||
{
|
||||
WpSiAudioEndpoint *self = WP_SI_AUDIO_ENDPOINT (si);
|
||||
g_autoptr (WpCore) core = wp_object_get_core (WP_OBJECT (self));
|
||||
|
||||
self->impl_endpoint = wp_impl_endpoint_new (core, WP_SI_ENDPOINT (self));
|
||||
|
||||
g_signal_connect_object (self->impl_endpoint, "pw-proxy-destroyed",
|
||||
G_CALLBACK (wp_session_item_handle_proxy_destroyed), self, 0);
|
||||
|
||||
wp_object_activate (WP_OBJECT (self->impl_endpoint),
|
||||
WP_OBJECT_FEATURES_ALL, NULL,
|
||||
(GAsyncReadyCallback) on_impl_endpoint_activated, transition);
|
||||
}
|
||||
|
||||
static void
|
||||
si_audio_endpoint_class_init (WpSiAudioEndpointClass * klass)
|
||||
{
|
||||
WpSessionItemClass *si_class = (WpSessionItemClass *) klass;
|
||||
|
||||
si_class->reset = si_audio_endpoint_reset;
|
||||
si_class->configure = si_audio_endpoint_configure;
|
||||
si_class->get_associated_proxy = si_audio_endpoint_get_associated_proxy;
|
||||
si_class->disable_active = si_audio_endpoint_disable_active;
|
||||
si_class->disable_exported = si_audio_endpoint_disable_exported;
|
||||
si_class->enable_active = si_audio_endpoint_enable_active;
|
||||
si_class->enable_exported = si_audio_endpoint_enable_exported;
|
||||
}
|
||||
|
||||
static GVariant *
|
||||
si_audio_endpoint_get_registration_info (WpSiEndpoint * item)
|
||||
{
|
||||
WpSiAudioEndpoint *self = WP_SI_AUDIO_ENDPOINT (item);
|
||||
GVariantBuilder b;
|
||||
|
||||
g_variant_builder_init (&b, G_VARIANT_TYPE ("(ssya{ss})"));
|
||||
g_variant_builder_add (&b, "s", self->name);
|
||||
g_variant_builder_add (&b, "s", self->direction == WP_DIRECTION_INPUT ?
|
||||
"Audio/Sink" : "Audio/Source");
|
||||
g_variant_builder_add (&b, "y", self->direction);
|
||||
g_variant_builder_add (&b, "a{ss}", NULL);
|
||||
|
||||
return g_variant_builder_end (&b);
|
||||
}
|
||||
|
||||
static WpProperties *
|
||||
si_audio_endpoint_get_properties (WpSiEndpoint * item)
|
||||
{
|
||||
WpSiAudioEndpoint *self = WP_SI_AUDIO_ENDPOINT (item);
|
||||
WpProperties *result = wp_properties_new_empty ();
|
||||
|
||||
wp_properties_set (result, "endpoint.name", self->name);
|
||||
wp_properties_setf (result, "endpoint.priority", "%u", self->priority);
|
||||
wp_properties_set (result, "endpoint.description", "Audio Endpoint");
|
||||
wp_properties_setf (result, PW_KEY_ENDPOINT_AUTOCONNECT, "%d", FALSE);
|
||||
wp_properties_set (result, PW_KEY_ENDPOINT_CLIENT_ID, NULL);
|
||||
|
||||
/* associate with the node */
|
||||
wp_properties_setf (result, PW_KEY_NODE_ID, "%d",
|
||||
wp_proxy_get_bound_id (WP_PROXY (self->node)));
|
||||
|
||||
return result;
|
||||
}
|
||||
|
||||
static void
|
||||
si_audio_endpoint_endpoint_init (WpSiEndpointInterface * iface)
|
||||
{
|
||||
iface->get_registration_info = si_audio_endpoint_get_registration_info;
|
||||
iface->get_properties = si_audio_endpoint_get_properties;
|
||||
}
|
||||
|
||||
static GVariant *
|
||||
si_audio_endpoint_get_ports (WpSiPortInfo * item, const gchar * context)
|
||||
{
|
||||
WpSiAudioEndpoint *self = WP_SI_AUDIO_ENDPOINT (item);
|
||||
g_auto (GVariantBuilder) b = G_VARIANT_BUILDER_INIT (G_VARIANT_TYPE_ARRAY);
|
||||
g_autoptr (WpIterator) it = NULL;
|
||||
g_auto (GValue) val = G_VALUE_INIT;
|
||||
WpDirection direction = self->direction;
|
||||
guint32 node_id;
|
||||
|
||||
/* context can only be either NULL or "reverse" */
|
||||
if (!g_strcmp0 (context, "reverse")) {
|
||||
direction = (self->direction == WP_DIRECTION_INPUT) ?
|
||||
WP_DIRECTION_OUTPUT : WP_DIRECTION_INPUT;
|
||||
}
|
||||
else if (context != NULL) {
|
||||
/* on any other context, return an empty list of ports */
|
||||
return g_variant_new_array (G_VARIANT_TYPE ("(uuu)"), NULL, 0);
|
||||
}
|
||||
|
||||
g_variant_builder_init (&b, G_VARIANT_TYPE ("a(uuu)"));
|
||||
node_id = wp_proxy_get_bound_id (WP_PROXY (self->node));
|
||||
|
||||
for (it = wp_node_new_ports_iterator (self->node);
|
||||
wp_iterator_next (it, &val);
|
||||
g_value_unset (&val))
|
||||
{
|
||||
WpPort *port = g_value_get_object (&val);
|
||||
g_autoptr (WpProperties) props = NULL;
|
||||
const gchar *channel;
|
||||
guint32 port_id, channel_id = 0;
|
||||
|
||||
if (wp_port_get_direction (port) != direction)
|
||||
continue;
|
||||
|
||||
port_id = wp_proxy_get_bound_id (WP_PROXY (port));
|
||||
|
||||
/* try to find the audio channel; if channel is NULL, this will silently
|
||||
leave the channel_id to its default value, 0 */
|
||||
props = wp_pipewire_object_get_properties (WP_PIPEWIRE_OBJECT (port));
|
||||
channel = wp_properties_get (props, PW_KEY_AUDIO_CHANNEL);
|
||||
if (channel) {
|
||||
WpSpaIdValue idval = wp_spa_id_value_from_short_name (
|
||||
"Spa:Enum:AudioChannel", channel);
|
||||
if (idval)
|
||||
channel_id = wp_spa_id_value_number (idval);
|
||||
}
|
||||
|
||||
g_variant_builder_add (&b, "(uuu)", node_id, port_id, channel_id);
|
||||
}
|
||||
|
||||
return g_variant_builder_end (&b);
|
||||
}
|
||||
|
||||
static void
|
||||
si_audio_endpoint_port_info_init (WpSiPortInfoInterface * iface)
|
||||
{
|
||||
iface->get_ports = si_audio_endpoint_get_ports;
|
||||
}
|
||||
|
||||
WP_PLUGIN_EXPORT gboolean
|
||||
wireplumber__module_init (WpCore * core, GVariant * args, GError ** error)
|
||||
{
|
||||
wp_si_factory_register (core, wp_si_factory_new_simple (SI_FACTORY_NAME,
|
||||
si_audio_endpoint_get_type ()));
|
||||
return TRUE;
|
||||
}
|
||||
|
|
@ -48,6 +48,13 @@ test(
|
|||
env: common_env,
|
||||
)
|
||||
|
||||
test(
|
||||
'test-si-audio-endpoint',
|
||||
executable('test-si-audio-endpoint', 'si-audio-endpoint.c',
|
||||
dependencies: common_deps, c_args: common_args),
|
||||
env: common_env,
|
||||
)
|
||||
|
||||
test(
|
||||
'test-si-standard-link',
|
||||
executable('test-si-standard-link', 'si-standard-link.c',
|
||||
|
|
|
|||
274
tests/modules/si-audio-endpoint.c
Normal file
274
tests/modules/si-audio-endpoint.c
Normal file
|
|
@ -0,0 +1,274 @@
|
|||
/* WirePlumber
|
||||
*
|
||||
* Copyright © 2020 Collabora Ltd.
|
||||
* @author Julian Bouzas <julian.bouzas@collabora.com>
|
||||
*
|
||||
* SPDX-License-Identifier: MIT
|
||||
*/
|
||||
|
||||
#include "../common/base-test-fixture.h"
|
||||
|
||||
typedef struct {
|
||||
WpBaseTestFixture base;
|
||||
} TestFixture;
|
||||
|
||||
static void
|
||||
test_si_audio_endpoint_setup (TestFixture * f, gconstpointer user_data)
|
||||
{
|
||||
wp_base_test_fixture_setup (&f->base, 0);
|
||||
|
||||
/* load modules */
|
||||
{
|
||||
g_autoptr (WpTestServerLocker) lock =
|
||||
wp_test_server_locker_new (&f->base.server);
|
||||
|
||||
g_assert_cmpint (pw_context_add_spa_lib (f->base.server.context,
|
||||
"fake*", "test/libspa-test"), ==, 0);
|
||||
g_assert_cmpint (pw_context_add_spa_lib (f->base.server.context,
|
||||
"audiotestsrc", "audiotestsrc/libspa-audiotestsrc"), ==, 0);
|
||||
g_assert_cmpint (pw_context_add_spa_lib (f->base.server.context,
|
||||
"audio.convert", "audioconvert/libspa-audioconvert"), ==, 0);
|
||||
g_assert_nonnull (pw_context_load_module (f->base.server.context,
|
||||
"libpipewire-module-spa-node-factory", NULL, NULL));
|
||||
g_assert_nonnull (pw_context_load_module (f->base.server.context,
|
||||
"libpipewire-module-adapter", NULL, NULL));
|
||||
}
|
||||
{
|
||||
g_autoptr (GError) error = NULL;
|
||||
wp_core_load_component (f->base.core,
|
||||
"libwireplumber-module-si-audio-adapter", "module", NULL, &error);
|
||||
g_assert_no_error (error);
|
||||
}
|
||||
{
|
||||
g_autoptr (GError) error = NULL;
|
||||
wp_core_load_component (f->base.core,
|
||||
"libwireplumber-module-si-audio-endpoint", "module", NULL, &error);
|
||||
g_assert_no_error (error);
|
||||
}
|
||||
}
|
||||
|
||||
static void
|
||||
test_si_audio_endpoint_teardown (TestFixture * f, gconstpointer user_data)
|
||||
{
|
||||
wp_base_test_fixture_teardown (&f->base);
|
||||
}
|
||||
|
||||
static void
|
||||
test_si_audio_endpoint_configure_activate (TestFixture * f,
|
||||
gconstpointer user_data)
|
||||
{
|
||||
g_autoptr (WpNode) target_node = NULL;
|
||||
g_autoptr (WpSessionItem) target = NULL;
|
||||
g_autoptr (WpSessionItem) endpoint = NULL;
|
||||
|
||||
/* create target node */
|
||||
|
||||
target_node = wp_node_new_from_factory (f->base.core,
|
||||
"adapter",
|
||||
wp_properties_new (
|
||||
"factory.name", "audiotestsrc",
|
||||
"node.name", "audiotestsrc.adapter",
|
||||
NULL));
|
||||
g_assert_nonnull (target_node);
|
||||
wp_object_activate (WP_OBJECT (target_node),
|
||||
WP_PIPEWIRE_OBJECT_FEATURES_MINIMAL, NULL,
|
||||
(GAsyncReadyCallback) test_object_activate_finish_cb, f);
|
||||
g_main_loop_run (f->base.loop);
|
||||
|
||||
/* create target */
|
||||
|
||||
target = wp_session_item_make (f->base.core, "si-audio-adapter");
|
||||
g_assert_nonnull (target);
|
||||
g_assert_true (WP_IS_SI_PORT_INFO (target));
|
||||
|
||||
/* configure target */
|
||||
|
||||
{
|
||||
WpProperties *props = wp_properties_new_empty ();
|
||||
wp_properties_setf (props, "node", "%p", target_node);
|
||||
g_assert_true (wp_session_item_configure (target, props));
|
||||
g_assert_true (wp_session_item_is_configured (target));
|
||||
}
|
||||
|
||||
/* create endpoint */
|
||||
|
||||
endpoint = wp_session_item_make (f->base.core, "si-audio-endpoint");
|
||||
g_assert_nonnull (endpoint);
|
||||
g_assert_true (WP_IS_SI_ENDPOINT (endpoint));
|
||||
|
||||
/* configure endpoint */
|
||||
|
||||
{
|
||||
WpProperties *props = wp_properties_new_empty ();
|
||||
wp_properties_set (props, "name", "endpoint");
|
||||
wp_properties_setf (props, "target", "%p", target);
|
||||
g_assert_true (wp_session_item_configure (endpoint, props));
|
||||
g_assert_true (wp_session_item_is_configured (endpoint));
|
||||
}
|
||||
|
||||
{
|
||||
const gchar *str = NULL;
|
||||
g_autoptr (WpProperties) props = wp_session_item_get_properties (endpoint);
|
||||
g_assert_nonnull (props);
|
||||
str = wp_properties_get (props, "name");
|
||||
g_assert_nonnull (str);
|
||||
g_assert_cmpstr ("endpoint", ==, str);
|
||||
str = wp_properties_get (props, "direction");
|
||||
g_assert_nonnull (str);
|
||||
g_assert_cmpstr ("1", ==, str);
|
||||
str = wp_properties_get (props, "si-factory-name");
|
||||
g_assert_nonnull (str);
|
||||
g_assert_cmpstr ("si-audio-endpoint", ==, str);
|
||||
}
|
||||
|
||||
/* activate endpoint */
|
||||
|
||||
wp_object_activate (WP_OBJECT (endpoint), WP_SESSION_ITEM_FEATURE_ACTIVE,
|
||||
NULL, (GAsyncReadyCallback) test_object_activate_finish_cb, f);
|
||||
g_main_loop_run (f->base.loop);
|
||||
g_assert_cmphex (wp_object_get_active_features (WP_OBJECT (endpoint)), ==,
|
||||
WP_SESSION_ITEM_FEATURE_ACTIVE);
|
||||
|
||||
/* reset */
|
||||
wp_session_item_reset (endpoint);
|
||||
g_assert_false (wp_session_item_is_configured (endpoint));
|
||||
}
|
||||
|
||||
static void
|
||||
test_si_audio_endpoint_export (TestFixture * f, gconstpointer user_data)
|
||||
{
|
||||
g_autoptr (WpNode) target_node = NULL;
|
||||
g_autoptr (WpSessionItem) target = NULL;
|
||||
g_autoptr (WpSessionItem) endpoint = NULL;
|
||||
g_autoptr (WpSession) session = NULL;
|
||||
g_autoptr (WpObjectManager) clients_om = NULL;
|
||||
g_autoptr (WpClient) self_client = NULL;
|
||||
|
||||
/* find self_client, to be used for verifying endpoint.client.id */
|
||||
|
||||
clients_om = wp_object_manager_new ();
|
||||
wp_object_manager_add_interest (clients_om, WP_TYPE_CLIENT, NULL);
|
||||
wp_object_manager_request_object_features (clients_om,
|
||||
WP_TYPE_CLIENT, WP_PROXY_FEATURE_BOUND);
|
||||
g_signal_connect_swapped (clients_om, "objects-changed",
|
||||
G_CALLBACK (g_main_loop_quit), f->base.loop);
|
||||
wp_core_install_object_manager (f->base.core, clients_om);
|
||||
g_main_loop_run (f->base.loop);
|
||||
g_assert_nonnull (self_client =
|
||||
wp_object_manager_lookup (clients_om, WP_TYPE_CLIENT, NULL));
|
||||
|
||||
/* create session */
|
||||
|
||||
session = WP_SESSION (wp_impl_session_new (f->base.core));
|
||||
g_assert_nonnull (session);
|
||||
|
||||
wp_object_activate (WP_OBJECT (session), WP_OBJECT_FEATURES_ALL, NULL,
|
||||
(GAsyncReadyCallback) test_object_activate_finish_cb, f);
|
||||
g_main_loop_run (f->base.loop);
|
||||
|
||||
/* create target node */
|
||||
|
||||
target_node = wp_node_new_from_factory (f->base.core,
|
||||
"adapter",
|
||||
wp_properties_new (
|
||||
"factory.name", "audiotestsrc",
|
||||
"node.name", "audiotestsrc.adapter",
|
||||
NULL));
|
||||
g_assert_nonnull (target_node);
|
||||
wp_object_activate (WP_OBJECT (target_node),
|
||||
WP_PIPEWIRE_OBJECT_FEATURES_MINIMAL, NULL,
|
||||
(GAsyncReadyCallback) test_object_activate_finish_cb, f);
|
||||
g_main_loop_run (f->base.loop);
|
||||
|
||||
/* create target */
|
||||
|
||||
target = wp_session_item_make (f->base.core, "si-audio-adapter");
|
||||
g_assert_nonnull (target);
|
||||
g_assert_true (WP_IS_SI_PORT_INFO (target));
|
||||
|
||||
/* configure target */
|
||||
|
||||
{
|
||||
WpProperties *props = wp_properties_new_empty ();
|
||||
wp_properties_setf (props, "node", "%p", target_node);
|
||||
g_assert_true (wp_session_item_configure (target, props));
|
||||
g_assert_true (wp_session_item_is_configured (target));
|
||||
}
|
||||
|
||||
/* create endpoint */
|
||||
|
||||
endpoint = wp_session_item_make (f->base.core, "si-audio-endpoint");
|
||||
g_assert_nonnull (endpoint);
|
||||
|
||||
/* configure endpoint */
|
||||
{
|
||||
WpProperties *props = wp_properties_new_empty ();
|
||||
wp_properties_set (props, "name", "endpoint");
|
||||
wp_properties_setf (props, "target", "%p", target);
|
||||
wp_properties_setf (props, "session", "%p", session);
|
||||
g_assert_true (wp_session_item_configure (endpoint, props));
|
||||
g_assert_true (wp_session_item_is_configured (endpoint));
|
||||
}
|
||||
|
||||
/* activate endpoint */
|
||||
|
||||
{
|
||||
wp_object_activate (WP_OBJECT (endpoint),
|
||||
WP_SESSION_ITEM_FEATURE_ACTIVE | WP_SESSION_ITEM_FEATURE_EXPORTED,
|
||||
NULL, (GAsyncReadyCallback) test_object_activate_finish_cb, f);
|
||||
g_main_loop_run (f->base.loop);
|
||||
g_assert_cmphex (wp_object_get_active_features (WP_OBJECT (endpoint)), ==,
|
||||
WP_SESSION_ITEM_FEATURE_ACTIVE | WP_SESSION_ITEM_FEATURE_EXPORTED);
|
||||
}
|
||||
|
||||
{
|
||||
g_autoptr (WpEndpoint) ep = NULL;
|
||||
g_autoptr (WpProperties) props = NULL;
|
||||
gchar *tmp;
|
||||
|
||||
g_assert_nonnull (
|
||||
ep = wp_session_item_get_associated_proxy (endpoint, WP_TYPE_ENDPOINT));
|
||||
g_assert_nonnull (
|
||||
props = wp_pipewire_object_get_properties (WP_PIPEWIRE_OBJECT (ep)));
|
||||
|
||||
g_assert_cmpstr (wp_endpoint_get_name (ep), ==, "endpoint");
|
||||
g_assert_cmpstr (wp_endpoint_get_media_class (ep), ==,
|
||||
"Audio/Source");
|
||||
g_assert_cmpint (wp_endpoint_get_direction (ep), ==, WP_DIRECTION_OUTPUT);
|
||||
g_assert_cmpstr (wp_properties_get (props, "endpoint.name"), ==,
|
||||
"endpoint");
|
||||
g_assert_cmpstr (wp_properties_get (props, "media.class"), ==,
|
||||
"Audio/Source");
|
||||
|
||||
tmp = g_strdup_printf ("%d", wp_proxy_get_bound_id (WP_PROXY (session)));
|
||||
g_assert_cmpstr (wp_properties_get (props, "session.id"), ==, tmp);
|
||||
g_free (tmp);
|
||||
}
|
||||
|
||||
/* reset */
|
||||
wp_session_item_reset (endpoint);
|
||||
g_assert_false (wp_session_item_is_configured (endpoint));
|
||||
}
|
||||
|
||||
gint
|
||||
main (gint argc, gchar *argv[])
|
||||
{
|
||||
g_test_init (&argc, &argv, NULL);
|
||||
wp_init (WP_INIT_ALL);
|
||||
|
||||
/* configure-activate */
|
||||
g_test_add ("/modules/si-audio-endpoint/configure-activate",
|
||||
TestFixture, NULL,
|
||||
test_si_audio_endpoint_setup,
|
||||
test_si_audio_endpoint_configure_activate,
|
||||
test_si_audio_endpoint_teardown);
|
||||
|
||||
/* export */
|
||||
g_test_add ("/modules/si-audio-endpoint/export",
|
||||
TestFixture, NULL,
|
||||
test_si_audio_endpoint_setup,
|
||||
test_si_audio_endpoint_export,
|
||||
test_si_audio_endpoint_teardown);
|
||||
|
||||
return g_test_run ();
|
||||
}
|
||||
Loading…
Add table
Reference in a new issue