| 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 |  |