Revision control
Copy as Markdown
// 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 "recordingengine/qffmpegrecordingengineutils_p.h"
#include "recordingengine/qffmpegencoderthread_p.h"
#include "private/qplatformaudiobufferinput_p.h"
#include "private/qplatformvideoframeinput_p.h"
QT_BEGIN_NAMESPACE
namespace QFFmpeg {
template <typename F>
static void doWithMediaFrameInput(QObject *source, F &&f)
{
if (auto videoFrameInput = qobject_cast<QPlatformVideoFrameInput *>(source))
f(videoFrameInput);
else if (auto audioBufferInput = qobject_cast<QPlatformAudioBufferInput *>(source))
f(audioBufferInput);
}
void setEncoderInterface(QObject *source, QMediaInputEncoderInterface *encoderInterface)
{
doWithMediaFrameInput(source, [&](auto source) {
using Source = std::remove_pointer_t<decltype(source)>;
source->setEncoderInterface(encoderInterface);
if (encoderInterface)
// Postpone emit 'encoderUpdated' as the encoding pipeline may be not
// completely ready at the moment. The case is calling QMediaRecorder::stop
// upon handling 'readyToSendFrame'
QMetaObject::invokeMethod(source, &Source::encoderUpdated, Qt::QueuedConnection);
else
Q_EMIT source->encoderUpdated();
});
}
void setEncoderUpdateConnection(QObject *source, EncoderThread *encoder)
{
doWithMediaFrameInput(source, [&](auto source) {
using Source = std::remove_pointer_t<decltype(source)>;
QObject::connect(encoder, &EncoderThread::canPushFrameChanged, source,
&Source::encoderUpdated);
});
}
void disconnectEncoderFromSource(EncoderThread *encoder)
{
QObject *source = encoder->source();
if (!source)
return;
// We should address the dependency AudioEncoder from QFFmpegAudioInput to
// set null source here.
// encoder->setSource(nullptr);
QObject::disconnect(source, nullptr, encoder, nullptr);
setEncoderInterface(source, nullptr);
}
} // namespace QFFmpeg
QT_END_NAMESPACE