PulseAudio Qt Bindings

streamrestore.cpp
1/*
2 SPDX-FileCopyrightText: 2016 David Rosca <nowrep@gmail.com>
3
4 SPDX-License-Identifier: LGPL-2.1-only OR LGPL-3.0-only OR LicenseRef-KDE-Accepted-LGPL
5*/
6
7#include "streamrestore.h"
8#include "context.h"
9#include "context_p.h"
10#include "streamrestore_p.h"
11
12#include "debug.h"
13#include "pulseobject_p.h"
14
15namespace PulseAudioQt
16{
17StreamRestore::StreamRestore(quint32 index, const QVariantMap &properties, QObject *parent)
18 : PulseObject(parent)
19 , d(new StreamRestorePrivate(this))
20{
21 memset(&d->m_volume, 0, sizeof(d->m_volume));
22 memset(&d->m_channelMap, 0, sizeof(d->m_channelMap));
23
24 d->m_index = index;
25 PulseObject::d->m_properties = properties;
26}
27
28StreamRestore::~StreamRestore()
29{
30 delete d;
31}
32
33StreamRestorePrivate::StreamRestorePrivate(StreamRestore *q)
34 : q(q)
35{
36}
37
38StreamRestorePrivate::~StreamRestorePrivate()
39{
40}
41
42void StreamRestorePrivate::update(const pa_ext_stream_restore_info *info)
43{
44 q->PulseObject::d->updatePulseObject(info);
45 m_cache.valid = false;
46
47 const QString infoDevice = QString::fromUtf8(info->device);
48 if (m_device != infoDevice) {
49 m_device = infoDevice;
50 Q_EMIT q->deviceChanged();
51 }
52 if (m_muted != info->mute) {
53 m_muted = info->mute;
54 Q_EMIT q->mutedChanged();
55 }
56 if (!pa_cvolume_equal(&m_volume, &info->volume)) {
57 m_volume = info->volume;
58 Q_EMIT q->volumeChanged();
59 Q_EMIT q->channelVolumesChanged();
60 }
61 if (!pa_channel_map_equal(&m_channelMap, &info->channel_map)) {
62 m_channels.clear();
63 m_channels.reserve(info->channel_map.channels);
64 for (int i = 0; i < info->channel_map.channels; ++i) {
65 m_channels << QString::fromUtf8(pa_channel_position_to_pretty_string(info->channel_map.map[i]));
66 }
67 m_channelMap = info->channel_map;
68 Q_EMIT q->channelsChanged();
69 }
70}
71
72QString StreamRestore::device() const
73{
74 return d->m_device;
75}
76
77void StreamRestore::setDevice(const QString &device)
78{
79 if (d->m_cache.valid) {
80 if (d->m_cache.device != device) {
81 d->writeChanges(d->m_cache.volume, d->m_cache.muted, device);
82 }
83 } else {
84 if (d->m_device != device) {
85 d->writeChanges(d->m_volume, d->m_muted, device);
86 }
87 }
88}
89
90qint64 StreamRestore::volume() const
91{
92 // FIXME: workaround for pipewire not supporting stream restore subscription
93 // revert when fix is released
94 // https://gitlab.freedesktop.org/pipewire/pipewire/-/issues/3805
95 if (d->m_cache.valid) {
96 return d->m_cache.volume.values[0];
97 } else {
98 return d->m_volume.values[0];
99 }
100}
101
102void StreamRestore::setVolume(qint64 volume)
103{
104 pa_cvolume vol = d->m_cache.valid ? d->m_cache.volume : d->m_volume;
105
106 // If no channel exists force one. We need one to be able to control the volume
107 // See https://bugs.kde.org/show_bug.cgi?id=407397
108 if (vol.channels == 0) {
109 vol.channels = 1;
110 }
111
112 for (int i = 0; i < vol.channels; ++i) {
113 vol.values[i] = volume;
114 }
115
116 if (d->m_cache.valid) {
117 d->writeChanges(vol, d->m_cache.muted, d->m_cache.device);
118 } else {
119 d->writeChanges(vol, d->m_muted, d->m_device);
120 }
121}
122
123bool StreamRestore::isMuted() const
124{
125 // FIXME: workaround for pipewire not supporting stream restore subscription
126 // revert when fix is released
127 // https://gitlab.freedesktop.org/pipewire/pipewire/-/issues/3805
128 if (d->m_cache.valid) {
129 return d->m_cache.muted;
130 } else {
131 return d->m_muted;
132 }
133}
134
135void StreamRestore::setMuted(bool muted)
136{
137 if (d->m_cache.valid) {
138 if (d->m_cache.muted != muted) {
139 d->writeChanges(d->m_cache.volume, muted, d->m_cache.device);
140 }
141 } else {
142 if (d->m_muted != muted) {
143 d->writeChanges(d->m_volume, muted, d->m_device);
144 }
145 }
146}
147
148bool StreamRestore::hasVolume() const
149{
150 return true;
151}
152
153bool StreamRestore::isVolumeWritable() const
154{
155 return true;
156}
157
158QList<QString> StreamRestore::channels() const
159{
160 return d->m_channels;
161}
162
163QList<qreal> StreamRestore::channelVolumes() const
164{
165 QList<qreal> ret;
166 ret.reserve(d->m_volume.channels);
167 for (int i = 0; i < d->m_volume.channels; ++i) {
168 ret << d->m_volume.values[i];
169 }
170 return ret;
171}
172
173void StreamRestore::setChannelVolume(int channel, qint64 volume)
174{
175 Q_ASSERT(channel >= 0 && channel < d->m_volume.channels);
176 pa_cvolume vol = d->m_cache.valid ? d->m_cache.volume : d->m_volume;
177 vol.values[channel] = volume;
178
179 if (d->m_cache.valid) {
180 d->writeChanges(vol, d->m_cache.muted, d->m_cache.device);
181 } else {
182 d->writeChanges(vol, d->m_muted, d->m_device);
183 }
184}
185
186quint32 StreamRestore::deviceIndex() const
187{
188 return PA_INVALID_INDEX;
189}
190
191void StreamRestore::setDeviceIndex(quint32 deviceIndex)
192{
193 Q_UNUSED(deviceIndex);
194 qCWarning(PULSEAUDIOQT) << "Not implemented";
195}
196
197void StreamRestorePrivate::writeChanges(const pa_cvolume &volume, bool muted, const QString &device)
198{
199 const QByteArray nameData = q->name().toUtf8();
200 const QByteArray deviceData = device.toUtf8();
201
202 pa_ext_stream_restore_info info;
203 info.name = nameData.constData();
204 info.channel_map = m_channelMap;
205 info.volume = volume;
206 info.device = deviceData.isEmpty() ? nullptr : deviceData.constData();
207 info.mute = muted;
208
209 // If no channel exists force one. We need one to be able to control the volume
210 // See https://bugs.kde.org/show_bug.cgi?id=407397
211 if (info.channel_map.channels == 0) {
212 info.channel_map.channels = 1;
213 info.channel_map.map[0] = PA_CHANNEL_POSITION_MONO;
214 }
215
216 m_cache.valid = true;
217 m_cache.volume = volume;
218 m_cache.muted = muted;
219 m_cache.device = device;
220
221 Context::instance()->d->streamRestoreWrite(&info);
222}
223
224quint32 StreamRestore::index() const
225{
226 return d->m_index;
227}
228
229} // PulseAudioQt
KGuiItem properties()
The primary namespace of PulseAudioQt.
Definition card.cpp:17
const char * constData() const const
bool isEmpty() const const
void reserve(qsizetype size)
void clear()
QString fromUtf8(QByteArrayView str)
QByteArray toUtf8() const const
This file is part of the KDE documentation.
Documentation copyright © 1996-2024 The KDE developers.
Generated on Fri May 24 2024 11:54:31 by doxygen 1.10.0 written by Dimitri van Heesch, © 1997-2006

KDE's Doxygen guidelines are available online.