summaryrefslogtreecommitdiff
path: root/backends/pulse/pulse-ext-stream.c
diff options
context:
space:
mode:
authorMichal Ratajsky <[email protected]>2014-07-18 15:41:59 +0200
committerMichal Ratajsky <[email protected]>2014-07-18 15:41:59 +0200
commit56c76128b0144a5c61e77d2a7aec07a337cfb66d (patch)
treef67ce44025881578cf6de3332064c214da176a23 /backends/pulse/pulse-ext-stream.c
parent85070f3b97a3213d75a7bebf86ad973aaa21c55b (diff)
downloadlibmatemixer-56c76128b0144a5c61e77d2a7aec07a337cfb66d.tar.bz2
libmatemixer-56c76128b0144a5c61e77d2a7aec07a337cfb66d.tar.xz
PulseAudio fixes and API updates
Diffstat (limited to 'backends/pulse/pulse-ext-stream.c')
-rw-r--r--backends/pulse/pulse-ext-stream.c301
1 files changed, 301 insertions, 0 deletions
diff --git a/backends/pulse/pulse-ext-stream.c b/backends/pulse/pulse-ext-stream.c
new file mode 100644
index 0000000..96164e8
--- /dev/null
+++ b/backends/pulse/pulse-ext-stream.c
@@ -0,0 +1,301 @@
+/*
+ * Copyright (C) 2014 Michal Ratajsky <[email protected]>
+ *
+ * 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 of the licence, 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, see <http://www.gnu.org/licenses/>.
+ */
+
+#include <string.h>
+#include <glib.h>
+#include <glib-object.h>
+
+#include <libmatemixer/matemixer-client-stream.h>
+#include <libmatemixer/matemixer-enums.h>
+#include <libmatemixer/matemixer-stream.h>
+
+#include <pulse/pulseaudio.h>
+#include <pulse/ext-stream-restore.h>
+
+#include "pulse-connection.h"
+#include "pulse-client-stream.h"
+#include "pulse-ext-stream.h"
+#include "pulse-helpers.h"
+#include "pulse-sink.h"
+#include "pulse-source.h"
+#include "pulse-stream.h"
+
+static void pulse_ext_stream_class_init (PulseExtStreamClass *klass);
+static void pulse_ext_stream_init (PulseExtStream *ext);
+
+G_DEFINE_TYPE (PulseExtStream, pulse_ext_stream, PULSE_TYPE_CLIENT_STREAM);
+
+static void pulse_ext_stream_reload (PulseStream *pstream);
+
+static gboolean pulse_ext_stream_set_mute (PulseStream *pstream,
+ gboolean mute);
+static gboolean pulse_ext_stream_set_volume (PulseStream *pstream,
+ pa_cvolume *cvolume);
+static gboolean pulse_ext_stream_set_parent (PulseClientStream *pclient,
+ PulseStream *parent);
+static gboolean pulse_ext_stream_remove (PulseClientStream *pclient);
+
+static void
+pulse_ext_stream_class_init (PulseExtStreamClass *klass)
+{
+ PulseStreamClass *stream_class;
+ PulseClientStreamClass *client_class;
+
+ stream_class = PULSE_STREAM_CLASS (klass);
+
+ stream_class->reload = pulse_ext_stream_reload;
+ stream_class->set_mute = pulse_ext_stream_set_mute;
+ stream_class->set_volume = pulse_ext_stream_set_volume;
+
+ client_class = PULSE_CLIENT_STREAM_CLASS (klass);
+
+ client_class->set_parent = pulse_ext_stream_set_parent;
+ client_class->remove = pulse_ext_stream_remove;
+}
+
+static void
+pulse_ext_stream_init (PulseExtStream *ext)
+{
+}
+
+PulseStream *
+pulse_ext_stream_new (PulseConnection *connection,
+ const pa_ext_stream_restore_info *info,
+ PulseStream *parent)
+{
+ PulseStream *ext;
+
+ g_return_val_if_fail (PULSE_IS_CONNECTION (connection), NULL);
+ g_return_val_if_fail (info != NULL, NULL);
+
+ ext = g_object_new (PULSE_TYPE_EXT_STREAM,
+ "connection", connection,
+ NULL);
+
+ /* Consider the stream name as unchanging parameter */
+ pulse_stream_update_name (ext, info->name);
+
+ /* Other data may change at any time, so let's make a use of our update function */
+ pulse_ext_stream_update (ext, info, parent);
+
+ return ext;
+}
+
+gboolean
+pulse_ext_stream_update (PulseStream *pstream,
+ const pa_ext_stream_restore_info *info,
+ PulseStream *parent)
+{
+ MateMixerClientStreamRole role = MATE_MIXER_CLIENT_STREAM_ROLE_NONE;
+ MateMixerStreamFlags flags = MATE_MIXER_STREAM_CLIENT |
+ MATE_MIXER_STREAM_HAS_VOLUME |
+ MATE_MIXER_STREAM_HAS_MUTE |
+ MATE_MIXER_STREAM_CAN_SET_VOLUME;
+ MateMixerClientStreamFlags client_flags =
+ MATE_MIXER_CLIENT_STREAM_CACHED;
+
+ PulseClientStream *pclient;
+ gchar *suffix;
+
+ g_return_val_if_fail (PULSE_IS_EXT_STREAM (pstream), FALSE);
+ g_return_val_if_fail (info != NULL, FALSE);
+
+ pclient = PULSE_CLIENT_STREAM (pstream);
+
+ suffix = strchr (info->name, ':');
+ if (suffix != NULL)
+ suffix++;
+
+ /* Let all the information update before emitting notify signals */
+ g_object_freeze_notify (G_OBJECT (pstream));
+
+ if (g_str_has_prefix (info->name, "sink-input"))
+ flags |= MATE_MIXER_STREAM_OUTPUT;
+ else if (g_str_has_prefix (info->name, "source-output"))
+ flags |= MATE_MIXER_STREAM_INPUT;
+ else
+ g_debug ("Unknown ext-stream %s", info->name);
+
+ if (strstr (info->name, "-by-media-role:")) {
+ if (G_LIKELY (suffix != NULL))
+ role = pulse_convert_media_role_name (suffix);
+ }
+ else if (strstr (info->name, "-by-application-name:")) {
+ client_flags |= MATE_MIXER_CLIENT_STREAM_APPLICATION;
+
+ if (G_LIKELY (suffix != NULL))
+ pulse_client_stream_update_app_name (pclient, suffix);
+ }
+ else if (strstr (info->name, "-by-application-id:")) {
+ client_flags |= MATE_MIXER_CLIENT_STREAM_APPLICATION;
+
+ if (G_LIKELY (suffix != NULL))
+ pulse_client_stream_update_app_id (pclient, suffix);
+ }
+
+ /* Flags needed before volume */
+ pulse_stream_update_flags (pstream, flags);
+
+ pulse_stream_update_channel_map (pstream, &info->channel_map);
+ pulse_stream_update_volume (pstream, &info->volume, 0);
+
+ pulse_stream_update_mute (pstream, info->mute ? TRUE : FALSE);
+
+ pulse_client_stream_update_flags (pclient, client_flags);
+ pulse_client_stream_update_role (pclient, role);
+
+ if (parent != NULL)
+ pulse_client_stream_update_parent (pclient, MATE_MIXER_STREAM (parent));
+ else
+ pulse_client_stream_update_parent (pclient, NULL);
+
+ g_object_thaw_notify (G_OBJECT (pstream));
+ return TRUE;
+}
+
+static void
+pulse_ext_stream_reload (PulseStream *pstream)
+{
+ g_return_if_fail (PULSE_IS_EXT_STREAM (pstream));
+
+ pulse_connection_load_ext_stream_info (pulse_stream_get_connection (pstream));
+}
+
+static gboolean
+pulse_ext_stream_set_mute (PulseStream *pstream, gboolean mute)
+{
+ MateMixerStream *parent;
+ const pa_channel_map *map;
+ const pa_cvolume *cvolume;
+ pa_ext_stream_restore_info info;
+
+ g_return_val_if_fail (PULSE_IS_EXT_STREAM (pstream), FALSE);
+
+ info.name = mate_mixer_stream_get_name (MATE_MIXER_STREAM (pstream));
+ info.mute = mute;
+
+ map = pulse_stream_get_channel_map (pstream);
+ if (map != NULL)
+ info.channel_map = *map;
+ else
+ pa_channel_map_init (&info.channel_map);
+
+ cvolume = pulse_stream_get_cvolume (pstream);
+ if (cvolume != NULL)
+ info.volume = *cvolume;
+ else
+ pa_cvolume_init (&info.volume);
+
+ parent = mate_mixer_client_stream_get_parent (MATE_MIXER_CLIENT_STREAM (pstream));
+ if (parent != NULL)
+ info.device = mate_mixer_stream_get_name (parent);
+ else
+ info.device = NULL;
+
+ return pulse_connection_write_ext_stream (pulse_stream_get_connection (pstream), &info);
+}
+
+static gboolean
+pulse_ext_stream_set_volume (PulseStream *pstream, pa_cvolume *cvolume)
+{
+ MateMixerStream *parent;
+ const pa_channel_map *map;
+ pa_ext_stream_restore_info info;
+
+ g_return_val_if_fail (PULSE_IS_EXT_STREAM (pstream), FALSE);
+ g_return_val_if_fail (cvolume != NULL, FALSE);
+
+ info.name = mate_mixer_stream_get_name (MATE_MIXER_STREAM (pstream));
+ info.mute = mate_mixer_stream_get_mute (MATE_MIXER_STREAM (pstream));
+
+ map = pulse_stream_get_channel_map (pstream);
+ if (map != NULL)
+ info.channel_map = *map;
+ else
+ pa_channel_map_init (&info.channel_map);
+
+ parent = mate_mixer_client_stream_get_parent (MATE_MIXER_CLIENT_STREAM (pstream));
+ if (parent != NULL)
+ info.device = mate_mixer_stream_get_name (parent);
+ else
+ info.device = NULL;
+
+ info.volume = *cvolume;
+
+ return pulse_connection_write_ext_stream (pulse_stream_get_connection (pstream), &info);
+}
+
+static gboolean
+pulse_ext_stream_set_parent (PulseClientStream *pclient, PulseStream *parent)
+{
+ MateMixerStreamFlags flags;
+ PulseStream *pstream;
+ const pa_channel_map *map;
+ const pa_cvolume *cvolume;
+ pa_ext_stream_restore_info info;
+
+ g_return_val_if_fail (PULSE_IS_EXT_STREAM (pclient), FALSE);
+ g_return_val_if_fail (PULSE_IS_STREAM (parent), FALSE);
+
+ flags = mate_mixer_stream_get_flags (MATE_MIXER_STREAM (pclient));
+
+ /* Validate the parent stream */
+ if (flags & MATE_MIXER_STREAM_INPUT && !PULSE_IS_SOURCE (parent)) {
+ g_warning ("Could not change stream parent to %s: not a parent input stream",
+ mate_mixer_stream_get_name (MATE_MIXER_STREAM (parent)));
+ return FALSE;
+ } else if (!PULSE_IS_SINK (parent)) {
+ g_warning ("Could not change stream parent to %s: not a parent output stream",
+ mate_mixer_stream_get_name (MATE_MIXER_STREAM (parent)));
+ return FALSE;
+ }
+
+ pstream = PULSE_STREAM (pclient);
+
+ info.name = mate_mixer_stream_get_name (MATE_MIXER_STREAM (pstream));
+ info.mute = mate_mixer_stream_get_mute (MATE_MIXER_STREAM (pstream));
+
+ map = pulse_stream_get_channel_map (pstream);
+ if (map != NULL)
+ info.channel_map = *map;
+ else
+ pa_channel_map_init (&info.channel_map);
+
+ cvolume = pulse_stream_get_cvolume (pstream);
+ if (cvolume != NULL)
+ info.volume = *cvolume;
+ else
+ pa_cvolume_init (&info.volume);
+
+ info.device = mate_mixer_stream_get_name (MATE_MIXER_STREAM (parent));
+
+ return pulse_connection_write_ext_stream (pulse_stream_get_connection (pstream), &info);
+}
+
+static gboolean
+pulse_ext_stream_remove (PulseClientStream *pclient)
+{
+ PulseStream *pstream;
+ const gchar *name;
+
+ g_return_val_if_fail (PULSE_IS_EXT_STREAM (pclient), FALSE);
+
+ pstream = PULSE_STREAM (pclient);
+ name = mate_mixer_stream_get_name (MATE_MIXER_STREAM (pstream));
+
+ return pulse_connection_delete_ext_stream (pulse_stream_get_connection (pstream), name);
+}
generated by cgit v1.2.1 (git 2.18.0) at 2024-06-22 03:40:24 +0000