From a2290d5e13ccee88fd9ae66a3895eb4da646f81f Mon Sep 17 00:00:00 2001 From: Michal Ratajsky Date: Fri, 13 Jun 2014 17:36:14 +0200 Subject: Weekly update --- backends/pulse/pulse-source.c | 213 ++++++++++++++++++++++++++++++++++++++++++ 1 file changed, 213 insertions(+) (limited to 'backends/pulse/pulse-source.c') diff --git a/backends/pulse/pulse-source.c b/backends/pulse/pulse-source.c index e69de29..2aea6b6 100644 --- a/backends/pulse/pulse-source.c +++ b/backends/pulse/pulse-source.c @@ -0,0 +1,213 @@ +/* + * Copyright (C) 2014 Michal Ratajsky + * + * 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 . + */ + +#include +#include + +#include +#include + +#include + +#include "pulse-connection.h" +#include "pulse-stream.h" +#include "pulse-source.h" + +struct _PulseSourcePrivate +{ + guint32 index_monitored_sink; +}; + +static gboolean source_set_mute (MateMixerStream *stream, + gboolean mute); +static gboolean source_set_volume (MateMixerStream *stream, + pa_cvolume *volume); +static gboolean source_set_active_port (MateMixerStream *stream, + const gchar *port_name); + +G_DEFINE_TYPE (PulseSource, pulse_source, PULSE_TYPE_STREAM); + +static void +pulse_source_init (PulseSource *source) +{ + source->priv = G_TYPE_INSTANCE_GET_PRIVATE (source, + PULSE_TYPE_SOURCE, + PulseSourcePrivate); +} + +static void +pulse_source_class_init (PulseSourceClass *klass) +{ + PulseStreamClass *stream_class; + + stream_class = PULSE_STREAM_CLASS (klass); + + stream_class->set_mute = source_set_mute; + stream_class->set_volume = source_set_volume; + stream_class->set_active_port = source_set_active_port; + + g_type_class_add_private (klass, sizeof (PulseSourcePrivate)); +} + +PulseStream * +pulse_source_new (PulseConnection *connection, const pa_source_info *info) +{ + PulseSource *source; + GList *ports = NULL; + int i; + + for (i = 0; i < info->n_ports; i++) { + MateMixerPort *port; + MateMixerPortStatus status = MATE_MIXER_PORT_UNKNOWN_STATUS; + pa_source_port_info *p_info = info->ports[i]; + +#if PA_CHECK_VERSION(2, 0, 0) + switch (p_info->available) { + case PA_PORT_AVAILABLE_YES: + status = MATE_MIXER_PORT_AVAILABLE; + break; + case PA_PORT_AVAILABLE_NO: + status = MATE_MIXER_PORT_UNAVAILABLE; + break; + default: + break; + } +#endif + port = mate_mixer_port_new (p_info->name, + p_info->description, + NULL, + p_info->priority, + status); + + ports = g_list_prepend (ports, port); + } + + source = g_object_new (PULSE_TYPE_SOURCE, + "connection", connection, + "index", info->index, + NULL); + + /* According to the PulseAudio code, the list of sink port never changes with + * updates. + * This may be not future-proof, but checking and validating the list of ports on + * each update would be an expensive operation, so let's set the list only during + * the construction */ + pulse_stream_update_ports (PULSE_STREAM (source), g_list_reverse (ports)); + + /* Other data may change at any time, so let's make a use of our update function */ + pulse_source_update (PULSE_STREAM (source), info); + + return PULSE_STREAM (source); +} + +gboolean +pulse_source_update (PulseStream *stream, const pa_source_info *info) +{ + PulseSource *source; + MateMixerStreamFlags flags = MATE_MIXER_STREAM_INPUT | + MATE_MIXER_STREAM_HAS_MUTE | + MATE_MIXER_STREAM_HAS_VOLUME | + MATE_MIXER_STREAM_CAN_SET_VOLUME; + + g_return_val_if_fail (PULSE_IS_SOURCE (stream), FALSE); + + source = PULSE_SOURCE (stream); + + /* Let all the information update before emitting notify signals */ + g_object_freeze_notify (G_OBJECT (stream)); + + pulse_stream_update_name (stream, info->name); + pulse_stream_update_description (stream, info->description); + pulse_stream_update_mute (stream, info->mute ? TRUE : FALSE); + pulse_stream_update_channel_map (stream, &info->channel_map); + pulse_stream_update_volume_extended (stream, + &info->volume, + info->base_volume, + info->n_volume_steps); + if (info->active_port) + pulse_stream_update_active_port (stream, info->active_port->name); + + switch (info->state) { + case PA_SOURCE_RUNNING: + pulse_stream_update_status (stream, MATE_MIXER_STREAM_RUNNING); + break; + case PA_SOURCE_IDLE: + pulse_stream_update_status (stream, MATE_MIXER_STREAM_IDLE); + break; + case PA_SOURCE_SUSPENDED: + pulse_stream_update_status (stream, MATE_MIXER_STREAM_SUSPENDED); + break; + default: + pulse_stream_update_status (stream, MATE_MIXER_STREAM_UNKNOWN_STATUS); + break; + } + + /* Build the flag list */ + if (info->flags & PA_SINK_DECIBEL_VOLUME) + flags |= MATE_MIXER_STREAM_HAS_DECIBEL_VOLUME; + if (info->flags & PA_SINK_FLAT_VOLUME) + flags |= MATE_MIXER_STREAM_HAS_FLAT_VOLUME; + + if (pa_channel_map_can_balance (&info->channel_map)) + flags |= MATE_MIXER_STREAM_CAN_BALANCE; + if (pa_channel_map_can_fade (&info->channel_map)) + flags |= MATE_MIXER_STREAM_CAN_FADE; + + pulse_stream_update_flags (stream, flags); + + if (source->priv->index_monitored_sink != info->monitor_of_sink) { + source->priv->index_monitored_sink = info->monitor_of_sink; + + // TODO: provide a property + // g_object_notify (G_OBJECT (stream), "monitor"); + } + + g_object_thaw_notify (G_OBJECT (stream)); + return TRUE; +} + +static gboolean +source_set_mute (MateMixerStream *stream, gboolean mute) +{ + g_return_val_if_fail (PULSE_IS_SOURCE (stream), FALSE); + + return pulse_connection_set_source_mute (pulse_stream_get_connection (PULSE_STREAM (stream)), + pulse_stream_get_index (PULSE_STREAM (stream)), + mute); +} + +static gboolean +source_set_volume (MateMixerStream *stream, pa_cvolume *volume) +{ + g_return_val_if_fail (PULSE_IS_SOURCE (stream), FALSE); + g_return_val_if_fail (volume != NULL, FALSE); + + return pulse_connection_set_source_volume (pulse_stream_get_connection (PULSE_STREAM (stream)), + pulse_stream_get_index (PULSE_STREAM (stream)), + volume); +} + +static gboolean +source_set_active_port (MateMixerStream *stream, const gchar *port_name) +{ + g_return_val_if_fail (PULSE_IS_SOURCE (stream), FALSE); + g_return_val_if_fail (port_name != NULL, FALSE); + + return pulse_connection_set_source_port (pulse_stream_get_connection (PULSE_STREAM (stream)), + pulse_stream_get_index (PULSE_STREAM (stream)), + port_name); +} -- cgit v1.2.1