1// Copyright (C) 2021 The Qt Company Ltd.
2// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR LGPL-3.0-only OR GPL-2.0-only OR GPL-3.0-only
3
4#include <common/qgstreameraudioinput_p.h>
5
6#include <QtCore/qloggingcategory.h>
7#include <QtMultimedia/qaudiodevice.h>
8#include <QtMultimedia/qaudioinput.h>
9
10#include <audio/qgstreameraudiodevice_p.h>
11#include <common/qgstpipeline_p.h>
12
13
14QT_BEGIN_NAMESPACE
15
16namespace {
17
18Q_STATIC_LOGGING_CATEGORY(qLcMediaAudioInput, "qt.multimedia.audioinput")
19
20constexpr QLatin1String defaultSrcName = [] {
21 using namespace Qt::Literals;
22
23 if constexpr (QT_CONFIG(pulseaudio))
24 return "pulsesrc"_L1;
25 else if constexpr (QT_CONFIG(alsa))
26 return "alsasrc"_L1;
27 else
28 return "autoaudiosrc"_L1;
29}();
30
31bool srcHasDeviceProperty(const QGstElement &element)
32{
33 using namespace Qt::Literals;
34 QLatin1String elementType = element.typeName();
35
36 if constexpr (QT_CONFIG(pulseaudio))
37 return elementType == "GstPulseSrc"_L1;
38
39 if constexpr (0 && QT_CONFIG(alsa)) // alsasrc has a "device" property, but it cannot be changed
40 // during playback
41 return elementType == "GstAlsaSrc"_L1;
42
43 return false;
44}
45
46} // namespace
47
48q23::expected<QPlatformAudioInput *, QString> QGstreamerAudioInput::create(QAudioInput *parent)
49{
50 static const auto error = qGstErrorMessageIfElementsNotAvailable(arg: "autoaudiosrc", args: "volume");
51 if (error)
52 return q23::unexpected{ *error };
53
54 return new QGstreamerAudioInput(parent);
55}
56
57QGstreamerAudioInput::QGstreamerAudioInput(QAudioInput *parent)
58 : QObject(parent),
59 QPlatformAudioInput(parent),
60 m_audioInputBin(QGstBin::create(name: "audioInput")),
61 m_audioSrc{
62 QGstElement::createFromFactory(factory: defaultSrcName.constData(), name: "autoaudiosrc"),
63 },
64 m_audioVolume{
65 QGstElement::createFromFactory(factory: "volume", name: "volume"),
66 }
67{
68 m_audioInputBin.add(ts: m_audioSrc, ts: m_audioVolume);
69 qLinkGstElements(ts: m_audioSrc, ts: m_audioVolume);
70
71 m_audioInputBin.addGhostPad(child: m_audioVolume, name: "src");
72}
73
74QGstElement QGstreamerAudioInput::createGstElement()
75{
76 const auto *customDevice =
77 QAudioDevicePrivate::handle<QGStreamerCustomAudioDeviceInfo>(device: m_audioDevice);
78
79 if (customDevice) {
80 qCDebug(qLcMediaAudioInput) << "requesting custom audio src element: " << customDevice->id;
81
82 QGstElement element = QGstBin::createFromPipelineDescription(pipelineDescription: customDevice->id,
83 /*name=*/nullptr,
84 /*ghostUnlinkedPads=*/true);
85 if (element)
86 return element;
87
88 qCWarning(qLcMediaAudioInput) << "Cannot create audio source element:" << customDevice->id;
89 }
90
91 const QByteArray &id = m_audioDevice.id();
92 if constexpr (QT_CONFIG(pulseaudio) || QT_CONFIG(alsa)) {
93 QGstElement newSrc = QGstElement::createFromFactory(factory: defaultSrcName.constData(), name: "audiosrc");
94 if (newSrc) {
95 newSrc.set(property: "device", str: id.constData());
96 return newSrc;
97 }
98
99 qWarning() << "Cannot create" << defaultSrcName;
100 }
101 qCWarning(qLcMediaAudioInput) << "Invalid audio device";
102 qCWarning(qLcMediaAudioInput)
103 << "Failed to create a gst element for the audio device, using a default audio source";
104 return QGstElement::createFromFactory(factory: "autoaudiosrc", name: "audiosrc");
105}
106
107QGstreamerAudioInput::~QGstreamerAudioInput()
108{
109 m_audioInputBin.setStateSync(state: GST_STATE_NULL);
110}
111
112void QGstreamerAudioInput::setVolume(float volume)
113{
114 m_audioVolume.set(property: "volume", d: volume);
115}
116
117void QGstreamerAudioInput::setMuted(bool muted)
118{
119 m_audioVolume.set(property: "mute", b: muted);
120}
121
122void QGstreamerAudioInput::setAudioDevice(const QAudioDevice &device)
123{
124 if (device == m_audioDevice)
125 return;
126 qCDebug(qLcMediaAudioInput) << "setAudioDevice" << device.description() << device.isNull();
127 m_audioDevice = device;
128
129 if (srcHasDeviceProperty(element: m_audioSrc) && !isCustomAudioDevice(device: m_audioDevice)) {
130 m_audioSrc.set(property: "device", str: m_audioDevice.id().constData());
131 return;
132 }
133
134 QGstElement newSrc = createGstElement();
135
136 m_audioVolume.sink().modifyPipelineInIdleProbe(f: [&] {
137 qUnlinkGstElements(ts: m_audioSrc, ts: m_audioVolume);
138 m_audioInputBin.stopAndRemoveElements(ts&: m_audioSrc);
139 m_audioSrc = std::move(newSrc);
140 m_audioInputBin.add(ts: m_audioSrc);
141 qLinkGstElements(ts: m_audioSrc, ts: m_audioVolume);
142 m_audioSrc.syncStateWithParent();
143 });
144}
145
146QT_END_NAMESPACE
147

source code of qtmultimedia/src/plugins/multimedia/gstreamer/common/qgstreameraudioinput.cpp