qaudiobufferinput.cpp

Go to the documentation of this file.

// Copyright (C) 2024 The Qt Company Ltd.
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR LGPL-3.0-only OR GPL-2.0-only OR GPL-3.0-only
 
#include "qaudiobufferinput.h"
#include "qplatformaudiobufferinput_p.h"
#include "qmediainputencoderinterface_p.h"
#include "qmediaframeinput_p.h"
 
QT_BEGIN_NAMESPACE
 
class QAudioBufferInputPrivate : public QMediaFrameInputPrivate
{
public:
    QAudioBufferInputPrivate(QAudioBufferInput *q) : q(q) { }
 
    bool sendAudioBuffer(const QAudioBuffer &audioBuffer)
    {
        return sendMediaFrame(
                [&]() { emit m_platfromAudioBufferInput->newAudioBuffer(audioBuffer); });
    }
 
    void initialize(const QAudioFormat &format = {})
    {
        m_platfromAudioBufferInput = std::make_unique<QPlatformAudioBufferInput>(format);
        addUpdateSignal(m_platfromAudioBufferInput.get(),
                        &QPlatformAudioBufferInput::encoderUpdated);
    }
 
    void uninitialize()
    {
        m_platfromAudioBufferInput.reset();
 
        if (captureSession())
            captureSession()->setAudioBufferInput(nullptr);
    }
 
    QMediaCaptureSession *session() const { return m_captureSession; }
 
    QPlatformAudioBufferInput *platfromAudioBufferInput() const
    {
        return m_platfromAudioBufferInput.get();
    }
 
private:
    void updateCaptureSessionConnections(QMediaCaptureSession *prevSession,
                                         QMediaCaptureSession *newSession) override
    {
        if (prevSession)
            removeUpdateSignal(prevSession, &QMediaCaptureSession::audioOutputChanged);
 
        if (newSession)
            addUpdateSignal(newSession, &QMediaCaptureSession::audioOutputChanged);
    }
 
    bool checkIfCanSendMediaFrame() const override
    {
        if (auto encoderInterface = m_platfromAudioBufferInput->encoderInterface())
            return encoderInterface->canPushFrame();
 
        // Not implemented yet
        // return captureSession()->audioOutput() != nullptr;
        return false;
    }
 
    void emitReadyToSendMediaFrame() override { emit q->readyToSendAudioBuffer(); }
 
private:
    QAudioBufferInput *q = nullptr;
    QMediaCaptureSession *m_captureSession = nullptr;
    std::unique_ptr<QPlatformAudioBufferInput> m_platfromAudioBufferInput;
};
 
QAudioBufferInput::QAudioBufferInput(QObject *parent) : QAudioBufferInput({}, parent) { }
 
QAudioBufferInput::QAudioBufferInput(const QAudioFormat &format, QObject *parent)
    : QObject(*new QAudioBufferInputPrivate(this), parent)
{
    Q_D(QAudioBufferInput);
    d->initialize(format);
}
 
QAudioBufferInput::~QAudioBufferInput()
{
    Q_D(QAudioBufferInput);
    d->uninitialize();
}
 
bool QAudioBufferInput::sendAudioBuffer(const QAudioBuffer &audioBuffer)
{
    Q_D(QAudioBufferInput);
    return d->sendAudioBuffer(audioBuffer);
}
 
QAudioFormat QAudioBufferInput::format() const
{
    Q_D(const QAudioBufferInput);
    return d->platfromAudioBufferInput()->audioFormat();
}
 
QMediaCaptureSession *QAudioBufferInput::captureSession() const
{
    Q_D(const QAudioBufferInput);
    return d->captureSession();
}
 
void QAudioBufferInput::setCaptureSession(QMediaCaptureSession *captureSession)
{
    Q_D(QAudioBufferInput);
    d->setCaptureSession(captureSession);
}
 
QPlatformAudioBufferInput *QAudioBufferInput::platformAudioBufferInput() const
{
    Q_D(const QAudioBufferInput);
    return d->platfromAudioBufferInput();
}
 
QT_END_NAMESPACE