| 1 | /**************************************************************************** |
| 2 | ** |
| 3 | ** Copyright (C) 2017 The Qt Company Ltd. |
| 4 | ** Contact: https://www.qt.io/licensing/ |
| 5 | ** |
| 6 | ** This file is part of the examples of the Qt Toolkit. |
| 7 | ** |
| 8 | ** $QT_BEGIN_LICENSE:BSD$ |
| 9 | ** Commercial License Usage |
| 10 | ** Licensees holding valid commercial Qt licenses may use this file in |
| 11 | ** accordance with the commercial license agreement provided with the |
| 12 | ** Software or, alternatively, in accordance with the terms contained in |
| 13 | ** a written agreement between you and The Qt Company. For licensing terms |
| 14 | ** and conditions see https://www.qt.io/terms-conditions. For further |
| 15 | ** information use the contact form at https://www.qt.io/contact-us. |
| 16 | ** |
| 17 | ** BSD License Usage |
| 18 | ** Alternatively, you may use this file under the terms of the BSD license |
| 19 | ** as follows: |
| 20 | ** |
| 21 | ** "Redistribution and use in source and binary forms, with or without |
| 22 | ** modification, are permitted provided that the following conditions are |
| 23 | ** met: |
| 24 | ** * Redistributions of source code must retain the above copyright |
| 25 | ** notice, this list of conditions and the following disclaimer. |
| 26 | ** * Redistributions in binary form must reproduce the above copyright |
| 27 | ** notice, this list of conditions and the following disclaimer in |
| 28 | ** the documentation and/or other materials provided with the |
| 29 | ** distribution. |
| 30 | ** * Neither the name of The Qt Company Ltd nor the names of its |
| 31 | ** contributors may be used to endorse or promote products derived |
| 32 | ** from this software without specific prior written permission. |
| 33 | ** |
| 34 | ** |
| 35 | ** THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS |
| 36 | ** "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT |
| 37 | ** LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR |
| 38 | ** A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT |
| 39 | ** OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, |
| 40 | ** SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT |
| 41 | ** LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, |
| 42 | ** DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY |
| 43 | ** THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT |
| 44 | ** (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE |
| 45 | ** OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE." |
| 46 | ** |
| 47 | ** $QT_END_LICENSE$ |
| 48 | ** |
| 49 | ****************************************************************************/ |
| 50 | |
| 51 | #include "audiooutput.h" |
| 52 | |
| 53 | #include <QAudioDeviceInfo> |
| 54 | #include <QAudioOutput> |
| 55 | #include <QDebug> |
| 56 | #include <QVBoxLayout> |
| 57 | #include <qmath.h> |
| 58 | #include <qendian.h> |
| 59 | |
| 60 | Generator::Generator(const QAudioFormat &format |
| 61 | , qint64 durationUs |
| 62 | , int sampleRate) |
| 63 | { |
| 64 | if (format.isValid()) |
| 65 | generateData(format, durationUs, sampleRate); |
| 66 | } |
| 67 | |
| 68 | void Generator::start() |
| 69 | { |
| 70 | open(mode: QIODevice::ReadOnly); |
| 71 | } |
| 72 | |
| 73 | void Generator::stop() |
| 74 | { |
| 75 | m_pos = 0; |
| 76 | close(); |
| 77 | } |
| 78 | |
| 79 | void Generator::generateData(const QAudioFormat &format, qint64 durationUs, int sampleRate) |
| 80 | { |
| 81 | const int channelBytes = format.sampleSize() / 8; |
| 82 | const int sampleBytes = format.channelCount() * channelBytes; |
| 83 | qint64 length = (format.sampleRate() * format.channelCount() * (format.sampleSize() / 8)) |
| 84 | * durationUs / 1000000; |
| 85 | Q_ASSERT(length % sampleBytes == 0); |
| 86 | Q_UNUSED(sampleBytes) // suppress warning in release builds |
| 87 | |
| 88 | m_buffer.resize(size: length); |
| 89 | unsigned char *ptr = reinterpret_cast<unsigned char *>(m_buffer.data()); |
| 90 | int sampleIndex = 0; |
| 91 | |
| 92 | while (length) { |
| 93 | // Produces value (-1..1) |
| 94 | const qreal x = qSin(v: 2 * M_PI * sampleRate * qreal(sampleIndex++ % format.sampleRate()) / format.sampleRate()); |
| 95 | for (int i=0; i<format.channelCount(); ++i) { |
| 96 | if (format.sampleSize() == 8) { |
| 97 | if (format.sampleType() == QAudioFormat::UnSignedInt) { |
| 98 | const quint8 value = static_cast<quint8>((1.0 + x) / 2 * 255); |
| 99 | *reinterpret_cast<quint8 *>(ptr) = value; |
| 100 | } else if (format.sampleType() == QAudioFormat::SignedInt) { |
| 101 | const qint8 value = static_cast<qint8>(x * 127); |
| 102 | *reinterpret_cast<qint8 *>(ptr) = value; |
| 103 | } |
| 104 | } else if (format.sampleSize() == 16) { |
| 105 | if (format.sampleType() == QAudioFormat::UnSignedInt) { |
| 106 | quint16 value = static_cast<quint16>((1.0 + x) / 2 * 65535); |
| 107 | if (format.byteOrder() == QAudioFormat::LittleEndian) |
| 108 | qToLittleEndian<quint16>(src: value, dest: ptr); |
| 109 | else |
| 110 | qToBigEndian<quint16>(src: value, dest: ptr); |
| 111 | } else if (format.sampleType() == QAudioFormat::SignedInt) { |
| 112 | qint16 value = static_cast<qint16>(x * 32767); |
| 113 | if (format.byteOrder() == QAudioFormat::LittleEndian) |
| 114 | qToLittleEndian<qint16>(src: value, dest: ptr); |
| 115 | else |
| 116 | qToBigEndian<qint16>(src: value, dest: ptr); |
| 117 | } |
| 118 | } |
| 119 | |
| 120 | ptr += channelBytes; |
| 121 | length -= channelBytes; |
| 122 | } |
| 123 | } |
| 124 | } |
| 125 | |
| 126 | qint64 Generator::readData(char *data, qint64 len) |
| 127 | { |
| 128 | qint64 total = 0; |
| 129 | if (!m_buffer.isEmpty()) { |
| 130 | while (len - total > 0) { |
| 131 | const qint64 chunk = qMin(a: (m_buffer.size() - m_pos), b: len - total); |
| 132 | memcpy(dest: data + total, src: m_buffer.constData() + m_pos, n: chunk); |
| 133 | m_pos = (m_pos + chunk) % m_buffer.size(); |
| 134 | total += chunk; |
| 135 | } |
| 136 | } |
| 137 | return total; |
| 138 | } |
| 139 | |
| 140 | qint64 Generator::writeData(const char *data, qint64 len) |
| 141 | { |
| 142 | Q_UNUSED(data); |
| 143 | Q_UNUSED(len); |
| 144 | |
| 145 | return 0; |
| 146 | } |
| 147 | |
| 148 | qint64 Generator::bytesAvailable() const |
| 149 | { |
| 150 | return m_buffer.size() + QIODevice::bytesAvailable(); |
| 151 | } |
| 152 | |
| 153 | AudioTest::AudioTest() |
| 154 | : m_pushTimer(new QTimer(this)) |
| 155 | { |
| 156 | initializeWindow(); |
| 157 | initializeAudio(deviceInfo: QAudioDeviceInfo::defaultOutputDevice()); |
| 158 | } |
| 159 | |
| 160 | AudioTest::~AudioTest() |
| 161 | { |
| 162 | m_pushTimer->stop(); |
| 163 | } |
| 164 | |
| 165 | void AudioTest::initializeWindow() |
| 166 | { |
| 167 | QWidget *window = new QWidget; |
| 168 | QVBoxLayout *layout = new QVBoxLayout; |
| 169 | |
| 170 | m_deviceBox = new QComboBox(this); |
| 171 | const QAudioDeviceInfo &defaultDeviceInfo = QAudioDeviceInfo::defaultOutputDevice(); |
| 172 | m_deviceBox->addItem(atext: defaultDeviceInfo.deviceName(), auserData: QVariant::fromValue(value: defaultDeviceInfo)); |
| 173 | for (auto &deviceInfo: QAudioDeviceInfo::availableDevices(mode: QAudio::AudioOutput)) { |
| 174 | if (deviceInfo != defaultDeviceInfo) |
| 175 | m_deviceBox->addItem(atext: deviceInfo.deviceName(), auserData: QVariant::fromValue(value: deviceInfo)); |
| 176 | } |
| 177 | connect(sender: m_deviceBox, signal: QOverload<int>::of(ptr: &QComboBox::activated), receiver: this, slot: &AudioTest::deviceChanged); |
| 178 | layout->addWidget(m_deviceBox); |
| 179 | |
| 180 | m_modeButton = new QPushButton(this); |
| 181 | connect(sender: m_modeButton, signal: &QPushButton::clicked, receiver: this, slot: &AudioTest::toggleMode); |
| 182 | layout->addWidget(m_modeButton); |
| 183 | |
| 184 | m_suspendResumeButton = new QPushButton(this); |
| 185 | connect(sender: m_suspendResumeButton, signal: &QPushButton::clicked, receiver: this, slot: &AudioTest::toggleSuspendResume); |
| 186 | layout->addWidget(m_suspendResumeButton); |
| 187 | |
| 188 | QHBoxLayout *volumeBox = new QHBoxLayout; |
| 189 | m_volumeLabel = new QLabel; |
| 190 | m_volumeLabel->setText(tr(s: "Volume:" )); |
| 191 | m_volumeSlider = new QSlider(Qt::Horizontal); |
| 192 | m_volumeSlider->setMinimum(0); |
| 193 | m_volumeSlider->setMaximum(100); |
| 194 | m_volumeSlider->setSingleStep(10); |
| 195 | connect(sender: m_volumeSlider, signal: &QSlider::valueChanged, receiver: this, slot: &AudioTest::volumeChanged); |
| 196 | volumeBox->addWidget(m_volumeLabel); |
| 197 | volumeBox->addWidget(m_volumeSlider); |
| 198 | layout->addLayout(layout: volumeBox); |
| 199 | |
| 200 | window->setLayout(layout); |
| 201 | |
| 202 | setCentralWidget(window); |
| 203 | window->show(); |
| 204 | } |
| 205 | |
| 206 | void AudioTest::initializeAudio(const QAudioDeviceInfo &deviceInfo) |
| 207 | { |
| 208 | QAudioFormat format; |
| 209 | format.setSampleRate(44100); |
| 210 | format.setChannelCount(1); |
| 211 | format.setSampleSize(16); |
| 212 | format.setCodec("audio/pcm" ); |
| 213 | format.setByteOrder(QAudioFormat::LittleEndian); |
| 214 | format.setSampleType(QAudioFormat::SignedInt); |
| 215 | |
| 216 | if (!deviceInfo.isFormatSupported(format)) { |
| 217 | qWarning() << "Default format not supported - trying to use nearest" ; |
| 218 | format = deviceInfo.nearestFormat(format); |
| 219 | } |
| 220 | |
| 221 | const int durationSeconds = 1; |
| 222 | const int toneSampleRateHz = 600; |
| 223 | m_generator.reset(other: new Generator(format, durationSeconds * 1000000, toneSampleRateHz)); |
| 224 | m_audioOutput.reset(other: new QAudioOutput(deviceInfo, format)); |
| 225 | m_generator->start(); |
| 226 | |
| 227 | qreal initialVolume = QAudio::convertVolume(volume: m_audioOutput->volume(), |
| 228 | from: QAudio::LinearVolumeScale, |
| 229 | to: QAudio::LogarithmicVolumeScale); |
| 230 | m_volumeSlider->setValue(qRound(d: initialVolume * 100)); |
| 231 | toggleMode(); |
| 232 | } |
| 233 | |
| 234 | void AudioTest::deviceChanged(int index) |
| 235 | { |
| 236 | m_generator->stop(); |
| 237 | m_audioOutput->stop(); |
| 238 | m_audioOutput->disconnect(receiver: this); |
| 239 | initializeAudio(deviceInfo: m_deviceBox->itemData(index).value<QAudioDeviceInfo>()); |
| 240 | } |
| 241 | |
| 242 | void AudioTest::volumeChanged(int value) |
| 243 | { |
| 244 | qreal linearVolume = QAudio::convertVolume(volume: value / qreal(100), |
| 245 | from: QAudio::LogarithmicVolumeScale, |
| 246 | to: QAudio::LinearVolumeScale); |
| 247 | |
| 248 | m_audioOutput->setVolume(linearVolume); |
| 249 | } |
| 250 | |
| 251 | void AudioTest::toggleMode() |
| 252 | { |
| 253 | m_pushTimer->stop(); |
| 254 | m_audioOutput->stop(); |
| 255 | toggleSuspendResume(); |
| 256 | |
| 257 | if (m_pullMode) { |
| 258 | //switch to pull mode (QAudioOutput pulls from Generator as needed) |
| 259 | m_modeButton->setText(tr(s: "Enable push mode" )); |
| 260 | m_audioOutput->start(device: m_generator.data()); |
| 261 | } else { |
| 262 | //switch to push mode (periodically push to QAudioOutput using a timer) |
| 263 | m_modeButton->setText(tr(s: "Enable pull mode" )); |
| 264 | auto io = m_audioOutput->start(); |
| 265 | m_pushTimer->disconnect(); |
| 266 | |
| 267 | connect(sender: m_pushTimer, signal: &QTimer::timeout, slot: [this, io]() { |
| 268 | if (m_audioOutput->state() == QAudio::StoppedState) |
| 269 | return; |
| 270 | |
| 271 | QByteArray buffer(32768, 0); |
| 272 | int chunks = m_audioOutput->bytesFree() / m_audioOutput->periodSize(); |
| 273 | while (chunks) { |
| 274 | const qint64 len = m_generator->read(data: buffer.data(), maxlen: m_audioOutput->periodSize()); |
| 275 | if (len) |
| 276 | io->write(data: buffer.data(), len); |
| 277 | if (len != m_audioOutput->periodSize()) |
| 278 | break; |
| 279 | --chunks; |
| 280 | } |
| 281 | }); |
| 282 | |
| 283 | m_pushTimer->start(msec: 20); |
| 284 | } |
| 285 | |
| 286 | m_pullMode = !m_pullMode; |
| 287 | } |
| 288 | |
| 289 | void AudioTest::toggleSuspendResume() |
| 290 | { |
| 291 | if (m_audioOutput->state() == QAudio::SuspendedState || m_audioOutput->state() == QAudio::StoppedState) { |
| 292 | m_audioOutput->resume(); |
| 293 | m_suspendResumeButton->setText(tr(s: "Suspend recording" )); |
| 294 | } else if (m_audioOutput->state() == QAudio::ActiveState) { |
| 295 | m_audioOutput->suspend(); |
| 296 | m_suspendResumeButton->setText(tr(s: "Resume playback" )); |
| 297 | } else if (m_audioOutput->state() == QAudio::IdleState) { |
| 298 | // no-op |
| 299 | } |
| 300 | } |
| 301 | |
| 302 | |